reduced calls to get secret rfom 39 to 35

still too many calls to get secret

Author: mike dupont

.env

@@ -1,40 +1,38 @@
 # Required environment variables
-DISCORD_APPLICATION_ID=
-DISCORD_API_TOKEN= # Bot token
+#DISCORD_APPLICATION_ID=
+#DISCORD_API_TOKEN= # Bot token
 #OPENAI_API_KEY=sk-* # OpenAI API key, starting with sk-
-REDPILL_API_KEY= # REDPILL API Key
-GROK_API_KEY= # GROK API Key
-GROQ_API_KEY=gsk_*
-OPENROUTER_API_KEY=
-GOOGLE_GENERATIVE_AI_API_KEY= # Gemini API key
+#REDPILL_API_KEY= # REDPILL API Key
+#GROK_API_KEY= # GROK API Key
+#GROQ_API_KEY=gsk_*
+#OPENROUTER_API_KEY=
+#GOOGLE_GENERATIVE_AI_API_KEY= # Gemini API key
 
-ELEVENLABS_XI_API_KEY= # API key from elevenlabs
+#ELEVENLABS_XI_API_KEY= # API key from elevenlabs
 
 # ELEVENLABS SETTINGS
-ELEVENLABS_MODEL_ID=eleven_multilingual_v2
-ELEVENLABS_VOICE_ID=21m00Tcm4TlvDq8ikWAM
-ELEVENLABS_VOICE_STABILITY=0.5
-ELEVENLABS_VOICE_SIMILARITY_BOOST=0.9
-ELEVENLABS_VOICE_STYLE=0.66
-ELEVENLABS_VOICE_USE_SPEAKER_BOOST=false
-ELEVENLABS_OPTIMIZE_STREAMING_LATENCY=4
-ELEVENLABS_OUTPUT_FORMAT=pcm_16000
-
-TWITTER_DRY_RUN=false
-TWITTER_USERNAME= # Account username
-TWITTER_PASSWORD= # Account password
-TWITTER_EMAIL= # Account email
-TWITTER_COOKIES= # Account cookies
-
-X_SERVER_URL=
-XAI_API_KEY=
-XAI_MODEL=
+#ELEVENLABS_MODEL_ID=eleven_multilingual_v2
+#ELEVENLABS_VOICE_ID=21m00Tcm4TlvDq8ikWAM
+#ELEVENLABS_VOICE_STABILITY=0.5
+#ELEVENLABS_VOICE_SIMILARITY_BOOST=0.9
+#ELEVENLABS_VOICE_STYLE=0.66
+#ELEVENLABS_VOICE_USE_SPEAKER_BOOST=false
+#ELEVENLABS_OPTIMIZE_STREAMING_LATENCY=4
+#ELEVENLABS_OUTPUT_FORMAT=pcm_16000
+
+#TWITTER_DRY_RUN=false
+#TWITTER_USERNAME= # Account username
+#TWITTER_PASSWORD= # Account password
+#TWITTER_EMAIL= # Account email
+#TWITTER_COOKIES= # Account cookies
+
+#X_SERVER_URL=
+#XAI_API_KEY=
+#XAI_MODEL=
 
 #POST INTERVAL RANDOM MIN-MAX MINUTES
 POST_INTERVAL_MIN=  #90 #Default
 POST_INTERVAL_MAX= #180 #Default
-
-
 #USE IMAGE GEN
 IMAGE_GEN= #TRUE
 
@@ -43,12 +41,10 @@ IMAGE_GEN= #TRUE
 
 #OpenRouter (Use one model for everything or set individual for small, medium, large tasks)
 #leave blank to use defaults hermes 70b for small tasks & 405b for medium/large tasks
-OPENROUTER_MODEL=
-SMALL_OPENROUTER_MODEL=
+#OPENROUTER_MODEL=
+#SMALL_OPENROUTER_MODEL=
 MEDIUM_OLLAMA_MODEL=
 LARGE_OLLAMA_MODEL=
-
-
 #Set to Use for New OLLAMA provider
 #OLLAMA_SERVER_URL=   #Leave blank for default localhost:11434
 OLLAMA_MODEL=temp1
@@ -59,34 +55,34 @@ MEDIUM_OLLAMA_MODEL=        #default herems3
 LARGE_OLLAMA_MODEL=         #default hermes3:70b
 
 # For asking Claude stuff
-ANTHROPIC_API_KEY=
+#ANTHROPIC_API_KEY=
 
 # Heurist API (Get API Key at https://heurist.ai/dev-access)
-HEURIST_API_KEY=
-SMALL_HEURIST_LANGUAGE_MODEL=
-MEDIUM_HEURIST_LANGUAGE_MODEL=
-LARGE_HEURIST_LANGUAGE_MODEL=
-HEURIST_IMAGE_MODEL=
+#HEURIST_API_KEY=
+#SMALL_HEURIST_LANGUAGE_MODEL=
+#MEDIUM_HEURIST_LANGUAGE_MODEL=
+#LARGE_HEURIST_LANGUAGE_MODEL=
+#HEURIST_IMAGE_MODEL=
 
-WALLET_PRIVATE_KEY=EXAMPLE_WALLET_PRIVATE_KEY
-WALLET_PUBLIC_KEY=EXAMPLE_WALLET_PUBLIC_KEY
+#WALLET_PRIVATE_KEY=EXAMPLE_WALLET_PRIVATE_KEY
+#WALLET_PUBLIC_KEY=EXAMPLE_WALLET_PUBLIC_KEY
 
-BIRDEYE_API_KEY=
+#BIRDEYE_API_KEY=
 
-SOL_ADDRESS=So11111111111111111111111111111111111111112
-SLIPPAGE=1
-BASE_MINT=So11111111111111111111111111111111111111112
-RPC_URL=https://api.mainnet-beta.solana.com
-HELIUS_API_KEY=
+#SOL_ADDRESS=So11111111111111111111111111111111111111112
+#SLIPPAGE=1
+#BASE_MINT=So11111111111111111111111111111111111111112
+#RPC_URL=https://api.mainnet-beta.solana.com
+#HELIUS_API_KEY=
 
 
 ## Telegram
-TELEGRAM_BOT_TOKEN=
+#TELEGRAM_BOT_TOKEN=
 
-TOGETHER_API_KEY=
+#TOGETHER_API_KEY=
 SERVER_PORT=3000
 VERBOSE=true
 NODE_ENV=dev
 # Starknet
-STARKNET_ADDRESS=
-STARKNET_PRIVATE_KEY=
+#STARKNET_ADDRESS=
+#STARKNET_PRIVATE_KEY=

agent/src/index.ts

@@ -21,6 +21,7 @@ import { HttpInstrumentation } from '@opentelemetry/instrumentation-http';
 import { wrapTracer } from '@opentelemetry/api/experimental';
 
 //Specify zipkin url. default url is http://localhost:9411/api/v2/spans
+// docker run -d -p 9411:9411 openzipkin/zipkin
 const zipkinUrl = 'http://localhost';
 const zipkinPort = '9411';
 const zipkinPath = '/api/v2/spans';
@@ -89,24 +90,10 @@ try {
 } catch(error){
   elizaLogger.log("ERROR",error)
 }
-// const sdk = new NodeSDK({         resource: new Resource({
-
-//const tracer=opentelemetry.trace.getTracer('ai16z');
-
-
 
+// wrapper
 const tracer = wrapTracer(opentelemetry.trace.getTracer('ai16z-agent'))
 
-//     //traceExporter: new ConsoleSpanExporter(),
-//     traceExporter: myExporter,
-//     //traceExporter_zipkin
-//     instrumentations: [, new HttpInstrumentation()     ],
-// });
-// // For troubleshooting, set the log level to DiagLogLevel.DEBUG
-// diag.setLogger(new DiagConsoleLogger(), DiagLogLevel.ALL);
-// console.log(sdk.start());
-
-
 import { PostgresDatabaseAdapter } from "@elizaos/adapter-postgres";
 import { SqliteDatabaseAdapter } from "@elizaos/adapter-sqlite";
 import { AutoClientInterface } from "@elizaos/client-auto";
@@ -220,7 +207,7 @@ export function parseArguments(): {
 
 function tryLoadFile(filePath: string): string | null {
   elizaLogger.log(`tryLoadFile filePath: ${filePath}`);
-  return tracer.withActiveSpan('tryLoadFile', () => {
+  return tracer.withActiveSpan(`tryLoadFile filePath: ${filePath}`, () => {
     try {
       const ret = fs.readFileSync(filePath, "utf8");
       return ret;
@@ -473,6 +460,7 @@ export function getTokenForProvider(
 }
 
 function initializeDatabase(dataDir: string) {
+  return tracer.withActiveSpan('initializeDatabase', () => {
     if (process.env.POSTGRES_URL) {
         elizaLogger.info("Initializing PostgreSQL connection...");
         const db = new PostgresDatabaseAdapter({
@@ -499,13 +487,16 @@ function initializeDatabase(dataDir: string) {
         const db = new SqliteDatabaseAdapter(new Database(filePath));
         return db;
     }
+  })
 }
 
 // also adds plugins from character file into the runtime
 export async function initializeClients(
     character: Character,
     runtime: IAgentRuntime
 ) {
+
+  return await tracer.withActiveSpan('initializeClients', async () => {
     // each client can only register once
     // and if we want two we can explicitly support it
     const clients: Record<string, any> = {};
@@ -590,11 +581,15 @@ export async function initializeClients(
         }
     }
 
+
     return clients;
+  });
 }
 
 function getSecret(character: Character, secret: string) {
-    return character.settings?.secrets?.[secret] || process.env[secret];
+    return tracer.withActiveSpan('getSecret', () => {
+      return character.settings?.secrets?.[secret] || process.env[secret];
+    });
 }
 
 let nodePlugin: any | undefined;
@@ -605,6 +600,8 @@ export async function createAgent(
     cache: ICacheManager,
     token: string
 ): Promise<AgentRuntime> {
+  return await tracer.withActiveSpan('createAgent', async () => {
+
     elizaLogger.success(
         elizaLogger.successesTitle,
         "Creating runtime for character",
@@ -727,18 +724,23 @@ export async function createAgent(
         cacheManager: cache,
         fetch: logFetch,
     });
+  });
 }
 
-function initializeFsCache(baseDir: string, character: Character) {
+  function initializeFsCache(baseDir: string, character: Character) {
+    return tracer.withActiveSpan('initializeFsCache', () => {
     const cacheDir = path.resolve(baseDir, character.id, "cache");
 
     const cache = new CacheManager(new FsCacheAdapter(cacheDir));
-    return cache;
+      return cache;
+    });
 }
 
-function initializeDbCache(character: Character, db: IDatabaseCacheAdapter) {
-    const cache = new CacheManager(new DbCacheAdapter(db, character.id));
-    return cache;
+  function initializeDbCache(character: Character, db: IDatabaseCacheAdapter) {
+    return tracer.withActiveSpan('initializeDbCache', () => {
+        const cache = new CacheManager(new DbCacheAdapter(db, character.id));
+        return cache;
+      });
 }
 
 function initializeCache(
@@ -747,6 +749,7 @@ function initializeCache(
     baseDir?: string,
     db?: IDatabaseCacheAdapter
 ) {
+  return tracer.withActiveSpan('initializeCache', () => {
     switch (cacheStore) {
         case CacheStore.REDIS:
             if (process.env.REDIS_URL) {
@@ -778,12 +781,14 @@ function initializeCache(
                 `Invalid cache store: ${cacheStore} or required configuration missing.`
             );
     }
+  });
 }
 
 async function startAgent(
     character: Character,
     directClient: DirectClient
 ): Promise<AgentRuntime> {
+
     let db: IDatabaseAdapter & IDatabaseCacheAdapter;
     try {
         character.id ??= stringToUuid(character.name);