|
| 1 | +import { Command } from 'commander'; |
| 2 | +import path from 'path'; |
| 3 | +import { logger } from '../core/logger.js'; |
| 4 | +import { |
| 5 | + startSyncServer, |
| 6 | + stopSyncServer, |
| 7 | + getSyncServerStatus, |
| 8 | + pushDirectoryToSyncServer, |
| 9 | + pullDirectoryFromSyncServer, |
| 10 | + getSyncHistory, |
| 11 | + runSyncDaemon, |
| 12 | + checkDockerAndOptionallyInstall |
| 13 | +} from '../core/sync.js'; |
| 14 | + |
| 15 | +const DEFAULT_SERVER_URL = 'http://127.0.0.1:4780'; |
| 16 | + |
| 17 | +export const syncCommand = new Command('sync') |
| 18 | + .description('Mock remote sync features (GitHub-like push/pull for local environments)'); |
| 19 | + |
| 20 | +syncCommand.command('start') |
| 21 | + .description('Start local mock sync server') |
| 22 | + .option('--host <host>', 'Bind host', '127.0.0.1') |
| 23 | + .option('--port <port>', 'Bind port', '4780') |
| 24 | + .action(async (options) => { |
| 25 | + try { |
| 26 | + await startSyncServer(options.host, Number(options.port)); |
| 27 | + } catch (error) { |
| 28 | + logger.error('Failed to start sync server', error); |
| 29 | + process.exit(1); |
| 30 | + } |
| 31 | + }); |
| 32 | + |
| 33 | +syncCommand.command('stop') |
| 34 | + .description('Stop local mock sync server') |
| 35 | + .action(async () => { |
| 36 | + try { |
| 37 | + await stopSyncServer(); |
| 38 | + } catch (error) { |
| 39 | + logger.error('Failed to stop sync server', error); |
| 40 | + process.exit(1); |
| 41 | + } |
| 42 | + }); |
| 43 | + |
| 44 | +syncCommand.command('status') |
| 45 | + .description('Show local mock sync server status') |
| 46 | + .action(async () => { |
| 47 | + try { |
| 48 | + const status = await getSyncServerStatus(); |
| 49 | + if (!status.running) { |
| 50 | + logger.info('Sync server: STOPPED'); |
| 51 | + return; |
| 52 | + } |
| 53 | + logger.info(`Sync server: RUNNING (pid: ${status.pid}, host: ${status.host}, port: ${status.port})`); |
| 54 | + } catch (error) { |
| 55 | + logger.error('Failed to read sync server status', error); |
| 56 | + process.exit(1); |
| 57 | + } |
| 58 | + }); |
| 59 | + |
| 60 | +syncCommand.command('push') |
| 61 | + .description('Push a local directory snapshot to mock sync server') |
| 62 | + .requiredOption('--repo <name>', 'Repository name on sync server') |
| 63 | + .option('--source <dir>', 'Local source directory', process.cwd()) |
| 64 | + .option('--server <url>', 'Sync server URL', DEFAULT_SERVER_URL) |
| 65 | + .option('--message <message>', 'Snapshot message') |
| 66 | + .action(async (options) => { |
| 67 | + try { |
| 68 | + const sourceDir = path.resolve(options.source); |
| 69 | + logger.info(`Preparing snapshot from: ${sourceDir}`); |
| 70 | + const result = await pushDirectoryToSyncServer({ |
| 71 | + sourceDir, |
| 72 | + repo: options.repo, |
| 73 | + serverUrl: options.server, |
| 74 | + message: options.message |
| 75 | + }); |
| 76 | + |
| 77 | + logger.info(`Push complete. Version: v${result.version}, files: ${result.fileCount}`); |
| 78 | + } catch (error) { |
| 79 | + logger.error('Sync push failed', error); |
| 80 | + process.exit(1); |
| 81 | + } |
| 82 | + }); |
| 83 | + |
| 84 | +syncCommand.command('pull') |
| 85 | + .description('Pull a snapshot from mock sync server into local directory') |
| 86 | + .requiredOption('--repo <name>', 'Repository name on sync server') |
| 87 | + .option('--target <dir>', 'Local target directory', process.cwd()) |
| 88 | + .option('--server <url>', 'Sync server URL', DEFAULT_SERVER_URL) |
| 89 | + .option('--version <version>', 'Snapshot version (default: latest)', 'latest') |
| 90 | + .action(async (options) => { |
| 91 | + try { |
| 92 | + const targetDir = path.resolve(options.target); |
| 93 | + logger.info(`Pulling into: ${targetDir}`); |
| 94 | + const result = await pullDirectoryFromSyncServer({ |
| 95 | + targetDir, |
| 96 | + repo: options.repo, |
| 97 | + serverUrl: options.server, |
| 98 | + version: options.version |
| 99 | + }); |
| 100 | + |
| 101 | + logger.info(`Pull complete. Version: v${result.version}, files: ${result.fileCount}`); |
| 102 | + } catch (error) { |
| 103 | + logger.error('Sync pull failed', error); |
| 104 | + process.exit(1); |
| 105 | + } |
| 106 | + }); |
| 107 | + |
| 108 | +syncCommand.command('history') |
| 109 | + .description('Show snapshot history for a repo on mock sync server') |
| 110 | + .requiredOption('--repo <name>', 'Repository name on sync server') |
| 111 | + .option('--server <url>', 'Sync server URL', DEFAULT_SERVER_URL) |
| 112 | + .action(async (options) => { |
| 113 | + try { |
| 114 | + const history = await getSyncHistory(options.server, options.repo); |
| 115 | + logger.info(`Latest: v${history.latestVersion}`); |
| 116 | + logger.info(`Versions: ${history.versions.length ? history.versions.map(v => `v${v}`).join(', ') : '(none)'}`); |
| 117 | + } catch (error) { |
| 118 | + logger.error('Failed to fetch sync history', error); |
| 119 | + process.exit(1); |
| 120 | + } |
| 121 | + }); |
| 122 | + |
| 123 | +syncCommand.command('docker') |
| 124 | + .description('Check Docker availability (optional auto install via winget)') |
| 125 | + .option('--install', 'Install Docker Desktop on Windows if missing') |
| 126 | + .action(async (options) => { |
| 127 | + try { |
| 128 | + const status = await checkDockerAndOptionallyInstall(Boolean(options.install)); |
| 129 | + if (status.installed) { |
| 130 | + logger.info(`Docker: INSTALLED (${status.version})`); |
| 131 | + return; |
| 132 | + } |
| 133 | + |
| 134 | + logger.warn('Docker: NOT INSTALLED'); |
| 135 | + if (status.installMessage) { |
| 136 | + logger.info(status.installMessage); |
| 137 | + } |
| 138 | + } catch (error) { |
| 139 | + logger.error('Docker check/install failed', error); |
| 140 | + process.exit(1); |
| 141 | + } |
| 142 | + }); |
| 143 | + |
| 144 | +syncCommand.command('daemon', { hidden: true }) |
| 145 | + .option('--host <host>', 'Bind host', '127.0.0.1') |
| 146 | + .option('--port <port>', 'Bind port', '4780') |
| 147 | + .action(async (options) => { |
| 148 | + try { |
| 149 | + await runSyncDaemon(options.host, Number(options.port)); |
| 150 | + } catch (error) { |
| 151 | + logger.error('Sync daemon failed', error); |
| 152 | + process.exit(1); |
| 153 | + } |
| 154 | + }); |
0 commit comments