feat: built frontend and achieved arcitecture 100% 🎉

.mcp.json

@@ -3,6 +3,13 @@
     "codebase-memory-mcp": {
       "command": "codebase-memory-mcp",
       "args": []
+    },
+    "puppeteer": {
+      "command": "npx",
+      "args": [
+        "-y",
+        "@modelcontextprotocol/server-puppeteer@2025.5.12"
+      ]
     }
   }
 }

apps/api/mcp/bootstrap.ts

@@ -1,14 +1,17 @@
 import { PluginRegistry } from "./registry.js";
 import { ToolsDiscovery } from "./discovery.js";
 import { ToolExecutor } from "./execute.js";
+import { fileURLToPath } from "url";
 import { fileManagerPlugin } from "./plugins/filemanager/manifest.js";
 import { context7Plugin } from "./plugins/context7/manifest.js";
+import { puppeteerPlugin } from "./plugins/puppeteer/manifest.js";
 
 export const mcpRegistry = new PluginRegistry();
 
 // Register plugins from modular layout manifests
 mcpRegistry.registerPlugin(fileManagerPlugin);
 mcpRegistry.registerPlugin(context7Plugin);
+mcpRegistry.registerPlugin(puppeteerPlugin);
 
 export const mcpDiscovery = new ToolsDiscovery(mcpRegistry);
 export const mcpExecutor = new ToolExecutor(mcpDiscovery);

apps/api/mcp/plugins/context7/manifest.ts

@@ -1,4 +1,4 @@
-import "../../../../src/utils/env.js";
+import "../../../src/utils/env.js";
 import { StdioMCPServer } from "../../stdio-server.js";
 
 const context7Env: Record<string, string> = {};

apps/api/mcp/plugins/puppeteer/manifest.ts

@@ -0,0 +1,9 @@
+import "../../../src/utils/env.js";
+import { StdioMCPServer } from "../../stdio-server.js";
+
+export const puppeteerPlugin = new StdioMCPServer(
+  "puppeteer",
+  "npx",
+  ["-y", "@modelcontextprotocol/server-puppeteer"],
+  {}
+);

apps/api/package.json

@@ -14,6 +14,7 @@
   },
   "dependencies": {
     "@modelcontextprotocol/sdk": "^1.4.0",
+    "@modelcontextprotocol/server-puppeteer": "^2025.5.12",
     "@repo/db": "*",
     "@repo/shared": "*",
     "cors": "^2.8.5",

apps/api/src/agent/agent.test.ts

@@ -1,7 +1,7 @@
 import { vi, describe, it, expect, beforeEach, afterEach } from "vitest";
 import { runAgent } from "./loop.js";
 import { createMemory } from "./memory.js";
-import { llmClient } from "./llm.js";
+import { llmClient, nextStep } from "./llm.js";
 
 // Mock @repo/db
 vi.mock("@repo/db", () => {
@@ -425,6 +425,91 @@ describe("Agent Module & Execution Loop", () => {
     expect(result.reason).toBe("Approval not approved");
   });
 
+  // 14) Parallel Tool Execution tests
+  describe("Parallel Tool Execution", () => {
+    it("should parse type: tool_calls from LLM and validate schemas", async () => {
+      vi.spyOn(llmClient, "callModel").mockResolvedValue(
+        JSON.stringify({
+          type: "tool_calls",
+          tool_calls: [
+            { tool_name: "test_tool", arguments: { arg1: "val1" } },
+            { tool_name: "test_tool", arguments: { arg1: "val2" } }
+          ]
+        })
+      );
+
+      const memory = createMemory();
+      const tools = [
+        {
+          name: "test_tool",
+          description: "A test tool",
+          inputSchema: { type: "object", properties: { arg1: { type: "string" } } },
+          execute: vi.fn(),
+        }
+      ];
+
+      const res = await nextStep(memory, tools);
+      expect(res.step.type).toBe("tool_calls");
+      if (res.step.type === "tool_calls") {
+        expect(res.step.tool_calls).toHaveLength(2);
+        expect(res.step.tool_calls[0]?.tool_name).toBe("test_tool");
+      }
+    });
+
+    it("should execute parallel tool calls successfully when allowed", async () => {
+      let callCount = 0;
+      vi.spyOn(llmClient, "callModel").mockImplementation(async () => {
+        callCount++;
+        if (callCount === 1) {
+          return JSON.stringify({
+            type: "tool_calls",
+            tool_calls: [
+              { tool_name: "test_tool", arguments: { arg1: "val1" } },
+              { tool_name: "test_tool", arguments: { arg1: "val2" } }
+            ]
+          });
+        }
+        return JSON.stringify({
+          type: "final_answer",
+          answer: "Finished parallel work.",
+        });
+      });
+
+      vi.mocked(decide).mockResolvedValue({
+        decision: "ALLOW",
+      });
+
+      vi.mocked(mcpExecutor.execute).mockResolvedValue("mockResult");
+
+      const result = await runAgent("Do parallel tasks", "conv-parallel-1");
+      expect(result.status).toBe("SUCCESS");
+      expect(result.answer).toBe("Finished parallel work.");
+      expect(mcpExecutor.execute).toHaveBeenCalledTimes(2);
+      expect(result.memory.toolResults).toContain("mockResult");
+    });
+
+    it("should request approval for parallel tool calls when pending", async () => {
+      vi.spyOn(llmClient, "callModel").mockResolvedValue(
+        JSON.stringify({
+          type: "tool_calls",
+          tool_calls: [
+            { tool_name: "test_tool", arguments: { arg1: "val1" } }
+          ]
+        })
+      );
+
+      vi.mocked(decide).mockResolvedValue({
+        decision: "PENDING",
+        reason: "approval-parallel-123",
+      });
+
+      const result = await runAgent("Do parallel task requiring approval", "conv-parallel-2");
+      expect(result.status).toBe("PENDING");
+      expect(result.approvalId).toBe("approval-parallel-123");
+      expect(result.memory.approvalId).toBe("approval-parallel-123");
+    });
+  });
+
   describe("Gemini API Client Timeout", () => {
     afterEach(() => {
       vi.unstubAllGlobals();