app.js

"use strict";

// Dependencies
const request = require("request");
const OAuth = require("oauth-1.0a");
const crypto = require("crypto");

module.exports = NetSuiteOAuth;

/**
 * Constructor
 *
 * @param url
 * @param method
 * @param consumerKey
 * @param consumerSecret
 * @param tokenId
 * @param tokenSecret
 * @param account
 * @param algorithm
 * @param signatureMethod
 * @returns {PromiseLike<ArrayBuffer>}
 * @constructor
 */
function NetSuiteOAuth(
  url,
  method,
  consumerKey,
  consumerSecret,
  tokenId,
  tokenSecret,
  account,
  algorithm = "sha1",
  signatureMethod = "HMAC-SHA1"
) {
  this.oauth = OAuth({
    consumer: {
      key: consumerKey,
      secret: consumerSecret,
    },
    realm: account,
    signature_method: signatureMethod,
    hash_function(base_string, key) {
      return crypto
        .createHmac(algorithm, key)
        .update(base_string)
        .digest("base64");
    },
  });

  this.request_data = {
    url: url,
    method: method,
  };

  this.token = {
    key: tokenId,
    secret: tokenSecret,
  };

  this.headers = this.oauth.toHeader(
    this.oauth.authorize(this.request_data, this.token)
  );
  this.headers["Content-Type"] = "application/json";
}

NetSuiteOAuth.prototype.get = function () {
  return new Promise((resolve, reject) => {
    request(
      {
        url: this.request_data.url,
        method: this.request_data.method,
        headers: this.headers,
      },
      function (error, response, body) {
        if (error || response.statusCode.toString()[0] != 2) {
          console.log("Body data:", body);
          reject(body || error);
        } else {
          if (typeof body == "string") body = JSON.parse(body);
          resolve(body || error);
        }
      }
    );
  });
};

NetSuiteOAuth.prototype.post = function (data) {
  return new Promise((resolve, reject) => {
    request(
      {
        url: this.request_data.url,
        method: this.request_data.method,
        json: data,
        headers: this.headers,
      },
      function (error, response, body) {
        if (error || response.statusCode.toString()[0] != 2) {
          console.log("Body data:", body);
          reject(body || error);
        } else {
          if (typeof body == "string") {
            try {
              body = JSON.parse(body);
            } catch (error) {
              console.log("unable to parse response body");
              reject(error);
            }
          }
          resolve(body || error);
        }
      }
    );
  });
};

NetSuiteOAuth.prototype.put = function (data) {
  return new Promise((resolve, reject) => {
    request(
      {
        url: this.request_data.url,
        method: this.request_data.method,
        json: data,
        headers: this.headers,
      },
      function (error, response, body) {
        if (error || response.statusCode.toString()[0] != 2) {
          console.log("Body data:", body);
          reject(body || error);
        } else {
          if (typeof body == "string") {
            try {
              body = JSON.parse(body);
            } catch (error) {
              console.log("unable to parse response body");
              reject(error);
            }
          }
          resolve(body || error);
        }
      }
    );
  });
};