ts_regtest.py 32 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, command-line Bitcoin cold storage solution
  4. # Copyright (C)2013-2019 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,write_data_to_file
  26. from mmgen.protocol import CoinProtocol
  27. from mmgen.addr import AddrList
  28. from mmgen.seed import Wallet
  29. from test.common import *
  30. from test.test_py_d.common import *
  31. dfl_wcls = Wallet
  32. rt_pw = 'abc-α'
  33. rt_data = {
  34. 'tx_fee': {'btc':'0.0001','bch':'0.001','ltc':'0.01'},
  35. 'rtFundAmt': {'btc':'500','bch':'500','ltc':'5500'},
  36. 'rtFee': {
  37. 'btc': ('20s','10s','60s','31s','10s','20s'),
  38. 'bch': ('20s','10s','60s','0.0001','10s','20s'),
  39. 'ltc': ('1000s','500s','1500s','0.05','400s','1000s')
  40. },
  41. 'rtBals': {
  42. 'btc': ('499.9999488','399.9998282','399.9998147','399.9996877',
  43. '52.99980410','946.99933647','999.99914057','52.9999',
  44. '946.99933647'),
  45. 'bch': ('499.9999484','399.9999194','399.9998972','399.9997692',
  46. '46.78890380','953.20966920','999.99857300','46.789',
  47. '953.2096692'),
  48. 'ltc': ('5499.99744','5399.994425','5399.993885','5399.987535',
  49. '52.98520500','10946.93753500','10999.92274000','52.99',
  50. '10946.937535'),
  51. },
  52. 'rtBals_gb': {
  53. 'btc': {
  54. '0conf0': {
  55. 'mmgen': ('283.22339537','0','283.22339537'),
  56. 'nonmm': ('16.77647763','0','116.77629233'),
  57. 'total': ('299.999873','0','399.9996877'),
  58. },
  59. '0conf1': {
  60. 'mmgen': ('283.22339537','283.22339537','0'),
  61. 'nonmm': ('16.77647763','16.77647763','99.9998147'),
  62. 'total': ('299.999873','299.999873','99.9998147'),
  63. },
  64. '1conf1': {
  65. 'mmgen': ('0','0','283.22339537'),
  66. 'nonmm': ('0','0','116.77629233'),
  67. 'total': ('0','0','399.9996877'),
  68. },
  69. '1conf2': {
  70. 'mmgen': ('0','283.22339537','0'),
  71. 'nonmm': ('0','16.77647763','99.9998147'),
  72. 'total': ('0','299.999873','99.9998147'),
  73. },
  74. },
  75. 'bch': {
  76. '0conf0': {
  77. 'mmgen': ('283.22339437','0','283.22339437'),
  78. 'nonmm': ('16.77647763','0','116.77637483'),
  79. 'total': ('299.999872','0','399.9997692'),
  80. },
  81. '0conf1': {
  82. 'mmgen': ('283.22339437','283.22339437','0'),
  83. 'nonmm': ('16.77647763','16.77647763','99.9998972'),
  84. 'total': ('299.999872','299.999872','99.9998972'),
  85. },
  86. '1conf1': {
  87. 'mmgen': ('0','0','283.22339437'),
  88. 'nonmm': ('0','0','116.77637483'),
  89. 'total': ('0','0','399.9997692'),
  90. },
  91. '1conf2': {
  92. 'mmgen': ('0','283.22339437','0'),
  93. 'nonmm': ('0','16.77647763','99.9998972'),
  94. 'total': ('0','299.999872','99.9998972'),
  95. },
  96. },
  97. 'ltc': {
  98. '0conf0': {
  99. 'mmgen': ('283.21717237','0','283.21717237'),
  100. 'nonmm': ('16.77647763','0','5116.77036263'),
  101. 'total': ('299.99365','0','5399.987535'),
  102. },
  103. '0conf1': {
  104. 'mmgen': ('283.21717237','283.21717237','0'),
  105. 'nonmm': ('16.77647763','16.77647763','5099.993885'),
  106. 'total': ('299.99365','299.99365','5099.993885'),
  107. },
  108. '1conf1': {
  109. 'mmgen': ('0','0','283.21717237'),
  110. 'nonmm': ('0','0','5116.77036263'),
  111. 'total': ('0','0','5399.987535'),
  112. },
  113. '1conf2': {
  114. 'mmgen': ('0','283.21717237','0'),
  115. 'nonmm': ('0','16.77647763','5099.993885'),
  116. 'total': ('0','299.99365','5099.993885'),
  117. },
  118. }
  119. },
  120. 'rtBobOp3': {'btc':'S:2','bch':'L:3','ltc':'S:2'},
  121. 'rtAmts': {
  122. 'btc': ('500',),
  123. 'bch': ('500',),
  124. 'ltc': ('5500',)
  125. }
  126. }
  127. from test.test_py_d.ts_base import *
  128. from test.test_py_d.ts_shared import *
  129. class TestSuiteRegtest(TestSuiteBase,TestSuiteShared):
  130. 'transacting and tracking wallet operations via regtest mode'
  131. networks = ('btc','ltc','bch')
  132. passthru_opts = ('coin',)
  133. tmpdir_nums = [17]
  134. cmd_group = (
  135. ('setup', 'regtest (Bob and Alice) mode setup'),
  136. ('walletgen_bob', 'wallet generation (Bob)'),
  137. ('walletgen_alice', 'wallet generation (Alice)'),
  138. ('addrgen_bob', 'address generation (Bob)'),
  139. ('addrgen_alice', 'address generation (Alice)'),
  140. ('addrimport_bob', "importing Bob's addresses"),
  141. ('addrimport_alice', "importing Alice's addresses"),
  142. ('fund_bob', "funding Bob's wallet"),
  143. ('fund_alice', "funding Alice's wallet"),
  144. ('bob_bal1', "Bob's balance"),
  145. ('bob_add_label', "adding an 80-screen-width label (lat+cyr+gr)"),
  146. ('bob_twview1', "viewing Bob's tracking wallet"),
  147. ('bob_split1', "splitting Bob's funds"),
  148. ('generate', 'mining a block'),
  149. ('bob_bal2', "Bob's balance"),
  150. ('bob_rbf_1output_create', 'creating RBF tx with one output'),
  151. ('bob_rbf_1output_bump', 'bumping RBF tx with one output'),
  152. ('bob_bal2a', "Bob's balance (age_fmt=confs)"),
  153. ('bob_bal2b', "Bob's balance (showempty=1)"),
  154. ('bob_bal2c', "Bob's balance (showempty=1 minconf=2 age_fmt=days)"),
  155. ('bob_bal2d', "Bob's balance (minconf=2)"),
  156. ('bob_bal2e', "Bob's balance (showempty=1 sort=age)"),
  157. ('bob_bal2f', "Bob's balance (showempty=1 sort=age,reverse)"),
  158. ('bob_send_maybe_rbf', 'sending funds to Alice (RBF, if supported)'),
  159. ('get_mempool1', 'mempool (before RBF bump)'),
  160. ('bob_rbf_status1', 'getting status of transaction'),
  161. ('bob_rbf_bump', 'bumping RBF transaction'),
  162. ('get_mempool2', 'mempool (after RBF bump)'),
  163. ('bob_rbf_status2', 'getting status of transaction after replacement'),
  164. ('bob_rbf_status3', 'getting status of replacement transaction (mempool)'),
  165. ('generate', 'mining a block'),
  166. ('bob_rbf_status4', 'getting status of transaction after confirmed (1) replacement'),
  167. ('bob_rbf_status5', 'getting status of replacement transaction (confirmed)'),
  168. ('generate', 'mining a block'),
  169. ('bob_rbf_status6', 'getting status of transaction after confirmed (2) replacement'),
  170. ('bob_bal3', "Bob's balance"),
  171. ('bob_pre_import', 'sending to non-imported address'),
  172. ('generate', 'mining a block'),
  173. ('bob_import_addr', 'importing non-MMGen address with --rescan'),
  174. ('bob_bal4', "Bob's balance (after import with rescan)"),
  175. ('bob_import_list', 'importing flat address list'),
  176. ('bob_split2', "splitting Bob's funds"),
  177. ('bob_0conf0_getbalance', "Bob's balance (unconfirmed, minconf=0)"),
  178. ('bob_0conf1_getbalance', "Bob's balance (unconfirmed, minconf=1)"),
  179. ('generate', 'mining a block'),
  180. ('bob_1conf1_getbalance', "Bob's balance (confirmed, minconf=1)"),
  181. ('bob_1conf2_getbalance', "Bob's balance (confirmed, minconf=2)"),
  182. ('bob_bal5', "Bob's balance"),
  183. ('bob_send_non_mmgen', 'sending funds to Alice (from non-MMGen addrs)'),
  184. ('generate', 'mining a block'),
  185. ('alice_bal_rpcfail', 'RPC failure code'),
  186. ('alice_send_estimatefee', 'tx creation with no fee on command line'),
  187. ('generate', 'mining a block'),
  188. ('bob_bal6', "Bob's balance"),
  189. ('bob_subwallet_addrgen1', "generating Bob's addrs from subwallet 29L"),
  190. ('bob_subwallet_addrgen2', "generating Bob's addrs from subwallet 127S"),
  191. ('bob_subwallet_addrimport1', "importing Bob's addrs from subwallet 29L"),
  192. ('bob_subwallet_addrimport2', "importing Bob's addrs from subwallet 127S"),
  193. ('bob_subwallet_fund', "funding Bob's subwallet addrs"),
  194. ('generate', 'mining a block'),
  195. ('bob_twview2', "viewing Bob's tracking wallet"),
  196. ('bob_twview3', "viewing Bob's tracking wallet"),
  197. ('bob_subwallet_txcreate', 'creating a transaction with subwallet inputs'),
  198. ('bob_subwallet_txsign', 'signing a transaction with subwallet inputs'),
  199. ('bob_subwallet_txdo', "sending from Bob's subwallet addrs"),
  200. ('generate', 'mining a block'),
  201. ('bob_twview4', "viewing Bob's tracking wallet"),
  202. ('bob_alice_bal', "Bob and Alice's balances"),
  203. ('alice_bal2', "Alice's balance"),
  204. ('alice_add_label1', 'adding a label'),
  205. ('alice_chk_label1', 'the label'),
  206. ('alice_add_label2', 'adding a label'),
  207. ('alice_chk_label2', 'the label'),
  208. ('alice_edit_label1', 'editing a label (zh)'),
  209. ('alice_edit_label2', 'editing a label (lat+cyr+gr)'),
  210. ('alice_chk_label3', 'the label'),
  211. ('alice_remove_label1', 'removing a label'),
  212. ('alice_chk_label4', 'the label'),
  213. ('alice_add_label_coinaddr', 'adding a label using the coin address'),
  214. ('alice_chk_label_coinaddr', 'the label'),
  215. ('alice_add_label_badaddr1', 'adding a label with invalid address'),
  216. ('alice_add_label_badaddr2', 'adding a label with invalid address for this chain'),
  217. ('alice_add_label_badaddr3', 'adding a label with wrong MMGen address'),
  218. ('alice_add_label_badaddr4', 'adding a label with wrong coin address'),
  219. ('stop', 'stopping regtest daemon'),
  220. )
  221. usr_subsids = { 'bob': {}, 'alice': {} }
  222. def __init__(self,trunner,cfgs,spawn):
  223. coin = g.coin.lower()
  224. for k in rt_data:
  225. globals()[k] = rt_data[k][coin] if coin in rt_data[k] else None
  226. return TestSuiteBase.__init__(self,trunner,cfgs,spawn)
  227. def _add_comments_to_addr_file(self,addrfile,outfile,use_labels=False):
  228. silence()
  229. gmsg("Adding comments to address file '{}'".format(addrfile))
  230. a = AddrList(addrfile)
  231. for n,idx in enumerate(a.idxs(),1):
  232. if use_labels:
  233. a.set_comment(idx,get_label())
  234. else:
  235. if n % 2: a.set_comment(idx,'Test address {}'.format(n))
  236. a.format(add_comments=True)
  237. write_data_to_file(outfile,a.fmt_data,quiet=True,ignore_opt_outdir=True)
  238. end_silence()
  239. def setup(self):
  240. os.environ['MMGEN_BOGUS_WALLET_DATA'] = ''
  241. if g.testnet:
  242. die(2,'--testnet option incompatible with regtest test suite')
  243. try: shutil.rmtree(joinpath(self.tr.data_dir,'regtest'))
  244. except: pass
  245. os.environ['MMGEN_TEST_SUITE'] = '' # mnemonic is piped to stdin, so stop being a terminal
  246. t = self.spawn('mmgen-regtest',['-n','setup'])
  247. os.environ['MMGEN_TEST_SUITE'] = '1'
  248. for s in ('Starting setup','Creating','Mined','Creating','Creating','Setup complete'):
  249. t.expect(s)
  250. return t
  251. def walletgen(self,user):
  252. t = self.spawn('mmgen-walletgen',['-q','-r0','-p1','--'+user])
  253. t.passphrase_new('new '+dfl_wcls.desc,rt_pw)
  254. t.label()
  255. t.expect('move it to the data directory? (Y/n): ','y')
  256. t.written_to_file(capfirst(dfl_wcls.desc))
  257. return t
  258. def walletgen_bob(self): return self.walletgen('bob')
  259. def walletgen_alice(self): return self.walletgen('alice')
  260. def _user_dir(self,user,coin=None):
  261. return joinpath(self.tr.data_dir,'regtest',coin or g.coin.lower(),user)
  262. def _user_sid(self,user):
  263. return os.path.basename(get_file_with_ext(self._user_dir(user),'mmdat'))[:8]
  264. def _get_user_subsid(self,user,subseed_idx):
  265. if subseed_idx in self.usr_subsids[user]:
  266. return self.usr_subsids[user][subseed_idx]
  267. icls = Wallet
  268. fn = get_file_with_ext(self._user_dir(user),icls.ext)
  269. t = self.spawn('mmgen-tool',['get_subseed',subseed_idx,'wallet='+fn],no_msg=True)
  270. t.passphrase(icls.desc,rt_pw)
  271. sid = t.read().strip()[:8]
  272. self.usr_subsids[user][subseed_idx] = sid
  273. return sid
  274. def addrgen(self,user,wf=None,addr_range='1-5',subseed_idx=None,mmtypes=[]):
  275. from mmgen.addr import MMGenAddrType
  276. for mmtype in mmtypes or g.proto.mmtypes:
  277. t = self.spawn('mmgen-addrgen',
  278. ['--quiet','--'+user,'--type='+mmtype,'--outdir={}'.format(self._user_dir(user))] +
  279. ([wf] if wf else []) +
  280. (['--subwallet='+subseed_idx] if subseed_idx else []) +
  281. [addr_range],
  282. extra_desc='({})'.format(MMGenAddrType.mmtypes[mmtype].name))
  283. t.passphrase(dfl_wcls.desc,rt_pw)
  284. t.written_to_file('Addresses')
  285. ok_msg()
  286. t.skip_ok = True
  287. return t
  288. def addrgen_bob(self): return self.addrgen('bob')
  289. def addrgen_alice(self): return self.addrgen('alice')
  290. def addrimport(self,user,sid=None,addr_range='1-5',num_addrs=5,mmtypes=[]):
  291. id_strs = { 'legacy':'', 'compressed':'-C', 'segwit':'-S', 'bech32':'-B' }
  292. if not sid: sid = self._user_sid(user)
  293. from mmgen.addr import MMGenAddrType
  294. for mmtype in mmtypes or g.proto.mmtypes:
  295. desc = MMGenAddrType.mmtypes[mmtype].name
  296. addrfile = joinpath(self._user_dir(user),
  297. '{}{}{}[{}]{x}.testnet.addrs'.format(
  298. sid,self.altcoin_pfx,id_strs[desc],addr_range,
  299. x='-α' if g.debug_utf8 else ''))
  300. if mmtype == g.proto.mmtypes[0] and user == 'bob':
  301. psave = g.proto
  302. g.proto = CoinProtocol(g.coin,True)
  303. self._add_comments_to_addr_file(addrfile,addrfile,use_labels=True)
  304. g.proto = psave
  305. t = self.spawn( 'mmgen-addrimport',
  306. ['--quiet', '--'+user, '--batch', addrfile],
  307. extra_desc='({})'.format(desc))
  308. if g.debug:
  309. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  310. t.expect('Importing')
  311. t.expect('{} addresses imported'.format(num_addrs))
  312. ok_msg()
  313. t.skip_ok = True
  314. return t
  315. def addrimport_bob(self): return self.addrimport('bob')
  316. def addrimport_alice(self): return self.addrimport('alice')
  317. def fund_wallet(self,user,mmtype,amt,sid=None,addr_range='1-5'):
  318. if not sid: sid = self._user_sid(user)
  319. addr = self.get_addr_from_addrlist(user,sid,mmtype,0,addr_range=addr_range)
  320. t = self.spawn('mmgen-regtest', ['send',str(addr),str(amt)])
  321. t.expect('Sending {} {}'.format(amt,g.coin))
  322. t.expect('Mined 1 block')
  323. return t
  324. def fund_bob(self): return self.fund_wallet('bob','C',rtFundAmt)
  325. def fund_alice(self): return self.fund_wallet('alice',('L','S')[g.proto.cap('segwit')],rtFundAmt)
  326. def user_twview(self,user,chk=None,sort='age'):
  327. t = self.spawn('mmgen-tool',['--'+user,'twview','sort='+sort])
  328. if chk: t.expect(chk,regex=True)
  329. t.read()
  330. return t
  331. def bob_twview1(self): return self.user_twview('bob',chk=r'1\).*\b{}\b'.format(rtAmts[0]))
  332. def user_bal(self,user,bal,args=['showempty=1'],skip_check=False,exit_val=0):
  333. t = self.spawn('mmgen-tool',['--'+user,'listaddresses'] + args)
  334. if skip_check:
  335. t.read()
  336. else:
  337. total = t.expect_getend('TOTAL: ')
  338. cmp_or_die('{} {}'.format(bal,g.coin),total)
  339. t.req_exit_val = exit_val
  340. return t
  341. def alice_bal1(self):
  342. return self.user_bal('alice',rtFundAmt)
  343. def alice_bal2(self):
  344. return self.user_bal('alice',rtBals[8])
  345. def bob_bal1(self):
  346. return self.user_bal('bob',rtFundAmt)
  347. def bob_bal2(self):
  348. return self.user_bal('bob',rtBals[0])
  349. def bob_bal2a(self):
  350. return self.user_bal('bob',rtBals[0],args=['showempty=1','age_fmt=confs'])
  351. def bob_bal2b(self):
  352. return self.user_bal('bob',rtBals[0],args=['showempty=1'])
  353. def bob_bal2c(self):
  354. return self.user_bal('bob',rtBals[0],args=['showempty=1','minconf=2','age_fmt=days'],skip_check=True)
  355. def bob_bal2d(self):
  356. return self.user_bal('bob',rtBals[0],args=['minconf=2'],skip_check=True)
  357. def bob_bal2e(self):
  358. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age'])
  359. def bob_bal2f(self):
  360. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=age,reverse'])
  361. def bob_bal3(self):
  362. return self.user_bal('bob',rtBals[1])
  363. def bob_bal4(self):
  364. return self.user_bal('bob',rtBals[2])
  365. def bob_bal5(self):
  366. return self.user_bal('bob',rtBals[3])
  367. def bob_bal6(self):
  368. return self.user_bal('bob',rtBals[7])
  369. def bob_subwallet_addrgen1(self):
  370. return self.addrgen('bob',subseed_idx='29L',mmtypes=['C']) # 29L: 2FA7BBA8
  371. def bob_subwallet_addrgen2(self):
  372. return self.addrgen('bob',subseed_idx='127S',mmtypes=['C']) # 127S: '09E8E286'
  373. def subwallet_addrimport(self,user,subseed_idx):
  374. sid = self._get_user_subsid(user,subseed_idx)
  375. return self.addrimport(user,sid=sid,mmtypes=['C'])
  376. def bob_subwallet_addrimport1(self): return self.subwallet_addrimport('bob','29L')
  377. def bob_subwallet_addrimport2(self): return self.subwallet_addrimport('bob','127S')
  378. def bob_subwallet_fund(self):
  379. sid1 = self._get_user_subsid('bob','29L')
  380. sid2 = self._get_user_subsid('bob','127S')
  381. chg_addr = self._user_sid('bob') + (':B:1',':L:1')[g.coin=='BCH']
  382. outputs_cl = [sid1+':C:2,0.29',sid2+':C:3,0.127',chg_addr]
  383. inputs = ('3','1')[g.coin=='BCH']
  384. return self.user_txdo('bob',rtFee[1],outputs_cl,inputs,extra_args=['--subseeds=127'])
  385. def bob_twview2(self):
  386. sid1 = self._get_user_subsid('bob','29L')
  387. return self.user_twview('bob',chk=r'\b{}:C:2\b\s+{}'.format(sid1,'0.29'),sort='twmmid')
  388. def bob_twview3(self):
  389. sid2 = self._get_user_subsid('bob','127S')
  390. return self.user_twview('bob',chk=r'\b{}:C:3\b\s+{}'.format(sid2,'0.127'),sort='amt')
  391. def bob_subwallet_txcreate(self):
  392. sid1 = self._get_user_subsid('bob','29L')
  393. sid2 = self._get_user_subsid('bob','127S')
  394. outputs_cl = [sid1+':C:5,0.0159',sid2+':C:5']
  395. t = self.spawn('mmgen-txcreate',['-d',self.tmpdir,'-B','--bob'] + outputs_cl)
  396. return self.txcreate_ui_common(t,
  397. menu = ['a'],
  398. inputs = ('1,2','2,3')[g.coin=='BCH'],
  399. interactive_fee = '0.00001')
  400. def bob_subwallet_txsign(self):
  401. fn = get_file_with_ext(self.tmpdir,'rawtx')
  402. t = self.spawn('mmgen-txsign',['-d',self.tmpdir,'--bob','--subseeds=127',fn])
  403. t.view_tx('t')
  404. t.passphrase(dfl_wcls.desc,rt_pw)
  405. t.do_comment(None)
  406. t.expect('(Y/n): ','y')
  407. t.written_to_file('Signed transaction')
  408. return t
  409. def bob_subwallet_txdo(self):
  410. outputs_cl = [self._user_sid('bob')+':L:5']
  411. inputs = ('1,2','2,3')[g.coin=='BCH']
  412. return self.user_txdo('bob',rtFee[5],outputs_cl,inputs,menu=['a'],extra_args=['--subseeds=127']) # sort: amt
  413. def bob_twview4(self):
  414. sid = self._user_sid('bob')
  415. amt = ('0.4169328','0.41364')[g.coin=='LTC']
  416. return self.user_twview('bob',chk=r'\b{}:L:5\b\s+.*\s+\b{}\b'.format(sid,amt),sort='twmmid')
  417. def bob_getbalance(self,bals,confs=1):
  418. for i in (0,1,2):
  419. assert Decimal(bals['mmgen'][i]) + Decimal(bals['nonmm'][i]) == Decimal(bals['total'][i])
  420. t = self.spawn('mmgen-tool',['--bob','getbalance','minconf={}'.format(confs)])
  421. for k in ('mmgen','nonmm','total'):
  422. t.expect(r'\n\S+:\s+{} {c}\s+{} {c}\s+{} {c}'.format(*bals[k],c=g.coin),regex=True)
  423. t.read()
  424. return t
  425. def bob_0conf0_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf0'],confs=0)
  426. def bob_0conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf1'],confs=1)
  427. def bob_1conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf1'],confs=1)
  428. def bob_1conf2_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf2'],confs=2)
  429. def bob_alice_bal(self):
  430. t = self.spawn('mmgen-regtest',['get_balances'])
  431. t.expect('Switching')
  432. ret = t.expect_getend("Bob's balance:").strip()
  433. cmp_or_die(rtBals[4],ret)
  434. ret = t.expect_getend("Alice's balance:").strip()
  435. cmp_or_die(rtBals[5],ret)
  436. ret = t.expect_getend("Total balance:").strip()
  437. cmp_or_die(rtBals[6],ret)
  438. return t
  439. def user_txsend_status(self,user,tx_file,exp1='',exp2='',extra_args=[],bogus_send=False):
  440. os.environ['MMGEN_BOGUS_SEND'] = ('','1')[bool(bogus_send)]
  441. t = self.spawn('mmgen-txsend',['-d',self.tmpdir,'--'+user,'--status'] + extra_args + [tx_file])
  442. os.environ['MMGEN_BOGUS_SEND'] = '1'
  443. if exp1: t.expect(exp1,regex=True)
  444. if exp2: t.expect(exp2,regex=True)
  445. return t
  446. def user_txdo( self, user, fee, outputs_cl, outputs_list,
  447. extra_args = [],
  448. wf = None,
  449. do_label = False,
  450. bad_locktime = False,
  451. full_tx_view = False,
  452. menu = ['M'],
  453. bogus_send = False):
  454. os.environ['MMGEN_BOGUS_SEND'] = ('','1')[bool(bogus_send)]
  455. t = self.spawn('mmgen-txdo',
  456. ['-d',self.tmpdir,'-B','--'+user] +
  457. (['--tx-fee='+fee] if fee else []) +
  458. extra_args + ([],[wf])[bool(wf)] + outputs_cl)
  459. os.environ['MMGEN_BOGUS_SEND'] = '1'
  460. self.txcreate_ui_common(t,
  461. caller = 'txdo',
  462. menu = menu,
  463. inputs = outputs_list,
  464. file_desc = 'Signed transaction',
  465. interactive_fee = (tx_fee,'')[bool(fee)],
  466. add_comment = tx_label_jp,
  467. view = 't',save=True)
  468. t.passphrase(dfl_wcls.desc,rt_pw)
  469. t.written_to_file('Signed transaction')
  470. self._do_confirm_send(t)
  471. s,exit_val = (('Transaction sent',0),("can't be included",1))[bad_locktime]
  472. t.expect(s)
  473. t.req_exit_val = exit_val
  474. return t
  475. def bob_split1(self):
  476. sid = self._user_sid('bob')
  477. outputs_cl = [sid+':C:1,100', sid+':L:2,200',sid+':'+rtBobOp3]
  478. return self.user_txdo('bob',rtFee[0],outputs_cl,'1',do_label=True,full_tx_view=True)
  479. def get_addr_from_addrlist(self,user,sid,mmtype,idx,addr_range='1-5'):
  480. id_str = { 'L':'', 'S':'-S', 'C':'-C', 'B':'-B' }[mmtype]
  481. ext = '{}{}{}[{}]{x}.testnet.addrs'.format(
  482. sid,self.altcoin_pfx,id_str,addr_range,x='-α' if g.debug_utf8 else '')
  483. addrfile = get_file_with_ext(self._user_dir(user),ext,no_dot=True)
  484. psave = g.proto
  485. g.proto = CoinProtocol(g.coin,True)
  486. if hasattr(g.proto,'bech32_hrp_rt'):
  487. g.proto.bech32_hrp = g.proto.bech32_hrp_rt
  488. silence()
  489. addr = AddrList(addrfile).data[idx].addr
  490. end_silence()
  491. g.proto = psave
  492. return addr
  493. def _create_tx_outputs(self,user,data):
  494. sid = self._user_sid(user)
  495. return [self.get_addr_from_addrlist(user,sid,mmtype,idx-1)+amt_str for mmtype,idx,amt_str in data]
  496. def bob_rbf_1output_create(self):
  497. if g.coin != 'BTC': return 'skip' # non-coin-dependent test, so run just once for BTC
  498. out_addr = self._create_tx_outputs('alice',(('B',5,''),))
  499. t = self.spawn('mmgen-txcreate',['-d',self.tr.trash_dir,'-B','--bob','--rbf'] + out_addr)
  500. return self.txcreate_ui_common(t,menu=[],inputs='3',interactive_fee='3s') # out amt: 199.99999343
  501. def bob_rbf_1output_bump(self):
  502. if g.coin != 'BTC': return 'skip'
  503. ext = '9343,3]{x}.testnet.rawtx'.format(x='-α' if g.debug_utf8 else '')
  504. txfile = get_file_with_ext(self.tr.trash_dir,ext,delete=False,no_dot=True)
  505. return self.user_txbump('bob',self.tr.trash_dir,txfile,'8s',has_label=False,signed_tx=False,one_output=True)
  506. def bob_send_maybe_rbf(self):
  507. outputs_cl = self._create_tx_outputs('alice',(('L',1,',60'),('C',1,',40'))) # alice_sid:L:1, alice_sid:C:1
  508. outputs_cl += [self._user_sid('bob')+':'+rtBobOp3]
  509. return self.user_txdo('bob',rtFee[1],outputs_cl,'3',
  510. extra_args=([],['--rbf'])[g.proto.cap('rbf')])
  511. def bob_send_non_mmgen(self):
  512. outputs_cl = self._create_tx_outputs('alice',(
  513. (('L','S')[g.proto.cap('segwit')],2,',10'),
  514. (('L','S')[g.proto.cap('segwit')],3,'')
  515. )) # alice_sid:S:2, alice_sid:S:3
  516. keyfile = joinpath(self.tmpdir,'non-mmgen.keys')
  517. return self.user_txdo('bob',rtFee[3],outputs_cl,'1,4-10',
  518. extra_args=['--keys-from-file='+keyfile,'--vsize-adj=1.02'])
  519. def alice_send_estimatefee(self):
  520. outputs_cl = self._create_tx_outputs('bob',(('L',1,''),)) # bob_sid:L:1
  521. return self.user_txdo('alice',None,outputs_cl,'1') # fee=None
  522. def user_txbump(self,user,outdir,txfile,fee,add_args=[],has_label=True,signed_tx=True,one_output=False):
  523. if not g.proto.cap('rbf'): return 'skip'
  524. os.environ['MMGEN_BOGUS_SEND'] = ''
  525. t = self.spawn('mmgen-txbump',
  526. ['-d',outdir,'--'+user,'--tx-fee='+fee,'--output-to-reduce=c'] + add_args + [txfile])
  527. os.environ['MMGEN_BOGUS_SEND'] = '1'
  528. if not one_output:
  529. t.expect('OK? (Y/n): ','y') # output OK?
  530. t.expect('OK? (Y/n): ','y') # fee OK?
  531. t.do_comment(False,has_label=has_label)
  532. if signed_tx:
  533. t.passphrase(dfl_wcls.desc,rt_pw)
  534. t.written_to_file('Signed transaction')
  535. self.txsend_ui_common(t,caller='txdo',bogus_send=False,file_desc='Signed transaction')
  536. else:
  537. t.expect('Save transaction? (y/N): ','y')
  538. t.written_to_file('Transaction')
  539. t.read()
  540. return t
  541. def bob_rbf_bump(self):
  542. ext = ',{}]{x}.testnet.sigtx'.format(rtFee[1][:-1],x='-α' if g.debug_utf8 else '')
  543. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  544. return self.user_txbump('bob',self.tmpdir,txfile,rtFee[2],add_args=['--send'])
  545. def generate(self,coin=None,num_blocks=1):
  546. int(num_blocks)
  547. if coin: opt.coin = coin
  548. t = self.spawn('mmgen-regtest',['generate',str(num_blocks)])
  549. t.expect('Mined {} block'.format(num_blocks))
  550. return t
  551. def _get_mempool(self):
  552. disable_debug()
  553. ret = self.spawn('mmgen-regtest',['show_mempool']).read()
  554. restore_debug()
  555. m = re.search(r'(\[\s*"[a-f0-9]{64}"\s*])',ret) # allow for extra output by handler at end
  556. return json.loads(m.group(1))
  557. def get_mempool1(self):
  558. mp = self._get_mempool()
  559. if len(mp) != 1:
  560. rdie(2,'Mempool has more or less than one TX!')
  561. self.write_to_tmpfile('rbf_txid',mp[0]+'\n')
  562. return 'ok'
  563. def bob_rbf_status(self,fee,exp1,exp2=''):
  564. if not g.proto.cap('rbf'): return 'skip'
  565. ext = ',{}]{x}.testnet.sigtx'.format(fee[:-1],x='-α' if g.debug_utf8 else '')
  566. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  567. return self.user_txsend_status('bob',txfile,exp1,exp2)
  568. def bob_rbf_status1(self):
  569. if not g.proto.cap('rbf'): return 'skip'
  570. return self.bob_rbf_status(rtFee[1],'in mempool, replaceable')
  571. def get_mempool2(self):
  572. if not g.proto.cap('rbf'): return 'skip'
  573. mp = self._get_mempool()
  574. if len(mp) != 1:
  575. rdie(2,'Mempool has more or less than one TX!')
  576. chk = self.read_from_tmpfile('rbf_txid')
  577. if chk.strip() == mp[0]:
  578. rdie(2,'TX in mempool has not changed! RBF bump failed')
  579. self.write_to_tmpfile('rbf_txid2',mp[0]+'\n')
  580. return 'ok'
  581. def bob_rbf_status2(self):
  582. if not g.proto.cap('rbf'): return 'skip'
  583. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  584. return self.bob_rbf_status(rtFee[1],
  585. 'Transaction has been replaced','{} in mempool'.format(new_txid))
  586. def bob_rbf_status3(self):
  587. if not g.proto.cap('rbf'): return 'skip'
  588. return self.bob_rbf_status(rtFee[2],'status: in mempool, replaceable')
  589. def bob_rbf_status4(self):
  590. if not g.proto.cap('rbf'): return 'skip'
  591. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  592. return self.bob_rbf_status(rtFee[1],
  593. 'Replacement transaction has 1 confirmation',
  594. 'Replacing transactions:\s+{}'.format(new_txid))
  595. def bob_rbf_status5(self):
  596. if not g.proto.cap('rbf'): return 'skip'
  597. return self.bob_rbf_status(rtFee[2],'Transaction has 1 confirmation')
  598. def bob_rbf_status6(self):
  599. if not g.proto.cap('rbf'): return 'skip'
  600. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  601. return self.bob_rbf_status(rtFee[1],
  602. 'Replacement transaction has 2 confirmations',
  603. 'Replacing transactions:\s+{}'.format(new_txid))
  604. @staticmethod
  605. def _gen_pairs(n):
  606. disable_debug()
  607. from subprocess import run,PIPE
  608. ret = [run(['python3',joinpath('cmds','mmgen-tool'),'--testnet=1'] +
  609. (['--type=compressed'],[])[i==0] +
  610. ['-r0','randpair'],
  611. stdout=PIPE,check=True
  612. ).stdout.decode().split() for i in range(n)]
  613. restore_debug()
  614. return ret
  615. def bob_pre_import(self):
  616. pairs = self._gen_pairs(5)
  617. self.write_to_tmpfile('non-mmgen.keys','\n'.join([a[0] for a in pairs])+'\n')
  618. self.write_to_tmpfile('non-mmgen.addrs','\n'.join([a[1] for a in pairs])+'\n')
  619. return self.user_txdo('bob',rtFee[4],[pairs[0][1]],'3')
  620. def user_import(self,user,args):
  621. t = self.spawn('mmgen-addrimport',['--quiet','--'+user]+args)
  622. if g.debug:
  623. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  624. t.expect('Importing')
  625. t.expect('OK')
  626. return t
  627. def bob_import_addr(self):
  628. addr = self.read_from_tmpfile('non-mmgen.addrs').split()[0]
  629. return self.user_import('bob',['--rescan','--address='+addr])
  630. def bob_import_list(self):
  631. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  632. return self.user_import('bob',['--addrlist',addrfile])
  633. def bob_split2(self):
  634. addrs = self.read_from_tmpfile('non-mmgen.addrs').split()
  635. amts = (1.12345678,2.87654321,3.33443344,4.00990099,5.43214321)
  636. outputs1 = list(map('{},{}'.format,addrs,amts))
  637. sid = self._user_sid('bob')
  638. l1,l2 = (':S',':B') if 'B' in g.proto.mmtypes else (':S',':S') if g.proto.cap('segwit') else (':L',':L')
  639. outputs2 = [sid+':C:2,6.333', sid+':L:3,6.667',sid+l1+':4,0.123',sid+l2+':5']
  640. return self.user_txdo('bob',rtFee[5],outputs1+outputs2,'1-2')
  641. def user_add_label(self,user,addr,label):
  642. t = self.spawn('mmgen-tool',['--'+user,'add_label',addr,label])
  643. t.expect('Added label.*in tracking wallet',regex=True)
  644. return t
  645. def user_remove_label(self,user,addr):
  646. t = self.spawn('mmgen-tool',['--'+user,'remove_label',addr])
  647. t.expect('Removed label.*in tracking wallet',regex=True)
  648. return t
  649. def bob_add_label(self):
  650. sid = self._user_sid('bob')
  651. return self.user_add_label('bob',sid+':C:1',tw_label_lat_cyr_gr)
  652. def alice_add_label1(self):
  653. sid = self._user_sid('alice')
  654. return self.user_add_label('alice',sid+':C:1','Original Label - 月へ')
  655. def alice_add_label2(self):
  656. sid = self._user_sid('alice')
  657. return self.user_add_label('alice',sid+':C:1','Replacement Label')
  658. def alice_add_label_coinaddr(self):
  659. mmid = self._user_sid('alice') + (':S:1',':L:1')[g.coin=='BCH']
  660. t = self.spawn('mmgen-tool',['--alice','listaddress',mmid],no_msg=True)
  661. btcaddr = [i for i in t.read().splitlines() if i.lstrip()[0:len(mmid)] == mmid][0].split()[1]
  662. return self.user_add_label('alice',btcaddr,'Label added using coin address')
  663. def user_chk_label(self,user,addr,label):
  664. t = self.spawn('mmgen-tool',['--'+user,'listaddresses','all_labels=1'])
  665. t.expect(r'{}\s+\S{{30}}\S+\s+{}\s+'.format(addr,label),regex=True)
  666. return t
  667. def alice_chk_label_coinaddr(self):
  668. mmid = self._user_sid('alice') + (':S:1',':L:1')[g.coin=='BCH']
  669. return self.user_chk_label('alice',mmid,'Label added using coin address')
  670. def alice_add_label_badaddr(self,addr,reply):
  671. t = self.spawn('mmgen-tool',['--alice','add_label',addr,'(none)'])
  672. t.expect(reply,regex=True)
  673. return t
  674. def alice_add_label_badaddr1(self):
  675. return self.alice_add_label_badaddr(rt_pw,'Invalid coin address for this chain: ')
  676. def alice_add_label_badaddr2(self):
  677. addr = g.proto.pubhash2addr('00'*20,False) # mainnet zero address
  678. return self.alice_add_label_badaddr(addr,'Invalid coin address for this chain: '+addr)
  679. def alice_add_label_badaddr3(self):
  680. addr = self._user_sid('alice') + ':C:123'
  681. return self.alice_add_label_badaddr(addr,
  682. "MMGen address '{}' not found in tracking wallet".format(addr))
  683. def alice_add_label_badaddr4(self):
  684. addr = CoinProtocol(g.coin,True).pubhash2addr('00'*20,False) # testnet zero address
  685. return self.alice_add_label_badaddr(addr,
  686. "Address '{}' not found in tracking wallet".format(addr))
  687. def alice_bal_rpcfail(self):
  688. addr = self._user_sid('alice') + ':C:2'
  689. os.environ['MMGEN_RPC_FAIL_ON_COMMAND'] = 'listunspent'
  690. t = self.spawn('mmgen-tool',['--alice','getbalance'])
  691. os.environ['MMGEN_RPC_FAIL_ON_COMMAND'] = ''
  692. t.expect('Method not found')
  693. t.read()
  694. t.req_exit_val = 3
  695. return t
  696. def alice_remove_label1(self):
  697. sid = self._user_sid('alice')
  698. mmid = sid + (':S:3',':L:3')[g.coin=='BCH']
  699. return self.user_remove_label('alice',mmid)
  700. def alice_chk_label1(self):
  701. sid = self._user_sid('alice')
  702. return self.user_chk_label('alice',sid+':C:1','Original Label - 月へ')
  703. def alice_chk_label2(self):
  704. sid = self._user_sid('alice')
  705. return self.user_chk_label('alice',sid+':C:1','Replacement Label')
  706. def alice_edit_label1(self): return self.user_edit_label('alice','4',tw_label_lat_cyr_gr)
  707. def alice_edit_label2(self): return self.user_edit_label('alice','3',tw_label_zh)
  708. def alice_chk_label3(self):
  709. sid = self._user_sid('alice')
  710. mmid = sid + (':S:3',':L:3')[g.coin=='BCH']
  711. return self.user_chk_label('alice',mmid,tw_label_lat_cyr_gr)
  712. def alice_chk_label4(self):
  713. sid = self._user_sid('alice')
  714. mmid = sid + (':S:3',':L:3')[g.coin=='BCH']
  715. return self.user_chk_label('alice',mmid,'-')
  716. def user_edit_label(self,user,output,label):
  717. t = self.spawn('mmgen-txcreate',['-B','--'+user,'-i'])
  718. t.expect(r'add \[l\]abel:.','M',regex=True)
  719. t.expect(r'add \[l\]abel:.','l',regex=True)
  720. t.expect(r"Enter unspent.*return to main menu\):.",output+'\n',regex=True)
  721. t.expect(r"Enter label text.*return to main menu\):.",label+'\n',regex=True)
  722. t.expect(r'\[q\]uit view, .*?:.','q',regex=True)
  723. return t
  724. def stop(self):
  725. if opt.no_daemon_stop:
  726. self.spawn('',msg_only=True)
  727. msg_r('(leaving daemon running by user request)')
  728. return 'ok'
  729. else:
  730. return self.spawn('mmgen-regtest',['stop'])