@vtfk/azure-servicebus-queue
Advanced tools
Comparing version 1.1.1 to 1.2.0
{ | ||
"name": "@vtfk/azure-servicebus-queue", | ||
"version": "1.1.1", | ||
"version": "1.2.0", | ||
"description": "High-level API for Azure Servicebus Queue operations", | ||
@@ -23,3 +23,3 @@ "main": "src/index.js", | ||
"dependencies": { | ||
"@azure/service-bus": "1.0.3", | ||
"@azure/service-bus": "1.1.0", | ||
"@vtfk/azure-storage-blob": "1.0.3", | ||
@@ -37,6 +37,6 @@ "uuid": "3.3.3" | ||
"devDependencies": { | ||
"ava": "2.3.0", | ||
"dotenv": "8.1.0", | ||
"standard": "14.1.0" | ||
"ava": "2.4.0", | ||
"dotenv": "8.2.0", | ||
"standard": "14.3.1" | ||
} | ||
} |
@@ -0,0 +0,0 @@ # (WIP) azure-servicebus-queue |
@@ -76,7 +76,14 @@ const { ServiceBusClient, ReceiveMode } = require('@azure/service-bus') | ||
function readBigMessage (fileId) { | ||
function readBigMessage (fileId, remove) { | ||
if (!storageClient) { | ||
throw Error('You need to initialize storage blob connection to receive messages >64 kb') | ||
} | ||
return storageClient.read(fileId) | ||
const data = storageClient.read(fileId) | ||
if (remove) { | ||
storageClient.remove(fileId) | ||
} | ||
return data | ||
} | ||
@@ -91,3 +98,3 @@ | ||
if (message[0].body && message[0].body.fileId) { | ||
const content = await readBigMessage(message[0].body.fileId) | ||
const content = await readBigMessage(message[0].body.fileId, true) | ||
messages.push(JSON.parse(content)) | ||
@@ -148,3 +155,3 @@ } else { | ||
storage: { | ||
readBigMessage: fileId => readBigMessage(fileId), | ||
readBigMessage: (fileId, remove) => readBigMessage(fileId, remove === true || false), | ||
sendBigMessage: message => sendBigMessage(message) | ||
@@ -151,0 +158,0 @@ } |
Sorry, the diff of this file is not supported yet
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
12538
138
1
+ Added@azure/amqp-common@1.0.0-preview.6(transitive)
+ Added@azure/service-bus@1.1.0(transitive)
+ Addeddebug@4.3.4(transitive)
+ Addedms@2.1.2(transitive)
- Removed@azure/amqp-common@1.0.0-preview.17(transitive)
- Removed@azure/service-bus@1.0.3(transitive)
Updated@azure/service-bus@1.1.0