summary refs log tree commit diff
path: root/scripts-dev/federation_client.py
diff options
context:
space:
mode:
authorMathieu Velten <mathieuv@matrix.org>2023-09-07 12:37:16 +0200
committerGitHub <noreply@github.com>2023-09-07 12:37:16 +0200
commit42a392f4e25c528c231e4768554659d4fab7129e (patch)
tree5e8202e2f01ba15027bd69475b761f9fc5665856 /scripts-dev/federation_client.py
parentMerge branch 'develop' into mv/add-mxid-validation-log (diff)
parentAdd `/notifications` endpoint to workers (#16265) (diff)
downloadsynapse-42a392f4e25c528c231e4768554659d4fab7129e.tar.xz
Merge branch 'develop' into mv/add-mxid-validation-log
Diffstat (limited to 'scripts-dev/federation_client.py')
-rwxr-xr-xscripts-dev/federation_client.py14
1 files changed, 13 insertions, 1 deletions
diff --git a/scripts-dev/federation_client.py b/scripts-dev/federation_client.py

index 63f0b25ddd..e8baeac5e2 100755 --- a/scripts-dev/federation_client.py +++ b/scripts-dev/federation_client.py
@@ -247,7 +247,7 @@ def main() -> None: def read_args_from_config(args: argparse.Namespace) -> None: - with open(args.config, "r") as fh: + with open(args.config) as fh: config = yaml.safe_load(fh) if not args.server_name: @@ -329,6 +329,17 @@ class MatrixConnectionAdapter(HTTPAdapter): raise ValueError("Invalid host:port '%s'" % (server_name,)) return out[0], port, out[0] + # Look up SRV for Matrix 1.8 `matrix-fed` service first + try: + srv = srvlookup.lookup("matrix-fed", "tcp", server_name)[0] + print( + f"SRV lookup on _matrix-fed._tcp.{server_name} gave {srv}", + file=sys.stderr, + ) + return srv.host, srv.port, server_name + except Exception: + pass + # Fall back to deprecated `matrix` service try: srv = srvlookup.lookup("matrix", "tcp", server_name)[0] print( @@ -337,6 +348,7 @@ class MatrixConnectionAdapter(HTTPAdapter): ) return srv.host, srv.port, server_name except Exception: + # Fall even further back to just port 8448 return server_name, 8448, server_name @staticmethod