runner
This commit is contained in:
309
lxc.js
309
lxc.js
@ -1,5 +1,28 @@
|
|||||||
'use strict';
|
'use strict';
|
||||||
var exec = require('child_process').exec;
|
var exec = require('child_process').exec;
|
||||||
|
var extend = require('node.extend');
|
||||||
|
|
||||||
|
|
||||||
|
var parseArgs = function(required, takes, config){
|
||||||
|
var all = Object.keys(config);
|
||||||
|
// console.log(all)
|
||||||
|
for(var i=required.length; i--;){
|
||||||
|
if(all.indexOf(required[i]) !== -1){
|
||||||
|
required.splice(i, 1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if(required.length !== 0) return false;
|
||||||
|
|
||||||
|
var out = '';
|
||||||
|
for(var i=0; i< takes.length; i++){
|
||||||
|
if(all.indexOf(takes[i]) !== -1){
|
||||||
|
out += '--'+takes[i]+' '+config[takes[i]]+' ';
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return out;
|
||||||
|
};
|
||||||
|
|
||||||
function sysExec(command, callback){
|
function sysExec(command, callback){
|
||||||
command = 'unset XDG_SESSION_ID XDG_RUNTIME_DIR; cgm movepid all virt $$; ' + command;
|
command = 'unset XDG_SESSION_ID XDG_RUNTIME_DIR; cgm movepid all virt $$; ' + command;
|
||||||
@ -13,126 +36,224 @@ function sysExec(command, callback){
|
|||||||
})(callback));
|
})(callback));
|
||||||
};
|
};
|
||||||
|
|
||||||
|
|
||||||
var Container = function(config){
|
var Container = function(config){
|
||||||
this.name = config.name;
|
this.name = config.name;
|
||||||
this.state = config.state;
|
this.state = config.state || 'STOPPED';
|
||||||
this.ip = config.ip || (config.ipv4 || '').replace('-', '') || null ;
|
this.ip = config.ip || (config.ipv4 || '').replace('-', '') || null ;
|
||||||
|
this.overlayfs = null
|
||||||
}
|
}
|
||||||
|
|
||||||
Container.prototype.autoShutDown = function(time) {
|
Container.prototype.clone = function(callback){
|
||||||
time = time || 600000;
|
var overlayfs = this.overlayfs : ' -B overlayfs -s ' ? '';
|
||||||
|
|
||||||
// this.__shutDownTimeout = setTimeout(function(){}, this.autoShutDown):
|
return sysExec('lxc-clone -o '+this.orig+ ' -n '+this.name + overlayfs, callback);
|
||||||
};
|
};
|
||||||
|
|
||||||
var lxcORM = function(){
|
Container.prototype.start = function(callback){
|
||||||
var orm = {}
|
args = parseArgs({
|
||||||
lxc.list(function(data){
|
required: ['name'],
|
||||||
for(var idx = data.length; idx--;){
|
takes: ['name'],
|
||||||
orm[data[idx].name] = new Container(data[idx]);
|
defaults: extend({}, this);
|
||||||
}
|
|
||||||
});
|
});
|
||||||
|
|
||||||
return orm
|
return sysExec('lxc-start --daemon '+args, callback);
|
||||||
};
|
};
|
||||||
|
|
||||||
var lxc = {
|
Container.prototype.startEphemeral = function(callback){
|
||||||
create: function(name, template, config, callback){
|
args = parseArgs({
|
||||||
return sysExec('lxc-create -n '+name+' -t '+template, callback);
|
required: ['orig'],
|
||||||
},
|
takes: ['orig', 'name', 'key', 'union-type', 'keep-data'],
|
||||||
|
defaults: extend({}, this)
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
clone: function(name, base_name, callback){
|
var command = 'lxc-start-ephemeral --daemon '+args;
|
||||||
return sysExec('lxc-clone -o '+base_name+ ' -n '+name +' -B overlayfs -s', callback);
|
return sysExec(command, function(data){
|
||||||
},
|
console.log('startEphemeral', arguments);
|
||||||
|
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]});
|
||||||
|
}
|
||||||
|
|
||||||
destroy: function(name, callback){
|
callback({'?': '?', data: data, name: name, base_name: base_name});
|
||||||
return sysExec('lxc-destroy -n '+ name, function(data){
|
});
|
||||||
var info = data.match(/Destroyed container/);
|
};
|
||||||
console.log('destroy info:', info);
|
|
||||||
var args = [true].concat(Array.prototype.slice.call(arguments, 1));
|
|
||||||
return callback.apply(this, args);
|
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
start: function(name, callback){
|
Container.prototype.destroy = function(callback){
|
||||||
return sysExec('lxc-start --name '+name+' --daemon', callback);
|
args = parseArgs({
|
||||||
},
|
required: ['name'],
|
||||||
|
takes: ['name', 'force'],
|
||||||
|
defaults: extend({}, this)
|
||||||
|
});
|
||||||
|
|
||||||
startEphemeral: function(name, base_name, callback){
|
return sysExec('lxc-destroy '+ args, function(data){
|
||||||
var command = 'lxc-start-ephemeral -o '+base_name+ ' -n '+name +' --union-type overlayfs -d';
|
var info = data.match(/Destroyed container/);
|
||||||
return sysExec(command, function(data){
|
console.log('destroy info:', info);
|
||||||
console.log('startEphemeral', arguments);
|
var args = [true].concat(Array.prototype.slice.call(arguments, 1));
|
||||||
if(data.match("doesn't exist.")){
|
return callback.apply(this, args);
|
||||||
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});
|
Container.prototype.stop = function(callback){
|
||||||
});
|
args = parseArgs({
|
||||||
},
|
required: ['name'],
|
||||||
|
takes: ['name', 'reboot', 'nowait', 'timeout', 'kill'],
|
||||||
|
defaults: extend({}, this)
|
||||||
|
|
||||||
|
});
|
||||||
|
return sysExec('lxc-stop '+args, callback);
|
||||||
|
};
|
||||||
|
|
||||||
stop: function(name, callback){
|
Container.prototype.freeze = function(callback){
|
||||||
return sysExec('lxc-stop -n '+ name, callback);
|
args = parseArgs({
|
||||||
},
|
required: ['name'],
|
||||||
|
takes: ['name', 'force'],
|
||||||
|
defaults: extend({}, this)
|
||||||
|
});
|
||||||
|
return sysExec('lxc-freeze -n '+name, callback);
|
||||||
|
};
|
||||||
|
|
||||||
freeze: function(name, callback){
|
Container.prototype.unfreeze = function(callback){
|
||||||
return sysExec('lxc-freeze -n '+name, callback);
|
|
||||||
},
|
|
||||||
|
|
||||||
unfreeze: function(name, callback){
|
return sysExec('lxc-unfreeze --name '+this.name, callback);
|
||||||
return sysExec('lxc-unfreeze -n '+name, callback);
|
};
|
||||||
},
|
|
||||||
|
|
||||||
info: function(name, callback){
|
Container.prototype.info = function(callback){
|
||||||
return sysExec('lxc-info -n '+name, function(data){
|
args = parseArgs({
|
||||||
console.log('info', arguments);
|
required: ['name'],
|
||||||
if(data.match("doesn't exist")){
|
takes: ['name', 'reboot', 'nowait', 'timeout', 'kill'],
|
||||||
return callback({state: 'NULL'});
|
defaults: extend({}, this)
|
||||||
}
|
|
||||||
|
});
|
||||||
|
return sysExec('lxc-stop '+args, callback);
|
||||||
|
};
|
||||||
|
|
||||||
var info = {};
|
Container.prototype.freeze = function(callback){
|
||||||
data = data.replace(/\suse/ig, '').replace(/\sbytes/ig, '').split("\n").slice(0,-1);
|
args = parseArgs({
|
||||||
for(var i in data){
|
required: ['name'],
|
||||||
var temp = data[i].split(/\:\s+/);
|
takes: ['name', 'force'],
|
||||||
info[temp[0].toLowerCase().trim()] = temp[1].trim();
|
defaults: extend({}, this)
|
||||||
}
|
});
|
||||||
var args = [info].concat(Array.prototype.slice.call(arguments, 1));
|
return sysExec('lxc-freeze -n '+name, callback);
|
||||||
callback.apply(this, args);
|
};
|
||||||
});
|
|
||||||
},
|
|
||||||
|
|
||||||
list: function(callback){
|
Container.prototype.unfreeze = function(callback){
|
||||||
sysExec('lxc-ls --fancy', function(data){
|
|
||||||
var output = data.split("\n");
|
|
||||||
var keys = output.splice(0,1)[0].split(/\s+/).slice(0,-1);
|
|
||||||
var info = [];
|
|
||||||
|
|
||||||
keys = keys.map(function(v){return v.toLowerCase()});
|
return sysExec('lxc-unfreeze --name '+this.name, callback);
|
||||||
output = output.slice(0).slice(0,-1);
|
};
|
||||||
|
|
||||||
for(var i in output){
|
Container.prototype.info = function(callback){
|
||||||
if(output[i].match(/^-/)) continue; // compatibility with 1.x and 2.x output
|
return sysExec('lxc-info --name '+this.name, function(data){
|
||||||
|
console.log('info', arguments);
|
||||||
|
if(data.match("doesn't exist")){
|
||||||
|
return callback({state: 'NULL'});
|
||||||
|
}
|
||||||
|
|
||||||
var aIn = output[i].split(/\s+/).slice(0,-1);
|
var info = {};
|
||||||
var mapOut = {};
|
data = data.replace(/\suse/ig, '').replace(/\sbytes/ig, '').split("\n").slice(0,-1);
|
||||||
aIn.map(function(value,idx){
|
for(var i in data){
|
||||||
mapOut[keys[idx]] = value;
|
var temp = data[i].split(/\:\s+/);
|
||||||
});
|
info[temp[0].toLowerCase().trim()] = temp[1].trim();
|
||||||
info.push(mapOut);
|
}
|
||||||
|
var args = [info].concat(Array.prototype.slice.call(arguments, 1));
|
||||||
}
|
return callback.apply(this, args);
|
||||||
var args = [info].concat(Array.prototype.slice.call(arguments, 1));
|
});
|
||||||
callback.apply(this, args);
|
};
|
||||||
});
|
|
||||||
|
Container.prototype.UpdateFromInfo = function(data){
|
||||||
|
for(var key in Object.keys(data)){
|
||||||
|
this[key] = data[key];
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
var lxcORM = function(){
|
||||||
|
this.containers = {}
|
||||||
|
lxc.list(function(data){
|
||||||
|
for(var idx = data.length; idx--;){
|
||||||
|
container[data[idx].name] = new Container(data[idx]);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
this.isReady = false;
|
||||||
|
this.whenReady = [];
|
||||||
|
|
||||||
};
|
};
|
||||||
|
|
||||||
module.exports = lxc;
|
lxc.prototype.callReady = function(){
|
||||||
|
for(var idx=0; idx<this.whenReady.length; idx--){
|
||||||
|
this.whenReady[idx].apply(this);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var orm = lxcORM()
|
lxcORM.prototype.ready = function(callback){
|
||||||
setTimeout(function(){console.log(orm)}, 5000)
|
if(this.isReady){
|
||||||
|
return callback.apply(this);
|
||||||
|
}
|
||||||
|
else{
|
||||||
|
this.whenReady.append(callback);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
lxcORM.prototype.create = function(args, callback){
|
||||||
|
|
||||||
|
args = parseArgs({
|
||||||
|
required: ['name', 'template'],
|
||||||
|
takes: ['name', 'template', ' ', 'd', 'r', 'a'],
|
||||||
|
defaults: extend({template:'download', ' ': ' ', d: 'ubuntu', r: 'trusty', a: 'amd64'}, args)
|
||||||
|
|
||||||
|
})
|
||||||
|
|
||||||
|
return sysExec('lxc-create '+args, callback);
|
||||||
|
};
|
||||||
|
|
||||||
|
lxcORM.prototype.list= function(callback){
|
||||||
|
sysExec('lxc-ls --fancy', function(data){
|
||||||
|
var output = data.split("\n");
|
||||||
|
var keys = output.splice(0,1)[0].split(/\s+/).slice(0,-1);
|
||||||
|
var info = [];
|
||||||
|
|
||||||
|
keys = keys.map(function(v){return v.toLowerCase()});
|
||||||
|
output = output.slice(0).slice(0,-1);
|
||||||
|
|
||||||
|
for(var i in output){
|
||||||
|
if(output[i].match(/^-/)) continue; // compatibility with 1.x and 2.x output
|
||||||
|
|
||||||
|
var aIn = output[i].split(/\s+/).slice(0,-1);
|
||||||
|
var mapOut = {};
|
||||||
|
aIn.map(function(value,idx){
|
||||||
|
mapOut[keys[idx]] = value;
|
||||||
|
});
|
||||||
|
info.push(mapOut);
|
||||||
|
|
||||||
|
}
|
||||||
|
var args = [info].concat(Array.prototype.slice.call(arguments, 1));
|
||||||
|
callback.apply(this, args);
|
||||||
|
});
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
// module.exports = lxc;
|
||||||
|
|
||||||
|
var orm = new lxcORM()
|
||||||
|
lxc.ready(function(){
|
||||||
|
console.log(arguments, this);
|
||||||
|
})
|
||||||
|
// setTimeout(function(){console.log(orm)}, 5000)
|
||||||
|
|||||||
Reference in New Issue
Block a user