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

Do federation query if event not existing locally

Browse source 
Signed-off-by: Alex Chen <minecnly@gmail.com>
This commit is contained in:
Cnly 2019-06-28 23:40:09 +08:00
parent 750887efd8
commit f46d41b2ed
1 changed files with 26 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
clientapi/routing/getevent.go
View file

@ -15,6 +15,8 @@
package routing
import (
"net/http"
"github.com/matrix-org/dendrite/clientapi/auth/authtypes"
"github.com/matrix-org/dendrite/clientapi/httputil"
"github.com/matrix-org/dendrite/clientapi/jsonerror"
@ -22,7 +24,6 @@ import (
"github.com/matrix-org/dendrite/roomserver/api"
"github.com/matrix-org/gomatrixserverlib"
"github.com/matrix-org/util"
"net/http"
)
type getEventRequest struct {
@ -57,12 +58,31 @@ func GetEvent(
return httputil.LogThenError(req, err)
}
var requestedEvent gomatrixserverlib.Event
if len(eventsResp.Events) == 0 {
// TODO: Event not found locally. May need a federation query here.
return util.JSONResponse{
Code: http.StatusNotFound,
JSON: jsonerror.NotFound("The event was not found or you do not have permission to read this event."),
// Event not found locally. Do a federation query in hope of getting
// the event from another server.
// TODO: May need a better way to determine which server to query
_, domain, err := gomatrixserverlib.SplitID('$', eventID)
if err != nil {
return httputil.LogThenError(req, err)
}
txnResp, err := federation.GetEvent(req.Context(), domain, eventID)
if err != nil {
return httputil.LogThenError(req, err)
}
if len(txnResp.PDUs) == 0 {
return util.JSONResponse{
Code: http.StatusNotFound,
JSON: jsonerror.NotFound("The event was not found or you do not have permission to read this event."),
}
}
requestedEvent = txnResp.PDUs[0]
} else {
requestedEvent = eventsResp.Events[0]
}
r := getEventRequest{
@ -73,7 +93,7 @@ func GetEvent(
cfg: cfg,
federation: federation,
keyRing: keyRing,
requestedEvent: eventsResp.Events[0],
requestedEvent: requestedEvent,
}
stateNeeded := gomatrixserverlib.StateNeededForAuth([]gomatrixserverlib.Event{r.requestedEvent})