From a96d02da5d796434f6a448902c8a39e41db0e199 Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Wed, 16 Jul 2025 19:55:04 +0100 Subject: [PATCH] Update config util to take files as well as command-line text (#437) --- trustgraph-cli/scripts/tg-init-trustgraph | 22 +++++++++++++++++++++- 1 file changed, 21 insertions(+), 1 deletion(-) diff --git a/trustgraph-cli/scripts/tg-init-trustgraph b/trustgraph-cli/scripts/tg-init-trustgraph index 2265437e..84c34b61 100755 --- a/trustgraph-cli/scripts/tg-init-trustgraph +++ b/trustgraph-cli/scripts/tg-init-trustgraph @@ -118,7 +118,10 @@ def ensure_config(config, pulsar_host, pulsar_api_key): print("Retrying...", flush=True) continue -def init(pulsar_admin_url, pulsar_host, pulsar_api_key, config, tenant): +def init( + pulsar_admin_url, pulsar_host, pulsar_api_key, tenant, + config, config_file, +): clusters = get_clusters(pulsar_admin_url) @@ -156,6 +159,18 @@ def init(pulsar_admin_url, pulsar_host, pulsar_api_key, config, tenant): ensure_config(dec, pulsar_host, pulsar_api_key) + elif config_file is not None: + + try: + print("Decoding config...", flush=True) + dec = json.load(open(config_file)) + print("Decoded.", flush=True) + except Exception as e: + print("Exception:", e, flush=True) + raise e + + ensure_config(dec, pulsar_host, pulsar_api_key) + else: print("No config to update.", flush=True) @@ -188,6 +203,11 @@ def main(): help=f'Initial configuration to load', ) + parser.add_argument( + '-C', '--config-file', + help=f'Initial configuration to load from file', + ) + parser.add_argument( '-t', '--tenant', default="tg",