feat(memory): Stage E Phase 4.2 - encode() routes through typed-network observer

CognitiveMemoryManager.encode() now invokes TypedNetworkObserver.extract()
after the standard trace creation when typed-network is configured.
Resulting facts are namespaced by the parent trace ID and persisted
into the manager's TypedNetworkStore.

Best-effort: extraction failures are logged to stderr but do not abort
the encode call. The standard trace lifecycle is unaffected when
typed-network is not configured (zero-cost no-op).

Author: jddunn

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@framers/agentos",
-  "version": "0.3.2",
+  "version": "0.3.3",
   "description": "Modular AgentOS orchestration library",
   "type": "module",
   "main": "dist/index.js",

src/memory/CognitiveMemoryManager.ts

@@ -598,6 +598,24 @@ export class CognitiveMemoryManager implements ICognitiveMemoryManager {
       });
     }
 
+    // --- Stage E: typed-network extraction (optional) ---
+    // Routes the encoded content through the LLM observer to produce 0+
+    // typed facts (W/E/O/S banks). Facts are namespaced by the parent
+    // trace ID so they can be cross-referenced at retrieval time. Best
+    // effort: extraction failures are logged via stderr but do not abort
+    // the encode (the trace is already persisted at this point).
+    if (this.typedNetworkObserver && this.typedNetworkStore) {
+      try {
+        const facts = await this.typedNetworkObserver.extract(input, trace.id);
+        for (const fact of facts) {
+          this.typedNetworkStore.addFact(fact);
+        }
+      } catch (err) {
+        const msg = err instanceof Error ? err.message : String(err);
+        process.stderr.write(`[CognitiveMemoryManager.encode typed-network extraction failed] ${msg}\n`);
+      }
+    }
+
     return trace;
   }
 

src/memory/__tests__/CognitiveMemoryManager.typedNetwork.test.ts

@@ -128,4 +128,68 @@ describe('CognitiveMemoryManager: typedNetwork wiring', () => {
     // Minimal variant skips spreading activation: bank routing only.
     expect(manager.getTypedSpreadingActivation()).toBeNull();
   });
+
+  it('encode() extracts typed facts via observer and persists into the typed-network store', async () => {
+    // The stub LLM returns 2 typed facts: one WORLD, one OPINION.
+    const extractingLLM: ITypedExtractionLLM = {
+      invoke: async () =>
+        JSON.stringify({
+          facts: [
+            {
+              text: 'Berlin is in Germany',
+              bank: 'WORLD',
+              temporal: { mention: '2026-04-25T12:00:00Z' },
+              participants: [],
+              reasoning_markers: [],
+              entities: ['Berlin', 'Germany'],
+              confidence: 1.0,
+            },
+            {
+              text: 'The user prefers TypeScript',
+              bank: 'OPINION',
+              temporal: { mention: '2026-04-25T12:00:00Z' },
+              participants: [{ name: 'user', role: 'subject' }],
+              reasoning_markers: ['because'],
+              entities: ['TypeScript'],
+              confidence: 0.7,
+            },
+          ],
+        }),
+    };
+    await manager.initialize({
+      ...makeMinimalDeps(),
+      typedNetwork: { variant: 'full', observerLLM: extractingLLM },
+    });
+
+    // Encode triggers extraction.
+    const trace = await manager.encode(
+      'Berlin is in Germany. I think the user prefers TypeScript because it is statically typed.',
+      { valence: 0, arousal: 0.3, dominance: 0 },
+      'neutral',
+    );
+
+    const store = manager.getTypedNetworkStore()!;
+    expect(store.getBank('WORLD').size).toBe(1);
+    expect(store.getBank('OPINION').size).toBe(1);
+    expect(store.getBank('EXPERIENCE').size).toBe(0);
+    expect(store.getBank('OBSERVATION').size).toBe(0);
+
+    // Trace ID should be the namespace anchor for the extracted facts so the
+    // facts are linked back to the parent encoding event.
+    const expectedFactId = `${trace.id}-fact-0`;
+    expect(store.getFact(expectedFactId)).toBeDefined();
+    expect(store.getFact(expectedFactId)?.text).toBe('Berlin is in Germany');
+  });
+
+  it('encode() is a no-op (no extraction call) when typedNetwork not configured', async () => {
+    await manager.initialize(makeMinimalDeps());
+    // No typedNetwork: extraction must never be called.
+    await manager.encode(
+      'Sample text',
+      { valence: 0, arousal: 0.3, dominance: 0 },
+      'neutral',
+    );
+    // No store to inspect; verifying via absence of error + null state above.
+    expect(manager.getTypedNetworkStore()).toBeNull();
+  });
 });