set always header X-SES-Worker-Processed

email-worker/worker.py

@@ -142,6 +142,11 @@ class MessageProcessor:
                         self.metrics.increment_bounce(domain, 'rewritten')
                 else:
                     from_addr_final = from_addr
+                
+                # ⭐ HIER NEU: Marker für alle Emails von extern setzen
+                if not skip_rules:  # Nur wenn nicht bereits processed
+                    parsed['X-SES-Worker-Processed'] = 'delivered'
+                    raw_bytes = parsed.as_bytes()
 
             except Exception as e:
                 log(f"⚠ Parsing/Logic Error: {e}. Sending original.", 'WARNING', worker_name)