diff --git a/pkg/connector/sync.go b/pkg/connector/sync.go index 3c643a73..5cdf2c8b 100644 --- a/pkg/connector/sync.go +++ b/pkg/connector/sync.go @@ -286,6 +286,21 @@ func (t *TelegramClient) handleDialogs(ctx context.Context, dialogs tg.ModifiedM if err = resultToError(res); err != nil { return err } + + // Generate a read receipt from the last known read message id + res = t.main.Bridge.QueueRemoteEvent(t.userLogin, &simplevent.Receipt{ + EventMeta: simplevent.EventMeta{ + Type: bridgev2.RemoteEventReadReceipt, + PortalKey: portalKey, + Sender: t.mySender(), + }, + LastTarget: ids.MakeMessageID(portalKey, dialog.ReadInboxMaxID), + ReadUpToStreamOrder: int64(dialog.ReadInboxMaxID), + }) + + if err = resultToError(res); err != nil { + return err + } } return nil }