feat: Added destroy to connect

Author: kevinwang5658

package.json

@@ -145,7 +145,7 @@
     "deploy": "npm run pkg && npm run notarize && npm run upload",
     "prepublishOnly": "npm run build"
   },
-  "version": "1.1.0-beta7",
+  "version": "1.1.0-beta8",
   "bugs": "https://github.com/codifycli/codify/issues",
   "keywords": [
     "oclif",

src/connect/http-routes/create-command.ts

@@ -12,6 +12,7 @@ export enum ConnectCommand {
   PLAN = 'plan',
   IMPORT = 'import',
   REFRESH = 'refresh',
+  DESTROY = 'destroy',
   INIT = 'init',
   TEST = 'test',
 }

src/connect/http-routes/handlers/destroy-handler.ts

@@ -0,0 +1,53 @@
+import { spawn } from '@homebridge/node-pty-prebuilt-multiarch';
+import { ConfigFileSchema } from '@codifycli/schemas';
+import * as fs from 'node:fs/promises';
+import os from 'node:os';
+import path from 'node:path';
+import { WebSocket } from 'ws';
+
+import { ConnectOrchestrator } from '../../../orchestrators/connect.js';
+import { ajv } from '../../../utils/ajv.js';
+import { ShellUtils } from '../../../utils/shell.js';
+import { Session } from '../../socket-server.js';
+import { ConnectCommand, createCommandHandler } from '../create-command.js';
+
+const validator = ajv.compile(ConfigFileSchema);
+
+export function destroyHandler() {
+  const spawnCommand = async (body: Record<string, unknown>, ws: WebSocket, session: Session) => {
+    const codifyConfig = body.config;
+    if (!codifyConfig) {
+      throw new Error('Unable to parse codify config');
+    }
+
+    if (!validator(codifyConfig)) {
+      throw new Error('Invalid codify config');
+    }
+
+    const tmpDir = await fs.mkdtemp(os.tmpdir() + '/');
+    const filePath = path.join(tmpDir, 'codify.jsonc');
+    await fs.writeFile(filePath, JSON.stringify(codifyConfig, null, 2));
+
+    session.additionalData.filePath = filePath;
+
+    return spawn(ShellUtils.getDefaultShell(), ['-c', `${ConnectOrchestrator.nodeBinary} ${ConnectOrchestrator.rootCommand} destroy -p ${filePath}`], {
+      name: 'xterm-color',
+      cols: 80,
+      rows: 30,
+      cwd: process.env.HOME,
+      env: process.env
+    });
+  }
+
+  const onExit = async (exitCode: number, ws: WebSocket, session: Session) => {
+    if (session.additionalData.filePath) {
+      await fs.rm(session.additionalData.filePath as string, { recursive: true, force: true });
+    }
+  }
+
+  return createCommandHandler({
+    name: ConnectCommand.DESTROY,
+    spawnCommand,
+    onExit
+  });
+}

src/connect/http-routes/router.ts

@@ -1,6 +1,7 @@
 import { Router } from 'express';
 
 import { applyHandler } from './handlers/apply-handler.js';
+import { destroyHandler } from './handlers/destroy-handler.js';
 import { importHandler } from './handlers/import-handler.js';
 import defaultHandler from './handlers/index.js';
 import { initHandler } from './handlers/init-handler.js';
@@ -14,6 +15,7 @@ const router = Router();
 
 router.use('/', defaultHandler);
 router.use('/apply', applyHandler());
+router.use('/destroy', destroyHandler());
 router.use('/plan', planHandler())
 router.use('/import', importHandler());
 router.use('/refresh', refreshHandler());