ts_xmrwallet.py 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, command-line Bitcoin cold storage solution
  4. # Copyright (C)2013-2021 The MMGen Project <mmgen@tuta.io>
  5. #
  6. # This program is free software: you can redistribute it and/or modify
  7. # it under the terms of the GNU General Public License as published by
  8. # the Free Software Foundation, either version 3 of the License, or
  9. # (at your option) any later version.
  10. #
  11. # This program is distributed in the hope that it will be useful,
  12. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. # GNU General Public License for more details.
  15. #
  16. # You should have received a copy of the GNU General Public License
  17. # along with this program. If not, see <http://www.gnu.org/licenses/>.
  18. """
  19. ts_xmrwallet.py: xmrwallet tests for the test.py test suite
  20. """
  21. import sys,os,atexit,asyncio,shutil
  22. from subprocess import run,PIPE
  23. from mmgen.globalvars import g
  24. from mmgen.opts import opt
  25. from mmgen.obj import MMGenRange,XMRAmt
  26. from mmgen.addr import KeyAddrList,AddrIdxList
  27. from ..include.common import *
  28. from .common import *
  29. from .ts_base import *
  30. class TestSuiteXMRWallet(TestSuiteBase):
  31. """
  32. Monero wallet operations
  33. """
  34. networks = ('xmr',)
  35. passthru_opts = ()
  36. tmpdir_nums = [29]
  37. dfl_random_txs = 3
  38. color = True
  39. cmd_group = (
  40. ('gen_kafiles', 'generating key-address files'),
  41. ('create_wallets_miner', 'creating Monero wallets (Miner)'),
  42. ('mine_initial_coins', 'mining initial coins'),
  43. ('create_wallets_alice', 'creating Monero wallets (Alice)'),
  44. ('fund_alice', 'sending funds'),
  45. ('sync_wallets_all', 'syncing all wallets'),
  46. ('sync_wallets_selected', 'syncing selected wallets'),
  47. ('sweep_to_address_proxy', 'sweeping to new address (via TX relay + proxy)'),
  48. ('sweep_to_account', 'sweeping to new account'),
  49. ('sweep_to_address_noproxy', 'sweeping to new address (via TX relay, no proxy)'),
  50. ('transfer_to_miner_proxy', 'transferring funds to Miner (via TX relay + proxy)'),
  51. ('transfer_to_miner_noproxy', 'transferring funds to Miner (via TX relay, no proxy)'),
  52. ('transfer_to_miner_create1', 'transferring funds to Miner (create TX)'),
  53. ('transfer_to_miner_send1', 'transferring funds to Miner (send TX via proxy)'),
  54. ('transfer_to_miner_create2', 'transferring funds to Miner (create TX)'),
  55. ('transfer_to_miner_send2', 'transferring funds to Miner (send TX, no proxy)'),
  56. ('sweep_create_and_send', 'sweeping to new account (create TX + send TX, in stages)'),
  57. )
  58. def __init__(self,trunner,cfgs,spawn):
  59. TestSuiteBase.__init__(self,trunner,cfgs,spawn)
  60. if trunner == None:
  61. return
  62. from mmgen.protocol import init_proto
  63. self.proto = init_proto('XMR',network='testnet')
  64. self.datadir_base = os.path.join('test','daemons','xmrtest')
  65. self.long_opts = ['--testnet=1', '--monero-wallet-rpc-password=passw0rd']
  66. self.init_users()
  67. self.init_daemon_args()
  68. for v in self.users.values():
  69. run(['mkdir','-p',v.udir])
  70. self.init_proxy()
  71. self.tx_relay_daemon_parm = 'localhost:{}'.format( self.users['bob'].md.rpc_port )
  72. self.tx_relay_daemon_proxy_parm = (
  73. self.tx_relay_daemon_parm + f':127.0.0.1:{self.socks_port}' # proxy must be IP, not 'localhost'
  74. if self.use_proxy else None )
  75. if not opt.no_daemon_stop:
  76. atexit.register(self.stop_daemons)
  77. atexit.register(self.stop_miner_wallet_daemon)
  78. if not opt.no_daemon_autostart:
  79. self.stop_daemons()
  80. shutil.rmtree(self.datadir_base,ignore_errors=True)
  81. os.makedirs(self.datadir_base)
  82. self.start_daemons()
  83. self.balance = None
  84. # init methods
  85. def init_proxy(self):
  86. def port_in_use(port):
  87. import socket
  88. try: socket.create_connection(('localhost',port)).close()
  89. except: return False
  90. else: return True
  91. def start_proxy():
  92. if not opt.no_daemon_autostart:
  93. run(a+b2)
  94. omsg(f'SSH SOCKS server started, listening at localhost:{self.socks_port}')
  95. def kill_proxy():
  96. if g.platform == 'linux':
  97. omsg(f'Killing SSH SOCKS server at localhost:{self.socks_port}')
  98. cmd = [ 'pkill', '-f', ' '.join(a + b2) ]
  99. run(cmd)
  100. self.use_proxy = False
  101. self.socks_port = 9060
  102. a = ['ssh','-x','-o','ExitOnForwardFailure=True','-D',f'localhost:{self.socks_port}']
  103. b0 = ['-o','PasswordAuthentication=False']
  104. b1 = ['localhost','true']
  105. b2 = ['-fN','-E','txrelay-proxy.debug','localhost']
  106. if port_in_use(self.socks_port):
  107. omsg(f'Port {self.socks_port} already in use. Assuming SSH SOCKS server is running')
  108. self.use_proxy = True
  109. else:
  110. cp = run(a+b0+b1,stdout=PIPE,stderr=PIPE)
  111. err = cp.stderr.decode()
  112. if err:
  113. omsg(err)
  114. if cp.returncode == 0:
  115. start_proxy()
  116. self.use_proxy = True
  117. elif 'onnection refused' in err:
  118. die(2,fmt("""
  119. The SSH daemon must be running and listening on localhost in order to test
  120. XMR TX relaying via SOCKS proxy. If sshd is not running, please start it.
  121. Otherwise, add the line 'ListenAddress 127.0.0.1' to your sshd_config, and
  122. then restart the daemon.
  123. """,indent=' '))
  124. elif 'ermission denied' in err:
  125. msg(fmt(f"""
  126. In order to test XMR TX relaying via SOCKS proxy, it’s desirable to enable
  127. SSH to localhost without a password, which is not currently supported by
  128. your configuration. Your possible courses of action:
  129. 1. Continue by answering 'y' at this prompt, and enter your system password
  130. at the following prompt;
  131. 2. Exit the test here, add your user SSH public key to your user
  132. 'authorized_keys' file, and restart the test; or
  133. 3. Exit the test here, start the SSH SOCKS proxy manually by entering the
  134. following command, and restart the test:
  135. {' '.join(a+b2)}
  136. """,indent=' ',strip_char='\t'))
  137. if keypress_confirm('Continue?'):
  138. start_proxy()
  139. self.use_proxy = True
  140. else:
  141. die(1,'Exiting at user request')
  142. else:
  143. die(2,fmt(f"""
  144. Please start the SSH SOCKS proxy by entering the following command:
  145. {' '.join(a+b2)}
  146. Then restart the test.
  147. """,indent=' '))
  148. if not opt.no_daemon_stop:
  149. atexit.register(kill_proxy)
  150. def init_users(self):
  151. from mmgen.daemon import CoinDaemon,MoneroWalletDaemon
  152. from mmgen.rpc import MoneroRPCClient,MoneroRPCClientRaw,MoneroWalletRPCClient
  153. self.users = {}
  154. n = self.tmpdir_nums[0]
  155. ud = namedtuple('user_data',[
  156. 'sid',
  157. 'mmwords',
  158. 'udir',
  159. 'datadir',
  160. 'kal_range',
  161. 'kafile',
  162. 'walletfile_fs',
  163. 'addrfile_fs',
  164. 'md',
  165. 'md_rpc',
  166. 'md_json_rpc',
  167. 'wd',
  168. 'wd_rpc',
  169. ])
  170. for user,sid,shift,kal_range in ( # kal_range must be None, a single digit, or a single hyphenated range
  171. ('miner', '98831F3A', 130, '1-2'),
  172. ('bob', '1378FC64', 140, None),
  173. ('alice', 'FE3C6545', 150, '1-4'),
  174. ):
  175. udir = os.path.join('test',f'tmp{n}',user)
  176. datadir = os.path.join(self.datadir_base,user)
  177. md = CoinDaemon(
  178. proto = self.proto,
  179. test_suite = True,
  180. port_shift = shift,
  181. opts = ['online'],
  182. datadir = datadir
  183. )
  184. md_rpc = MoneroRPCClientRaw(
  185. host = md.host,
  186. port = md.rpc_port,
  187. user = None,
  188. passwd = None,
  189. test_connection = False,
  190. )
  191. md_json_rpc = MoneroRPCClient(
  192. host = md.host,
  193. port = md.rpc_port,
  194. user = None,
  195. passwd = None,
  196. test_connection = False,
  197. )
  198. wd = MoneroWalletDaemon(
  199. proto = self.proto,
  200. test_suite = True,
  201. wallet_dir = udir,
  202. user = 'foo',
  203. passwd = 'bar',
  204. port_shift = shift,
  205. datadir = os.path.join('test','daemons'),
  206. daemon_addr = f'127.0.0.1:{md.rpc_port}',
  207. )
  208. wd_rpc = MoneroWalletRPCClient( daemon=wd, test_connection=False )
  209. self.users[user] = ud(
  210. sid = sid,
  211. mmwords = f'test/ref/{sid}.mmwords',
  212. udir = udir,
  213. datadir = datadir,
  214. kal_range = kal_range,
  215. kafile = f'{udir}/{sid}-XMR-M[{kal_range}].testnet.akeys',
  216. walletfile_fs = f'{udir}/{sid}-{{}}-MoneroWallet.testnet',
  217. addrfile_fs = f'{udir}/{sid}-{{}}-MoneroWallet.testnet.address.txt',
  218. md = md,
  219. md_rpc = md_rpc,
  220. md_json_rpc = md_json_rpc,
  221. wd = wd,
  222. wd_rpc = wd_rpc,
  223. )
  224. def init_daemon_args(self):
  225. common_args = ['--p2p-bind-ip=127.0.0.1','--fixed-difficulty=1'] # ,'--rpc-ssl-allow-any-cert']
  226. for u in self.users:
  227. other_ports = [self.users[u2].md.p2p_port for u2 in self.users if u2 != u]
  228. node_args = [f'--add-exclusive-node=127.0.0.1:{p}' for p in other_ports]
  229. self.users[u].md.usr_coind_args = common_args + node_args
  230. # cmd_group methods
  231. def gen_kafiles(self):
  232. for user,data in self.users.items():
  233. if not data.kal_range:
  234. continue
  235. run(['mkdir','-p',data.udir])
  236. run(f'rm -f {data.kafile}',shell=True)
  237. t = self.spawn(
  238. 'mmgen-keygen', [
  239. '--testnet=1','-q', '--accept-defaults', '--coin=xmr',
  240. f'--outdir={data.udir}', data.mmwords, data.kal_range
  241. ],
  242. extra_desc = f'({capfirst(user)})' )
  243. t.read()
  244. t.ok()
  245. t.skip_ok = True
  246. return t
  247. def create_wallets_miner(self): return self.create_wallets('miner')
  248. def create_wallets_alice(self): return self.create_wallets('alice')
  249. def create_wallets(self,user,wallet=None):
  250. assert wallet is None or is_int(wallet), 'wallet arg'
  251. data = self.users[user]
  252. run(
  253. 'rm -f {}*'.format( data.walletfile_fs.format(wallet or '*') ),
  254. shell = True
  255. )
  256. dir_opt = [f'--wallet-dir={data.udir}']
  257. t = self.spawn(
  258. 'mmgen-xmrwallet',
  259. self.long_opts + dir_opt + [ 'create', data.kafile, (wallet or data.kal_range) ] )
  260. t.expect('Check key-to-address validity? (y/N): ','n')
  261. for i in MMGenRange(wallet or data.kal_range).items:
  262. t.expect('Address: ')
  263. t.read()
  264. return t
  265. async def mine_initial_coins(self):
  266. await self.open_wallet_user('miner',1)
  267. return await self.mine_chk('miner',1,0,lambda x: x > 20,'unlocked balance > 20')
  268. async def fund_alice(self):
  269. await self.transfer(
  270. 'miner',
  271. 1234567891234,
  272. read_from_file(self.users['alice'].addrfile_fs.format(1)),
  273. )
  274. bal = '1.234567891234'
  275. return await self.mine_chk(
  276. 'alice',1,0,
  277. lambda x: str(x) == bal,f'unlocked balance == {bal}',
  278. random_txs = self.dfl_random_txs
  279. )
  280. def sync_wallets_all(self):
  281. return self.sync_wallets('alice',add_opts=['--rescan-blockchain'])
  282. def sync_wallets_selected(self):
  283. return self.sync_wallets('alice',wallets='1-2,4')
  284. def sync_wallets(self,user,wallets=None,add_opts=None):
  285. data = self.users[user]
  286. cmd_opts = list_gen(
  287. [f'--wallet-dir={data.udir}'],
  288. [f'--daemon=localhost:{data.md.rpc_port}'],
  289. )
  290. t = self.spawn(
  291. 'mmgen-xmrwallet',
  292. self.long_opts + cmd_opts + (add_opts or []) + [ 'sync', data.kafile ] + ([wallets] if wallets else []) )
  293. t.expect('Check key-to-address validity? (y/N): ','n')
  294. wlist = AddrIdxList(wallets) if wallets else MMGenRange(data.kal_range).items
  295. for n,wnum in enumerate(wlist):
  296. t.expect('Syncing wallet {}/{} ({})'.format(
  297. n+1,
  298. len(wlist),
  299. os.path.basename(data.walletfile_fs.format(wnum)),
  300. ))
  301. t.expect('Chain height: ')
  302. t.expect('Wallet height: ')
  303. t.expect('Balance: ')
  304. t.read()
  305. return t
  306. def do_op(self, op, user, arg2,
  307. tx_relay_parm = None,
  308. do_not_relay = False,
  309. return_amt = False,
  310. reuse_acct = False,
  311. add_desc = None,
  312. do_ret = False ):
  313. data = self.users[user]
  314. cmd_opts = list_gen(
  315. [f'--wallet-dir={data.udir}'],
  316. [f'--outdir={data.udir}'],
  317. [f'--daemon=localhost:{data.md.rpc_port}'],
  318. [f'--tx-relay-daemon={tx_relay_parm}', tx_relay_parm],
  319. ['--do-not-relay', do_not_relay]
  320. )
  321. add_desc = (', ' + add_desc) if add_desc else ''
  322. t = self.spawn(
  323. 'mmgen-xmrwallet',
  324. self.long_opts + cmd_opts + [ op, data.kafile, arg2 ],
  325. extra_desc = f'({capfirst(user)}{add_desc})' )
  326. t.expect('Check key-to-address validity? (y/N): ','n')
  327. if op == 'sweep':
  328. t.expect(
  329. 'Create new {} .* \(y/N\): '.format(('address','account')[',' in arg2]),
  330. ('y','n')[reuse_acct],
  331. regex=True )
  332. if reuse_acct:
  333. t.expect( 'to last existing account .* \(y/N\): ','y', regex=True )
  334. if return_amt:
  335. amt = XMRAmt(strip_ansi_escapes(t.expect_getend('Amt: ')).replace('XMR','').strip())
  336. if do_not_relay:
  337. t.expect('Save MoneroMMGenTX data? (y/N): ','y')
  338. t.written_to_file('MoneroMMGenTX data')
  339. else:
  340. t.expect(f'Relay {op} transaction? (y/N): ','y')
  341. t.read()
  342. return t if do_ret else amt if return_amt else t.ok()
  343. def sweep_to_address_proxy(self):
  344. self.do_op('sweep','alice','1:0',self.tx_relay_daemon_proxy_parm)
  345. return self.mine_chk('alice',1,0,lambda x: x > 1,'unlocked balance > 1')
  346. def sweep_to_account(self):
  347. self.do_op('sweep','alice','1:0,2')
  348. return self.mine_chk('alice',2,1,lambda x: x > 1,'unlocked balance > 1')
  349. def sweep_to_address_noproxy(self):
  350. self.do_op('sweep','alice','2:1',self.tx_relay_daemon_parm)
  351. return self.mine_chk('alice',2,1,lambda x: x > 0.9,'unlocked balance > 0.9')
  352. async def transfer_to_miner_proxy(self):
  353. addr = read_from_file(self.users['miner'].addrfile_fs.format(2))
  354. amt = '0.135'
  355. self.do_op('transfer','alice',f'2:1:{addr},{amt}',self.tx_relay_daemon_proxy_parm)
  356. await self.stop_wallet_user('miner')
  357. await self.open_wallet_user('miner',2)
  358. await self.mine_chk('miner',2,0,lambda x: str(x) == amt,f'unlocked balance == {amt}')
  359. ok()
  360. return await self.mine_chk('alice',2,1,lambda x: x > 0.9,'unlocked balance > 0.9')
  361. async def transfer_to_miner_noproxy(self):
  362. addr = read_from_file(self.users['miner'].addrfile_fs.format(2))
  363. self.do_op('transfer','alice',f'2:1:{addr},0.0995',self.tx_relay_daemon_parm)
  364. await self.mine_chk('miner',2,0,lambda x: str(x) == '0.2345','unlocked balance == 0.2345')
  365. ok()
  366. return await self.mine_chk('alice',2,1,lambda x: x > 0.9,'unlocked balance > 0.9')
  367. def transfer_to_miner_create(self,amt):
  368. get_file_with_ext(self.users['alice'].udir,'sigtx',delete_all=True)
  369. addr = read_from_file(self.users['miner'].addrfile_fs.format(2))
  370. return self.do_op('transfer','alice',f'2:1:{addr},{amt}',do_not_relay=True,do_ret=True)
  371. def transfer_to_miner_create1(self):
  372. return self.transfer_to_miner_create('0.0111')
  373. def transfer_to_miner_create2(self):
  374. return self.transfer_to_miner_create('0.0012')
  375. def relay_tx(self,relay_opt=None,add_desc=None):
  376. user = 'alice'
  377. data = self.users[user]
  378. fn = get_file_with_ext(data.udir,'sigtx')
  379. add_desc = (', ' + add_desc) if add_desc else ''
  380. t = self.spawn(
  381. 'mmgen-xmrwallet',
  382. self.long_opts
  383. + ([relay_opt] if relay_opt else [])
  384. + [ 'relay', fn ],
  385. extra_desc = f'(relaying TX, {capfirst(user)}{add_desc})' )
  386. t.expect('Relay transaction? ','y')
  387. t.read()
  388. t.ok()
  389. async def transfer_to_miner_send1(self):
  390. self.relay_tx(f'--tx-relay-daemon={self.tx_relay_daemon_proxy_parm}',add_desc='via proxy')
  391. await self.mine_chk('miner',2,0,lambda x: str(x) == '0.2456','unlocked balance == 0.2456')
  392. ok()
  393. return await self.mine_chk('alice',2,1,lambda x: x > 0.9,'unlocked balance > 0.9')
  394. async def transfer_to_miner_send2(self):
  395. self.relay_tx(f'--tx-relay-daemon={self.tx_relay_daemon_parm}',add_desc='no proxy')
  396. await self.mine_chk('miner',2,0,lambda x: str(x) == '0.2468','unlocked balance == 0.2468')
  397. ok()
  398. return await self.mine_chk('alice',2,1,lambda x: x > 0.9,'unlocked balance > 0.9')
  399. async def sweep_create_and_send(self):
  400. bal = XMRAmt('0')
  401. min_bal = XMRAmt('0.9')
  402. for i in range(4):
  403. if i: ok()
  404. get_file_with_ext(self.users['alice'].udir,'sigtx',delete_all=True)
  405. send_amt = self.do_op(
  406. 'sweep','alice','2:1,3', # '2:1,3'
  407. do_not_relay = True,
  408. reuse_acct = True,
  409. add_desc = f'TX #{i+1}',
  410. return_amt = True )
  411. ok()
  412. self.relay_tx(f'--tx-relay-daemon={self.tx_relay_daemon_parm}',add_desc=f'send amt: {send_amt} XMR')
  413. await self.mine_chk('alice',2,1,lambda x: 'chk_bal_chg','balance has changed')
  414. ok()
  415. bal += await self.mine_chk('alice',3,0,lambda x,y=bal: x > y, f'bal > {bal}',return_amt=True)
  416. if bal >= min_bal:
  417. return 'ok'
  418. return False
  419. # wallet methods
  420. async def open_wallet_user(self,user,wnum):
  421. data = self.users[user]
  422. silence()
  423. kal = KeyAddrList(self.proto,data.kafile,skip_key_address_validity_check=True)
  424. end_silence()
  425. self.users[user].wd.start(silent=not (opt.exact_output or opt.verbose))
  426. return await data.wd_rpc.call(
  427. 'open_wallet',
  428. filename = os.path.basename(data.walletfile_fs.format(wnum)),
  429. password = kal.entry(wnum).wallet_passwd )
  430. async def stop_wallet_user(self,user):
  431. await self.users[user].wd_rpc.stop_daemon(silent=not (opt.exact_output or opt.verbose))
  432. return 'ok'
  433. # mining methods
  434. async def start_mining(self):
  435. data = self.users['miner']
  436. addr = read_from_file(data.addrfile_fs.format(1)) # mine to wallet #1, account 0
  437. for i in range(20):
  438. ret = await data.md_rpc.call(
  439. 'start_mining',
  440. do_background_mining = False, # run mining in background or foreground
  441. ignore_battery = True, # ignore battery state (on laptop)
  442. miner_address = addr, # account address to mine to
  443. threads_count = 3 ) # number of mining threads to run
  444. status = self.get_status(ret)
  445. if status == 'OK':
  446. return True
  447. elif status == 'BUSY':
  448. await asyncio.sleep(5)
  449. omsg('Daemon busy. Attempting to start mining...')
  450. else:
  451. die(2,f'Monerod returned status {status}')
  452. else:
  453. die(2,'Max retries exceeded')
  454. async def stop_mining(self):
  455. ret = await self.users['miner'].md_rpc.call('stop_mining')
  456. return self.get_status(ret)
  457. async def mine_chk(self,user,wnum,account,test,test_desc,random_txs=None,return_amt=False):
  458. """
  459. - open destination wallet
  460. - optionally create and broadcast random TXs
  461. - start mining
  462. - mine until funds appear in wallet
  463. - stop mining
  464. - close wallet
  465. """
  466. async def get_height():
  467. u = self.users['miner']
  468. for i in range(20):
  469. try:
  470. return (await u.md_json_rpc.call('get_last_block_header'))['block_header']['height']
  471. except Exception as e:
  472. if 'onnection refused' in str(e):
  473. omsg(f'{e}\nMonerod appears to have crashed. Attempting to restart...')
  474. await asyncio.sleep(5)
  475. u.md.restart()
  476. await asyncio.sleep(5)
  477. await self.start_mining()
  478. else:
  479. raise
  480. else:
  481. die(2,'Restart attempt limit exceeded')
  482. async def send_random_txs():
  483. from mmgen.tool import tool_api
  484. t = tool_api()
  485. t.init_coin('XMR','testnet')
  486. t.usr_randchars = 0
  487. imsg_r(f'Sending random transactions: ')
  488. for i in range(random_txs):
  489. await self.transfer(
  490. 'miner',
  491. 123456789,
  492. t.randpair()[1],
  493. )
  494. imsg_r(f'{i+1} ')
  495. oqmsg_r('+')
  496. await asyncio.sleep(0.5)
  497. imsg('')
  498. def print_balance(dest,ub):
  499. imsg('Total balance in {}’s wallet {}, account #{}: {}'.format(
  500. capfirst(dest.user),
  501. dest.wnum,
  502. dest.account,
  503. ub.hl()
  504. ))
  505. async def get_balance(dest,count):
  506. data = self.users[dest.user]
  507. await data.wd_rpc.call('refresh')
  508. if count and not count % 20:
  509. await data.wd_rpc.call('rescan_blockchain')
  510. ret = await data.wd_rpc.call('get_accounts')
  511. return XMRAmt(ret['subaddress_accounts'][dest.account]['unlocked_balance'],from_unit='atomic')
  512. # start execution:
  513. self.do_msg(extra_desc =
  514. (f'sending {random_txs} random TXs, ' if random_txs else '') +
  515. f'mining, checking wallet {user}:{wnum}:{account}' )
  516. dest = namedtuple(
  517. 'dest_info',['user','wnum','account','test','test_desc'])(user,wnum,account,test,test_desc)
  518. if dest.user != 'miner':
  519. await self.open_wallet_user(dest.user,dest.wnum)
  520. ub_start = await get_balance(dest,0)
  521. chk_bal_chg = dest.test(ub_start) == 'chk_bal_chg'
  522. if random_txs:
  523. await send_random_txs()
  524. await self.start_mining()
  525. h = await get_height()
  526. imsg_r(f'Chain height: {h} ')
  527. for count in range(500):
  528. ub = await get_balance(dest,count)
  529. if dest.test(ub) is True or ( chk_bal_chg and ub != ub_start ):
  530. imsg('')
  531. oqmsg_r('+')
  532. print_balance(dest,ub)
  533. break
  534. await asyncio.sleep(2)
  535. h = await get_height()
  536. imsg_r(f'{h} ')
  537. oqmsg_r('+')
  538. else:
  539. die(2,'Timeout exceeded, balance {ub!r}')
  540. await self.stop_mining()
  541. if user != 'miner':
  542. await self.stop_wallet_user(dest.user)
  543. return ub if return_amt else 'ok'
  544. # util methods
  545. def get_status(self,ret):
  546. if ret['status'] != 'OK':
  547. imsg( 'RPC status: {}'.format( ret['status'] ))
  548. return ret['status']
  549. def do_msg(self,extra_desc=None):
  550. self.spawn(
  551. '',
  552. msg_only = True,
  553. extra_desc = f'({extra_desc})' if extra_desc else None
  554. )
  555. async def transfer(self,user,amt,addr):
  556. return await self.users[user].wd_rpc.call('transfer',destinations=[{'amount':amt,'address':addr}])
  557. # daemon start/stop methods
  558. def start_daemons(self):
  559. for v in self.users.values():
  560. run(['mkdir','-p',v.datadir])
  561. v.md.start()
  562. def stop_daemons(self):
  563. for v in self.users.values():
  564. if v.md.state != 'stopped':
  565. v.md.stop()
  566. def start_wallet_daemons(self):
  567. self.users['miner'].wd.start()
  568. def stop_miner_wallet_daemon(self):
  569. self.users['miner'].wd.stop()