feat: add task projection table

Author: Pyiner

garyx-gateway/src/composition/app_bootstrap.rs

@@ -43,6 +43,7 @@ use crate::mcp_metrics::McpToolMetrics;
 use crate::recent_thread_projection::RecentThreadProjectingStore;
 use crate::runtime_cells::{ChannelDispatcherCell, LiveConfigCell};
 use crate::skills::SkillsService;
+use crate::task_projection::register_gateway_task_projection_reader;
 use crate::wikis::WikiStore;
 use crate::workflows::WorkflowScheduler;
 
@@ -311,6 +312,7 @@ impl AppStateBuilder {
             self.garyx_db.clone(),
             self.thread_history.transcript_store(),
         ));
+        register_gateway_task_projection_reader(&thread_store, &self.garyx_db);
         let thread_history = ThreadHistoryRepository::new(
             thread_store.clone(),
             self.thread_history.transcript_store(),

garyx-gateway/src/composition/app_state.rs

@@ -34,6 +34,7 @@ use crate::recent_thread_projection::{
 };
 use crate::runtime_cells::{ChannelDispatcherCell, LiveConfigCell};
 use crate::skills::SkillsService;
+use crate::task_projection::{backfill_task_projection_if_incomplete, reconcile_task_projection};
 use crate::thread_meta_projection::{
     backfill_thread_meta_projection_if_incomplete, list_channel_endpoints_with_projection_backfill,
 };
@@ -291,6 +292,13 @@ impl AppState {
                 &state.ops.garyx_db,
             )
             .await;
+            let task_projection = backfill_task_projection_if_incomplete(
+                &state.threads.thread_store,
+                &state.ops.garyx_db,
+            )
+            .await;
+            let reconciled_task_projection =
+                reconcile_task_projection(&state.threads.thread_store, &state.ops.garyx_db).await;
             let reconciled_workflows = crate::workflows::reconcile_interrupted_workflows(
                 &state,
                 &workflow_reconcile_cutoff,
@@ -310,6 +318,8 @@ impl AppState {
                 thread_meta_projection_message_routes = thread_meta_projection.message_routes,
                 thread_meta_projection_delivery_contexts =
                     thread_meta_projection.last_delivery_contexts,
+                task_projection_backfill_count = task_projection,
+                task_projection_reconcile_count = reconciled_task_projection,
                 workflow_reconcile_count = reconciled_workflows,
                 "gateway sync snapshots warmed"
             );