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

Don't send federation queries to ourselves.

Browse source 
Signed-off-by: Alex Chen <minecnly@gmail.com>
This commit is contained in:
Cnly 2019-08-24 02:17:34 +08:00
parent a930c0d0b1
commit ee86685e0b
1 changed files with 16 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
clientapi/routing/directory.go
View file

@ -71,18 +71,24 @@ func DirectoryRoom(
if res.RoomID == "" {
// If we don't know it locally, do a federation query.
fedRes, fedErr := federation.LookupRoomAlias(req.Context(), domain, roomAlias)
if fedErr != nil {
switch fedErr.(type) {
case gomatrix.HTTPError:
// TODO: Return 502 if the remote server errored.
// TODO: Return 504 if the remote server timed out.
return httputil.LogThenError(req, fedErr)
default:
return httputil.LogThenError(req, fedErr)
// But don't send the query to ourselves.
if domain != cfg.Matrix.ServerName {
fedRes, fedErr := federation.LookupRoomAlias(req.Context(), domain, roomAlias)
if fedErr != nil {
switch fedErr.(type) {
case gomatrix.HTTPError:
// TODO: Return 502 if the remote server errored.
// TODO: Return 504 if the remote server timed out.
return httputil.LogThenError(req, fedErr)
default:
return httputil.LogThenError(req, fedErr)
}
}
res.RoomID = fedRes.RoomID
res.fillServers(fedRes.Servers)
}
if fedRes.RoomID == "" {
if res.RoomID == "" {
return util.JSONResponse{
Code: http.StatusNotFound,
JSON: jsonerror.NotFound(
@ -90,9 +96,6 @@ func DirectoryRoom(
),
}
}
res.RoomID = fedRes.RoomID
res.fillServers(fedRes.Servers)
} else {
joinedHostsReq := federationSenderAPI.QueryJoinedHostServerNamesInRoomRequest{RoomID: res.RoomID}
var joinedHostsRes federationSenderAPI.QueryJoinedHostServerNamesInRoomResponse