feat(core)!: drop unused module-lifecycle public types; consolidate wire + session-file utilities

packages/agent-worker/src/__tests__/message-batcher.test.ts

@@ -13,8 +13,8 @@
  */
 
 import { describe, expect, test } from "bun:test";
+import type { QueuedMessage } from "@lobu/core";
 import { MessageBatcher } from "../gateway/message-batcher";
-import type { QueuedMessage } from "../gateway/types";
 
 function makeMsg(
   messageId: string,

packages/agent-worker/src/gateway/gateway-integration.ts

@@ -27,7 +27,6 @@ export class HttpWorkerTransport implements WorkerTransport {
   private botResponseTs?: string;
   public processedMessageIds: string[] = [];
   private jobId?: string;
-  private moduleData?: Record<string, unknown>;
   private teamId: string;
   private platform?: string;
   private platformMetadata?: Record<string, unknown>;
@@ -52,10 +51,6 @@ export class HttpWorkerTransport implements WorkerTransport {
     this.jobId = jobId;
   }
 
-  setModuleData(moduleData: Record<string, unknown>): void {
-    this.moduleData = moduleData;
-  }
-
   async signalDone(finalDelta?: string): Promise<void> {
     // Send final delta if there is one
     if (finalDelta) {
@@ -137,7 +132,6 @@ export class HttpWorkerTransport implements WorkerTransport {
     await this.sendResponse(
       this.buildBaseResponse({
         delta: actualDelta,
-        moduleData: this.moduleData,
         isFullReplacement,
       })
     );
@@ -147,7 +141,6 @@ export class HttpWorkerTransport implements WorkerTransport {
     await this.sendResponse(
       this.buildBaseResponse({
         processedMessageIds: this.processedMessageIds,
-        moduleData: this.moduleData,
       })
     );
   }

packages/agent-worker/src/gateway/message-batcher.ts

@@ -2,8 +2,7 @@
  * Message batching for grouping rapid messages
  */
 
-import { createLogger } from "@lobu/core";
-import type { QueuedMessage } from "./types";
+import { createLogger, type QueuedMessage } from "@lobu/core";
 
 const logger = createLogger("message-batcher");
 

packages/agent-worker/src/gateway/sse-client.ts

@@ -8,6 +8,8 @@ import {
   createLogger,
   extractTraceId,
   flushTracing,
+  type MessagePayload,
+  type QueuedMessage,
   SpanStatusCode,
   stripEnv,
 } from "@lobu/core";
@@ -16,7 +18,6 @@ import type { WorkerConfig, WorkerExecutor } from "../core/types";
 import { SENSITIVE_WORKER_ENV_KEYS } from "../shared/worker-env-keys";
 import { HttpWorkerTransport } from "./gateway-integration";
 import { MessageBatcher } from "./message-batcher";
-import type { MessagePayload, QueuedMessage } from "./types";
 
 const logger = createLogger("sse-client");
 

packages/agent-worker/src/gateway/types.ts

@@ -1,83 +1,13 @@
 /**
- * Shared types for gateway communication
+ * Worker-side response payload returned to the gateway over HTTP.
+ *
+ * The gateway↔worker wire contract (`MessagePayload`, `JobType`,
+ * `QueuedMessage`) is exported from `@lobu/core` — import from there
+ * directly, not from this file.
  */
 
-import type { AgentOptions, ThreadResponsePayload } from "@lobu/core";
+import type { ThreadResponsePayload } from "@lobu/core";
 
-/**
- * Platform-specific metadata (e.g., Slack team_id, channel, thread_ts)
- */
-interface PlatformMetadata {
-  team_id?: string;
-  channel?: string;
-  ts?: string;
-  thread_ts?: string;
-  files?: unknown[];
-  traceId?: string; // Trace ID for end-to-end observability
-  [key: string]: unknown;
-}
-
-/**
- * Job type for queue messages
- * - message: Standard agent message execution
- * - exec: Direct command execution in sandbox
- */
-export type JobType = "message" | "exec";
-
-/**
- * Message payload for agent execution
- */
-export interface MessagePayload {
-  botId: string;
-  userId: string;
-  agentId: string;
-  conversationId: string;
-  platform: string;
-  channelId: string;
-  messageId: string;
-  messageText: string;
-  platformMetadata: PlatformMetadata;
-  agentOptions: AgentOptions;
-  jobId?: string; // Optional job ID from gateway
-  teamId?: string; // Optional team ID (WhatsApp uses top-level, Slack uses platformMetadata)
-
-  // The runs.id of the row that dispatched this job. Set by the gateway
-  // MessageConsumer (stamped from the runs-queue claim's job.id) and
-  // threaded into WorkerConfig.runId. The worker's cleanup() uses it to
-  // attribute the agent_transcript_snapshot row to the correct run —
-  // see codex P1#1 on PR #865.
-  runId?: number;
-
-  // Per-run worker JWT bound to `runId` above. Minted by MessageConsumer
-  // and threaded into WorkerConfig.runJobToken. The worker uses THIS
-  // token (not the deployment-lifetime WORKER_TOKEN) when calling the
-  // snapshot endpoint, so the route's `tokenData.runId === body.runId`
-  // equality check can reject any cross-run impersonation — codex round
-  // 2 finding A on PR #865.
-  runJobToken?: string;
-
-  // Job type (default: "message")
-  jobType?: JobType;
-
-  // Exec-specific fields (only used when jobType === "exec")
-  execId?: string; // Unique ID for exec job (for response routing)
-  execCommand?: string; // Command to execute
-  execCwd?: string; // Working directory for command
-  execEnv?: Record<string, string>; // Additional environment variables
-  execTimeout?: number; // Timeout in milliseconds
-}
-
-/**
- * Queued message with timestamp
- */
-export interface QueuedMessage {
-  payload: MessagePayload;
-  timestamp: number;
-}
-
-/**
- * Response data sent back to gateway
- */
 export type ResponseData = ThreadResponsePayload & {
   originalMessageId: string;
 };

packages/agent-worker/src/index.ts

@@ -39,7 +39,6 @@ async function main() {
     logger.info(`Tracing initialized: lobu-worker -> ${otlpEndpoint}`);
   }
 
-  await moduleRegistry.registerAvailableModules();
   await moduleRegistry.initAll();
   logger.info("✅ Modules initialized");
 

packages/agent-worker/src/openclaw/worker.ts

@@ -394,13 +394,6 @@ export class OpenClawWorker implements WorkerExecutor {
             this.config.userId,
             this.config.sessionKey
           );
-
-          const { initModuleWorkspace } = await import("../modules/lifecycle");
-          await initModuleWorkspace({
-            workspaceDir: this.workspaceManager.getCurrentWorkingDirectory(),
-            username: this.config.userId,
-            sessionKey: this.config.sessionKey,
-          });
         }
       );
 
@@ -425,26 +418,6 @@ export class OpenClawWorker implements WorkerExecutor {
         }
       );
 
-      // Module hooks may modify the system prompt before agent execution.
-      try {
-        const { onSessionStart } = await import("../modules/lifecycle");
-        const moduleContext = await onSessionStart({
-          platform: this.config.platform,
-          channelId: this.config.channelId,
-          userId: this.config.userId,
-          conversationId: this.config.conversationId,
-          messageId: this.config.responseId,
-          workingDirectory: this.workspaceManager.getCurrentWorkingDirectory(),
-          customInstructions,
-        });
-        if (moduleContext.customInstructions) {
-          customInstructions = moduleContext.customInstructions;
-        }
-      } catch (error) {
-        logger.error("Failed to call onSessionStart hooks:", error);
-      }
-
-      // Add file I/O instructions AFTER module hooks so they aren't overwritten
       customInstructions += this.getFileIOInstructions();
 
       logger.info(
@@ -507,14 +480,6 @@ export class OpenClawWorker implements WorkerExecutor {
         }
       );
 
-      const { collectModuleData } = await import("../modules/lifecycle");
-      const moduleData = await collectModuleData({
-        workspaceDir: this.workspaceManager.getCurrentWorkingDirectory(),
-        userId: this.config.userId,
-        conversationId: this.config.conversationId,
-      });
-      this.workerTransport.setModuleData(moduleData);
-
       if (result.success) {
         // Snapshot writer in cleanup() reads this to discriminate the row.
         // Hydrate skips non-completed snapshots, so getting this right is