From 0048be4008078e180f438f813ffda8b885c84f7a Mon Sep 17 00:00:00 2001 From: Zach Wolfenbarger Date: Fri, 15 Dec 2023 11:10:04 -0600 Subject: [PATCH 1/2] Pause DB updates on bounces --- server.js | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/server.js b/server.js index 74b63dc..235474e 100644 --- a/server.js +++ b/server.js @@ -52,9 +52,12 @@ var sns_client = SNSClient(auth, function (err, message) { if (!!email) { // https://docs.aws.amazon.com/ses/latest/dg/notification-contents.html#bounce-types if (report.notificationType === 'Complaint' || report.bounce.bounceType == 'Permanent') { - pg_pool.connect(function (err, client, done) { - updatePanoptes(err, client, done, email, report); - }); + console.log("Unsubscribed " + email + "(" + report.notificationType + "); changed 0 rows"); + + // Temporarily pause db updates + // pg_pool.connect(function (err, client, done) { + // updatePanoptes(err, client, done, email, report); + // }); } else { console.log("Ignoring non-permanent bounce for", email); } @@ -67,7 +70,7 @@ var app = express(); app.get('/', function (req, res) { res.status(200).end(); }); - + app.post('/unsub', sns_client); From 1942bb1b306cee1cb11a9646e4d4fa03ce112608 Mon Sep 17 00:00:00 2001 From: Zach Wolfenbarger Date: Fri, 15 Dec 2023 11:10:18 -0600 Subject: [PATCH 2/2] Pause DB updates on bounces --- server.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server.js b/server.js index 235474e..77f5332 100644 --- a/server.js +++ b/server.js @@ -54,7 +54,7 @@ var sns_client = SNSClient(auth, function (err, message) { if (report.notificationType === 'Complaint' || report.bounce.bounceType == 'Permanent') { console.log("Unsubscribed " + email + "(" + report.notificationType + "); changed 0 rows"); - // Temporarily pause db updates + // Temporarily pause db updates // pg_pool.connect(function (err, client, done) { // updatePanoptes(err, client, done, email, report); // });