This commit is contained in:
William Mantly 2016-05-28 01:54:17 -04:00
parent 2ba7fa58e2
commit 586c8cc32f

View File

@ -7,7 +7,7 @@ var request = require('request');
var lxc = require('../lxc'); var lxc = require('../lxc');
var doapi = require('../doapi')(); var doapi = require('../doapi')();
var workerShapID = '17575764' var workerSnapID = 'V1'
// console.log = function(){}; // console.log = function(){};
@ -41,12 +41,12 @@ var checkDroplet = function(id, time){
var workerCreate = function(){ var workerCreate = function(){
doapi.dropletCreate({ doapi.dropletCreate({
name: 'clw'+workerShapID+'-'+(Math.random()*100).toString().replace('.',''), name: 'clw'+workerSnapID+'-'+(Math.random()*100).toString().replace('.',''),
image: '17575764' image: '17575764'
}, function(data){ }, function(data){
data = JSON.parse(data); data = JSON.parse(data);
dopletNewID = data.droplet.id; dopletNewID = data.droplet.id;
doapi.dropletSetTag('clw'+'17575764', data.droplet.id, function(data){ doapi.dropletSetTag('clw'+workerSnapID, data.droplet.id, function(data){
setTimeout(function(){checkDroplet(dopletNewID)}, 60000); setTimeout(function(){checkDroplet(dopletNewID)}, 60000);
}); });
}); });
@ -90,7 +90,7 @@ var checkWorkersBalance = function(count){
}, 3000); }, 3000);
}; };
var start // var start
var ramPercentUsed = function(ip, callback){ var ramPercentUsed = function(ip, callback){
@ -169,12 +169,13 @@ var makeWorkerObj = function(worker){
}; };
var initWorkers = function(){ var initWorkers = function(){
doapi.dropletsByTag('clw'+workerShapID, function(data){ doapi.dropletsByTag('clw'+workerSnapID, function(data){
data = JSON.parse(data); data = JSON.parse(data);
if(data.droplets.length === 0) return checkWorkersBalance();
data['droplets'].forEach(function(worker){ data['droplets'].forEach(function(worker){
doapi.dropletDestroy(worker.id, function(){}); doapi.dropletDestroy(worker.id, function(){});
}); });
checkWorkersBalance();
}); });
}; };