makeomatic/ms-payments

const Errors = require('common-errors');
const is = require('is');
const { ActionTransport } = require('@microfleet/core');

// helpers
const key = require('../../redis-key');
const { AGREEMENT_DATA, FREE_PLAN_ID } = require('../../constants');
const { deserialize } = require('../../utils/redis');
/**
 * @api {amqp} <prefix>.agreement.get Get Agreement
 * @apiVersion 1.0.0
 * @apiName get
 * @apiGroup Agreement
 *
 * @apiDescription Returns agreement information
  *
 * @apiSchema {jsonschema=agreement/get.json} apiRequest
 * @apiSchema {jsonschema=response/agreement/get.json} apiResponse
 */
async function getAgreement({ params: message }) {
  const { redis } = this;
  const { id, owner } = message;
  const agreementKey = key(AGREEMENT_DATA, id);

  if (id === FREE_PLAN_ID) {
    // no data, sorry
    return {
      agreement: { id },
      owner,
      plan: id,
    };
  }

  const data = await redis.hgetall(agreementKey);
  if (is.empty(data)) {
    throw new Errors.HttpStatusError(404, `agreement ${id} not found`);
  }

  const output = deserialize(data);
  if (owner && output.owner !== owner) {
    throw new Errors.HttpStatusError(403, `no access to ${id}`);
  }

  return output;
}

getAgreement.transports = [ActionTransport.amqp, ActionTransport.internal];

module.exports = getAgreement;