fix: connection key not working (#312)

Author: sagoez

api/src/logic/mod.rs

@@ -336,7 +336,11 @@ async fn get_connection(
 ) -> Result<Arc<Connection>, PicaError> {
     let connection = cache
         .get_or_insert_with_filter(
-            &(access.ownership.id.clone(), connection_key.clone()),
+            &(access.ownership.id.clone().to_string()
+                + connection_key.clone().to_str().map_err(|e| {
+                    tracing::error!("Error converting connection key to string: {e}");
+                    ApplicationError::bad_request("Invalid connection key header", None)
+                })?),
             stores.connection.clone(),
             doc! {
                 "key": connection_key.to_str().map_err(|_| {

cache/src/local.rs

@@ -141,7 +141,7 @@ where
 }
 
 type ConnectionModelSchemaKey = (Arc<str>, Arc<str>);
-type ConnectionHeaderKey = (Arc<str>, HeaderValue);
+// type ConnectionHeaderKey = (Arc<str>, HeaderValue);
 type ConnectionKey = Arc<str>;
 
 pub type EventAccessCache = GenericCache<HeaderValue, EventAccess>;
@@ -152,6 +152,6 @@ pub type ConnectionModelDefinitionDestinationCache =
     GenericCache<Destination, ConnectionModelDefinition>;
 pub type ConnectionModelDefinitionCacheIdKey = GenericCache<Id, ConnectionModelDefinition>;
 pub type ConnectionDefinitionCache = GenericCache<Id, ConnectionDefinition>;
-pub type ConnectionHeaderCache = GenericCache<ConnectionHeaderKey, Connection>;
+pub type ConnectionHeaderCache = GenericCache<String, Connection>;
 pub type ConnectionCache = GenericCache<ConnectionKey, Connection>;
 pub type ConnectionModelDefinitionCacheStringKey = GenericCache<String, Option<SparseCMD>>;