Merge pull request #251 from quantcdn/feat/command-publish

Feat: Add publish command.

README.md

@@ -33,6 +33,7 @@ Commands:
   quant page <file> <location>                       Make a local page asset available via Quant
   quant proxy <path> <origin> [status]               Create a proxy to allow traffic directly to origin
   [basicAuthUser] [basicAuthPass]
+  quant publish <path>                               Publish an asset
   quant purge <path>                                 Purge the cache for a given url
   quant redirect <from> <to> [status] [author]       Create a redirect
   quant search <index|unindex|clear>                 Perform search index operations

src/commands/publish.js

@@ -0,0 +1,51 @@
+/**
+ * Unpublish a QuantCDN url.
+ *
+ * @usage
+ *   quant publish <path>
+ */
+const chalk = require('chalk');
+const client = require('../quant-client');
+const config = require('../config');
+
+const command = {};
+
+command.command = 'publish <path>';
+command.describe = 'Publish an asset';
+command.builder = (yargs) => {
+  yargs.options('revision', {
+    describe: 'The revision id to publish',
+    alias: 'r',
+    type: 'string',
+    default: 'latest',
+  });
+};
+
+command.handler = function(argv) {
+  console.log(chalk.bold.green('*** Quant publish ***'));
+
+  // config.fromArgs(argv);
+  if (!config.fromArgs(argv)) {
+    return console.error(chalk.yellow('Quant is not configured, run init.'));
+  }
+
+  const _client = client(config);
+
+  if (argv.revision == 'latest') {
+    _client.revisions(argv.path)
+        .then((res) => {
+          const revisionIds = Object.keys(res.revisions);
+          const latestRevision = Math.max(...revisionIds);
+          _client.publish(argv.path, latestRevision)
+              .then((res) => console.log(chalk.green('Success:') + ` Published successfully`)) // eslint-disable-line
+              .catch((err) => console.log(chalk.red.bold('Error:') + ` ${err}`));
+        })
+        .catch((err) => console.log(chalk.red.bold('Error:') + ` ${err}`));
+  } else {
+    _client.publish(argv.path, argv.revision)
+        .then((res) => console.log(chalk.green('Success:') + ` Published successfully`)) // eslint-disable-line
+        .catch((err) => console.log(chalk.red.bold('Error:') + ` ${err}`));
+  }
+};
+
+module.exports = command;

src/commands/scan.js

@@ -70,7 +70,7 @@ command.handler = async function(argv) {
     }
 
     try {
-      revision = await quant.revisions(filepath);
+      revision = await quant.revision(filepath);
     } catch (err) {}
 
     if (!revision) {

src/quant-client.js

@@ -513,7 +513,7 @@ const client = function(config) {
      *
      * @throws Error.
      */
-    revisions: async function(url, revision = false) {
+    revision: async function(url, revision = false) {
       const path = revision ? revision : 'published';
 
       url = url.indexOf('/') == 0 ? url : `/${url}`;
@@ -532,6 +532,36 @@ const client = function(config) {
       return handleResponse(res);
     },
 
+    /**
+     * Get the revision history from Quant.
+     *
+     * @param {string} url
+     *   The URL path to get revisions for.
+     * @param {string|bool} revision
+     *   Retrieve a specific revision.
+     *
+     * @return {object}
+     *   The response.
+     *
+     * @throws Error.
+     */
+    revisions: async function(url) {
+      url = url.indexOf('/') == 0 ? url : `/${url}`;
+      url = url.toLowerCase();
+      url = url.replace(/\/?index\.html/, '');
+
+      const options = {
+        url: `${config.get('endpoint')}/revisions`,
+        headers: {
+          ...headers,
+          'Quant-Url': url,
+        },
+        json: true,
+      };
+      const res = await get(options);
+      return handleResponse(res);
+    },
+
     /**
      * Purge URL patterns from Quants Varnish.
      *