Merge pull request #13 from dcvilyz/main

Telegram Race Conditions, discord mute error handling
somewheresystems · Dec 3, 2024 · 4c8e17d · 4c8e17d
2 parents 47cc8ea + a8f9c91
commit 4c8e17d
Show file tree

Hide file tree

Showing 22 changed files with 2,838 additions and 1,204 deletions.
diff --git a/.gitignore b/.gitignore
@@ -35,12 +35,17 @@ tweetcache/
 twitter_cookies.json
 timeline_cache.json
 
+
 *.sqlite
 characters/
 
 packages/core/src/providers/cache
 packages/core/src/providers/cache/*
 cache/*
+packages/agent/imagecache
+packages/agent/imagecache/*
+
+ROADMAP.md
 
 twitter_archive
 test.html

diff --git a/ROADMAP.md b/ROADMAP.md
@@ -0,0 +1,5 @@
+#
+# LOOMLOVE
+# DCVILYZ
+# 
+# 
diff --git a/packages/agent/imagecache/062878d30f28cdbdaef710ab9469f793.png b/packages/agent/imagecache/062878d30f28cdbdaef710ab9469f793.png
diff --git a/packages/agent/imagecache/38ad5661c842ee35cc45a06fcac0649b.png b/packages/agent/imagecache/38ad5661c842ee35cc45a06fcac0649b.png
diff --git a/packages/agent/imagecache/ee9b8044253fff62e02ced9ffa7c05b8.png b/packages/agent/imagecache/ee9b8044253fff62e02ced9ffa7c05b8.png
diff --git a/packages/agent/src/index.ts b/packages/agent/src/index.ts
@@ -82,7 +82,7 @@ async function startAgent(character: Character) {
             runtime as IAgentRuntime
         );
 
-        directClient.registerAgent(await runtime);
+        directClient.registerAgent(runtime);
 
         return clients;
     } catch (error) {

diff --git a/packages/core/src/cli/index.ts b/packages/core/src/cli/index.ts
@@ -248,13 +248,33 @@ export async function startTelegram(
 
 export async function startTwitter(runtime: IAgentRuntime) {
     elizaLogger.log("Starting Twitter clients...");
+
+    // Create all clients first
     const twitterSearchClient = new Client.TwitterSearchClient(runtime);
-    await wait();
-    const twitterInteractionClient = new Client.TwitterInteractionClient(
-        runtime
-    );
-    await wait();
+    const twitterInteractionClient = new Client.TwitterInteractionClient(runtime);
     const twitterGenerationClient = new Client.TwitterPostClient(runtime);
+
+    // Wait for each client to be ready
+    await Promise.all([
+        new Promise<void>((resolve) => {
+            twitterSearchClient.once('ready', () => {
+                elizaLogger.log("Twitter search client ready");
+                resolve();
+            });
+        }),
+        new Promise<void>((resolve) => {
+            twitterInteractionClient.once('ready', () => {
+                elizaLogger.log("Twitter interaction client ready");
+                resolve();
+            });
+        }),
+        new Promise<void>((resolve) => {
+            twitterGenerationClient.once('ready', () => {
+                elizaLogger.log("Twitter generation client ready");
+                resolve();
+            });
+        })
+    ]);
 
     return [
         twitterInteractionClient,