feat: fixups and auth

Author: drew-harris

server/src/handlers/webhook_handler.rs

@@ -21,7 +21,7 @@ struct WebhookRespose {
     message: String,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize)]
 #[serde(rename_all = "camelCase")]
 pub enum Operation {
     Publish,
@@ -32,7 +32,7 @@ pub enum Operation {
     ScheduledEnd,
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize)]
 #[serde(rename_all = "camelCase")]
 pub struct ContentValue {
     id: String,
@@ -84,7 +84,7 @@ impl From<ContentValue> for ChunkReqPayload {
     }
 }
 
-#[derive(Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize)]
 #[serde(rename_all = "camelCase")]
 pub struct WebhookRequest {
     model_name: String,
@@ -94,7 +94,7 @@ pub struct WebhookRequest {
     operation: Operation,
 }
 
-#[derive(Deserialize, Debug)]
+#[derive(Deserialize)]
 #[serde(rename_all = "camelCase")]
 pub struct WebhookQueryParams {
     trieve_key: String,

server/src/operators/webhook_operator.rs

@@ -71,10 +71,10 @@ pub async fn publish_content<T: Into<ChunkReqPayload>>(
         ServiceError::BadRequest("Failed to Serialize BulkUploadMessage".to_string())
     })?;
 
-    let _ = redis::cmd("lpush")
+    redis::cmd("lpush")
         .arg("ingestion")
         .arg(&serialized_message)
-        .query_async(&mut *redis_conn)
+        .query_async::<redis::aio::MultiplexedConnection, usize>(&mut *redis_conn)
         .await
         .map_err(|err| ServiceError::BadRequest(err.to_string()))?;