RackHD/on-tasks

// Copyright © 2017 Dell Inc. or its subsidiaries. All Rights Reserved.

'use strict';

var di = require('di');
module.exports = WsmanGetComponentFactory;
di.annotate(WsmanGetComponentFactory, new di.Provide('Job.Dell.Wsman.GetXml'));
di.annotate(WsmanGetComponentFactory, new di.Inject(
    'Job.Dell.Wsman.Base',
    'JobUtils.WsmanTool',
    'Logger',
    'Assert',
    'Util',
    'Services.Configuration',
    'Errors',
    'Services.Encryption',
    'validator',
    'JobUtils.NfsClient'
));

function WsmanGetComponentFactory(
    BaseJob,
    WsmanTool,
    Logger,
    assert,
    util,
    configuration,
    errors,
    encryption,
    validator,
    NfsClient
) {
    var logger = Logger.initialize(WsmanGetComponentFactory);

    function WsmanGetComponentJob(options, context, taskId) {
        WsmanGetComponentJob.super_.call(this, logger, options, context, taskId);
        assert.object(this.options);
        this.nodeId = this.context.target;
    }

    util.inherits(WsmanGetComponentJob, BaseJob);

    WsmanGetComponentJob.prototype._initJob = function () {
        var self = this;
        self.dell = configuration.get('dell');
        if (!self.dell || !self.dell.services || !self.dell.services.configuration) {
            throw new errors.NotFoundError('Dell SCP  web service is not defined in smiConfig.json.');
        }
        if(!self.dell.shareFolder){
            throw new errors.NotFoundError('The shareFolder is not defined in smiConfig.json.');
        }
        if(self.dell.shareFolder.shareType === 0){
            var mountDir = '/tmp/' + self.context.graphId;
            var nfsClient = new NfsClient(
                self.dell.shareFolder.address,
                self.dell.shareFolder.shareName,
                mountDir
            );
            self.context.mountDir = mountDir;
            return nfsClient.mount();
        }
    };

    WsmanGetComponentJob.prototype._handleSyncRequest = function() {
        var self = this;
        if(self.options.ipAddress === '' || self.options.username === '' ||
            self.options.password === ''){
                return self.checkOBM('SCP create xml for deleting volume')
                    .then(function(obm){
                        return self.getComponent(obm);
                    });
        }else{
            var obm = {
               "config": {
                   "host": self.options.ipAddress,
                   "user": self.options.username,
                   "password": self.options.password
               }
            };
            return self.getComponent(obm);
        }
    };

    WsmanGetComponentJob.prototype._handleSyncResponse = function(response) {
        if (response.body.status === "OK") {
            return response;
        } else {
            throw new Error("Failed to getXml from smi service.");
        }
    };

    WsmanGetComponentJob.prototype.getComponent = function(obm) {
        if (!validator.isIP(obm.config.host)) {
            throw new Error('Invalid ServerIP');
        }
        var self = this;
        var componentNames = "";
        if(self.options.volumeId !== undefined && self.options.volumeId !== "") {
            componentNames = self.options.volumeId.split(':')[1];
        } else if(self.options.drives !== undefined) {
            var drive = self.options.drives.split(',')[0];
            componentNames = drive.slice(drive.lastIndexOf(':')+1, drive.length);
        } else if(self.options.driveId) {
            componentNames = self.options.driveId.split(':')[2];
        } else {
            throw new Error('Drives or volumeId isn\'t defined.');
        }
        var data = {
            "componentNames": [componentNames],
            "fileName": self.context.graphId + ".xml",
            "serverIP": obm.config.host,
            "serverPassword": obm.config.user,
            "serverUsername": encryption.decrypt(obm.config.password),
            "shareAddress": self.dell.shareFolder.address,
            "shareName": self.dell.shareFolder.shareName,
            "sharePassword": self.dell.shareFolder.password,
            "shareType": self.dell.shareFolder.shareType,
            "shutdownType": self.options.shutdownType,
            "shareUsername": self.dell.shareFolder.username
        };

        var wsman = new WsmanTool(self.dell.gateway, {
            verifySSl: false,
            recvTimeoutMs: 60000
        });
        return wsman.clientRequest(
            self.dell.services.configuration.getComponents,
            "POST",
            data
        );
    };

    return WsmanGetComponentJob;
}