From eb7bcef036055b0fb062b6dbc63cff48e6978226 Mon Sep 17 00:00:00 2001 From: The MMGen Project Date: Wed, 1 Oct 2025 15:30:57 +0000 Subject: [PATCH] util.py: reimplement `async_run()` (stub) --- examples/halving-calculator.py | 2 +- mmgen/main_addrimport.py | 2 +- mmgen/main_autosign.py | 2 +- mmgen/main_msg.py | 2 +- mmgen/main_regtest.py | 2 +- mmgen/main_tool.py | 2 +- mmgen/main_txbump.py | 2 +- mmgen/main_txcreate.py | 2 +- mmgen/main_txdo.py | 2 +- mmgen/main_txsend.py | 2 +- mmgen/main_txsign.py | 2 +- mmgen/util.py | 4 ++-- 12 files changed, 13 insertions(+), 13 deletions(-) diff --git a/examples/halving-calculator.py b/examples/halving-calculator.py index 1a67b010..d21954cb 100755 --- a/examples/halving-calculator.py +++ b/examples/halving-calculator.py @@ -87,4 +87,4 @@ async def main(): f'Est. time until halving: {dhms(cur["time"] + t_rem - clock_time)}\n' ) -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_addrimport.py b/mmgen/main_addrimport.py index 149dc205..80f932f1 100755 --- a/mmgen/main_addrimport.py +++ b/mmgen/main_addrimport.py @@ -178,4 +178,4 @@ cfg = Config(opts_data=opts_data, need_amt=False) proto = cfg._proto -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_autosign.py b/mmgen/main_autosign.py index cbbfe931..4a537f80 100755 --- a/mmgen/main_autosign.py +++ b/mmgen/main_autosign.py @@ -187,7 +187,7 @@ def main(do_loop): ret = await asi.do_sign() asi.at_exit(not ret) - async_run(do()) + async_run(cfg, do) from .cfg import Config from .autosign import Autosign diff --git a/mmgen/main_msg.py b/mmgen/main_msg.py index f8f7c98e..df9bb3ae 100755 --- a/mmgen/main_msg.py +++ b/mmgen/main_msg.py @@ -227,4 +227,4 @@ async def main(): case _: die(1, f'{op!r}: unrecognized operation') -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_regtest.py b/mmgen/main_regtest.py index 4d9a4a2a..45788f84 100755 --- a/mmgen/main_regtest.py +++ b/mmgen/main_regtest.py @@ -86,4 +86,4 @@ elif cmd_args[0] not in ('cli', 'wallet_cli', 'balances'): async def main(): await MMGenRegtest(cfg, cfg.coin, bdb_wallet=cfg.bdb_wallet).cmd(cmd_args) -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_tool.py b/mmgen/main_tool.py index e9fb79f4..c9f9cad5 100755 --- a/mmgen/main_tool.py +++ b/mmgen/main_tool.py @@ -392,7 +392,7 @@ if gc.prog_name.endswith('-tool'): args, kwargs = process_args(cmd, args, cls) func = getattr(cls(cfg, cmdname=cmd), cmd) - ret = async_run(func(*args, **kwargs)) if isAsync(func) else func(*args, **kwargs) + ret = async_run(cfg, func, args=args, kwargs=kwargs) if isAsync(func) else func(*args, **kwargs) process_result( ret, diff --git a/mmgen/main_txbump.py b/mmgen/main_txbump.py index be20fa59..9c6ae37a 100755 --- a/mmgen/main_txbump.py +++ b/mmgen/main_txbump.py @@ -217,4 +217,4 @@ async def main(): ask_write_default_yes = False, ask_overwrite = not cfg.yes) -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_txcreate.py b/mmgen/main_txcreate.py index cbd4cd3f..7c9c4bbc 100755 --- a/mmgen/main_txcreate.py +++ b/mmgen/main_txcreate.py @@ -155,4 +155,4 @@ async def main(): ask_overwrite = not cfg.yes, ask_write_default_yes = False) -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_txdo.py b/mmgen/main_txdo.py index bd92fbca..8cad5ee4 100755 --- a/mmgen/main_txdo.py +++ b/mmgen/main_txdo.py @@ -196,4 +196,4 @@ async def main(): else: die(2, 'Transaction could not be signed') -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_txsend.py b/mmgen/main_txsend.py index abd11fe8..12aae915 100755 --- a/mmgen/main_txsend.py +++ b/mmgen/main_txsend.py @@ -158,4 +158,4 @@ async def main(): await tx.send(cfg, asi) -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/main_txsign.py b/mmgen/main_txsign.py index 9d94b49c..ee06b7cd 100755 --- a/mmgen/main_txsign.py +++ b/mmgen/main_txsign.py @@ -158,4 +158,4 @@ async def main(): if bad_tx_count: die(2, f'{bad_tx_count} transaction{suf(bad_tx_count)} could not be signed') -async_run(main()) +async_run(cfg, main) diff --git a/mmgen/util.py b/mmgen/util.py index a54af3c0..c0b40b5f 100755 --- a/mmgen/util.py +++ b/mmgen/util.py @@ -441,9 +441,9 @@ def get_subclasses(cls, *, names=False): yield from gen(i) return tuple((c.__name__ for c in gen(cls)) if names else gen(cls)) -def async_run(coro): +def async_run(cfg, func, *, args=(), kwargs={}): import asyncio - return asyncio.run(coro) + return asyncio.run(func(*args, **kwargs)) def wrap_ripemd160(called=[]): if not called: