Function server

packages/plugin/src/index.ts:51–626

(ctx)

import { closeQuietly } from "./shared/sqlite-helpers";

const server: Plugin = async (ctx) => {
    // Move config from the legacy per-harness locations to the shared CortexKit
    // location BEFORE loading (hard cutover: the loader reads only CortexKit).
    // Idempotent + lock-guarded for Desktop multi-instance; fails open. Warnings
    // (conflicts / partial failures) are surfaced via the config-warning path.
    const configMigrationWarnings = migrateMagicContextConfigLocations(ctx.directory, {
        warn: (m) => log(`[magic-context] ${m}`),
        info: (m) => log(`[magic-context] ${m}`),
    });
    const pluginConfig = loadPluginConfig(ctx.directory);
    if (configMigrationWarnings.length > 0) {
        pluginConfig.configWarnings = [
            ...configMigrationWarnings,
            ...(pluginConfig.configWarnings ?? []),
        ];
    }
    // Apply SQLite connection tuning before the first openDatabase() below.
    setSqlitePragmaConfig({
        cacheSizeMb: pluginConfig.sqlite.cache_size_mb,
        mmapSizeMb: pluginConfig.sqlite.mmap_size_mb,
    });
    // Debug data-collection toggle: when on, keep subagent child sessions
    // (historian/dreamer/sidekick/migration) instead of deleting on success.
    setKeepSubagents(pluginConfig.keep_subagents === true);
    const autoUpdateAbort = new AbortController();
    // Abort on process exit via the shared single-listener registry. Registering
    // a process.once("exit") here directly would add one listener PER plugin
    // instance, and OpenCode Desktop runs many in one process (Node warns past 10).
    registerExitAbort(autoUpdateAbort);

    // Surface config validation warnings to user and log
    if (pluginConfig.configWarnings?.length) {
        for (const w of pluginConfig.configWarnings) {
            log(`[magic-context] config warning: ${w}`);
        }
        // Send warning to user via startup notification (after a short delay so session is ready)
        const warningText = [
            "## ⚠️ Magic Context Config Warning",
            "",
            "Some configuration values are invalid and were replaced with defaults:",
            "",
            ...pluginConfig.configWarnings.map((w) => `- ${w}`),
            "",
            "Check your `magic-context.jsonc` to fix these values.",
        ].join("\n");

        setTimeout(async () => {
            try {
                const { sendIgnoredMessage } = await import(
                    "./hooks/magic-context/send-session-notification"
                );
                // sendIgnoredMessage already handles TUI (toast) vs Desktop (ignored message)
                // via isTuiConnected(). We need a session ID — use the first active session.
                // SDK types don't expose `session.list()`'s actual response shape (the
                // client surface has been through multiple revisions; some versions
                // return `{ data: [...] }`, others return the array directly), so we
                // probe both shapes defensively at runtime.
                type SessionListFn = () => Promise<