Added apply functionality

Author: kevinwang5658

codify-core/package.json

@@ -62,6 +62,9 @@
     "topics": {
       "hello": {
         "description": "Say hello to the world and others"
+      },
+      "apply": {
+        "description": "apply"
       }
     },
     "macos": {

codify-core/src/commands/apply.ts codify-core/src/commands/apply/index.tscodify-core/src/commands/apply.ts renamed to codify-core/src/commands/apply/index.ts

@@ -1,4 +1,7 @@
 import { Args, Command, Flags } from '@oclif/core'
+import path from 'node:path';
+
+import { ApplyOrchestrator } from './orchestrator.js';
 
 export default class Apply extends Command {
   static args = {
@@ -16,6 +19,8 @@ export default class Apply extends Command {
     force: Flags.boolean({ char: 'f' }),
     // flag with a value (-n, --name=VALUE)
     name: Flags.string({ char: 'n', description: 'name to print' }),
+    // flag with a value (-p, --path=VALUE)
+    path: Flags.string({ char: 'p', description: 'path to project' }),
   }
 
   public async run(): Promise<void> {
@@ -26,5 +31,12 @@ export default class Apply extends Command {
     if (args.file && flags.force) {
       this.log(`you input --force and --file: ${args.file}`)
     }
+
+    if (flags.path) {
+      this.log(`Applying Codify from: ${flags.path}`);
+    }
+
+    const resolvedPath = path.resolve(flags.path ?? '.');
+    await ApplyOrchestrator.run(resolvedPath);
   }
 }

codify-core/src/commands/apply/orchestrator.ts

@@ -0,0 +1,48 @@
+import readline from 'node:readline'
+
+import { ConfigReader } from '../../config-compiler/index.js';
+import { PluginCollection } from '../../plugins/plugin-collection.js';
+
+const rl = readline.createInterface({
+  input: process.stdin,
+  output: process.stdout
+});
+
+
+export const ApplyOrchestrator = {
+
+  async run(rootDirectory: string): Promise<string> {
+    const project = await ConfigReader.parseProject(rootDirectory);
+    if (project.isEmpty()) {
+      console.log('Empty project. Taking no action');
+      return '';
+    }
+
+    const pluginCollection = new PluginCollection();
+    const dependencyMap = await pluginCollection.initialize(project);
+    project.validateWithResourceMap(dependencyMap);
+    project.resolveResourceDependencies(dependencyMap);
+
+    const validationResults = await pluginCollection.validate(project);
+    project.handlePluginResourceValidationResults(validationResults);
+    project.calculateEvaluationOrder();
+
+    const plan = await pluginCollection.getPlan(project);
+    console.log(JSON.stringify(plan, null, 2));
+
+    console.log('Is this okay?');
+
+    for await (const line of rl) {
+      if (line === 'yes') {
+        break;
+      } else {
+        return '';
+      }
+    }
+
+    await pluginCollection.apply(plan);
+    await pluginCollection.destroy();
+
+    return '';
+  },
+};

codify-core/src/commands/plan/orchestrator.ts

@@ -1,9 +1,9 @@
-import { ConfigCompiler } from '../../config-compiler/index.js';
+import { ConfigReader } from '../../config-compiler/index.js';
 import { PluginCollection } from '../../plugins/plugin-collection.js';
 
 export const PlanOrchestrator = {
   async run(rootDirectory: string): Promise<string> {
-    const project = await ConfigCompiler.parseProject(rootDirectory);
+    const project = await ConfigReader.parseProject(rootDirectory);
     if (project.isEmpty()) {
       console.log('Empty project. Taking no action');
       return '';

codify-core/src/config-compiler/index.ts

@@ -7,7 +7,7 @@ import { ConfigLoader } from './loader/index.js';
 import { FileParser } from './parser/index.js';
 import { JsonFileParser } from './parser/json/file-parser.js';
 
-export class ConfigCompiler {
+export class ConfigReader {
 
   static readonly supportedParsers: Record<string, FileParser> = {
     'json': new JsonFileParser(),
@@ -17,7 +17,7 @@ export class ConfigCompiler {
     const loadedProject = await (new ConfigLoader().loadProject(directory));
 
     const configBlocksResult = await Promise.all(loadedProject.coreModule.files.map((file) => {
-      const parser = ConfigCompiler.supportedParsers[file.fileType];
+      const parser = ConfigReader.supportedParsers[file.fileType];
       if (!parser) {
         throw new InternalError(`Unsupported file format loaded into parser: ${file.fileName}`);
       }

codify-core/src/config-compiler/loader/index.ts

@@ -1,7 +1,7 @@
 import * as fs from 'node:fs/promises';
 import * as path from 'node:path';
 
-import { ConfigCompiler } from '../index.js';
+import { ConfigReader } from '../index.js';
 import { LoadedFile } from './entities/file.js';
 import { LoadedModule } from './entities/module.js';
 import { LoadedProject } from './entities/project.js';
@@ -37,7 +37,7 @@ export class ConfigLoader {
 
     await Promise.all(dir
       .map(async (fileName) => {
-        const matchedParser = Object.entries(ConfigCompiler.supportedParsers).find(([k]) => fileName.endsWith(k))
+        const matchedParser = Object.entries(ConfigReader.supportedParsers).find(([k]) => fileName.endsWith(k))
         if (!matchedParser) {
           return;
         }

codify-core/src/entities/project.ts

@@ -8,7 +8,6 @@ import { ResourceConfig } from './resource-config.js';
 export class Project {
   projectConfig: ProjectConfig | null;
   resourceConfigs: ResourceConfig[];
-
   evaluationOrder: ResourceConfig[] = [];
 
   constructor(projectConfig: ProjectConfig | null, resourceConfigs: ResourceConfig[]) {

codify-core/src/plugins/entities/plugin.ts

@@ -65,6 +65,10 @@ export class Plugin {
     return response;
   }
 
+  async apply(planId: string): Promise<void> {
+    await this.ipcBridge!.sendMessageForResult({ cmd: 'apply', data: { planId } });
+  }
+
   destroy() {
     this.ipcBridge!.killPlugin();
   }

codify-core/src/plugins/plugin-collection.ts

@@ -61,6 +61,17 @@ export class PluginCollection {
     return result;
   }
 
+  async apply(planResponseData: PlanResponseData[]): Promise<void> {
+    for (const { planId, resourceType } of planResponseData) {
+      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);
+    }
+  }
+
   async destroy(): Promise<void> {
     for (const plugin of this.plugins.values()) {
       plugin.destroy();