aedes-persistence-nedb
Advanced tools
Comparing version 1.0.0 to 1.0.1
{ | ||
"name": "aedes-persistence-nedb", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "NeDB persistence for Aedes.", | ||
@@ -5,0 +5,0 @@ "main": "persistence.js", |
@@ -75,3 +75,4 @@ 'use strict'; | ||
if (packet.payload.length > 0) { | ||
self.retained.update({ topic: packet.topic }, packet, { upsert: true }, function (err, num, docs) { | ||
var pkt = transformPacket(packet); | ||
self.retained.update({ topic: packet.topic }, pkt, { upsert: true }, function (err, num, docs) { | ||
return callback(err); | ||
@@ -94,3 +95,4 @@ }); | ||
readable.curIndex++; | ||
readable.push(docs[0]); | ||
var packet = transformPacket(docs[0]); | ||
readable.push(packet); | ||
}); | ||
@@ -97,0 +99,0 @@ }; |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
41937
1131