no markAsBlocked,

basic_setup/ses_sns_shim_global.py

@@ -53,7 +53,6 @@ def get_queue_url(domain):
             raise
 
 def publish_to_sns(topic_arn, message_body, msg_id):
-    """Versucht SNS Publish. Gibt True bei Erfolg, False bei Topic-Not-Found."""
     attempt = 0
     while attempt < MAX_RETRIES:
         try:
@@ -65,8 +64,9 @@ def publish_to_sns(topic_arn, message_body, msg_id):
             return True
         except ClientError as e:
             error_code = e.response['Error']['Code']
-            if error_code == 'NotFound' or error_code == 'NotFoundException':
-                logger.info(f"ℹ️ SNS Topic not found for {topic_arn} — falling back to SQS")
+            # Fallback auf SQS bei Topic-nicht-gefunden ODER fehlender Berechtigung
+            if error_code in ('NotFound', 'NotFoundException', 'AuthorizationError'):
+                logger.info(f"ℹ️ SNS unavailable for {topic_arn} ({error_code}) — falling back to SQS")
                 return False
             attempt += 1
             logger.warning(f"Retry {attempt}/{MAX_RETRIES} SNS: {error_code}")

email-worker-nodejs/src/worker/message-processor.ts

@@ -26,7 +26,7 @@ import { BlocklistChecker } from '../email/blocklist.js';
 import { BounceHandler } from '../email/bounce-handler.js';
 import { parseEmail, isProcessedByWorker } from '../email/parser.js';
 import { RulesProcessor } from '../email/rules-processor.js';
-
+import { config } from '../config.js';
 // ---------------------------------------------------------------------------
 // Processor
 // ---------------------------------------------------------------------------
@@ -258,7 +258,8 @@ export class MessageProcessor {
 
       if (totalHandled === recipients.length) {
         if (blockedRecipients.length === recipients.length) {
-          // All blocked
+          // All blocked — im Standby kein S3 anfassen
+          if (!config.standbyMode) {
             try {
               await this.s3.markAsBlocked(
                 domain,
@@ -272,14 +273,18 @@ export class MessageProcessor {
               log(`⚠ Failed to handle blocked email: ${err.message ?? err}`, 'ERROR', workerName);
               return false;
             }
+          }
         } else if (successful.length > 0) {
+          if (!config.standbyMode) {
             await this.s3.markAsProcessed(
               domain,
               messageId,
               workerName,
               failedPermanent.length > 0 ? failedPermanent : undefined,
             );
+          }
         } else if (failedPermanent.length > 0) {
+          if (!config.standbyMode) {
             await this.s3.markAsAllInvalid(
               domain,
               messageId,
@@ -287,6 +292,7 @@ export class MessageProcessor {
               workerName,
             );
           }
+        }
 
         // Summary
         const parts: string[] = [];