util.py: reimplement async_run() (stub)

This commit is contained in:
The MMGen Project 2025-10-01 15:30:57 +00:00
commit eb7bcef036
Signed by: mmgen
GPG key ID: 3F8B1861E32B7DA2
12 changed files with 13 additions and 13 deletions

View file

@ -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)

View file

@ -178,4 +178,4 @@ cfg = Config(opts_data=opts_data, need_amt=False)
proto = cfg._proto
async_run(main())
async_run(cfg, main)

View file

@ -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

View file

@ -227,4 +227,4 @@ async def main():
case _:
die(1, f'{op!r}: unrecognized operation')
async_run(main())
async_run(cfg, main)

View file

@ -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)

View file

@ -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,

View file

@ -217,4 +217,4 @@ async def main():
ask_write_default_yes = False,
ask_overwrite = not cfg.yes)
async_run(main())
async_run(cfg, main)

View file

@ -155,4 +155,4 @@ async def main():
ask_overwrite = not cfg.yes,
ask_write_default_yes = False)
async_run(main())
async_run(cfg, main)

View file

@ -196,4 +196,4 @@ async def main():
else:
die(2, 'Transaction could not be signed')
async_run(main())
async_run(cfg, main)

View file

@ -158,4 +158,4 @@ async def main():
await tx.send(cfg, asi)
async_run(main())
async_run(cfg, main)

View file

@ -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)

View file

@ -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: