From 01b9e7677dad60d736b65d182e35487727933502 Mon Sep 17 00:00:00 2001
From: Jeremiah Russell <jerry@jrussell.ie>
Date: Sat, 11 Oct 2025 06:54:45 +0100
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20fix(processor):=20execute=20dele?=
 =?UTF-8?q?te=20messages?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- execute final delete messages only when execute flag is true
---
 src/processor.rs | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/processor.rs b/src/processor.rs
index e6e0c24..e6a15b7 100644
--- a/src/processor.rs
+++ b/src/processor.rs
@@ -44,7 +44,13 @@ impl<'a> Processor<'a> {
 
         log::info!("{messages_to_trash:?}");
         log::info!("Ready to run");
-        messages_to_trash.run(0).await
+        messages_to_trash.prepare(0).await?;
+        if self.execute {
+            log::warn!("***executing final delete messages***");
+            messages_to_trash.batch_trash().await
+        } else {
+            Ok(())
+        }
     }
 
     /// Delete the messages