(message *object.Message)
| 69 | } |
| 70 | |
| 71 | func clearMessageChatGenerating(message *object.Message) error { |
| 72 | chatId := util.GetId(message.Owner, message.Chat) |
| 73 | chat, err := object.GetChat(chatId) |
| 74 | if err != nil { |
| 75 | return err |
| 76 | } |
| 77 | if chat == nil { |
| 78 | return fmt.Errorf("chat %s not found", chatId) |
| 79 | } |
| 80 | |
| 81 | chat.IsGenerating = false |
| 82 | _, err = object.UpdateChat(chatId, chat) |
| 83 | return err |
| 84 | } |
| 85 | |
| 86 | func writeInfoStream(responseWriter http.ResponseWriter, infoText string) error { |
| 87 | event := fmt.Sprintf("event: myinfo\ndata: %s\n\n", infoText) |
no test coverage detected