1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187
use std::collections::HashMap;
use std::sync::Arc;
use actix_web::http::header::HeaderValue;
use actix_web::HttpRequest;
use actix_web::web::Data;
use chrono::Utc;
use crate::constant;
use crate::squire;
lazy_static::lazy_static! {
static ref SESSION_MAPPING: std::sync::Mutex<HashMap<String, String>> = std::sync::Mutex::new(HashMap::new());
}
/// Represents user credentials extracted from an authorization header.
///
/// Contains the username, signature, and timestamp obtained by decoding and parsing the authorization header.
struct Credentials {
username: String,
signature: String,
timestamp: String,
}
/// Represents the result of authentication, indicating whether it was successful or not.
///
/// If successful, it includes the username and a generated key for the session.
pub struct AuthToken {
pub ok: bool,
pub detail: String,
pub username: String,
}
/// Extracts credentials from the authorization header in the following steps
///
/// # Arguments
///
/// * `authorization` - An optional `HeaderValue` containing the authorization header.
///
/// # See Also
/// - Decodes the base64 encoded header
/// - Splits it into 3 parts with first one being the username followed by the signature and timestamp
/// - Converts the username from hex into a string.
///
/// # Returns
///
/// Returns a `Result` containing the extracted `Credentials` or an error message if extraction fails.
fn extract_credentials(authorization: Option<&HeaderValue>) -> Result<Credentials, &'static str> {
let header = authorization.unwrap().to_str().unwrap().to_string();
// base64 encoded in JavaScript using inbuilt btoa function
let b64_decode_response = squire::secure::base64_decode(&header);
return match b64_decode_response {
Ok(decoded_auth) => {
if decoded_auth.is_empty() {
log::warn!("Authorization header was received without a value");
return Err("No credentials received");
}
let vector: Vec<&str> = decoded_auth.split(',').collect();
Ok(Credentials {
// Decode hex username into string to retrieve password from config file
username: squire::secure::hex_decode(vector.first().unwrap()),
signature: vector.get(1).unwrap().to_string(),
timestamp: vector.get(2).unwrap().to_string(),
})
}
Err(err) => {
Err(err)
}
};
}
/// Verifies user login based on extracted credentials and configuration settings.
///
/// # Arguments
///
/// * `request` - The HTTP request containing the authorization header.
/// * `config` - The configuration settings containing user credentials and session duration.
///
/// # Returns
///
/// Returns a `Result` containing a `HashMap` with session information if authentication is successful,
/// otherwise returns an error message.
pub fn verify_login(
request: &HttpRequest,
config: &Data<Arc<squire::settings::Config>>,
) -> Result<HashMap<&'static str, String>, String> {
let authorization = request.headers().get("authorization");
let err_response;
if authorization.is_some() {
let extracted_credentials = extract_credentials(authorization);
match extracted_credentials {
Ok(credentials) => {
let password = config.authorization.get(&credentials.username);
if password.is_some() { // Check if the username is present in HashMap as key
let message = format!("{}{}{}",
squire::secure::hex_encode(&credentials.username),
squire::secure::hex_encode(password.unwrap()),
credentials.timestamp);
// Create a new signature with hex encoded username and password stored in config file as plain text
let expected_signature = squire::secure::calculate_hash(message);
if expected_signature == credentials.signature {
let key = squire::secure::keygen();
SESSION_MAPPING.lock().unwrap().insert(credentials.username.to_string(), key.to_string());
let mut mapped = HashMap::new();
mapped.insert("username", credentials.username.to_string());
mapped.insert("key", key.to_string());
mapped.insert("timestamp", credentials.timestamp.to_string());
return Ok(mapped);
} else {
log::warn!("{} entered bad credentials", credentials.username);
err_response = "Incorrect username or password";
}
} else {
log::warn!("{} is not allowed", credentials.username);
err_response = "Incorrect username or password";
}
}
Err(err) => {
err_response = err;
}
}
} else {
log::warn!("Authorization header was missing");
err_response = "No credentials received";
}
Err(err_response.to_string())
}
/// Verifies a session token extracted from an HTTP request against stored session mappings and configuration.
///
/// # Arguments
///
/// * `request` - The HTTP request containing the session token in the form of a cookie.
/// * `config` - The configuration settings containing session duration.
///
/// # Returns
///
/// Returns an `AuthToken` indicating the result of the token verification.
pub fn verify_token(request: &HttpRequest, config: &Data<Arc<squire::settings::Config>>) -> AuthToken {
if SESSION_MAPPING.lock().unwrap().is_empty() {
log::warn!("No stored sessions, no point in validating further");
return AuthToken {
ok: false,
detail: "Server doesn't recognize your session".to_string(),
username: "NA".to_string(),
};
}
if let Some(cookie) = request.cookie("session_token") {
if let Ok(decrypted) = constant::FERNET.decrypt(cookie.value()) {
let payload: HashMap<String, String> = serde_json::from_str(&String::from_utf8_lossy(&decrypted)).unwrap();
let username = payload.get("username").unwrap().to_string();
let cookie_key = payload.get("key").unwrap().to_string();
let timestamp = payload.get("timestamp").unwrap().parse::<i64>().unwrap();
let stored_key = SESSION_MAPPING.lock().unwrap().get(&username).unwrap().to_string();
let current_time = Utc::now().timestamp();
// Max time and expiry for session token is set in the Cookie, but this is a fallback mechanism
if stored_key != *cookie_key {
return AuthToken {
ok: false,
detail: "Invalid session token".to_string(),
username,
};
}
if current_time - timestamp > config.session_duration as i64 {
return AuthToken { ok: false, detail: "Session Expired".to_string(), username };
}
AuthToken {
ok: true,
detail: format!("Session valid for {}s", timestamp + config.session_duration as i64 - current_time),
username,
}
} else {
AuthToken {
ok: false,
detail: "Invalid session token".to_string(),
username: "NA".to_string(),
}
}
} else {
AuthToken {
ok: false,
detail: "Session information not found".to_string(),
username: "NA".to_string(),
}
}
}