Added Ability to put constant SessionKey

src/app/app.rs

@@ -21,13 +21,20 @@ pub struct AppContext {
 impl AppContext {
     pub async fn new(settings_reader: SettingsReader) -> Self {
         let connection_settings = settings_reader.get_connections_settings().await;
+
+        let token_secret_key = if let Some(session_key) = settings_reader.get_session_key().await {
+            AesKey::new(get_token_secret_key_from_settings(session_key.as_bytes()).as_slice())
+        } else {
+            AesKey::new(generate_random_token_secret_key().as_slice())
+        };
+
         Self {
             settings_reader,
             http_connections: AtomicIsize::new(0),
             id: AtomicI64::new(0),
             connection_settings,
             saved_client_certs: SavedClientCert::new(),
-            token_secret_key: AesKey::new(generate_token_secret_key().as_slice()),
+            token_secret_key,
             client_certificates: ClientCertificatesCache::new(),
         }
     }
@@ -37,7 +44,7 @@ impl AppContext {
     }
 }
 
-fn generate_token_secret_key() -> Vec<u8> {
+fn generate_random_token_secret_key() -> Vec<u8> {
     let mut result = Vec::with_capacity(48);
 
     let mut key = vec![];
@@ -52,3 +59,19 @@ fn generate_token_secret_key() -> Vec<u8> {
 
     result
 }
+
+fn get_token_secret_key_from_settings(session_key: &[u8]) -> Vec<u8> {
+    let mut result = Vec::with_capacity(48);
+
+    let mut key = vec![];
+
+    while result.len() < 48 {
+        if key.len() == 0 {
+            key = session_key.to_vec();
+        }
+
+        result.push(key.pop().unwrap());
+    }
+
+    result
+}

src/settings/connections_settings.rs

@@ -10,6 +10,7 @@ const DEFAULT_CONNECT_TO_REMOTE_TIMEOUT: Duration = Duration::from_secs(5);
 pub struct ConnectionsSettings {
     pub buffer_size: Option<String>,
     pub connect_to_remote_timeout: Option<String>,
+    pub session_key: Option<String>,
 }
 
 impl ConnectionsSettings {

src/settings/settings.rs

@@ -55,6 +55,18 @@ impl SettingsReader {
         result
     }
 
+    pub async fn get_session_key(&self) -> Option<String> {
+        let read_access = self.settings.read().await;
+
+        if let Some(global_settings) = read_access.global_settings.as_ref() {
+            if let Some(connection_settings) = global_settings.connection_settings.as_ref() {
+                return connection_settings.session_key.clone();
+            }
+        }
+
+        None
+    }
+
     pub async fn get_http_endpoint_modify_headers_settings(
         &self,
         endpoint_info: &HttpServerConnectionInfo,