ts_regtest.py 29 KB

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