Release v0.1.8 — P2P Bridge & Cortex 0.3.8 (#21)

## Summary
- P2P config parsing and sidecar flag forwarding for native QUIC
transport
- CortexClient P2P methods: status, list/add/remove peers, probe
- Dual sync mode in cortex-sync: native (QUIC gossip) vs polled (REST)
with graceful degradation
- Sync CLI enhancements with native P2P info display
- Bumped to v0.1.8, requires Cortex >= 0.3.8

## Test plan
- [x] `pnpm test` — 907 files, 7859 tests all pass
- [x] Full E2E: Mayros CLI + CortexClient against live Cortex with P2P
(8 steps verified)
- [x] `pnpm build` clean

Author: ApiliumDevTeam

extensions/agent-mesh/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-agent-mesh",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "description": "Mayros multi-agent coordination mesh with shared namespaces, delegation, and knowledge fusion",
   "type": "module",

extensions/analytics/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-analytics",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "type": "module",
   "main": "index.ts",

extensions/bash-sandbox/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-bash-sandbox",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "description": "Bash command sandbox with domain allowlist, command blocklist, and dangerous pattern detection",
   "type": "module",

extensions/bluebubbles/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-bluebubbles",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "description": "Mayros BlueBubbles channel plugin",
   "license": "MIT",
   "type": "module",

extensions/ci-plugin/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-ci-plugin",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "description": "CI/CD pipeline integration for Mayros — GitHub Actions and GitLab CI providers",
   "type": "module",
   "dependencies": {

extensions/code-indexer/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-code-indexer",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "description": "Mayros code indexer plugin — regex-based codebase scanning with RDF triple storage in Cortex",
   "type": "module",

extensions/code-tools/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-code-tools",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "type": "module",
   "dependencies": {

extensions/copilot-proxy/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@apilium/mayros-copilot-proxy",
-  "version": "0.1.7",
+  "version": "0.1.8",
   "private": true,
   "description": "Mayros Copilot Proxy provider plugin",
   "type": "module",

extensions/cortex-sync/config.test.ts

@@ -0,0 +1,105 @@
+/**
+ * Tests for cortex-sync configuration parsing, including P2P bridge (B3).
+ */
+
+import { describe, expect, it } from "vitest";
+import { parseCortexSyncConfig, type CortexSyncConfig } from "./config.js";
+
+describe("parseCortexSyncConfig", () => {
+  it("returns defaults for empty input", () => {
+    const cfg = parseCortexSyncConfig({});
+    expect(cfg.namespace).toBe("mayros");
+    expect(cfg.sync.intervalSeconds).toBe(300);
+    expect(cfg.sync.autoSync).toBe(false);
+    expect(cfg.sync.conflictStrategy).toBe("last-writer-wins");
+    expect(cfg.sync.maxTriplesPerSync).toBe(5000);
+    expect(cfg.sync.syncTimeoutMs).toBe(30000);
+    expect(cfg.sync.nativeP2pPreferred).toBe(true);
+    expect(cfg.discovery.bonjourEnabled).toBe(false);
+    expect(cfg.discovery.manualPeers).toEqual([]);
+  });
+
+  it("nativeP2pPreferred defaults to true", () => {
+    const cfg = parseCortexSyncConfig({});
+    expect(cfg.sync.nativeP2pPreferred).toBe(true);
+  });
+
+  it("nativeP2pPreferred can be set to false", () => {
+    const cfg = parseCortexSyncConfig({
+      sync: { nativeP2pPreferred: false },
+    });
+    expect(cfg.sync.nativeP2pPreferred).toBe(false);
+  });
+
+  it("nativeP2pPreferred true is respected", () => {
+    const cfg = parseCortexSyncConfig({
+      sync: { nativeP2pPreferred: true },
+    });
+    expect(cfg.sync.nativeP2pPreferred).toBe(true);
+  });
+
+  it("clamps intervalSeconds to range", () => {
+    const cfg1 = parseCortexSyncConfig({ sync: { intervalSeconds: 1 } });
+    expect(cfg1.sync.intervalSeconds).toBe(10);
+
+    const cfg2 = parseCortexSyncConfig({ sync: { intervalSeconds: 100000 } });
+    expect(cfg2.sync.intervalSeconds).toBe(86400);
+  });
+
+  it("clamps maxTriplesPerSync to range", () => {
+    const cfg1 = parseCortexSyncConfig({ sync: { maxTriplesPerSync: 1 } });
+    expect(cfg1.sync.maxTriplesPerSync).toBe(100);
+
+    const cfg2 = parseCortexSyncConfig({ sync: { maxTriplesPerSync: 100000 } });
+    expect(cfg2.sync.maxTriplesPerSync).toBe(50000);
+  });
+
+  it("parses valid conflictStrategy", () => {
+    const cfg = parseCortexSyncConfig({
+      sync: { conflictStrategy: "keep-both" },
+    });
+    expect(cfg.sync.conflictStrategy).toBe("keep-both");
+  });
+
+  it("falls back to default for invalid conflictStrategy", () => {
+    const cfg = parseCortexSyncConfig({
+      sync: { conflictStrategy: "invalid" },
+    });
+    expect(cfg.sync.conflictStrategy).toBe("last-writer-wins");
+  });
+
+  it("parses manual peers", () => {
+    const cfg = parseCortexSyncConfig({
+      discovery: {
+        manualPeers: [
+          {
+            nodeId: "node1",
+            endpoint: "http://localhost:8080",
+            namespaces: ["ns1"],
+            enabled: true,
+          },
+        ],
+      },
+    });
+    expect(cfg.discovery.manualPeers).toHaveLength(1);
+    expect(cfg.discovery.manualPeers[0].nodeId).toBe("node1");
+  });
+
+  it("filters invalid manual peers (missing nodeId or endpoint)", () => {
+    const cfg = parseCortexSyncConfig({
+      discovery: {
+        manualPeers: [
+          { nodeId: "", endpoint: "http://localhost:8080" },
+          { nodeId: "valid", endpoint: "" },
+          { nodeId: "ok", endpoint: "http://valid" },
+        ],
+      },
+    });
+    expect(cfg.discovery.manualPeers).toHaveLength(1);
+    expect(cfg.discovery.manualPeers[0].nodeId).toBe("ok");
+  });
+
+  it("rejects unknown sync keys", () => {
+    expect(() => parseCortexSyncConfig({ sync: { bogus: true } })).toThrow("unknown keys");
+  });
+});

extensions/cortex-sync/config.ts

@@ -36,6 +36,7 @@ export type SyncConfig = {
   conflictStrategy: ConflictStrategy;
   maxTriplesPerSync: number;
   syncTimeoutMs: number;
+  nativeP2pPreferred: boolean;
 };
 
 export type DiscoveryConfig = {
@@ -80,7 +81,14 @@ function parseSyncConfig(raw: unknown): SyncConfig {
   if (typeof raw === "object" && raw !== null && !Array.isArray(raw)) {
     assertAllowedKeys(
       sync,
-      ["intervalSeconds", "autoSync", "conflictStrategy", "maxTriplesPerSync", "syncTimeoutMs"],
+      [
+        "intervalSeconds",
+        "autoSync",
+        "conflictStrategy",
+        "maxTriplesPerSync",
+        "syncTimeoutMs",
+        "nativeP2pPreferred",
+      ],
       "sync config",
     );
   }
@@ -110,7 +118,17 @@ function parseSyncConfig(raw: unknown): SyncConfig {
       ? Math.max(5000, Math.min(120000, Math.floor(sync.syncTimeoutMs)))
       : DEFAULT_SYNC_TIMEOUT_MS;
 
-  return { intervalSeconds, autoSync, conflictStrategy, maxTriplesPerSync, syncTimeoutMs };
+  const nativeP2pPreferred =
+    typeof sync.nativeP2pPreferred === "boolean" ? sync.nativeP2pPreferred : true;
+
+  return {
+    intervalSeconds,
+    autoSync,
+    conflictStrategy,
+    maxTriplesPerSync,
+    syncTimeoutMs,
+    nativeP2pPreferred,
+  };
 }
 
 function parsePeerConfig(raw: unknown): SyncPeerConfig {
@@ -195,5 +213,10 @@ export const cortexSyncConfigUiHints = {
     default: DEFAULT_BONJOUR_ENABLED,
     description: "Enable local network peer discovery",
   },
+  "sync.nativeP2pPreferred": {
+    type: "boolean",
+    default: true,
+    description: "Prefer native P2P gossip over REST polling when available",
+  },
   "discovery.manualPeers": { type: "array", description: "Manually configured peers" },
 } as const;