iartamonov/mautrix-telegram
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

backfill: set CanBackfill in the correct places

Browse Source 
Signed-off-by: Sumner Evans <sumner.evans@automattic.com>
This commit is contained in:
Sumner Evans
2024-10-07 09:16:24 -06:00
parent 57b32f6ac6
commit 6c44ba487a
2 changed files with 23 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/connector/sync.go
+2 -1
View File
@@ -106,7 +106,8 @@ func (t *TelegramClient) handleDialogs(ctx context.Context, dialogs tg.ModifiedM
}
}
chatInfo := bridgev2.ChatInfo{
UserLocal: &bridgev2.UserLocalPortalInfo{},
CanBackfill: true,
UserLocal: &bridgev2.UserLocalPortalInfo{},
Members: &bridgev2.ChatMemberList{
MemberMap: map[networkid.UserID]bridgev2.ChatMember{
t.userID: bridgev2.ChatMember{
pkg/connector/telegram.go
+21 -9
View File
@@ -218,6 +218,7 @@ func (t *TelegramClient) onUpdateNewMessage(ctx context.Context, channels map[in
TotalMemberCount: len(action.Users),
MemberMap: memberMap,
},
CanBackfill: true,
},
})
@@ -241,6 +242,7 @@ func (t *TelegramClient) onUpdateNewMessage(ctx context.Context, channels map[in
EventsDefault: &modLevel,
},
},
CanBackfill: true,
},
})
// case *tg.MessageActionChatMigrateTo:
@@ -739,9 +741,12 @@ func (t *TelegramClient) onNotifySettings(ctx context.Context, update *tg.Update
}
t.main.Bridge.QueueRemoteEvent(t.userLogin, &simplevent.ChatResync{
ChatInfo: &bridgev2.ChatInfo{UserLocal: &bridgev2.UserLocalPortalInfo{
MutedUntil: mutedUntil,
}},
ChatInfo: &bridgev2.ChatInfo{
UserLocal: &bridgev2.UserLocalPortalInfo{
MutedUntil: mutedUntil,
},
CanBackfill: true,
},
EventMeta: simplevent.EventMeta{
Type: bridgev2.RemoteEventChatResync,
PortalKey: t.makePortalKeyFromPeer(update.Peer.(*tg.NotifyPeer).Peer),
@@ -785,9 +790,12 @@ func (t *TelegramClient) onPinnedDialogs(ctx context.Context, msg *tg.UpdatePinn
t.userLogin.Metadata.(*UserLoginMetadata).PinnedDialogs = append(t.userLogin.Metadata.(*UserLoginMetadata).PinnedDialogs, portalKey.ID)
t.main.Bridge.QueueRemoteEvent(t.userLogin, &simplevent.ChatResync{
ChatInfo: &bridgev2.ChatInfo{UserLocal: &bridgev2.UserLocalPortalInfo{
Tag: ptr.Ptr(event.RoomTagFavourite),
}},
ChatInfo: &bridgev2.ChatInfo{
UserLocal: &bridgev2.UserLocalPortalInfo{
Tag: ptr.Ptr(event.RoomTagFavourite),
},
CanBackfill: true,
},
EventMeta: simplevent.EventMeta{
Type: bridgev2.RemoteEventChatResync,
PortalKey: portalKey,
@@ -798,9 +806,12 @@ func (t *TelegramClient) onPinnedDialogs(ctx context.Context, msg *tg.UpdatePinn
var empty event.RoomTag
for portalKey := range needsUnpinning {
t.main.Bridge.QueueRemoteEvent(t.userLogin, &simplevent.ChatResync{
ChatInfo: &bridgev2.ChatInfo{UserLocal: &bridgev2.UserLocalPortalInfo{
Tag: &empty,
}},
ChatInfo: &bridgev2.ChatInfo{
UserLocal: &bridgev2.UserLocalPortalInfo{
Tag: &empty,
},
CanBackfill: true,
},
EventMeta: simplevent.EventMeta{
Type: bridgev2.RemoteEventChatResync,
PortalKey: portalKey,
@@ -830,6 +841,7 @@ func (t *TelegramClient) onChatDefaultBannedRights(ctx context.Context, entities
Members: &bridgev2.ChatMemberList{
PowerLevels: t.getPowerLevelOverridesFromBannedRights(entities.Chats[0], update.DefaultBannedRights),
},
CanBackfill: true,
},
EventMeta: simplevent.EventMeta{
Type: bridgev2.RemoteEventChatResync,