shovel/lib/api/monorail/monorail.js

// Copyright 2015, EMC, Inc.

/*eslint-env node*/
var config = require('./../../../config.json');
var client = require('./../client');
var Promise = require('bluebird');
var _ = require('underscore');
Promise.promisifyAll(client);

var pfx = '/api/' + config.monorail.version;
var request = {
    host: config.monorail.httpHost,
    port: config.monorail.httpPort,
    path: pfx,
    token: '',
    data: '',
    api: ''
};
/*
 * Monorail wrapper functions
*/
var MonorailWrapper = {
    request_nodes_get: function () {
        'use strict';
        request.path = pfx + '/nodes';
        return client.GetAsync(request);
    },
    request_node_get: function (identifier) {
        'use strict';
        request.path = pfx + '/nodes/' + identifier;
        return client.GetAsync(request);
    },
    request_whitelist_set: function (hwaddr) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/dhcp/whitelist';
        return client.PostAsync(request);
    },
    request_whitelist_del: function (hwaddr) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/dhcp/whitelist';
        return client.DeleteAsync(request);
    },
    request_catalogs_get: function (hwaddr) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/catalogs';
        return client.GetAsync(request);
    },
    get_catalog_data_by_source: function (hwaddr, source) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/catalogs/' + source;
        return client.GetAsync(request);
    },
    request_poller_get: function (identifier) {
        'use strict';
        request.path = pfx + '/nodes/' + identifier + '/pollers';
        return client.GetAsync(request);
    },
    request_poller_data_get: function (identifier) {
        'use strict';
        request.path = pfx + '/pollers/' + identifier + '/data/current';
        return client.GetAsync(request);
    },
    lookupCatalog: function lookupCatalog(node) {
        'use strict';
        var self = this;
        return self.get_catalog_data_by_source(node.id, 'dmi')
        .then(function (dmi) {
            if (!_.has(JSON.parse(dmi), 'data')) {
                return false;
            }
        })
        .then(function () {
            return self.get_catalog_data_by_source(node.id, 'lsscsi');
        })
        .then(function (lsscsi) {
            if (!_.has(JSON.parse(lsscsi), 'data')) {
                return false;
            }
        })
            .then(function () {
                return self.get_catalog_data_by_source(node.id, 'bmc');
            })
        .then(function (bmc) {
            if (!_.has(JSON.parse(bmc), 'data')) {
                return false;
            } else {
                return true;
            }
        })
        .catch(function () {
            return false;
        });
    },
    nodeDiskSize: function nodeDiskSize(node) {
        'use strict';
        var localGb = 0;
        var self = this;
        return self.get_catalog_data_by_source(node.id, 'lsscsi').
            then(function (scsi) {
                scsi = JSON.parse(scsi);
                if (scsi.data) {
                    for (var elem = 0; elem < scsi.data.length; elem++) {
                        var item = scsi.data[elem];
                        if (item.peripheralType === 'disk') {
                            localGb += parseFloat(item.size.replace('GB', '').trim());
                        }
                    }
                }
                return Promise.resolve(localGb);
            })
        .catch(function (err) {
            throw err;
        });
    },
    getNodeMemoryCpu: function getNodeMemoryCpu(computeNode) {
        'use strict';
        var self = this;
        var dmiData = { cpus: 0, memory: 0 };
        return self.get_catalog_data_by_source(computeNode.id, 'dmi').
        then(function (dmi) {
            dmi = JSON.parse(dmi);
            if (dmi.data) {
                var dmiTotal = 0;
                if (dmi.data['Memory Device']) {
                    var memoryDevice = dmi.data['Memory Device'];
                    for (var elem = 0; elem < memoryDevice.length; elem++) {
                        var item = memoryDevice[elem];
                        //logger.info(item['Size']);
                        if (item.Size.indexOf('GB') > -1) {
                            dmiTotal += parseFloat(item.Size.replace('GB', '').trim()) * 1000;
                        }
                        if (item.Size.indexOf('MB') > -1) {
                            dmiTotal += parseFloat(item.Size.replace('MB', '').trim());
                        }
                    }
                    dmiData.memory = dmiTotal;
                }
                if (dmi.data.hasOwnProperty('Processor Information')) {
                    dmiData.cpus = dmi.data['Processor Information'].length;
                }
            }
            return Promise.resolve(dmiData);
        })
        .catch(function (err) {
            throw err;
        });
    },
    runWorkFlow: function runWorkFlow(hwaddr,graphName,content) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/workflows/?name=' + graphName;
        if (content !== null) {
            request.data = JSON.stringify(content);
        }
        return client.PostAsync(request);
    },
    getWorkFlowActive: function getWorkFlowActive(hwaddr) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/workflows/active';
        return client.GetAsync(request);
    },
    deleteWorkFlowActive: function deleteWorkFlowActive(hwaddr) {
        'use strict';
        request.path = pfx + '/nodes/' + hwaddr + '/workflows/active';
        return client.DeleteAsync(request);
    },
    createTask: function createTask(content) {
        'use strict';
        request.path = pfx + '/workflows/tasks/';
        request.data = JSON.stringify(content);
        return client.PutAsync(request);
    },
    createWorkflow: function createWorkflow(content) {
        'use strict';
        request.path = pfx + '/workflows';
        request.data = JSON.stringify(content);
        return client.PutAsync(request);
    },
    getStatus: function () {
        'use strict';
        return client.getStatus();
    }
};
module.exports = Object.create(MonorailWrapper);