Fix #133: process Telegram errors properly

Emulsion.Tests/Telegram/FunogramTests.fs

@@ -3,11 +3,11 @@ module Emulsion.Tests.Telegram.Client
 open System
 
 open Funogram.Telegram.Types
+open Funogram.Types
 open Xunit
 
 open Emulsion
 open Emulsion.Telegram
-open Emulsion.Telegram.Funogram
 
 [<Literal>]
 let private selfUserId = 100500L
@@ -140,7 +140,7 @@ let private replyingUser = createUser (Some "replyingUser") "" None
 let private forwardingUser = createUser (Some "forwardingUser") "" None
 
 module ReadMessageTests =
-    let readMessage = MessageConverter.read selfUserId
+    let readMessage = Funogram.MessageConverter.read selfUserId
 
     [<Fact>]
     let readMessageWithUnknownUser() =
@@ -317,7 +317,7 @@ module ReadMessageTests =
 
     [<Fact>]
     let multilineForwardShouldBeUnlimited(): unit =
-        let messageLinesLimit = MessageConverter.DefaultMessageLinesLimit
+        let messageLinesLimit = Funogram.MessageConverter.DefaultMessageLinesLimit
         let multilineMessage = String.init messageLinesLimit (fun _ -> "test\n") + "test"
         let forwardedMessage = createMessage (Some originalUser) (Some multilineMessage)
         let message = createForwardedMessage forwardingUser forwardedMessage
@@ -331,7 +331,7 @@ module ReadMessageTests =
 
     [<Fact>]
     let longForwardShouldBeUnlimited(): unit =
-        let messageLengthLimit = MessageConverter.DefaultMessageLengthLimit
+        let messageLengthLimit = Funogram.MessageConverter.DefaultMessageLengthLimit
         let longString = String.init (messageLengthLimit + 1) (fun _ -> "A")
         let forwardedMessage = createMessage (Some originalUser) (Some longString)
         let message = createForwardedMessage forwardingUser forwardedMessage
@@ -543,6 +543,16 @@ module ProcessMessageTests =
                           Chat = defaultChat }
         Assert.Equal(None, processMessage message)
 
+module ProcessSendResultTests =
+    [<Fact>]
+    let processResultShouldDoNothingOnOk(): unit =
+        Assert.Equal((), Funogram.processSendResult(Ok()))
+
+    [<Fact>]
+    let processResultShouldThrowOnError(): unit =
+        let result = Error({ ErrorCode = 502; Description = "Error" })
+        Assert.ThrowsAny<Exception>(fun () -> Funogram.processSendResult result) |> ignore
+
 module FlattenMessageTests =
     let private flattenMessage = Funogram.MessageConverter.flatten Funogram.MessageConverter.DefaultQuoteSettings
     let private flattenMessageLineLimit limit =

Emulsion/Telegram/Client.fs

@@ -16,4 +16,4 @@ type Client(ctx: ServiceContext, cancellationToken: CancellationToken, settings:
     }
 
     override _.Send message =
-        Funogram.send ctx.Logger settings botConfig message
+        Funogram.send settings botConfig message

Emulsion/Telegram/Funogram.fs

@@ -297,15 +297,11 @@ module MessageConverter =
                 else extractMessageContent replyTo
             { main = mainMessage; replyTo = Some replyToMessage }
 
-let private processResultWithValue (logger: ILogger) (result: Result<'a, ApiResponseError>) =
+let internal processSendResult(result: Result<'a, ApiResponseError>): unit =
     match result with
-    | Ok v -> Some v
+    | Ok _ -> ()
     | Error e ->
-        logger.Error("Telegram API call processing error: {Error}", e)
-        None
-
-let private processResult logger (result: Result<'a, ApiResponseError>) =
-    processResultWithValue logger result |> ignore
+        failwith $"Telegram API Call processing error {e.ErrorCode}: {e.Description}"
 
 let internal processMessage (context: {| SelfUserId: int64; GroupId: int64 |})
                             (message: FunogramMessage): TelegramMessage option =
@@ -334,15 +330,15 @@ let internal prepareHtmlMessage: Message -> string = function
 | Authored {author = author; text = text} -> sprintf "<b>%s</b>\n%s" (Html.escape author) (Html.escape text)
 | Event {text = text} -> sprintf "%s" (Html.escape text)
 
-let send (logger: ILogger) (settings: TelegramSettings) (botConfig: BotConfig) (OutgoingMessage content): Async<unit> =
+let send (settings: TelegramSettings) (botConfig: BotConfig) (OutgoingMessage content): Async<unit> =
     let sendHtmlMessage groupId text =
         Api.sendMessageBase groupId text (Some ParseMode.HTML) None None None None
 
     let groupId = Int(int64 settings.GroupId)
     let message = prepareHtmlMessage content
     async {
         let! result = api botConfig (sendHtmlMessage groupId message)
-        return processResult logger result
+        return processSendResult result
     }
 
 let run (logger: ILogger)