Make sysinfo based on provider
This commit is contained in:
+48
-14
@@ -1,28 +1,62 @@
|
|||||||
|
/* jslint node:true */
|
||||||
|
|
||||||
'use strict';
|
'use strict';
|
||||||
|
|
||||||
|
var assert = require('assert'),
|
||||||
|
caas = require('./sysinfo/caas.js'),
|
||||||
|
config = require('./config.js'),
|
||||||
|
ec2 = require('./sysinfo/ec2.js'),
|
||||||
|
util = require('util');
|
||||||
|
|
||||||
exports = module.exports = {
|
exports = module.exports = {
|
||||||
|
SysInfoError: SysInfoError,
|
||||||
|
|
||||||
getIp: getIp
|
getIp: getIp
|
||||||
};
|
};
|
||||||
|
|
||||||
var os = require('os');
|
|
||||||
|
|
||||||
var gCachedIp = null;
|
var gCachedIp = null;
|
||||||
|
|
||||||
function getIp() {
|
function SysInfoError(reason, errorOrMessage) {
|
||||||
if (gCachedIp) return gCachedIp;
|
assert.strictEqual(typeof reason, 'string');
|
||||||
|
assert(errorOrMessage instanceof Error || typeof errorOrMessage === 'string' || typeof errorOrMessage === 'undefined');
|
||||||
|
|
||||||
var ifaces = os.networkInterfaces();
|
Error.call(this);
|
||||||
for (var dev in ifaces) {
|
Error.captureStackTrace(this, this.constructor);
|
||||||
if (dev.match(/^(en|eth|wlp).*/) === null) continue;
|
|
||||||
|
|
||||||
for (var i = 0; i < ifaces[dev].length; i++) {
|
this.name = this.constructor.name;
|
||||||
if (ifaces[dev][i].family === 'IPv4') {
|
this.reason = reason;
|
||||||
gCachedIp = ifaces[dev][i].address;
|
if (typeof errorOrMessage === 'undefined') {
|
||||||
return gCachedIp;
|
this.message = reason;
|
||||||
}
|
} else if (typeof errorOrMessage === 'string') {
|
||||||
}
|
this.message = errorOrMessage;
|
||||||
|
} else {
|
||||||
|
this.message = 'Internal error';
|
||||||
|
this.nestedError = errorOrMessage;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
util.inherits(SysInfoError, Error);
|
||||||
|
SysInfoError.INTERNAL_ERROR = 'Internal Error';
|
||||||
|
|
||||||
return null;
|
function getApi(callback) {
|
||||||
|
assert.strictEqual(typeof callback, 'function');
|
||||||
|
|
||||||
|
var api = config.provider() === 'caas' ? caas : ec2;
|
||||||
|
|
||||||
|
var options = {};
|
||||||
|
|
||||||
|
callback(null, api, options);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function getIp(callback) {
|
||||||
|
assert.strictEqual(typeof callback, 'function');
|
||||||
|
|
||||||
|
if (gCachedIp) return callback(null, gCachedIp);
|
||||||
|
|
||||||
|
getApi(function (error, ip) {
|
||||||
|
if (error) return callback(error);
|
||||||
|
|
||||||
|
gCachedIp = ip;
|
||||||
|
|
||||||
|
callback(null, gCachedIp);
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|||||||
@@ -0,0 +1,26 @@
|
|||||||
|
'use strict';
|
||||||
|
|
||||||
|
exports = module.exports = {
|
||||||
|
getIp: getIp
|
||||||
|
};
|
||||||
|
|
||||||
|
var assert = require('assert'),
|
||||||
|
os = require('os'),
|
||||||
|
SysInfoError = require('../sysinfo.js').SysInfoError;
|
||||||
|
|
||||||
|
function getIp(callback) {
|
||||||
|
assert.strictEqual(typeof callback, 'function');
|
||||||
|
|
||||||
|
var ifaces = os.networkInterfaces();
|
||||||
|
for (var dev in ifaces) {
|
||||||
|
if (dev.match(/^(en|eth|wlp).*/) === null) continue;
|
||||||
|
|
||||||
|
for (var i = 0; i < ifaces[dev].length; i++) {
|
||||||
|
if (ifaces[dev][i].family === 'IPv4') {
|
||||||
|
return callback(null, ifaces[dev][i].address);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
callback(new SysInfoError(SysInfoError.INTERNAL_ERROR, 'No IP found'));
|
||||||
|
}
|
||||||
@@ -0,0 +1,14 @@
|
|||||||
|
'use strict';
|
||||||
|
|
||||||
|
exports = module.exports = {
|
||||||
|
getIp: getIp
|
||||||
|
};
|
||||||
|
|
||||||
|
var assert = require('assert'),
|
||||||
|
SysInfoError = require('../sysinfo.js').SysInfoError;
|
||||||
|
|
||||||
|
function getIp(callback) {
|
||||||
|
assert.strictEqual(typeof callback, 'function');
|
||||||
|
|
||||||
|
callback(new SysInfoError(SysInfoError.INTERNAL_ERROR, 'Not implemented'));
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user