whoopsi, required files

pull/2418/head
John McLear 2014-12-29 21:13:49 +01:00
parent 3773b6346b
commit 1081156f13
2 changed files with 83 additions and 0 deletions

View File

@ -0,0 +1,44 @@
/**
* Copyright 2014 John McLear.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS-IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
var async = require("async");
var db = require("../db/DB").db;
var ERR = require("async-stacktrace");
exports.getPadRaw = function(padId, callback){
async.waterfall([
function(cb){
db.findKeys("pad:"+padId+"*", null, function(err,records){
if(!err){
cb(err, records);
}
})
},
function(records, cb){
var data = {};
async.forEachSeries(Object.keys(records), function(key, r){
db.get(records[key], function(err, entry){
data[records[key]] = entry;
r(null); // callback;
});
}, function(err){
cb(err, data);
})
}], function(err, data){
callback(null, data);
});
}

View File

@ -0,0 +1,39 @@
/**
* Copyright Yaco Sistemas S.L. 2011.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS-IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
var log4js = require('log4js');
var async = require("async");
var db = require("../db/DB").db;
exports.setPadRaw = function(padId, records, callback){
records = JSON.parse(records);
async.eachSeries(Object.keys(records), function(key, cb){
var value = records[key]
// rewrite padId
var oldPadId = key.split(":");
oldPadId[1] = padId;
var newKey = oldPadId.join(":"); // create the new key
// Write the value to the server
db.set(newKey, value);
cb();
}, function(){
callback(null, true);
});
}