ts_regtest.py 49 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325
  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','0.4169328','6.24987417'),
  47. 'bch': ('499.9999484','399.9999194','399.9998972','399.9997692',
  48. '46.78890380','953.20966920','999.99857300','46.789',
  49. '953.2096692','0.4169328','39.58187387'),
  50. 'ltc': ('5499.99744','5399.994425','5399.993885','5399.987535',
  51. '52.98520500','10946.93753500','10999.92274000','52.99',
  52. '10946.937535','0.41364','6.24846787'),
  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 make_burn_addr(proto):
  130. from mmgen.tool.coin import tool_cmd
  131. return tool_cmd(
  132. cmdname = 'pubhash2addr',
  133. proto = proto,
  134. mmtype = 'compressed' ).pubhash2addr('00'*20)
  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_bob_deterministic', "funding Bob’s first MMGen address (deterministic method)"),
  158. ('fund_alice_deterministic', "funding Alice’s first MMGen address (deterministic method)"),
  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'),
  194. ('bob_bal4', "Bob's balance (after import)"),
  195. ('bob_import_list', 'importing flat address list'),
  196. ('bob_import_list_rescan', 'importing flat address list with --rescan'),
  197. ('bob_import_list_rescan_aio','importing flat address list with --rescan (aiohttp backend)'),
  198. ('bob_resolve_addr', 'resolving an address in the tracking wallet'),
  199. ('bob_rescan_addr', 'rescanning an address'),
  200. ('bob_rescan_blockchain_all','rescanning the blockchain (full rescan)'),
  201. ('bob_rescan_blockchain_gb', 'rescanning the blockchain (Genesis block)'),
  202. ('bob_rescan_blockchain_one','rescanning the blockchain (single block)'),
  203. ('bob_rescan_blockchain_ss', 'rescanning the blockchain (range of blocks)'),
  204. ('bob_twexport', 'exporting a tracking wallet to JSON'),
  205. ('carol_twimport', 'importing a tracking wallet JSON dump'),
  206. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  207. ('bob_twexport_noamt', 'exporting a tracking wallet to JSON (include_amts=0)'),
  208. ('carol_twimport_nochksum', 'importing a tracking wallet JSON dump (ignore_checksum=1)'),
  209. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  210. ('carol_twimport_batch', 'importing a tracking wallet JSON dump (batch=1)'),
  211. ('bob_twexport_pretty', 'exporting a tracking wallet to JSON (pretty=1)'),
  212. ('bob_edit_json_twdump', 'editing a tracking wallet JSON dump'),
  213. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  214. ('carol_twimport_pretty', 'importing an edited tracking wallet JSON dump (ignore_checksum=1)'),
  215. ('carol_listaddresses', 'viewing Carol’s tracking wallet'),
  216. ('bob_split2', "splitting Bob's funds"),
  217. ('bob_0conf0_getbalance', "Bob's balance (unconfirmed, minconf=0)"),
  218. ('bob_0conf1_getbalance', "Bob's balance (unconfirmed, minconf=1)"),
  219. ('generate', 'mining a block'),
  220. ('bob_1conf1_getbalance', "Bob's balance (confirmed, minconf=1)"),
  221. ('bob_1conf2_getbalance', "Bob's balance (confirmed, minconf=2)"),
  222. ('bob_bal5', "Bob's balance"),
  223. ('bob_send_non_mmgen', 'sending funds to Alice (from non-MMGen addrs)'),
  224. ('generate', 'mining a block'),
  225. ('alice_send_estimatefee', 'tx creation with no fee on command line'),
  226. ('generate', 'mining a block'),
  227. ('bob_bal6', "Bob's balance"),
  228. ('bob_subwallet_addrgen1', "generating Bob's addrs from subwallet 29L"),
  229. ('bob_subwallet_addrgen2', "generating Bob's addrs from subwallet 127S"),
  230. ('bob_subwallet_addrimport1', "importing Bob's addrs from subwallet 29L"),
  231. ('bob_subwallet_addrimport2', "importing Bob's addrs from subwallet 127S"),
  232. ('bob_subwallet_fund', "funding Bob's subwallet addrs"),
  233. ('generate', 'mining a block'),
  234. ('bob_twview2', "viewing Bob's tracking wallet"),
  235. ('bob_twview3', "viewing Bob's tracking wallet"),
  236. ('bob_subwallet_txcreate', 'creating a transaction with subwallet inputs'),
  237. ('bob_subwallet_txsign', 'signing a transaction with subwallet inputs'),
  238. ('bob_subwallet_txdo', "sending from Bob's subwallet addrs"),
  239. ('generate', 'mining a block'),
  240. ('bob_twview4', "viewing Bob's tracking wallet"),
  241. ('bob_alice_bal', "Bob and Alice's balances"),
  242. ('bob_nochg_burn', 'zero-change transaction to burn address'),
  243. ('generate', 'mining a block'),
  244. ('bob_txhist1', "viewing Bob's transaction history (sort=age)"),
  245. ('bob_txhist2', "viewing Bob's transaction history (sort=blockheight reverse=1)"),
  246. ('bob_txhist3', "viewing Bob's transaction history (sort=blockheight sinceblock=-7)"),
  247. ('bob_txhist4', "viewing Bob's transaction history (sinceblock=399 detail=1)"),
  248. ('bob_txhist_interactive', "viewing Bob's transaction history (age_fmt=date_time interactive=true)"),
  249. ('alice_bal2', "Alice's balance"),
  250. ('alice_add_label1', 'adding a label'),
  251. ('alice_chk_label1', 'the label'),
  252. ('alice_add_label2', 'adding a label'),
  253. ('alice_chk_label2', 'the label'),
  254. ('alice_edit_label1', 'editing a label (zh)'),
  255. ('alice_edit_label2', 'editing a label (lat+cyr+gr)'),
  256. ('alice_chk_label3', 'the label'),
  257. ('alice_remove_label1', 'removing a label'),
  258. ('alice_chk_label4', 'the label'),
  259. ('alice_add_label_coinaddr', 'adding a label using the coin address'),
  260. ('alice_chk_label_coinaddr', 'the label'),
  261. ('alice_add_label_badaddr1', 'adding a label with invalid address'),
  262. ('alice_add_label_badaddr2', 'adding a label with invalid address for this chain'),
  263. ('alice_add_label_badaddr3', 'adding a label with wrong MMGen address'),
  264. ('alice_add_label_badaddr4', 'adding a label with wrong coin address'),
  265. ('alice_listaddresses1', 'listaddresses'),
  266. ('alice_listaddresses_days', 'listaddresses (age_fmt=days)'),
  267. ('alice_listaddresses_date', 'listaddresses (age_fmt=date)'),
  268. ('alice_listaddresses_date_time', 'listaddresses (age_fmt=date_time)'),
  269. ('alice_twview1', 'twview'),
  270. ('alice_twview_days', 'twview (age_fmt=days)'),
  271. ('alice_twview_date', 'twview (age_fmt=date)'),
  272. ('alice_twview_date_time', 'twview (age_fmt=date_time)'),
  273. ('alice_txcreate_info', 'txcreate -i'),
  274. ('bob_msgcreate', 'creating a message file for signing'),
  275. ('bob_msgsign', 'signing the message file (default wallet)'),
  276. ('bob_walletconv_words', 'creating an MMGen mnemonic wallet'),
  277. ('bob_subwalletgen_bip39', 'creating a BIP39 mnemonic subwallet'),
  278. ('bob_msgsign_userwallet', 'signing the message file (user-specified wallet)'),
  279. ('bob_msgsign_userwallets', 'signing the message file (user-specified wallets)'),
  280. ('bob_msgverify', 'verifying the message file (all addresses)'),
  281. ('bob_msgverify_raw', 'verifying the raw message file (all addresses)'),
  282. ('bob_msgverify_single', 'verifying the message file (single address)'),
  283. ('bob_msgexport_single', 'exporting the message file (single address)'),
  284. ('bob_msgexport', 'exporting the message file (all addresses)'),
  285. ('bob_msgverify_export', 'verifying the exported JSON data (all addresses)'),
  286. ('bob_msgverify_export_single','verifying the exported JSON data (single address)'),
  287. ('stop', 'stopping regtest daemon'),
  288. )
  289. def __init__(self,trunner,cfgs,spawn):
  290. TestSuiteBase.__init__(self,trunner,cfgs,spawn)
  291. if trunner == None:
  292. return
  293. if self.proto.testnet:
  294. die(2,'--testnet and --regtest options incompatible with regtest test suite')
  295. self.proto = init_proto(self.proto.coin,network='regtest',need_amt=True)
  296. coin = self.proto.coin.lower()
  297. import test.test_py_d.ts_regtest as rt_mod
  298. for k in rt_data:
  299. setattr( rt_mod, k, rt_data[k][coin] if coin in rt_data[k] else None )
  300. if self.proto.coin == 'BTC':
  301. self.test_rbf = True # tests are non-coin-dependent, so run just once for BTC
  302. if g.test_suite_deterministic:
  303. self.deterministic = True
  304. self.miner_addr = 'bcrt1qaq8t3pakcftpk095tnqfv5cmmczysls024atnd' # regtest.create_hdseed()
  305. self.miner_wif = 'cTyMdQ2BgfAsjopRVZrj7AoEGp97pKfrC2NkqLuwHr4KHfPNAKwp'
  306. os.environ['MMGEN_BOGUS_SEND'] = ''
  307. os.environ['MMGEN_TEST_SUITE_REGTEST'] = '1'
  308. self.write_to_tmpfile('wallet_password',rt_pw)
  309. self.dfl_mmtype = 'C' if self.proto.coin == 'BCH' else 'B'
  310. def __del__(self):
  311. os.environ['MMGEN_BOGUS_SEND'] = '1'
  312. os.environ['MMGEN_TEST_SUITE_REGTEST'] = ''
  313. def _add_comments_to_addr_file(self,addrfile,outfile,use_labels=False):
  314. silence()
  315. gmsg(f'Adding comments to address file {addrfile!r}')
  316. a = AddrList(self.proto,addrfile)
  317. for n,idx in enumerate(a.idxs(),1):
  318. if use_labels:
  319. a.set_comment(idx,get_label())
  320. else:
  321. if n % 2: a.set_comment(idx,f'Test address {n}')
  322. af = a.get_file()
  323. af.format(add_comments=True)
  324. from mmgen.fileutil import write_data_to_file
  325. write_data_to_file(outfile,af.fmt_data,quiet=True,ignore_opt_outdir=True)
  326. end_silence()
  327. def setup(self):
  328. stop_test_daemons(self.proto.network_id,force=True,remove_datadir=True)
  329. from shutil import rmtree
  330. try: rmtree(joinpath(self.tr.data_dir,'regtest'))
  331. except: pass
  332. t = self.spawn('mmgen-regtest',['-n','setup'])
  333. for s in ('Starting','Creating','Creating','Creating','Mined','Setup complete'):
  334. t.expect(s)
  335. return t
  336. def daemon_version(self):
  337. t = self.spawn('mmgen-tool', ['--bob','daemon_version'])
  338. t.expect('version')
  339. return t
  340. def halving_calculator_bob(self):
  341. t = self.spawn('halving-calculator.py',['--bob'],cmd_dir='examples')
  342. t.expect('time until halving')
  343. return t
  344. def walletgen(self,user):
  345. t = self.spawn('mmgen-walletgen',['-q','-r0','-p1','--'+user])
  346. t.passphrase_new('new '+dfl_wcls.desc,rt_pw)
  347. t.label()
  348. t.expect('move it to the data directory? (Y/n): ','y')
  349. t.written_to_file(capfirst(dfl_wcls.desc))
  350. return t
  351. def walletgen_bob(self): return self.walletgen('bob')
  352. def walletgen_alice(self): return self.walletgen('alice')
  353. def _user_dir(self,user,coin=None):
  354. return joinpath(self.tr.data_dir,'regtest',coin or self.proto.coin.lower(),user)
  355. def _user_sid(self,user):
  356. return os.path.basename(get_file_with_ext(self._user_dir(user),'mmdat'))[:8]
  357. def _get_user_subsid(self,user,subseed_idx):
  358. fn = get_file_with_ext(self._user_dir(user),dfl_wcls.ext)
  359. silence()
  360. w = Wallet( fn=fn, passwd_file=os.path.join(self.tmpdir,'wallet_password') )
  361. end_silence()
  362. return w.seed.subseed(subseed_idx).sid
  363. def addrgen(self,user,wf=None,addr_range='1-5',subseed_idx=None,mmtypes=[]):
  364. from mmgen.addr import MMGenAddrType
  365. for mmtype in mmtypes or self.proto.mmtypes:
  366. t = self.spawn('mmgen-addrgen',
  367. ['--quiet','--'+user,'--type='+mmtype,f'--outdir={self._user_dir(user)}'] +
  368. ([wf] if wf else []) +
  369. (['--subwallet='+subseed_idx] if subseed_idx else []) +
  370. [addr_range],
  371. extra_desc='({})'.format( MMGenAddrType.mmtypes[mmtype].name ))
  372. t.passphrase(dfl_wcls.desc,rt_pw)
  373. t.written_to_file('Addresses')
  374. ok_msg()
  375. t.skip_ok = True
  376. return t
  377. def addrgen_bob(self): return self.addrgen('bob')
  378. def addrgen_alice(self): return self.addrgen('alice')
  379. def addrimport(self,user,sid=None,addr_range='1-5',num_addrs=5,mmtypes=[],batch=True,quiet=True):
  380. id_strs = { 'legacy':'', 'compressed':'-C', 'segwit':'-S', 'bech32':'-B' }
  381. if not sid: sid = self._user_sid(user)
  382. from mmgen.addr import MMGenAddrType
  383. for mmtype in mmtypes or self.proto.mmtypes:
  384. desc = MMGenAddrType.mmtypes[mmtype].name
  385. addrfile = joinpath(self._user_dir(user),
  386. '{}{}{}[{}]{x}.regtest.addrs'.format(
  387. sid,self.altcoin_pfx,id_strs[desc],addr_range,
  388. x='-α' if g.debug_utf8 else ''))
  389. if mmtype == self.proto.mmtypes[0] and user == 'bob':
  390. self._add_comments_to_addr_file(addrfile,addrfile,use_labels=True)
  391. t = self.spawn(
  392. 'mmgen-addrimport',
  393. args = (
  394. (['--quiet'] if quiet else []) +
  395. ['--'+user] +
  396. (['--batch'] if batch else []) +
  397. [addrfile] ),
  398. extra_desc = f'({desc})' )
  399. if g.debug:
  400. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  401. t.expect('Importing')
  402. if batch:
  403. t.expect(f'{num_addrs} addresses imported')
  404. else:
  405. t.expect(f'import completed OK')
  406. t.ok()
  407. t.skip_ok = True
  408. return t
  409. def addrimport_bob(self): return self.addrimport('bob')
  410. def addrimport_alice(self): return self.addrimport('alice',batch=False,quiet=False)
  411. def bob_import_miner_addr(self):
  412. if not self.deterministic:
  413. return 'skip'
  414. return self.spawn(
  415. 'mmgen-addrimport',
  416. [ '--bob', '--rescan', '--quiet', f'--address={self.miner_addr}' ] )
  417. def fund_wallet_deterministic(self,user,addr,utxo_nums,skip_passphrase=False):
  418. """
  419. the deterministic funding method using specific inputs
  420. """
  421. if not self.deterministic:
  422. return 'skip'
  423. self.write_to_tmpfile('miner.key',f'{self.miner_wif}\n')
  424. keyfile = joinpath(self.tmpdir,'miner.key')
  425. return self.user_txdo(
  426. 'bob', '40s',
  427. [ f'{addr},{rtFundAmt}', make_burn_addr(self.proto) ],
  428. utxo_nums,
  429. extra_args = [f'--keys-from-file={keyfile}'],
  430. skip_passphrase = skip_passphrase )
  431. def fund_bob_deterministic(self):
  432. return self.fund_wallet_deterministic( 'bob', f'{self._user_sid("bob")}:C:1', '1-11' )
  433. def fund_alice_deterministic(self):
  434. sid = self._user_sid('alice')
  435. mmtype = ('L','S')[self.proto.cap('segwit')]
  436. addr = self.get_addr_from_addrlist('alice',sid,mmtype,0,addr_range='1-5')
  437. return self.fund_wallet_deterministic( 'alice', addr, '1-11', skip_passphrase=True )
  438. async def bob_recreate_tracking_wallet(self):
  439. if not self.deterministic:
  440. return 'skip'
  441. self.spawn('',msg_only=True)
  442. from mmgen.base_proto.bitcoin.regtest import MMGenRegtest
  443. rt = MMGenRegtest(self.proto.coin)
  444. await rt.stop()
  445. from shutil import rmtree
  446. imsg(f'Deleting Bob’s old tracking wallet')
  447. rmtree(os.path.join(rt.d.datadir,'regtest','wallets','bob'),ignore_errors=True)
  448. rt.init_daemon()
  449. rt.d.start(silent=True)
  450. imsg(f'Creating Bob’s new tracking wallet')
  451. await rt.rpc_call('createwallet','bob',True,True,None,False,False,False)
  452. await rt.stop()
  453. await rt.start()
  454. return 'ok'
  455. def addrimport_bob2(self):
  456. if not self.deterministic:
  457. return 'skip'
  458. return self.addrimport('bob')
  459. def fund_wallet(self,user,mmtype,amt,sid=None,addr_range='1-5'):
  460. if self.deterministic:
  461. return 'skip'
  462. if not sid:
  463. sid = self._user_sid(user)
  464. addr = self.get_addr_from_addrlist(user,sid,mmtype,0,addr_range=addr_range)
  465. t = self.spawn('mmgen-regtest', ['send',str(addr),str(amt)])
  466. t.expect(f'Sending {amt} miner {self.proto.coin}')
  467. t.expect('Mined 1 block')
  468. return t
  469. def fund_bob(self):
  470. return self.fund_wallet('bob','C',rtFundAmt)
  471. def fund_alice(self):
  472. return self.fund_wallet('alice',('L','S')[self.proto.cap('segwit')],rtFundAmt)
  473. def user_twview(self,user,chk,sort='age'):
  474. t = self.spawn('mmgen-tool',['--'+user,'twview','sort='+sort])
  475. if chk:
  476. t.expect(r'{}\b.*\D{}\b'.format(*chk),regex=True)
  477. return t
  478. def bob_twview1(self): return self.user_twview('bob', chk = ('1',rtAmts[0]) )
  479. def user_bal(self,user,bal,args=['showempty=1'],skip_check=False):
  480. t = self.spawn('mmgen-tool',['--'+user,'listaddresses'] + args)
  481. if not skip_check:
  482. cmp_or_die(f'{bal} {self.proto.coin}',strip_ansi_escapes(t.expect_getend('TOTAL: ')))
  483. return t
  484. def alice_bal1(self):
  485. return self.user_bal('alice',rtFundAmt)
  486. def alice_bal2(self):
  487. return self.user_bal('alice',rtBals[8])
  488. def bob_bal1(self):
  489. return self.user_bal('bob',rtFundAmt)
  490. def bob_bal2(self):
  491. return self.user_bal('bob',rtBals[0])
  492. def bob_bal2a(self):
  493. return self.user_bal('bob',rtBals[0],args=['showempty=1','age_fmt=confs'])
  494. def bob_bal2b(self):
  495. return self.user_bal('bob',rtBals[0],args=['showempty=1'])
  496. def bob_bal2c(self):
  497. return self.user_bal('bob',rtBals[0],args=['showempty=1','minconf=2','age_fmt=days'],skip_check=True)
  498. def bob_bal2d(self):
  499. return self.user_bal('bob',rtBals[0],args=['minconf=2'],skip_check=True)
  500. def bob_bal2e(self):
  501. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age'])
  502. def bob_bal2f(self):
  503. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age,reverse'])
  504. def bob_bal3(self):
  505. return self.user_bal('bob',rtBals[1])
  506. def bob_bal4(self):
  507. return self.user_bal('bob',rtBals[2])
  508. def bob_bal5(self):
  509. return self.user_bal('bob',rtBals[3])
  510. def bob_bal6(self):
  511. return self.user_bal('bob',rtBals[7])
  512. def bob_subwallet_addrgen1(self):
  513. return self.addrgen('bob',subseed_idx='29L',mmtypes=['C']) # 29L: 2FA7BBA8
  514. def bob_subwallet_addrgen2(self):
  515. return self.addrgen('bob',subseed_idx='127S',mmtypes=['C']) # 127S: '09E8E286'
  516. def subwallet_addrimport(self,user,subseed_idx):
  517. sid = self._get_user_subsid(user,subseed_idx)
  518. return self.addrimport(user,sid=sid,mmtypes=['C'])
  519. def bob_subwallet_addrimport1(self): return self.subwallet_addrimport('bob','29L')
  520. def bob_subwallet_addrimport2(self): return self.subwallet_addrimport('bob','127S')
  521. def bob_subwallet_fund(self):
  522. sid1 = self._get_user_subsid('bob','29L')
  523. sid2 = self._get_user_subsid('bob','127S')
  524. chg_addr = self._user_sid('bob') + (':B:1',':L:1')[self.proto.coin=='BCH']
  525. outputs_cl = [sid1+':C:2,0.29',sid2+':C:3,0.127',chg_addr]
  526. inputs = ('3','1')[self.proto.coin=='BCH']
  527. return self.user_txdo('bob',rtFee[1],outputs_cl,inputs,extra_args=['--subseeds=127'])
  528. def bob_twview2(self):
  529. sid1 = self._get_user_subsid('bob','29L')
  530. return self.user_twview('bob',chk=(sid1+':C:2','0.29'),sort='twmmid')
  531. def bob_twview3(self):
  532. sid2 = self._get_user_subsid('bob','127S')
  533. return self.user_twview('bob',chk=(sid2+':C:3','0.127'),sort='amt')
  534. def bob_subwallet_txcreate(self):
  535. sid1 = self._get_user_subsid('bob','29L')
  536. sid2 = self._get_user_subsid('bob','127S')
  537. outputs_cl = [sid1+':C:5,0.0159',sid2+':C:5']
  538. t = self.spawn('mmgen-txcreate',['-d',self.tmpdir,'-B','--bob'] + outputs_cl)
  539. return self.txcreate_ui_common(t,
  540. menu = ['a'],
  541. inputs = ('1,2','2,3')[self.proto.coin=='BCH'],
  542. interactive_fee = '0.00001')
  543. def bob_subwallet_txsign(self):
  544. fn = get_file_with_ext(self.tmpdir,'rawtx')
  545. t = self.spawn('mmgen-txsign',['-d',self.tmpdir,'--bob','--subseeds=127',fn])
  546. t.view_tx('t')
  547. t.passphrase(dfl_wcls.desc,rt_pw)
  548. t.do_comment(None)
  549. t.expect('(Y/n): ','y')
  550. t.written_to_file('Signed transaction')
  551. return t
  552. def bob_subwallet_txdo(self):
  553. outputs_cl = [self._user_sid('bob')+':L:5']
  554. inputs = ('1,2','2,3')[self.proto.coin=='BCH']
  555. return self.user_txdo('bob',rtFee[5],outputs_cl,inputs,menu=['a'],extra_args=['--subseeds=127']) # sort: amt
  556. def bob_twview4(self):
  557. sid = self._user_sid('bob')
  558. return self.user_twview('bob',chk=(sid+':L:5',rtBals[9]),sort='twmmid')
  559. def user_txhist(self,user,args,expect):
  560. t = self.spawn('mmgen-tool',['--'+user,'txhist'] + args)
  561. res = strip_ansi_escapes(t.read()).replace('\r','')
  562. m = re.search(expect,res,re.DOTALL)
  563. assert m, m
  564. return t
  565. def bob_txhist1(self):
  566. return self.user_txhist('bob',
  567. args = ['sort=age'],
  568. expect = fr'\s1\).*\s{rtFundAmt}\s' )
  569. def bob_txhist2(self):
  570. return self.user_txhist('bob',
  571. args = ['sort=blockheight','reverse=1','age_fmt=block'],
  572. expect = fr'\s1\).*:{self.dfl_mmtype}:1\s' )
  573. def bob_txhist3(self):
  574. return self.user_txhist('bob',
  575. args = ['sort=blockheight','sinceblock=-7','age_fmt=block'],
  576. expect = fr'Displaying transactions since block 399.*\s6\).*:C:2\s.*\s{rtBals[9]}\s.*:L:5.*\s7\)'
  577. )
  578. def bob_txhist4(self):
  579. return self.user_txhist('bob',
  580. args = ['sort=blockheight','sinceblock=399','age_fmt=block','detail=1'],
  581. expect = fr'Displaying transactions since block 399.*\s7\).*Block:.*406.*Value:.*{rtBals[10]}'
  582. )
  583. def bob_txhist_interactive(self):
  584. self.get_file_with_ext('out',delete_all=True)
  585. t = self.spawn('mmgen-tool',
  586. ['--bob',f'--outdir={self.tmpdir}','txhist','age_fmt=date_time','interactive=true'] )
  587. for resp in ('u','i','t','a','m','T','A','r','r','D','D','D','D','p','P','b','V'):
  588. t.expect('draw:\b',resp,regex=True)
  589. txnum,idx = (8,1) if self.proto.coin == 'BCH' else (9,3)
  590. t.expect(f'\s{txnum}\).*Inputs:.*:L:{idx}.*Outputs \(3\):.*:C:2.*\s10\)','q',regex=True)
  591. return t
  592. def bob_getbalance(self,bals,confs=1):
  593. for i in (0,1,2):
  594. assert Decimal(bals['mmgen'][i]) + Decimal(bals['nonmm'][i]) == Decimal(bals['total'][i])
  595. t = self.spawn('mmgen-tool',['--bob','getbalance',f'minconf={confs}'])
  596. t.expect('Wallet')
  597. for k in ('mmgen','nonmm','total'):
  598. ret = strip_ansi_escapes(t.expect_getend(r'\S+: ',regex=True))
  599. cmp_or_die(
  600. ' '.join(bals[k]),
  601. re.sub(rf'\s+{self.proto.coin}\s*',' ',ret).strip(),
  602. desc=k,
  603. )
  604. return t
  605. def bob_0conf0_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf0'],confs=0)
  606. def bob_0conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf1'],confs=1)
  607. def bob_1conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf1'],confs=1)
  608. def bob_1conf2_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf2'],confs=2)
  609. def bob_nochg_burn(self):
  610. return self.user_txdo('bob',
  611. fee = '0.00009713',
  612. outputs_cl = [f'{make_burn_addr(self.proto)}'],
  613. outputs_list = '1' )
  614. def bob_alice_bal(self):
  615. t = self.spawn('mmgen-regtest',['balances'])
  616. ret = t.expect_getend("Bob's balance:").strip()
  617. cmp_or_die(rtBals[4],ret)
  618. ret = t.expect_getend("Alice's balance:").strip()
  619. cmp_or_die(rtBals[5],ret)
  620. ret = t.expect_getend("Total balance:").strip()
  621. cmp_or_die(rtBals[6],ret)
  622. return t
  623. def user_txsend_status(self,user,tx_file,exp1='',exp2='',extra_args=[]):
  624. t = self.spawn('mmgen-txsend',['-d',self.tmpdir,'--'+user,'--status'] + extra_args + [tx_file])
  625. if exp1: t.expect(exp1,regex=True)
  626. if exp2: t.expect(exp2,regex=True)
  627. return t
  628. def user_txdo( self, user, fee, outputs_cl, outputs_list,
  629. extra_args = [],
  630. wf = None,
  631. do_label = False,
  632. bad_locktime = False,
  633. full_tx_view = False,
  634. menu = ['M'],
  635. skip_passphrase = False ):
  636. t = self.spawn('mmgen-txdo',
  637. ['-d',self.tmpdir,'-B','--'+user] +
  638. (['--tx-fee='+fee] if fee else []) +
  639. extra_args + ([],[wf])[bool(wf)] + outputs_cl)
  640. self.txcreate_ui_common(t,
  641. caller = 'txdo',
  642. menu = menu,
  643. inputs = outputs_list,
  644. file_desc = 'Signed transaction',
  645. interactive_fee = (tx_fee,'')[bool(fee)],
  646. add_comment = tx_label_jp,
  647. view = 't',save=True)
  648. if not skip_passphrase:
  649. t.passphrase(dfl_wcls.desc,rt_pw)
  650. t.written_to_file('Signed transaction')
  651. self._do_confirm_send(t)
  652. s,exit_val = (('Transaction sent',0),("can't be included",1))[bad_locktime]
  653. t.expect(s)
  654. t.req_exit_val = exit_val
  655. return t
  656. def bob_split1(self):
  657. sid = self._user_sid('bob')
  658. outputs_cl = [sid+':C:1,100', sid+':L:2,200',sid+':'+rtBobOp3]
  659. return self.user_txdo('bob',rtFee[0],outputs_cl,'1',do_label=True,full_tx_view=True)
  660. def get_addr_from_addrlist(self,user,sid,mmtype,idx,addr_range='1-5'):
  661. id_str = { 'L':'', 'S':'-S', 'C':'-C', 'B':'-B' }[mmtype]
  662. ext = '{}{}{}[{}]{x}.regtest.addrs'.format(
  663. sid,self.altcoin_pfx,id_str,addr_range,x='-α' if g.debug_utf8 else '')
  664. addrfile = get_file_with_ext(self._user_dir(user),ext,no_dot=True)
  665. silence()
  666. addr = AddrList(self.proto,addrfile).data[idx].addr
  667. end_silence()
  668. return addr
  669. def _create_tx_outputs(self,user,data):
  670. sid = self._user_sid(user)
  671. return [self.get_addr_from_addrlist(user,sid,mmtype,idx-1)+amt_str for mmtype,idx,amt_str in data]
  672. def bob_rbf_1output_create(self):
  673. if not self.test_rbf:
  674. return 'skip'
  675. out_addr = self._create_tx_outputs('alice',(('B',5,''),))
  676. t = self.spawn('mmgen-txcreate',['-d',self.tr.trash_dir,'-B','--bob','--rbf'] + out_addr)
  677. return self.txcreate_ui_common(t,menu=[],inputs='3',interactive_fee='3s') # out amt: 199.99999343
  678. def bob_rbf_1output_bump(self):
  679. if not self.test_rbf:
  680. return 'skip'
  681. ext = '9343,3]{x}.regtest.rawtx'.format(x='-α' if g.debug_utf8 else '')
  682. txfile = get_file_with_ext(self.tr.trash_dir,ext,delete=False,no_dot=True)
  683. return self.user_txbump('bob',
  684. self.tr.trash_dir,
  685. txfile,
  686. '8s',
  687. has_label = False,
  688. signed_tx = False,
  689. one_output = True )
  690. def bob_send_maybe_rbf(self):
  691. outputs_cl = self._create_tx_outputs('alice',(('L',1,',60'),('C',1,',40'))) # alice_sid:L:1, alice_sid:C:1
  692. outputs_cl += [self._user_sid('bob')+':'+rtBobOp3]
  693. return self.user_txdo('bob',rtFee[1],outputs_cl,'3',
  694. extra_args=([],['--rbf'])[self.proto.cap('rbf')])
  695. def bob_send_non_mmgen(self):
  696. outputs_cl = self._create_tx_outputs('alice',(
  697. (('L','S')[self.proto.cap('segwit')],2,',10'),
  698. (('L','S')[self.proto.cap('segwit')],3,'')
  699. )) # alice_sid:S:2, alice_sid:S:3
  700. keyfile = joinpath(self.tmpdir,'non-mmgen.keys')
  701. return self.user_txdo('bob',rtFee[3],outputs_cl,'1,4-10',
  702. extra_args=['--keys-from-file='+keyfile,'--vsize-adj=1.02'])
  703. def alice_send_estimatefee(self):
  704. outputs_cl = self._create_tx_outputs('bob',(('L',1,''),)) # bob_sid:L:1
  705. return self.user_txdo('alice',None,outputs_cl,'1') # fee=None
  706. def user_txbump(self,user,outdir,txfile,fee,add_args=[],has_label=True,signed_tx=True,one_output=False):
  707. if not self.proto.cap('rbf'):
  708. return 'skip'
  709. t = self.spawn('mmgen-txbump',
  710. ['-d',outdir,'--'+user,'--tx-fee='+fee,'--output-to-reduce=c'] + add_args + [txfile])
  711. if not one_output:
  712. t.expect('OK? (Y/n): ','y') # output OK?
  713. t.expect('OK? (Y/n): ','y') # fee OK?
  714. t.do_comment(False,has_label=has_label)
  715. if signed_tx:
  716. t.passphrase(dfl_wcls.desc,rt_pw)
  717. t.written_to_file('Signed transaction')
  718. self.txsend_ui_common(t,caller='txdo',bogus_send=False,file_desc='Signed transaction')
  719. else:
  720. t.expect('Save fee-bumped transaction? (y/N): ','y')
  721. t.written_to_file('Fee-bumped transaction')
  722. return t
  723. def bob_rbf_bump(self):
  724. ext = ',{}]{x}.regtest.sigtx'.format(rtFee[1][:-1],x='-α' if g.debug_utf8 else '')
  725. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  726. return self.user_txbump('bob',self.tmpdir,txfile,rtFee[2],add_args=['--send'])
  727. def generate(self,coin=None,num_blocks=1):
  728. int(num_blocks)
  729. t = self.spawn('mmgen-regtest',['generate',str(num_blocks)])
  730. t.expect(f'Mined {num_blocks} block')
  731. return t
  732. def _get_mempool(self):
  733. if not g.debug_utf8:
  734. disable_debug()
  735. ret = self.spawn('mmgen-regtest',['mempool']).read()
  736. if not g.debug_utf8:
  737. restore_debug()
  738. m = re.search(r'(\[\s*"[a-f0-9]{64}"\s*])',ret) # allow for extra output by handler at end
  739. return json.loads(m.group(1))
  740. def get_mempool1(self):
  741. mp = self._get_mempool()
  742. if len(mp) != 1:
  743. die(4,'Mempool has more or less than one TX!')
  744. self.write_to_tmpfile('rbf_txid',mp[0]+'\n')
  745. return 'ok'
  746. def bob_rbf_status(self,fee,exp1,exp2=''):
  747. if not self.proto.cap('rbf'):
  748. return 'skip'
  749. ext = ',{}]{x}.regtest.sigtx'.format(fee[:-1],x='-α' if g.debug_utf8 else '')
  750. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  751. return self.user_txsend_status('bob',txfile,exp1,exp2)
  752. def bob_rbf_status1(self):
  753. if not self.proto.cap('rbf'):
  754. return 'skip'
  755. return self.bob_rbf_status(rtFee[1],'in mempool, replaceable')
  756. def get_mempool2(self):
  757. if not self.proto.cap('rbf'):
  758. return 'skip'
  759. mp = self._get_mempool()
  760. if len(mp) != 1:
  761. die(4,'Mempool has more or less than one TX!')
  762. chk = self.read_from_tmpfile('rbf_txid')
  763. if chk.strip() == mp[0]:
  764. die(4,'TX in mempool has not changed! RBF bump failed')
  765. self.write_to_tmpfile('rbf_txid2',mp[0]+'\n')
  766. return 'ok'
  767. def bob_rbf_status2(self):
  768. if not self.proto.cap('rbf'):
  769. return 'skip'
  770. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  771. return self.bob_rbf_status(rtFee[1],
  772. 'Transaction has been replaced',f'{new_txid} in mempool')
  773. def bob_rbf_status3(self):
  774. if not self.proto.cap('rbf'):
  775. return 'skip'
  776. return self.bob_rbf_status(rtFee[2],'status: in mempool, replaceable')
  777. def bob_rbf_status4(self):
  778. if not self.proto.cap('rbf'):
  779. return 'skip'
  780. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  781. return self.bob_rbf_status(rtFee[1],
  782. 'Replacement transaction has 1 confirmation',
  783. f'Replacing transactions:\s+{new_txid}' )
  784. def bob_rbf_status5(self):
  785. if not self.proto.cap('rbf'):
  786. return 'skip'
  787. return self.bob_rbf_status(rtFee[2],'Transaction has 1 confirmation')
  788. def bob_rbf_status6(self):
  789. if not self.proto.cap('rbf'):
  790. return 'skip'
  791. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  792. return self.bob_rbf_status(rtFee[1],
  793. 'Replacement transaction has 2 confirmations',
  794. f'Replacing transactions:\s+{new_txid}' )
  795. def _gen_pairs(self,n):
  796. from mmgen.tool.api import tool_api
  797. t = tool_api()
  798. t.init_coin(self.proto.coin,self.proto.network)
  799. def gen_addr(Type):
  800. t.addrtype = Type
  801. wif = t.hex2wif(getrandhex(32))
  802. return ( wif, t.wif2addr(wif) )
  803. return [gen_addr('legacy')] + [gen_addr('compressed') for i in range(n-1)]
  804. def bob_pre_import(self):
  805. pairs = self._gen_pairs(5)
  806. self.write_to_tmpfile('non-mmgen.keys','\n'.join([a[0] for a in pairs])+'\n')
  807. self.write_to_tmpfile('non-mmgen.addrs','\n'.join([a[1] for a in pairs])+'\n')
  808. return self.user_txdo('bob',rtFee[4],[pairs[0][1]],'3')
  809. def user_import(self,user,args,nAddr):
  810. t = self.spawn('mmgen-addrimport',['--'+user]+args)
  811. if g.debug:
  812. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  813. t.expect(f'Importing {nAddr} address')
  814. if '--rescan' in args:
  815. if not '--quiet' in args:
  816. t.expect('Continue? (Y/n): ','y')
  817. t.expect('Rescanning block')
  818. return t
  819. def bob_import_addr(self):
  820. addr = self.read_from_tmpfile('non-mmgen.addrs').split()[0]
  821. return self.user_import('bob',['--quiet','--address='+addr],nAddr=1)
  822. def bob_import_list_rescan_aio(self):
  823. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  824. return self.user_import('bob',['--rescan','--rpc-backend=aio','--addrlist',addrfile],nAddr=5)
  825. def bob_resolve_addr(self):
  826. mmaddr = '{}:C:1'.format(self._user_sid('bob'))
  827. t = self.spawn('mmgen-tool',['--bob','resolve_address',mmaddr])
  828. coinaddr = t.read().split()[0].strip()
  829. t = self.spawn('mmgen-tool',['--bob','resolve_address',coinaddr],no_msg=True)
  830. mmaddr_res = t.read().split()[0].strip()
  831. assert mmaddr == mmaddr_res, f'{mmaddr} != {mmaddr_res}'
  832. return t
  833. def bob_import_list(self):
  834. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  835. return self.user_import('bob',['--quiet','--addrlist',addrfile],nAddr=5)
  836. def bob_import_list_rescan(self):
  837. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  838. return self.user_import('bob',['--quiet','--rescan','--addrlist',addrfile],nAddr=5)
  839. def bob_rescan_addr(self):
  840. sid = self._user_sid('bob')
  841. t = self.spawn('mmgen-tool',['--bob','rescan_address',f'{sid}:C:1'])
  842. t.expect('Found 1 unspent output')
  843. t.expect('updated successfully')
  844. return t
  845. def bob_rescan_blockchain(self,add_args,expect):
  846. t = self.spawn('mmgen-tool',['--bob','rescan_blockchain'] + add_args)
  847. t.expect(f'Scanning blocks {expect}')
  848. t.expect('Done')
  849. return t
  850. def bob_rescan_blockchain_all(self):
  851. return self.bob_rescan_blockchain([],'400-400')
  852. def bob_rescan_blockchain_gb(self):
  853. return self.bob_rescan_blockchain(['start_block=0','stop_block=0'],'0-0')
  854. def bob_rescan_blockchain_one(self):
  855. return self.bob_rescan_blockchain(['start_block=300','stop_block=300'],'300-300')
  856. def bob_rescan_blockchain_ss(self):
  857. return self.bob_rescan_blockchain(['start_block=300','stop_block=302'],'300-302')
  858. def bob_twexport(self,add_args=[]):
  859. t = self.spawn('mmgen-tool',['--bob',f'--outdir={self.tmpdir}','twexport'] + add_args)
  860. t.written_to_file('JSON data')
  861. return t
  862. def bob_twexport_noamt(self):
  863. return self.bob_twexport(add_args=['include_amts=0'])
  864. def bob_twexport_pretty(self):
  865. return self.bob_twexport(add_args=['pretty=1'])
  866. def bob_edit_json_twdump(self):
  867. self.spawn('',msg_only=True)
  868. from mmgen.tw.json import TwJSON
  869. fn = TwJSON.Base(self.proto).dump_fn
  870. text = json.loads(self.read_from_tmpfile(fn))
  871. text['data']['entries'][3][3] = f'edited comment [фубар] [{gr_uc}]'
  872. self.write_to_tmpfile( fn, json.dumps(text,indent=4) )
  873. return 'ok'
  874. def carol_twimport(self,add_args=[],expect_str=None):
  875. from mmgen.tw.json import TwJSON
  876. fn = joinpath( self.tmpdir, TwJSON.Base(self.proto).dump_fn )
  877. t = self.spawn('mmgen-tool',['--carol','twimport',fn] + add_args)
  878. t.expect('(y/N): ','y')
  879. if expect_str:
  880. t.expect(expect_str)
  881. elif 'batch=true' in add_args:
  882. t.expect('{} addresses imported'.format(15 if self.proto.coin == 'BCH' else 25))
  883. else:
  884. t.expect('import completed OK')
  885. t.expect('Found 3 unspent outputs')
  886. return t
  887. def carol_twimport_nochksum(self):
  888. return self.carol_twimport(add_args=['ignore_checksum=true'])
  889. def carol_twimport_batch(self):
  890. return self.carol_twimport(add_args=['batch=true'])
  891. def carol_twimport_pretty(self):
  892. return self.carol_twimport(add_args=['ignore_checksum=true'],expect_str='ignoring incorrect checksum')
  893. def carol_listaddresses(self):
  894. return self.spawn('mmgen-tool',['--carol','listaddresses','showempty=1'])
  895. async def carol_delete_wallet(self):
  896. imsg(f'Unloading Carol’s tracking wallet')
  897. t = self.spawn('mmgen-regtest',['cli','unloadwallet','carol'])
  898. t.ok()
  899. from mmgen.rpc import rpc_init
  900. rpc = await rpc_init(self.proto)
  901. wdir = joinpath(rpc.daemon.network_datadir,'wallets','carol')
  902. from shutil import rmtree
  903. imsg(f'Deleting Carol’s tracking wallet')
  904. rmtree(wdir)
  905. return 'silent'
  906. def bob_split2(self):
  907. addrs = self.read_from_tmpfile('non-mmgen.addrs').split()
  908. amts = (1.12345678,2.87654321,3.33443344,4.00990099,5.43214321)
  909. outputs1 = list(map('{},{}'.format,addrs,amts))
  910. sid = self._user_sid('bob')
  911. l1,l2 = (
  912. (':S',':B') if 'B' in self.proto.mmtypes else
  913. (':S',':S') if self.proto.cap('segwit') else
  914. (':L',':L') )
  915. outputs2 = [sid+':C:2,6.333', sid+':L:3,6.667',sid+l1+':4,0.123',sid+l2+':5']
  916. return self.user_txdo('bob',rtFee[5],outputs1+outputs2,'1-2')
  917. def user_add_label(self,user,addr,label):
  918. t = self.spawn('mmgen-tool',['--'+user,'add_label',addr,label])
  919. t.expect('Added label.*in tracking wallet',regex=True)
  920. return t
  921. def user_remove_label(self,user,addr):
  922. t = self.spawn('mmgen-tool',['--'+user,'remove_label',addr])
  923. t.expect('Removed label.*in tracking wallet',regex=True)
  924. return t
  925. def bob_add_label(self):
  926. sid = self._user_sid('bob')
  927. return self.user_add_label('bob',sid+':C:1',tw_label_lat_cyr_gr)
  928. def alice_add_label1(self):
  929. sid = self._user_sid('alice')
  930. return self.user_add_label('alice',sid+':C:1','Original Label - 月へ')
  931. def alice_add_label2(self):
  932. sid = self._user_sid('alice')
  933. return self.user_add_label('alice',sid+':C:1','Replacement Label')
  934. def _user_chk_label(self,user,addr,label):
  935. t = self.spawn('mmgen-tool',['--'+user,'listaddresses','all_labels=1'])
  936. ret = strip_ansi_escapes(t.expect_getend(addr)).strip().split(None,1)[1]
  937. cmp_or_die(ret[:len(label)],label)
  938. return t
  939. def alice_add_label_coinaddr(self):
  940. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  941. t = self.spawn('mmgen-tool',['--alice','listaddress',mmid],no_msg=True)
  942. addr = [i for i in strip_ansi_escapes(t.read()).splitlines() if i.startswith(mmid)][0].split()[1]
  943. return self.user_add_label('alice',addr,'Label added using coin address of MMGen address')
  944. def alice_chk_label_coinaddr(self):
  945. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  946. return self._user_chk_label('alice',mmid,'Label added using coin address of MMGen address')
  947. def alice_add_label_badaddr(self,addr,reply):
  948. if os.getenv('PYTHONOPTIMIZE'):
  949. omsg(yellow(f'PYTHONOPTIMIZE set, skipping test {self.test_name!r}'))
  950. return 'skip'
  951. t = self.spawn('mmgen-tool',['--alice','add_label',addr,'(none)'])
  952. t.expect(reply,regex=True)
  953. return t
  954. def alice_add_label_badaddr1(self):
  955. return self.alice_add_label_badaddr( rt_pw,'Invalid coin address for this chain: ')
  956. def alice_add_label_badaddr2(self):
  957. addr = init_proto(self.proto.coin,network='mainnet').pubhash2addr(bytes(20),False) # mainnet zero address
  958. return self.alice_add_label_badaddr( addr, f'Invalid coin address for this chain: {addr}' )
  959. def alice_add_label_badaddr3(self):
  960. addr = self._user_sid('alice') + ':C:123'
  961. return self.alice_add_label_badaddr( addr, f'MMGen address {addr!r} not found in tracking wallet' )
  962. def alice_add_label_badaddr4(self):
  963. addr = self.proto.pubhash2addr(bytes(20),False) # regtest (testnet) zero address
  964. return self.alice_add_label_badaddr( addr, f'Address {addr!r} not found in tracking wallet' )
  965. def alice_remove_label1(self):
  966. sid = self._user_sid('alice')
  967. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  968. return self.user_remove_label('alice',mmid)
  969. def alice_chk_label1(self):
  970. sid = self._user_sid('alice')
  971. return self._user_chk_label('alice',sid+':C:1','Original Label - 月へ')
  972. def alice_chk_label2(self):
  973. sid = self._user_sid('alice')
  974. return self._user_chk_label('alice',sid+':C:1','Replacement Label')
  975. def alice_edit_label1(self): return self.user_edit_label('alice','4',tw_label_lat_cyr_gr)
  976. def alice_edit_label2(self): return self.user_edit_label('alice','3',tw_label_zh)
  977. def alice_chk_label3(self):
  978. sid = self._user_sid('alice')
  979. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  980. return self._user_chk_label('alice',mmid,tw_label_lat_cyr_gr)
  981. def alice_chk_label4(self):
  982. sid = self._user_sid('alice')
  983. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  984. return self._user_chk_label('alice',mmid,'-')
  985. def user_edit_label(self,user,output,label):
  986. t = self.spawn('mmgen-txcreate',['-B','--'+user,'-i'])
  987. t.expect(r'add \[l\]abel:.','M',regex=True)
  988. t.expect(r'add \[l\]abel:.','l',regex=True)
  989. t.expect(r"Enter unspent.*return to main menu\):.",output+'\n',regex=True)
  990. t.expect(r"Enter label text.*return to main menu\):.",label+'\n',regex=True)
  991. t.expect(r'\[q\]uit view, .*?:.','q',regex=True)
  992. return t
  993. def alice_listaddresses(self,args,expect):
  994. t = self.spawn('mmgen-tool',['--alice','listaddresses','showempty=1'] + args)
  995. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  996. t.expect(expect_str,regex=True)
  997. return t
  998. def alice_listaddresses1(self):
  999. return self.alice_listaddresses(
  1000. args = [],
  1001. expect = (rtAmts[1],r'\d+') )
  1002. def alice_listaddresses_days(self):
  1003. return self.alice_listaddresses(
  1004. args = ['age_fmt=days'],
  1005. expect = (rtAmts[1],r'\d+') )
  1006. def alice_listaddresses_date(self):
  1007. return self.alice_listaddresses(
  1008. args = ['age_fmt=date'],
  1009. expect = (rtAmts[1],pat_date) )
  1010. def alice_listaddresses_date_time(self):
  1011. return self.alice_listaddresses(
  1012. args = ['age_fmt=date_time'],
  1013. expect = (rtAmts[1],pat_date_time) )
  1014. def alice_twview(self,args,expect):
  1015. t = self.spawn('mmgen-tool',['--alice','twview'] + args)
  1016. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  1017. t.expect(expect_str,regex=True)
  1018. return t
  1019. def alice_twview1(self):
  1020. return self.alice_twview(
  1021. args = [],
  1022. expect = (rtAmts[0],r'\d+') )
  1023. def alice_twview_days(self):
  1024. return self.alice_twview(
  1025. args = ['age_fmt=days'],
  1026. expect = (rtAmts[0],r'\d+') )
  1027. def alice_twview_date(self):
  1028. return self.alice_twview(
  1029. args = ['age_fmt=date'],
  1030. expect = (rtAmts[0],pat_date) )
  1031. def alice_twview_date_time(self):
  1032. return self.alice_twview(
  1033. args = ['age_fmt=date_time'],
  1034. expect = (rtAmts[0],pat_date_time) )
  1035. def alice_txcreate_info(self,args=[]):
  1036. t = self.spawn('mmgen-txcreate',['--alice','-Bi'])
  1037. pats = (
  1038. ( '\d+', 'D'),
  1039. ( '\d+', 'D'),
  1040. ( '\d+', 'D'),
  1041. ( pat_date, 'q'),
  1042. ) if opt.pexpect_spawn else (
  1043. ( '\d+', 'D'),
  1044. ( '\d+', 'D'),
  1045. ( '\d+', 'D'),
  1046. ( pat_date, 'w'),
  1047. ( '\d+\s+\d+\s+'+pat_date_time,'q'),
  1048. )
  1049. for d,s in pats:
  1050. t.expect(
  1051. r'\D{}\D.*\b{}\b'.format( rtAmts[0], d ),
  1052. s,
  1053. regex=True )
  1054. return t
  1055. def bob_msgcreate(self):
  1056. sid1 = self._user_sid('bob')
  1057. sid2 = self._get_user_subsid('bob','29L')
  1058. return self.spawn(
  1059. 'mmgen-msg', [
  1060. '--bob',
  1061. f'--outdir={self.tmpdir}',
  1062. 'create',
  1063. '16/3/2022 Earthquake strikes Fukushima coast',
  1064. f'{sid1}:{self.dfl_mmtype}:1-4',
  1065. f'{sid2}:C:3-7,87,98'
  1066. ])
  1067. def bob_msgsign(self,wallets=[]):
  1068. fn = get_file_with_ext(self.tmpdir,'rawmsg.json')
  1069. t = self.spawn(
  1070. 'mmgen-msg', [
  1071. '--bob',
  1072. f'--outdir={self.tmpdir}',
  1073. 'sign',
  1074. fn
  1075. ] + wallets )
  1076. if not wallets:
  1077. t.passphrase(dfl_wcls.desc,rt_pw)
  1078. return t
  1079. def bob_walletconv_words(self):
  1080. t = self.spawn(
  1081. 'mmgen-walletconv', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=words' ] )
  1082. t.passphrase(dfl_wcls.desc,rt_pw)
  1083. t.written_to_file('data')
  1084. return t
  1085. def bob_subwalletgen_bip39(self):
  1086. t = self.spawn(
  1087. 'mmgen-subwalletgen', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=bip39', '29L' ] )
  1088. t.passphrase(dfl_wcls.desc,rt_pw)
  1089. t.written_to_file('data')
  1090. return t
  1091. def bob_msgsign_userwallet(self):
  1092. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1093. return self.bob_msgsign([fn1])
  1094. def bob_msgsign_userwallets(self):
  1095. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1096. fn2 = get_file_with_ext(self.tmpdir,'bip39')
  1097. return self.bob_msgsign([fn2,fn1])
  1098. def bob_msgverify(self,addr=None,ext='sigmsg.json',cmd='verify',msgfile=None):
  1099. return self.spawn(
  1100. 'mmgen-msg', [
  1101. '--bob',
  1102. f'--outdir={self.tmpdir}',
  1103. cmd,
  1104. msgfile or get_file_with_ext(self.tmpdir,ext),
  1105. ] + ([addr] if addr else []) )
  1106. def bob_msgverify_raw(self):
  1107. t = self.bob_msgverify(ext='rawmsg.json')
  1108. t.req_exit_val = 1
  1109. return t
  1110. def bob_msgverify_single(self):
  1111. sid = self._user_sid('bob')
  1112. return self.bob_msgverify(addr=f'{sid}:{self.dfl_mmtype}:1')
  1113. def bob_msgexport(self,addr=None):
  1114. t = self.bob_msgverify( addr=addr, cmd='export' )
  1115. t.written_to_file('data')
  1116. return t
  1117. def bob_msgexport_single(self):
  1118. sid = self._user_sid('bob')
  1119. return self.bob_msgexport(addr=f'{sid}:{self.dfl_mmtype}:1')
  1120. def bob_msgverify_export(self):
  1121. return self.bob_msgverify(
  1122. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1123. )
  1124. def bob_msgverify_export_single(self):
  1125. sid = self._user_sid('bob')
  1126. mmid = f'{sid}:{self.dfl_mmtype}:1'
  1127. t = self.spawn('mmgen-tool', [ '--bob', '--color=0', 'listaddress', mmid ], no_msg=True)
  1128. addr = t.expect_getend(mmid).split()[0]
  1129. t.close()
  1130. return self.bob_msgverify(
  1131. addr = addr,
  1132. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1133. )
  1134. def stop(self):
  1135. if opt.no_daemon_stop:
  1136. self.spawn('',msg_only=True)
  1137. msg_r('(leaving daemon running by user request)')
  1138. return 'ok'
  1139. else:
  1140. return self.spawn('mmgen-regtest',['stop'])