From a85659df9dc19453d32307bbdc78afdb100c1dc6 Mon Sep 17 00:00:00 2001 From: Sumner Evans Date: Tue, 8 Oct 2024 12:59:22 -0600 Subject: [PATCH] backfill: fix request on forward backfill Signed-off-by: Sumner Evans --- pkg/connector/backfill.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/pkg/connector/backfill.go b/pkg/connector/backfill.go index c7d9192b..7fbd5c77 100644 --- a/pkg/connector/backfill.go +++ b/pkg/connector/backfill.go @@ -195,12 +195,17 @@ func (t *TelegramClient) FetchMessages(ctx context.Context, fetchParams bridgev2 Peer: peer, Limit: fetchParams.Count, } - if fetchParams.AnchorMessage != nil && !fetchParams.Forward { - _, req.MaxID, err = ids.ParseMessageID(fetchParams.AnchorMessage.ID) + if fetchParams.AnchorMessage != nil { + if fetchParams.Forward { + _, req.MinID, err = ids.ParseMessageID(fetchParams.AnchorMessage.ID) + } else { + _, req.MaxID, err = ids.ParseMessageID(fetchParams.AnchorMessage.ID) + } if err != nil { return nil, err } } + log.Info().Any("req", req).Msg("Fetching messages") msgs, err := APICallWithUpdates(ctx, t, func() (tg.ModifiedMessagesMessages, error) { var rawMsgs tg.MessagesMessagesClass if fetchParams.Forward { @@ -254,6 +259,7 @@ func (t *TelegramClient) FetchMessages(ctx context.Context, fetchParams bridgev2 // If we are doing forward backfill and we get to the anchor message, // don't convert any more messages. if stopAt > 0 && msg.GetID() <= stopAt { + log.Debug().Int("stop_at", stopAt).Int("message_id", msg.GetID()).Msg("stopping at anchor message") break }