WIP for virtual applies

Author: kevinwang5658

src/common/initialize-plugins.ts

@@ -22,11 +22,18 @@ export interface InitializationResult {
   project: Project,
 }
 
+export interface ParseInput {
+  fileOrDir: string | undefined,
+  json: string,
+}
+
 export class PluginInitOrchestrator {
   static async run(
     args: InitializeArgs,
     reporter: Reporter,
   ): Promise<InitializationResult> {
+
+
     let project = await PluginInitOrchestrator.parse(
       args.path,
       args.allowEmptyProject ?? false,
@@ -45,7 +52,7 @@ export class PluginInitOrchestrator {
   }
 
   private static async parse(
-    fileOrDir: string | undefined,
+    input: ParseInput,
     allowEmptyProject: boolean,
     reporter: Reporter
   ): Promise<Project> {
@@ -55,24 +62,24 @@ export class PluginInitOrchestrator {
       ? await PluginInitOrchestrator.findCodifyJson()
       : fileOrDir
 
-    if (!pathToParse && !allowEmptyProject) {
-      ctx.subprocessFinished(SubProcessName.PARSE);
-      ctx.subprocessStarted(SubProcessName.CREATE_ROOT_FILE)
-      const createRootCodifyFile = await reporter.promptConfirmation('\nNo codify file found. Do you want to create a root file at ~/codify.jsonc?');
-
-      if (createRootCodifyFile) {
-        await fs.writeFile(
-          path.resolve(os.homedir(), 'codify.jsonc'),
-          '[]',
-          { encoding: 'utf8', flag: 'wx' }
-        ); // flag: 'wx' prevents overwrites if the file exists
-      }
-
-      ctx.subprocessFinished(SubProcessName.CREATE_ROOT_FILE)
-
-      console.log('Created ~/codify.jsonc file')
-      process.exit(0);
-    }
+    // if (!pathToParse && !allowEmptyProject) {
+    //   ctx.subprocessFinished(SubProcessName.PARSE);
+    //   ctx.subprocessStarted(SubProcessName.CREATE_ROOT_FILE)
+    //   const createRootCodifyFile = await reporter.promptConfirmation('\nNo codify file found. Do you want to create a root file at ~/codify.jsonc?');
+    //
+    //   if (createRootCodifyFile) {
+    //     await fs.writeFile(
+    //       path.resolve(os.homedir(), 'codify.jsonc'),
+    //       '[]',
+    //       { encoding: 'utf8', flag: 'wx' }
+    //     ); // flag: 'wx' prevents overwrites if the file exists
+    //   }
+    //
+    //   ctx.subprocessFinished(SubProcessName.CREATE_ROOT_FILE)
+    //
+    //   console.log('Created ~/codify.jsonc file')
+    //   process.exit(0);
+    // }
 
     const project = pathToParse
       ? await CodifyParser.parse(pathToParse)

src/config.ts

@@ -6,5 +6,7 @@ export const config = {
     'https://codify-dashboard.com',
     'https://https://codify-dashboard.kevinwang5658.workers.dev',
     'http://localhost:3000'
-  ]
+  ],
+
+  codifyFileRegex: /^(.*)?codify(.json|.yaml|.json5|.jsonc)$/
 }

src/connect/server.ts

@@ -1,7 +1,7 @@
 import { IncomingMessage, Server, createServer } from 'node:http';
 import { Duplex } from 'node:stream';
-import { v4 as uuid } from 'uuid';
 import { WebSocket, WebSocketServer } from 'ws';
+
 import { config } from '../config.js';
 
 let instance: WsServerManager | undefined;

src/entities/project.ts

@@ -11,13 +11,23 @@ import { type Plan } from './plan.js';
 import { ProjectConfig } from './project-config.js';
 import { ResourceConfig } from './resource-config.js';
 
+interface CodifyFile {
+  type: 'local' | 'remote';
+  pathOrId: string;
+}
+
+export enum ProjectType {
+  LOCAL = 'local',
+  REMOTE = 'remote',
+}
+
 export class Project {
   projectConfig: ProjectConfig | null;
   resourceConfigs: ResourceConfig[];
   stateConfigs: ResourceConfig[] | null = null;
   evaluationOrder: null | string[] = null;
 
-  codifyFiles: string[];
+  codifyFiles: CodifyFile[];
 
   sourceMaps?: SourceMapCache;
   planRequestsCache?: Map<string, PlanRequestData>
@@ -28,7 +38,7 @@ export class Project {
     return Project.create([], []);
   }
 
-  static create(configs: ConfigBlock[], codifyFiles: string[], sourceMaps?: SourceMapCache): Project {
+  static create(configs: ConfigBlock[], codifyFiles: CodifyFile[], sourceMaps?: SourceMapCache): Project {
     const projectConfigs = configs.filter((u) => u.configClass === ConfigType.PROJECT);
     if (projectConfigs.length > 1) {
       throw new Error(`Only one project config can be specified. Found ${projectConfigs.length}. \n\n
@@ -43,7 +53,7 @@ ${JSON.stringify(projectConfigs, null, 2)}`);
     );
   }
 
-  constructor(projectConfig: ProjectConfig | null, resourceConfigs: ResourceConfig[], codifyFiles: string[], sourceMaps?: SourceMapCache) {
+  constructor(projectConfig: ProjectConfig | null, resourceConfigs: ResourceConfig[], codifyFiles: CodifyFile[], sourceMaps?: SourceMapCache) {
     this.projectConfig = projectConfig;
     this.resourceConfigs = resourceConfigs;
     this.sourceMaps = sourceMaps;

src/parser/config-factory.ts

@@ -22,7 +22,7 @@ class Factory {
     sourceMaps: SourceMapCache
   ): ConfigBlock {
     const rawConfig = parsedConfig.contents;
-    const type = parsedConfig.contents.type;
+    const { type } = parsedConfig.contents;
 
     switch (type) {
       case ConfigType.PROJECT: {

src/parser/index.ts

@@ -12,8 +12,12 @@ import { JsoncParser } from './jsonc/json-parser.js';
 import { FileReader } from './reader.js';
 import { SourceMapCache } from './source-maps.js';
 import { YamlParser } from './yaml/yaml-parser.js';
+import { config } from '../config.js';
 
-export const CODIFY_FILE_REGEX = /^(.*)?codify(.json|.yaml|.json5|.jsonc)$/;
+export interface ParseInput {
+  fileOrDir: string | undefined,
+  json: string,
+}
 
 class Parser {
   private readonly languageSpecificParsers= {
@@ -23,16 +27,26 @@ class Parser {
     [FileType.JSONC]: new JsoncParser()
   }
 
-  async parse(dirOrFile: string): Promise<Project> {
-    const absolutePath = path.resolve(dirOrFile);
+  async parse(input: ParseInput): Promise<Project> {
     const sourceMaps = new SourceMapCache()
-    const codifyFiles = await this.getFilePaths(absolutePath)
+
+    let files: InMemoryFile[] = [];
+    if (input.fileOrDir) {
+      const absolutePath = path.resolve(input.fileOrDir);
+      const codifyFiles = await this.getFilePaths(absolutePath)
+      files = await this.readFiles(codifyFiles);
+    } else if (input.json) {
+      files = [{
+        filePath: 'stdin',
+        fileType: FileType.JSON,
+        contents: input.json
+      }]
+    }
 
-    const configs = await this.readFiles(codifyFiles)
-      .then((files) => this.parseContents(files, sourceMaps))
-      .then((config) => this.createConfigBlocks(config, sourceMaps))
+    const contents = this.parseContents(files, sourceMaps)
+    const configs = this.createConfigBlocks(contents, sourceMaps)
 
-    return Project.create(configs, codifyFiles, sourceMaps);
+    return Project.create(configs, files, sourceMaps);
   }
 
   private async getFilePaths(dirOrFile: string): Promise<string[]> {
@@ -41,7 +55,7 @@ class Parser {
     // A single file was passed in. We need to test if the file satisfies the codify file regex
     if (!isDirectory) {
       const fileName = path.basename(dirOrFile);
-      if (!CODIFY_FILE_REGEX.test(fileName)) {
+      if (!config.codifyFileRegex.test(fileName)) {
         throw new Error(`Invalid file path provided ${dirOrFile} ${fileName}. Expected the file to be *.codify.jsonc, *.codify.json5, *.codify.json, or *.codify.yaml `)
       }
 
@@ -51,7 +65,7 @@ class Parser {
     const filesInDir = await fs.readdir(dirOrFile);
 
     return filesInDir
-      .filter((name) => CODIFY_FILE_REGEX.test(name))
+      .filter((name) => config.codifyFileRegex.test(name))
       .map((name) => path.join(dirOrFile, name))
   }