remove tail worker (#16)

Author: vahidlazio

confidence-cloudflare-resolver/src/lib.rs

@@ -207,14 +207,22 @@ pub async fn main(req: Request, env: Env, _ctx: Context) -> Result<Response> {
         .run(req, env)
         .await;
 
-    let aggregated = FLAG_LOGGER.pop_flag_log_batch();
-    if !(aggregated.flag_assigned.is_empty()
-        && aggregated.flag_resolve_info.is_empty()
-        && aggregated.client_resolve_info.is_empty())
-    {
-        let converted = serde_json::to_string(&aggregated)?;
-        console_log!("FLAGS_LOGS_QUEUE:{}", converted);
-    }
+    wasm_bindgen_futures::spawn_local(async move {
+        let aggregated = FLAG_LOGGER.pop_flag_log_batch();
+        if !(aggregated.flag_assigned.is_empty()
+            && aggregated.flag_resolve_info.is_empty()
+            && aggregated.client_resolve_info.is_empty())
+        {
+            if let Ok(converted) = serde_json::to_string(&aggregated) {
+                FLAGS_LOGS_QUEUE
+                    .get()
+                    .unwrap()
+                    .send(converted)
+                    .await
+                    .unwrap();
+            }
+        }
+    });
 
     response
 }

confidence-cloudflare-resolver/tail/src/index.js

@@ -1,7 +1,6 @@
 name = "confidence-cloudflare-resolver"
 main = "build/worker/shim.mjs"
 compatibility_date = "2025-01-28"
-tail_consumers = [{service = "confidence-resolver-tail"}]
 
 [observability]
 enabled = true
@@ -11,6 +10,10 @@ queue = "flag-logs-queue"
 max_batch_size = 100 # max number of messages in a batch
 max_batch_timeout = 10 # seconds
 
+[[queues.producers]]
+queue = "flag-logs-queue"
+binding = "flag_logs_queue"
+
 [vars]
 CONFIDENCE_CLIENT_ID = "ID"
 CONFIDENCE_CLIENT_SECRET = "SECRET"