plugins.js

'use strict';

const schemas = require('../schemas/plugins');

class PluginsClient {

  constructor(docker) {
    this.docker = docker;
  }

  list(options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.list.options).then((params) => {
      return self.docker.modem.get({
        url: '/plugins',
        qs: params,
        successCodes: {
          200: 'No Error',
          204: 'No Content'
        },
        errorCodes: {
          500: 'Server Error'
        }
      });
    });
  }

  install(options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.install.options).then((params) => {
      return self.docker.modem.post({
        url: '/plugins/pull',
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          500: 'plugin already exists or error parsing reference'
        }
      });
    });
  }

  inspect(name, options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.inspect.options).then((params) => {
      return self.docker.modem.get({
        url: `/plugins/${name}`,
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          404: 'plugin not installed'
        }
      });
    });
  }

  enable(name, options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.enable.options).then((params) => {
      return self.docker.modem.post({
        url: `/plugins/${name}/enable`,
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          500: 'plugin already enabled'
        }
      });
    });
  }

  upgrade(name, options, auth) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.upgrade.options).then((params) => {

      const requestOptions = {
        url: `/plugins/${name}/upgrade`,
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          500: 'plugin already enabled'
        }
      };

      if(auth) {
        requestOptions.headers = {
          'X-Registry-Auth': auth.generate(auth)
        };
      }

      return self.docker.modem.post(requestOptions);
    });
  }

  disable(name, options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.disable.options).then((params) => {
      return self.docker.modem.post({
        url: `/plugins/${name}/disable`,
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          500: 'plugin already disabled'
        }
      });
    });
  }

  remove(name, options) {
    const self = this;

    options = options || {};

    return self.docker._validate(options, schemas.remove.options).then((params) => {
      return self.docker.modem.destroy({
        url: `/plugins/${name}`,
        qs: params,
        successCodes: {
          200: 'No Error'
        },
        errorCodes: {
          404: 'plugin not installed',
          500: 'plugin is active'
        }
      });
    });
  }

}

module.exports.Client = function(docker) {
  return new PluginsClient(docker);
};