coolaj86/masterquest-sqlite3.js
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

allow shared dbsMap, always set created_at and updated_at

Browse Source
This commit is contained in:
AJ ONeal 2016-03-03 20:22:16 -05:00
parent e726c24a83
commit 23c3faf439
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/dbwrap.js
View File

@ -1,14 +1,17 @@
'use strict'; 'use strict';
function wrap(db, dir) { function wrap(db, dir, dbsMap) {
// TODO if I put a failure right here, // TODO if I put a failure right here,
// why doesn't the unhandled promise rejection fire? // why doesn't the unhandled promise rejection fire?
var PromiseA = require('bluebird'); var PromiseA = require('bluebird');
var promises = []; var promises = [];
var earr = []; var earr = [];
var dbsMap = {};
var debug = false; var debug = false;
if (!dbsMap) {
dbsMap = {};
}
db.escape = function (str) { db.escape = function (str) {
return (str||'').toString().replace(/'/g, "''"); return (str||'').toString().replace(/'/g, "''");
}; };
@ -324,6 +327,9 @@ function wrap(db, dir) {
return PromiseA.reject(new Error("no id supplied")); return PromiseA.reject(new Error("no id supplied"));
} }
obj.created_at = Date.now();
obj.updated_at = Date.now();
return new PromiseA(function (resolve, reject) { return new PromiseA(function (resolve, reject) {
var json = JSON.stringify(obj); var json = JSON.stringify(obj);
var data = JSON.parse(json); var data = JSON.parse(json);
@ -449,6 +455,7 @@ function wrap(db, dir) {
//var vals = []; //var vals = [];
// removes known fields from data // removes known fields from data
data.updated_at = Date.now();
var sql = strainUpdate(id, data/*, vals*/, sqlTpl); var sql = strainUpdate(id, data/*, vals*/, sqlTpl);
//console.log('[debug] DB.set() sql:', sql); //console.log('[debug] DB.set() sql:', sql);
@ -544,6 +551,7 @@ function wrap(db, dir) {
} }
dir.forEach(function (dir) { dir.forEach(function (dir) {
// TODO if directive is the same as existing dbsMap, skip it
promises.push(createTable(dir).then(function (dbw) { promises.push(createTable(dir).then(function (dbw) {
dbsMap[dir.modelname] = dbw; dbsMap[dir.modelname] = dbw;