Bug Report - Lack of Graceful Shutdown in Message Updates Handling about telegram.bot

[tuscen]

I wouldn't say that this is a bug, but a specific behaviour desired by some people. I could implement an additional option to do that, but it won't be 100% reliable and have it's own can of worms. E.g. how do you think we should handle cancellation in this case since the original token is cancelled?

I see three options how to commit the last offset:

1. Pass two cancellation tokens, one to cancel the core loop and another to cancel offset commit operation
2. Use a timeout for cancellation operation, but what if I want to cancel the operation manually and not wait for a timeout I don't have any API to control?
3. Add another method to the interfaces to all of the pollers that one can call to commit the latest offset using previously saved offset

To me the first two are horrible since they introduce not obvious lifetimes and cancellation mechanisms and only the third one seems the most sane. In the end, there is no easy solution that is ideal and satisfy everyone.

[Palindromer]

@tuscen, I suggest the following solution:

Firstly, we could introduce a check for the cancellation token within each iteration of the foreach-loop. And if a cancellation is requested, break out of the loop, ensuring that any remaining updates are not handled.

Secondly, upon cancellation, send a GetUpdatesRequest with the offset of the last successfully handled update. This ensures that the offset is appropriately committed even in the event of a graceful shutdown.

Suggested changes in code:

foreach (var update in updates)
{
    try
    {
        await updateHandler.HandleUpdateAsync(
            botClient: _botClient,
            update: update,
            cancellationToken: cancellationToken
        ).ConfigureAwait(false);
    }
    catch (OperationCanceledException)
    {
        // ignored
    }

    if (cancellationToken.IsCancellationRequested)
    {
        // Commit the last succeful offset.
        var request = new GetUpdatesRequest
        {
            Limit = 1,
            Offset = messageOffset,
        };
        await _botClient.MakeRequestAsync(request);

        // Don't handle the rest of updates.
        break;
    }
      
    messageOffset = update.Id + 1;
}

[tuscen]

@Palindromer That's what I wrote earlier - your suggested code does not handle cancellation at all

[Palindromer]

@tuscen Could you please explain more why do you think cancellation is not adequately handled by the suggested code?