Added uninstall command

Author: kevinwang5658

README.md

@@ -41,6 +41,7 @@ USAGE
 * [`codify plugins:uninstall PLUGIN...`](#codify-pluginsuninstall-plugin-1)
 * [`codify plugins:uninstall PLUGIN...`](#codify-pluginsuninstall-plugin-2)
 * [`codify plugins update`](#codify-plugins-update)
+* [`codify uninstall [RESOURCE]`](#codify-uninstall-resource)
 
 ## `codify apply [FILE]`
 
@@ -400,4 +401,24 @@ DESCRIPTION
 ```
 
 _See code: [@oclif/plugin-plugins](https://github.com/oclif/plugin-plugins/blob/v3.9.4/src/commands/plugins/update.ts)_
+
+## `codify uninstall [RESOURCE]`
+
+describe the command here
+
+```
+USAGE
+  $ codify uninstall [RESOURCE]
+
+ARGUMENTS
+  RESOURCE  resource type to uninstall
+
+DESCRIPTION
+  describe the command here
+
+EXAMPLES
+  $ codify uninstall
+```
+
+_See code: [src/commands/uninstall.ts](https://github.com/kevinwang5658/codify/blob/v0.0.0/src/commands/uninstall.ts)_
 <!-- commandsstop -->

src/commands/apply/index.ts

@@ -51,6 +51,7 @@ export default class Apply extends Command {
       await ApplyOrchestrator.run(planResult);
     } catch (error: unknown) {
       console.error(error);
+      process.exit(1);
     }
 
     process.exit(0);

src/commands/uninstall.ts

@@ -0,0 +1,48 @@
+import { Args, Command } from '@oclif/core'
+import { UninstallOrchestrator } from '../orchestrators/uninstall.js';
+import { DefaultReporter } from '../ui/reporters/default-reporter.js';
+import { ctx } from '../events/context.js';
+
+export default class Uninstall extends Command {
+  static description = 'describe the command here'
+
+  static examples = [
+    '<%= config.bin %> <%= command.id %>',
+  ]
+
+  static flags = {}
+
+  static strict = false;
+
+  static args = {
+    resources: Args.string({
+      description: 'A resource typeId for uninstalling. Ex: "codify uninstall homebrew"',
+      required: true,
+    }),
+  }
+
+  public async run(): Promise<void> {
+    const { raw } = await this.parse(Uninstall)
+    new DefaultReporter()
+
+    const args = raw
+      .filter((r) => r.type === 'arg')
+      .map((r) => r.input);
+
+
+    // const name = flags.name ?? 'world'
+    // this.log(`hello ${name} from /Users/kevinwang/Projects/codify2/codify/src/commands/uninstall.ts`)
+    if (args.length === 0) {
+      throw new Error('A resource id must be specified for uninstall. Ex: "codify uninstall homebrew"')
+    }
+
+    try {
+      await UninstallOrchestrator.run(args);
+    } catch (error) {
+      ctx.log(error);
+      process.exit(1);
+    }
+
+    process.exit(0);
+  }
+}

src/events/context.ts

@@ -15,7 +15,8 @@ export enum Event {
 
 export enum ProcessName {
   PLAN = 'plan',
-  APPLY = 'apply'
+  APPLY = 'apply',
+  UNINSTALL = 'uninstall',
 }
 
 export enum SubProcessName {

src/orchestrators/apply.ts

@@ -10,8 +10,10 @@ export const ApplyOrchestrator = {
       .filter((p) => p.operation !== ResourceOperation.NOOP)
 
     ctx.processStarted(ProcessName.APPLY);
+
     await pluginCollection.apply(filteredPlan);
     await pluginCollection.destroy();
+
     ctx.processFinished(ProcessName.APPLY);
   },
 };

src/orchestrators/common.ts

@@ -0,0 +1,17 @@
+import { Project } from '../entities/project.js';
+import { ctx, SubProcessName } from '../events/context.js';
+import { DependencyMap, PluginCollection } from '../plugins/plugin-collection.js';
+
+export const CommonOrchestrator = {
+  async initializePlugins(project?: Project): Promise<{
+    dependencyMap: DependencyMap
+    pluginCollection: PluginCollection,
+  }> {
+    ctx.subprocessStarted(SubProcessName.INITIALIZE_PLUGINS)
+    const pluginCollection = new PluginCollection();
+    const dependencyMap = await pluginCollection.initialize(project);
+    ctx.subprocessFinished(SubProcessName.INITIALIZE_PLUGINS)
+
+    return { dependencyMap, pluginCollection };
+  },
+};

src/orchestrators/plan.ts

@@ -4,6 +4,7 @@ import { Project } from '../entities/project.js';
 import { ctx, ProcessName, SubProcessName } from '../events/context.js';
 import { Parser } from '../parser/index.js';
 import { PluginCollection } from '../plugins/plugin-collection.js';
+import { CommonOrchestrator } from './common.js';
 
 export interface PlanOrchestratorResponse {
   plan: PlanResponseData[],
@@ -19,10 +20,7 @@ export const PlanOrchestrator = {
     const project = await Parser.parseProject(path);
     ctx.subprocessFinished(SubProcessName.PARSE);
 
-    ctx.subprocessStarted(SubProcessName.INITIALIZE_PLUGINS)
-    const pluginCollection = new PluginCollection();
-    const dependencyMap = await pluginCollection.initialize(project);
-    ctx.subprocessFinished(SubProcessName.INITIALIZE_PLUGINS)
+    const { dependencyMap, pluginCollection } = await CommonOrchestrator.initializePlugins(project);
 
     ctx.subprocessStarted(SubProcessName.VALIDATE)
     project.validateWithResourceMap(dependencyMap);

src/orchestrators/uninstall.ts

@@ -0,0 +1,29 @@
+import { PlanResponseData, ResourceOperation } from 'codify-schemas';
+import { randomUUID } from 'node:crypto';
+
+import { ctx, ProcessName } from '../events/context.js';
+import { CommonOrchestrator } from './common.js';
+
+export const UninstallOrchestrator = {
+  async run(typeIds: string[]): Promise<void> {
+    if (typeIds.length === 0) {
+      return;
+    }
+
+    const plan = typeIds.map((type) => ({
+      operation: ResourceOperation.DESTROY,
+      parameters: [] as any[],
+      planId: randomUUID(),
+      resourceType: type,
+    } as PlanResponseData))
+
+    const { pluginCollection } = await CommonOrchestrator.initializePlugins();
+
+    ctx.processStarted(ProcessName.UNINSTALL);
+
+    await pluginCollection.apply(plan);
+    await pluginCollection.destroy();
+
+    ctx.processFinished(ProcessName.UNINSTALL);
+  },
+};

src/plugins/plugin-collection.ts

@@ -20,7 +20,7 @@ export class PluginCollection {
   private resourceToPluginMapping = new Map<string, string>()
   private pluginToResourceMapping = new Map<string, string[]>()
 
-  async initialize(project: Project): Promise<Map<string, string[]>> {
+  async initialize(project?: Project): Promise<Map<string, string[]>> {
     const plugins = await this.resolvePlugins(project);
 
     for (const plugin of plugins) {
@@ -62,15 +62,17 @@ export class PluginCollection {
   }
 
   async apply(planResponseData: PlanResponseData[]): Promise<void> {
-    for (const { planId, resourceType } of planResponseData) {
+    for (const plan of planResponseData) {
+      const { resourceType } = plan;
+
       ctx.subprocessStarted(SubProcessName.APPLYING_RESOURCE, resourceType);
 
       const pluginName = this.resourceToPluginMapping.get(resourceType);
       if (!pluginName) {
         throw new Error(`Internal error: unable to determine plugin for apply: ${resourceType}`);
       }
 
-      await this.plugins.get(pluginName)!.apply(planId);
+      await this.plugins.get(pluginName)!.apply(plan);
 
       ctx.subprocessFinished(SubProcessName.APPLYING_RESOURCE, resourceType);
     }
@@ -82,15 +84,19 @@ export class PluginCollection {
     }
   }
 
-  private async resolvePlugins(project: Project): Promise<Plugin[]> {
+  private async resolvePlugins(project?: Project): Promise<Plugin[]> {
     const pluginDefinitions: Record<string, string> = {
       ...DEFAULT_PLUGINS,
-      ...project.projectConfig?.plugins,
+      ...project?.projectConfig?.plugins,
     };
 
-    return Promise.all(Object.entries(pluginDefinitions).map(([name, version]) =>
+    const configPlugins = await Promise.all(Object.entries(pluginDefinitions).map(([name, version]) =>
       PluginResolver.resolve(name, version)
     ));
+
+    const existingPlugins = await PluginResolver.resolveExisting(Object.keys(pluginDefinitions));
+
+    return [...existingPlugins, ...configPlugins];
   }
 
   private async initializePlugins(plugins: Plugin[]): Promise<Map<string, string[]>> {

src/plugins/plugin.ts

@@ -67,8 +67,8 @@ export class Plugin {
     return response;
   }
 
-  async apply(planId: string): Promise<void> {
-    await this.process!.sendMessageForResult({ cmd: 'apply', data: { planId } });
+  async apply(plan: PlanResponseData): Promise<void> {
+    await this.process!.sendMessageForResult({ cmd: 'apply', data: { plan } });
   }
 
   destroy() {