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

Update relay server db from pinecone monolith SetRelayServers

Browse source
This commit is contained in:
Devon Hudson 2023-01-24 16:23:21 -07:00
parent 012bdf735e
commit c510106e35
No known key found for this signature in database
GPG key ID: CD06B18E77F6A628
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
build/gobind-pinecone/monolith.go
View file

@ -589,7 +589,15 @@ func (r *RelayServerRetriever) SetRelayServers(servers []gomatrixserverlib.Serve
defer r.queriedServersMutex.Unlock() defer r.queriedServersMutex.Unlock()
r.relayServersQueried = make(map[gomatrixserverlib.ServerName]bool) r.relayServersQueried = make(map[gomatrixserverlib.ServerName]bool)
for _, server := range servers { for _, server := range servers {
// TODO : add servers to dendrite database request := api.P2PAddRelayServersRequest{
Server: gomatrixserverlib.ServerName(r.ServerName),
RelayServers: servers,
}
response := api.P2PAddRelayServersResponse{}
err := r.FederationAPI.P2PAddRelayServers(r.Context, &request, &response)
if err != nil {
logrus.Warnf("Failed adding relay servers for this node: %s", err.Error())
}
r.relayServersQueried[server] = false r.relayServersQueried[server] = false
} }