feat: add sync worker to process database queue items and trigger automated FAISS index updates

src/similarity_model/sync_worker.py

@@ -174,13 +174,42 @@ def process_single_item(engine, item) -> bool:
 def run_worker():
     logger.info("Initializing Sync Worker service...")
     
-    # Verify DB connection
+    # Verify DB connection and auto-initialize schema/triggers if missing
     try:
-        with engine.connect() as conn:
-            conn.execute(text("SELECT 1"))
-        logger.info("Database connection verified successfully.")
+        with engine.begin() as conn:
+            # 1. Check and create SyncQueue table
+            row = conn.execute(text("SELECT OBJECT_ID('SyncQueue', 'U')")).fetchone()
+            if row[0] is None:
+                logger.info("SyncQueue table does not exist. Initializing from DDL script...")
+                ddl_path = Path(__file__).resolve().parents[2] / "Data" / "database" / "create_sync_queue.sql"
+                if ddl_path.exists():
+                    sql = ddl_path.read_text(encoding="utf-8")
+                    conn.execute(text(sql))
+                    logger.info("SyncQueue table and indexes created successfully.")
+                else:
+                    logger.error("DDL script 'create_sync_queue.sql' not found!")
+            
+            # 2. Check and deploy SQL triggers
+            row_trg = conn.execute(text("SELECT OBJECT_ID('trg_Projects_Insert', 'TR')")).fetchone()
+            if row_trg[0] is None:
+                logger.info("SQL Triggers do not exist on 'Projects'. Deploying triggers...")
+                triggers_path = Path(__file__).resolve().parents[2] / "Data" / "database" / "create_triggers.sql"
+                if triggers_path.exists():
+                    sql_content = triggers_path.read_text(encoding="utf-8")
+                    import re
+                    # Split by SQL Server GO batch separator and execute statements individually
+                    statements = re.split(r'(?i)\bGO\b', sql_content)
+                    for stmt in statements:
+                        stmt_clean = stmt.strip()
+                        if stmt_clean:
+                            conn.execute(text(stmt_clean))
+                    logger.info("SQL Triggers deployed successfully.")
+                else:
+                    logger.error("Trigger script 'create_triggers.sql' not found!")
+                    
+        logger.info("Database connection verified and schema initialized successfully.")
     except Exception as exc:
-        logger.critical(f"Database connection failed: {exc}")
+        logger.critical(f"Database connection or schema initialization failed: {exc}")
         sys.exit(1)
         
     rebuild_manager = RebuildManager()