basic hello world scenario does a thing

Author: lalalune

package.json

@@ -7,6 +7,7 @@
     "check": "biome check --write .",
     "preinstall": "npx only-allow bun",
     "swarm": "turbo run build --filter=./packages/core && concurrently \"turbo run start --filter=@elizaos/agent -- --swarm \" \"turbo run start --filter=!@elizaos/agent --filter=!@elizaos/docs --filter=!@elizaos/core\"",
+    "swarm:scenario": "turbo run build --filter=./packages/core && concurrently \"turbo run start --filter=@elizaos/agent -- --swarm --scenario \" \"turbo run start --filter=!@elizaos/agent --filter=!@elizaos/docs --filter=!@elizaos/core\"",
     "build": "turbo run build --filter=./packages/core && turbo run build --filter=./packages/*",
     "build:core": "turbo run build --filter=./packages/core",
     "build:cli": "turbo run build --filter=./packages/cli && cd packages/cli && bun link",

packages/agent/src/swarm/index.ts

@@ -10,9 +10,9 @@ import counselor from "./counselor";
 
 export const swarm: {character: Character, init: (runtime: IAgentRuntime) => Promise<void>}[] = [
   complianceOfficer,
-  // communityManager,
-  // socialMediaManager,
-  // counselor,
+  communityManager,
+  socialMediaManager,
+  counselor,
 ];
 
 export default swarm;

packages/agent/src/swarm/scenario.ts

@@ -1,32 +1,74 @@
-import { ChannelType, type IAgentRuntime, stringToUuid, type UUID } from "@elizaos/core";
+import { ChannelType, type IAgentRuntime, Memory, stringToUuid, type UUID } from "@elizaos/core";
 import { v4 as uuidv4 } from 'uuid';
 
-// 
+async function sayMessage(participant: IAgentRuntime, roomMap, participants: IAgentRuntime[], message: string) {
+    const participantId = participant.agentId;
 
-const scenarios = [
-    async function scenario1(members: IAgentRuntime[]) {
-        const participant1 = members[0];
-        const participant2 = members[1];
+    // for each participant, create the memory
+    for (const participant of [participants[0]]) {
+        console.log("participant");
+        console.log(participant.agentId, participantId);
+        if(participant.agentId === participantId) {
+            continue;
+        }
 
-        const roomId = uuidv4() as UUID;
-
-        await participant1.ensureConnection({
-            userId: participant1.agentId,
+        const roomId = roomMap.get(participant.agentId);
+        await participant.ensureConnection({
+            userId: participantId,
             roomId,
-            userName: participant1.character.name,
-            userScreenName: participant1.character.name,
+            userName: participant.character.name,
+            userScreenName: participant.character.name,
             source: "scenario",
             type: ChannelType.GROUP,
         });
-
-        await participant2.ensureConnection({
-            userId: participant2.agentId,
+        const memoryManager = participant.messageManager;
+        const memory: Memory = {
+            userId: participantId,
+            agentId: participant.agentId,
             roomId,
-            userName: participant2.character.name,
-            userScreenName: participant2.character.name,
-            source: "scenario",
-            type: ChannelType.GROUP,
-        });
+            content: {
+                text: message,
+            }
+        }
+        await memoryManager.createMemory(memory);
+
+        // participant.emitEvent("MESSAGE_RECEIVED", {
+        //     runtime: participant,
+        //     message: memory,
+        //     roomId: roomId,
+        //     userId: participantId,
+        //     serverId: roomId,
+        //     channelId: roomId,
+        //     source: "scenario",
+        //     type: ChannelType.GROUP,
+        // });
+    }
+}
+
+const scenarios = [
+    async function scenario1(members: IAgentRuntime[]) {
+        // create a map of member agentId to room UUID
+        const roomMap = new Map<string, UUID>();
+        for (const member of members) {
+            const roomId = uuidv4() as UUID;
+            roomMap.set(member.agentId, roomId);
+        }
+
+        await sayMessage(members[0], roomMap, members, "Hello bob!");
+        await sayMessage(members[1], roomMap, members, "Hello alice!");
+        await sayMessage(members[0], roomMap, members, "Hello bob again!");
+        await sayMessage(members[1], roomMap, members, "Hello alice again!");
+        await sayMessage(members[2], roomMap, members, "I'm charlie!");
+        await sayMessage(members[0], roomMap, members, "Hello bob, how are you?");
+        await sayMessage(members[1], roomMap, members, "Hello alice, I'm good!");
+        await sayMessage(members[2], roomMap, members, "I'm good too!");
+
+        const conversations = await Promise.all(members.map(async (member) => {
+            return member.messageManager.getMemories({
+                roomId: roomMap.get(member.agentId),
+            });
+        }));
+        console.log(conversations);
     },
 ];
 

packages/core/src/runtime.ts

@@ -785,6 +785,10 @@ export class AgentRuntime implements IAgentRuntime {
         channelId?: string,
         serverId?: string,
     }) {
+        if(userId === this.agentId) {
+            throw new Error("Agent should not connect to itself");
+        }
+
         await Promise.all([
             this.ensureUserExists(
                 this.agentId,