HookClient.js

const PageableStream = require('./PageableStream');
const HTTPClient = require('./HTTPClient');
const logger = require('../utils/logger');

const endpoints = {
  createHook: {
    method: 'POST',
    path: '/api/dispatcher/hooks'
  },
  getHook: {
    method: 'GET',
    path: '/api/dispatcher/hooks/:hook'
  },
  getHooks: {
    method: 'GET',
    path: '/api/dispatcher/hooks'
  },
  updateHook: {
    method: 'PUT',
    path: '/api/dispatcher/hooks/:hook'
  },
  deleteHook: {
    method: 'DELETE',
    path: '/api/dispatcher/hooks/:hook'
  }
};

class HookClient {

  constructor() {
    this.httpClient = new HTTPClient();
  }

  createHook(token, hook) {
    return new Promise((resolve, reject) => {
      this.httpClient.sendEndpointRequest(
        endpoints.createHook,
        {
          headers: {
            'x-auth-token': token
          },
          body: hook
        }
      ).then(response => {
        resolve(response.body);
      }).catch(err => {
        if (err.statusCode === 400) {
          reject('A hook with this name already exists.');
        }
        else {
          reject(err.message);
        }
      });
    });
  }

  getHook(token, name) {
    return new Promise((resolve, reject) => {
      logger.debug(`Getting hook ${name}`);
      this.httpClient.sendEndpointRequest(
        endpoints.getHook,
        {
          headers: {
            'x-auth-token': token
          },
          pathVariables: {
            hook: name
          }
        }
      ).then(response => {
        resolve(response.body);
      }).catch(errResponse => {
        if (errResponse.statusCode === 404) {
          reject(`Hook "${name}" could not be found`);
        }
        else {
          reject(errResponse.message);
        }
      });
    });
  }

  getHooks(token) {
    return new Promise(resolve => {
      logger.debug('Getting hooks');
      const stream = new PageableStream();
      resolve(stream);
      this.httpClient.retrieveAllPages(
        stream,
        endpoints.getHooks,
        {
          headers: {
            'x-auth-token': token
          }
        },
        'hooks'
      );
    });
  }

  updateHook(token, name, hook) {
    return new Promise((resolve, reject) => {
      this.httpClient.sendEndpointRequest(
        endpoints.updateHook,
        {
          headers: {
            'x-auth-token': token
          },
          pathVariables: {
            hook: name
          },
          body: hook
        }
      ).then(response => {
        resolve(response.body);
      }).catch(errResponse => {
        if (errResponse.statusCode === 404) {
          reject(`Hook "${name}" does not exists.`);
        }
        else if (errResponse.statusCode === 409){
          reject('A hook with this name already exists.');
        } else {
          reject(errResponse.message);
        }
      });
    });
  }

  deleteHook(token, hook) {
    return new Promise((resolve, reject) => {
      this.httpClient.sendEndpointRequest(
        endpoints.deleteHook,
        {
          headers: {
            'x-auth-token': token
          },
          pathVariables: {
            hook
          }
        }
      ).then(response => {
        resolve(response.body);
      }).catch(err => {
        if (err.statusCode === 404) {
          reject('The hook you are trying to remove does not exist.');
        }
        else {
          reject(err.message);
        }
      });
    });
  }

}

module.exports = HookClient;