From 8ea20049da2cbd49d65f22e82fe2b2276fa45963 Mon Sep 17 00:00:00 2001 From: Matthias Fischmann Date: Mon, 7 Jul 2025 19:20:26 +0200 Subject: [PATCH] TODOs --- .../src/Wire/BackendDeadUserNotificationWatcher.hs | 1 + services/background-worker/src/Wire/BackendNotificationPusher.hs | 1 + 2 files changed, 2 insertions(+) diff --git a/services/background-worker/src/Wire/BackendDeadUserNotificationWatcher.hs b/services/background-worker/src/Wire/BackendDeadUserNotificationWatcher.hs index 68b22f55c1..eb4ddf128a 100644 --- a/services/background-worker/src/Wire/BackendDeadUserNotificationWatcher.hs +++ b/services/background-worker/src/Wire/BackendDeadUserNotificationWatcher.hs @@ -30,6 +30,7 @@ getLastDeathQueue Nothing = Nothing -- FUTUREWORK: what happens if messages expire _after_ we checked against cassandra here? -- Should we have an async notification terminate this? +-- TODO: document this function *much* better. explain the general idea. startConsumer :: Q.Channel -> AppT IO Q.ConsumerTag startConsumer chan = do env <- ask diff --git a/services/background-worker/src/Wire/BackendNotificationPusher.hs b/services/background-worker/src/Wire/BackendNotificationPusher.hs index 40a228df15..cbefc9e925 100644 --- a/services/background-worker/src/Wire/BackendNotificationPusher.hs +++ b/services/background-worker/src/Wire/BackendNotificationPusher.hs @@ -320,6 +320,7 @@ getRemoteDomains adminClient = do type WorkerResult = (IORef (Maybe Q.Channel), IORef (Map Domain (Q.ConsumerTag, MVar ()))) -- FUTUREWORK: rework this in the vein of DeadLetterWatcher +-- TODO: document this function *much* better. explain the general idea. startWorker :: AmqpEndpoint -> AppT IO WorkerResult startWorker rabbitmqOpts = do env <- ask