#!/usr/bin/env python3
import sys
import asyncio

from electrum_trc.network import filter_protocol, Network
from electrum_trc.util import create_and_start_event_loop, log_exceptions


try:
    txid = sys.argv[1]
except:
    print("usage: txradar txid")
    sys.exit(1)


loop, stopping_fut, loop_thread = create_and_start_event_loop()
network = Network()
network.start()

@log_exceptions
async def f():
    try:
        peers = await network.get_peers()
        peers = filter_protocol(peers, 's')
        results = await network.send_multiple_requests(peers, 'blockchain.transaction.get', [txid])
        r1, r2 = [], []
        for k, v in results.items():
            (r1 if not isinstance(v, Exception) else r2).append(k)
        print(f"Received {len(results)} answers")
        try: propagation = len(r1) * 100. / (len(r1) + len(r2))
        except ZeroDivisionError: propagation = 0
        print(f"Propagation rate: {propagation:.1f} percent")
    finally:
        stopping_fut.set_result(1)

asyncio.run_coroutine_threadsafe(f(), loop)

[(16, 'electrum_trc.util.create_and_start_event_loop', 'create_and_start_event_loop', False, 'from electrum_trc.util import create_and_start_event_loop, log_exceptions\n'), (17, 'electrum_trc.network.Network', 'Network', False, 'from electrum_trc.network import filter_protocol, Network\n'), (13, 'sys.exit', 'sys.exit', False, 'import sys\n'), (24, 'electrum_trc.network.filter_protocol', 'filter_protocol', False, 'from electrum_trc.network import filter_protocol, Network\n')]