Add application files

app.py

@@ -50,9 +50,9 @@ async def initialize_system():
     """Initialize MCP connections and vector store"""
     try:
         await mcp_registry.connect()
-        return "System initialized successfully"
+        print("✅ System initialized successfully")
     except Exception as e:
-        return f"System initialization error: {str(e)}"
+        print(f"⚠️ System initialization error: {str(e)}")
 
 
 async def run_pipeline_gradio(company_names_input: str) -> AsyncGenerator[tuple, None]:

database/schema.sql

@@ -183,7 +183,7 @@ CREATE TABLE IF NOT EXISTS email_activities (
     subject TEXT,
     preview TEXT,
     link_url TEXT, -- For click tracking
-    metadata TEXT, -- JSON for additional data
+    meta_data TEXT, -- JSON for additional data
     occurred_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
 
     FOREIGN KEY (contact_id) REFERENCES contacts(id) ON DELETE CASCADE,
@@ -234,7 +234,7 @@ CREATE TABLE IF NOT EXISTS activities (
     meeting_id INTEGER,
     type TEXT NOT NULL, -- discovery, enrichment, email_sent, email_opened, reply_received, meeting_scheduled, meeting_completed, note_added, status_changed
     description TEXT,
-    metadata TEXT, -- JSON for additional context
+    meta_data TEXT, -- JSON for additional context
     performed_by TEXT, -- agent_name or 'user'
     occurred_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
 

models/database.py

@@ -284,7 +284,7 @@ class EmailActivity(Base):
     subject = Column(String)
     preview = Column(Text)
     link_url = Column(String)
-    metadata = Column(Text)  # JSON
+    meta_data = Column(Text)  # JSON
     occurred_at = Column(DateTime, default=datetime.utcnow)
 
     # Relationships
@@ -340,7 +340,7 @@ class Activity(Base):
     meeting_id = Column(Integer, ForeignKey('meetings.id', ondelete='SET NULL'))
     type = Column(String, nullable=False)
     description = Column(Text)
-    metadata = Column(Text)  # JSON
+    meta_data = Column(Text)  # JSON
     performed_by = Column(String)
     occurred_at = Column(DateTime, default=datetime.utcnow)