feat(cli): Updating function deployment status

Author: byawitz

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

@@ -6,7 +6,7 @@ const { Updater, SPINNER_ARC, SPINNER_DOTS } = require('../updater');
 const { paginate } = require('../paginate');
 const { questionsDeployBuckets, questionsDeployTeams, questionsDeployFunctions, questionsGetEntrypoint, questionsDeployCollections, questionsConfirmDeployCollections } = require("../questions");
 const { actionRunner, success, log, error, commandDescriptions } = require("../parser");
-const { functionsGet, functionsCreate, functionsUpdate, functionsCreateDeployment, functionsUpdateDeployment, functionsListVariables, functionsDeleteVariable, functionsCreateVariable } = require('./functions');
+const { functionsGet, functionsCreate, functionsUpdate, functionsCreateDeployment, functionsUpdateDeployment, functionsGetDeployment, functionsListVariables, functionsDeleteVariable, functionsCreateVariable } = require('./functions');
 const {
     databasesGet,
     databasesCreate,
@@ -41,6 +41,7 @@ const {
 
 const STEP_SIZE = 100;      // Resources
 const POOL_DEBOUNCE = 2000; // Milliseconds
+const POOL_MAX_DEBOUNCE = 30; // Times
 
 let poolMaxDebounces = 30;
 
@@ -312,11 +313,13 @@ const deployFunction = async ({ functionId, all, yes } = {}) => {
     log('Pushing functions\n');
 
     Updater.start(false,)
+    let successfullyPushed = 0;
     let successfullyDeployed = 0;
 
     await Promise.all(functions.map(async (func) => {
         const ignore = func.ignore ? 'appwrite.json' : '.gitignore';
         let functionExists = false;
+        let deploymentCreated = false;
 
         const updaterRow = new Updater({ status: '', resource: func.name, id: func['$id'], end: `Ignoring using: ${ignore}` });
 
@@ -438,9 +441,9 @@ const deployFunction = async ({ functionId, all, yes } = {}) => {
                 parseOutput: false
             })
 
-            updaterRow.update({ status: 'Pushed' })
-            successfullyDeployed++;
-
+            updaterRow.update({ status: 'Pushed' });
+            deploymentCreated = true;
+            successfullyPushed++;
         } catch (e) {
             switch (e.code) {
                 case 'ENOENT':
@@ -450,12 +453,54 @@ const deployFunction = async ({ functionId, all, yes } = {}) => {
                     updaterRow.fail({ errorMessage: e.message ?? 'General error occurs please try again' })
             }
         }
+
+        if (deploymentCreated) {
+            try {
+                const deploymentId = response['$id'];
+                updaterRow.update({ status: 'Deploying', end: 'Checking deployment status...' })
+                let pool_checks = 0;
+
+                while (true) {
+                    if (pool_checks >= POOL_MAX_DEBOUNCE) {
+                        updaterRow.update({ end: 'Deployment takes too long; check the console' })
+                        break;
+                    }
+
+                    response = await functionsGetDeployment({
+                        functionId: func['$id'],
+                        deploymentId: deploymentId,
+                        parseOutput: false
+                    });
+
+
+                    const status = response['status'];
+                    if (status === 'ready') {
+                        updaterRow.update({ status: 'Deployed' });
+                        successfullyDeployed++;
+
+                        break;
+                    } else if (status === 'failed') {
+                        updaterRow.fail({ errorMessage: 'failed to deploy' });
+
+                        break;
+                    } else {
+                        updaterRow.update({ status: 'Deploying', end: `current status: ${status}` })
+                    }
+
+                    pool_checks++;
+                    await new Promise(resolve => setTimeout(resolve, POOL_DEBOUNCE));
+                }
+            } catch (e) {
+                updaterRow.fail({ errorMessage: e.message ?? 'General error occurs please try again' })
+            }
+        }
+
         updaterRow.stopSpinner();
     }));
 
     Updater.stop();
 
-    success(`Pushed ${successfullyDeployed} functions`);
+    success(`Pushed ${successfullyPushed} functions with ${successfullyDeployed} successfully deployed`);
 }
 
 const createAttribute = async (databaseId, collectionId, attribute) => {

templates/cli/lib/updater.js.twig

@@ -39,6 +39,12 @@ class Updater {
         let end = chalk.yellow(payload.end);
 
         if (status.toLowerCase().trim() === 'pushed') {
+            start = chalk.greenBright.bold(status);
+            prefix = chalk.greenBright.bold('✓');
+            end = '';
+        } else if (status.toLowerCase().trim() === 'deploying') {
+            start = chalk.cyanBright.bold(status);
+        } else if (status.toLowerCase().trim() === 'deployed') {
             start = chalk.green.bold(status);
             prefix = chalk.green.bold('✓');
             end = '';