fix(telegram): send progress updates as new messages (#19)

Author: alexk-dev

golemcore/telegram/plugin.yaml

@@ -1,7 +1,7 @@
 id: golemcore/telegram
 provider: golemcore
 name: telegram
-version: 1.2.1
+version: 1.2.2
 pluginApiVersion: 1
 engineVersion: ">=0.0.0 <1.0.0"
 entrypoint: me.golemcore.plugins.golemcore.telegram.TelegramPluginBootstrap

golemcore/telegram/pom.xml

@@ -9,7 +9,7 @@
         <relativePath>../../pom.xml</relativePath>
     </parent>
 
-    <version>1.2.1</version>
+    <version>1.2.2</version>
     <artifactId>golemcore-telegram-plugin</artifactId>
     <name>golemcore/telegram</name>
     <description>Telegram channel plugin for GolemCore</description>

golemcore/telegram/src/main/java/me/golemcore/plugins/golemcore/telegram/adapter/inbound/telegram/TelegramAdapter.java

@@ -53,7 +53,6 @@
 import org.telegram.telegrambots.meta.api.methods.send.SendMessage;
 import org.telegram.telegrambots.meta.api.methods.send.SendPhoto;
 import org.telegram.telegrambots.meta.api.methods.send.SendVoice;
-import org.telegram.telegrambots.meta.api.methods.updatingmessages.EditMessageText;
 import org.telegram.telegrambots.meta.api.objects.Document;
 import org.telegram.telegrambots.meta.exceptions.TelegramApiRequestException;
 import org.telegram.telegrambots.meta.api.objects.InputFile;
@@ -149,7 +148,6 @@ public class TelegramAdapter implements ChannelPort, LongPollingSingleThreadUpda
     private volatile String registeredBotToken;
     private final Object lifecycleLock = new Object();
     private final Map<String, InviteAttemptState> inviteAttemptStates = new ConcurrentHashMap<>();
-    private final Map<String, ProgressStatusMessage> progressMessages = new ConcurrentHashMap<>();
 
     /**
      * Package-private setter for testing — allows injecting a mock TelegramClient.
@@ -776,24 +774,11 @@ public CompletableFuture<Void> sendProgressUpdate(String chatId, ProgressUpdate
                 return;
             }
             if (update.type() == ProgressUpdateType.CLEAR) {
-                progressMessages.remove(chatId);
                 return;
             }
 
             String rendered = renderProgressUpdate(update);
-            ProgressStatusMessage current = progressMessages.get(chatId);
-            if (current != null && rendered.equals(current.text())) {
-                return;
-            }
-            if (current != null && tryEditProgressMessage(chatId, current.messageId(), rendered)) {
-                progressMessages.put(chatId, new ProgressStatusMessage(current.messageId(), rendered));
-                return;
-            }
-
-            Integer messageId = sendProgressMessage(chatId, rendered);
-            if (messageId != null) {
-                progressMessages.put(chatId, new ProgressStatusMessage(messageId, rendered));
-            }
+            sendProgressMessage(chatId, rendered);
         });
     }
 
@@ -860,24 +845,8 @@ private Integer sendProgressMessage(String chatId, String rendered) {
         }
     }
 
-    private boolean tryEditProgressMessage(String chatId, int messageId, String rendered) {
-        try {
-            EditMessageText edit = EditMessageText.builder()
-                    .chatId(chatId)
-                    .messageId(messageId)
-                    .text(TelegramHtmlFormatter.format(rendered))
-                    .parseMode("HTML")
-                    .build();
-            executeWithRetry(() -> telegramClient.execute(edit));
-            return true;
-        } catch (Exception e) {
-            log.debug("Failed to edit progress update in chat {}: {}", chatId, e.getMessage());
-            return false;
-        }
-    }
-
     private String renderProgressUpdate(ProgressUpdate update) {
-        String prefix = update.type() == ProgressUpdateType.INTENT ? "Working on this:\n" : "Progress update:\n";
+        String prefix = update.type() == ProgressUpdateType.INTENT ? "" : "Progress update:\n";
         return prefix + update.text();
     }
 
@@ -931,9 +900,6 @@ private String truncateCaption(String caption) {
         return caption.substring(0, TELEGRAM_MAX_CAPTION_LENGTH - 3) + "...";
     }
 
-    private record ProgressStatusMessage(int messageId, String text) {
-    }
-
     private static String truncateForLog(String text, int maxLen) {
         if (text == null || text.length() <= maxLen)
             return text;

golemcore/telegram/src/test/java/me/golemcore/plugins/golemcore/telegram/adapter/inbound/telegram/TelegramAdapterMessageTest.java

@@ -10,6 +10,7 @@
 import me.golemcore.plugin.api.runtime.security.AllowlistValidator;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.mockito.ArgumentCaptor;
 
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.test.util.ReflectionTestUtils;
@@ -19,7 +20,6 @@
 import org.telegram.telegrambots.meta.api.methods.send.SendMessage;
 import org.telegram.telegrambots.meta.api.methods.send.SendPhoto;
 import org.telegram.telegrambots.meta.api.methods.send.SendVoice;
-import org.telegram.telegrambots.meta.api.methods.updatingmessages.EditMessageText;
 import org.telegram.telegrambots.meta.exceptions.TelegramApiException;
 import org.telegram.telegrambots.meta.exceptions.TelegramApiRequestException;
 import org.telegram.telegrambots.meta.generics.TelegramClient;
@@ -109,31 +109,32 @@ void shouldSendNewProgressMessage() throws Exception {
         when(telegramClient.execute(any(SendMessage.class))).thenReturn(telegramMessage);
 
         adapter.sendProgressUpdate(CHAT_ID, new ProgressUpdate(
-                ProgressUpdateType.SUMMARY,
-                "Ran a few checks and grouped the result.",
+                ProgressUpdateType.INTENT,
+                "Working on: checking the current state before making changes.",
                 java.util.Map.of())).get();
 
-        verify(telegramClient).execute(any(SendMessage.class));
+        ArgumentCaptor<SendMessage> captor = ArgumentCaptor.forClass(SendMessage.class);
+        verify(telegramClient).execute(captor.capture());
+        assertEquals("Working on: checking the current state before making changes.", captor.getValue().getText());
     }
 
     @Test
-    void shouldEditExistingProgressMessage() throws Exception {
+    void shouldSendNewMessageForEachProgressUpdate() throws Exception {
         org.telegram.telegrambots.meta.api.objects.message.Message telegramMessage = mock(
                 org.telegram.telegrambots.meta.api.objects.message.Message.class);
         when(telegramMessage.getMessageId()).thenReturn(77);
         when(telegramClient.execute(any(SendMessage.class))).thenReturn(telegramMessage);
-        when(telegramClient.execute(any(EditMessageText.class))).thenReturn(mock(java.io.Serializable.class));
 
         adapter.sendProgressUpdate(CHAT_ID, new ProgressUpdate(
                 ProgressUpdateType.INTENT,
-                "Checking the current state before making changes.",
+                "Working on: checking the current state before making changes.",
                 java.util.Map.of())).get();
         adapter.sendProgressUpdate(CHAT_ID, new ProgressUpdate(
                 ProgressUpdateType.SUMMARY,
                 "Reviewed the repo and grouped the latest shell runs.",
                 java.util.Map.of())).get();
 
-        verify(telegramClient).execute(any(EditMessageText.class));
+        verify(telegramClient, atLeast(2)).execute(any(SendMessage.class));
     }
 
     // ===== sendPhoto =====

registry/golemcore/telegram/index.yaml

@@ -1,10 +1,11 @@
 id: golemcore/telegram
 owner: golemcore
 name: telegram
-latest: 1.2.1
+latest: 1.2.2
 versions:
   - 1.0.0
   - 1.1.0
   - 1.2.0
   - 1.2.1
+  - 1.2.2
 source: "https://github.com/alexk-dev/golemcore-plugins/tree/main/golemcore/telegram"

registry/golemcore/telegram/versions/1.2.2.yaml

@@ -0,0 +1,13 @@
+id: golemcore/telegram
+version: 1.2.2
+pluginApiVersion: 1
+engineVersion: ">=0.0.0 <1.0.0"
+artifactUrl: "dist/golemcore/telegram/1.2.2/golemcore-telegram-plugin-1.2.2.jar"
+checksumSha256: "bc4152aaa6963f7937d78ef18a0b02215c18d26e31421b7f42b8c438c6a8ddfc"
+publishedAt: "2026-03-18T17:25:22Z"
+sourceCommit: "8d91116cb9bbca97ea64e0f65a192e18954f0ee5"
+entrypoint: me.golemcore.plugins.golemcore.telegram.TelegramPluginBootstrap
+sourceUrl: "https://github.com/alexk-dev/golemcore-plugins/tree/main/golemcore/telegram"
+license: "Apache-2.0"
+maintainers:
+  - alexk-dev