/**
* Integration test runner for RemNote MCP Server.
*
* Runs real MCP tool calls against a live server with a connected RemNote plugin.
* Creates real content in RemNote — all prefixed with [MCP-TEST] for easy cleanup.
*
* Usage:
* npm run test:integration # Interactive — prompts for confirmation
* npm run test:integration -- --yes # Skip confirmation prompt
*
* Environment variables:
* REMNOTE_MCP_URL — MCP server URL (default: http://127.0.0.1:3001)
* MCP_TEST_DELAY — Delay in ms after create before search (default: 2000)
*/
import * as readline from 'node:readline';
import { McpTestClient } from './mcp-test-client.js';
import { statusWorkflow } from './workflows/01-status.js';
import { createSearchWorkflow } from './workflows/02-create-search.js';
import { readUpdateWorkflow } from './workflows/03-read-update.js';
import { journalWorkflow } from './workflows/04-journal.js';
import { errorCasesWorkflow } from './workflows/05-error-cases.js';
import type { WorkflowResult, WorkflowFn, SharedState } from './types.js';
const RESET = '\x1b[0m';
const GREEN = '\x1b[32m';
const RED = '\x1b[31m';
const YELLOW = '\x1b[33m';
const BOLD = '\x1b[1m';
const DIM = '\x1b[2m';
function printBanner(): void {
console.log(`
${BOLD}╔═══════════════════════════════════════════════╗
║ RemNote MCP Server — Integration Tests ║
║ ${YELLOW}WARNING: Creates real content in RemNote!${RESET}${BOLD} ║
╚═══════════════════════════════════════════════╝${RESET}
`);
}
async function confirmPrompt(): Promise<boolean> {
const rl = readline.createInterface({
input: process.stdin,
output: process.stdout,
});
return new Promise((resolve) => {
rl.question('Continue? (y/N) ', (answer) => {
rl.close();
resolve(answer.trim().toLowerCase() === 'y');
});
});
}
function printStepResult(label: string, passed: boolean, durationMs: number, error?: string): void {
const icon = passed ? `${GREEN}✓${RESET}` : `${RED}✗${RESET}`;
const timing = `${DIM}(${durationMs}ms)${RESET}`;
console.log(` ${icon} ${label} ${timing}`);
if (error) {
console.log(` ${RED}${error}${RESET}`);
}
}
function printWorkflowResult(index: number, result: WorkflowResult): void {
const prefix = String(index + 1).padStart(2, '0');
if (result.skipped) {
console.log(`\n${DIM}[${prefix}] ${result.name} (skipped)${RESET}`);
} else {
console.log(`\n[${prefix}] ${result.name}`);
}
for (const step of result.steps) {
printStepResult(step.label, step.passed, step.durationMs, step.error);
}
}
function printSummary(results: WorkflowResult[], totalDurationMs: number): void {
const totalWorkflows = results.length;
const passedWorkflows = results.filter(
(r) => !r.skipped && r.steps.every((s) => s.passed)
).length;
const totalSteps = results.reduce((sum, r) => sum + r.steps.length, 0);
const passedSteps = results.reduce((sum, r) => sum + r.steps.filter((s) => s.passed).length, 0);
const allPassed = passedWorkflows === totalWorkflows;
const color = allPassed ? GREEN : RED;
console.log(`\n${BOLD}═══ Summary ═══${RESET}`);
console.log(
`${color}${passedWorkflows}/${totalWorkflows} workflows passed (${passedSteps}/${totalSteps} steps)${RESET}`
);
console.log(`Duration: ${(totalDurationMs / 1000).toFixed(1)}s`);
console.log(`\n${BOLD}═══ Cleanup ═══${RESET}`);
console.log('Test artifacts created with prefix [MCP-TEST].');
console.log('Search your RemNote KB for "[MCP-TEST]" to find and delete them.');
}
async function main(): Promise<void> {
const skipConfirm = process.argv.includes('--yes');
const baseUrl = process.env.REMNOTE_MCP_URL ?? 'http://127.0.0.1:3001';
const mcpUrl = baseUrl.endsWith('/mcp') ? baseUrl : `${baseUrl}/mcp`;
const runId = new Date().toISOString();
printBanner();
if (!skipConfirm) {
const confirmed = await confirmPrompt();
if (!confirmed) {
console.log('Aborted.');
process.exit(0);
}
}
console.log(`Server: ${mcpUrl}`);
console.log(`Run ID: ${runId}`);
const client = new McpTestClient();
const results: WorkflowResult[] = [];
const state: SharedState = {};
const overallStart = Date.now();
// Connect to MCP server
try {
await client.connect(baseUrl);
} catch (e) {
console.error(`\n${RED}Failed to connect to MCP server at ${mcpUrl}${RESET}`);
console.error(`${RED}${(e as Error).message}${RESET}`);
console.error(`\nMake sure the server is running: ${BOLD}npm run dev${RESET}`);
process.exit(1);
}
// Define workflow sequence
const workflows: Array<{ name: string; fn: WorkflowFn }> = [
{ name: 'Status Check', fn: statusWorkflow },
{ name: 'Create & Search', fn: createSearchWorkflow },
{ name: 'Read & Update', fn: readUpdateWorkflow },
{ name: 'Journal', fn: journalWorkflow },
{ name: 'Error Cases', fn: errorCasesWorkflow },
];
try {
for (let i = 0; i < workflows.length; i++) {
const workflow = workflows[i];
// If status check failed, skip remaining workflows
if (i === 1 && results[0] && results[0].steps.some((s) => !s.passed)) {
const skippedResult: WorkflowResult = {
name: workflow.name,
steps: [
{
label: 'Skipped — status check failed',
passed: false,
durationMs: 0,
error: 'Prerequisite workflow 01 (Status Check) failed',
},
],
skipped: true,
};
results.push(skippedResult);
printWorkflowResult(i, skippedResult);
// Skip all remaining workflows too
for (let j = i + 1; j < workflows.length; j++) {
const skipped: WorkflowResult = {
name: workflows[j].name,
steps: [
{
label: 'Skipped — status check failed',
passed: false,
durationMs: 0,
error: 'Prerequisite workflow 01 (Status Check) failed',
},
],
skipped: true,
};
results.push(skipped);
printWorkflowResult(j, skipped);
}
break;
}
const result = await workflow.fn({ client, runId }, state);
results.push(result);
printWorkflowResult(i, result);
}
} finally {
await client.close();
}
const totalDuration = Date.now() - overallStart;
printSummary(results, totalDuration);
const allPassed = results.every((r) => !r.skipped && r.steps.every((s) => s.passed));
process.exit(allPassed ? 0 : 1);
}
main().catch((e) => {
console.error(`\n${RED}Unexpected error: ${(e as Error).message}${RESET}`);
process.exit(1);
});
