diff options
author | David Robertson <davidr@element.io> | 2022-04-03 21:21:08 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-04-03 21:21:08 +0100 |
commit | 80839a44f1752669c8c4e0de440b1e49ba909aeb (patch) | |
tree | bf4a775c2dd23ad80bbda7d323e4299d9c535c0d /scripts-dev/tail-synapse.py | |
parent | Add type hints for `tests/unittest.py`. (#12347) (diff) | |
download | synapse-80839a44f1752669c8c4e0de440b1e49ba909aeb.tar.xz |
Remove more dead/broken dev scripts (#12355)
Diffstat (limited to '')
-rw-r--r-- | scripts-dev/tail-synapse.py | 67 |
1 files changed, 0 insertions, 67 deletions
diff --git a/scripts-dev/tail-synapse.py b/scripts-dev/tail-synapse.py deleted file mode 100644 index 44e3a6dbf1..0000000000 --- a/scripts-dev/tail-synapse.py +++ /dev/null @@ -1,67 +0,0 @@ -import collections -import json -import sys -import time - -import requests - -Entry = collections.namedtuple("Entry", "name position rows") - -ROW_TYPES = {} - - -def row_type_for_columns(name, column_names): - column_names = tuple(column_names) - row_type = ROW_TYPES.get((name, column_names)) - if row_type is None: - row_type = collections.namedtuple(name, column_names) - ROW_TYPES[(name, column_names)] = row_type - return row_type - - -def parse_response(content): - streams = json.loads(content) - result = {} - for name, value in streams.items(): - row_type = row_type_for_columns(name, value["field_names"]) - position = value["position"] - rows = [row_type(*row) for row in value["rows"]] - result[name] = Entry(name, position, rows) - return result - - -def replicate(server, streams): - return parse_response( - requests.get( - server + "/_synapse/replication", verify=False, params=streams - ).content - ) - - -def main(): - server = sys.argv[1] - - streams = None - while not streams: - try: - streams = { - row.name: row.position - for row in replicate(server, {"streams": "-1"})["streams"].rows - } - except requests.exceptions.ConnectionError: - time.sleep(0.1) - - while True: - try: - results = replicate(server, streams) - except Exception: - sys.stdout.write("connection_lost(" + repr(streams) + ")\n") - break - for update in results.values(): - for row in update.rows: - sys.stdout.write(repr(row) + "\n") - streams[update.name] = update.position - - -if __name__ == "__main__": - main() |