fix(ci): clean decopilot contract follow-ups

Author: tlgimenes

apps/mesh/src/api/routes/decopilot/conversation.ts

@@ -5,8 +5,6 @@
  */
 
 import type { ChatMessage } from "./types";
-import type { Memory } from "./memory";
-import type { ThreadMessage } from "@/storage/types";
 export {
   denyPendingApprovals,
   processConversation,
@@ -25,45 +23,3 @@ export function splitRequestMessages(messages: ChatMessage[]): {
   const requestMessage = messages.find((m) => m.role !== "system")!;
   return { systemMessages, requestMessage };
 }
-
-async function loadMemory(memory: Memory, windowSize: number) {
-  const threadMessages = await memory.loadHistory(windowSize);
-  return threadMessages;
-}
-
-function mergeMessages(
-  threadMessages: ThreadMessage[],
-  requestMessage?: ChatMessage,
-): ChatMessage[] {
-  // Filter out messages with empty parts to prevent bricked threads
-  // (e.g. assistant messages saved after an LLM error before any content was generated)
-  const validMessages = threadMessages.filter(
-    (m) => m.parts && m.parts.length > 0,
-  );
-  if (!requestMessage) {
-    return validMessages as ChatMessage[];
-  }
-  const matchIndex = validMessages.findIndex((m) => m.id === requestMessage.id);
-  const conversation =
-    matchIndex >= 0
-      ? [...validMessages.slice(0, matchIndex), requestMessage]
-      : [...validMessages, requestMessage];
-  return conversation;
-}
-
-export async function loadAndMergeMessages(
-  memory: Memory,
-  requestMessage: ChatMessage | undefined,
-  systemMessages: ChatMessage[],
-  windowSize: number,
-  /** Subagent runs start FRESH: skip the thread's history and send only the
-   *  system prompt + the request (the subtask prompt). */
-  skipHistory = false,
-): Promise<ChatMessage[]> {
-  const threadMessages = skipHistory
-    ? []
-    : await loadMemory(memory, windowSize);
-  const conversation = mergeMessages(threadMessages, requestMessage);
-  const allMessages: ChatMessage[] = [...systemMessages, ...conversation];
-  return allMessages;
-}

apps/mesh/src/api/routes/decopilot/memory.ts

@@ -33,7 +33,7 @@ export interface MemoryConfig {
  * - Message history loading
  * - Pruning for context window management
  */
-export class Memory {
+class Memory {
   readonly thread: Thread;
   readonly organization_id: string;
 

packages/e2e/tests/link-dispatch-pull.spec.ts

@@ -220,7 +220,10 @@ test.describe("pull-transport round-trip", () => {
     let daemon: TunnelLinkDaemon | null = null;
 
     try {
-      daemon = await createTunnelLinkDaemon(api, user.userId, ["claude-code"]);
+      daemon = await createTunnelLinkDaemon(api, user.userId, [
+        "body-offload",
+        "claude-code",
+      ]);
       const orgId = await orgIdForSlug(db, orgSlug);
       const { agentId, threadId } = await createPullThread(
         api,