From 163a93189c219e439e142eee3e964e1fba7ddbc0 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 28 Sep 2017 20:37:58 +0200
Subject: reject messages that aren't valid ids

---
 worker.js | 9 +++++++++
 1 file changed, 9 insertions(+)

(limited to 'worker.js')

diff --git a/worker.js b/worker.js
index 411958f..be82f81 100644
--- a/worker.js
+++ b/worker.js
@@ -80,6 +80,15 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
     // set maximum allowed number of unacked msgs
     await ch.prefetch(BATCHSIZE);
     ch.consume(QUEUE, async (msg) => {
+        if (msg.content.length > 1024) {
+            // thx NodeJS for implementing `new Buffer(size)`
+            // Sometimes I fuck up during message sending
+            // and forget a `id.toString()`, creating huge blobs of zeros,
+            // which makes Sequelize panic because the packets are 2MB.
+            // May god forgive me for deploying debug code…
+            await ch.nack(m, false, false);
+        }
+
         participants.add(msg.content.toString());
         buffer.add(msg);
         if (timeout == undefined) timeout = setTimeout(tryCrunch, LOAD_TIMEOUT*1000);
-- 
cgit v1.3.1