Merge branch 'develop' into develop

Author: shakkernerd

.env.example

@@ -88,6 +88,12 @@ TWITTER_TARGET_USERS=           # Comma separated list of Twitter user names to
 TWITTER_RETRY_LIMIT=            # Maximum retry attempts for Twitter login
 TWITTER_SPACES_ENABLE=false     # Enable or disable Twitter Spaces logic
 
+# CONFIGURATION FOR APPROVING TWEETS BEFORE IT GETS POSTED
+TWITTER_APPROVAL_DISCORD_CHANNEL_ID= # Channel ID for the Discord bot to listen and send approval messages
+TWITTER_APPROVAL_DISCORD_BOT_TOKEN= # Discord bot token (this could be a different bot token from DISCORD_API_TOKEN)
+TWITTER_APPROVAL_ENABLED=  # Enable or disable Twitter approval logic #Default is false
+TWITTER_APPROVAL_CHECK_INTERVAL=60000  # Default: 60 seconds
+
 # Post Interval Settings (in minutes)
 POST_INTERVAL_MIN=              # Default: 90
 POST_INTERVAL_MAX=              # Default: 180
@@ -357,7 +363,7 @@ MVX_NETWORK= # must be one of mainnet, devnet, testnet
 NEAR_WALLET_SECRET_KEY=
 NEAR_WALLET_PUBLIC_KEY=
 NEAR_ADDRESS=
-SLIPPAGE=1
+NEAR_SLIPPAGE=1
 NEAR_RPC_URL=https://rpc.testnet.near.org
 NEAR_NETWORK=testnet # or mainnet
 
@@ -422,6 +428,9 @@ SPHERON_WALLET_ADDRESS=
 # Stargaze NFT marketplace from Cosmos (You can use https://graphql.mainnet.stargaze-apis.com/graphql)
 STARGAZE_ENDPOINT=
 
+# API key for giphy from https://developers.giphy.com/dashboard/
+GIPHY_API_KEY=
+
 # GenLayer
 GENLAYER_PRIVATE_KEY= # Private key of the GenLayer account to use for the agent in this format (0x0000000000000000000000000000000000000000000000000000000000000000)
 
@@ -430,4 +439,13 @@ OPEN_WEATHER_API_KEY=  # OpenWeather API key
 
 # Allora
 ALLORA_API_KEY= # Allora API key, format: UP-f8db7d6558ab432ca0d92716
-ALLORA_CHAIN_SLUG= # must be one of mainnet, testnet. If not specified, it will use testnet by default
+ALLORA_CHAIN_SLUG= # must be one of mainnet, testnet. If not specified, it will use testnet by default
+
+# Opacity zkTLS
+OPACITY_TEAM_ID=f309ac8ae8a9a14a7e62cd1a521b1c5f
+OPACITY_CLOUDFLARE_NAME=eigen-test
+OPACITY_PROVER_URL=https://opacity-ai-zktls-demo.vercel.app
+
+# Verifiable Inference Configuration
+VERIFIABLE_INFERENCE_ENABLED=false # Set to false to disable verifiable inference
+VERIFIABLE_INFERENCE_PROVIDER=opacity # Options: opacity

agent/package.json

@@ -57,6 +57,7 @@
         "@elizaos/plugin-solana-agentkit": "workspace:*",
         "@elizaos/plugin-starknet": "workspace:*",
         "@elizaos/plugin-stargaze": "workspace:*",
+        "@elizaos/plugin-giphy": "workspace:*",
         "@elizaos/plugin-ton": "workspace:*",
         "@elizaos/plugin-sui": "workspace:*",
         "@elizaos/plugin-tee": "workspace:*",
@@ -72,10 +73,12 @@
         "@elizaos/plugin-web-search": "workspace:*",
         "@elizaos/plugin-thirdweb": "workspace:*",
         "@elizaos/plugin-genlayer": "workspace:*",
+        "@elizaos/plugin-depin": "workspace:*",
         "@elizaos/plugin-open-weather": "workspace:*",
         "@elizaos/plugin-obsidian": "workspace:*",
         "@elizaos/plugin-arthera": "workspace:*",
         "@elizaos/plugin-allora": "workspace:*",
+        "@elizaos/plugin-opacity": "workspace:*",
         "readline": "1.3.0",
         "ws": "8.18.0",
         "yargs": "17.7.2"

agent/src/index.ts

@@ -71,6 +71,7 @@ import { TEEMode, teePlugin } from "@elizaos/plugin-tee";
 import { teeMarlinPlugin } from "@elizaos/plugin-tee-marlin";
 import { tonPlugin } from "@elizaos/plugin-ton";
 import { webSearchPlugin } from "@elizaos/plugin-web-search";
+import { giphyPlugin } from "@elizaos/plugin-giphy";
 import { echoChamberPlugin } from "@elizaos/plugin-echochambers";
 import { thirdwebPlugin } from "@elizaos/plugin-thirdweb";
 import { zksyncEraPlugin } from "@elizaos/plugin-zksync-era";
@@ -85,6 +86,7 @@ import net from "net";
 import path from "path";
 import { fileURLToPath } from "url";
 import yargs from "yargs";
+import { OpacityAdapter } from "@elizaos/plugin-opacity";
 
 const __filename = fileURLToPath(import.meta.url); // get the resolved path to the file
 const __dirname = path.dirname(__filename); // get the name of the directory
@@ -553,6 +555,28 @@ export async function createAgent(
     //     });
     //     elizaLogger.log("Verifiable inference adapter initialized");
     // }
+    // Initialize Opacity adapter if environment variables are present
+    let verifiableInferenceAdapter;
+    if (
+        process.env.OPACITY_TEAM_ID &&
+        process.env.OPACITY_CLOUDFLARE_NAME &&
+        process.env.OPACITY_PROVER_URL &&
+        process.env.VERIFIABLE_INFERENCE_ENABLED === "true"
+    ) {
+        verifiableInferenceAdapter = new OpacityAdapter({
+            teamId: process.env.OPACITY_TEAM_ID,
+            teamName: process.env.OPACITY_CLOUDFLARE_NAME,
+            opacityProverUrl: process.env.OPACITY_PROVER_URL,
+            modelProvider: character.modelProvider,
+            token: token,
+        });
+        elizaLogger.log("Verifiable inference adapter initialized");
+        elizaLogger.log("teamId", process.env.OPACITY_TEAM_ID);
+        elizaLogger.log("teamName", process.env.OPACITY_CLOUDFLARE_NAME);
+        elizaLogger.log("opacityProverUrl", process.env.OPACITY_PROVER_URL);
+        elizaLogger.log("modelProvider", character.modelProvider);
+        elizaLogger.log("token", token);
+    }
 
     return new AgentRuntime({
         databaseAdapter: db,
@@ -659,6 +683,7 @@ export async function createAgent(
                 ? echoChambersPlugin
                 : null,
             getSecret(character, "STARGAZE_ENDPOINT") ? stargazePlugin : null,
+            getSecret(character, "GIPHY_API_KEY") ? giphyPlugin : null,
             getSecret(character, "GENLAYER_PRIVATE_KEY")
                 ? genLayerPlugin
                 : null,
@@ -681,7 +706,7 @@ export async function createAgent(
         managers: [],
         cacheManager: cache,
         fetch: logFetch,
-        // verifiableInferenceAdapter,
+        verifiableInferenceAdapter,
     });
 }
 

packages/adapter-postgres/schema.sql

@@ -148,7 +148,7 @@ BEGIN
             "originalId" UUID REFERENCES knowledge("id"),
             "chunkIndex" INTEGER,
             "isShared" BOOLEAN DEFAULT FALSE,
-            CHECK((isShared = true AND "agentId" IS NULL) OR (isShared = false AND "agentId" IS NOT NULL))
+            CHECK(("isShared" = true AND "agentId" IS NULL) OR ("isShared" = false AND "agentId" IS NOT NULL))
         )', vector_dim);
 END $$;
 

packages/client-telegram/src/messageManager.ts

@@ -678,8 +678,11 @@ export class MessageManager {
     ): Promise<Message.TextMessage[]> {
         if (content.attachments && content.attachments.length > 0) {
             content.attachments.map(async (attachment: Media) => {
-                if (attachment.contentType.startsWith("image")) {
-                    this.sendImage(ctx, attachment.url, attachment.description);
+                if (attachment.contentType === "image/gif") {
+                    // Handle GIFs specifically
+                    await this.sendAnimation(ctx, attachment.url, attachment.description);
+                } else if (attachment.contentType.startsWith("image")) {
+                    await this.sendImage(ctx, attachment.url, attachment.description);
                 }
             });
         } else {
@@ -743,6 +746,42 @@ export class MessageManager {
         }
     }
 
+    private async sendAnimation(
+        ctx: Context,
+        animationPath: string,
+        caption?: string
+    ): Promise<void> {
+        try {
+            if (/^(http|https):\/\//.test(animationPath)) {
+                // Handle HTTP URLs
+                await ctx.telegram.sendAnimation(ctx.chat.id, animationPath, {
+                    caption,
+                });
+            } else {
+                // Handle local file paths
+                if (!fs.existsSync(animationPath)) {
+                    throw new Error(`File not found: ${animationPath}`);
+                }
+
+                const fileStream = fs.createReadStream(animationPath);
+
+                await ctx.telegram.sendAnimation(
+                    ctx.chat.id,
+                    {
+                        source: fileStream,
+                    },
+                    {
+                        caption,
+                    }
+                );
+            }
+
+            elizaLogger.info(`Animation sent successfully: ${animationPath}`);
+        } catch (error) {
+            elizaLogger.error("Error sending animation:", error);
+        }
+    }
+
     // Split message into smaller parts
     private splitMessage(text: string): string[] {
         const chunks: string[] = [];

packages/client-twitter/package.json

@@ -22,7 +22,8 @@
         "@elizaos/core": "workspace:*",
         "agent-twitter-client": "0.0.18",
         "glob": "11.0.0",
-        "zod": "3.23.8"
+        "zod": "3.23.8",
+        "discord.js": "14.16.3"
     },
     "devDependencies": {
         "tsup": "8.3.5",