From 88c9d9ebea994e6aeb17f7637f5bfa99584b755d Mon Sep 17 00:00:00 2001
From: "crashkeys.dev" <dawn@crashkeys.dev>
Date: Tue, 24 Mar 2026 21:45:57 +0100
Subject: [PATCH] debug: when `DEBUG=1` is set, the `StdoutSink` is enabled.

---
 src/lib.rs | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/src/lib.rs b/src/lib.rs
index 6108be6..9a02fe5 100644
--- a/src/lib.rs
+++ b/src/lib.rs
@@ -44,6 +44,11 @@ pub mod run {
 			// Debug quotes fall back to the default configuration
 			FsFilterSourceManager::default()
 		});
+		let stdout = if !is_debug {
+			None
+		} else {
+			Some(StdoutSink::spawn(StdoutSink))
+		};
 
 		let use_redis = std::env::var("USE_REDIS").unwrap_or("0".to_string()) == "1";
 		if use_redis {
@@ -58,10 +63,10 @@ pub mod run {
 
 			let queue =
 				RedisQueueStorage::spawn(RedisQueueStorage::new(con, DEFAULT_KEY.to_string()));
-			run_cycle(schedule, source, queue, bsky).await
+			run_cycle(schedule, source, queue, stdout, bsky).await
 		} else {
 			let queue = MemoryQueueStorage::spawn(MemoryQueueStorage::new());
-			run_cycle(schedule, source, queue, bsky).await
+			run_cycle(schedule, source, queue, stdout, bsky).await
 		}
 	}
 
@@ -69,12 +74,10 @@ pub mod run {
 		schedule: &str,
 		source: ActorRef<S>,
 		queue: ActorRef<Q>,
+		stdout: Option<ActorRef<StdoutSink>>,
 		bsky: Option<ActorRef<BskySink>>,
 	) -> Result<(), Box<dyn std::error::Error>> {
-		let sink = {
-			let stdout = StdoutSink::spawn(StdoutSink);
-			SinkManager::spawn(SinkManager::new(Some(stdout), bsky))
-		};
+		let sink = { SinkManager::spawn(SinkManager::new(stdout, bsky)) };
 
 		let cycle = { QuoteCycle::spawn(QuoteCycle::with_thread_rng(source, queue)) };
 
-- 
2.51.2