daydreamsai · ponderingdemocritus · Feb 1, 2025 · Jan 31, 2025 · Jan 31, 2025 · Jan 31, 2025
diff --git a/examples/example-api.ts b/examples/example-api.ts
@@ -9,7 +9,7 @@
 
 import { Orchestrator } from "../packages/core/src/core/orchestrator";
 import { HandlerRole } from "../packages/core/src/core/types";
-import { RoomManager } from "../packages/core/src/core/room-manager";
+import { ConversationManager } from "../packages/core/src/core/conversation-manager";
 import { ChromaVectorDB } from "../packages/core/src/core/vector-db";
 import { MessageProcessor } from "../packages/core/src/core/processors/message-processor";
 import { ResearchQuantProcessor } from "../packages/core/src/core/processors/research-processor";
@@ -22,6 +22,7 @@ import { z } from "zod";
 import readline from "readline";
 import { MongoDb } from "../packages/core/src/core/db/mongo-db";
 import { MasterProcessor } from "../packages/core/src/core/processors/master-processor";
+import { makeFlowLifecycle } from "../packages/core/src/core/life-cycle";
 
 async function main() {
     const loglevel = LogLevel.DEBUG;
@@ -33,7 +34,7 @@ async function main() {
 
     await vectorDb.purge(); // Clear previous session data
 
-    const roomManager = new RoomManager(vectorDb);
+    const conversationManager = new ConversationManager(vectorDb);
 
     // Research client
     const researchClient = new LLMClient({
@@ -52,22 +53,16 @@ async function main() {
         loglevel
     );
 
-    // Initialize processor with default character personality
-    const messageProcessor = new MessageProcessor(
-        llmClient,
-        defaultCharacter,
-        loglevel
-    );
-
-    const researchProcessor = new ResearchQuantProcessor(
-        researchClient,
-        defaultCharacter,
-        loglevel,
-        1000 // chunk size, depends
-    );
-
     // Add processors to the master processor
-    masterProcessor.addProcessor([messageProcessor, researchProcessor]);
+    masterProcessor.addProcessor([
+        new MessageProcessor(llmClient, defaultCharacter, loglevel),
+        new ResearchQuantProcessor(
+            researchClient,
+            defaultCharacter,
+            loglevel,
+            1000 // chunk size, depends
+        ),
+    ]);
 
     const scheduledTaskDb = new MongoDb(
         "mongodb://localhost:27017",
@@ -80,12 +75,9 @@ async function main() {
 
     await scheduledTaskDb.deleteAll();
 
-    // Initialize core system
     const orchestrator = new Orchestrator(
-        roomManager,
-        vectorDb,
         masterProcessor,
-        scheduledTaskDb,
+        makeFlowLifecycle(scheduledTaskDb, conversationManager),
         {
             level: loglevel,
             enableColors: true,
@@ -94,7 +86,7 @@ async function main() {
     );
 
     // Initialize autonomous thought generation
-    const consciousness = new Consciousness(llmClient, roomManager, {
+    const consciousness = new Consciousness(llmClient, conversationManager, {
         intervalMs: 300000, // Think every 5 minutes
         minConfidence: 0.7,
         logLevel: loglevel,
@@ -220,12 +212,12 @@ async function main() {
                 const outputs: any = await orchestrator.dispatchToInput(
                     "user_chat",
                     {
-                        headers: {
-                            "x-user-id": userId,
-                        },
-                    },
-                    userMessage,
-                    userId
+                        userId,
+                        platformId: "discord",
+                        threadId: "123",
+                        data: { content: userMessage },
+                        contentId: "123",
+                    }
                 );
 
                 // Now `outputs` is an array of suggestions with role=output that got triggered

diff --git a/examples/example-basic.ts b/examples/example-basic.ts
@@ -88,7 +88,9 @@ async function main() {
         role: HandlerRole.OUTPUT,
         execute: async (data: any) => {
             const result = await starknetChain.write(data.payload);
-            return `Transaction: ${JSON.stringify(result, null, 2)}`;
+            return {
+                content: `Transaction: ${JSON.stringify(result, null, 2)}`,
+            };
         },
         outputSchema: z
             .object({
@@ -123,7 +125,9 @@ async function main() {
                 `query: ${query}`,
                 `result: ${JSON.stringify(result, null, 2)}`,
             ].join("\n\n");
-            return `GraphQL data fetched successfully: ${resultStr}`;
+            return {
+                content: `GraphQL data fetched successfully: ${resultStr}`,
+            };
         },
         outputSchema: z
             .object({

diff --git a/examples/example-discord.ts b/examples/example-discord.ts
@@ -7,7 +7,7 @@
 import { Orchestrator } from "../packages/core/src/core/orchestrator";
 import { HandlerRole, LogLevel } from "../packages/core/src/core/types";
 import { DiscordClient } from "../packages/core/src/core/io/discord";
-import { RoomManager } from "../packages/core/src/core/room-manager";
+import { ConversationManager } from "../packages/core/src/core/conversation-manager";
 import { ChromaVectorDB } from "../packages/core/src/core/vector-db";
 import { MessageProcessor } from "../packages/core/src/core/processors/message-processor";
 import { LLMClient } from "../packages/core/src/core/llm-client";
@@ -19,6 +19,7 @@ import readline from "readline";
 import { MongoDb } from "../packages/core/src/core/db/mongo-db";
 import { Message } from "discord.js";
 import { MasterProcessor } from "../packages/core/src/core/processors/master-processor";
+import { makeFlowLifecycle } from "../packages/core/src/core/life-cycle";
 
 async function main() {
     // Set logging level as you see fit
@@ -33,10 +34,10 @@ async function main() {
     // Optional: Purge previous session data if you want a fresh start
     await vectorDb.purge();
 
-    const roomManager = new RoomManager(vectorDb);
+    const conversationManager = new ConversationManager(vectorDb);
 
     const llmClient = new LLMClient({
-        model: "anthropic/claude-3-5-sonnet-latest", // Example model
+        model: "anthropic/claude-3-5-sonnet-latest",
         temperature: 0.3,
     });
 
@@ -46,15 +47,10 @@ async function main() {
         loglevel
     );
 
-    // Initialize processor with default character personality
-    const messageProcessor = new MessageProcessor(
-        llmClient,
-        defaultCharacter,
-        loglevel
+    masterProcessor.addProcessor(
+        new MessageProcessor(llmClient, defaultCharacter, loglevel)
     );
 
-    masterProcessor.addProcessor(messageProcessor);
-
     // Connect to MongoDB (for scheduled tasks, if you use them)
     const scheduledTaskDb = new MongoDb(
         "mongodb://localhost:27017",
@@ -69,10 +65,8 @@ async function main() {
 
     // Create the Orchestrator
     const core = new Orchestrator(
-        roomManager,
-        vectorDb,
         masterProcessor,
-        scheduledTaskDb,
+        makeFlowLifecycle(scheduledTaskDb, conversationManager),
         {
             level: loglevel,
             enableColors: true,
@@ -96,9 +90,7 @@ async function main() {
         name: "discord_stream",
         role: HandlerRole.INPUT,
         subscribe: (onData) => {
-            discord.startMessageStream((incomingMessage: Message) => {
-                onData(incomingMessage);
-            });
+            discord.startMessageStream(onData);
             return () => {
                 discord.stopMessageStream();
             };

diff --git a/examples/example-goal.ts b/examples/example-goal.ts
@@ -106,11 +106,13 @@ async function main() {
         role: HandlerRole.OUTPUT,
         execute: async (data: any) => {
             const result = await starknetChain.write(data.payload);
-            return `Transaction executed successfully: ${JSON.stringify(
-                result,
-                null,
-                2
-            )}`;
+            return {
+                content: `Transaction executed successfully: ${JSON.stringify(
+                    result,
+                    null,
+                    2
+                )}`,
+            };
         },
         outputSchema: z
             .object({
@@ -145,7 +147,9 @@ async function main() {
                 `query: ${query}`,
                 `result: ${JSON.stringify(result, null, 2)}`,
             ].join("\n\n");
-            return `GraphQL data fetched successfully: ${resultStr}`;
+            return {
+                content: `GraphQL data fetched successfully: ${resultStr}`,
+            };
         },
         outputSchema: z
             .object({

diff --git a/examples/example-server.ts b/examples/example-server.ts
@@ -12,24 +12,25 @@ import { ChromaVectorDB } from "../packages/core/src/core/vector-db";
 
 import { Orchestrator } from "../packages/core/src/core/orchestrator";
 import { HandlerRole } from "../packages/core/src/core/types";
-import { RoomManager } from "../packages/core/src/core/room-manager";
+import { ConversationManager } from "../packages/core/src/core/conversation-manager";
 import { MessageProcessor } from "../packages/core/src/core/processors/message-processor";
 import { defaultCharacter } from "../packages/core/src/core/character";
 
 import { LogLevel } from "../packages/core/src/core/types";
 import { MongoDb } from "../packages/core/src/core/db/mongo-db";
 import { MasterProcessor } from "../packages/core/src/core/processors/master-processor";
+import { makeFlowLifecycle } from "../packages/core/src/core/life-cycle";
 
-const scheduledTaskDb = new MongoDb(
+const kvDb = new MongoDb(
     "mongodb://localhost:27017",
     "myApp",
     "scheduled_tasks"
 );
 
-await scheduledTaskDb.connect();
+await kvDb.connect();
 console.log(chalk.green("✅ Scheduled task database connected"));
 
-await scheduledTaskDb.deleteAll();
+await kvDb.deleteAll();
 
 // ------------------------------------------------------
 // 1) CREATE DAYDREAMS AGENT
@@ -50,7 +51,7 @@ async function createDaydreamsAgent() {
     });
 
     // 1.3. Room manager initialization
-    const roomManager = new RoomManager(vectorDb);
+    const conversationManager = new ConversationManager(vectorDb);
 
     const masterProcessor = new MasterProcessor(
         llmClient,
@@ -69,10 +70,8 @@ async function createDaydreamsAgent() {
 
     // 1.5. Initialize core system
     const orchestrator = new Orchestrator(
-        roomManager,
-        vectorDb,
         masterProcessor,
-        scheduledTaskDb,
+        makeFlowLifecycle(kvDb, conversationManager),
         {
             level: loglevel,
             enableColors: true,
@@ -102,6 +101,10 @@ async function createDaydreamsAgent() {
                 message: string;
             };
             console.log(`Reply to user ${userId ?? "??"}: ${message}`);
+            return {
+                userId,
+                message,
+            };
         },
     });
 
@@ -151,16 +154,13 @@ wss.on("connection", (ws) => {
             }
 
             // Process the message using the orchestrator with the provided userId
-            const outputs = await orchestrator.dispatchToInput(
-                "user_chat",
-                {
-                    headers: {
-                        "x-user-id": userId,
-                    },
-                },
-                userMessage,
-                orchestratorId ? orchestratorId : undefined
-            );
+            const outputs = await orchestrator.dispatchToInput("user_chat", {
+                userId,
+                platformId: "discord",
+                threadId: orchestratorId,
+                data: { content: userMessage },
+                contentId: orchestratorId,
+            });
 
             // Send responses back through WebSocket
             if (outputs && (outputs as any).length > 0) {
@@ -211,8 +211,7 @@ app.get("/api/history/:userId", async (req, res) => {
         console.log("Fetching history for userId:", userId);
 
         // Get all orchestrator records for this user
-        const histories =
-            await scheduledTaskDb.getOrchestratorsByUserId(userId);
+        const histories = await kvDb.getOrchestratorsByUserId(userId);
 
         if (!histories || histories.length === 0) {
             console.log("No histories found");
@@ -241,7 +240,7 @@ app.get("/api/history/:userId/:chatId", async (req, res) => {
             return res.status(400).json({ error: "Invalid chat ID format" });
         }
 
-        const history = await scheduledTaskDb.getOrchestratorById(objectId);
+        const history = await kvDb.getOrchestratorById(objectId);
 
         if (!history) {
             return res.status(404).json({ error: "History not found" });