hotfix for runtime context (context lost at the end of debug session)

Author: alaa-eddine

packages/core/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@smythos/sre",
-    "version": "1.5.57",
+    "version": "1.5.60",
     "description": "Smyth Runtime Environment",
     "author": "Alaa-eddine KADDOURI",
     "license": "MIT",

packages/core/src/subsystems/MemoryManager/RuntimeContext.ts

@@ -147,6 +147,25 @@ export class RuntimeContext extends EventEmitter {
 
         const deleteSession = this.runtime.sessionClosed;
 
+        //TODO : Do we need to cache the context if not in debug mode ?
+
+        const data = this.serialize();
+        //if (data) fs.writeFileSync(this.ctxFile, JSON.stringify(data, null, 2));
+        if (data) {
+            let serializedData = JSON.stringify(data);
+            console.debug('Agent Context Size', this.ctxFile, serializedData.length, AccessCandidate.agent(this.runtime.agent.id));
+
+            await this._cacheConnector
+                .requester(AccessCandidate.agent(this.runtime.agent.id))
+                .set(this.ctxFile, serializedData, null, null, 3 * 60 * 60); //expires in 3 hours max
+
+            const mb = serializedData.length / 1024 / 1024;
+            const cooldown = (mb / 10) * 1000;
+            serializedData = null;
+
+            await delay(cooldown);
+        }
+
         if (deleteSession) {
             const exists = await this._cacheConnector.requester(AccessCandidate.agent(this.runtime.agent.id)).exists(this.ctxFile);
 
@@ -159,33 +178,18 @@ export class RuntimeContext extends EventEmitter {
                 //if (fs.existsSync(this.ctxFile)) fs.unlinkSync(this.ctxFile);
                 this.ctxFile = null;
             }
-        } else {
-            //TODO : Do we need to cache the context if not in debug mode ?
-
-            const data = this.serialize();
-            //if (data) fs.writeFileSync(this.ctxFile, JSON.stringify(data, null, 2));
-            if (data) {
-                let serializedData = JSON.stringify(data);
-                console.debug('Agent Context Size', this.ctxFile, serializedData.length, AccessCandidate.agent(this.runtime.agent.id));
-
-                await this._cacheConnector
-                    .requester(AccessCandidate.agent(this.runtime.agent.id))
-                    .set(this.ctxFile, serializedData, null, null, 3 * 60 * 60); //expires in 3 hours max
-
-                const mb = serializedData.length / 1024 / 1024;
-                const cooldown = (mb / 10) * 1000;
-                serializedData = null;
-
-                await delay(cooldown);
-            }
         }
     }
     private _syncQueue = Promise.resolve();
 
     public enqueueSync() {
         if (!this.ctxFile) return;
         console.log('ENQUEUE SYNC');
-        this._syncQueue = this._syncQueue.then(() => this.sync()).catch(() => {}); // avoid unhandled rejections
+        this._syncQueue = this._syncQueue
+            .then(() => this.sync())
+            .catch((err) => {
+                console.error('Error syncing context', err);
+            }); // avoid unhandled rejections
     }
     public incStep() {
         this.step++;