deblan-mirror/mautrix-go
1
0
Fork 0
mirror of https://mau.dev/mautrix/go.git synced 2026-03-14 14:25:53 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Send bridge step message tracking checkpoint on websocket bridges

Browse source
This commit is contained in:
Tulir Asokan 2021-11-25 23:14:31 +02:00
commit 46ef2b4793
1 changed files with 3 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

18
appservice/http.go
View file

@ -198,7 +198,9 @@ func (as *AppService) handleEvents(evts []*event.Event, defaultTypeClass event.T
as.Log.Debugfln("Failed to parse content of %s (type %s): %v", evt.ID, evt.Type.Type, err)
}
go as.sendMessageSendCheckpoint(evt)
if _, ok := CheckpointTypes[evt.Type]; ok {
go as.SendMessageSendCheckpoint(evt, StepBridge)
}
if evt.Type.IsState() {
// TODO remove this check after https://github.com/matrix-org/synapse/pull/11265
@ -211,20 +213,6 @@ func (as *AppService) handleEvents(evts []*event.Event, defaultTypeClass event.T
}
}
func (as *AppService) sendMessageSendCheckpoint(evt *event.Event) {
endpoint := as.MessageSendCheckpointEndpoint
if endpoint == "" {
return
}
if _, ok := CheckpointTypes[evt.Type]; !ok {
return
}
as.Log.Debugfln("Sending message send checkpoint for %s to API server", evt.ID)
as.SendMessageSendCheckpoint(evt, StepBridge)
}
// GetRoom handles a /rooms GET call from the homeserver.
func (as *AppService) GetRoom(w http.ResponseWriter, r *http.Request) {
if !as.CheckServerToken(w, r) {