Readwise MCP Server

#!/usr/bin/env node // Runtime imports - need .js extension import { ReadwiseMCPServer } from './server.js'; // Type-only imports - no .js extension import type { TransportType } from './types/index.js'; // Local imports with implementation - need .js extension import { ReadwiseClient } from './api/client.js'; import { ReadwiseAPI } from './api/readwise-api.js'; import { SafeLogger } from './utils/safe-logger.js'; import { LogLevel } from './utils/logger-interface.js'; import { getConfig, saveConfig } from './utils/config.js'; import yargs from 'yargs'; import { hideBin } from 'yargs/helpers'; import readline from 'readline'; /** * Main entry point for the Readwise MCP server */ async function main() { try { const argv = yargs(hideBin(process.argv)) .option('port', { alias: 'p', description: 'Port to listen on', type: 'number', default: process.env.PORT ? parseInt(process.env.PORT, 10) : 8081 }) .option('transport', { alias: 't', description: 'Transport type (stdio or sse)', choices: ['stdio', 'sse'] as TransportType[], default: 'stdio' as TransportType }) .option('debug', { alias: 'd', description: 'Enable debug logging', type: 'boolean', default: false }) .option('api-key', { alias: 'k', description: 'Readwise API key', type: 'string' }) .option('setup', { alias: 's', description: 'Run setup wizard', type: 'boolean', default: false }) .help() .argv as { port: number; transport: TransportType; debug: boolean; 'api-key'?: string; setup: boolean; }; // Create logger const logger = new SafeLogger({ level: argv.debug ? LogLevel.DEBUG : LogLevel.INFO, transport: argv.transport === 'sse' ? console.log : console.error, timestamps: true, colors: true, }); logger.info('Starting Readwise MCP server'); logger.debug('Command line arguments:', argv as any); try { // Run setup wizard if requested if (argv.setup) { const apiKey = await runSetupWizard(); logger.info('Setup complete'); return; } // Load config logger.debug('Loading configuration...'); const config = getConfig(); logger.debug('Configuration loaded'); // Get API key from command-line args, config, or environment const apiKey = argv['api-key'] || config.readwiseApiKey || process.env.READWISE_API_KEY || ''; // Allow server to start without API key for Smithery scanning (lazy loading) // API key will be validated when tools are actually called if (!apiKey) { logger.warn('No API key provided. Server will start but tools will require authentication.'); } else { logger.debug('API key provided'); } logger.info('Initializing server...'); logger.info(`Port: ${argv.port}, Transport: ${argv.transport}`); // Start the server let server: ReadwiseMCPServer; try { server = new ReadwiseMCPServer( apiKey, argv.port, logger, argv.transport ); logger.info('Server instance created successfully'); } catch (error) { logger.error('Failed to create server instance:', error as any); throw error; } logger.info('Starting server...'); try { await server.start(); logger.info('✓ Server started successfully'); logger.info(`✓ Server is running and ready to accept connections on port ${argv.port}`); // Keep the process alive - important for containerized deployments // The server will continue running until explicitly stopped setInterval(() => { // Periodic heartbeat to ensure process stays alive // This helps detect if the process is still responsive if (process.uptime() % 60 === 0) { logger.debug(`Server heartbeat: uptime ${Math.floor(process.uptime())}s`); } }, 10000); // Every 10 seconds } catch (error) { logger.error('Failed to start server:', error as any); process.exit(1); } // Handle shutdown gracefully const shutdown = async () => { logger.info('Shutting down...'); try { await server.stop(); logger.info('Server stopped successfully'); } catch (error) { logger.error('Error stopping server:', error as any); } process.exit(0); }; process.on('SIGINT', shutdown); process.on('SIGTERM', shutdown); // Handle unhandled errors - log but don't exit immediately to allow health checks process.on('uncaughtException', (error) => { logger.error('Uncaught exception', error); // Log but don't exit - allow health checks to still work // In production, you might want to exit here, but for Smithery we want to stay alive }); process.on('unhandledRejection', (reason, promise) => { logger.error('Unhandled promise rejection', { reason, promise } as any); // Log but don't exit - allow server to continue serving health checks }); } catch (error) { logger.error('Failed to start server:', error as any); process.exit(1); } } catch (error) { // Top-level error handler - log and exit if we can't even create logger console.error('Fatal error starting server:', error); if (error instanceof Error) { console.error('Error details:', { message: error.message, stack: error.stack, name: error.name }); } process.exit(1); } } /** * Run the setup wizard to configure the API key */ async function runSetupWizard(): Promise<string> { const rl = readline.createInterface({ input: process.stdin, output: process.stdout }); const question = (prompt: string): Promise<string> => { return new Promise((resolve) => { rl.question(prompt, (answer) => { resolve(answer); }); }); }; console.log('Readwise MCP Server Setup Wizard'); console.log('-------------------------------'); console.log(''); console.log('This wizard will help you set up your Readwise MCP server.'); console.log('You will need your Readwise API key to continue.'); console.log(''); console.log('You can find your API key at https://readwise.io/access_token'); console.log(''); let apiKey = await question('Enter your Readwise API key: '); while (!apiKey) { console.log('API key is required.'); apiKey = await question('Enter your Readwise API key: '); } try { // Test the API key by making a request to the Readwise API console.log('Validating API key...'); const client = new ReadwiseClient({ apiKey }); const api = new ReadwiseAPI(client); try { // Attempt to fetch a single book to verify API key works await api.getBooks({ page: 1, page_size: 1 }); console.log('API key validated successfully.'); } catch (error) { if (error instanceof Error && error.message.includes('401')) { console.error('Error: Invalid API key. Please check your API key and try again.'); rl.close(); return runSetupWizard(); // Restart the setup wizard } console.warn('Warning: Could not validate API key due to API connection issue.'); const proceed = await question('Do you want to save this API key anyway? (y/n): '); if (proceed.toLowerCase() !== 'y') { rl.close(); return runSetupWizard(); // Restart the setup wizard } } // Save the API key to the config with secure permissions saveConfig({ readwiseApiKey: apiKey }); console.log(''); console.log('Configuration saved successfully.'); console.log('You can now start the server using:'); console.log(' readwise-mcp'); console.log(''); } catch (error) { console.error('Error saving configuration:', error instanceof Error ? error.message : String(error)); } finally { rl.close(); } return apiKey; } // Start the server with comprehensive error handling main().catch((error) => { console.error('Fatal error starting server:', error); if (error instanceof Error) { console.error('Error message:', error.message); console.error('Error stack:', error.stack); } else { console.error('Non-Error object:', error); } process.exit(1); }); // Ensure process doesn't exit unexpectedly process.on('beforeExit', (code) => { console.error(`Process about to exit with code ${code}`); }); process.on('exit', (code) => { console.error(`Process exiting with code ${code}`); });