mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-30 10:13:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Send create room events as new

Browse source
This commit is contained in:
Neil Alexander 2022-01-21 13:44:27 +00:00
parent 3f960d3829
commit e02fa90608
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 11 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
clientapi/routing/createroom.go
View file

@ -452,20 +452,17 @@ func createRoom(
return jsonerror.InternalServerError() return jsonerror.InternalServerError()
} }
accumulated := gomatrixserverlib.UnwrapEventHeaders(builtEvents) inputs := make([]roomserverAPI.InputRoomEvent, 0, len(builtEvents))
if err = roomserverAPI.SendEventWithState( for _, event := range builtEvents {
req.Context(), inputs = append(inputs, roomserverAPI.InputRoomEvent{
rsAPI, Kind: roomserverAPI.KindNew,
roomserverAPI.KindNew, Event: event,
&gomatrixserverlib.RespState{ AuthEventIDs: event.AuthEventIDs(),
StateEvents: accumulated, SendAsServer: roomserverAPI.DoNotSendToOtherServers,
AuthEvents: accumulated, })
}, }
ev.Headered(roomVersion), if err = roomserverAPI.SendInputRoomEvents(req.Context(), rsAPI, inputs, false); err != nil {
nil, util.GetLogger(req.Context()).WithError(err).Error("roomserverAPI.SendInputRoomEvents failed")
false,
); err != nil {
util.GetLogger(req.Context()).WithError(err).Error("SendEventWithState failed")
return jsonerror.InternalServerError() return jsonerror.InternalServerError()
} }
} }