Merge branch 'elizaOS:develop' into develop

Author: mgunnin

packages/client-twitter/src/plugins/SttTtsSpacesPlugin.ts

@@ -260,7 +260,7 @@ export class SttTtsPlugin implements Plugin {
     /**
      * On speaker silence => flush STT => GPT => TTS => push to Janus
      */
-    private async processAudio(userId: UUID): Promise<void> {
+    private async processAudio(userId: string): Promise<void> {
         if (this.isProcessingAudio) {
             return;
         }
@@ -396,21 +396,32 @@ export class SttTtsPlugin implements Plugin {
      */
     private async handleUserMessage(
         userText: string,
-        userId: UUID
+        userId: string // This is the raw Twitter user ID like 'tw-1865462035586142208'
     ): Promise<string> {
+        // Extract the numeric ID part
+        const numericId = userId.replace("tw-", "");
+        const roomId = stringToUuid(`twitter_generate_room-${this.spaceId}`);
+
+        // Create consistent UUID for the user
+        const userUuid = stringToUuid(`twitter-user-${numericId}`);
+
+        // Ensure the user exists in the accounts table
         await this.runtime.ensureUserExists(
-            this.runtime.agentId,
-            this.client.profile.username,
-            this.runtime.character.name,
+            userUuid,
+            userId, // Use full Twitter ID as username
+            `Twitter User ${numericId}`,
             "twitter"
         );
 
-        const roomId = stringToUuid("twitter_generate_room-" + this.spaceId);
+        // Ensure room exists and user is in it
+        await this.runtime.ensureRoomExists(roomId);
+        await this.runtime.ensureParticipantInRoom(userUuid, roomId);
+
         let state = await this.runtime.composeState(
             {
                 agentId: this.runtime.agentId,
                 content: { text: userText, source: "twitter" },
-                userId,
+                userId: userUuid,
                 roomId,
             },
             {
@@ -420,13 +431,13 @@ export class SttTtsPlugin implements Plugin {
         );
 
         const memory = {
-            id: stringToUuid(roomId + "-voice-message-" + Date.now()),
+            id: stringToUuid(`${roomId}-voice-message-${Date.now()}`),
             agentId: this.runtime.agentId,
             content: {
                 text: userText,
                 source: "twitter",
             },
-            userId,
+            userId: userUuid,
             roomId,
             embedding: getEmbeddingZeroVector(),
             createdAt: Date.now(),
@@ -459,7 +470,7 @@ export class SttTtsPlugin implements Plugin {
         const responseContent = await this._generateResponse(memory, context);
 
         const responseMemory: Memory = {
-            id: stringToUuid(memory.id + "-voice-response-" + Date.now()),
+            id: stringToUuid(`${memory.id}-voice-response-${Date.now()}`),
             agentId: this.runtime.agentId,
             userId: this.runtime.agentId,
             content: {
@@ -591,17 +602,17 @@ export class SttTtsPlugin implements Plugin {
 
         if (response === "RESPOND") {
             return true;
-        } else if (response === "IGNORE") {
-            return false;
-        } else if (response === "STOP") {
-            return false;
-        } else {
-            elizaLogger.error(
-                "Invalid response from response generateText:",
-                response
-            );
+        }
+
+        if (response === "IGNORE" || response === "STOP") {
             return false;
         }
+
+        elizaLogger.error(
+            "Invalid response from response generateText:",
+            response
+        );
+        return false;
     }
 
     /**