Merge pull request #930 from appwrite/feat-latest-deployment

feat(cli): Pull last deployment instead of local when available

Author: christyjacob4

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

@@ -6,7 +6,7 @@ const inquirer = require("inquirer");
 const { messagingListTopics } = require("./messaging");
 const { teamsList } = require("./teams");
 const { projectsGet } = require("./projects");
-const { functionsList, functionsDownloadDeployment } = require("./functions");
+const { functionsList, functionsDownloadDeployment, functionsListDeployments } = require("./functions");
 const { databasesGet, databasesListCollections, databasesList } = require("./databases");
 const { storageListBuckets } = require("./storage");
 const { localConfig } = require("../config");
@@ -97,45 +97,70 @@ const pullFunctions = async ({ code, withVariables }) => {
 
         if (code === false) {
             warn("Source code download skipped.");
-        } else if (!func['deployment']) {
-            warn("Source code download skipped because function doesn't have active deployment.");
-        } else {
-            if (allowCodePull === null) {
-                const codeAnswer = await inquirer.prompt(questionsPullFunctionsCode);
-                allowCodePull = codeAnswer.override;
+            continue;
+        }
+
+        if (allowCodePull === null) {
+            const codeAnswer = await inquirer.prompt(questionsPullFunctionsCode);
+            allowCodePull = codeAnswer.override;
+        }
+
+        if (!allowCodePull) {
+            continue;
+        }
+
+        let deploymentId = null;
+
+        try {
+            const fetchResponse = await functionsListDeployments({
+                functionId: func['$id'],
+                queries: [
+                    JSON.stringify({ method: 'limit', values: [1] }),
+                    JSON.stringify({ method: 'orderDesc', values: ['$id'] })
+                ],
+                parseOutput: false
+            });
+
+            if (fetchResponse['total'] > 0) {
+                deploymentId = fetchResponse['deployments'][0]['$id'];
             }
 
-            if (allowCodePull) {
-                log("Pulling active deployment's code ...");
-
-                const compressedFileName = `${func['$id']}-${+new Date()}.tar.gz`
-                await functionsDownloadDeployment({
-                    functionId: func['$id'],
-                    deploymentId: func['deployment'],
-                    destination: compressedFileName,
-                    overrideForCli: true,
-                    parseOutput: false
-                });
-
-                tar.extract({
-                    sync: true,
-                    cwd: func['path'],
-                    file: compressedFileName,
-                    strict: false,
-                });
-
-                fs.rmSync(compressedFileName);
-
-                if (withVariables) {
-                    const envFileLocation = `${func['path']}/.env`
-                    try {
-                        fs.rmSync(envFileLocation);
-                    } catch {
-                    }
-
-                    fs.writeFileSync(envFileLocation, func['vars'].map(r => `${r.key}=${r.value}\n`).join(''))
-                }
+        } catch {
+        }
+
+        if (deploymentId === null) {
+            log("Source code download skipped because function doesn't have any available deployment");
+            continue;
+        }
+
+        log("Pulling latest deployment code ...");
+
+        const compressedFileName = `${func['$id']}-${+new Date()}.tar.gz`
+        await functionsDownloadDeployment({
+            functionId: func['$id'],
+            deploymentId,
+            destination: compressedFileName,
+            overrideForCli: true,
+            parseOutput: false
+        });
+
+        tar.extract({
+            sync: true,
+            cwd: func['path'],
+            file: compressedFileName,
+            strict: false,
+        });
+
+        fs.rmSync(compressedFileName);
+
+        if (withVariables) {
+            const envFileLocation = `${func['path']}/.env`
+            try {
+                fs.rmSync(envFileLocation);
+            } catch {
             }
+
+            fs.writeFileSync(envFileLocation, func['vars'].map(r => `${r.key}=${r.value}\n`).join(''))
         }
     }