formating
This commit is contained in:
parent
7c28ee7eb8
commit
c99f3e8877
193
lxc.js
193
lxc.js
@ -1,129 +1,94 @@
|
|||||||
module.exports = function(config){
|
module.exports = function(config){
|
||||||
var obj = {};
|
var obj = {};
|
||||||
var cmd = require('node-cmd');
|
var cmd = require('node-cmd');
|
||||||
|
|
||||||
var sysExec = function(command, callback){
|
var sysExec = function(command, callback){
|
||||||
// console.log('sysExec: ', command, '||| callback:', callback)
|
// console.log('sysExec: ', command, '||| callback:', callback)
|
||||||
cmd.get('unset XDG_SESSION_ID XDG_RUNTIME_DIR; cgm movepid all virt $$; '+command, callback)
|
cmd.get('unset XDG_SESSION_ID XDG_RUNTIME_DIR; cgm movepid all virt $$; '+command, callback)
|
||||||
}
|
}
|
||||||
/* var obj = {};
|
|
||||||
var child = require('child'),
|
|
||||||
sshBind = config.sshBind || false;
|
|
||||||
|
|
||||||
//http://stackoverflow.com/questions/10530532/
|
obj.create = function(name, template, config, cbComplete){
|
||||||
function textToArgs(s){
|
sysExec('lxc-create -n '+name+' -t '+template, cbComplete);
|
||||||
var words = [];
|
};
|
||||||
s.replace(/"([^"]*)"|'([^']*)'|(\S+)/g,function(g0,g1,g2,g3){ words.push(g1 || g2 || g3 || '')});
|
|
||||||
return words;
|
obj.clone = function(name, base_name, cbComplete, cbData){
|
||||||
}
|
sysExec('lxc-clone -o '+base_name+ ' -n '+name +' -B overlayfs -s', cbComplete, cbData);
|
||||||
|
};
|
||||||
|
|
||||||
var sysExec = function(command, onData, onClose){
|
obj.destroy = function(name, callback){
|
||||||
|
sysExec('lxc-destroy -n '+ name, function(data){
|
||||||
|
callback(!data.match(/Destroyed container/))
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
onData = onData || function(){};
|
obj.start = function(name, callback){
|
||||||
onClose = onClose || function(){};
|
var cmd = 'lxc-start --name '+name+' --daemon';
|
||||||
|
console.log('start cmd\n', cmd, '\n');
|
||||||
|
sysExec(cmd, callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
obj.startEphemeral = function(name, base_name, callback){
|
||||||
|
|
||||||
if (sshBind != false)
|
var output = '';
|
||||||
{
|
sysExec('lxc-start-ephemeral -o '+base_name+ ' -n '+name +' --union-type overlayfs -d', function(data){
|
||||||
var runCommand = sshBind.slice();
|
if(data.match("doesn't exist.")) return callback({status: 500, error: "doesn't exist."});
|
||||||
runCommand.push(command);
|
if(data.match("already exists.")) return callback({status: 500, error: "already exists"});
|
||||||
} else {
|
if(data.match(/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/)) return callback({status: 200, state:'RUNNING', ip: data.match(/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/)[0]});
|
||||||
var runCommand = textToArgs('unset XDG_SESSION_ID XDG_RUNTIME_DIR; cgm movepid all virt $$; '+command);
|
callback({'?': '?', data: data, name: name, base_name: base_name});
|
||||||
}
|
});
|
||||||
|
};
|
||||||
|
|
||||||
var errors = '';
|
obj.stop = function(name, callback){
|
||||||
|
console.log('stop', name);
|
||||||
child({
|
sysExec('lxc-stop -n '+ name, callback);
|
||||||
command: runCommand.slice(0,1)[0],
|
};
|
||||||
args: runCommand.slice(1),
|
|
||||||
cbStdout: function(data){ onData(''+data) },
|
|
||||||
cbStderr: function(data){ errors+=data; onData(''+data) },
|
|
||||||
cbClose: function(exitCode){ onClose(exitCode == 0 ? null:exitCode, errors) }
|
|
||||||
}).start();
|
|
||||||
};
|
|
||||||
*/
|
|
||||||
|
|
||||||
obj.create = function(name, template, config, cbComplete){
|
|
||||||
sysExec('lxc-create -n '+name+' -t '+template, cbComplete);
|
|
||||||
};
|
|
||||||
|
|
||||||
obj.clone = function(name, base_name, cbComplete, cbData){
|
|
||||||
sysExec('lxc-clone -o '+base_name+ ' -n '+name +' -B overlayfs -s', cbComplete, cbData);
|
|
||||||
};
|
|
||||||
|
|
||||||
obj.destroy = function(name, callback){
|
|
||||||
sysExec('lxc-destroy -n '+ name, function(data){
|
|
||||||
callback(!data.match(/Destroyed container/))
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
obj.start = function(name, callback){
|
|
||||||
var cmd = 'lxc-start --name '+name+' --daemon';
|
|
||||||
console.log('start cmd\n', cmd, '\n');
|
|
||||||
sysExec(cmd, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
obj.startEphemeral = function(name, base_name, callback){
|
|
||||||
|
|
||||||
var output = '';
|
|
||||||
sysExec('lxc-start-ephemeral -o '+base_name+ ' -n '+name +' --union-type overlayfs -d', function(data){
|
|
||||||
if(data.match("doesn't exist.")) return callback({status: 500, error: "doesn't exist."});
|
|
||||||
if(data.match("already exists.")) return callback({status: 500, error: "already exists"});
|
|
||||||
if(data.match(/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/)) return callback({status: 200, state:'RUNNING', ip: data.match(/\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}/)[0]});
|
|
||||||
callback({'?': '?', data: data, name: name, base_name: base_name});
|
|
||||||
});
|
|
||||||
};
|
|
||||||
|
|
||||||
obj.stop = function(name, callback){
|
|
||||||
console.log('stop', name);
|
|
||||||
sysExec('lxc-stop -n '+ name, callback);
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
obj.freeze = function(name, cbComplete, cbData){
|
obj.freeze = function(name, cbComplete, cbData){
|
||||||
sysExec('lxc-freeze -n '+name, cbComplete, cbData);
|
sysExec('lxc-freeze -n '+name, cbComplete, cbData);
|
||||||
};
|
};
|
||||||
|
|
||||||
obj.unfreeze = function(name, cbComplete, cbData){
|
obj.unfreeze = function(name, cbComplete, cbData){
|
||||||
sysExec('lxc-unfreeze -n '+name, cbComplete, cbData);
|
sysExec('lxc-unfreeze -n '+name, cbComplete, cbData);
|
||||||
};
|
};
|
||||||
|
|
||||||
obj.info = function(name, callback){
|
obj.info = function(name, callback){
|
||||||
|
|
||||||
var output = '';
|
var output = '';
|
||||||
sysExec('lxc-info -n '+name, function(data){
|
sysExec('lxc-info -n '+name, function(data){
|
||||||
console.log('info', name, data)
|
console.log('info', name, data)
|
||||||
if(data.match("doesn't exist")) return callback({state: 'NULL'});
|
if(data.match("doesn't exist")) return callback({state: 'NULL'});
|
||||||
var info = {};
|
var info = {};
|
||||||
data = data.replace(/\suse/ig, '').replace(/\sbytes/ig, '').split("\n").slice(0,-1);
|
data = data.replace(/\suse/ig, '').replace(/\sbytes/ig, '').split("\n").slice(0,-1);
|
||||||
for(var i in data){
|
for(var i in data){
|
||||||
var temp = data[i].split(/\:\s+/);
|
var temp = data[i].split(/\:\s+/);
|
||||||
info[temp[0].toLowerCase().trim()] = temp[1].trim();
|
info[temp[0].toLowerCase().trim()] = temp[1].trim();
|
||||||
}
|
}
|
||||||
callback(info);
|
callback(info);
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
obj.list = function(callback){
|
obj.list = function(callback){
|
||||||
sysExec('lxc-ls --fancy', function(data){
|
sysExec('lxc-ls --fancy', function(data){
|
||||||
var output = data.split("\n");
|
var output = data.split("\n");
|
||||||
var keys = output.splice(0,1)[0].split(/\s+/).slice(0,-1);
|
var keys = output.splice(0,1)[0].split(/\s+/).slice(0,-1);
|
||||||
var info = [];
|
var info = [];
|
||||||
|
|
||||||
keys = keys.map(function(v){return v.toLowerCase()});
|
keys = keys.map(function(v){return v.toLowerCase()});
|
||||||
output = output.slice(0).splice(1).slice(0,-1);
|
output = output.slice(0).splice(1).slice(0,-1);
|
||||||
|
|
||||||
for (var i in output)
|
for (var i in output)
|
||||||
{
|
{
|
||||||
|
|
||||||
var aIn = output[i].split(/\s+/).slice(0,-1),
|
var aIn = output[i].split(/\s+/).slice(0,-1),
|
||||||
mapOut = {};
|
mapOut = {};
|
||||||
aIn.map( function(v,i){ mapOut[keys[i]] = v; } );
|
aIn.map( function(v,i){ mapOut[keys[i]] = v; } );
|
||||||
info.push(mapOut);
|
info.push(mapOut);
|
||||||
|
|
||||||
}
|
}
|
||||||
callback(info);
|
callback(info);
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
|
|
||||||
return obj;
|
return obj;
|
||||||
};
|
};
|
||||||
Loading…
x
Reference in New Issue
Block a user