mirror of
https://github.com/Kaelio/ktx.git
synced 2026-06-16 08:25:14 +02:00
99f7a31919
Make packages/cli/package.json the single source of truth for the @kaelio/ktx version. publicNpmPackageVersion() now reads it directly, so artifact filenames, release-readiness checks, and the Python wheel version all derive from one field. The duplicate release-policy.json.publicNpmPackageVersion is removed. Previously the two fields could drift: tarballs were named kaelio-ktx-0.4.1.tgz while internally containing @kaelio/ktx@0.0.0-private. - update-public-release-version.mjs rewrites both Python pyproject.toml files (ktx-daemon, ktx-sl) alongside the npm package.jsons, normalizing the version for PEP 440 (e.g. 0.1.0-rc.2 -> 0.1.0rc2). - semantic-release-config.cjs adds the two pyproject.toml files to @semantic-release/git assets so the release commit back to main carries every version source in lockstep. - The six "?? '0.0.0-private'" fallback literals across the CLI are replaced with "?? getKtxCliPackageInfo().version", and createDefaultKtxMcpServer makes its version arg required. - docs/release.md describes the actual commit-back model: the dev tree always reflects the most recent release; no sentinel pin to maintain. Verified: pnpm run artifacts:build now produces kaelio-ktx-0.4.1.tgz and kaelio_ktx-0.4.1-py3-none-any.whl with @kaelio/ktx@0.4.1 inside. Full type-check, dead-code, and 2287 vitests + 173 script tests pass.
64 lines
2.3 KiB
TypeScript
64 lines
2.3 KiB
TypeScript
import process from 'node:process';
|
|
import type { Readable, Writable } from 'node:stream';
|
|
import { loadKtxProject } from './context/project/project.js';
|
|
import type { McpServer } from '@modelcontextprotocol/sdk/server/mcp.js';
|
|
import { StdioServerTransport } from '@modelcontextprotocol/sdk/server/stdio.js';
|
|
import { getKtxCliPackageInfo, type KtxCliIo } from './cli-runtime.js';
|
|
import { createKtxMcpServerFactory } from './mcp-server-factory.js';
|
|
|
|
export interface RunKtxMcpStdioServerOptions {
|
|
projectDir: string;
|
|
cliVersion?: string;
|
|
io?: KtxCliIo;
|
|
createMcpServer?: () => McpServer;
|
|
loadProject?: typeof loadKtxProject;
|
|
stdin?: Readable;
|
|
stdout?: Writable;
|
|
}
|
|
|
|
export async function runKtxMcpStdioServer(options: RunKtxMcpStdioServerOptions): Promise<void> {
|
|
const project =
|
|
options.createMcpServer === undefined
|
|
? await (options.loadProject ?? loadKtxProject)({ projectDir: options.projectDir })
|
|
: undefined;
|
|
const protocolIo: KtxCliIo = {
|
|
stdout: { write() {} },
|
|
stderr: options.io?.stderr ?? process.stderr,
|
|
};
|
|
const createMcpServer =
|
|
options.createMcpServer ??
|
|
(await createKtxMcpServerFactory({
|
|
project: project!,
|
|
projectDir: options.projectDir,
|
|
cliVersion: options.cliVersion ?? getKtxCliPackageInfo().version,
|
|
io: protocolIo,
|
|
}));
|
|
const stdin = options.stdin ?? process.stdin;
|
|
const transport = new StdioServerTransport(stdin, options.stdout);
|
|
|
|
await new Promise<void>((resolve, reject) => {
|
|
let settled = false;
|
|
const settle = (callback: () => void) => {
|
|
if (settled) return;
|
|
settled = true;
|
|
stdin.off('end', closeTransport);
|
|
stdin.off('close', closeTransport);
|
|
callback();
|
|
};
|
|
const closeTransport = () => {
|
|
transport.close().catch((error: unknown) => {
|
|
settle(() => reject(error instanceof Error ? error : new Error(String(error))));
|
|
});
|
|
};
|
|
transport.onclose = () => settle(resolve);
|
|
transport.onerror = (error) => {
|
|
options.io?.stderr.write(`KTX MCP stdio transport error: ${error.message}\n`);
|
|
settle(() => reject(error));
|
|
};
|
|
stdin.once('end', closeTransport);
|
|
stdin.once('close', closeTransport);
|
|
createMcpServer().connect(transport).catch((error: unknown) => {
|
|
settle(() => reject(error instanceof Error ? error : new Error(String(error))));
|
|
});
|
|
});
|
|
}
|