fix nedb to sqlite migrate
Simon Smith committed
Sep 7, 2023 at 19:35 UTC
23c2627b3bee1f6b4a86113039042d6e802e7100
1 file changed
+9
-1
db.js
+9
-1
@@ -1470,7 +1470,14 @@ module.exports.CreateDB = function (parent, func) {
1470
obj.StoreEvent = function (event, func) {
1471
obj.dbCounters.eventsSet++;
1472
sqlDbQuery('INSERT INTO events VALUES (NULL, $1, $2, $3, $4, $5, $6) RETURNING id', [event.time, ((typeof event.domain == 'string') ? event.domain : null), event.action, event.nodeid ? event.nodeid : null, event.userid ? event.userid : null, JSON.stringify(event)], function (err, docs) {
1473
- if ((err == null) && (docs[0].id)) { for (var i in event.ids) { if (event.ids[i] != '*') { sqlDbQuery('INSERT INTO eventids VALUES ($1, $2)', [docs[0].id, event.ids[i]]); } } }
1473
+ if(func){ func(); }
1474
+ if ((err == null) && (docs[0].id)) {
1475
+ for (var i in event.ids) {
1476
+ if (event.ids[i] != '*') {
1477
+ sqlDbQuery('INSERT INTO eventids VALUES ($1, $2)', [docs[0].id, event.ids[i]], function(){ if(func){ func(); } });
1478
+ }
1479
+ }
1480
+ }
1481
});
1482
};
1483
obj.GetEvents = function (ids, domain, func) {
@@ -3239,6 +3246,7 @@ module.exports.CreateDB = function (parent, func) {
3246
for (var i in docs) {
3247
pendingTransfer++;
3248
eventRecordsTransferCount++;
3249
+ for (var b in docs[i].ids) { if (docs[i].ids[b] != '*') { pendingTransfer++; } }
3250
obj.StoreEvent(docs[i], function () { pendingTransfer--; });
3251
}
3252
}