@iin-mdc/koa-utils/lib/message-bus-client.js

"use strict"

const request = require("request")

class MessageBusClient {
  constructor(logger, options={}) {
    let {uri, token} = options

    this.logger  = logger
    this.baseUri = `${uri}/api/v2/management`
    this.requestOptions = {
      json: true,
      headers: {
        "Content-Type": "application/json;charset=utf-8",
        "Authorization": `Token ${token}`
      }
    }
  }

  //"/controllers/:uuid/execAsync/:command*"
  async executeAsync(controllerUuid, commandName, body={}) {
    return this.performRequest({
      uri: `${this.baseUri}/controllers/${controllerUuid}/execAsync/${commandName}`,
      method: "POST",
      body
    })
  }

  //"/controllers/:uuid/execSync/:command*"
  async executeSync(controllerUuid, commandName, body={}) {
    return this.performRequest({
      uri: `${this.baseUri}/controllers/${controllerUuid}/execSync/${commandName}`,
      method: "POST",
      body
    })
  }

  //"/controllers/:uuid/status"
  async getControllerStatus(controllerUuid) {
    return this.performRequest({
      uri: `${this.baseUri}/controllers/${controllerUuid}/status`,
      method: "GET"
    })
  }

  //"/controllers/:uuid/status"
  async updateApplication(controllerUuid, applicationUuid) {
    return this.performRequest({
      uri: `${this.baseUri}/controllers/${controllerUuid}`,
      method: "POST",
      body: {ApplicationUuid: applicationUuid}
    })
  }


  async performRequest(requestOptions) {
    let opts = Object.assign({}, this.requestOptions, requestOptions)
    return new Promise((resolve, reject) => {
      request(opts, (error, response, body) => {
        if(error)                      return reject(error)
        if(response.statusCode >= 400) return reject(new MessageBusError(response.statusMessage))
        return resolve(body)
      })
    })
  }
}

class MessageBusError extends Error {}

MessageBusClient.MessageBusError = MessageBusError
module.exports = MessageBusClient