mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2026-01-15 10:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Fix prev event lookup in syncapi

Browse source
This commit is contained in:
Devon Hudson 2023-07-06 09:36:34 -06:00
parent d507c5fc95
commit 0dd7ba22f0
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
syncapi/consumers/roomserver.go
View file

@ -558,29 +558,30 @@ func (s *OutputRoomEventConsumer) updateStateEvent(event *rstypes.HeaderedEvent)
var succeeded bool var succeeded bool
defer sqlutil.EndTransactionWithCheck(snapshot, &succeeded, &err) defer sqlutil.EndTransactionWithCheck(snapshot, &succeeded, &err)
prevEvent, err := snapshot.GetStateEvent(
s.ctx, event.RoomID(), event.Type(), stateKey,
)
if err != nil {
return event, err
}
validRoomID, err := spec.NewRoomID(event.RoomID()) validRoomID, err := spec.NewRoomID(event.RoomID())
if err != nil { if err != nil {
return event, err return event, err
} }
sKeyUser := ""
if event.StateKey() != nil { if event.StateKey() != nil {
if *event.StateKey() != "" { if *event.StateKey() != "" {
var sku *spec.UserID var sku *spec.UserID
sku, err = s.rsAPI.QueryUserIDForSender(s.ctx, *validRoomID, spec.SenderID(stateKey)) sku, err = s.rsAPI.QueryUserIDForSender(s.ctx, *validRoomID, spec.SenderID(stateKey))
if err == nil && sku != nil { if err == nil && sku != nil {
sKey := sku.String() sKeyUser = sku.String()
event.StateKeyResolved = &sKey event.StateKeyResolved = &sKeyUser
} }
} }
} }
prevEvent, err := snapshot.GetStateEvent(
s.ctx, event.RoomID(), event.Type(), sKeyUser,
)
if err != nil {
return event, err
}
userID, err := s.rsAPI.QueryUserIDForSender(s.ctx, *validRoomID, event.SenderID()) userID, err := s.rsAPI.QueryUserIDForSender(s.ctx, *validRoomID, event.SenderID())
if err != nil { if err != nil {
return event, err return event, err