memmy-agent: Let every AI remember the same you-V1.0.6

App/backend/README.md

@@ -26,7 +26,7 @@ npm run db:migrate
 - `adapters/inbound/local-api`: Fastify routes, runtime-token authentication,
   CORS, SSE, and the Composio MCP bridge.
 - `adapters/outbound/agent-source`: built-in history readers for Cursor, Claude
-  Code, Codex, OpenCode, OpenClaw, Hermes, and WorkBuddy.
+  Code, Codex, OpenCode, OpenClaw, Hermes, WorkBuddy, Pi, and qwenwork.
 - `adapters/outbound/skill-writer`: Memory skill, hook, command, and plugin
   installation for the supported agents.
 - `adapters/outbound/agent-adapter`: manifest, loader, and registry contracts
@@ -118,10 +118,13 @@ Every route in this table requires the local runtime token.
 | OpenClaw    | SQLite databases under `~/.openclaw/`                                                                                                                                                                       | Workspace `AGENTS.md`, `~/.openclaw/skills/memmy-memory/`, and the Memory extension                    |
 | Hermes      | `~/.hermes/sessions/**/*.jsonl` and `~/.hermes/state.db`                                                                                                                                                    | `~/.hermes/SOUL.md`, `skills/memmy-memory/`, and Memory/resume plugins                                 |
 | WorkBuddy   | `~/.workbuddy/projects/**/*.jsonl`                                                                                                                                                                          | `~/.workbuddy/skills/memmy-memory/`                                                                    |
+| Pi          | `~/.pi/agent/sessions/**/*.jsonl`                                                                                                                                                                           | `~/.pi/agent/skills/memmy-memory/`                                                                     |
+| qwenwork    | `~/.qwenworkcn/projects/**/*.jsonl`                                                                                                                                                                         | `~/.qwenworkcn/skills/memmy-memory/`                                                                   |
 
 Agent roots can be overridden with `CLAUDE_CONFIG_DIR`, `CODEX_HOME`,
 `OPENCODE_CONFIG_DIR`, `OPENCLAW_STATE_DIR`, `HERMES_HOME`,
-`WORKBUDDY_CONFIG_DIR`, or `CODEBUDDY_CONFIG_DIR`, as applicable.
+`WORKBUDDY_CONFIG_DIR`, `CODEBUDDY_CONFIG_DIR`, `PI_CODING_AGENT_DIR`, or
+`QWENWORK_CONFIG_DIR`, as applicable.
 
 ## Memory Layer Configuration
 

App/backend/local-api-contracts/src/index.ts

@@ -183,6 +183,7 @@ export type MemoryServiceRuntimeConfig = z.infer<typeof MemoryServiceRuntimeConf
 export const RuntimeConfigSchema = z.object({
     baseUrl: z.string().url(),
     localToken: z.string().min(1),
+    timeZone: z.string().min(1).optional(),
     memory: MemoryServiceRuntimeConfigSchema.optional(),
     agentGateway: AgentGatewayRuntimeConfigSchema.optional()
 });
@@ -1057,6 +1058,20 @@ export const IntegrationConnectionsResponseSchema = z.object({
 });
 export type IntegrationConnectionsResponse = z.infer<typeof IntegrationConnectionsResponseSchema>;
 
+/**
+ * Schema for UI-reported tool connection outcomes (integration OAuth end-state,
+ * channel QR/start abandon, etc.). `errorCode=cancelled` means user closed mid-flow.
+ */
+export const ReportIntegrationConnectionEventInputSchema = z.object({
+  surface: z.enum(["channel", "integration"]),
+  toolkit: z.string().min(1),
+  event: z.enum(["connected", "failed"]),
+  errorCode: z.string().min(1).optional()
+});
+export type ReportIntegrationConnectionEventInput = z.infer<
+  typeof ReportIntegrationConnectionEventInputSchema
+>;
+
 /** Schema for execute integration tool input. */
 export const ExecuteIntegrationToolInputSchema = z.object({
     toolSlug: z.string().min(1),

App/backend/local-api-contracts/src/memory-runtime.ts

@@ -108,6 +108,7 @@ export const MemoryProcessingRecordSchema = z.object({
   errorCode: z.string().nullable().optional(),
   errorMessage: z.string().nullable().optional(),
   failedAt: IsoTimeSchema.nullable().optional(),
+  autoRetryScheduled: z.boolean().optional(),
   updatedAt: IsoTimeSchema
 });
 export type MemoryProcessingRecord = z.infer<typeof MemoryProcessingRecordSchema>;

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/index.ts

@@ -11,6 +11,7 @@ import { registerTurnRoutes } from "./turns.js";
 
 export interface AgentRuntimeRouteDeps {
   services: BackendServices;
+  timeZone?: string;
   authenticateRuntimeToken: (request: FastifyRequest, reply: FastifyReply) => Promise<unknown>;
 }
 

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/memory.ts

@@ -8,7 +8,7 @@ import {
 import { z } from "zod";
 import type { FastifyInstance } from "fastify";
 import { withErrorEnvelope } from "../../../../../services/error-envelope.js";
-import type { RuntimeContext } from "../../../../../services/runtime-context.js";
+import { runtimeContextFromRequest } from "../../../../../services/runtime-context.js";
 import type { AgentRuntimeRouteDeps } from "./index.js";
 
 const MemoryParamsSchema = z.object({
@@ -21,7 +21,7 @@ export function registerMemoryRoutes(app: FastifyInstance, deps: AgentRuntimeRou
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const input = AddMemoryInputSchema.parse(request.body);
-      return reply.send(await deps.services.memoryDetail.add(input, runtimeContext()));
+      return reply.send(await deps.services.memoryDetail.add(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -39,7 +39,7 @@ export function registerMemoryRoutes(app: FastifyInstance, deps: AgentRuntimeRou
         tools,
         excludedSourceAgents
       });
-      return reply.send(await deps.services.panel.memoryApiLogs(input, runtimeContext()));
+      return reply.send(await deps.services.panel.memoryApiLogs(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -70,7 +70,7 @@ export function registerMemoryRoutes(app: FastifyInstance, deps: AgentRuntimeRou
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const params = MemoryParamsSchema.parse(request.params);
-      return reply.send(await deps.services.memoryDetail.getById(params.id, runtimeContext()));
+      return reply.send(await deps.services.memoryDetail.getById(params.id, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -80,15 +80,11 @@ export function registerMemoryRoutes(app: FastifyInstance, deps: AgentRuntimeRou
     withErrorEnvelope(async (request, reply) => {
       const params = MemoryParamsSchema.parse(request.params);
       const input = DeleteMemoryInputSchema.parse(request.body ?? {});
-      return reply.send(await deps.services.memoryDetail.delete(params.id, input, runtimeContext()));
+      return reply.send(await deps.services.memoryDetail.delete(params.id, input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 }
 
-function runtimeContext(): RuntimeContext {
-  return { adapterId: "runtime" };
-}
-
 function queryValues(rawUrl: string | undefined, name: string): string[] | undefined {
   const values = new URL(rawUrl ?? "/", "http://localhost").searchParams
     .getAll(name)

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/panel.ts

@@ -3,23 +3,23 @@ import { PanelItemsInputSchema, PanelTasksInputSchema } from "@memmy/local-api-c
 import type { FastifyInstance } from "fastify";
 import { z } from "zod";
 import { withErrorEnvelope } from "../../../../../services/error-envelope.js";
-import type { RuntimeContext } from "../../../../../services/runtime-context.js";
+import { runtimeContextFromRequest } from "../../../../../services/runtime-context.js";
 import type { AgentRuntimeRouteDeps } from "./index.js";
 
 export function registerPanelRoutes(app: FastifyInstance, deps: AgentRuntimeRouteDeps): void {
   app.get(
     "/api/v1/panel/overview",
     { preHandler: deps.authenticateRuntimeToken },
-    withErrorEnvelope(async (_request, reply) => {
-      return reply.send(await deps.services.panel.overview(runtimeContext()));
+    withErrorEnvelope(async (request, reply) => {
+      return reply.send(await deps.services.panel.overview(runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
   app.get(
     "/api/v1/panel/analysis",
     { preHandler: deps.authenticateRuntimeToken },
-    withErrorEnvelope(async (_request, reply) => {
-      return reply.send(await deps.services.panel.analysis(runtimeContext()));
+    withErrorEnvelope(async (request, reply) => {
+      return reply.send(await deps.services.panel.analysis(runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -33,7 +33,7 @@ export function registerPanelRoutes(app: FastifyInstance, deps: AgentRuntimeRout
         ...rawQuery,
         excludedSourceAgents
       });
-      return reply.send(await deps.services.panel.items(input, runtimeContext()));
+      return reply.send(await deps.services.panel.items(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -42,7 +42,7 @@ export function registerPanelRoutes(app: FastifyInstance, deps: AgentRuntimeRout
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const input = PanelTasksInputSchema.parse(request.query);
-      return reply.send(await deps.services.panel.tasks(input, runtimeContext()));
+      return reply.send(await deps.services.panel.tasks(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -51,16 +51,12 @@ export function registerPanelRoutes(app: FastifyInstance, deps: AgentRuntimeRout
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const { id } = z.object({ id: z.string().min(1) }).parse(request.params);
-      return reply.send(await deps.services.panel.deleteTask(id, runtimeContext()));
+      return reply.send(await deps.services.panel.deleteTask(id, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
 }
 
-function runtimeContext(): RuntimeContext {
-  return { adapterId: "runtime" };
-}
-
 function queryValues(rawUrl: string | undefined, name: string): string[] | undefined {
   const values = new URL(rawUrl ?? "/", "http://localhost").searchParams
     .getAll(name)

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/search.ts

@@ -2,7 +2,7 @@
 import { SearchInputSchema } from "@memmy/local-api-contracts";
 import type { FastifyInstance } from "fastify";
 import { withErrorEnvelope } from "../../../../../services/error-envelope.js";
-import type { RuntimeContext } from "../../../../../services/runtime-context.js";
+import { runtimeContextFromRequest } from "../../../../../services/runtime-context.js";
 import type { AgentRuntimeRouteDeps } from "./index.js";
 
 export function registerSearchRoute(app: FastifyInstance, deps: AgentRuntimeRouteDeps): void {
@@ -11,8 +11,7 @@ export function registerSearchRoute(app: FastifyInstance, deps: AgentRuntimeRout
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const input = SearchInputSchema.parse(request.body);
-      const ctx: RuntimeContext = { adapterId: "runtime" };
-      return reply.send(await deps.services.search.search(input, ctx));
+      return reply.send(await deps.services.search.search(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 }

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/sessions.ts

@@ -6,7 +6,7 @@ import {
 import { z } from "zod";
 import type { FastifyInstance } from "fastify";
 import { withErrorEnvelope } from "../../../../../services/error-envelope.js";
-import type { RuntimeContext } from "../../../../../services/runtime-context.js";
+import { runtimeContextFromRequest } from "../../../../../services/runtime-context.js";
 import type { AgentRuntimeRouteDeps } from "./index.js";
 
 const SessionParamsSchema = z.object({
@@ -19,7 +19,7 @@ export function registerSessionRoutes(app: FastifyInstance, deps: AgentRuntimeRo
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const input = OpenSessionInputSchema.parse(request.body ?? {});
-      const result = await deps.services.session.open(input, runtimeContext());
+      const result = await deps.services.session.open(input, runtimeContextFromRequest(request, deps.timeZone));
       return reply.send(result.response);
     })
   );
@@ -30,13 +30,9 @@ export function registerSessionRoutes(app: FastifyInstance, deps: AgentRuntimeRo
     withErrorEnvelope(async (request, reply) => {
       const params = SessionParamsSchema.parse(request.params);
       const input = CloseSessionInputSchema.parse(request.body ?? {});
-      const result = await deps.services.session.close(params.sessionId, input, runtimeContext());
+      const result = await deps.services.session.close(params.sessionId, input, runtimeContextFromRequest(request, deps.timeZone));
       return reply.send(result.response);
     })
   );
 
 }
-
-function runtimeContext(): RuntimeContext {
-  return { adapterId: "runtime" };
-}

App/backend/src/adapters/inbound/local-api/routes/agent-runtime/turns.ts

@@ -3,7 +3,7 @@ import { CompleteTurnInputSchema, StartTurnInputSchema } from "@memmy/local-api-
 import { z } from "zod";
 import type { FastifyInstance } from "fastify";
 import { withErrorEnvelope } from "../../../../../services/error-envelope.js";
-import type { RuntimeContext } from "../../../../../services/runtime-context.js";
+import { runtimeContextFromRequest } from "../../../../../services/runtime-context.js";
 import type { AgentRuntimeRouteDeps } from "./index.js";
 
 const TurnParamsSchema = z.object({
@@ -16,7 +16,7 @@ export function registerTurnRoutes(app: FastifyInstance, deps: AgentRuntimeRoute
     { preHandler: deps.authenticateRuntimeToken },
     withErrorEnvelope(async (request, reply) => {
       const input = StartTurnInputSchema.parse(request.body);
-      return reply.send(await deps.services.turn.start(input, runtimeContext()));
+      return reply.send(await deps.services.turn.start(input, runtimeContextFromRequest(request, deps.timeZone)));
     })
   );
 
@@ -26,12 +26,8 @@ export function registerTurnRoutes(app: FastifyInstance, deps: AgentRuntimeRoute
     withErrorEnvelope(async (request, reply) => {
       const params = TurnParamsSchema.parse(request.params);
       const input = CompleteTurnInputSchema.parse(request.body);
-      const result = await deps.services.turn.complete(params.turnId, input, runtimeContext());
+      const result = await deps.services.turn.complete(params.turnId, input, runtimeContextFromRequest(request, deps.timeZone));
       return reply.send(result.response);
     })
   );
 }
-
-function runtimeContext(): RuntimeContext {
-  return { adapterId: "runtime" };
-}

App/backend/src/adapters/inbound/local-api/routes/channels.ts

@@ -5,7 +5,8 @@ import {
   ChannelProviderSchema,
   ConnectChannelInputSchema,
   ConnectChannelResponseSchema,
-  OkResponseSchema
+  OkResponseSchema,
+  ReportIntegrationConnectionEventInputSchema
 } from "@memmy/local-api-contracts";
 import { z } from "zod";
 import type { FastifyInstance, FastifyReply, FastifyRequest } from "fastify";
@@ -77,4 +78,14 @@ export function registerChannelRoutes(app: FastifyInstance, options: RegisterCha
       return reply.send(response);
     })
   );
+
+  app.post(
+    "/api/v1/channels/connection-events",
+    { preHandler: options.authenticateRuntimeToken },
+    withErrorEnvelope(async (request, reply) => {
+      const input = ReportIntegrationConnectionEventInputSchema.parse(request.body);
+      const response = OkResponseSchema.parse(await options.channels.reportConnectionEvent(input));
+      return reply.send(response);
+    })
+  );
 }

App/backend/src/adapters/inbound/local-api/routes/integrations.ts

@@ -3,7 +3,8 @@ import {
   AuthorizeIntegrationResponseSchema,
   IntegrationCapabilitiesResponseSchema,
   IntegrationConnectionsResponseSchema,
-  OkResponseSchema
+  OkResponseSchema,
+  ReportIntegrationConnectionEventInputSchema
 } from "@memmy/local-api-contracts";
 import { z } from "zod";
 import type { FastifyInstance, FastifyReply, FastifyRequest } from "fastify";
@@ -54,6 +55,16 @@ export function registerIntegrationRoutes(app: FastifyInstance, options: Registe
     })
   );
 
+  app.post(
+    "/api/v1/integrations/connection-events",
+    { preHandler: options.authenticateRuntimeToken },
+    withErrorEnvelope(async (request, reply) => {
+      const input = ReportIntegrationConnectionEventInputSchema.parse(request.body);
+      const response = OkResponseSchema.parse(await options.integrations.reportConnectionEvent(input));
+      return reply.send(response);
+    })
+  );
+
   app.delete(
     "/api/v1/integrations/connections/:id",
     { preHandler: options.authenticateRuntimeToken },

App/backend/src/adapters/inbound/local-api/server.ts

@@ -21,14 +21,16 @@ const DEFAULT_HEARTBEAT_INTERVAL_MS = 15_000;
 const LOCAL_API_SERVICE_NAME = "memmy-local-api";
 const RUNTIME_TOKEN_HEADER = "x-memmy-local-token";
 const CORS_ALLOWED_METHODS = "GET,POST,PUT,PATCH,DELETE,OPTIONS";
-const CORS_ALLOWED_HEADERS = `content-type,${RUNTIME_TOKEN_HEADER}`;
+const CORS_ALLOWED_HEADERS = `content-type,${RUNTIME_TOKEN_HEADER},x-memmy-time-zone`;
 const DEFAULT_ALLOWED_LOCAL_HOSTS = new Set(["127.0.0.1", "localhost", "::1", "[::1]"]);
 const OPAQUE_ORIGIN = "null";
 const FILE_ORIGIN = "file://";
 
 export interface CreateLocalApiServerOptions {
   permissionManager: PermissionManager;
   services: BackendServices;
+  /** Configured agent timezone. Renderer headers are used only when absent. */
+  timeZone?: string;
   /**
    * Local validation token for the Composio MCP bridge; the agent carries it in mcpServers.composio.headers to access /mcp/composio.
    */
@@ -133,6 +135,7 @@ export function createLocalApiServer(options: CreateLocalApiServerOptions): Fast
   });
   registerAgentRuntimeRoutes(app, {
     services: options.services,
+    timeZone: options.timeZone,
     authenticateRuntimeToken
   });