ts_regtest.py 41 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, command-line Bitcoin cold storage solution
  4. # Copyright (C)2013-2022 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_regtest.py: Regtest tests for the test.py test suite
  20. """
  21. import os,json
  22. from decimal import Decimal
  23. from mmgen.globalvars import g
  24. from mmgen.opts import opt
  25. from mmgen.util import die,gmsg
  26. from mmgen.protocol import init_proto
  27. from mmgen.addrlist import AddrList
  28. from mmgen.wallet import Wallet,get_wallet_cls
  29. from ..include.common import *
  30. from .common import *
  31. pat_date = r'\b\d\d-\d\d-\d\d\b'
  32. pat_date_time = r'\b\d\d\d\d-\d\d-\d\d\s+\d\d:\d\d\b'
  33. dfl_wcls = get_wallet_cls('mmgen')
  34. rt_pw = 'abc-α'
  35. rt_data = {
  36. 'tx_fee': {'btc':'0.0001','bch':'0.001','ltc':'0.01'},
  37. 'rtFundAmt': {'btc':'500','bch':'500','ltc':'5500'},
  38. 'rtFee': {
  39. 'btc': ('20s','10s','60s','31s','10s','20s'),
  40. 'bch': ('20s','10s','60s','0.0001','10s','20s'),
  41. 'ltc': ('1000s','500s','1500s','0.05','400s','1000s')
  42. },
  43. 'rtBals': {
  44. 'btc': ('499.9999488','399.9998282','399.9998147','399.9996877',
  45. '52.99980410','946.99933647','999.99914057','52.9999',
  46. '946.99933647'),
  47. 'bch': ('499.9999484','399.9999194','399.9998972','399.9997692',
  48. '46.78890380','953.20966920','999.99857300','46.789',
  49. '953.2096692'),
  50. 'ltc': ('5499.99744','5399.994425','5399.993885','5399.987535',
  51. '52.98520500','10946.93753500','10999.92274000','52.99',
  52. '10946.937535'),
  53. },
  54. 'rtBals_gb': {
  55. 'btc': {
  56. '0conf0': {
  57. 'mmgen': ('283.22339537','0','283.22339537'),
  58. 'nonmm': ('16.77647763','0','116.77629233'),
  59. 'total': ('299.999873','0','399.9996877'),
  60. },
  61. '0conf1': {
  62. 'mmgen': ('283.22339537','283.22339537','0'),
  63. 'nonmm': ('16.77647763','16.77647763','99.9998147'),
  64. 'total': ('299.999873','299.999873','99.9998147'),
  65. },
  66. '1conf1': {
  67. 'mmgen': ('0','0','283.22339537'),
  68. 'nonmm': ('0','0','116.77629233'),
  69. 'total': ('0','0','399.9996877'),
  70. },
  71. '1conf2': {
  72. 'mmgen': ('0','283.22339537','0'),
  73. 'nonmm': ('0','16.77647763','99.9998147'),
  74. 'total': ('0','299.999873','99.9998147'),
  75. },
  76. },
  77. 'bch': {
  78. '0conf0': {
  79. 'mmgen': ('283.22339437','0','283.22339437'),
  80. 'nonmm': ('16.77647763','0','116.77637483'),
  81. 'total': ('299.999872','0','399.9997692'),
  82. },
  83. '0conf1': {
  84. 'mmgen': ('283.22339437','283.22339437','0'),
  85. 'nonmm': ('16.77647763','16.77647763','99.9998972'),
  86. 'total': ('299.999872','299.999872','99.9998972'),
  87. },
  88. '1conf1': {
  89. 'mmgen': ('0','0','283.22339437'),
  90. 'nonmm': ('0','0','116.77637483'),
  91. 'total': ('0','0','399.9997692'),
  92. },
  93. '1conf2': {
  94. 'mmgen': ('0','283.22339437','0'),
  95. 'nonmm': ('0','16.77647763','99.9998972'),
  96. 'total': ('0','299.999872','99.9998972'),
  97. },
  98. },
  99. 'ltc': {
  100. '0conf0': {
  101. 'mmgen': ('283.21717237','0','283.21717237'),
  102. 'nonmm': ('16.77647763','0','5116.77036263'),
  103. 'total': ('299.99365','0','5399.987535'),
  104. },
  105. '0conf1': {
  106. 'mmgen': ('283.21717237','283.21717237','0'),
  107. 'nonmm': ('16.77647763','16.77647763','5099.993885'),
  108. 'total': ('299.99365','299.99365','5099.993885'),
  109. },
  110. '1conf1': {
  111. 'mmgen': ('0','0','283.21717237'),
  112. 'nonmm': ('0','0','5116.77036263'),
  113. 'total': ('0','0','5399.987535'),
  114. },
  115. '1conf2': {
  116. 'mmgen': ('0','283.21717237','0'),
  117. 'nonmm': ('0','16.77647763','5099.993885'),
  118. 'total': ('0','299.99365','5099.993885'),
  119. },
  120. }
  121. },
  122. 'rtBobOp3': {'btc':'S:2','bch':'L:3','ltc':'S:2'},
  123. 'rtAmts': {
  124. 'btc': ('500','500'),
  125. 'bch': ('500','560'),
  126. 'ltc': ('5500','5500')
  127. }
  128. }
  129. def create_burn_addr(proto):
  130. from mmgen.tool.api import tool_api
  131. t = tool_api()
  132. t.init_coin(proto.coin,proto.network)
  133. t.addrtype = 'compressed'
  134. return t.privhex2addr('beadface'*8)
  135. from .ts_base import *
  136. from .ts_shared import *
  137. class TestSuiteRegtest(TestSuiteBase,TestSuiteShared):
  138. 'transacting and tracking wallet operations via regtest mode'
  139. networks = ('btc','ltc','bch')
  140. passthru_opts = ('coin',)
  141. extra_spawn_args = ['--regtest=1']
  142. tmpdir_nums = [17]
  143. color = True
  144. deterministic = False
  145. test_rbf = False
  146. cmd_group = (
  147. ('setup', 'regtest (Bob and Alice) mode setup'),
  148. ('daemon_version', 'mmgen-tool daemon_version'),
  149. ('halving_calculator_bob', 'halving calculator (Bob)'),
  150. ('walletgen_bob', 'wallet generation (Bob)'),
  151. ('walletgen_alice', 'wallet generation (Alice)'),
  152. ('addrgen_bob', 'address generation (Bob)'),
  153. ('addrgen_alice', 'address generation (Alice)'),
  154. ('addrimport_bob', "importing Bob's addresses"),
  155. ('addrimport_alice', "importing Alice's addresses"),
  156. ('bob_import_miner_addr', "importing miner’s coinbase addr into Bob’s wallet"),
  157. ('fund_bob2', "funding Bob’s first MMGen address"),
  158. ('fund_alice2', "funding Alice’s first MMGen address"),
  159. ('bob_recreate_tracking_wallet','creation of new tracking wallet (Bob)'),
  160. ('addrimport_bob2', "reimporting Bob's addresses"),
  161. ('fund_bob', "funding Bob's wallet"),
  162. ('fund_alice', "funding Alice's wallet"),
  163. ('generate', 'mining a block'),
  164. ('bob_bal1', "Bob's balance"),
  165. ('bob_add_label', "adding an 80-screen-width label (lat+cyr+gr)"),
  166. ('bob_twview1', "viewing Bob's tracking wallet"),
  167. ('bob_split1', "splitting Bob's funds"),
  168. ('generate', 'mining a block'),
  169. ('bob_bal2', "Bob's balance"),
  170. ('bob_rbf_1output_create', 'creating RBF tx with one output'),
  171. ('bob_rbf_1output_bump', 'bumping RBF tx with one output'),
  172. ('bob_bal2a', "Bob's balance (age_fmt=confs)"),
  173. ('bob_bal2b', "Bob's balance (showempty=1)"),
  174. ('bob_bal2c', "Bob's balance (showempty=1 minconf=2 age_fmt=days)"),
  175. ('bob_bal2d', "Bob's balance (minconf=2)"),
  176. ('bob_bal2e', "Bob's balance (showempty=1 sort=age)"),
  177. ('bob_bal2f', "Bob's balance (showempty=1 sort=age,reverse)"),
  178. ('bob_send_maybe_rbf', 'sending funds to Alice (RBF, if supported)'),
  179. ('get_mempool1', 'mempool (before RBF bump)'),
  180. ('bob_rbf_status1', 'getting status of transaction'),
  181. ('bob_rbf_bump', 'bumping RBF transaction'),
  182. ('get_mempool2', 'mempool (after RBF bump)'),
  183. ('bob_rbf_status2', 'getting status of transaction after replacement'),
  184. ('bob_rbf_status3', 'getting status of replacement transaction (mempool)'),
  185. ('generate', 'mining a block'),
  186. ('bob_rbf_status4', 'getting status of transaction after confirmed (1) replacement'),
  187. ('bob_rbf_status5', 'getting status of replacement transaction (confirmed)'),
  188. ('generate', 'mining a block'),
  189. ('bob_rbf_status6', 'getting status of transaction after confirmed (2) replacement'),
  190. ('bob_bal3', "Bob's balance"),
  191. ('bob_pre_import', 'sending to non-imported address'),
  192. ('generate', 'mining a block'),
  193. ('bob_import_addr', 'importing non-MMGen address with --rescan'),
  194. ('bob_bal4', "Bob's balance (after import with rescan)"),
  195. ('bob_import_list', 'importing flat address list'),
  196. ('bob_import_list_rescan', 'importing flat address list with --rescan'),
  197. ('bob_split2', "splitting Bob's funds"),
  198. ('bob_0conf0_getbalance', "Bob's balance (unconfirmed, minconf=0)"),
  199. ('bob_0conf1_getbalance', "Bob's balance (unconfirmed, minconf=1)"),
  200. ('generate', 'mining a block'),
  201. ('bob_1conf1_getbalance', "Bob's balance (confirmed, minconf=1)"),
  202. ('bob_1conf2_getbalance', "Bob's balance (confirmed, minconf=2)"),
  203. ('bob_bal5', "Bob's balance"),
  204. ('bob_send_non_mmgen', 'sending funds to Alice (from non-MMGen addrs)'),
  205. ('generate', 'mining a block'),
  206. ('alice_send_estimatefee', 'tx creation with no fee on command line'),
  207. ('generate', 'mining a block'),
  208. ('bob_bal6', "Bob's balance"),
  209. ('bob_subwallet_addrgen1', "generating Bob's addrs from subwallet 29L"),
  210. ('bob_subwallet_addrgen2', "generating Bob's addrs from subwallet 127S"),
  211. ('bob_subwallet_addrimport1', "importing Bob's addrs from subwallet 29L"),
  212. ('bob_subwallet_addrimport2', "importing Bob's addrs from subwallet 127S"),
  213. ('bob_subwallet_fund', "funding Bob's subwallet addrs"),
  214. ('generate', 'mining a block'),
  215. ('bob_twview2', "viewing Bob's tracking wallet"),
  216. ('bob_twview3', "viewing Bob's tracking wallet"),
  217. ('bob_subwallet_txcreate', 'creating a transaction with subwallet inputs'),
  218. ('bob_subwallet_txsign', 'signing a transaction with subwallet inputs'),
  219. ('bob_subwallet_txdo', "sending from Bob's subwallet addrs"),
  220. ('generate', 'mining a block'),
  221. ('bob_twview4', "viewing Bob's tracking wallet"),
  222. ('bob_alice_bal', "Bob and Alice's balances"),
  223. ('alice_bal2', "Alice's balance"),
  224. ('alice_add_label1', 'adding a label'),
  225. ('alice_chk_label1', 'the label'),
  226. ('alice_add_label2', 'adding a label'),
  227. ('alice_chk_label2', 'the label'),
  228. ('alice_edit_label1', 'editing a label (zh)'),
  229. ('alice_edit_label2', 'editing a label (lat+cyr+gr)'),
  230. ('alice_chk_label3', 'the label'),
  231. ('alice_remove_label1', 'removing a label'),
  232. ('alice_chk_label4', 'the label'),
  233. ('alice_add_label_coinaddr', 'adding a label using the coin address'),
  234. ('alice_chk_label_coinaddr', 'the label'),
  235. ('alice_add_label_badaddr1', 'adding a label with invalid address'),
  236. ('alice_add_label_badaddr2', 'adding a label with invalid address for this chain'),
  237. ('alice_add_label_badaddr3', 'adding a label with wrong MMGen address'),
  238. ('alice_add_label_badaddr4', 'adding a label with wrong coin address'),
  239. ('alice_listaddresses1', 'listaddresses'),
  240. ('alice_listaddresses_days', 'listaddresses (age_fmt=days)'),
  241. ('alice_listaddresses_date', 'listaddresses (age_fmt=date)'),
  242. ('alice_listaddresses_date_time', 'listaddresses (age_fmt=date_time)'),
  243. ('alice_twview1', 'twview'),
  244. ('alice_twview_days', 'twview (age_fmt=days)'),
  245. ('alice_twview_date', 'twview (age_fmt=date)'),
  246. ('alice_twview_date_time', 'twview (age_fmt=date_time)'),
  247. ('alice_txcreate_info', 'txcreate -i'),
  248. ('bob_msgcreate', 'creating a message file for signing'),
  249. ('bob_msgsign', 'signing the message file (default wallet)'),
  250. ('bob_walletconv_words', 'creating an MMGen mnemonic wallet'),
  251. ('bob_subwalletgen_bip39', 'creating a BIP39 mnemonic subwallet'),
  252. ('bob_msgsign_userwallet', 'signing the message file (user-specified wallet)'),
  253. ('bob_msgsign_userwallets', 'signing the message file (user-specified wallets)'),
  254. ('bob_msgverify', 'verifying the message file (all addresses)'),
  255. ('bob_msgverify_raw', 'verifying the raw message file (all addresses)'),
  256. ('bob_msgverify_single', 'verifying the message file (single address)'),
  257. ('bob_msgexport', 'exporting the message file'),
  258. ('bob_msgexport_single', 'exporting the message file (single address)'),
  259. ('stop', 'stopping regtest daemon'),
  260. )
  261. def __init__(self,trunner,cfgs,spawn):
  262. TestSuiteBase.__init__(self,trunner,cfgs,spawn)
  263. if trunner == None:
  264. return
  265. if self.proto.testnet:
  266. die(2,'--testnet and --regtest options incompatible with regtest test suite')
  267. self.proto = init_proto(self.proto.coin,network='regtest',need_amt=True)
  268. coin = self.proto.coin.lower()
  269. import test.test_py_d.ts_regtest as rt_mod
  270. for k in rt_data:
  271. setattr( rt_mod, k, rt_data[k][coin] if coin in rt_data[k] else None )
  272. if self.proto.coin == 'BTC':
  273. self.test_rbf = True # tests are non-coin-dependent, so run just once for BTC
  274. if g.test_suite_deterministic:
  275. self.deterministic = True
  276. self.burn_addr = create_burn_addr(self.proto)
  277. self.miner_addr = 'bcrt1q537rgyctcqdgs8nm8gvku05znka4h2m00lx8ps' # regtest.create_hdseed()
  278. self.miner_wif = 'cTEkSYCWKvNo757uwFPd4yuCXsbZvfJDipHsHWFRapXpnikMHvgn'
  279. os.environ['MMGEN_BOGUS_SEND'] = ''
  280. os.environ['MMGEN_TEST_SUITE_REGTEST'] = '1'
  281. self.write_to_tmpfile('wallet_password',rt_pw)
  282. self.dfl_mmtype = 'C' if self.proto.coin == 'BCH' else 'B'
  283. def __del__(self):
  284. os.environ['MMGEN_BOGUS_SEND'] = '1'
  285. os.environ['MMGEN_TEST_SUITE_REGTEST'] = ''
  286. def _add_comments_to_addr_file(self,addrfile,outfile,use_labels=False):
  287. silence()
  288. gmsg(f'Adding comments to address file {addrfile!r}')
  289. a = AddrList(self.proto,addrfile)
  290. for n,idx in enumerate(a.idxs(),1):
  291. if use_labels:
  292. a.set_comment(idx,get_label())
  293. else:
  294. if n % 2: a.set_comment(idx,f'Test address {n}')
  295. af = a.get_file()
  296. af.format(add_comments=True)
  297. from mmgen.fileutil import write_data_to_file
  298. write_data_to_file(outfile,af.fmt_data,quiet=True,ignore_opt_outdir=True)
  299. end_silence()
  300. def setup(self):
  301. stop_test_daemons(self.proto.network_id,force=True,remove_datadir=True)
  302. try: shutil.rmtree(joinpath(self.tr.data_dir,'regtest'))
  303. except: pass
  304. t = self.spawn('mmgen-regtest',['-n','setup'])
  305. for s in ('Starting','Creating','Creating','Creating','Mined','Setup complete'):
  306. t.expect(s)
  307. return t
  308. def daemon_version(self):
  309. t = self.spawn('mmgen-tool', ['--bob','daemon_version'])
  310. t.expect('version')
  311. return t
  312. def halving_calculator_bob(self):
  313. t = self.spawn('halving-calculator.py',['--bob'],cmd_dir='examples')
  314. t.expect('time until halving')
  315. return t
  316. def walletgen(self,user):
  317. t = self.spawn('mmgen-walletgen',['-q','-r0','-p1','--'+user])
  318. t.passphrase_new('new '+dfl_wcls.desc,rt_pw)
  319. t.label()
  320. t.expect('move it to the data directory? (Y/n): ','y')
  321. t.written_to_file(capfirst(dfl_wcls.desc))
  322. return t
  323. def walletgen_bob(self): return self.walletgen('bob')
  324. def walletgen_alice(self): return self.walletgen('alice')
  325. def _user_dir(self,user,coin=None):
  326. return joinpath(self.tr.data_dir,'regtest',coin or self.proto.coin.lower(),user)
  327. def _user_sid(self,user):
  328. return os.path.basename(get_file_with_ext(self._user_dir(user),'mmdat'))[:8]
  329. def _get_user_subsid(self,user,subseed_idx):
  330. fn = get_file_with_ext(self._user_dir(user),dfl_wcls.ext)
  331. silence()
  332. w = Wallet( fn=fn, passwd_file=os.path.join(self.tmpdir,'wallet_password') )
  333. end_silence()
  334. return w.seed.subseed(subseed_idx).sid
  335. def addrgen(self,user,wf=None,addr_range='1-5',subseed_idx=None,mmtypes=[]):
  336. from mmgen.addr import MMGenAddrType
  337. for mmtype in mmtypes or self.proto.mmtypes:
  338. t = self.spawn('mmgen-addrgen',
  339. ['--quiet','--'+user,'--type='+mmtype,f'--outdir={self._user_dir(user)}'] +
  340. ([wf] if wf else []) +
  341. (['--subwallet='+subseed_idx] if subseed_idx else []) +
  342. [addr_range],
  343. extra_desc='({})'.format( MMGenAddrType.mmtypes[mmtype].name ))
  344. t.passphrase(dfl_wcls.desc,rt_pw)
  345. t.written_to_file('Addresses')
  346. ok_msg()
  347. t.skip_ok = True
  348. return t
  349. def addrgen_bob(self): return self.addrgen('bob')
  350. def addrgen_alice(self): return self.addrgen('alice')
  351. def addrimport(self,user,sid=None,addr_range='1-5',num_addrs=5,mmtypes=[]):
  352. id_strs = { 'legacy':'', 'compressed':'-C', 'segwit':'-S', 'bech32':'-B' }
  353. if not sid: sid = self._user_sid(user)
  354. from mmgen.addr import MMGenAddrType
  355. for mmtype in mmtypes or self.proto.mmtypes:
  356. desc = MMGenAddrType.mmtypes[mmtype].name
  357. addrfile = joinpath(self._user_dir(user),
  358. '{}{}{}[{}]{x}.regtest.addrs'.format(
  359. sid,self.altcoin_pfx,id_strs[desc],addr_range,
  360. x='-α' if g.debug_utf8 else ''))
  361. if mmtype == self.proto.mmtypes[0] and user == 'bob':
  362. self._add_comments_to_addr_file(addrfile,addrfile,use_labels=True)
  363. t = self.spawn(
  364. 'mmgen-addrimport',
  365. ['--quiet', '--'+user, '--batch', addrfile],
  366. extra_desc=f'({desc})' )
  367. if g.debug:
  368. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  369. t.expect('Importing')
  370. t.expect(f'{num_addrs} addresses imported')
  371. ok_msg()
  372. t.skip_ok = True
  373. return t
  374. def addrimport_bob(self): return self.addrimport('bob')
  375. def addrimport_alice(self): return self.addrimport('alice')
  376. def bob_import_miner_addr(self):
  377. if not self.deterministic:
  378. return 'skip'
  379. return self.spawn('mmgen-addrimport', [ '--bob', '--rescan', '--quiet', f'--address={self.miner_addr}' ])
  380. def fund_wallet2(self,user,addr,utxo_nums,skip_passphrase=False):
  381. """
  382. the deterministic funding method using specific inputs
  383. """
  384. if not self.deterministic:
  385. return 'skip'
  386. self.write_to_tmpfile('miner.key',f'{self.miner_wif}\n')
  387. keyfile = joinpath(self.tmpdir,'miner.key')
  388. return self.user_txdo(
  389. 'bob', '40s',
  390. [ f'{addr},{rtFundAmt}', self.burn_addr ],
  391. utxo_nums,
  392. extra_args = [f'--keys-from-file={keyfile}'],
  393. skip_passphrase = skip_passphrase )
  394. def fund_bob2(self):
  395. return self.fund_wallet2( 'bob', f'{self._user_sid("bob")}:C:1', '1-11' )
  396. def fund_alice2(self):
  397. sid = self._user_sid('alice')
  398. mmtype = ('L','S')[self.proto.cap('segwit')]
  399. addr = self.get_addr_from_addrlist('alice',sid,mmtype,0,addr_range='1-5')
  400. return self.fund_wallet2( 'alice', addr, '1-11', skip_passphrase=True )
  401. async def bob_recreate_tracking_wallet(self):
  402. if not self.deterministic:
  403. return 'skip'
  404. self.spawn('',msg_only=True)
  405. from mmgen.base_proto.bitcoin.regtest import MMGenRegtest
  406. rt = MMGenRegtest(self.proto.coin)
  407. await rt.stop()
  408. from shutil import rmtree
  409. imsg(f'Deleting Bob’s old tracking wallet')
  410. rmtree(os.path.join(rt.d.datadir,'regtest','wallets','bob'),ignore_errors=True)
  411. rt.init_daemon()
  412. rt.d.start(silent=True)
  413. imsg(f'Creating Bob’s new tracking wallet')
  414. await rt.rpc_call('createwallet','bob',True,True,None,False,False,False)
  415. await rt.stop()
  416. await rt.start()
  417. return 'ok'
  418. def addrimport_bob2(self):
  419. if not self.deterministic:
  420. return 'skip'
  421. return self.addrimport('bob')
  422. def fund_wallet(self,user,mmtype,amt,sid=None,addr_range='1-5'):
  423. if self.deterministic:
  424. return 'skip'
  425. if not sid:
  426. sid = self._user_sid(user)
  427. addr = self.get_addr_from_addrlist(user,sid,mmtype,0,addr_range=addr_range)
  428. t = self.spawn('mmgen-regtest', ['send',str(addr),str(amt)])
  429. t.expect(f'Sending {amt} miner {self.proto.coin}')
  430. t.expect('Mined 1 block')
  431. return t
  432. def fund_bob(self):
  433. return self.fund_wallet('bob','C',rtFundAmt)
  434. def fund_alice(self):
  435. return self.fund_wallet('alice',('L','S')[self.proto.cap('segwit')],rtFundAmt)
  436. def user_twview(self,user,chk,sort='age'):
  437. t = self.spawn('mmgen-tool',['--'+user,'twview','sort='+sort])
  438. if chk:
  439. t.expect(r'{}\b.*\D{}\b'.format(*chk),regex=True)
  440. return t
  441. def bob_twview1(self): return self.user_twview('bob', chk = ('1',rtAmts[0]) )
  442. def user_bal(self,user,bal,args=['showempty=1'],skip_check=False):
  443. t = self.spawn('mmgen-tool',['--'+user,'listaddresses'] + args)
  444. if not skip_check:
  445. cmp_or_die(f'{bal} {self.proto.coin}',strip_ansi_escapes(t.expect_getend('TOTAL: ')))
  446. return t
  447. def alice_bal1(self):
  448. return self.user_bal('alice',rtFundAmt)
  449. def alice_bal2(self):
  450. return self.user_bal('alice',rtBals[8])
  451. def bob_bal1(self):
  452. return self.user_bal('bob',rtFundAmt)
  453. def bob_bal2(self):
  454. return self.user_bal('bob',rtBals[0])
  455. def bob_bal2a(self):
  456. return self.user_bal('bob',rtBals[0],args=['showempty=1','age_fmt=confs'])
  457. def bob_bal2b(self):
  458. return self.user_bal('bob',rtBals[0],args=['showempty=1'])
  459. def bob_bal2c(self):
  460. return self.user_bal('bob',rtBals[0],args=['showempty=1','minconf=2','age_fmt=days'],skip_check=True)
  461. def bob_bal2d(self):
  462. return self.user_bal('bob',rtBals[0],args=['minconf=2'],skip_check=True)
  463. def bob_bal2e(self):
  464. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age'])
  465. def bob_bal2f(self):
  466. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age,reverse'])
  467. def bob_bal3(self):
  468. return self.user_bal('bob',rtBals[1])
  469. def bob_bal4(self):
  470. return self.user_bal('bob',rtBals[2])
  471. def bob_bal5(self):
  472. return self.user_bal('bob',rtBals[3])
  473. def bob_bal6(self):
  474. return self.user_bal('bob',rtBals[7])
  475. def bob_subwallet_addrgen1(self):
  476. return self.addrgen('bob',subseed_idx='29L',mmtypes=['C']) # 29L: 2FA7BBA8
  477. def bob_subwallet_addrgen2(self):
  478. return self.addrgen('bob',subseed_idx='127S',mmtypes=['C']) # 127S: '09E8E286'
  479. def subwallet_addrimport(self,user,subseed_idx):
  480. sid = self._get_user_subsid(user,subseed_idx)
  481. return self.addrimport(user,sid=sid,mmtypes=['C'])
  482. def bob_subwallet_addrimport1(self): return self.subwallet_addrimport('bob','29L')
  483. def bob_subwallet_addrimport2(self): return self.subwallet_addrimport('bob','127S')
  484. def bob_subwallet_fund(self):
  485. sid1 = self._get_user_subsid('bob','29L')
  486. sid2 = self._get_user_subsid('bob','127S')
  487. chg_addr = self._user_sid('bob') + (':B:1',':L:1')[self.proto.coin=='BCH']
  488. outputs_cl = [sid1+':C:2,0.29',sid2+':C:3,0.127',chg_addr]
  489. inputs = ('3','1')[self.proto.coin=='BCH']
  490. return self.user_txdo('bob',rtFee[1],outputs_cl,inputs,extra_args=['--subseeds=127'])
  491. def bob_twview2(self):
  492. sid1 = self._get_user_subsid('bob','29L')
  493. return self.user_twview('bob',chk=(sid1+':C:2','0.29'),sort='twmmid')
  494. def bob_twview3(self):
  495. sid2 = self._get_user_subsid('bob','127S')
  496. return self.user_twview('bob',chk=(sid2+':C:3','0.127'),sort='amt')
  497. def bob_subwallet_txcreate(self):
  498. sid1 = self._get_user_subsid('bob','29L')
  499. sid2 = self._get_user_subsid('bob','127S')
  500. outputs_cl = [sid1+':C:5,0.0159',sid2+':C:5']
  501. t = self.spawn('mmgen-txcreate',['-d',self.tmpdir,'-B','--bob'] + outputs_cl)
  502. return self.txcreate_ui_common(t,
  503. menu = ['a'],
  504. inputs = ('1,2','2,3')[self.proto.coin=='BCH'],
  505. interactive_fee = '0.00001')
  506. def bob_subwallet_txsign(self):
  507. fn = get_file_with_ext(self.tmpdir,'rawtx')
  508. t = self.spawn('mmgen-txsign',['-d',self.tmpdir,'--bob','--subseeds=127',fn])
  509. t.view_tx('t')
  510. t.passphrase(dfl_wcls.desc,rt_pw)
  511. t.do_comment(None)
  512. t.expect('(Y/n): ','y')
  513. t.written_to_file('Signed transaction')
  514. return t
  515. def bob_subwallet_txdo(self):
  516. outputs_cl = [self._user_sid('bob')+':L:5']
  517. inputs = ('1,2','2,3')[self.proto.coin=='BCH']
  518. return self.user_txdo('bob',rtFee[5],outputs_cl,inputs,menu=['a'],extra_args=['--subseeds=127']) # sort: amt
  519. def bob_twview4(self):
  520. sid = self._user_sid('bob')
  521. amt = ('0.4169328','0.41364')[self.proto.coin=='LTC']
  522. return self.user_twview('bob',chk=(sid+':L:5',amt),sort='twmmid')
  523. def bob_getbalance(self,bals,confs=1):
  524. for i in (0,1,2):
  525. assert Decimal(bals['mmgen'][i]) + Decimal(bals['nonmm'][i]) == Decimal(bals['total'][i])
  526. t = self.spawn('mmgen-tool',['--bob','getbalance',f'minconf={confs}'])
  527. t.expect('Wallet')
  528. for k in ('mmgen','nonmm','total'):
  529. ret = strip_ansi_escapes(t.expect_getend(r'\S+: ',regex=True))
  530. cmp_or_die(
  531. ' '.join(bals[k]),
  532. re.sub(rf'\s+{self.proto.coin}\s*',' ',ret).strip(),
  533. desc=k,
  534. )
  535. return t
  536. def bob_0conf0_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf0'],confs=0)
  537. def bob_0conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf1'],confs=1)
  538. def bob_1conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf1'],confs=1)
  539. def bob_1conf2_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf2'],confs=2)
  540. def bob_alice_bal(self):
  541. t = self.spawn('mmgen-regtest',['balances'])
  542. ret = t.expect_getend("Bob's balance:").strip()
  543. cmp_or_die(rtBals[4],ret)
  544. ret = t.expect_getend("Alice's balance:").strip()
  545. cmp_or_die(rtBals[5],ret)
  546. ret = t.expect_getend("Total balance:").strip()
  547. cmp_or_die(rtBals[6],ret)
  548. return t
  549. def user_txsend_status(self,user,tx_file,exp1='',exp2='',extra_args=[]):
  550. t = self.spawn('mmgen-txsend',['-d',self.tmpdir,'--'+user,'--status'] + extra_args + [tx_file])
  551. if exp1: t.expect(exp1,regex=True)
  552. if exp2: t.expect(exp2,regex=True)
  553. return t
  554. def user_txdo( self, user, fee, outputs_cl, outputs_list,
  555. extra_args = [],
  556. wf = None,
  557. do_label = False,
  558. bad_locktime = False,
  559. full_tx_view = False,
  560. menu = ['M'],
  561. skip_passphrase = False ):
  562. t = self.spawn('mmgen-txdo',
  563. ['-d',self.tmpdir,'-B','--'+user] +
  564. (['--tx-fee='+fee] if fee else []) +
  565. extra_args + ([],[wf])[bool(wf)] + outputs_cl)
  566. self.txcreate_ui_common(t,
  567. caller = 'txdo',
  568. menu = menu,
  569. inputs = outputs_list,
  570. file_desc = 'Signed transaction',
  571. interactive_fee = (tx_fee,'')[bool(fee)],
  572. add_comment = tx_label_jp,
  573. view = 't',save=True)
  574. if not skip_passphrase:
  575. t.passphrase(dfl_wcls.desc,rt_pw)
  576. t.written_to_file('Signed transaction')
  577. self._do_confirm_send(t)
  578. s,exit_val = (('Transaction sent',0),("can't be included",1))[bad_locktime]
  579. t.expect(s)
  580. t.req_exit_val = exit_val
  581. return t
  582. def bob_split1(self):
  583. sid = self._user_sid('bob')
  584. outputs_cl = [sid+':C:1,100', sid+':L:2,200',sid+':'+rtBobOp3]
  585. return self.user_txdo('bob',rtFee[0],outputs_cl,'1',do_label=True,full_tx_view=True)
  586. def get_addr_from_addrlist(self,user,sid,mmtype,idx,addr_range='1-5'):
  587. id_str = { 'L':'', 'S':'-S', 'C':'-C', 'B':'-B' }[mmtype]
  588. ext = '{}{}{}[{}]{x}.regtest.addrs'.format(
  589. sid,self.altcoin_pfx,id_str,addr_range,x='-α' if g.debug_utf8 else '')
  590. addrfile = get_file_with_ext(self._user_dir(user),ext,no_dot=True)
  591. silence()
  592. addr = AddrList(self.proto,addrfile).data[idx].addr
  593. end_silence()
  594. return addr
  595. def _create_tx_outputs(self,user,data):
  596. sid = self._user_sid(user)
  597. return [self.get_addr_from_addrlist(user,sid,mmtype,idx-1)+amt_str for mmtype,idx,amt_str in data]
  598. def bob_rbf_1output_create(self):
  599. if not self.test_rbf:
  600. return 'skip'
  601. out_addr = self._create_tx_outputs('alice',(('B',5,''),))
  602. t = self.spawn('mmgen-txcreate',['-d',self.tr.trash_dir,'-B','--bob','--rbf'] + out_addr)
  603. return self.txcreate_ui_common(t,menu=[],inputs='3',interactive_fee='3s') # out amt: 199.99999343
  604. def bob_rbf_1output_bump(self):
  605. if not self.test_rbf:
  606. return 'skip'
  607. ext = '9343,3]{x}.regtest.rawtx'.format(x='-α' if g.debug_utf8 else '')
  608. txfile = get_file_with_ext(self.tr.trash_dir,ext,delete=False,no_dot=True)
  609. return self.user_txbump('bob',
  610. self.tr.trash_dir,
  611. txfile,
  612. '8s',
  613. has_label = False,
  614. signed_tx = False,
  615. one_output = True )
  616. def bob_send_maybe_rbf(self):
  617. outputs_cl = self._create_tx_outputs('alice',(('L',1,',60'),('C',1,',40'))) # alice_sid:L:1, alice_sid:C:1
  618. outputs_cl += [self._user_sid('bob')+':'+rtBobOp3]
  619. return self.user_txdo('bob',rtFee[1],outputs_cl,'3',
  620. extra_args=([],['--rbf'])[self.proto.cap('rbf')])
  621. def bob_send_non_mmgen(self):
  622. outputs_cl = self._create_tx_outputs('alice',(
  623. (('L','S')[self.proto.cap('segwit')],2,',10'),
  624. (('L','S')[self.proto.cap('segwit')],3,'')
  625. )) # alice_sid:S:2, alice_sid:S:3
  626. keyfile = joinpath(self.tmpdir,'non-mmgen.keys')
  627. return self.user_txdo('bob',rtFee[3],outputs_cl,'1,4-10',
  628. extra_args=['--keys-from-file='+keyfile,'--vsize-adj=1.02'])
  629. def alice_send_estimatefee(self):
  630. outputs_cl = self._create_tx_outputs('bob',(('L',1,''),)) # bob_sid:L:1
  631. return self.user_txdo('alice',None,outputs_cl,'1') # fee=None
  632. def user_txbump(self,user,outdir,txfile,fee,add_args=[],has_label=True,signed_tx=True,one_output=False):
  633. if not self.proto.cap('rbf'):
  634. return 'skip'
  635. t = self.spawn('mmgen-txbump',
  636. ['-d',outdir,'--'+user,'--tx-fee='+fee,'--output-to-reduce=c'] + add_args + [txfile])
  637. if not one_output:
  638. t.expect('OK? (Y/n): ','y') # output OK?
  639. t.expect('OK? (Y/n): ','y') # fee OK?
  640. t.do_comment(False,has_label=has_label)
  641. if signed_tx:
  642. t.passphrase(dfl_wcls.desc,rt_pw)
  643. t.written_to_file('Signed transaction')
  644. self.txsend_ui_common(t,caller='txdo',bogus_send=False,file_desc='Signed transaction')
  645. else:
  646. t.expect('Save fee-bumped transaction? (y/N): ','y')
  647. t.written_to_file('Fee-bumped transaction')
  648. return t
  649. def bob_rbf_bump(self):
  650. ext = ',{}]{x}.regtest.sigtx'.format(rtFee[1][:-1],x='-α' if g.debug_utf8 else '')
  651. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  652. return self.user_txbump('bob',self.tmpdir,txfile,rtFee[2],add_args=['--send'])
  653. def generate(self,coin=None,num_blocks=1):
  654. int(num_blocks)
  655. t = self.spawn('mmgen-regtest',['generate',str(num_blocks)])
  656. t.expect(f'Mined {num_blocks} block')
  657. return t
  658. def _get_mempool(self):
  659. if not g.debug_utf8:
  660. disable_debug()
  661. ret = self.spawn('mmgen-regtest',['mempool']).read()
  662. if not g.debug_utf8:
  663. restore_debug()
  664. m = re.search(r'(\[\s*"[a-f0-9]{64}"\s*])',ret) # allow for extra output by handler at end
  665. return json.loads(m.group(1))
  666. def get_mempool1(self):
  667. mp = self._get_mempool()
  668. if len(mp) != 1:
  669. die(4,'Mempool has more or less than one TX!')
  670. self.write_to_tmpfile('rbf_txid',mp[0]+'\n')
  671. return 'ok'
  672. def bob_rbf_status(self,fee,exp1,exp2=''):
  673. if not self.proto.cap('rbf'):
  674. return 'skip'
  675. ext = ',{}]{x}.regtest.sigtx'.format(fee[:-1],x='-α' if g.debug_utf8 else '')
  676. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  677. return self.user_txsend_status('bob',txfile,exp1,exp2)
  678. def bob_rbf_status1(self):
  679. if not self.proto.cap('rbf'):
  680. return 'skip'
  681. return self.bob_rbf_status(rtFee[1],'in mempool, replaceable')
  682. def get_mempool2(self):
  683. if not self.proto.cap('rbf'):
  684. return 'skip'
  685. mp = self._get_mempool()
  686. if len(mp) != 1:
  687. die(4,'Mempool has more or less than one TX!')
  688. chk = self.read_from_tmpfile('rbf_txid')
  689. if chk.strip() == mp[0]:
  690. die(4,'TX in mempool has not changed! RBF bump failed')
  691. self.write_to_tmpfile('rbf_txid2',mp[0]+'\n')
  692. return 'ok'
  693. def bob_rbf_status2(self):
  694. if not self.proto.cap('rbf'):
  695. return 'skip'
  696. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  697. return self.bob_rbf_status(rtFee[1],
  698. 'Transaction has been replaced',f'{new_txid} in mempool')
  699. def bob_rbf_status3(self):
  700. if not self.proto.cap('rbf'):
  701. return 'skip'
  702. return self.bob_rbf_status(rtFee[2],'status: in mempool, replaceable')
  703. def bob_rbf_status4(self):
  704. if not self.proto.cap('rbf'):
  705. return 'skip'
  706. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  707. return self.bob_rbf_status(rtFee[1],
  708. 'Replacement transaction has 1 confirmation',
  709. f'Replacing transactions:\s+{new_txid}' )
  710. def bob_rbf_status5(self):
  711. if not self.proto.cap('rbf'):
  712. return 'skip'
  713. return self.bob_rbf_status(rtFee[2],'Transaction has 1 confirmation')
  714. def bob_rbf_status6(self):
  715. if not self.proto.cap('rbf'):
  716. return 'skip'
  717. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  718. return self.bob_rbf_status(rtFee[1],
  719. 'Replacement transaction has 2 confirmations',
  720. f'Replacing transactions:\s+{new_txid}' )
  721. def _gen_pairs(self,n):
  722. from mmgen.tool.api import tool_api
  723. t = tool_api()
  724. t.init_coin(self.proto.coin,self.proto.network)
  725. def gen_addr(Type):
  726. t.addrtype = Type
  727. wif = t.hex2wif(getrandhex(32))
  728. return ( wif, t.wif2addr(wif) )
  729. return [gen_addr('legacy')] + [gen_addr('compressed') for i in range(n-1)]
  730. def bob_pre_import(self):
  731. pairs = self._gen_pairs(5)
  732. self.write_to_tmpfile('non-mmgen.keys','\n'.join([a[0] for a in pairs])+'\n')
  733. self.write_to_tmpfile('non-mmgen.addrs','\n'.join([a[1] for a in pairs])+'\n')
  734. return self.user_txdo('bob',rtFee[4],[pairs[0][1]],'3')
  735. def user_import(self,user,args):
  736. t = self.spawn('mmgen-addrimport',['--'+user]+args)
  737. if g.debug:
  738. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  739. t.expect('Importing')
  740. t.expect('OK')
  741. return t
  742. def bob_import_addr(self):
  743. addr = self.read_from_tmpfile('non-mmgen.addrs').split()[0]
  744. return self.user_import('bob',['--quiet','--address='+addr])
  745. def bob_import_list(self):
  746. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  747. return self.user_import('bob',['--quiet','--addrlist',addrfile])
  748. def bob_import_list_rescan(self):
  749. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  750. return self.user_import('bob',['--quiet','--rescan','--addrlist',addrfile])
  751. def bob_split2(self):
  752. addrs = self.read_from_tmpfile('non-mmgen.addrs').split()
  753. amts = (1.12345678,2.87654321,3.33443344,4.00990099,5.43214321)
  754. outputs1 = list(map('{},{}'.format,addrs,amts))
  755. sid = self._user_sid('bob')
  756. l1,l2 = (
  757. (':S',':B') if 'B' in self.proto.mmtypes else
  758. (':S',':S') if self.proto.cap('segwit') else
  759. (':L',':L') )
  760. outputs2 = [sid+':C:2,6.333', sid+':L:3,6.667',sid+l1+':4,0.123',sid+l2+':5']
  761. return self.user_txdo('bob',rtFee[5],outputs1+outputs2,'1-2')
  762. def user_add_label(self,user,addr,label):
  763. t = self.spawn('mmgen-tool',['--'+user,'add_label',addr,label])
  764. t.expect('Added label.*in tracking wallet',regex=True)
  765. return t
  766. def user_remove_label(self,user,addr):
  767. t = self.spawn('mmgen-tool',['--'+user,'remove_label',addr])
  768. t.expect('Removed label.*in tracking wallet',regex=True)
  769. return t
  770. def bob_add_label(self):
  771. sid = self._user_sid('bob')
  772. return self.user_add_label('bob',sid+':C:1',tw_label_lat_cyr_gr)
  773. def alice_add_label1(self):
  774. sid = self._user_sid('alice')
  775. return self.user_add_label('alice',sid+':C:1','Original Label - 月へ')
  776. def alice_add_label2(self):
  777. sid = self._user_sid('alice')
  778. return self.user_add_label('alice',sid+':C:1','Replacement Label')
  779. def _user_chk_label(self,user,addr,label):
  780. t = self.spawn('mmgen-tool',['--'+user,'listaddresses','all_labels=1'])
  781. ret = strip_ansi_escapes(t.expect_getend(addr)).strip().split(None,1)[1]
  782. cmp_or_die(ret[:len(label)],label)
  783. return t
  784. def alice_add_label_coinaddr(self):
  785. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  786. t = self.spawn('mmgen-tool',['--alice','listaddress',mmid],no_msg=True)
  787. addr = [i for i in strip_ansi_escapes(t.read()).splitlines() if i.startswith(mmid)][0].split()[1]
  788. return self.user_add_label('alice',addr,'Label added using coin address of MMGen address')
  789. def alice_chk_label_coinaddr(self):
  790. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  791. return self._user_chk_label('alice',mmid,'Label added using coin address of MMGen address')
  792. def alice_add_label_badaddr(self,addr,reply):
  793. if os.getenv('PYTHONOPTIMIZE'):
  794. omsg(yellow(f'PYTHONOPTIMIZE set, skipping test {self.test_name!r}'))
  795. return 'skip'
  796. t = self.spawn('mmgen-tool',['--alice','add_label',addr,'(none)'])
  797. t.expect(reply,regex=True)
  798. return t
  799. def alice_add_label_badaddr1(self):
  800. return self.alice_add_label_badaddr( rt_pw,'Invalid coin address for this chain: ')
  801. def alice_add_label_badaddr2(self):
  802. addr = init_proto(self.proto.coin,network='mainnet').pubhash2addr(bytes(20),False) # mainnet zero address
  803. return self.alice_add_label_badaddr( addr, f'Invalid coin address for this chain: {addr}' )
  804. def alice_add_label_badaddr3(self):
  805. addr = self._user_sid('alice') + ':C:123'
  806. return self.alice_add_label_badaddr( addr, f'MMGen address {addr!r} not found in tracking wallet' )
  807. def alice_add_label_badaddr4(self):
  808. addr = self.proto.pubhash2addr(bytes(20),False) # regtest (testnet) zero address
  809. return self.alice_add_label_badaddr( addr, f'Address {addr!r} not found in tracking wallet' )
  810. def alice_remove_label1(self):
  811. sid = self._user_sid('alice')
  812. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  813. return self.user_remove_label('alice',mmid)
  814. def alice_chk_label1(self):
  815. sid = self._user_sid('alice')
  816. return self._user_chk_label('alice',sid+':C:1','Original Label - 月へ')
  817. def alice_chk_label2(self):
  818. sid = self._user_sid('alice')
  819. return self._user_chk_label('alice',sid+':C:1','Replacement Label')
  820. def alice_edit_label1(self): return self.user_edit_label('alice','4',tw_label_lat_cyr_gr)
  821. def alice_edit_label2(self): return self.user_edit_label('alice','3',tw_label_zh)
  822. def alice_chk_label3(self):
  823. sid = self._user_sid('alice')
  824. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  825. return self._user_chk_label('alice',mmid,tw_label_lat_cyr_gr)
  826. def alice_chk_label4(self):
  827. sid = self._user_sid('alice')
  828. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  829. return self._user_chk_label('alice',mmid,'-')
  830. def user_edit_label(self,user,output,label):
  831. t = self.spawn('mmgen-txcreate',['-B','--'+user,'-i'])
  832. t.expect(r'add \[l\]abel:.','M',regex=True)
  833. t.expect(r'add \[l\]abel:.','l',regex=True)
  834. t.expect(r"Enter unspent.*return to main menu\):.",output+'\n',regex=True)
  835. t.expect(r"Enter label text.*return to main menu\):.",label+'\n',regex=True)
  836. t.expect(r'\[q\]uit view, .*?:.','q',regex=True)
  837. return t
  838. def alice_listaddresses(self,args,expect):
  839. t = self.spawn('mmgen-tool',['--alice','listaddresses','showempty=1'] + args)
  840. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  841. t.expect(expect_str,regex=True)
  842. return t
  843. def alice_listaddresses1(self):
  844. return self.alice_listaddresses(
  845. args = [],
  846. expect = (rtAmts[1],r'\d+') )
  847. def alice_listaddresses_days(self):
  848. return self.alice_listaddresses(
  849. args = ['age_fmt=days'],
  850. expect = (rtAmts[1],r'\d+') )
  851. def alice_listaddresses_date(self):
  852. return self.alice_listaddresses(
  853. args = ['age_fmt=date'],
  854. expect = (rtAmts[1],pat_date) )
  855. def alice_listaddresses_date_time(self):
  856. return self.alice_listaddresses(
  857. args = ['age_fmt=date_time'],
  858. expect = (rtAmts[1],pat_date_time) )
  859. def alice_twview(self,args,expect):
  860. t = self.spawn('mmgen-tool',['--alice','twview'] + args)
  861. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  862. t.expect(expect_str,regex=True)
  863. return t
  864. def alice_twview1(self):
  865. return self.alice_twview(
  866. args = [],
  867. expect = (rtAmts[0],r'\d+') )
  868. def alice_twview_days(self):
  869. return self.alice_twview(
  870. args = ['age_fmt=days'],
  871. expect = (rtAmts[0],r'\d+') )
  872. def alice_twview_date(self):
  873. return self.alice_twview(
  874. args = ['age_fmt=date'],
  875. expect = (rtAmts[0],pat_date) )
  876. def alice_twview_date_time(self):
  877. return self.alice_twview(
  878. args = ['age_fmt=date_time'],
  879. expect = (rtAmts[0],pat_date_time) )
  880. def alice_txcreate_info(self,args=[]):
  881. t = self.spawn('mmgen-txcreate',['--alice','-Bi'])
  882. pats = (
  883. ( '\d+', 'D'),
  884. ( '\d+', 'D'),
  885. ( '\d+', 'D'),
  886. ( pat_date, 'q'),
  887. ) if opt.pexpect_spawn else (
  888. ( '\d+', 'D'),
  889. ( '\d+', 'D'),
  890. ( '\d+', 'D'),
  891. ( pat_date, 'w'),
  892. ( '\d+\s+\d+\s+'+pat_date_time,'q'),
  893. )
  894. for d,s in pats:
  895. t.expect(
  896. r'\D{}\D.*\b{}\b'.format( rtAmts[0], d ),
  897. s,
  898. regex=True )
  899. return t
  900. def bob_msgcreate(self):
  901. sid1 = self._user_sid('bob')
  902. sid2 = self._get_user_subsid('bob','29L')
  903. return self.spawn(
  904. 'mmgen-msg', [
  905. '--bob',
  906. f'--outdir={self.tmpdir}',
  907. 'create',
  908. '16/3/2022 Earthquake strikes Fukushima coast',
  909. f'{sid1}:{self.dfl_mmtype}:1-4',
  910. f'{sid2}:C:3-7,87,98'
  911. ])
  912. def bob_msgsign(self,wallets=[]):
  913. fn = get_file_with_ext(self.tmpdir,'rawmsg.json')
  914. t = self.spawn(
  915. 'mmgen-msg', [
  916. '--bob',
  917. f'--outdir={self.tmpdir}',
  918. 'sign',
  919. fn
  920. ] + wallets )
  921. if not wallets:
  922. t.passphrase(dfl_wcls.desc,rt_pw)
  923. return t
  924. def bob_walletconv_words(self):
  925. t = self.spawn(
  926. 'mmgen-walletconv', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=words' ] )
  927. t.passphrase(dfl_wcls.desc,rt_pw)
  928. t.written_to_file('data')
  929. return t
  930. def bob_subwalletgen_bip39(self):
  931. t = self.spawn(
  932. 'mmgen-subwalletgen', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=bip39', '29L' ] )
  933. t.passphrase(dfl_wcls.desc,rt_pw)
  934. t.written_to_file('data')
  935. return t
  936. def bob_msgsign_userwallet(self):
  937. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  938. return self.bob_msgsign([fn1])
  939. def bob_msgsign_userwallets(self):
  940. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  941. fn2 = get_file_with_ext(self.tmpdir,'bip39')
  942. return self.bob_msgsign([fn2,fn1])
  943. def bob_msgverify(self,addr=None,ext='sigmsg.json',cmd='verify'):
  944. return self.spawn(
  945. 'mmgen-msg', [
  946. '--bob',
  947. f'--outdir={self.tmpdir}',
  948. cmd,
  949. get_file_with_ext(self.tmpdir,ext),
  950. ] + ([addr] if addr else []) )
  951. def bob_msgverify_raw(self):
  952. t = self.bob_msgverify(ext='rawmsg.json')
  953. t.req_exit_val = 1
  954. return t
  955. def bob_msgverify_single(self):
  956. sid = self._user_sid('bob')
  957. return self.bob_msgverify(addr=f'{sid}:{self.dfl_mmtype}:1')
  958. def bob_msgexport(self,addr=None):
  959. t = self.bob_msgverify( addr=addr, cmd='export' )
  960. t.written_to_file('data')
  961. return t
  962. def bob_msgexport_single(self):
  963. sid = self._user_sid('bob')
  964. return self.bob_msgexport(addr=f'{sid}:{self.dfl_mmtype}:1')
  965. def stop(self):
  966. if opt.no_daemon_stop:
  967. self.spawn('',msg_only=True)
  968. msg_r('(leaving daemon running by user request)')
  969. return 'ok'
  970. else:
  971. return self.spawn('mmgen-regtest',['stop'])