Comparing version 6.0.0 to 7.0.0
@@ -22,3 +22,3 @@ /*jslint node: true */ | ||
topic: val.topic, | ||
clientMap: new Map().set(val.clientId, val.qos), | ||
clientMap: new Map().set(val.clientId, { qos: val.qos, rh: val.rh, rap: val.rap, nl: val.nl }), | ||
}; | ||
@@ -30,5 +30,5 @@ | ||
{ | ||
for (let [clientId, qos] of r.clientMap) | ||
for (let [clientId, sub] of r.clientMap) | ||
{ | ||
yield { topic: r.topic, clientId, qos }; | ||
yield { topic: r.topic, clientId, ...sub }; | ||
} | ||
@@ -38,5 +38,5 @@ } | ||
{ | ||
for (let [clientId, qos] of r.clientMap) | ||
for (let [clientId, sub] of r.clientMap) | ||
{ | ||
yield { clientId, qos }; | ||
yield { clientId, ...sub }; | ||
} | ||
@@ -54,3 +54,3 @@ } | ||
clientMap.set(val.clientId, val.qos); | ||
clientMap.set(val.clientId, { qos: val.qos, rh: val.rh, rap: val.rap, nl: val.nl }); | ||
@@ -65,13 +65,7 @@ if (clientMap.size > size) | ||
{ | ||
var clientIdAndQos; | ||
if (topic === undefined) | ||
{ | ||
for (clientIdAndQos of existing.clientMap) | ||
for (let [clientId, sub] of existing.clientMap) | ||
{ | ||
dest.push( | ||
{ | ||
clientId: clientIdAndQos[0], | ||
topic: existing.topic, | ||
qos: clientIdAndQos[1] | ||
}); | ||
dest.push({ clientId, topic: existing.topic, ...sub }); | ||
} | ||
@@ -81,9 +75,5 @@ } | ||
{ | ||
for (clientIdAndQos of existing.clientMap) | ||
for (let [clientId, sub] of existing.clientMap) | ||
{ | ||
dest.push( | ||
{ | ||
clientId: clientIdAndQos[0], | ||
qos: clientIdAndQos[1] | ||
}); | ||
dest.push({ clientId,...sub }); | ||
} | ||
@@ -90,0 +80,0 @@ } |
{ | ||
"name": "qlobber", | ||
"description": "Node.js globbing for amqp-like topics", | ||
"version": "6.0.0", | ||
"version": "7.0.0", | ||
"homepage": "https://github.com/davedoesdev/qlobber", | ||
@@ -35,16 +35,16 @@ "author": { | ||
"engines": { | ||
"node": ">= 12" | ||
"node": ">= 14" | ||
}, | ||
"devDependencies": { | ||
"b": "git://github.com/davedoesdev/b.git", | ||
"c8": "^7.10.0", | ||
"chai": "^4.3.4", | ||
"grunt": "^1.4.1", | ||
"grunt-apidox": "^2.0.14", | ||
"grunt-contrib-jshint": "^3.1.1", | ||
"b": "davedoesdev/b", | ||
"c8": "^7.11.2", | ||
"chai": "^4.3.6", | ||
"grunt": "^1.5.2", | ||
"grunt-apidox": "^2.0.16", | ||
"grunt-contrib-jshint": "^3.2.0", | ||
"grunt-exec": "^3.0.0", | ||
"JSONStream": "^1.3.5", | ||
"mocha": "^9.1.3", | ||
"mocha": "^10.0.0", | ||
"stream-buffers": "^3.0.2" | ||
} | ||
} |
Sorry, the diff of this file is not supported yet
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
61131
1181