skyquake/plugins/about/api/about.js

   1 /*
   2  *
   3  *   Copyright 2016 RIFT.IO Inc
   4  *
   5  *   Licensed under the Apache License, Version 2.0 (the "License");
   6  *   you may not use this file except in compliance with the License.
   7  *   You may obtain a copy of the License at
   8  *
   9  *       http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *   Unless required by applicable law or agreed to in writing, software
  12  *   distributed under the License is distributed on an "AS IS" BASIS,
  13  *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *   See the License for the specific language governing permissions and
  15  *   limitations under the License.
  16  *
  17  */
  18
  19 var request = require('request');
  20 var Promise = require('bluebird');
  21 var rp = require('request-promise');
  22 var utils = require('../../../framework/core/api_utils/utils.js');
  23 var constants = require('../../../framework/core/api_utils/constants.js');
  24 var _ = require('underscore');
  25 var APIVersion = '/v1';
  26 var About = {};
  27
  28 About.getVCS = function(req) {
  29   var api_server = req.query["api_server"];
  30
  31   return new Promise(function(resolve, reject) {
  32     var requestHeaders = {};
  33     _.extend(requestHeaders,
  34       constants.HTTP_HEADERS.accept.data, {
  35         'Authorization': req.get('Authorization')
  36       });
  37     request({
  38         url: utils.confdPort(api_server) + APIVersion + '/api/operational/vcs/info?deep',
  39         type: 'GET',
  40         headers: requestHeaders,
  41         forever: constants.FOREVER_ON,
  42         rejectUnauthorized: false,
  43       },
  44       function(error, response, body) {
  45         var data;
  46         console.log(error);
  47         if (utils.validateResponse('About/vcs.get', error, response, body, resolve, reject)) {
  48           try {
  49             data = JSON.parse(response.body)["rw-base:info"]
  50           } catch (e) {
  51             return reject({});
  52           }
  53
  54           return resolve(data);
  55         }
  56       });
  57   });
  58 }
  59
  60 About.getVersion = function(req) {
  61   var api_server = req.query["api_server"];
  62
  63   return new Promise(function(resolve, reject) {
  64     var requestHeaders = {};
  65     _.extend(requestHeaders,
  66       constants.HTTP_HEADERS.accept.data, {
  67         'Authorization': req.get('Authorization')
  68       });
  69     request({
  70         url: utils.confdPort(api_server) + APIVersion + '/api/operational/version?deep',
  71         type: 'GET',
  72         headers: requestHeaders,
  73         forever: constants.FOREVER_ON,
  74         rejectUnauthorized: false,
  75       },
  76       function(error, response, body) {
  77         var data;
  78         console.log(error);
  79         if (utils.validateResponse('About/version.get', error, response, body, resolve, reject)) {
  80           try {
  81             data = JSON.parse(response.body)['rw-base:version']
  82           } catch (e) {
  83             return reject({});
  84           }
  85
  86           return resolve(data);
  87         }
  88       });
  89   });
  90 }
  91
  92 About.get = function(req) {
  93
  94   var api_server = req.query["api_server"];
  95
  96   return new Promise(function(resolve, reject) {
  97     Promise.all([
  98         About.getVCS(req),
  99         About.getVersion(req)
 100       ])
 101       .then(function(results) {
 102         var AboutObject = {};
 103         AboutObject.vcs = results[0];
 104         AboutObject.version = results[1];
 105         resolve(AboutObject);
 106       }, function(error) {
 107         console.log('error getting vcs data', error);
 108         reject(error)
 109       });
 110   });
 111 };
 112
 113 About.uptime = function(req) {
 114   var api_server = req.query["api_server"];
 115   return new Promise(function(resolve, reject) {
 116     var requestHeaders = {};
 117     _.extend(requestHeaders,
 118       constants.HTTP_HEADERS.accept.data, {
 119         'Authorization': req.get('Authorization')
 120       });
 121     request({
 122         url: utils.confdPort(api_server) + APIVersion + '/api/operational/uptime/uptime',
 123         type: 'GET',
 124         headers: requestHeaders,
 125         forever: constants.FOREVER_ON,
 126         rejectUnauthorized: false
 127       },
 128       function(error, response, body) {
 129         if (utils.validateResponse('About.uptime', error, response, body, resolve, reject)) {
 130           try {
 131             data = JSON.parse(response.body);
 132           } catch (e) {
 133             return reject({});
 134           }
 135           return resolve(data)
 136
 137         }
 138       })
 139   })
 140 }
 141 module.exports = About;