added message details

Author: tpae

Sources/osaurus_telegram/Models.swift

@@ -116,6 +116,10 @@ struct TaskFailedEvent: Decodable {
   let summary: String?
 }
 
+struct TaskOutputEvent: Decodable {
+  let text: String?
+}
+
 // MARK: - Dispatch Response
 
 struct DispatchResponse: Decodable {

Sources/osaurus_telegram/TaskHandler.swift

@@ -10,6 +10,7 @@ private enum TaskEventType {
   static let completed: Int32 = 4
   static let failed: Int32 = 5
   static let cancelled: Int32 = 6
+  static let output: Int32 = 7
 }
 
 /// Derives a stable non-zero draft ID from a task ID string.
@@ -23,7 +24,7 @@ func draftId(for taskId: String) -> Int {
 
 private let taskEventNames: [Int32: String] = [
   0: "STARTED", 1: "ACTIVITY", 2: "PROGRESS", 3: "CLARIFICATION",
-  4: "COMPLETED", 5: "FAILED", 6: "CANCELLED",
+  4: "COMPLETED", 5: "FAILED", 6: "CANCELLED", 7: "OUTPUT",
 ]
 
 func handleTaskEvent(ctx: PluginContext, taskId: String, eventType: Int32, eventJSON: String) {
@@ -71,6 +72,10 @@ func handleTaskEvent(ctx: PluginContext, taskId: String, eventType: Int32, event
   case TaskEventType.cancelled:
     handleCancelled(token: token, chatId: chatId, task: task, isPrivate: isPrivate)
 
+  case TaskEventType.output:
+    handleOutput(
+      token: token, chatId: chatId, task: task, isPrivate: isPrivate, eventJSON: eventJSON)
+
   default:
     logWarn("Unknown task event type \(eventType) for task \(taskId)")
   }
@@ -276,3 +281,26 @@ private func handleCancelled(token: String, chatId: String, task: TaskRow, isPri
   DatabaseManager.updateTask(taskId: task.taskId, status: "cancelled")
   logInfo("Task \(task.taskId) cancelled for chat \(chatId)")
 }
+
+private func handleOutput(
+  token: String, chatId: String, task: TaskRow, isPrivate: Bool, eventJSON: String
+) {
+  guard let event = parseJSON(eventJSON, as: TaskOutputEvent.self),
+    let text = event.text, !text.isEmpty
+  else {
+    logDebug("handleOutput: task \(task.taskId) failed to parse output event or empty text")
+    return
+  }
+
+  logDebug("handleOutput: task \(task.taskId) text=\(text.count) chars")
+
+  if isPrivate {
+    _ = telegramSendMessageDraft(
+      token: token, chatId: chatId,
+      draftId: draftId(for: task.taskId),
+      text: String(text.prefix(4096))
+    )
+  } else {
+    telegramSendChatAction(token: token, chatId: chatId)
+  }
+}

Tests/osaurus_telegram_tests/ModelsTests.swift

@@ -219,6 +219,19 @@ struct TaskEventPayloadTests {
     #expect(event.detail == "src/main.swift")
   }
 
+  @Test("Decodes TaskOutputEvent")
+  func outputEvent() throws {
+    let json = "{\"text\":\"Here are the results:\\n\\n1. First item\"}"
+    let event = try #require(parseJSON(json, as: TaskOutputEvent.self))
+    #expect(event.text == "Here are the results:\n\n1. First item")
+  }
+
+  @Test("Decodes TaskOutputEvent with null text")
+  func outputEventNullText() throws {
+    let event = try #require(parseJSON("{}", as: TaskOutputEvent.self))
+    #expect(event.text == nil)
+  }
+
   @Test("Handles missing optional fields gracefully")
   func missingOptionals() throws {
     let event = try #require(parseJSON("{}", as: TaskCompletedEvent.self))