Socket
Socket
Sign inDemoInstall

sqs-producer

Package Overview
Dependencies
Maintainers
2
Versions
41
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

sqs-producer - npm Package Compare versions

Comparing version 3.0.0-alpha.2 to 3.0.0-alpha.3

3

dist/producer.js

@@ -44,2 +44,3 @@ "use strict";

async sendBatch(failedMessages, successfulMessages, messages, startIndex) {
var _a;
const endIndex = startIndex + this.batchSize;

@@ -53,3 +54,3 @@ const batch = messages.slice(startIndex, endIndex);

const result = await this.sqs.send(command);
const failedMessagesBatch = failedMessages.concat((result === null || result === void 0 ? void 0 : result.Failed.map((entry) => entry.Id)) || []);
const failedMessagesBatch = failedMessages.concat(((_a = result === null || result === void 0 ? void 0 : result.Failed) === null || _a === void 0 ? void 0 : _a.map((entry) => entry.Id)) || []);
const successfulMessagesBatch = successfulMessages.concat((result === null || result === void 0 ? void 0 : result.Successful) || []);

@@ -56,0 +57,0 @@ if (endIndex < messages.length) {

{
"name": "sqs-producer",
"version": "3.0.0-alpha.2",
"version": "3.0.0-alpha.3",
"description": "Enqueues messages onto a given SQS queue",

@@ -5,0 +5,0 @@ "main": "dist/index.js",

@@ -94,3 +94,3 @@ import {

const failedMessagesBatch = failedMessages.concat(
result?.Failed.map((entry) => entry.Id) || []
result?.Failed?.map((entry) => entry.Id) || []
);

@@ -97,0 +97,0 @@ const successfulMessagesBatch = successfulMessages.concat(

SocketSocket SOC 2 Logo

Product

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

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc