Removed Local AI and added MCP tools

ai/core/AIService.js

@@ -38,17 +38,12 @@ class AIService {
 
     try {
       log.info('Initializing AI Service...');
-      // Dynamic require of index.js bootstrap to initialize the agent
       const { initializeAISystem } = require('../index.js');
       const result = await initializeAISystem(appDataDir, workspaceRoot, llmProvider, embeddingConfig);
       const { getAIAgent } = require('../index.js');
       this.agent = getAIAgent();
 
-      const AIFlow = require('./AIFlow');
-      this.aiFlow = new AIFlow(this.agent);
-      this.agent.aiFlow = this.aiFlow;
-
-      log.info('AI Service & AIFlow Orchestrator successfully initialized');
+      log.info('AI Service successfully initialized (embeddings + graph ready)');
       return result;
     } catch (error) {
       log.error('Failed to initialize AI Service:', error.message);
@@ -120,14 +115,12 @@ class AIService {
     const { shutdownAISystem } = require('../index.js');
     shutdownAISystem();
     this.agent = null;
-    this.aiFlow = null;
   }
 
   shutdown() {
     const { shutdownAISystem } = require('../index.js');
     shutdownAISystem();
     this.agent = null;
-    this.aiFlow = null;
     log.info('AI Service shut down');
   }
 
@@ -227,78 +220,6 @@ class AIService {
     }
   }
 
-  async chat(message, context = {}) {
-    if (!this.enabled || !this.agent) {
-      throw new Error('AI is currently disabled or uninitialized.');
-    }
-    if (!this.aiFlow) {
-      const AIFlow = require('./AIFlow');
-      this.aiFlow = new AIFlow(this.agent);
-      this.agent.aiFlow = this.aiFlow;
-    }
-    return this.aiFlow.execute(message, context);
-  }
-
-  /**
-   * Main chat query streaming wrapper
-   */
-  async stream(message, context = {}, onChunk, abortSignal) {
-    if (!this.enabled || !this.agent) {
-      throw new Error('AI is currently disabled or uninitialized.');
-    }
-    if (!this.aiFlow) {
-      const AIFlow = require('./AIFlow');
-      this.aiFlow = new AIFlow(this.agent);
-      this.agent.aiFlow = this.aiFlow;
-    }
-    return this.aiFlow.stream(message, context, onChunk, abortSignal);
-  }
-
-  // --- Facade API Methods for Subsystem Modules ---
-
-  getGraphStatus() {
-    return this.agent?.graphDb ? this.agent.graphDb.getStatus() : null;
-  }
-
-  getGraphData() {
-    return this.agent?.graphDb ? this.agent.graphDb.getAll() : null;
-  }
-
-  clearGraphData() {
-    if (this.agent?.graphDb) {
-      this.agent.graphDb.clearAllData();
-    }
-  }
-
-  async buildGraph(onProgress) {
-    return this.agent ? this.agent.buildRelationshipGraph(onProgress) : { success: false, error: 'Agent not initialized' };
-  }
-
-  getEmbeddingStats() {
-    return this.agent?.embeddingDb ? this.agent.embeddingDb.getStats() : null;
-  }
-
-  clearEmbeddingData() {
-    if (this.agent?.embeddingDb) {
-      this.agent.embeddingDb.clearAllData();
-    }
-  }
-
-  async generateEmbeddings(forceRefresh = false) {
-    return this.agent ? this.agent.generateEmbeddings(forceRefresh) : { success: false, error: 'Agent not initialized' };
-  }
-
-  detectPatterns() {
-    return this.agent ? this.agent.detectPatterns() : { success: false, error: 'Agent not initialized' };
-  }
-
-  getConversationStore() {
-    return this.agent?.conversationStore || null;
-  }
-
-  getPersonaManager() {
-    return this.agent?.personaManager || null;
-  }
 }
 
 const aiServiceInstance = new AIService();

ai/core/Agent.js

@@ -117,39 +117,9 @@ class Agent {
     }
   }
 
-  /**
-   * Process a query via AIFlow orchestrator
-   */
-  async query(userQuery, context = {}) {
-    if (!this.isInitialized) {
-      throw new Error('Agent not initialized');
-    }
 
-    if (this.aiFlow) {
-      return this.aiFlow.execute(userQuery, context);
-    }
+  // query() and stream() removed — chat moved to MCP layer
 
-    const AIFlow = require('./AIFlow');
-    this.aiFlow = new AIFlow(this);
-    return this.aiFlow.execute(userQuery, context);
-  }
-
-  /**
-   * Process a query with streaming output via AIFlow orchestrator
-   */
-  async stream(userQuery, context = {}, onChunk, abortSignal) {
-    if (!this.isInitialized) {
-      throw new Error('Agent not initialized');
-    }
-
-    if (this.aiFlow) {
-      return this.aiFlow.stream(userQuery, context, onChunk, abortSignal);
-    }
-
-    const AIFlow = require('./AIFlow');
-    this.aiFlow = new AIFlow(this);
-    return this.aiFlow.stream(userQuery, context, onChunk, abortSignal);
-  }
 
   /**
    * Generate embeddings for workspace