Merge branch 'develop' into 1223-fix-todos

Author: odilitime

.env.example

@@ -191,6 +191,11 @@ TOGETHER_API_KEY=
 # Server Configuration
 SERVER_PORT=3000
 
+# Abstract Configuration
+ABSTRACT_ADDRESS=
+ABSTRACT_PRIVATE_KEY=
+ABSTRACT_RPC_URL=https://api.testnet.abs.xyz
+
 # Starknet Configuration
 STARKNET_ADDRESS=
 STARKNET_PRIVATE_KEY=

.gitignore

@@ -9,6 +9,7 @@ concatenated-output.ts
 embedding-cache.json
 packages/plugin-buttplug/intiface-engine
 
+.idea
 .DS_Store
 
 dist/

agent/package.json

@@ -30,6 +30,7 @@
         "@elizaos/client-slack": "workspace:*",
         "@elizaos/core": "workspace:*",
         "@elizaos/plugin-0g": "workspace:*",
+        "@elizaos/plugin-abstract": "workspace:*",
         "@elizaos/plugin-aptos": "workspace:*",
         "@elizaos/plugin-bootstrap": "workspace:*",
         "@elizaos/plugin-intiface": "workspace:*",
@@ -51,6 +52,7 @@
         "@elizaos/plugin-multiversx": "workspace:*",
         "@elizaos/plugin-near": "workspace:*",
         "@elizaos/plugin-zksync-era": "workspace:*",
+        "@elizaos/plugin-3d-generation": "workspace:*",
         "readline": "1.3.0",
         "ws": "8.18.0",
         "yargs": "17.7.2"

agent/src/index.ts

@@ -46,6 +46,7 @@ import { evmPlugin } from "@elizaos/plugin-evm";
 import { storyPlugin } from "@elizaos/plugin-story";
 import { flowPlugin } from "@elizaos/plugin-flow";
 import { imageGenerationPlugin } from "@elizaos/plugin-image-generation";
+import { ThreeDGenerationPlugin } from "@elizaos/plugin-3d-generation";
 import { multiversxPlugin } from "@elizaos/plugin-multiversx";
 import { nearPlugin } from "@elizaos/plugin-near";
 import { nftGenerationPlugin } from "@elizaos/plugin-nft-generation";
@@ -55,6 +56,7 @@ import { suiPlugin } from "@elizaos/plugin-sui";
 import { TEEMode, teePlugin } from "@elizaos/plugin-tee";
 import { tonPlugin } from "@elizaos/plugin-ton";
 import { zksyncEraPlugin } from "@elizaos/plugin-zksync-era";
+import { abstractPlugin } from "@elizaos/plugin-abstract";
 import Database from "better-sqlite3";
 import fs from "fs";
 import path from "path";
@@ -386,12 +388,8 @@ export async function initializeClients(
 
     if (clientTypes.includes(Clients.TWITTER)) {
         const twitterClient = await TwitterClientInterface.start(runtime);
-
         if (twitterClient) {
             clients.twitter = twitterClient;
-            (twitterClient as any).enableSearch = !isFalsish(
-                getSecret(character, "TWITTER_SEARCH_ENABLE")
-            );
         }
     }
 
@@ -433,31 +431,6 @@ export async function initializeClients(
     return clients;
 }
 
-function isFalsish(input: any): boolean {
-    // If the input is exactly NaN, return true
-    if (Number.isNaN(input)) {
-        return true;
-    }
-
-    // Convert input to a string if it's not null or undefined
-    const value = input == null ? "" : String(input);
-
-    // List of common falsish string representations
-    const falsishValues = [
-        "false",
-        "0",
-        "no",
-        "n",
-        "off",
-        "null",
-        "undefined",
-        "",
-    ];
-
-    // Check if the value (trimmed and lowercased) is in the falsish list
-    return falsishValues.includes(value.trim().toLowerCase());
-}
-
 function getSecret(character: Character, secret: string) {
     return character.settings?.secrets?.[secret] || process.env[secret];
 }
@@ -544,6 +517,9 @@ export async function createAgent(
             getSecret(character, "HEURIST_API_KEY")
                 ? imageGenerationPlugin
                 : null,
+            getSecret(character, "FAL_API_KEY") 
+                ? ThreeDGenerationPlugin
+                : null,
             ...(getSecret(character, "COINBASE_API_KEY") &&
             getSecret(character, "COINBASE_PRIVATE_KEY")
                 ? [
@@ -562,6 +538,9 @@ export async function createAgent(
                 ? webhookPlugin
                 : null,
             getSecret(character, "EVM_PROVIDER_URL") ? goatPlugin : null,
+            getSecret(character, "ABSTRACT_PRIVATE_KEY")
+                ? abstractPlugin
+                : null,
             getSecret(character, "FLOW_ADDRESS") &&
             getSecret(character, "FLOW_PRIVATE_KEY")
                 ? flowPlugin

docs/docs/advanced/eliza-in-tee.md

@@ -101,7 +101,7 @@ const quote = await provider.generateAttestation(reportData);
 Before getting started with Eliza, ensure you have:
 
 - [Docker Desktop](https://www.docker.com/products/docker-desktop/) or [Orbstack](https://orbstack.dev/) (Orbstack is recommended)
-- For Mac/Windows: Check the prerequisites from [Quickstart Guide](./quickstart.md)
+- For Mac/Windows: Check the prerequisites from [Quickstart Guide](../quickstart.md)
 - For Linux: You just need Docker
 
 ---
@@ -144,7 +144,7 @@ To set up your environment for TEE development:
 
 1. **Configure Eliza Agent**
 
-    Go through the [configuration guide](./configuration.md) to set up your Eliza agent.
+    Go through the [configuration guide](../guides/configuration.md) to set up your Eliza agent.
 
 2. **Start the TEE Simulator**
    Follow the simulator setup instructions above based on your TEE mode.

docs/docs/core/actions.md

@@ -31,6 +31,7 @@ interface Action {
     examples: ActionExample[][];
     handler: Handler;
     validate: Validator;
+    suppressInitialMessage?: boolean;
 }
 ```
 
@@ -151,6 +152,7 @@ interface Action {
         state?: State,
     ) => Promise<void>;
     examples: ActionExample[][];
+    suppressInitialMessage?: boolean;
 }
 ```
 
@@ -162,6 +164,7 @@ interface Action {
 - **validate**: Determines if the action can be executed
 - **handler**: Implements the action's behavior
 - **examples**: Demonstrates proper usage patterns
+- **suppressInitialMessage**: When true, suppresses the initial response message before processing the action. Useful for actions that generate their own responses (like image generation)
 
 ---
 

package.json

@@ -4,6 +4,8 @@
         "preinstall": "npx only-allow pnpm",
         "build": "turbo run build --filter=!eliza-docs",
         "build-docker": "turbo run build",
+        "cleanstart": "if [ -f agent/data/db.sqlite ]; then rm agent/data/db.sqlite; fi && pnpm --filter \"@elizaos/agent\" start --isRoot",
+        "cleanstart:debug": "if [ -f agent/data/db.sqlite ]; then rm agent/data/db.sqlite; fi && cross-env NODE_ENV=development VERBOSE=true DEBUG=eliza:* pnpm --filter \"@elizaos/agent\" start --isRoot",
         "start": "pnpm --filter \"@elizaos/agent\" start --isRoot",
         "start:client": "pnpm --dir client dev",
         "start:debug": "cross-env NODE_ENV=development VERBOSE=true DEBUG=eliza:* pnpm --filter \"@elizaos/agent\" start --isRoot",

packages/client-direct/src/index.ts

@@ -222,6 +222,13 @@ export class DirectClient {
 
                 await runtime.evaluate(memory, state);
 
+                // Check if we should suppress the initial message
+                const action = runtime.actions.find(
+                    (a) => a.name === response.action
+                );
+                const shouldSuppressInitialMessage =
+                    action?.suppressInitialMessage;
+
                 const _result = await runtime.processActions(
                     memory,
                     [responseMessage],
@@ -232,10 +239,18 @@ export class DirectClient {
                     }
                 );
 
-                if (message) {
-                    res.json([response, message]);
+                if (!shouldSuppressInitialMessage) {
+                    if (message) {
+                        res.json([response, message]);
+                    } else {
+                        res.json([response]);
+                    }
                 } else {
-                    res.json([response]);
+                    if (message) {
+                        res.json([message]);
+                    } else {
+                        res.json([]);
+                    }
                 }
             }
         );

packages/client-twitter/src/index.ts

@@ -34,12 +34,15 @@ export const TwitterClientInterface: Client = {
 
         elizaLogger.log("Twitter client started");
 
-        const manager = new TwitterManager(runtime, this.enableSearch);
+        const manager = new TwitterManager(runtime, runtime.getSetting("TWITTER_SEARCH_ENABLE").toLowerCase() === "true");
 
         await manager.client.init();
 
         await manager.post.start();
 
+        if (manager.search)
+            await manager.search.start();
+
         await manager.interaction.start();
 
         await manager.search?.start();

packages/client-twitter/src/search.ts

@@ -1,5 +1,5 @@
 import { SearchMode } from "agent-twitter-client";
-import { composeContext } from "@elizaos/core";
+import {composeContext, elizaLogger} from "@elizaos/core";
 import { generateMessageResponse, generateText } from "@elizaos/core";
 import { messageCompletionFooter } from "@elizaos/core";
 import {
@@ -59,10 +59,12 @@ export class TwitterSearchClient {
     }
 
     private engageWithSearchTermsLoop() {
-        this.engageWithSearchTerms();
+        this.engageWithSearchTerms().then();
+        const randomMinutes = (Math.floor(Math.random() * (120 - 60 + 1)) + 60);
+        elizaLogger.log(`Next twitter search scheduled in ${randomMinutes} minutes`);
         setTimeout(
             () => this.engageWithSearchTermsLoop(),
-            (Math.floor(Math.random() * (120 - 60 + 1)) + 60) * 60 * 1000
+            randomMinutes * 60 * 1000
         );
     }