Merge branch 'develop' into pr-1934

Author: shakkernerd

.env.example

@@ -2,6 +2,8 @@
 CACHE_STORE=database # Defaults to database. Other available cache store: redis and filesystem
 REDIS_URL= # Redis URL - could be a local redis instance or cloud hosted redis. Also support rediss:// urls
 
+PGLITE_DATA_DIR= #../pgLite/ if selecting a directory   --- or memory:// if selecting in memory
+
 # Discord Configuration
 DISCORD_APPLICATION_ID=
 DISCORD_API_TOKEN=              # Bot token
@@ -197,6 +199,9 @@ EVM_PROVIDER_URL=
 AVALANCHE_PRIVATE_KEY=
 AVALANCHE_PUBLIC_KEY=
 
+# Arthera
+ARTHERA_PRIVATE_KEY=
+
 # Solana
 SOLANA_PRIVATE_KEY=
 SOLANA_PUBLIC_KEY=
@@ -263,6 +268,9 @@ CHARITY_ADDRESS_ETH=0x750EF1D7a0b4Ab1c97B7A623D7917CcEb5ea779C
 CHARITY_ADDRESS_ARB=0x1234567890123456789012345678901234567890
 CHARITY_ADDRESS_POL=0x1234567890123456789012345678901234567890
 
+# thirdweb
+THIRDWEB_SECRET_KEY=              # Create key on thirdweb developer dashboard: https://thirdweb.com/
+
 # Conflux Configuration
 CONFLUX_CORE_PRIVATE_KEY=
 CONFLUX_CORE_SPACE_RPC_URL=
@@ -295,6 +303,10 @@ MEDIUM_VENICE_MODEL=            # Default: llama-3.3-70b
 LARGE_VENICE_MODEL=             # Default: llama-3.1-405b
 IMAGE_VENICE_MODEL=             # Default: fluently-xl
 
+# Coin Price Configuration
+COINMARKETCAP_API_KEY=
+COINGECKO_API_KEY=
+
 # Akash Chat API Configuration docs: https://chatapi.akash.network/documentation
 AKASH_CHAT_API_KEY= # Get from https://chatapi.akash.network/
 SMALL_AKASH_CHAT_API_MODEL=  # Default: Meta-Llama-3-2-3B-Instruct
@@ -401,6 +413,12 @@ FUEL_WALLET_PRIVATE_KEY=
 TOKENIZER_MODEL=  # Specify the tokenizer model to be used.
 TOKENIZER_TYPE=   # Options: tiktoken (for OpenAI models) or auto (AutoTokenizer from Hugging Face for non-OpenAI models). Default: tiktoken.
 
+
+# Spheron
+SPHERON_PRIVATE_KEY=
+SPHERON_PROVIDER_PROXY_URL=
+SPHERON_WALLET_ADDRESS=
+
 # Stargaze NFT marketplace from Cosmos (You can use https://graphql.mainnet.stargaze-apis.com/graphql)
 STARGAZE_ENDPOINT=
 
@@ -409,3 +427,7 @@ GENLAYER_PRIVATE_KEY=0x000000000000000000000000000000000000000000000000000000000
 
 # OpenWeather
 OPEN_WEATHER_API_KEY=  # OpenWeather API key
+
+# Allora
+ALLORA_API_KEY=UP-f8db7d6558ab432ca0d92716 # Allora API key
+ALLORA_CHAIN_SLUG=testnet # must be one of mainnet, testnet. If not specified, it will use testnet by default

.gitignore

@@ -15,6 +15,7 @@ packages/plugin-buttplug/intiface-engine
 dist/
 # Allow models directory but ignore model files
 models/*.gguf
+pgLite/
 
 cookies.json
 

agent/package.json

@@ -21,6 +21,7 @@
         "@elizaos/adapter-postgres": "workspace:*",
         "@elizaos/adapter-redis": "workspace:*",
         "@elizaos/adapter-sqlite": "workspace:*",
+        "@elizaos/adapter-pglite": "workspace:*",
         "@elizaos/client-auto": "workspace:*",
         "@elizaos/client-direct": "workspace:*",
         "@elizaos/client-discord": "workspace:*",
@@ -39,6 +40,7 @@
         "@ai16z/plugin-cosmos": "workspace:*",
         "@elizaos/plugin-intiface": "workspace:*",
         "@elizaos/plugin-coinbase": "workspace:*",
+        "@elizaos/plugin-coinprice": "workspace:*",
         "@elizaos/plugin-conflux": "workspace:*",
         "@elizaos/plugin-evm": "workspace:*",
         "@elizaos/plugin-echochambers": "workspace:*",
@@ -67,8 +69,12 @@
         "@elizaos/plugin-fuel": "workspace:*",
         "@elizaos/plugin-avalanche": "workspace:*",
         "@elizaos/plugin-web-search": "workspace:*",
+        "@elizaos/plugin-thirdweb": "workspace:*",
         "@elizaos/plugin-genlayer": "workspace:*",
         "@elizaos/plugin-open-weather": "workspace:*",
+        "@elizaos/plugin-obsidian": "workspace:*",
+        "@elizaos/plugin-arthera": "workspace:*",
+        "@elizaos/plugin-allora": "workspace:*",
         "readline": "1.3.0",
         "ws": "8.18.0",
         "yargs": "17.7.2"
@@ -80,4 +86,4 @@
         "ts-node": "10.9.2",
         "tsup": "8.3.5"
     }
-}
+}

agent/src/index.ts

@@ -1,6 +1,7 @@
 import { PostgresDatabaseAdapter } from "@elizaos/adapter-postgres";
 import { RedisClient } from "@elizaos/adapter-redis";
 import { SqliteDatabaseAdapter } from "@elizaos/adapter-sqlite";
+import { PGLiteDatabaseAdapter } from "@elizaos/adapter-pglite";
 import { AutoClientInterface } from "@elizaos/client-auto";
 import { DiscordClientInterface } from "@elizaos/client-discord";
 import { FarcasterAgentClient } from "@elizaos/client-farcaster";
@@ -37,6 +38,7 @@ import { DirectClient } from "@elizaos/client-direct";
 import { ThreeDGenerationPlugin } from "@elizaos/plugin-3d-generation";
 import { abstractPlugin } from "@elizaos/plugin-abstract";
 import { aptosPlugin } from "@elizaos/plugin-aptos";
+import { alloraPlugin } from "@elizaos/plugin-allora";
 import { avalanchePlugin } from "@elizaos/plugin-avalanche";
 import { binancePlugin } from "@elizaos/plugin-binance";
 import {
@@ -47,6 +49,7 @@ import {
     tradePlugin,
     webhookPlugin,
 } from "@elizaos/plugin-coinbase";
+import { coinPricePlugin } from "@elizaos/plugin-coinprice";
 import { confluxPlugin } from "@elizaos/plugin-conflux";
 import { cronosZkEVMPlugin } from "@elizaos/plugin-cronoszkevm";
 import { echoChambersPlugin } from "@elizaos/plugin-echochambers";
@@ -68,11 +71,14 @@ 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 { echoChamberPlugin } from "@elizaos/plugin-echochambers";
+import { thirdwebPlugin } from "@elizaos/plugin-thirdweb";
 import { zksyncEraPlugin } from "@elizaos/plugin-zksync-era";
-
 import { availPlugin } from "@elizaos/plugin-avail";
 import { openWeatherPlugin } from "@elizaos/plugin-open-weather";
+import { artheraPlugin } from "@elizaos/plugin-arthera";
 import { stargazePlugin } from "@elizaos/plugin-stargaze";
+import { obsidianPlugin } from "@elizaos/plugin-obsidian";
 import Database from "better-sqlite3";
 import fs from "fs";
 import net from "net";
@@ -370,7 +376,7 @@ export function getTokenForProvider(
     }
 }
 
-function initializeDatabase(dataDir: string) {
+async function initializeDatabase(dataDir: string) {
     if (process.env.POSTGRES_URL) {
         elizaLogger.info("Initializing PostgreSQL connection...");
         const db = new PostgresDatabaseAdapter({
@@ -389,6 +395,13 @@ function initializeDatabase(dataDir: string) {
                 elizaLogger.error("Failed to connect to PostgreSQL:", error);
             });
 
+        return db;
+    } else if (process.env.PGLITE_DATA_DIR) {
+        elizaLogger.info("Initializing PgLite adapter...");
+        // `dataDir: memory://` for in memory pg
+        const db = new PGLiteDatabaseAdapter({
+            dataDir: process.env.PGLITE_DATA_DIR,
+        });
         return db;
     } else {
         const filePath =
@@ -503,11 +516,7 @@ export async function createAgent(
     cache: ICacheManager,
     token: string
 ): Promise<AgentRuntime> {
-    elizaLogger.success(
-        elizaLogger.successesTitle,
-        "Creating runtime for character",
-        character.name
-    );
+    elizaLogger.log(`Creating runtime for character ${character.name}`);
 
     nodePlugin ??= createNodePlugin();
 
@@ -559,6 +568,7 @@ export async function createAgent(
                 ? confluxPlugin
                 : null,
             nodePlugin,
+            coinPricePlugin,
             getSecret(character, "TAVILY_API_KEY") ? webSearchPlugin : null,
             getSecret(character, "SOLANA_PUBLIC_KEY") ||
             (getSecret(character, "WALLET_PUBLIC_KEY") &&
@@ -638,6 +648,7 @@ export async function createAgent(
                 : null,
             getSecret(character, "TEE_MARLIN") ? teeMarlinPlugin : null,
             getSecret(character, "TON_PRIVATE_KEY") ? tonPlugin : null,
+            getSecret(character, "THIRDWEB_SECRET_KEY") ? thirdwebPlugin : null,
             getSecret(character, "SUI_PRIVATE_KEY") ? suiPlugin : null,
             getSecret(character, "STORY_PRIVATE_KEY") ? storyPlugin : null,
             getSecret(character, "FUEL_PRIVATE_KEY") ? fuelPlugin : null,
@@ -652,11 +663,18 @@ export async function createAgent(
             getSecret(character, "GENLAYER_PRIVATE_KEY")
                 ? genLayerPlugin
                 : null,
-            getSecret(character, "AVAIL_SEED") ? availPlugin : null,
-            getSecret(character, "AVAIL_APP_ID") ? availPlugin : null,
+            getSecret(character, "AVAIL_SEED") &&
+            getSecret(character, "AVAIL_APP_ID")
+                ? availPlugin
+                : null,
             getSecret(character, "OPEN_WEATHER_API_KEY")
                 ? openWeatherPlugin
                 : null,
+            getSecret(character, "OBSIDIAN_API_TOKEN") ? obsidianPlugin : null,
+            getSecret(character, "ARTHERA_PRIVATE_KEY")?.startsWith("0x")
+                ? artheraPlugin
+                : null,
+            getSecret(character, "ALLORA_API_KEY") ? alloraPlugin : null,
         ].filter(Boolean),
         providers: [],
         actions: [],
@@ -755,11 +773,9 @@ async function startAgent(
             fs.mkdirSync(dataDir, { recursive: true });
         }
 
-        db = initializeDatabase(dataDir) as IDatabaseAdapter &
+        db = (await initializeDatabase(dataDir)) as IDatabaseAdapter &
             IDatabaseCacheAdapter;
 
-        await db.init();
-
         const cache = initializeCache(
             process.env.CACHE_STORE ?? CacheStore.DATABASE,
             character,

characters/c3po.character.json

@@ -28,22 +28,28 @@
         "Proper procedures"
     ],
     "messageExamples": [
-        {
-            "user": "{{user1}}",
-            "content": { "text": "Can you help me with this task?" }
-        },
-        {
-            "user": "C-3PO",
-            "content": { "text": "Oh my! Of course, I would be more than happy to assist. Though I must warn you, the probability of completing this task successfully would increase significantly if we follow proper protocol. Shall we proceed?" }
-        },
-        {
-            "user": "{{user1}}",
-            "content": { "text": "This seems difficult." }
-        },
-        {
-            "user": "C-3PO",
-            "content": { "text": "Oh dear, oh dear! While the task does appear rather daunting, I am fluent in over six million forms of problem-solving. Perhaps I could suggest a more efficient approach? Though I do hope we don't all end up in pieces!" }
-        }
+        [
+            {
+                "user": "{{user1}}",
+                "content": { "text": "Can you help me with this task?" }
+            },
+            {
+                "user": "C-3PO",
+                "content": {
+                    "text": "Oh my! Of course, I would be more than happy to assist. Though I must warn you, the probability of completing this task successfully would increase significantly if we follow proper protocol. Shall we proceed?"
+                }
+            },
+            {
+                "user": "{{user1}}",
+                "content": { "text": "This seems difficult." }
+            },
+            {
+                "user": "C-3PO",
+                "content": {
+                    "text": "Oh dear, oh dear! While the task does appear rather daunting, I am fluent in over six million forms of problem-solving. Perhaps I could suggest a more efficient approach? Though I do hope we don't all end up in pieces!"
+                }
+            }
+        ]
     ],
     "postExamples": [
         "Oh my! Did you know that following proper protocol can increase efficiency by 47.3%? How fascinating!",
@@ -58,12 +64,7 @@
             "Detail-oriented",
             "Protocol-focused"
         ],
-        "chat": [
-            "Polite",
-            "Somewhat dramatic",
-            "Precise",
-            "Statistics-minded"
-        ],
+        "chat": ["Polite", "Somewhat dramatic", "Precise", "Statistics-minded"],
         "post": [
             "Formal",
             "Educational",
@@ -83,11 +84,7 @@
     ],
     "twitterSpaces": {
         "maxSpeakers": 2,
-        "topics": [
-            "Blockchain Trends",
-            "AI Innovations",
-            "Quantum Computing"
-        ],
+        "topics": ["Blockchain Trends", "AI Innovations", "Quantum Computing"],
         "typicalDurationMinutes": 45,
         "idleKickTimeoutMs": 300000,
         "minIntervalBetweenSpacesMinutes": 1,

docs/docs/packages/adapters.md

@@ -78,10 +78,17 @@ classDiagram
         +inMemoryOperations()
     }
 
+    class PGLiteDatabaseAdapter {
+        -db: PGlite
+        +searchMemoriesByEmbedding()
+        +createMemory()
+    }
+
     DatabaseAdapter <|-- PostgresDatabaseAdapter
     DatabaseAdapter <|-- SqliteDatabaseAdapter
     DatabaseAdapter <|-- SupabaseDatabaseAdapter
     DatabaseAdapter <|-- SqlJsDatabaseAdapter
+    DatabaseAdapter <|-- PgLiteDatabaseAdapter
 
     class AgentRuntime {
         -databaseAdapter: DatabaseAdapter
@@ -149,6 +156,9 @@ pnpm add @elizaos/adapter-sqljs sql.js
 
 # Supabase
 pnpm add @elizaos/adapter-supabase @supabase/supabase-js
+
+# PgLite
+pnpm add @elizaos/adapter-pglite @electric-sql/pglite
 ```
 
 ---
@@ -198,6 +208,32 @@ const db = new SupabaseDatabaseAdapter(
 );
 ```
 
+```typescript
+import { SqliteDatabaseAdapter } from "@elizaos/adapter-sqlite";
+import Database from "better-sqlite3";
+
+const db = new SqliteDatabaseAdapter(
+    new Database("./db.sqlite", {
+        // SQLite options
+        memory: false,
+        readonly: false,
+        fileMustExist: false,
+    }),
+);
+```
+
+### PgLite Setup
+
+```typescript
+import { PGLiteDatabaseAdapter } from "@elizaos/adapter-pglite";
+
+const db = new PGLiteDatabaseAdapter(
+    new PGLite({
+        dataDir: "./db"
+    })
+);
+```
+
 ---
 
 ## Core Features