@@ -11,8 +11,10 @@ import { SlackClientInterface } from "@elizaos/client-slack";
1111import { TelegramClientInterface } from "@elizaos/client-telegram" ;
1212import { TwitterClientInterface } from "@elizaos/client-twitter" ;
1313import { FarcasterClientInterface } from "@elizaos/client-farcaster" ;
14+ import { DirectClient } from "@elizaos/client-direct" ;
1415// import { ReclaimAdapter } from "@elizaos/plugin-reclaim";
1516import { PrimusAdapter } from "@elizaos/plugin-primus" ;
17+ import { elizaCodeinPlugin , onchainJson } from "@elizaos/plugin-iq6900" ;
1618
1719import {
1820 AgentRuntime ,
@@ -40,7 +42,6 @@ import { zgPlugin } from "@elizaos/plugin-0g";
4042import { bootstrapPlugin } from "@elizaos/plugin-bootstrap" ;
4143import createGoatPlugin from "@elizaos/plugin-goat" ;
4244// import { intifacePlugin } from "@elizaos/plugin-intiface";
43- import { DirectClient } from "@elizaos/client-direct" ;
4445import { ThreeDGenerationPlugin } from "@elizaos/plugin-3d-generation" ;
4546import { abstractPlugin } from "@elizaos/plugin-abstract" ;
4647import { akashPlugin } from "@elizaos/plugin-akash" ;
@@ -102,6 +103,7 @@ import { thirdwebPlugin } from "@elizaos/plugin-thirdweb";
102103import { hyperliquidPlugin } from "@elizaos/plugin-hyperliquid" ;
103104import { echoChambersPlugin } from "@elizaos/plugin-echochambers" ;
104105import { dexScreenerPlugin } from "@elizaos/plugin-dexscreener" ;
106+ import { pythDataPlugin } from "@elizaos/plugin-pyth-data" ;
105107
106108import { zksyncEraPlugin } from "@elizaos/plugin-zksync-era" ;
107109import Database from "better-sqlite3" ;
@@ -111,7 +113,6 @@ import path from "path";
111113import { fileURLToPath } from "url" ;
112114import yargs from "yargs" ;
113115
114-
115116const __filename = fileURLToPath ( import . meta. url ) ; // get the resolved path to the file
116117const __dirname = path . dirname ( __filename ) ; // get the name of the directory
117118
@@ -189,6 +190,63 @@ function mergeCharacters(base: Character, child: Character): Character {
189190 } ;
190191 return mergeObjects ( base , child ) ;
191192}
193+ function isAllStrings ( arr : unknown [ ] ) : boolean {
194+ return Array . isArray ( arr ) && arr . every ( ( item ) => typeof item === "string" ) ;
195+ }
196+ export async function loadCharacterFromOnchain ( ) : Promise < Character [ ] > {
197+ const jsonText = onchainJson ;
198+
199+ console . log ( "JSON:" , jsonText ) ;
200+ if ( jsonText == "null" ) return [ ] ;
201+ const loadedCharacters = [ ] ;
202+ try {
203+ const character = JSON . parse ( jsonText ) ;
204+ validateCharacterConfig ( character ) ;
205+
206+ // .id isn't really valid
207+ const characterId = character . id || character . name ;
208+ const characterPrefix = `CHARACTER.${ characterId . toUpperCase ( ) . replace ( / / g, "_" ) } ;
209+
210+ const characterSettings = Object . entries ( process . env )
211+ . filter ( ( [ key ] ) => key . startsWith ( characterPrefix ) )
212+ . reduce ( ( settings , [ key , value ] ) => {
213+ const settingKey = key . slice ( characterPrefix . length ) ;
214+ settings [ settingKey ] = value ;
215+ return settings ;
216+ } , { } ) ;
217+
218+ if ( Object . keys ( characterSettings ) . length > 0 ) {
219+ character . settings = character . settings || { } ;
220+ character . settings . secrets = {
221+ ...characterSettings ,
222+ ...character . settings . secrets ,
223+ } ;
224+ }
225+
226+ // Handle plugins
227+ if ( isAllStrings ( character . plugins ) ) {
228+ elizaLogger . info ( "Plugins are: " , character . plugins ) ;
229+ const importedPlugins = await Promise . all (
230+ character . plugins . map ( async ( plugin ) => {
231+ const importedPlugin = await import ( plugin ) ;
232+ return importedPlugin . default ;
233+ } )
234+ ) ;
235+ character . plugins = importedPlugins ;
236+ }
237+
238+ loadedCharacters . push ( character ) ;
239+ elizaLogger . info (
240+ `Successfully loaded character from: ${ process . env . IQ_WALLET_ADDRESS }
241+ ) ;
242+ return loadedCharacters ;
243+ } catch ( e ) {
244+ elizaLogger . error (
245+ `Error parsing character from ${ process . env . IQ_WALLET_ADDRESS } ${ e }
246+ ) ;
247+ process . exit ( 1 ) ;
248+ }
249+ }
192250
193251async function loadCharacterFromUrl ( url : string ) : Promise < Character > {
194252 const response = await fetch ( url ) ;
@@ -247,14 +305,13 @@ async function loadCharacter(filePath: string): Promise<Character> {
247305}
248306
249307function commaSeparatedStringToArray ( commaSeparated : string ) : string [ ] {
250- return commaSeparated ?. split ( "," ) . map ( value => value . trim ( ) )
308+ return commaSeparated ?. split ( "," ) . map ( ( value ) => value . trim ( ) ) ;
251309}
252310
253-
254311export async function loadCharacters (
255312 charactersArg : string
256313) : Promise < Character [ ] > {
257- let characterPaths = commaSeparatedStringToArray ( charactersArg )
314+ let characterPaths = commaSeparatedStringToArray ( charactersArg ) ;
258315 const loadedCharacters : Character [ ] = [ ] ;
259316
260317 if ( characterPaths ?. length > 0 ) {
@@ -328,7 +385,9 @@ export async function loadCharacters(
328385
329386 if ( hasValidRemoteUrls ( ) ) {
330387 elizaLogger . info ( "Loading characters from remote URLs" ) ;
331- let characterUrls = commaSeparatedStringToArray ( process . env . REMOTE_CHARACTER_URLS )
388+ let characterUrls = commaSeparatedStringToArray (
389+ process . env . REMOTE_CHARACTER_URLS
390+ ) ;
332391 for ( const characterUrl of characterUrls ) {
333392 const character = await loadCharacterFromUrl ( characterUrl ) ;
334393 loadedCharacters . push ( character ) ;
@@ -784,6 +843,10 @@ export async function createAgent(
784843 character,
785844 // character.plugins are handled when clients are added
786845 plugins : [
846+ getSecret ( character , "IQ_WALLET_ADDRESS" ) &&
847+ getSecret ( character , "IQSOlRPC" )
848+ ? elizaCodeinPlugin
849+ : null ,
787850 bootstrapPlugin ,
788851 getSecret ( character , "DEXSCREENER_API_KEY" )
789852 ? dexScreenerPlugin
@@ -812,8 +875,9 @@ export async function createAgent(
812875 getSecret ( character , "WALLET_PUBLIC_KEY" ) ?. startsWith ( "0x" ) )
813876 ? evmPlugin
814877 : null ,
815- ( ( getSecret ( character , "EVM_PUBLIC_KEY" ) || getSecret ( character , "INJECTIVE_PUBLIC_KEY" ) ) &&
816- getSecret ( character , "INJECTIVE_PRIVATE_KEY" ) )
878+ ( getSecret ( character , "EVM_PUBLIC_KEY" ) ||
879+ getSecret ( character , "INJECTIVE_PUBLIC_KEY" ) ) &&
880+ getSecret ( character , "INJECTIVE_PRIVATE_KEY" )
817881 ? injectivePlugin
818882 : null ,
819883 getSecret ( character , "COSMOS_RECOVERY_PHRASE" ) &&
@@ -955,6 +1019,10 @@ export async function createAgent(
9551019 getSecret ( character , "RESERVOIR_API_KEY" )
9561020 ? createNFTCollectionsPlugin ( )
9571021 : null ,
1022+ getSecret ( character , "PYTH_TESTNET_PROGRAM_KEY" ) ||
1023+ getSecret ( character , "PYTH_MAINNET_PROGRAM_KEY" )
1024+ ? pythDataPlugin
1025+ : null ,
9581026 ] . filter ( Boolean ) ,
9591027 providers : [ ] ,
9601028 actions : [ ] ,
@@ -1116,21 +1184,23 @@ const checkPortAvailable = (port: number): Promise<boolean> => {
11161184 } ) ;
11171185} ;
11181186
1119-
11201187const hasValidRemoteUrls = ( ) =>
11211188 process . env . REMOTE_CHARACTER_URLS &&
11221189 process . env . REMOTE_CHARACTER_URLS !== "" &&
11231190 process . env . REMOTE_CHARACTER_URLS . startsWith ( "http" ) ;
11241191
1125-
11261192const startAgents = async ( ) => {
11271193 const directClient = new DirectClient ( ) ;
11281194 let serverPort = parseInt ( settings . SERVER_PORT || "3000" ) ;
11291195 const args = parseArguments ( ) ;
11301196 let charactersArg = args . characters || args . character ;
11311197 let characters = [ defaultCharacter ] ;
11321198
1133- if ( charactersArg || hasValidRemoteUrls ( ) ) {
1199+ if ( process . env . IQ_WALLET_ADDRESS && process . env . IQSOlRPC ) {
1200+ characters = await loadCharacterFromOnchain ( ) ;
1201+ }
1202+
1203+ if ( ( onchainJson == "null" && charactersArg ) || hasValidRemoteUrls ( ) ) {
11341204 characters = await loadCharacters ( charactersArg ) ;
11351205 }
11361206
0 commit comments