[wtsqs#enqueueMany] Fix empty list error

ali-essam · Jul 20, 2019 · 601c7ad · 601c7ad
1 parent e3ccc93
commit 601c7ad
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 0 deletions.
diff --git a/lib/wtsqs.js b/lib/wtsqs.js
@@ -142,6 +142,7 @@ class WTSQS {
    */
   async enqueueMany (payloads, { messageGroupId } = {}, sqsOptions = {}) {
     if (!(payloads instanceof Array)) throw new InvalidArgument('payloads must be of type array')
+    if (payloads.length === 0) return
 
     if (payloads.length > 10) {
       const chunks = chunk(payloads, 10)

diff --git a/test/wtsqs.test.js b/test/wtsqs.test.js
@@ -52,6 +52,10 @@ describe('WTSQS', () => {
       }
     })
 
+    it('should accept empty list of messages', async () => {
+      await wtsqs.enqueueMany([])
+    })
+
     it('should increase queue size by enqueued count', async function () {
       await sleep(1000)
       const sizeBefore = await wtsqs.size()