chore(cli): rebasing head

Author: byawitz

src/SDK/Language/CLI.php

@@ -177,6 +177,11 @@ public function getFiles(): array
                 'destination'   => 'lib/commands/init.js',
                 'template'      => 'cli/lib/commands/init.js.twig',
             ],
+            [
+                'scope'         => 'default',
+                'destination'   => 'lib/commands/create.js',
+                'template'      => 'cli/lib/commands/create.js.twig',
+            ],
             [
                 'scope'         => 'default',
                 'destination'   => 'lib/commands/pull.js',

templates/cli/index.js.twig

@@ -12,6 +12,7 @@ const { commandDescriptions, cliConfig } = require("./lib/parser");
 const { client } = require("./lib/commands/generic");
 {% if sdk.test != "true" %}
 const { login, logout } = require("./lib/commands/generic");
+const { create } = require("./lib/commands/create");
 const { init } = require("./lib/commands/init");
 const { pull } = require("./lib/commands/pull");
 const { push } = require("./lib/commands/push");
@@ -38,6 +39,7 @@ program
   .showSuggestionAfterError()
 {% if sdk.test != "true" %}
   .addCommand(login)
+  .addCommand(create)
   .addCommand(init)
   .addCommand(pull)
   .addCommand(push)

templates/cli/lib/commands/create.js.twig

@@ -0,0 +1,224 @@
+const fs = require("fs");
+const path = require("path");
+const childProcess = require('child_process');
+const { Command } = require("commander");
+const inquirer = require("inquirer");
+const { storageCreateBucket } = require("./storage");
+const { messagingCreateTopic } = require("./messaging");
+const { functionsCreate } = require("./functions");
+const { databasesCreateCollection } = require("./databases");
+const ID = require("../id");
+const { localConfig } = require("../config");
+const {
+    questionsCreateFunction,
+    questionsCreateBucket,
+    questionsCreateMessagingTopic,
+    questionsCreateCollection
+} = require("../questions");
+const { success, error, actionRunner, commandDescriptions } = require("../parser");
+
+const create = new Command("create")
+    .description(commandDescriptions['create'])
+    .configureHelp({
+        helpWidth: process.stdout.columns || 80
+    })
+    .action(actionRunner(async (_options, command) => {
+        command.help();
+    }));
+
+
+const createBucket = async () => {
+    let response = {}
+    const answers = await inquirer.prompt(questionsCreateBucket)
+    if (!answers.bucket || !answers.id || !answers.fileSecurity) process.exit(1)
+
+    try {
+        response = await storageCreateBucket({
+            bucketId: answers.id,
+            name: answers.bucket,
+            fileSecurity: answers.fileSecurity.toLowerCase() === 'yes',
+            enabled: true,
+            parseOutput: false
+        })
+
+        localConfig.addBucket(response);
+        success();
+    } catch (e) {
+        error(e.getMessage ?? 'Unknown error occurred. Please try again');
+    }
+};
+
+const createCollection = async () => {
+    let response = {}
+    const answers = await inquirer.prompt(questionsCreateCollection)
+    if (!answers.database || !answers.collection || !answers.id || !answers.documentSecurity) process.exit(1)
+
+    try {
+        response = await databasesCreateCollection({
+            databaseId: answers.database,
+            collectionId: answers.id,
+            name: answers.collection,
+            documentSecurity: answers.documentSecurity.toLowerCase() === 'yes',
+            enabled: true,
+            parseOutput: false
+        })
+
+        localConfig.addCollection(response);
+        success();
+    } catch (e) {
+        error(e.getMessage ?? 'Unknown error occurred. Please try again');
+    }
+};
+
+const createTopic = async () => {
+    let response = {}
+    const answers = await inquirer.prompt(questionsCreateMessagingTopic)
+    if (!answers.topic || !answers.id) process.exit(1)
+
+    try {
+        response = await messagingCreateTopic({
+            topicId: answers.id,
+            name: answers.topic,
+            parseOutput: false
+        })
+
+        localConfig.addMessagingTopic(response);
+        success();
+    } catch (e) {
+        error(e.getMessage ?? 'Unknown error occurred. Please try again');
+    }
+};
+
+const createFunction = async () => {
+    // TODO: Add CI/CD support (ID, name, runtime)
+    const answers = await inquirer.prompt(questionsCreateFunction)
+    const functionFolder = path.join(process.cwd(), 'functions');
+
+    if (!fs.existsSync(functionFolder)) {
+        fs.mkdirSync(functionFolder, {
+            recursive: true
+        });
+    }
+
+    const functionId = answers.id === 'unique()' ? ID.unique() : answers.id;
+    const functionDir = path.join(functionFolder, functionId);
+
+    if (fs.existsSync(functionDir)) {
+        throw new Error(`( ${functionId} ) already exists in the current directory. Please choose another name.`);
+    }
+
+    if (!answers.runtime.entrypoint) {
+        log(`Entrypoint for this runtime not found. You will be asked to configure entrypoint when you first push the function.`);
+    }
+
+    if (!answers.runtime.commands) {
+        log(`Installation command for this runtime not found. You will be asked to configure the install command when you first push the function.`);
+    }
+
+    let response = await functionsCreate({
+        functionId,
+        name: answers.name,
+        runtime: answers.runtime.id,
+        entrypoint: answers.runtime.entrypoint || '',
+        commands: answers.runtime.commands || '',
+        parseOutput: false
+    })
+
+    fs.mkdirSync(functionDir, "777");
+
+    let gitInitCommands = "git clone -b v3 --single-branch --depth 1 --sparse https://github.com/{{ sdk.gitUserName }}/functions-starter ."; // depth prevents fetching older commits reducing the amount fetched
+
+    let gitPullCommands = `git sparse-checkout add ${answers.runtime.id}`;
+
+    /* Force use CMD as powershell does not support && */
+    if (process.platform === 'win32') {
+        gitInitCommands = 'cmd /c "' + gitInitCommands + '"';
+        gitPullCommands = 'cmd /c "' + gitPullCommands + '"';
+    }
+
+    /*  Execute the child process but do not print any std output */
+    try {
+        childProcess.execSync(gitInitCommands, { stdio: 'pipe', cwd: functionDir });
+        childProcess.execSync(gitPullCommands, { stdio: 'pipe', cwd: functionDir });
+    } catch (error) {
+        /* Specialised errors with recommended actions to take */
+        if (error.message.includes('error: unknown option')) {
+            throw new Error(`${error.message} \n\nSuggestion: Try updating your git to the latest version, then trying to run this command again.`)
+        } else if (error.message.includes('is not recognized as an internal or external command,') || error.message.includes('command not found')) {
+            throw new Error(`${error.message} \n\nSuggestion: It appears that git is not installed, try installing git then trying to run this command again.`)
+        } else {
+            throw error;
+        }
+    }
+
+    fs.rmSync(path.join(functionDir, ".git"), { recursive: true });
+    const copyRecursiveSync = (src, dest) => {
+        let exists = fs.existsSync(src);
+        let stats = exists && fs.statSync(src);
+        let isDirectory = exists && stats.isDirectory();
+        if (isDirectory) {
+            if (!fs.existsSync(dest)) {
+                fs.mkdirSync(dest);
+            }
+
+            fs.readdirSync(src).forEach(function (childItemName) {
+                copyRecursiveSync(path.join(src, childItemName), path.join(dest, childItemName));
+            });
+        } else {
+            fs.copyFileSync(src, dest);
+        }
+    };
+    copyRecursiveSync(path.join(functionDir, answers.runtime.id), functionDir);
+
+    fs.rmSync(`${functionDir}/${answers.runtime.id}`, { recursive: true, force: true });
+
+    const readmePath = path.join(process.cwd(), 'functions', functionId, 'README.md');
+    const readmeFile = fs.readFileSync(readmePath).toString();
+    const newReadmeFile = readmeFile.split('\n');
+    newReadmeFile[0] = `# ${answers.name}`;
+    newReadmeFile.splice(1, 2);
+    fs.writeFileSync(readmePath, newReadmeFile.join('\n'));
+
+    let data = {
+        $id: response['$id'],
+        name: response.name,
+        runtime: response.runtime,
+        execute: response.execute,
+        events: response.events,
+        schedule: response.schedule,
+        timeout: response.timeout,
+        enabled: response.enabled,
+        logging: response.logging,
+        entrypoint: response.entrypoint,
+        commands: response.commands,
+        ignore: answers.runtime.ignore || null,
+        path: `functions/${functionId}`,
+    };
+
+    localConfig.addFunction(data);
+    success();
+}
+
+create
+    .command("function")
+    .description("Create a new {{ spec.title|caseUcfirst }} function")
+    .action(actionRunner(createFunction));
+
+create
+    .command("bucket")
+    .description("Create a new {{ spec.title|caseUcfirst }} bucket")
+    .action(actionRunner(createBucket));
+
+create
+    .command("collection")
+    .description("Create a new {{ spec.title|caseUcfirst }} collection")
+    .action(actionRunner(createCollection));
+
+create
+    .command("topic")
+    .description("Create a new {{ spec.title|caseUcfirst }} topic")
+    .action(actionRunner(createTopic));
+
+module.exports = {
+    create,
+};