feat: handle MCP notifications/message from servers

packages/opencode/src/mcp/index.ts

@@ -6,6 +6,7 @@ import { StdioClientTransport } from "@modelcontextprotocol/sdk/client/stdio.js"
 import { UnauthorizedError } from "@modelcontextprotocol/sdk/client/auth.js"
 import {
   CallToolResultSchema,
+  LoggingMessageNotificationSchema,
   type Tool as MCPToolDef,
   ToolListChangedNotificationSchema,
 } from "@modelcontextprotocol/sdk/types.js"
@@ -60,6 +61,15 @@ export namespace MCP {
     }),
   )
 
+  export const MessageReceived = BusEvent.define(
+    "mcp.message.received",
+    z.object({
+      server: z.string(),
+      level: z.string(),
+      data: z.string(),
+    }),
+  )
+
   export const Failed = NamedError.create(
     "MCPFailed",
     z.object({
@@ -475,6 +485,17 @@ export namespace MCP {
           s.defs[name] = listed
           await Effect.runPromise(bus.publish(ToolsChanged, { server: name }).pipe(Effect.ignore))
         })
+
+        client.setNotificationHandler(LoggingMessageNotificationSchema, async (notification) => {
+          const level = notification.params.level ?? "info"
+          const data = typeof notification.params.data === "string"
+            ? notification.params.data
+            : JSON.stringify(notification.params.data)
+          log.info("message notification received", { server: name, level, data: data.slice(0, 200) })
+          await Effect.runPromise(
+            bus.publish(MessageReceived, { server: name, level, data }).pipe(Effect.ignore),
+          )
+        })
       }
 
       const cache = yield* InstanceState.make<State>(

packages/opencode/src/session/instruction.ts

@@ -13,7 +13,7 @@ const log = Log.create({ service: "instruction" })
 
 const FILES = [
   "AGENTS.md",
-  "CLAUDE.md",
+  ...(Flag.OPENCODE_DISABLE_CLAUDE_CODE_PROMPT ? [] : ["CLAUDE.md"]),
   "CONTEXT.md", // deprecated
 ]