Handle error when retrieving messages while archiving

randomnetcat · Mar 22, 2024 · 4b34bef · 4b34bef
1 parent c9a4295
commit 4b34bef
Showing 1 changed file with 16 additions and 1 deletion.
diff --git a/src/main/kotlin/org/randomcat/agorabot/util/DefaultArchiver.kt b/src/main/kotlin/org/randomcat/agorabot/util/DefaultArchiver.kt
@@ -624,7 +624,22 @@ private suspend fun archiveChannel(
                                                     capacity = 100,
                                                     send = { messageChannel ->
                                                         withContext(Dispatchers.IO) {
-                                                            channel.sendForwardHistoryTo(messageChannel)
+                                                            try {
+                                                                channel.sendForwardHistoryTo(messageChannel)
+                                                            } catch (e: Exception) {
+                                                                val errorPath = basePath.resolve("ERROR_messages.txt")
+                                                                errorPath.writeText(
+                                                                    e.stackTraceToString(),
+                                                                    options = arrayOf(StandardOpenOption.CREATE_NEW)
+                                                                )
+
+                                                                // Resolve ambiguity on getId
+                                                                val channelSnowflake: ISnowflake = channel
+                                                                logger.error(
+                                                                    "Failed to get messages when archiving channel ${channelSnowflake.id}",
+                                                                    e
+                                                                )
+                                                            }
                                                         }
                                                     },
                                                     receive = { messageChannel ->