Class Registry

cli/registry.js:8–135

const Pusher = require('pusher-js');

class Registry {

  constructor (host, port, accessToken) {
    this.host = host;
    this.port = parseInt(port) || 0;
    this.accessToken = accessToken;
    this.http = this.port === 443 ? https : http;
    this.pusher = new Pusher('676bca06a7eb744a334f', {
      cluster: 'us3',
      forceTLS: true
    });
  }

  request (action, params, body, completeCallback, progressCallback) {

    let pusher = this.pusher;

    let completed = false;
    let callback = function () {
      completed = true;
      completeCallback.apply(this, arguments);
    };

    let performAction = function () {

      let uriString = Object.keys(params)
        .filter(function (key) {
          return params[key] !== undefined && params[key] !== null;
        })
        .map(function (key) {
          let value = params[key];
          value = typeof value === 'object'
            ? JSON.stringify(value)
            : value;
          return [encodeURIComponent(key), encodeURIComponent(value)].join('=');
        })
        .join('&');

      let req = this.http.request(
        {
          hostname: this.host,
          port: this.port,
          path: '/' + action + '?' + uriString,
          method: 'POST',
          headers: {
            'Authorization': `Bearer ${this.accessToken}`,
            'Content-Length': body ? body.byteLength : 0
          }
        },
        res => {
          let buffers = [];
          res.on('data', chunk => buffers.push(chunk));
          res.on('end', () => {
            let buffer = Buffer.concat(buffers);
            let text = buffer.toString();
            let json;
            let error;
            try {