apiclient.js

/*
 * API client creates requests against API and returns result body.
 */

var rootcheck   = require('./rootcheck.js')
var log         = require('fancy-log')
var https       = require('https')
var http        = require('http')
var fs          = require('fs-extra')

var exports = {}

exports.request = function(path, method, pushdata) {
    return new Promise(function(resolve, reject) {
        log("Creating request against API")

        var httpresponse = function(response) {
            var body = '';

            response.on('data', function(chunk) {
                body += chunk;
            });

            response.on('end', function() {
                var response = JSON.parse(body);

                // Catch API Input errors:
                if(response.success === false) {
                    // Check if the first error is an API error (coded 100). It the first is, a second will be as well.
                    if(response.errors[0].code === 100){
                        // API input was invalid.
                        response.errors.forEach(function(error) {
                            log.error("API error: " + error.message);
                        });

                        reject("One or more API errors");
                    } else {
                        reject(response);
                    }
                } else {
                    resolve(response);
                }
            });
        };

        var req;

        new Promise(function(resolve, reject) {
            if(global.config.apiserver.tls) {
                rootcheck.checkCert().then(function(){
                    var rootcert = fs.readFileSync('data/root.cert.pem');

                    req = https.request({
                        host: global.config.apiserver.hostname,
                        port: global.config.apiserver.port,
                        path: path,
                        method: method,
                        headers: {
                            'Content-Type': 'application/json'
                        },
                        ca: rootcert
                    }, httpresponse);
                    resolve();
                })
                .catch(function(err) {
                    reject("Could not check root cert: " + err);
                });
            } else {
                req = http.request({
                    host: global.config.apiserver.hostname,
                    port: global.config.apiserver.port,
                    path: path,
                    method: method,
                    headers: {
                        'Content-Type': 'application/json'
                    }
                }, httpresponse);
                resolve();
            }
        })
        .then(function(){
            req.on('error', function(error) {
                reject(error)
            });

            if(method === 'POST') {
                var json = JSON.stringify(pushdata);
                req.write(json);
            }

            // Send request
            req.end();
        })
        .catch(function(err) {
            reject(err)
        });
    })
}


module.exports = exports;