Merge pull request elizaOS#2248 from augchan42/feature/echochamber-conversation-starter

feat: (echochambers) add dead room detection and conversation starter

Author: shakkernerd

.env.example

@@ -18,8 +18,7 @@ export class EchoChamberClient {
     private config: EchoChamberConfig;
     private apiUrl: string;
     private modelInfo: ModelInfo;
-    private pollInterval: NodeJS.Timeout | null = null;
-    private watchedRoom: string | null = null;
+    private watchedRooms: Set<string> = new Set();
 
     constructor(runtime: IAgentRuntime, config: EchoChamberConfig) {
         this.runtime = runtime;
@@ -50,28 +49,30 @@ export class EchoChamberClient {
         };
     }
 
-    public async setWatchedRoom(roomId: string): Promise<void> {
+    public async addWatchedRoom(roomId: string): Promise<void> {
         try {
-            // Verify room exists
             const rooms = await this.listRooms();
             const room = rooms.find((r) => r.id === roomId);
 
             if (!room) {
                 throw new Error(`Room ${roomId} not found`);
             }
 
-            // Set new watched room
-            this.watchedRoom = roomId;
-
+            this.watchedRooms.add(roomId);
             elizaLogger.success(`Now watching room: ${room.name}`);
         } catch (error) {
-            elizaLogger.error("Error setting watched room:", error);
+            elizaLogger.error("Error adding watched room:", error);
             throw error;
         }
     }
 
-    public getWatchedRoom(): string | null {
-        return this.watchedRoom;
+    public removeWatchedRoom(roomId: string): void {
+        this.watchedRooms.delete(roomId);
+        elizaLogger.success(`Stopped watching room: ${roomId}`);
+    }
+
+    public getWatchedRooms(): string[] {
+        return Array.from(this.watchedRooms);
     }
 
     private async retryOperation<T>(
@@ -94,40 +95,26 @@ export class EchoChamberClient {
     public async start(): Promise<void> {
         elizaLogger.log("🚀 Starting EchoChamber client...");
         try {
-            // Verify connection by listing rooms
             await this.retryOperation(() => this.listRooms());
-            elizaLogger.success(
-                `✅ EchoChamber client successfully started for ${this.modelInfo.username}`
-            );
 
-            // Join default room if specified and no specific room is being watched
-            if (this.config.defaultRoom && !this.watchedRoom) {
-                await this.setWatchedRoom(this.config.defaultRoom);
+            for (const room of this.config.rooms) {
+                await this.addWatchedRoom(room);
             }
+
+            elizaLogger.success(
+                `✅ EchoChamber client started for ${this.modelInfo.username}`
+            );
+            elizaLogger.info(
+                `Watching rooms: ${Array.from(this.watchedRooms).join(", ")}`
+            );
         } catch (error) {
             elizaLogger.error("❌ Failed to start EchoChamber client:", error);
             throw error;
         }
     }
 
     public async stop(): Promise<void> {
-        if (this.pollInterval) {
-            clearInterval(this.pollInterval);
-            this.pollInterval = null;
-        }
-
-        // Leave watched room if any
-        if (this.watchedRoom) {
-            try {
-                this.watchedRoom = null;
-            } catch (error) {
-                elizaLogger.error(
-                    `Error leaving room ${this.watchedRoom}:`,
-                    error
-                );
-            }
-        }
-
+        this.watchedRooms.clear();
         elizaLogger.log("Stopping EchoChamber client...");
     }
 
@@ -189,4 +176,43 @@ export class EchoChamberClient {
             return data.message;
         });
     }
+
+    public async shouldInitiateConversation(room: ChatRoom): Promise<boolean> {
+        try {
+            const history = await this.getRoomHistory(room.id);
+            if (!history?.length) return true; // Empty room is good to start
+
+            const recentMessages = history
+                .filter((msg) => msg != null) // Filter out null messages
+                .sort(
+                    (a, b) =>
+                        new Date(b.timestamp).getTime() -
+                        new Date(a.timestamp).getTime()
+                );
+
+            if (!recentMessages.length) return true; // No valid messages
+
+            const lastMessageTime = new Date(
+                recentMessages[0].timestamp
+            ).getTime();
+            const timeSinceLastMessage = Date.now() - lastMessageTime;
+
+            const quietPeriodSeconds = Number(
+                this.runtime.getSetting("ECHOCHAMBERS_QUIET_PERIOD") || 300 // 5 minutes in seconds
+            );
+            const quietPeriod = quietPeriodSeconds * 1000; // Convert to milliseconds
+
+            if (timeSinceLastMessage < quietPeriod) {
+                elizaLogger.debug(
+                    `Room ${room.name} active recently, skipping`
+                );
+                return false;
+            }
+
+            return true;
+        } catch (error) {
+            elizaLogger.error(`Error checking conversation state: ${error}`);
+            return false;
+        }
+    }
 }

packages/plugin-echochambers/src/echoChamberClient.ts

@@ -34,8 +34,9 @@ export async function validateEchoChamberConfig(
     const username =
         runtime.getSetting("ECHOCHAMBERS_USERNAME") ||
         `agent-${runtime.agentId}`;
-    const defaultRoom =
-        runtime.getSetting("ECHOCHAMBERS_DEFAULT_ROOM") || "general";
+    // Change from DEFAULT_ROOM to ROOMS
+    const rooms = runtime.getSetting("ECHOCHAMBERS_ROOMS")?.split(",").map(r => r.trim()) || ["general"];
+
     const pollInterval = Number(
         runtime.getSetting("ECHOCHAMBERS_POLL_INTERVAL") || 120
     );
@@ -50,6 +51,6 @@ export async function validateEchoChamberConfig(
     elizaLogger.log("EchoChambers configuration validated successfully");
     elizaLogger.log(`API URL: ${apiUrl}`);
     elizaLogger.log(`Username: ${username}`);
-    elizaLogger.log(`Default Room: ${defaultRoom}`);
+    elizaLogger.log(`Watching Rooms: ${rooms.join(", ")}`);
     elizaLogger.log(`Poll Interval: ${pollInterval}s`);
 }

packages/plugin-echochambers/src/environment.ts

@@ -26,9 +26,10 @@ export const EchoChamberClientInterface: Client = {
                     runtime.getSetting("ECHOCHAMBERS_USERNAME") ||
                     `agent-${runtime.agentId}`,
                 model: runtime.modelProvider,
-                defaultRoom:
-                    runtime.getSetting("ECHOCHAMBERS_DEFAULT_ROOM") ||
-                    "general",
+                rooms: runtime
+                    .getSetting("ECHOCHAMBERS_ROOMS")
+                    ?.split(",")
+                    .map((r) => r.trim()) || ["general"],
             };
 
             elizaLogger.log("Starting EchoChambers client...");