@imqueue/mcp - npm Package Compare versions

Comparing version 1.2.1 to 2.0.0

dist/server.d.ts

+import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+export type Mode = "local" | "remote";
+/**
+ * The CLI-backed handlers, injected only in local mode. Declared explicitly (not
+ * `typeof import("./cli.js")`) so this shared module has NO type dependency on the
+ * node-only cli.ts — that keeps the edge/remote bundle and its type-check free of
+ * node:child_process. The local entry (index.ts) supplies the real functions and
+ * the compiler verifies they still match this shape.
+ */
+export interface CliHandlers {
+    cliStatus(): Promise<string>;
+    cliHelp(command?: string): Promise<string>;
+    createService(opts: {
+        name: string;
+        path?: string;
+        flags?: string[];
+        cwd?: string;
+        apply?: boolean;
+    }): Promise<string>;
+    generateClient(service: string, path?: string, cwd?: string): Promise<string>;
+    installCli(version?: string): Promise<string>;
+    fleet(opts: {
+        action: "start" | "stop" | "restart" | "status";
+        path?: string;
+        services?: string;
+        update?: boolean;
+        calm?: boolean;
+        verbose?: boolean;
+        cwd?: string;
+    }): Promise<string>;
+    config(opts: {
+        action: "check" | "get" | "set" | "init";
+        option?: string;
+        value?: string;
+        cwd?: string;
+    }): Promise<string>;
+    logs(opts: {
+        action?: "dump" | "clean";
+        services?: string;
+        prefix?: boolean;
+        cwd?: string;
+    }): Promise<string>;
+}
+/** How to install the full local server — surfaced by the remote hand-off + install_locally. */
+export declare const LOCAL_INSTALL: string;
+/**
+ * Create a fully-configured @imqueue MCP server.
+ * @param version  Version string to report (kept in sync with package.json by the caller).
+ * @param mode     "local" (full) or "remote" (docs+scaffold, CLI tools hand off to local).
+ * @param cli      CLI-backed handlers; required for the real tools in local mode.
+ */
+export declare function createServer(opts: {
+    version: string;
+    mode: Mode;
+    cli?: CliHandlers;
+}): McpServer;

dist/server.js

+// Shared @imqueue MCP server factory. Every tool is registered here once and the
+// server runs in one of two modes:
+//
+//   * "local"  — runs on the developer's machine (stdio entry: index.ts). The
+//                CLI-backed tools drive the real `imq` binary. Their handlers are
+//                INJECTED via `cli` so this module never imports node:child_process
+//                (keeps the remote/edge bundle clean).
+//   * "remote" — hosted over HTTP (worker/worker.ts, e.g. mcp.imqueue.org). Docs
+//                search + scaffolding work fully; the CLI/fleet tools can't touch
+//                the user's machine, so they return a "run me locally" hand-off —
+//                and, where it makes sense, the equivalent offline scaffold inline.
+import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+import { z } from "zod";
+import { searchDocs, getDoc } from "./docs.js";
+import { renderPackages } from "./packages.js";
+import { scaffoldService, scaffoldClient } from "./scaffold.js";
+const text = (t) => ({ content: [{ type: "text", text: t }] });
+const fail = (e) => ({
+    content: [{ type: "text", text: `Error: ${e instanceof Error ? e.message : String(e)}` }],
+    isError: true,
+});
+const methodSchema = z
+    .object({
+    name: z.string().describe("Method name"),
+    description: z.string().optional().describe("What the method does"),
+    params: z
+        .array(z.object({
+        name: z.string(),
+        type: z.string().describe("TypeScript type, e.g. 'string' or 'number[]'"),
+        description: z.string().optional(),
+    }))
+        .optional(),
+    returns: z.string().optional().describe("TypeScript return type WITHOUT Promise<> — e.g. 'User' or 'string'"),
+})
+    .strict();
+/** How to install the full local server — surfaced by the remote hand-off + install_locally. */
+export const LOCAL_INSTALL = [
+    "Install the full @imqueue MCP server locally — it runs via `npx`, no build step:",
+    "",
+    "• Claude Code:",
+    "    `claude mcp add imqueue -- npx -y @imqueue/mcp`",
+    "",
+    "• Cursor / Cline / Windsurf / other clients — add to your MCP config:",
+    "```json",
+    '{ "mcpServers": { "imqueue": { "command": "npx", "args": ["-y", "@imqueue/mcp"] } } }',
+    "```",
+].join("\n");
+/** Build a "this tool is local-only on the hosted server" response, optionally with an inline offline equivalent. */
+const handoff = (tool, why, offlineEquivalent) => text(`\`${tool}\` runs on **your machine** ${why}, so it isn't available on the hosted (\`mcp.imqueue.org\`) server.\n\n` +
+    LOCAL_INSTALL +
+    (offlineEquivalent
+        ? `\n\n---\n\nMeanwhile, here's an offline equivalent you can use right now:\n\n${offlineEquivalent}`
+        : ""));
+/**
+ * Create a fully-configured @imqueue MCP server.
+ * @param version  Version string to report (kept in sync with package.json by the caller).
+ * @param mode     "local" (full) or "remote" (docs+scaffold, CLI tools hand off to local).
+ * @param cli      CLI-backed handlers; required for the real tools in local mode.
+ */
+export function createServer(opts) {
+    const { version, mode, cli } = opts;
+    const server = new McpServer({ name: "imqueue", version });
+    const local = mode === "local" && !!cli;
+    // --- Stateless tools: identical in both modes ----------------------------
+    server.registerTool("search_docs", {
+        title: "Search @imqueue documentation",
+        description: "Search the official @imqueue docs (guides, tutorial, CLI manual, API reference, articles) and return the most relevant pages with their URLs. Use this first when asked how to do something in @imqueue, then get_doc to read a page in full.",
+        inputSchema: {
+            query: z.string().describe("What you want to find, e.g. 'expose a service method' or 'delayed jobs'"),
+            limit: z.number().int().min(1).max(20).optional().describe("Max results (default 6)"),
+        },
+    }, async ({ query, limit }) => {
+        try {
+            const hits = await searchDocs(query, limit ?? 6);
+            if (!hits.length)
+                return text(`No matches for "${query}". Try broader terms or call list_packages.`);
+            const body = hits.map((h) => `### ${h.title}  _(${h.section})_\n${h.description}\n${h.url}`).join("\n\n");
+            return text(`${hits.length} result(s) for "${query}":\n\n${body}\n\nRead any page in full with get_doc(url).`);
+        }
+        catch (e) {
+            return fail(e);
+        }
+    });
+    server.registerTool("get_doc", {
+        title: "Read an @imqueue doc page",
+        description: "Fetch the full markdown of an @imqueue documentation page by its URL (as returned by search_docs). Returns plain markdown suitable for reading and quoting.",
+        inputSchema: {
+            url: z.string().describe("An imqueue.org page URL, e.g. https://imqueue.org/get-started/"),
+        },
+    }, async ({ url }) => {
+        try {
+            const doc = await getDoc(url);
+            return text(`Source: ${doc.url}\n\n${doc.markdown}`);
+        }
+        catch (e) {
+            return fail(e);
+        }
+    });
+    server.registerTool("list_packages", {
+        title: "List @imqueue packages",
+        description: "Return the main @imqueue packages with a one-line summary and install command, so you can pick the right one.",
+        inputSchema: {},
+    }, async () => {
+        try {
+            return text(renderPackages());
+        }
+        catch (e) {
+            return fail(e);
+        }
+    });
+    server.registerTool("scaffold_service", {
+        title: "Scaffold an @imqueue service",
+        description: "Generate an idiomatic @imqueue/rpc service (an IMQService subclass with @expose()d, JSDoc-typed methods) plus a bootstrap that starts it. Provide the methods you want, or omit them for a starter template.",
+        inputSchema: {
+            name: z.string().describe("Service name, e.g. 'user' or 'UserService'"),
+            methods: z.array(methodSchema).optional().describe("Methods to expose"),
+        },
+    }, async ({ name, methods }) => {
+        try {
+            return text(scaffoldService(name, methods));
+        }
+        catch (e) {
+            return fail(e);
+        }
+    });
+    server.registerTool("scaffold_client", {
+        title: "Scaffold an @imqueue typed client",
+        description: "Show how to generate and use the fully-typed client for an @imqueue service. @imqueue generates the real client from a running service (via `imq client generate`), so this returns that command plus an illustrative usage snippet.",
+        inputSchema: {
+            service: z.string().describe("The service to call, e.g. 'user' or 'UserService'"),
+            methods: z.array(methodSchema).optional().describe("Known methods (used to shape the example call)"),
+        },
+    }, async ({ service, methods }) => {
+        try {
+            return text(scaffoldClient(service, methods));
+        }
+        catch (e) {
+            return fail(e);
+        }
+    });
+    // --- CLI-backed tools ------------------------------------------------------
+    // In local mode they drive the real `imq`. In remote mode each returns a
+    // hand-off to the local install (with an inline scaffold where one exists).
+    server.registerTool("cli_status", {
+        title: "Check the @imqueue CLI",
+        description: "Detect whether the `imq` CLI (@imqueue/cli) is installed locally and report its version. Call this before create_service/generate_client; if it's missing, fall back to scaffold_service/scaffold_client.",
+        inputSchema: {},
+    }, async () => {
+        if (local) {
+            try {
+                return text(await cli.cliStatus());
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("cli_status", "(it inspects the `imq` binary installed on your machine)");
+    });
+    server.registerTool("cli_help", {
+        title: "Show @imqueue CLI help",
+        description: "Run `imq [command] --help` and return the exact, version-accurate flags for a command (e.g. 'service create', 'client generate'). Use this to discover the flags to pass to create_service. No side effects.",
+        inputSchema: {
+            command: z.string().optional().describe("A subcommand, e.g. 'service create' (omit for top-level help)"),
+        },
+    }, async ({ command }) => {
+        if (local) {
+            try {
+                return text(await cli.cliHelp(command));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("cli_help", "(it shells out to your local `imq` for version-accurate flags)");
+    });
+    server.registerTool("create_service", {
+        title: "Create an @imqueue service with the CLI",
+        description: "Scaffold a real, provider-wired @imqueue service via `imq service create`. Runs as a DRY-RUN by default (shows the plan, writes nothing). Set apply=true to actually create it — that writes files and may init git / configure CI / push to a remote, so only apply with the user's intent. Pass CLI flags (see cli_help) to avoid interactive prompts. Requires `imq` (see cli_status). On the hosted server this returns an offline scaffold instead.",
+        inputSchema: {
+            name: z.string().describe("Service name, e.g. 'user'"),
+            path: z.string().optional().describe("Target directory (optional)"),
+            flags: z
+                .array(z.string())
+                .optional()
+                .describe("Extra `imq` flags, e.g. ['--vcs','github','--ci','github-actions'] or feature selection ['--packages','pg-prisma,validation,opentelemetry,gcp','-D']. Get exact flags from cli_help."),
+            cwd: z.string().optional().describe("Working directory to run in (defaults to the server's cwd)"),
+            apply: z.boolean().optional().describe("false/omitted = dry-run preview; true = actually create (writes files)"),
+        },
+    }, async ({ name, path, flags, cwd, apply }) => {
+        if (local) {
+            try {
+                return text(await cli.createService({ name, path, flags, cwd, apply }));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("create_service", "(it writes files into your project and can init git / configure CI / push to a remote)", scaffoldService(name));
+    });
+    server.registerTool("generate_client", {
+        title: "Generate a typed client with the CLI",
+        description: "Run `imq client generate <Service>` to emit the real, fully-typed client. The target service must be RUNNING (the CLI introspects the live service). Requires `imq` (see cli_status). On the hosted server this returns an offline client snippet instead.",
+        inputSchema: {
+            service: z.string().describe("Service name to generate a client for, e.g. 'User' / 'UserService'"),
+            path: z.string().optional().describe("Output directory (optional)"),
+            cwd: z.string().optional().describe("Working directory to run in"),
+        },
+    }, async ({ service, path, cwd }) => {
+        if (local) {
+            try {
+                return text(await cli.generateClient(service, path, cwd));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("generate_client", "(it introspects a service running on your machine to emit the real typed client)", scaffoldClient(service));
+    });
+    server.registerTool("cli_install", {
+        title: "Install the @imqueue CLI",
+        description: "Install @imqueue/cli globally via `npm install -g @imqueue/cli`. Use when cli_status reports it's missing. A global install may require a user-writable npm prefix or elevated permissions.",
+        inputSchema: {
+            version: z.string().optional().describe("npm version/tag to install (default 'latest')"),
+        },
+    }, async ({ version: v }) => {
+        if (local) {
+            try {
+                return text(await cli.installCli(v));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("cli_install", "(it installs the `imq` binary onto your machine with npm)");
+    });
+    server.registerTool("fleet", {
+        title: "Control the local @imqueue services fleet",
+        description: "Run `imq ctl <action>` over a directory of service repositories. `status` is read-only; `start`/`stop`/`restart` change running processes. Requires `imq` (see cli_status).",
+        inputSchema: {
+            action: z.enum(["start", "stop", "restart", "status"]).describe("What to do to the fleet"),
+            path: z.string().optional().describe("Directory containing the service repositories (default '.')"),
+            services: z.string().optional().describe("Comma-separated service names; omit to scan the path"),
+            update: z.boolean().optional().describe("git pull each service before starting (start/restart)"),
+            calm: z.boolean().optional().describe("Start services one at a time, waiting for each to be ready"),
+            verbose: z.boolean().optional().describe("Verbose output"),
+            cwd: z.string().optional().describe("Working directory to run in"),
+        },
+    }, async ({ action, path, services, update, calm, verbose, cwd }) => {
+        if (local) {
+            try {
+                return text(await cli.fleet({ action, path, services, update, calm, verbose, cwd }));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("fleet", "(it starts/stops and inspects @imqueue service processes running on your machine)");
+    });
+    server.registerTool("config", {
+        title: "Manage @imqueue CLI configuration",
+        description: "Run `imq config <action>`. `check` = is config initialized; `get [option]` = read a value (or list all); `set option value` = write a value (nested keys use a dot-path, e.g. 'ci.provider'); `init` = interactive setup (prefer `set` for automation — `init` will time out non-interactively). Requires `imq` (see cli_status).",
+        inputSchema: {
+            action: z.enum(["check", "get", "set", "init"]).describe("Config operation"),
+            option: z.string().optional().describe("Config key (dot-path for nested), for get/set"),
+            value: z.string().optional().describe("Value to set (required for `set`)"),
+            cwd: z.string().optional().describe("Working directory to run in"),
+        },
+    }, async ({ action, option, value, cwd }) => {
+        if (local) {
+            try {
+                return text(await cli.config({ action, option, value, cwd }));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("config", "(it reads/writes the `imq` CLI configuration on your machine)");
+    });
+    server.registerTool("logs", {
+        title: "Read or clean @imqueue fleet logs",
+        description: "Work with logs of services started by `imq ctl`. action='dump' (default) returns the current combined logs and exits — it never follows/streams, and output is capped. action='clean' deletes collected logs. Requires `imq` (see cli_status).",
+        inputSchema: {
+            action: z.enum(["dump", "clean"]).optional().describe("dump = read current logs (default); clean = delete collected logs"),
+            services: z.string().optional().describe("Comma-separated service names; omit to combine all"),
+            prefix: z.boolean().optional().describe("Prefix each line with the service name (default true)"),
+            cwd: z.string().optional().describe("Working directory to run in"),
+        },
+    }, async ({ action, services, prefix, cwd }) => {
+        if (local) {
+            try {
+                return text(await cli.logs({ action, services, prefix, cwd }));
+            }
+            catch (e) {
+                return fail(e);
+            }
+        }
+        return handoff("logs", "(it reads logs of @imqueue services running on your machine)");
+    });
+    // --- Remote-only helper ----------------------------------------------------
+    // A discoverable "how do I get the full thing" tool on the hosted server.
+    if (!local) {
+        server.registerTool("install_locally", {
+            title: "Install the full @imqueue MCP locally",
+            description: "Return the exact steps to install the full @imqueue MCP server on your machine (needed for the CLI/fleet tools, which act on your local project and services). The hosted server covers docs search and scaffolding; everything else runs locally.",
+            inputSchema: {},
+        }, async () => text(LOCAL_INSTALL));
+    }
+    return server;
+}
+//# sourceMappingURL=server.js.map

dist/server.js.map

+{"version":3,"file":"server.js","sourceRoot":"","sources":["../src/server.ts"],"names":[],"mappings":"AAAA,iFAAiF;AACjF,mCAAmC;AACnC,EAAE;AACF,8EAA8E;AAC9E,kFAAkF;AAClF,oFAAoF;AACpF,uDAAuD;AACvD,iFAAiF;AACjF,kFAAkF;AAClF,kFAAkF;AAClF,oFAAoF;AACpF,OAAO,EAAE,SAAS,EAAE,MAAM,yCAAyC,CAAC;AACpE,OAAO,EAAE,CAAC,EAAE,MAAM,KAAK,CAAC;AAExB,OAAO,EAAE,UAAU,EAAE,MAAM,EAAE,MAAM,WAAW,CAAC;AAC/C,OAAO,EAAE,cAAc,EAAE,MAAM,eAAe,CAAC;AAC/C,OAAO,EAAE,eAAe,EAAE,cAAc,EAAmB,MAAM,eAAe,CAAC;AAyCjF,MAAM,IAAI,GAAG,CAAC,CAAS,EAAE,EAAE,CAAC,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,IAAI,EAAE,MAAe,EAAE,IAAI,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC;AAChF,MAAM,IAAI,GAAG,CAAC,CAAU,EAAE,EAAE,CAAC,CAAC;IAC5B,OAAO,EAAE,CAAC,EAAE,IAAI,EAAE,MAAe,EAAE,IAAI,EAAE,UAAU,CAAC,YAAY,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC;IAClG,OAAO,EAAE,IAAI;CACd,CAAC,CAAC;AAEH,MAAM,YAAY,GAAG,CAAC;KACnB,MAAM,CAAC;IACN,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,aAAa,CAAC;IACxC,WAAW,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,sBAAsB,CAAC;IACnE,MAAM,EAAE,CAAC;SACN,KAAK,CACJ,CAAC,CAAC,MAAM,CAAC;QACP,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE;QAChB,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,8CAA8C,CAAC;QACzE,WAAW,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;KACnC,CAAC,CACH;SACA,QAAQ,EAAE;IACb,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,oEAAoE,CAAC;CAC9G,CAAC;KACD,MAAM,EAAE,CAAC;AAEZ,gGAAgG;AAChG,MAAM,CAAC,MAAM,aAAa,GAAG;IAC3B,kFAAkF;IAClF,EAAE;IACF,gBAAgB;IAChB,qDAAqD;IACrD,EAAE;IACF,uEAAuE;IACvE,SAAS;IACT,uFAAuF;IACvF,KAAK;CACN,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;AAEb,qHAAqH;AACrH,MAAM,OAAO,GAAG,CAAC,IAAY,EAAE,GAAW,EAAE,iBAA0B,EAAE,EAAE,CACxE,IAAI,CACF,KAAK,IAAI,+BAA+B,GAAG,yEAAyE;IAClH,aAAa;IACb,CAAC,iBAAiB;QAChB,CAAC,CAAC,gFAAgF,iBAAiB,EAAE;QACrG,CAAC,CAAC,EAAE,CAAC,CACV,CAAC;AAEJ;;;;;GAKG;AACH,MAAM,UAAU,YAAY,CAAC,IAAwD;IACnF,MAAM,EAAE,OAAO,EAAE,IAAI,EAAE,GAAG,EAAE,GAAG,IAAI,CAAC;IACpC,MAAM,MAAM,GAAG,IAAI,SAAS,CAAC,EAAE,IAAI,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC,CAAC;IAC3D,MAAM,KAAK,GAAG,IAAI,KAAK,OAAO,IAAI,CAAC,CAAC,GAAG,CAAC;IAExC,4EAA4E;IAE5E,MAAM,CAAC,YAAY,CACjB,aAAa,EACb;QACE,KAAK,EAAE,+BAA+B;QACtC,WAAW,EACT,+OAA+O;QACjP,WAAW,EAAE;YACX,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,yEAAyE,CAAC;YACrG,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,yBAAyB,CAAC;SACtF;KACF,EACD,KAAK,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,EAAE,EAAE;QACzB,IAAI,CAAC;YACH,MAAM,IAAI,GAAG,MAAM,UAAU,CAAC,KAAK,EAAE,KAAK,IAAI,CAAC,CAAC,CAAC;YACjD,IAAI,CAAC,IAAI,CAAC,MAAM;gBAAE,OAAO,IAAI,CAAC,mBAAmB,KAAK,6CAA6C,CAAC,CAAC;YACrG,MAAM,IAAI,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,OAAO,CAAC,CAAC,KAAK,OAAO,CAAC,CAAC,OAAO,OAAO,CAAC,CAAC,WAAW,KAAK,CAAC,CAAC,GAAG,EAAE,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;YAC1G,OAAO,IAAI,CAAC,GAAG,IAAI,CAAC,MAAM,mBAAmB,KAAK,SAAS,IAAI,8CAA8C,CAAC,CAAC;QACjH,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;QACjB,CAAC;IACH,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,SAAS,EACT;QACE,KAAK,EAAE,2BAA2B;QAClC,WAAW,EACT,6JAA6J;QAC/J,WAAW,EAAE;YACX,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,gEAAgE,CAAC;SAC3F;KACF,EACD,KAAK,EAAE,EAAE,GAAG,EAAE,EAAE,EAAE;QAChB,IAAI,CAAC;YACH,MAAM,GAAG,GAAG,MAAM,MAAM,CAAC,GAAG,CAAC,CAAC;YAC9B,OAAO,IAAI,CAAC,WAAW,GAAG,CAAC,GAAG,OAAO,GAAG,CAAC,QAAQ,EAAE,CAAC,CAAC;QACvD,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;QACjB,CAAC;IACH,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,eAAe,EACf;QACE,KAAK,EAAE,wBAAwB;QAC/B,WAAW,EACT,+GAA+G;QACjH,WAAW,EAAE,EAAE;KAChB,EACD,KAAK,IAAI,EAAE;QACT,IAAI,CAAC;YACH,OAAO,IAAI,CAAC,cAAc,EAAE,CAAC,CAAC;QAChC,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;QACjB,CAAC;IACH,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,kBAAkB,EAClB;QACE,KAAK,EAAE,8BAA8B;QACrC,WAAW,EACT,8MAA8M;QAChN,WAAW,EAAE;YACX,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,4CAA4C,CAAC;YACvE,OAAO,EAAE,CAAC,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mBAAmB,CAAC;SACxE;KACF,EACD,KAAK,EAAE,EAAE,IAAI,EAAE,OAAO,EAAE,EAAE,EAAE;QAC1B,IAAI,CAAC;YACH,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,EAAE,OAAmC,CAAC,CAAC,CAAC;QAC1E,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;QACjB,CAAC;IACH,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,iBAAiB,EACjB;QACE,KAAK,EAAE,mCAAmC;QAC1C,WAAW,EACT,sOAAsO;QACxO,WAAW,EAAE;YACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,mDAAmD,CAAC;YACjF,OAAO,EAAE,CAAC,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,gDAAgD,CAAC;SACrG;KACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,OAAO,EAAE,EAAE,EAAE;QAC7B,IAAI,CAAC;YACH,OAAO,IAAI,CAAC,cAAc,CAAC,OAAO,EAAE,OAAmC,CAAC,CAAC,CAAC;QAC5E,CAAC;QAAC,OAAO,CAAC,EAAE,CAAC;YACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;QACjB,CAAC;IACH,CAAC,CACF,CAAC;IAEF,8EAA8E;IAC9E,yEAAyE;IACzE,4EAA4E;IAE5E,MAAM,CAAC,YAAY,CACjB,YAAY,EACZ;QACE,KAAK,EAAE,wBAAwB;QAC/B,WAAW,EACT,2MAA2M;QAC7M,WAAW,EAAE,EAAE;KAChB,EACD,KAAK,IAAI,EAAE;QACT,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,SAAS,EAAE,CAAC,CAAC;YACtC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,YAAY,EAAE,0DAA0D,CAAC,CAAC;IAC3F,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,UAAU,EACV;QACE,KAAK,EAAE,wBAAwB;QAC/B,WAAW,EACT,8MAA8M;QAChN,WAAW,EAAE;YACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+DAA+D,CAAC;SACzG;KACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,EAAE,EAAE;QACpB,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;YAC3C,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,UAAU,EAAE,gEAAgE,CAAC,CAAC;IAC/F,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,gBAAgB,EAChB;QACE,KAAK,EAAE,yCAAyC;QAChD,WAAW,EACT,0bAA0b;QAC5b,WAAW,EAAE;YACX,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,2BAA2B,CAAC;YACtD,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;YACnE,KAAK,EAAE,CAAC;iBACL,KAAK,CAAC,CAAC,CAAC,MAAM,EAAE,CAAC;iBACjB,QAAQ,EAAE;iBACV,QAAQ,CACP,sLAAsL,CACvL;YACH,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,4DAA4D,CAAC;YACjG,KAAK,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,wEAAwE,CAAC;SACjH;KACF,EACD,KAAK,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE;QAC1C,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,aAAa,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;YAC3E,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CACZ,gBAAgB,EAChB,wFAAwF,EACxF,eAAe,CAAC,IAAI,CAAC,CACtB,CAAC;IACJ,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,iBAAiB,EACjB;QACE,KAAK,EAAE,sCAAsC;QAC7C,WAAW,EACT,4PAA4P;QAC9P,WAAW,EAAE;YACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,oEAAoE,CAAC;YAClG,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;YACnE,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;SACnE;KACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,IAAI,EAAE,GAAG,EAAE,EAAE,EAAE;QAC/B,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,cAAc,CAAC,OAAO,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC,CAAC;YAC7D,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CACZ,iBAAiB,EACjB,kFAAkF,EAClF,cAAc,CAAC,OAAO,CAAC,CACxB,CAAC;IACJ,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,aAAa,EACb;QACE,KAAK,EAAE,0BAA0B;QACjC,WAAW,EACT,6LAA6L;QAC/L,WAAW,EAAE;YACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+CAA+C,CAAC;SACzF;KACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,CAAC,EAAE,EAAE,EAAE;QACvB,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,CAAC;YACxC,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,aAAa,EAAE,2DAA2D,CAAC,CAAC;IAC7F,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,OAAO,EACP;QACE,KAAK,EAAE,2CAA2C;QAClD,WAAW,EACT,6KAA6K;QAC/K,WAAW,EAAE;YACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,SAAS,EAAE,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,yBAAyB,CAAC;YAC1F,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6DAA6D,CAAC;YACnG,QAAQ,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,sDAAsD,CAAC;YAChG,MAAM,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,uDAAuD,CAAC;YAChG,IAAI,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,4DAA4D,CAAC;YACnG,OAAO,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,gBAAgB,CAAC;YAC1D,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;SACnE;KACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,EAAE,EAAE,EAAE;QAC/D,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,KAAK,CAAC,EAAE,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;YACxF,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,OAAO,EAAE,mFAAmF,CAAC,CAAC;IAC/G,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,QAAQ,EACR;QACE,KAAK,EAAE,mCAAmC;QAC1C,WAAW,EACT,mUAAmU;QACrU,WAAW,EAAE;YACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,OAAO,EAAE,KAAK,EAAE,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,kBAAkB,CAAC;YAC5E,MAAM,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+CAA+C,CAAC;YACvF,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mCAAmC,CAAC;YAC1E,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;SACnE;KACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,EAAE;QACvC,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;YACjE,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,QAAQ,EAAE,+DAA+D,CAAC,CAAC;IAC5F,CAAC,CACF,CAAC;IAEF,MAAM,CAAC,YAAY,CACjB,MAAM,EACN;QACE,KAAK,EAAE,mCAAmC;QAC1C,WAAW,EACT,gPAAgP;QAClP,WAAW,EAAE;YACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mEAAmE,CAAC;YAC1H,QAAQ,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,oDAAoD,CAAC;YAC9F,MAAM,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,uDAAuD,CAAC;YAChG,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;SACnE;KACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,EAAE,GAAG,EAAE,EAAE,EAAE;QAC1C,IAAI,KAAK,EAAE,CAAC;YACV,IAAI,CAAC;gBACH,OAAO,IAAI,CAAC,MAAM,GAAI,CAAC,IAAI,CAAC,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;YAClE,CAAC;YAAC,OAAO,CAAC,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;YACjB,CAAC;QACH,CAAC;QACD,OAAO,OAAO,CAAC,MAAM,EAAE,8DAA8D,CAAC,CAAC;IACzF,CAAC,CACF,CAAC;IAEF,8EAA8E;IAC9E,0EAA0E;IAC1E,IAAI,CAAC,KAAK,EAAE,CAAC;QACX,MAAM,CAAC,YAAY,CACjB,iBAAiB,EACjB;YACE,KAAK,EAAE,uCAAuC;YAC9C,WAAW,EACT,oPAAoP;YACtP,WAAW,EAAE,EAAE;SAChB,EACD,KAAK,IAAI,EAAE,CAAC,IAAI,CAAC,aAAa,CAAC,CAChC,CAAC;IACJ,CAAC;IAED,OAAO,MAAM,CAAC;AAChB,CAAC"}

dist/index.js

 #!/usr/bin/env node
-// @imqueue MCP server — exposes @imqueue docs search and service/client
-// scaffolding to AI coding agents (Claude Code, Cursor, …) over stdio.
-import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
+// @imqueue MCP server — local (stdio) entry point. Exposes @imqueue docs search,
+// scaffolding and CLI/fleet tools to AI coding agents (Claude Code, Cursor, …).
+// The hosted (HTTP) entry lives in worker/worker.ts; both share ./server.ts.
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
-import { z } from "zod";
 import { createRequire } from "node:module";
-import { searchDocs, getDoc } from "./docs.js";
-import { renderPackages } from "./packages.js";
-import { scaffoldService, scaffoldClient } from "./scaffold.js";
+import { createServer } from "./server.js";
 import { cliStatus, cliHelp, createService, generateClient, installCli, fleet, config, logs } from "./cli.js";
@@ -16,229 +13,7 @@ // Read the version from package.json at runtime so it always matches the
 const { version } = require("../package.json");
-const text = (t) => ({ content: [{ type: "text", text: t }] });
-const fail = (e) => ({
-    content: [{ type: "text", text: `Error: ${e instanceof Error ? e.message : String(e)}` }],
-    isError: true,
+const server = createServer({
+    version,
+    mode: "local",
+    cli: { cliStatus, cliHelp, createService, generateClient, installCli, fleet, config, logs },
 });
-const methodSchema = z
-    .object({
-    name: z.string().describe("Method name"),
-    description: z.string().optional().describe("What the method does"),
-    params: z
-        .array(z.object({
-        name: z.string(),
-        type: z.string().describe("TypeScript type, e.g. 'string' or 'number[]'"),
-        description: z.string().optional(),
-    }))
-        .optional(),
-    returns: z.string().optional().describe("TypeScript return type WITHOUT Promise<> — e.g. 'User' or 'string'"),
-})
-    .strict();
-const server = new McpServer({ name: "imqueue", version });
-server.registerTool("search_docs", {
-    title: "Search @imqueue documentation",
-    description: "Search the official @imqueue docs (guides, tutorial, CLI manual, API reference, articles) and return the most relevant pages with their URLs. Use this first when asked how to do something in @imqueue, then get_doc to read a page in full.",
-    inputSchema: {
-        query: z.string().describe("What you want to find, e.g. 'expose a service method' or 'delayed jobs'"),
-        limit: z.number().int().min(1).max(20).optional().describe("Max results (default 6)"),
-    },
-}, async ({ query, limit }) => {
-    try {
-        const hits = await searchDocs(query, limit ?? 6);
-        if (!hits.length)
-            return text(`No matches for "${query}". Try broader terms or call list_packages.`);
-        const body = hits
-            .map((h) => `### ${h.title}  _(${h.section})_\n${h.description}\n${h.url}`)
-            .join("\n\n");
-        return text(`${hits.length} result(s) for "${query}":\n\n${body}\n\nRead any page in full with get_doc(url).`);
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("get_doc", {
-    title: "Read an @imqueue doc page",
-    description: "Fetch the full markdown of an @imqueue documentation page by its URL (as returned by search_docs). Returns plain markdown suitable for reading and quoting.",
-    inputSchema: {
-        url: z.string().describe("An imqueue.org page URL, e.g. https://imqueue.org/get-started/"),
-    },
-}, async ({ url }) => {
-    try {
-        const doc = await getDoc(url);
-        return text(`Source: ${doc.url}\n\n${doc.markdown}`);
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("list_packages", {
-    title: "List @imqueue packages",
-    description: "Return the main @imqueue packages with a one-line summary and install command, so you can pick the right one.",
-    inputSchema: {},
-}, async () => {
-    try {
-        return text(renderPackages());
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("scaffold_service", {
-    title: "Scaffold an @imqueue service",
-    description: "Generate an idiomatic @imqueue/rpc service (an IMQService subclass with @expose()d, JSDoc-typed methods) plus a bootstrap that starts it. Provide the methods you want, or omit them for a starter template.",
-    inputSchema: {
-        name: z.string().describe("Service name, e.g. 'user' or 'UserService'"),
-        methods: z.array(methodSchema).optional().describe("Methods to expose"),
-    },
-}, async ({ name, methods }) => {
-    try {
-        return text(scaffoldService(name, methods));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("scaffold_client", {
-    title: "Scaffold an @imqueue typed client",
-    description: "Show how to generate and use the fully-typed client for an @imqueue service. @imqueue generates the real client from a running service (via `imq client generate`), so this returns that command plus an illustrative usage snippet.",
-    inputSchema: {
-        service: z.string().describe("The service to call, e.g. 'user' or 'UserService'"),
-        methods: z.array(methodSchema).optional().describe("Known methods (used to shape the example call)"),
-    },
-}, async ({ service, methods }) => {
-    try {
-        return text(scaffoldClient(service, methods));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-// --- CLI-backed tools (require the `imq` binary on PATH) --------------------
-server.registerTool("cli_status", {
-    title: "Check the @imqueue CLI",
-    description: "Detect whether the `imq` CLI (@imqueue/cli) is installed locally and report its version. Call this before create_service/generate_client; if it's missing, fall back to scaffold_service/scaffold_client.",
-    inputSchema: {},
-}, async () => {
-    try {
-        return text(await cliStatus());
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("cli_help", {
-    title: "Show @imqueue CLI help",
-    description: "Run `imq [command] --help` and return the exact, version-accurate flags for a command (e.g. 'service create', 'client generate'). Use this to discover the flags to pass to create_service. No side effects.",
-    inputSchema: {
-        command: z.string().optional().describe("A subcommand, e.g. 'service create' (omit for top-level help)"),
-    },
-}, async ({ command }) => {
-    try {
-        return text(await cliHelp(command));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("create_service", {
-    title: "Create an @imqueue service with the CLI",
-    description: "Scaffold a real, provider-wired @imqueue service via `imq service create`. Runs as a DRY-RUN by default (shows the plan, writes nothing). Set apply=true to actually create it — that writes files and may init git / configure CI / push to a remote, so only apply with the user's intent. Pass CLI flags (see cli_help) to avoid interactive prompts. Requires `imq` (see cli_status).",
-    inputSchema: {
-        name: z.string().describe("Service name, e.g. 'user'"),
-        path: z.string().optional().describe("Target directory (optional)"),
-        flags: z.array(z.string()).optional().describe("Extra `imq` flags, e.g. ['--vcs','github','--ci','github-actions'] or feature selection ['--packages','pg-prisma,validation,opentelemetry,gcp','-D']. Get exact flags from cli_help."),
-        cwd: z.string().optional().describe("Working directory to run in (defaults to the server's cwd)"),
-        apply: z.boolean().optional().describe("false/omitted = dry-run preview; true = actually create (writes files)"),
-    },
-}, async ({ name, path, flags, cwd, apply }) => {
-    try {
-        return text(await createService({ name, path, flags, cwd, apply }));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("generate_client", {
-    title: "Generate a typed client with the CLI",
-    description: "Run `imq client generate <Service>` to emit the real, fully-typed client. The target service must be RUNNING (the CLI introspects the live service). Requires `imq` (see cli_status).",
-    inputSchema: {
-        service: z.string().describe("Service name to generate a client for, e.g. 'User' / 'UserService'"),
-        path: z.string().optional().describe("Output directory (optional)"),
-        cwd: z.string().optional().describe("Working directory to run in"),
-    },
-}, async ({ service, path, cwd }) => {
-    try {
-        return text(await generateClient(service, path, cwd));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("cli_install", {
-    title: "Install the @imqueue CLI",
-    description: "Install @imqueue/cli globally via `npm install -g @imqueue/cli`. Use when cli_status reports it's missing. A global install may require a user-writable npm prefix or elevated permissions.",
-    inputSchema: {
-        version: z.string().optional().describe("npm version/tag to install (default 'latest')"),
-    },
-}, async ({ version }) => {
-    try {
-        return text(await installCli(version));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("fleet", {
-    title: "Control the local @imqueue services fleet",
-    description: "Run `imq ctl <action>` over a directory of service repositories. `status` is read-only; `start`/`stop`/`restart` change running processes. Requires `imq` (see cli_status).",
-    inputSchema: {
-        action: z.enum(["start", "stop", "restart", "status"]).describe("What to do to the fleet"),
-        path: z.string().optional().describe("Directory containing the service repositories (default '.')"),
-        services: z.string().optional().describe("Comma-separated service names; omit to scan the path"),
-        update: z.boolean().optional().describe("git pull each service before starting (start/restart)"),
-        calm: z.boolean().optional().describe("Start services one at a time, waiting for each to be ready"),
-        verbose: z.boolean().optional().describe("Verbose output"),
-        cwd: z.string().optional().describe("Working directory to run in"),
-    },
-}, async ({ action, path, services, update, calm, verbose, cwd }) => {
-    try {
-        return text(await fleet({ action, path, services, update, calm, verbose, cwd }));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("config", {
-    title: "Manage @imqueue CLI configuration",
-    description: "Run `imq config <action>`. `check` = is config initialized; `get [option]` = read a value (or list all); `set option value` = write a value (nested keys use a dot-path, e.g. 'ci.provider'); `init` = interactive setup (prefer `set` for automation — `init` will time out non-interactively). Requires `imq` (see cli_status).",
-    inputSchema: {
-        action: z.enum(["check", "get", "set", "init"]).describe("Config operation"),
-        option: z.string().optional().describe("Config key (dot-path for nested), for get/set"),
-        value: z.string().optional().describe("Value to set (required for `set`)"),
-        cwd: z.string().optional().describe("Working directory to run in"),
-    },
-}, async ({ action, option, value, cwd }) => {
-    try {
-        return text(await config({ action, option, value, cwd }));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
-server.registerTool("logs", {
-    title: "Read or clean @imqueue fleet logs",
-    description: "Work with logs of services started by `imq ctl`. action='dump' (default) returns the current combined logs and exits — it never follows/streams, and output is capped. action='clean' deletes collected logs. Requires `imq` (see cli_status).",
-    inputSchema: {
-        action: z.enum(["dump", "clean"]).optional().describe("dump = read current logs (default); clean = delete collected logs"),
-        services: z.string().optional().describe("Comma-separated service names; omit to combine all"),
-        prefix: z.boolean().optional().describe("Prefix each line with the service name (default true)"),
-        cwd: z.string().optional().describe("Working directory to run in"),
-    },
-}, async ({ action, services, prefix, cwd }) => {
-    try {
-        return text(await logs({ action, services, prefix, cwd }));
-    }
-    catch (e) {
-        return fail(e);
-    }
-});
 async function main() {
@@ -245,0 +20,0 @@ const transport = new StdioServerTransport();

dist/index.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AACA,wEAAwE;AACxE,uEAAuE;AACvE,OAAO,EAAE,SAAS,EAAE,MAAM,yCAAyC,CAAC;AACpE,OAAO,EAAE,oBAAoB,EAAE,MAAM,2CAA2C,CAAC;AACjF,OAAO,EAAE,CAAC,EAAE,MAAM,KAAK,CAAC;AAExB,OAAO,EAAE,aAAa,EAAE,MAAM,aAAa,CAAC;AAE5C,OAAO,EAAE,UAAU,EAAE,MAAM,EAAE,MAAM,WAAW,CAAC;AAC/C,OAAO,EAAE,cAAc,EAAE,MAAM,eAAe,CAAC;AAC/C,OAAO,EAAE,eAAe,EAAE,cAAc,EAAmB,MAAM,eAAe,CAAC;AACjF,OAAO,EAAE,SAAS,EAAE,OAAO,EAAE,aAAa,EAAE,cAAc,EAAE,UAAU,EAAE,KAAK,EAAE,MAAM,EAAE,IAAI,EAAE,MAAM,UAAU,CAAC;AAE9G,yEAAyE;AACzE,2DAA2D;AAC3D,MAAM,OAAO,GAAG,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;AAC/C,MAAM,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,iBAAiB,CAAwB,CAAC;AAEtE,MAAM,IAAI,GAAG,CAAC,CAAS,EAAE,EAAE,CAAC,CAAC,EAAE,OAAO,EAAE,CAAC,EAAE,IAAI,EAAE,MAAe,EAAE,IAAI,EAAE,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC;AAChF,MAAM,IAAI,GAAG,CAAC,CAAU,EAAE,EAAE,CAAC,CAAC;IAC5B,OAAO,EAAE,CAAC,EAAE,IAAI,EAAE,MAAe,EAAE,IAAI,EAAE,UAAU,CAAC,YAAY,KAAK,CAAC,CAAC,CAAC,CAAC,CAAC,OAAO,CAAC,CAAC,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC;IAClG,OAAO,EAAE,IAAI;CACd,CAAC,CAAC;AAEH,MAAM,YAAY,GAAG,CAAC;KACnB,MAAM,CAAC;IACN,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,aAAa,CAAC;IACxC,WAAW,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,sBAAsB,CAAC;IACnE,MAAM,EAAE,CAAC;SACN,KAAK,CACJ,CAAC,CAAC,MAAM,CAAC;QACP,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE;QAChB,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,8CAA8C,CAAC;QACzE,WAAW,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE;KACnC,CAAC,CACH;SACA,QAAQ,EAAE;IACb,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,oEAAoE,CAAC;CAC9G,CAAC;KACD,MAAM,EAAE,CAAC;AAEZ,MAAM,MAAM,GAAG,IAAI,SAAS,CAAC,EAAE,IAAI,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC,CAAC;AAE3D,MAAM,CAAC,YAAY,CACjB,aAAa,EACb;IACE,KAAK,EAAE,+BAA+B;IACtC,WAAW,EACT,+OAA+O;IACjP,WAAW,EAAE;QACX,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,yEAAyE,CAAC;QACrG,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,GAAG,EAAE,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,yBAAyB,CAAC;KACtF;CACF,EACD,KAAK,EAAE,EAAE,KAAK,EAAE,KAAK,EAAE,EAAE,EAAE;IACzB,IAAI,CAAC;QACH,MAAM,IAAI,GAAG,MAAM,UAAU,CAAC,KAAK,EAAE,KAAK,IAAI,CAAC,CAAC,CAAC;QACjD,IAAI,CAAC,IAAI,CAAC,MAAM;YAAE,OAAO,IAAI,CAAC,mBAAmB,KAAK,6CAA6C,CAAC,CAAC;QACrG,MAAM,IAAI,GAAG,IAAI;aACd,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,OAAO,CAAC,CAAC,KAAK,OAAO,CAAC,CAAC,OAAO,OAAO,CAAC,CAAC,WAAW,KAAK,CAAC,CAAC,GAAG,EAAE,CAAC;aAC1E,IAAI,CAAC,MAAM,CAAC,CAAC;QAChB,OAAO,IAAI,CAAC,GAAG,IAAI,CAAC,MAAM,mBAAmB,KAAK,SAAS,IAAI,8CAA8C,CAAC,CAAC;IACjH,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,SAAS,EACT;IACE,KAAK,EAAE,2BAA2B;IAClC,WAAW,EACT,6JAA6J;IAC/J,WAAW,EAAE;QACX,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,gEAAgE,CAAC;KAC3F;CACF,EACD,KAAK,EAAE,EAAE,GAAG,EAAE,EAAE,EAAE;IAChB,IAAI,CAAC;QACH,MAAM,GAAG,GAAG,MAAM,MAAM,CAAC,GAAG,CAAC,CAAC;QAC9B,OAAO,IAAI,CAAC,WAAW,GAAG,CAAC,GAAG,OAAO,GAAG,CAAC,QAAQ,EAAE,CAAC,CAAC;IACvD,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,eAAe,EACf;IACE,KAAK,EAAE,wBAAwB;IAC/B,WAAW,EAAE,+GAA+G;IAC5H,WAAW,EAAE,EAAE;CAChB,EACD,KAAK,IAAI,EAAE;IACT,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,cAAc,EAAE,CAAC,CAAC;IAChC,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,kBAAkB,EAClB;IACE,KAAK,EAAE,8BAA8B;IACrC,WAAW,EACT,8MAA8M;IAChN,WAAW,EAAE;QACX,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,4CAA4C,CAAC;QACvE,OAAO,EAAE,CAAC,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mBAAmB,CAAC;KACxE;CACF,EACD,KAAK,EAAE,EAAE,IAAI,EAAE,OAAO,EAAE,EAAE,EAAE;IAC1B,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,EAAE,OAAmC,CAAC,CAAC,CAAC;IAC1E,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,iBAAiB,EACjB;IACE,KAAK,EAAE,mCAAmC;IAC1C,WAAW,EACT,sOAAsO;IACxO,WAAW,EAAE;QACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,mDAAmD,CAAC;QACjF,OAAO,EAAE,CAAC,CAAC,KAAK,CAAC,YAAY,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,gDAAgD,CAAC;KACrG;CACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,OAAO,EAAE,EAAE,EAAE;IAC7B,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,cAAc,CAAC,OAAO,EAAE,OAAmC,CAAC,CAAC,CAAC;IAC5E,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,+EAA+E;AAE/E,MAAM,CAAC,YAAY,CACjB,YAAY,EACZ;IACE,KAAK,EAAE,wBAAwB;IAC/B,WAAW,EACT,2MAA2M;IAC7M,WAAW,EAAE,EAAE;CAChB,EACD,KAAK,IAAI,EAAE;IACT,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,SAAS,EAAE,CAAC,CAAC;IACjC,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,UAAU,EACV;IACE,KAAK,EAAE,wBAAwB;IAC/B,WAAW,EACT,8MAA8M;IAChN,WAAW,EAAE;QACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+DAA+D,CAAC;KACzG;CACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,EAAE,EAAE;IACpB,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,OAAO,CAAC,OAAO,CAAC,CAAC,CAAC;IACtC,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,gBAAgB,EAChB;IACE,KAAK,EAAE,yCAAyC;IAChD,WAAW,EACT,2XAA2X;IAC7X,WAAW,EAAE;QACX,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,2BAA2B,CAAC;QACtD,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;QACnE,KAAK,EAAE,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,MAAM,EAAE,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,sLAAsL,CAAC;QACtO,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,4DAA4D,CAAC;QACjG,KAAK,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,wEAAwE,CAAC;KACjH;CACF,EACD,KAAK,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,EAAE,EAAE,EAAE;IAC1C,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,aAAa,CAAC,EAAE,IAAI,EAAE,IAAI,EAAE,KAAK,EAAE,GAAG,EAAE,KAAK,EAAE,CAAC,CAAC,CAAC;IACtE,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,iBAAiB,EACjB;IACE,KAAK,EAAE,sCAAsC;IAC7C,WAAW,EACT,uLAAuL;IACzL,WAAW,EAAE;QACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,oEAAoE,CAAC;QAClG,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;QACnE,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;KACnE;CACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,IAAI,EAAE,GAAG,EAAE,EAAE,EAAE;IAC/B,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,cAAc,CAAC,OAAO,EAAE,IAAI,EAAE,GAAG,CAAC,CAAC,CAAC;IACxD,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,aAAa,EACb;IACE,KAAK,EAAE,0BAA0B;IACjC,WAAW,EACT,6LAA6L;IAC/L,WAAW,EAAE;QACX,OAAO,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+CAA+C,CAAC;KACzF;CACF,EACD,KAAK,EAAE,EAAE,OAAO,EAAE,EAAE,EAAE;IACpB,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC;IACzC,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,OAAO,EACP;IACE,KAAK,EAAE,2CAA2C;IAClD,WAAW,EACT,6KAA6K;IAC/K,WAAW,EAAE;QACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,SAAS,EAAE,QAAQ,CAAC,CAAC,CAAC,QAAQ,CAAC,yBAAyB,CAAC;QAC1F,IAAI,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6DAA6D,CAAC;QACnG,QAAQ,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,sDAAsD,CAAC;QAChG,MAAM,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,uDAAuD,CAAC;QAChG,IAAI,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,4DAA4D,CAAC;QACnG,OAAO,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,gBAAgB,CAAC;QAC1D,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;KACnE;CACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,EAAE,EAAE,EAAE;IAC/D,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,KAAK,CAAC,EAAE,MAAM,EAAE,IAAI,EAAE,QAAQ,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;IACnF,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,QAAQ,EACR;IACE,KAAK,EAAE,mCAAmC;IAC1C,WAAW,EACT,mUAAmU;IACrU,WAAW,EAAE;QACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,OAAO,EAAE,KAAK,EAAE,KAAK,EAAE,MAAM,CAAC,CAAC,CAAC,QAAQ,CAAC,kBAAkB,CAAC;QAC5E,MAAM,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,+CAA+C,CAAC;QACvF,KAAK,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mCAAmC,CAAC;QAC1E,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;KACnE;CACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,EAAE,EAAE;IACvC,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,MAAM,CAAC,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;IAC5D,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,MAAM,CAAC,YAAY,CACjB,MAAM,EACN;IACE,KAAK,EAAE,mCAAmC;IAC1C,WAAW,EACT,gPAAgP;IAClP,WAAW,EAAE;QACX,MAAM,EAAE,CAAC,CAAC,IAAI,CAAC,CAAC,MAAM,EAAE,OAAO,CAAC,CAAC,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,mEAAmE,CAAC;QAC1H,QAAQ,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,oDAAoD,CAAC;QAC9F,MAAM,EAAE,CAAC,CAAC,OAAO,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,uDAAuD,CAAC;QAChG,GAAG,EAAE,CAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,EAAE,CAAC,QAAQ,CAAC,6BAA6B,CAAC;KACnE;CACF,EACD,KAAK,EAAE,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,EAAE,GAAG,EAAE,EAAE,EAAE;IAC1C,IAAI,CAAC;QACH,OAAO,IAAI,CAAC,MAAM,IAAI,CAAC,EAAE,MAAM,EAAE,QAAQ,EAAE,MAAM,EAAE,GAAG,EAAE,CAAC,CAAC,CAAC;IAC7D,CAAC;IAAC,OAAO,CAAC,EAAE,CAAC;QACX,OAAO,IAAI,CAAC,CAAC,CAAC,CAAC;IACjB,CAAC;AACH,CAAC,CACF,CAAC;AAEF,KAAK,UAAU,IAAI;IACjB,MAAM,SAAS,GAAG,IAAI,oBAAoB,EAAE,CAAC;IAC7C,MAAM,MAAM,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IAChC,2DAA2D;IAC3D,OAAO,CAAC,KAAK,CAAC,sCAAsC,CAAC,CAAC;AACxD,CAAC;AAED,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,GAAG,EAAE,EAAE;IACnB,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC;IAC7B,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;AAClB,CAAC,CAAC,CAAC"}
+{"version":3,"file":"index.js","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":";AACA,iFAAiF;AACjF,gFAAgF;AAChF,6EAA6E;AAC7E,OAAO,EAAE,oBAAoB,EAAE,MAAM,2CAA2C,CAAC;AACjF,OAAO,EAAE,aAAa,EAAE,MAAM,aAAa,CAAC;AAE5C,OAAO,EAAE,YAAY,EAAE,MAAM,aAAa,CAAC;AAC3C,OAAO,EAAE,SAAS,EAAE,OAAO,EAAE,aAAa,EAAE,cAAc,EAAE,UAAU,EAAE,KAAK,EAAE,MAAM,EAAE,IAAI,EAAE,MAAM,UAAU,CAAC;AAE9G,yEAAyE;AACzE,2DAA2D;AAC3D,MAAM,OAAO,GAAG,aAAa,CAAC,MAAM,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;AAC/C,MAAM,EAAE,OAAO,EAAE,GAAG,OAAO,CAAC,iBAAiB,CAAwB,CAAC;AAEtE,MAAM,MAAM,GAAG,YAAY,CAAC;IAC1B,OAAO;IACP,IAAI,EAAE,OAAO;IACb,GAAG,EAAE,EAAE,SAAS,EAAE,OAAO,EAAE,aAAa,EAAE,cAAc,EAAE,UAAU,EAAE,KAAK,EAAE,MAAM,EAAE,IAAI,EAAE;CAC5F,CAAC,CAAC;AAEH,KAAK,UAAU,IAAI;IACjB,MAAM,SAAS,GAAG,IAAI,oBAAoB,EAAE,CAAC;IAC7C,MAAM,MAAM,CAAC,OAAO,CAAC,SAAS,CAAC,CAAC;IAChC,2DAA2D;IAC3D,OAAO,CAAC,KAAK,CAAC,sCAAsC,CAAC,CAAC;AACxD,CAAC;AAED,IAAI,EAAE,CAAC,KAAK,CAAC,CAAC,GAAG,EAAE,EAAE;IACnB,OAAO,CAAC,KAAK,CAAC,QAAQ,EAAE,GAAG,CAAC,CAAC;IAC7B,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;AAClB,CAAC,CAAC,CAAC"}

package.json

 {
   "name": "@imqueue/mcp",
-  "version": "1.2.1",
+  "version": "2.0.0",
   "mcpName": "org.imqueue/mcp",
@@ -43,3 +43,7 @@ "description": "Model Context Protocol server for @imqueue — lets AI coding agents search the docs and scaffold typed services & clients.",
     "version": "node scripts/sync-version.mjs && git add server.json",
-    "prepublishOnly": "npm run build"
+    "prepublishOnly": "npm run build",
+    "postpublish": "node scripts/publish-registry.mjs",
+    "typecheck:worker": "tsc --noEmit -p worker/tsconfig.json",
+    "dev:worker": "wrangler dev",
+    "deploy:worker": "wrangler deploy"
   },
@@ -53,4 +57,5 @@ "dependencies": {
     "tsx": "^4.19.0",
-    "typescript": "^5.6.0"
+    "typescript": "^5.6.0",
+    "wrangler": "^4.0.0"
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

113952

9.92%

Number of package files

22

15.79%

Lines of code

845

19.86%

Worsened metrics

Dev dependency count

4

33.33%

No dependency changes