@bbc/http-transport/lib/request.js

'use strict';

const qs = require('qs');

class Request {
  constructor() {
    this._queries = {};
    this._headers = {};
    this._timeout = undefined;
    this._method = undefined;
    this._baseUrl = undefined;
    this._body;
  }

  addQuery(k, v) {
    if (arguments.length === 0 || v === undefined) {
      return this;
    }

    this._queries[k] = v;
    return this;
  }

  addHeader(k, v) {
    if (arguments.length === 0 || v === undefined) {
      return this;
    }

    this._headers[k] = v;
    return this;
  }

  body(content) {
    this._body = content;
    return this;
  }

  method(method) {
    this._method = method;
    return this;
  }

  baseUrl(baseUrl) {
    this._baseUrl = baseUrl;
    return this;
  }

  timeout(timeout) {
    this._timeout = timeout;
    return this;
  }

  getMethod() {
    return this._method;
  }

  getTimeout() {
    return this._timeout;
  }

  getUrl() {
    if (this.hasQueries()) {
      const delimiter = this.hasBaseQueries() ? '&' : '?';
      return `${this._baseUrl}${delimiter}${qs.stringify(this._queries)}`;
    }

    return this._baseUrl;
  }

  getRequestKey() {
    return `${this.getMethod()}:${this.getUrl()}`;
  }

  getHeaders() {
    return this._headers;
  }

  getQueries() {
    return this._queries;
  }

  hasQueries() {
    return Object.keys(this._queries).length > 0;
  }

  hasBaseQueries() {
    return this._baseUrl.indexOf('?') >= 0;
  }

  hasHeaders() {
    return Object.keys(this._headers).length > 0;
  }

  getBody() {
    return this._body;
  }

  static create() {
    return new Request();
  }
}

module.exports = Request;