fix: use RPC-based TUI detection instead of broken OPENCODE_CLIENT env var

process.env.OPENCODE_CLIENT is undefined in the server plugin process,
so all server-side isTui checks were always false. Replace with
isTuiConnected() which tracks whether TUI has polled via RPC.

- Unify /ctx-status and /ctx-recomp: single server-side registration,
  RPC action dispatch to TUI dialog, ignored message for Desktop/web
- Fix sendIgnoredMessage toast path that was never reaching TUI
- Replace SQLite plugin_messages with in-memory RPC notification queue
- Add RPC server/client for server<->TUI communication

Author: ualtinok

packages/plugin/src/features/builtin-commands/commands.ts

@@ -1,14 +1,7 @@
 import type { BuiltinCommandConfig } from "./types";
 
-/** Only display-only commands that are fully replaced by TUI-native UI (e.g. dialog).
- * Action commands (flush, aug, dream, recomp) must stay server-side because the
- * server-side command.execute.before hook does the actual work. */
-const TUI_OVERRIDE_COMMANDS = new Set(["ctx-status"]);
-
 export function getMagicContextBuiltinCommands(): BuiltinCommandConfig {
-    const isTui = process.env.OPENCODE_CLIENT === "cli";
-
-    const commands: BuiltinCommandConfig = {
+    return {
         "ctx-status": {
             template: "ctx-status",
             description: "Show magic context status, pending queue, cache TTL, and debug info",
@@ -31,13 +24,4 @@ export function getMagicContextBuiltinCommands(): BuiltinCommandConfig {
             description: "Run the hidden dreamer maintenance pass for this project now",
         },
     };
-
-    // In TUI mode, skip commands that have richer TUI-native implementations
-    if (isTui) {
-        for (const name of TUI_OVERRIDE_COMMANDS) {
-            delete commands[name];
-        }
-    }
-
-    return commands;
 }

packages/plugin/src/hooks/magic-context/command-handler.ts

@@ -9,6 +9,7 @@ import { runSidekick } from "../../features/magic-context/sidekick/agent";
 import { getCompartments } from "../../features/magic-context/storage";
 import type { PluginContext } from "../../plugin/types";
 import { sessionLog } from "../../shared";
+import { isTuiConnected, pushNotification } from "../../shared/rpc-notifications";
 import { executeFlush } from "./execute-flush";
 import { executeStatus } from "./execute-status";
 import type { NotificationParams } from "./send-session-notification";
@@ -274,6 +275,12 @@ export function createMagicContextCommandHandler(deps: {
             }
 
             if (isStatus) {
+                if (isTuiConnected()) {
+                    // In TUI, push an RPC action so the TUI poller shows a native dialog
+                    pushNotification("action", { action: "show-status-dialog" }, sessionId);
+                    sessionLog(sessionId, "command ctx-status: pushed show-status-dialog to TUI");
+                    throwSentinel(input.command);
+                }
                 const liveModelKey = deps.getLiveModelKey?.(sessionId);
                 const statusOutput = executeStatus(
                     deps.db,
@@ -289,12 +296,17 @@ export function createMagicContextCommandHandler(deps: {
             }
 
             if (isRecomp) {
+                if (isTuiConnected()) {
+                    // In TUI, push an RPC action so the TUI poller shows a confirmation dialog
+                    pushNotification("action", { action: "show-recomp-dialog" }, sessionId);
+                    sessionLog(sessionId, "command ctx-recomp: pushed show-recomp-dialog to TUI");
+                    throwSentinel(input.command);
+                }
                 if (!deps.executeRecomp) {
                     result =
                         "## Magic Recomp\n\n/ctx-recomp is unavailable because the recomp handler is not configured.";
                 } else {
-                    // Desktop double-tap confirmation.
-                    // TUI uses a native dialog → message bus → tui-action-consumer.ts
+                    // Desktop double-tap confirmation (no native dialog available).
                     const lastConfirmation = recompConfirmationBySession.get(sessionId);
                     const now = Date.now();
 

packages/plugin/src/hooks/magic-context/send-session-notification.ts

@@ -64,9 +64,10 @@ export async function sendIgnoredMessage(
     text: string,
     params: NotificationParams,
 ): Promise<void> {
-    // In TUI mode, show as toast instead of ignored message
-    const isTui = process.env.OPENCODE_CLIENT === "cli";
-    if (isTui) {
+    // In TUI mode, show as toast via RPC instead of ignored message.
+    // Cannot use process.env.OPENCODE_CLIENT — it's undefined in the server plugin process.
+    const { isTuiConnected: checkTui } = await import("../../shared/rpc-notifications");
+    if (checkTui()) {
         try {
             const c = client as Record<string, unknown>;
             const tui = c?.tui as Record<string, unknown> | undefined;

packages/plugin/src/index.ts

@@ -16,8 +16,10 @@ import { createEventHandler } from "./plugin/event";
 import { createSessionHooks } from "./plugin/hooks/create-session-hooks";
 import { createMessagesTransformHandler } from "./plugin/messages-transform";
 import { createToolRegistry } from "./plugin/tool-registry";
-import { startTuiActionConsumer } from "./plugin/tui-action-consumer";
+import { registerRpcHandlers } from "./plugin/rpc-handlers";
 import { type ConflictResult, detectConflicts } from "./shared/conflict-detector";
+import { getOpenCodeStorageDir } from "./shared/data-path";
+import { MagicContextRpcServer } from "./shared/rpc-server";
 import { log } from "./shared/logger";
 import { getAgentFallbackModels } from "./shared/model-requirements";
 
@@ -71,11 +73,16 @@ const plugin: Plugin = async (ctx) => {
                 : undefined,
         });
 
-        // Start TUI→server action message consumer (handles recomp confirmations etc.)
-        startTuiActionConsumer({
-            client: ctx.client,
+        // Start RPC server for TUI↔server communication (replaces SQLite plugin_messages bus)
+        const storageDir = `${getOpenCodeStorageDir()}/plugin/magic-context`;
+        const rpcServer = new MagicContextRpcServer(storageDir, ctx.directory);
+        registerRpcHandlers(rpcServer, {
             directory: ctx.directory,
             config: pluginConfig,
+            client: ctx.client,
+        });
+        rpcServer.start().catch((err) => {
+            log(`[magic-context] RPC server failed to start: ${err}`);
         });
     }