now the memory manager is being loaded

Author: mike dupont

.github/workflows/ci.yaml

@@ -8,7 +8,7 @@ jobs:
     check:
         runs-on: ubuntu-latest
         env:
-            OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
+            OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY  }}
             TURBO_TOKEN: ${{ secrets.TURBO_TOKEN }}
             TURBO_TEAM: ${{ vars.TURBO_TEAM }}
             TURBO_REMOTE_ONLY: true

pnpm-lock.yaml

@@ -12,7 +12,8 @@
         "start": "node dist/index.js",
         "dbg": "node --inspect-brk --loader ts-node/esm src/index.ts",
         "dbg2": "node --inspect --loader ts-node/esm src/index.ts",
-        "ts": "node --trace-warnings --trace-deprecation  --loader ts-node/esm src/index.ts",
+        "dbg3": "npx --node-options=--inspect-brk  tsx ./src/index",
+        "ts": "npx tsx src/index",
         "clean": "rm -rf node_modules dist"
     },
     "keywords": [],

scripts/jsdoc-automation/package.json

@@ -1,4 +1,4 @@
-import dotenv from "dotenv";
+import * as dotenv from "dotenv";
 const de = dotenv.config();
 console.log("DEBUG",de)
 
@@ -49,6 +49,8 @@ import {
     stringToUuid,
     getEmbeddingZeroVector,
     composeActionExamples,
+    MemoryManager,
+    IMemoryManager,
     // validateCharacterConfig,
 } from "@elizaos/core";
 //import { defaultCharacter } from "./defaultCharacter.ts";
@@ -129,6 +131,7 @@ Response format should be formatted in a JSON block like this:
 // import { TypeScriptParser } from "../TypeScriptParser.js";
 // This is the retriever we will use in RAG
 import { CodeFormatter } from "./utils/CodeFormatter.js";
+import { run } from "node:test";
 //import { CustomErrorParams, InputTypeOfTupleWithRest, IssueData, OutputTypeOfTupleWithRest, ParseParams, ParsePathComponent, ParseStatus, RefinementCtx, RefinementEffect, SafeParseReturnType, z, ZodBranded, ZodCatch, ZodCustomIssue, ZodDefault, ZodEffects, ZodError, ZodIntersection, ZodInvalidArgumentsIssue, ZodInvalidDateIssue, ZodInvalidEnumValueIssue, ZodInvalidIntersectionTypesIssue, ZodInvalidLiteralIssue, ZodInvalidReturnTypeIssue, ZodInvalidStringIssue, ZodInvalidUnionDiscriminatorIssue, ZodInvalidUnionIssue, ZodIssueBase, ZodIssueCode, ZodNotFiniteIssue, ZodNotMultipleOfIssue, ZodOptionalDef, ZodParsedType, ZodPipeline, ZodPromise, ZodReadonly, ZodTooBigIssue, ZodTooSmallIssue, ZodTupleDef, ZodUnion, ZodUnrecognizedKeysIssue } from "zod";
 //import { StructuredToolInterface, StructuredToolParams } from "@langchain/core/tools.js";
 //import { ToolChoice } from "@langchain/core/language_models/chat_models.js";
@@ -175,9 +178,10 @@ export class AIService {
     private chatModel: ChatWrapper; //<ChatOpenAICallOptions>
     private codeFormatter: CodeFormatter;
     private chatModelFAQ: ChatWrapper;// <ChatOpenAICallOptions>
-    //runtime: AgentRuntime;
+    
     private agents: Map<string, IAgentRuntime>; // container management
     runtime: AgentRuntime;
+    knowledgeManager: IMemoryManager;
 
     /**
      * Constructor for initializing the ChatOpenAI instance.
@@ -213,51 +217,36 @@ export class AIService {
 	//				this.chatModelFAQ = new FakeListChatModel({	    responses: []        });
         this.codeFormatter = new CodeFormatter();
 
+     
+
         this.agents = new Map();
         const token = "token";
         const character = defaultCharacter;
+    
+
         this.runtime = new AgentRuntime({token,
             modelProvider: character.modelProvider,
             evaluators: [],
             character,
+            
             // character.plugins are handled when clients are added
             plugins: [bootstrapPlugin].flat().filter(Boolean),
             providers: [],
-            managers: [],
+            managers: [ 
+                // memeory menages
+
+            ],
             fetch: logFetch,})
-        //{
-    //         agentId: "00000000-0000-0000-0000-000000000000",
-    //         serverUrl: "http://localhost",
-    //         databaseAdapter: {} as IDatabaseAdapter,
-    //         token: "token",
-    //         function getMemoryManager(manager: string): IMemoryManager | null {
-    //             if (manager === 'someCondition') {
-    //               return {
-    //                 runtime: 'someRuntime',
-    //                 tableName: 'someTableName',
-    //                 getMemories: async () => {
-    //                   // Implementation here
-    //                   return [];
-    //                 },
-    //                 getCachedEmbeddings: async () => {
-    //                   // Implementation here
-    //                   return [];
-    //                 },
-    //                 addEmbeddingToMemory: async (data: any) => {
-    //                   // Implementation here
-    //                   return {};
-    //                 },
-    //                 createMemory: async (memory: any) => {
-    //                   // Implementation here
-    //                 },
-    //                 // Add other properties and methods as required
-    //               };
-    //             }
-    //             return null;
-    //           }
-    //     };
-    // }
-    }
+            this.knowledgeManager = new MemoryManager({
+                  runtime: this.runtime,
+                  tableName: "lore",
+              });
+              console.log("KM",this.runtime.knowledgeManager)
+              console.log("Before",this.runtime.memoryManagers)
+              this.runtime.memoryManagers.set(this.runtime.knowledgeManager.tableName, this.runtime.knowledgeManager);
+              console.log("After",this.runtime.memoryManagers)
+        }
+        
 
     /**
      * Generates a comment based on the specified prompt by invoking the chat model.
@@ -278,32 +267,14 @@ export class AIService {
 
                 //characters = new Character()               
 
-                let runtime = this.agents.get(agentId);
+                //let runtime = this.agents.get(agentId);
+                let runtime = this.runtime;
                 if (!runtime) {
-                    const character = defaultCharacter;
-                    runtime = new AgentRuntime({
-                        token,
-        modelProvider: character.modelProvider,
-        evaluators: [],
-        character,
-        // character.plugins are handled when clients are added
-        plugins: [
-            //bootstrapPlugin
-            ].flat().filter(Boolean),
-        providers: [],
-        managers: [],
-       // fetch: logFetch,
-                       // agentId: agentId,
-                       // serverUrl: "XXXXXXXXXXXXXXXX",
-                       // databaseAdapter: {} as IDatabaseAdapter,
-                       // token: "token",
-                       // modelProvider: "defaultModelProvider", // Add the modelProvider property
-                    });
                     this.agents.set(agentId, runtime);
                 }
                 if (runtime) {
                     console.log("Runtime found for agentId:", agentId);
-                    await processChunk(finalPrompt, "chat", runtime);
+                    await processChunk(finalPrompt, "fragments", runtime);
                 } else {                   
                     console.warn("No runtime found for agentId:", agentId);
                 }
@@ -333,12 +304,14 @@ export class AIService {
     }
 }
 
-async function processChunk(prompt: string, manager: string, runtime: IAgentRuntime): Promise<string> {
+async function processChunk(prompt: string, manager: string, runtime: AgentRuntime): Promise<string> {
     console.log("process chunk");
     try {
         const mm = runtime.getMemoryManager(manager);
         if (!mm) {
-            throw new Error("Memory manager not found");
+            console.log("manager",manager);
+            console.log("memoryManagers",runtime.memoryManagers);
+            throw new Error("Memory manager not found", manager);
         }
         const memory = await mm.addEmbeddingToMemory({
             agentId: runtime.agentId,
@@ -513,38 +486,38 @@ async function  process_text(this: any, agentId: string, userName: string, name:
     }
 }
 
-interface IMemoryManager {
-  runtime: string;
-  tableName: string;
-  getMemories: () => Promise<any[]>;
-  getCachedEmbeddings: () => Promise<any[]>;
-  addEmbeddingToMemory: (data: any) => Promise<{}>;
-  createMemory: (memory: any) => Promise<void>;
-  // Add other properties and methods as required
-}
-
-function getMemoryManager(manager: string): IMemoryManager | null {
-  if (manager === 'someCondition') {
-    return {
-      runtime: 'someRuntime',
-      tableName: 'someTableName',
-      getMemories: async () => {
-        // Implementation here
-        return [];
-      },
-      getCachedEmbeddings: async () => {
-        // Implementation here
-        return [];
-      },
-      addEmbeddingToMemory: async (data: any) => {
-        // Implementation here
-        return {};
-      },
-      createMemory: async (memory: any) => {
-        // Implementation here
-      },
-      // Add other properties and methods as required
-    };
-  }
-  return null;
-}
+// interface IMemoryManager {
+//   runtime: string;
+//   tableName: string;
+//   getMemories: () => Promise<any[]>;
+//   getCachedEmbeddings: () => Promise<any[]>;
+//   addEmbeddingToMemory: (data: any) => Promise<{}>;
+//   createMemory: (memory: any) => Promise<void>;
+//   // Add other properties and methods as required
+// }
+
+// function getMemoryManager(manager: string): IMemoryManager | null {
+//   if (manager === 'someCondition') {
+//     return {
+//       runtime: 'someRuntime',
+//       tableName: 'someTableName',
+//       getMemories: async () => {
+//         // Implementation here
+//         return [];
+//       },
+//       getCachedEmbeddings: async () => {
+//         // Implementation here
+//         return [];
+//       },
+//       addEmbeddingToMemory: async (data: any) => {
+//         // Implementation here
+//         return {};
+//       },
+//       createMemory: async (memory: any) => {
+//         // Implementation here
+//       },
+//       // Add other properties and methods as required
+//     };
+//   }
+//   return null;
+// }

scripts/jsdoc-automation/src/AIService/AIService.ts

@@ -12,6 +12,10 @@
         "noEmitOnError": true,
         //"noImplicitAny": true,
       //  "noImplicitReturns": true,
+       // "checkJs": true,
+        "diagnostics": true,
+        //"inlineSourceMap": true,
+        "inlineSources": true,
 
 	    "typeRoots":["./node_modules/@types"],
         "module": "NodeNext",

scripts/jsdoc-automation/tsconfig.json

@@ -10,6 +10,21 @@ export default defineConfig({
     target: "node20",
    // logErrors: true,
     minify: false,
+    minifyWhitespace: false,
+    minifySyntax: false,
+    minifyIdentifiers: false,
+    keepNames: true,
+    //watch: true,
+    bundle: true,
+    platform: "node",
+    metafile: true,
+    external: ["dotenv"],
+    //noExternal: ["dotenv"],
+    esbuildOptions: (options) => {
+        options.banner = {
+            js: `import { createRequire } from 'module';const require = createRequire(import.meta.url);`,
+        };
+    },
     outDir: "dist",
     treeshake: true,
 });