Socket
Socket
Sign inDemoInstall

@vtfk/azure-servicebus-queue

Package Overview
Dependencies
115
Maintainers
4
Versions
7
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 1.1.1 to 1.2.0

10

package.json
{
"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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc