Added ability to load, apply and plan cloud files

Author: kevinwang5658

src/api/dashboard/index.ts

@@ -0,0 +1,25 @@
+import { LoginHelper } from '../../connect/login-helper.js';
+import { CloudDocument } from './types.js';
+
+const API_BASE_URL = 'http://localhost:3000'
+
+export const DashboardApiClient = {
+  async getDocument(id: string): Promise<CloudDocument> {
+    const login = LoginHelper.get()?.credentials;
+    if (!login) {
+      throw new Error('Not logged in');
+    }
+
+    const res = await fetch(
+      `${API_BASE_URL}/api/documents/${id}`,
+      { method: 'GET', headers: { 'Content-Type': 'application/json', 'authorization': login.accessToken } },
+    );
+
+    const json = await res.json();
+    if (!res.ok) {
+      throw new Error(JSON.stringify(json, null, 2));
+    }
+
+    return json;
+  }
+}

src/api/dashboard/types.ts

@@ -0,0 +1,6 @@
+import { Config } from 'codify-schemas';
+
+export interface CloudDocument {
+  id: string;
+  contents: Array<Config>
+}

src/commands/init.ts

@@ -30,5 +30,7 @@ For more information, visit: https://docs.codifycli.com/commands/init`
     await InitializeOrchestrator.run({
       verbosityLevel: flags.debug ? 3 : 0,
     },this.reporter);
+
+    process.exit(0)
   }
 }

src/commands/login.ts

@@ -19,5 +19,7 @@ For more information, visit: https://docs.codifycli.com/commands/validate
     const { flags } = await this.parse(Login)
 
     await LoginOrchestrator.run();
+
+    process.exit(0)
   }
 }

src/common/initialize-plugins.ts

@@ -52,13 +52,9 @@ export class PluginInitOrchestrator {
   ): Promise<Project> {
     ctx.subprocessStarted(SubProcessName.PARSE);
 
-    const pathToParse = (fileOrDir === undefined)
-      ? await PluginInitOrchestrator.findCodifyJson()
-      : fileOrDir
-
     const isLoggedIn = LoginHelper.get()?.isLoggedIn ?? false;
 
-    if (!pathToParse && !allowEmptyProject && !isLoggedIn) {
+    if (!fileOrDir && !allowEmptyProject && !isLoggedIn) {
       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?');
@@ -77,8 +73,8 @@ export class PluginInitOrchestrator {
       process.exit(0);
     }
 
-    const project = pathToParse
-      ? await CodifyParser.parse(pathToParse)
+    const project = fileOrDir
+      ? await CodifyParser.parse(fileOrDir)
       : Project.empty()
 
     ctx.subprocessFinished(SubProcessName.PARSE);

src/parser/cloud/cloud-parser.ts

@@ -1,9 +1,19 @@
+import { Config } from 'codify-schemas';
+
 import { InMemoryFile, LanguageSpecificParser, ParsedConfig } from '../entities.js';
 import { SourceMapCache } from '../source-maps.js';
 
 export class CloudParser implements LanguageSpecificParser {
-    parse(file: InMemoryFile, sourceMaps: SourceMapCache): ParsedConfig[] {
-        throw new Error('Method not implemented.');
-    }
+  parse(file: InMemoryFile, sourceMaps: SourceMapCache): ParsedConfig[] {
+    const contents = JSON.parse(file.contents) as Array<Config>;
+
+    return contents.map((content) => {
+      const { id, type, ...config } = content;
+      return {
+        contents: { type, ...config },
+        sourceMapKey: id as string,
+      }
+    })
+  }
 
 }

src/parser/entities.ts

@@ -21,4 +21,5 @@ export enum FileType {
   YAML = 'yaml',
   JSON5 = 'json5',
   JSONC = 'jsonc',
+  CLOUD = 'cloud',
 }

src/parser/index.ts

@@ -1,15 +1,19 @@
 import * as fs from 'node:fs/promises';
 import path from 'node:path';
+import { validate } from 'uuid'
 
 import { InternalError } from '../common/errors.js';
 import { ConfigBlock } from '../entities/config.js';
 import { Project } from '../entities/project.js';
+import { FileUtils } from '../utils/file.js';
+import { CloudParser } from './cloud/cloud-parser.js';
 import { ConfigFactory } from './config-factory.js';
 import { FileType, InMemoryFile, ParsedConfig } from './entities.js';
 import { JsonParser } from './json/json-parser.js';
 import { Json5Parser } from './json5/json-parser.js';
 import { JsoncParser } from './jsonc/json-parser.js';
-import { FileReader } from './reader.js';
+import { CloudReader } from './reader/cloud-reader.js';
+import { FileReader } from './reader/file-reader.js';
 import { SourceMapCache } from './source-maps.js';
 import { YamlParser } from './yaml/yaml-parser.js';
 
@@ -20,13 +24,13 @@ class Parser {
     [FileType.JSON]: new JsonParser(),
     [FileType.YAML]: new YamlParser(),
     [FileType.JSON5]: new Json5Parser(),
-    [FileType.JSONC]: new JsoncParser()
+    [FileType.JSONC]: new JsoncParser(),
+    [FileType.CLOUD]: new CloudParser(),
   }
 
   async parse(dirOrFile: string): Promise<Project> {
-    const absolutePath = path.resolve(dirOrFile);
     const sourceMaps = new SourceMapCache()
-    const codifyFiles = await this.getFilePaths(absolutePath)
+    const codifyFiles = await this.getFilePaths(dirOrFile)
 
     const configs = await this.readFiles(codifyFiles)
       .then((files) => this.parseContents(files, sourceMaps))
@@ -36,28 +40,43 @@ class Parser {
   }
 
   private async getFilePaths(dirOrFile: string): Promise<string[]> {
-    const isDirectory = (await fs.lstat(dirOrFile)).isDirectory();
+    // A cloud file is represented as an uuid. Skip file checks if it's a cloud file;
+    if (validate(dirOrFile)) {
+      return [dirOrFile];
+    }
+
+    const absolutePath = path.resolve(dirOrFile);
+    const isDirectory = (await fs.lstat(absolutePath)).isDirectory();
 
     // 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);
+      const fileName = path.basename(absolutePath);
       if (!CODIFY_FILE_REGEX.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 `)
+        throw new Error(`Invalid file path provided ${absolutePath} ${fileName}. Expected the file to be *.codify.jsonc, *.codify.json5, *.codify.json, or *.codify.yaml `)
       }
 
-      return [dirOrFile];
+      return [absolutePath];
     }
 
-    const filesInDir = await fs.readdir(dirOrFile);
+    const filesInDir = await fs.readdir(absolutePath);
 
     return filesInDir
       .filter((name) => CODIFY_FILE_REGEX.test(name))
-      .map((name) => path.join(dirOrFile, name))
+      .map((name) => path.join(absolutePath, name))
   }
 
   private readFiles(filePaths: string[]): Promise<InMemoryFile[]> {
+    const cloudReader = new CloudReader();
+    const fileReader = new FileReader();
+
     return Promise.all(filePaths.map(
-      (p) => FileReader.read(p)
+      async (p) => {
+        if (validate(p) && !(await FileUtils.fileExists(p))) {
+          return cloudReader.read(p)
+        }
+
+        return fileReader.read(p)
+      }
     ))
   }
 

src/parser/jsonc/json-parser.ts

@@ -30,9 +30,9 @@ export class JsoncParser implements LanguageSpecificParser {
     }
 
     return content.map((contents, idx) => ({
-        contents,
-        sourceMapKey: SourceMapCache.constructKey(file.filePath, `/${idx}`)
-      }))
+      contents,
+      sourceMapKey: SourceMapCache.constructKey(file.filePath, `/${idx}`)
+    }))
   }
 
   private validate(content: unknown): content is Config[] {

src/parser/reader/cloud-reader.ts

@@ -0,0 +1,16 @@
+import { DashboardApiClient } from '../../api/dashboard/index.js';
+import { FileType, InMemoryFile } from '../entities.js';
+import { Reader } from './index.js';
+
+export class CloudReader implements Reader {
+    async read(filePath: string): Promise<InMemoryFile> {
+      const document = await DashboardApiClient.getDocument(filePath);
+
+      return {
+        contents: JSON.stringify(document.contents),
+        filePath,
+        fileType: FileType.CLOUD,
+      }
+    }
+
+}