ts_regtest.py 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507
  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. test.test_py_d.ts_regtest: Regtest tests for the test.py test suite
  20. """
  21. import os,json,time
  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','283.22339537'),
  58. 'nonmm': ('16.77647763','116.77629233'),
  59. 'total': ('299.999873','399.9996877'),
  60. },
  61. '0conf1': {
  62. 'mmgen': ('283.22339537','0'),
  63. 'nonmm': ('16.77647763','99.9998147'),
  64. 'total': ('299.999873','99.9998147'),
  65. },
  66. '1conf1': {
  67. 'mmgen': ('0','283.22339537'),
  68. 'nonmm': ('0','116.77629233'),
  69. 'total': ('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','283.22339437'),
  80. 'nonmm': ('16.77647763','116.77637483'),
  81. 'total': ('299.999872','399.9997692'),
  82. },
  83. '0conf1': {
  84. 'mmgen': ('283.22339437','0'),
  85. 'nonmm': ('16.77647763','99.9998972'),
  86. 'total': ('299.999872','99.9998972'),
  87. },
  88. '1conf1': {
  89. 'mmgen': ('0','283.22339437'),
  90. 'nonmm': ('0','116.77637483'),
  91. 'total': ('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','283.21717237'),
  102. 'nonmm': ('16.77647763','5116.77036263'),
  103. 'total': ('299.99365','5399.987535'),
  104. },
  105. '0conf1': {
  106. 'mmgen': ('283.21717237','0'),
  107. 'nonmm': ('16.77647763','5099.993885'),
  108. 'total': ('299.99365','5099.993885'),
  109. },
  110. '1conf1': {
  111. 'mmgen': ('0','283.21717237'),
  112. 'nonmm': ('0','5116.77036263'),
  113. 'total': ('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','rpc_backend')
  141. extra_spawn_args = ['--regtest=1']
  142. tmpdir_nums = [17]
  143. color = True
  144. deterministic = False
  145. test_rbf = False
  146. cmd_group_in = (
  147. ('setup', 'regtest (Bob and Alice) mode setup'),
  148. ('subgroup.misc', []),
  149. ('subgroup.init_bob', []),
  150. ('subgroup.init_alice', []),
  151. ('subgroup.fund_users', ['init_bob','init_alice']),
  152. ('subgroup.msg', ['init_bob']),
  153. ('subgroup.twexport', ['fund_users']),
  154. ('subgroup.rescan', ['fund_users']),
  155. ('subgroup.main', ['fund_users']),
  156. ('subgroup.txhist', ['main']),
  157. ('subgroup.label', ['main']),
  158. ('subgroup.view', ['label']),
  159. ('subgroup.auto_chg', ['label']),
  160. ('stop', 'stopping regtest daemon'),
  161. )
  162. cmd_subgroups = {
  163. 'misc': (
  164. 'miscellaneous commands',
  165. ('daemon_version', 'mmgen-tool daemon_version'),
  166. ('halving_calculator_bob', 'halving calculator (Bob)'),
  167. ),
  168. 'init_bob': (
  169. 'creating Bob’s MMGen wallet and tracking wallet',
  170. ('walletgen_bob', 'wallet generation (Bob)'),
  171. ('addrgen_bob', 'address generation (Bob)'),
  172. ('addrimport_bob', "importing Bob's addresses"),
  173. ),
  174. 'init_alice': (
  175. 'creating Alice’s MMGen wallet and tracking wallet',
  176. ('walletgen_alice', 'wallet generation (Alice)'),
  177. ('addrgen_alice', 'address generation (Alice)'),
  178. ('addrimport_alice', "importing Alice's addresses"),
  179. ),
  180. 'fund_users': (
  181. 'funding Bob and Alice’s wallets',
  182. ('bob_import_miner_addr', "importing miner’s coinbase addr into Bob’s wallet"),
  183. ('fund_bob_deterministic', "funding Bob’s first MMGen address (deterministic method)"),
  184. ('fund_alice_deterministic', "funding Alice’s first MMGen address (deterministic method)"),
  185. ('bob_recreate_tracking_wallet', 'creation of new tracking wallet (Bob)'),
  186. ('addrimport_bob2', "reimporting Bob's addresses"),
  187. ('fund_bob', "funding Bob's wallet"),
  188. ('fund_alice', "funding Alice's wallet"),
  189. ('generate', 'mining a block'),
  190. ('bob_bal1', "Bob's balance"),
  191. ('generate_extra_deterministic', "generate extra blocks for deterministic run"),
  192. ),
  193. 'msg': (
  194. 'message signing',
  195. ('bob_msgcreate', 'creating a message file for signing'),
  196. ('bob_msgsign', 'signing the message file (default wallet)'),
  197. ('bob_walletconv_words', 'creating an MMGen mnemonic wallet'),
  198. ('bob_subwalletgen_bip39', 'creating a BIP39 mnemonic subwallet'),
  199. ('bob_msgsign_userwallet', 'signing the message file (user-specified wallet)'),
  200. ('bob_msgsign_userwallets', 'signing the message file (user-specified wallets)'),
  201. ('bob_msgverify', 'verifying the message file (all addresses)'),
  202. ('bob_msgverify_raw', 'verifying the raw message file (all addresses)'),
  203. ('bob_msgverify_single', 'verifying the message file (single address)'),
  204. ('bob_msgexport_single', 'exporting the message file (single address)'),
  205. ('bob_msgexport', 'exporting the message file (all addresses)'),
  206. ('bob_msgverify_export', 'verifying the exported JSON data (all addresses)'),
  207. ('bob_msgverify_export_single', 'verifying the exported JSON data (single address)'),
  208. ),
  209. 'twexport': (
  210. 'exporting and importing tracking wallet to JSON',
  211. ('bob_twexport', 'exporting a tracking wallet to JSON'),
  212. ('carol_twimport', 'importing a tracking wallet JSON dump'),
  213. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  214. ('bob_twexport_noamt', 'exporting a tracking wallet to JSON (include_amts=0)'),
  215. ('carol_twimport_nochksum', 'importing a tracking wallet JSON dump (ignore_checksum=1)'),
  216. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  217. ('carol_twimport_batch', 'importing a tracking wallet JSON dump (batch=1)'),
  218. ('bob_twexport_pretty', 'exporting a tracking wallet to JSON (pretty=1)'),
  219. ('bob_edit_json_twdump', 'editing a tracking wallet JSON dump'),
  220. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  221. ('carol_twimport_pretty', 'importing an edited tracking wallet JSON dump (ignore_checksum=1)'),
  222. ('carol_listaddresses', 'viewing Carol’s tracking wallet'),
  223. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  224. ),
  225. 'rescan': (
  226. 'rescanning address and blockchain',
  227. ('bob_resolve_addr', 'resolving an address in the tracking wallet'),
  228. ('bob_rescan_addr', 'rescanning an address'),
  229. ('bob_rescan_blockchain_all', 'rescanning the blockchain (full rescan)'),
  230. ('bob_rescan_blockchain_gb', 'rescanning the blockchain (Genesis block)'),
  231. ('bob_rescan_blockchain_one', 'rescanning the blockchain (single block)'),
  232. ('bob_rescan_blockchain_ss', 'rescanning the blockchain (range of blocks)'),
  233. ),
  234. 'main': (
  235. 'creating, signing, sending and bumping transactions',
  236. ('bob_add_comment', "adding an 80-screen-width label (lat+cyr+gr)"),
  237. ('bob_twview1', "viewing Bob's tracking wallet"),
  238. ('bob_split1', "splitting Bob's funds"),
  239. ('generate', 'mining a block'),
  240. ('bob_bal2', "Bob's balance"),
  241. ('bob_rbf_1output_create', 'creating RBF tx with one output'),
  242. ('bob_rbf_1output_bump', 'bumping RBF tx with one output'),
  243. ('bob_bal2a', "Bob's balance (age_fmt=confs)"),
  244. ('bob_bal2b', "Bob's balance (showempty=1)"),
  245. ('bob_bal2c', "Bob's balance (showempty=1 minconf=2 age_fmt=days)"),
  246. ('bob_bal2d', "Bob's balance (minconf=2)"),
  247. ('bob_bal2e', "Bob's balance (showempty=1 sort=age)"),
  248. ('bob_bal2f', "Bob's balance (showempty=1 sort=age,reverse)"),
  249. ('bob_send_maybe_rbf', 'sending funds to Alice (RBF, if supported)'),
  250. ('get_mempool1', 'mempool (before RBF bump)'),
  251. ('bob_rbf_status1', 'getting status of transaction'),
  252. ('bob_rbf_bump', 'bumping RBF transaction'),
  253. ('get_mempool2', 'mempool (after RBF bump)'),
  254. ('bob_rbf_status2', 'getting status of transaction after replacement'),
  255. ('bob_rbf_status3', 'getting status of replacement transaction (mempool)'),
  256. ('generate', 'mining a block'),
  257. ('bob_rbf_status4', 'getting status of transaction after confirmed (1) replacement'),
  258. ('bob_rbf_status5', 'getting status of replacement transaction (confirmed)'),
  259. ('generate', 'mining a block'),
  260. ('bob_rbf_status6', 'getting status of transaction after confirmed (2) replacement'),
  261. ('bob_bal3', "Bob's balance"),
  262. ('bob_pre_import', 'sending to non-imported address'),
  263. ('generate', 'mining a block'),
  264. ('bob_import_addr', 'importing non-MMGen address'),
  265. ('bob_bal4', "Bob's balance (after import)"),
  266. ('bob_import_list', 'importing flat address list'),
  267. ('bob_import_list_rescan', 'importing flat address list with --rescan'),
  268. ('bob_import_list_rescan_aio', 'importing flat address list with --rescan (aiohttp backend)'),
  269. ('bob_split2', "splitting Bob's funds"),
  270. ('bob_0conf0_getbalance', "Bob's balance (unconfirmed, minconf=0)"),
  271. ('bob_0conf1_getbalance', "Bob's balance (unconfirmed, minconf=1)"),
  272. ('generate', 'mining a block'),
  273. ('bob_1conf1_getbalance', "Bob's balance (confirmed, minconf=1)"),
  274. ('bob_1conf2_getbalance', "Bob's balance (confirmed, minconf=2)"),
  275. ('bob_bal5', "Bob's balance"),
  276. ('bob_send_non_mmgen', 'sending funds to Alice (from non-MMGen addrs)'),
  277. ('generate', 'mining a block'),
  278. ('alice_send_estimatefee', 'tx creation with no fee on command line'),
  279. ('generate', 'mining a block'),
  280. ('bob_bal6', "Bob's balance"),
  281. ('bob_subwallet_addrgen1', "generating Bob's addrs from subwallet 29L"),
  282. ('bob_subwallet_addrgen2', "generating Bob's addrs from subwallet 127S"),
  283. ('bob_subwallet_addrimport1', "importing Bob's addrs from subwallet 29L"),
  284. ('bob_subwallet_addrimport2', "importing Bob's addrs from subwallet 127S"),
  285. ('bob_subwallet_fund', "funding Bob's subwallet addrs"),
  286. ('generate', 'mining a block'),
  287. ('bob_twview2', "viewing Bob's tracking wallet"),
  288. ('bob_twview3', "viewing Bob's tracking wallet"),
  289. ('bob_subwallet_txcreate', 'creating a transaction with subwallet inputs'),
  290. ('bob_subwallet_txsign', 'signing a transaction with subwallet inputs'),
  291. ('bob_subwallet_txdo', "sending from Bob's subwallet addrs"),
  292. ('generate', 'mining a block'),
  293. ('bob_twview4', "viewing Bob's tracking wallet"),
  294. ('bob_alice_bal', "Bob and Alice's balances"),
  295. ('bob_nochg_burn', 'zero-change transaction to burn address'),
  296. ('generate', 'mining a block'),
  297. ),
  298. 'txhist': (
  299. 'viewing transaction history',
  300. ('bob_txhist1', "viewing Bob's transaction history (sort=age)"),
  301. ('bob_txhist2', "viewing Bob's transaction history (sort=blockheight reverse=1)"),
  302. ('bob_txhist3', "viewing Bob's transaction history (sort=blockheight sinceblock=-7)"),
  303. ('bob_txhist4', "viewing Bob's transaction history (sinceblock=399 detail=1)"),
  304. ('bob_txhist_interactive', "viewing Bob's transaction history (age_fmt=date_time interactive=true)"),
  305. ),
  306. 'label': (
  307. 'adding, removing and editing labels',
  308. ('alice_bal2', "Alice's balance"),
  309. ('alice_add_comment1', 'adding a label'),
  310. ('alice_chk_comment1', 'the label'),
  311. ('alice_add_comment2', 'adding a label'),
  312. ('alice_chk_comment2', 'the label'),
  313. ('alice_edit_comment1', 'editing a label (zh)'),
  314. ('alice_edit_comment2', 'editing a label (lat+cyr+gr)'),
  315. ('alice_chk_comment3', 'the label'),
  316. ('alice_remove_comment1', 'removing a label'),
  317. ('alice_chk_comment4', 'the label'),
  318. ('alice_add_comment_coinaddr', 'adding a label using the coin address'),
  319. ('alice_chk_comment_coinaddr', 'the label'),
  320. ('alice_add_comment_badaddr1', 'adding a label with invalid address'),
  321. ('alice_add_comment_badaddr2', 'adding a label with invalid address for this chain'),
  322. ('alice_add_comment_badaddr3', 'adding a label with wrong MMGen address'),
  323. ('alice_add_comment_badaddr4', 'adding a label with wrong coin address'),
  324. ),
  325. 'view': (
  326. 'viewing addresses and unspent outputs',
  327. ('alice_listaddresses1', 'listaddresses'),
  328. ('alice_listaddresses_days', 'listaddresses (age_fmt=days)'),
  329. ('alice_listaddresses_date', 'listaddresses (age_fmt=date)'),
  330. ('alice_listaddresses_date_time', 'listaddresses (age_fmt=date_time)'),
  331. ('alice_twview1', 'twview'),
  332. ('alice_twview_days', 'twview (age_fmt=days)'),
  333. ('alice_twview_date', 'twview (age_fmt=date)'),
  334. ('alice_twview_date_time', 'twview (age_fmt=date_time)'),
  335. ('alice_txcreate_info', 'txcreate -i'),
  336. ('alice_txcreate_info_term', 'txcreate -i (pexpect_spawn)'),
  337. ),
  338. 'auto_chg': (
  339. 'automatic change address selection',
  340. ('bob_split3', 'splitting Bob’s funds'),
  341. ('generate', 'mining a block'),
  342. ('bob_auto_chg1', 'creating an automatic change address transaction (C)'),
  343. ('bob_auto_chg2', 'creating an automatic change address transaction (B)'),
  344. ('bob_auto_chg3', 'creating an automatic change address transaction (S)'),
  345. ('bob_auto_chg4', 'creating an automatic change address transaction (single address)'),
  346. ('bob_auto_chg_addrtype1', 'creating an automatic change address transaction by addrtype (C)'),
  347. ('bob_auto_chg_addrtype2', 'creating an automatic change address transaction by addrtype (B)'),
  348. ('bob_auto_chg_addrtype3', 'creating an automatic change address transaction by addrtype (S)'),
  349. ('bob_auto_chg_addrtype4', 'creating an automatic change address transaction by addrtype (single address)'),
  350. ('bob_auto_chg_bad1', 'error handling for auto change address transaction (bad ID FFFFFFFF:C)'),
  351. ('bob_auto_chg_bad2', 'error handling for auto change address transaction (bad ID 00000000:C)'),
  352. ('bob_auto_chg_bad3', 'error handling for auto change address transaction (no unused addresses)'),
  353. ('bob_auto_chg_bad4', 'error handling for auto change address transaction by addrtype (no unused addresses)'),
  354. ),
  355. }
  356. def __init__(self,trunner,cfgs,spawn):
  357. TestSuiteBase.__init__(self,trunner,cfgs,spawn)
  358. if trunner == None:
  359. return
  360. if self.proto.testnet:
  361. die(2,'--testnet and --regtest options incompatible with regtest test suite')
  362. self.proto = init_proto(self.proto.coin,network='regtest',need_amt=True)
  363. coin = self.proto.coin.lower()
  364. import test.test_py_d.ts_regtest as rt_mod
  365. for k in rt_data:
  366. setattr( rt_mod, k, rt_data[k][coin] if coin in rt_data[k] else None )
  367. if self.proto.coin == 'BTC':
  368. self.test_rbf = True # tests are non-coin-dependent, so run just once for BTC
  369. if g.test_suite_deterministic:
  370. self.deterministic = True
  371. self.miner_addr = 'bcrt1qaq8t3pakcftpk095tnqfv5cmmczysls024atnd' # regtest.create_hdseed()
  372. self.miner_wif = 'cTyMdQ2BgfAsjopRVZrj7AoEGp97pKfrC2NkqLuwHr4KHfPNAKwp'
  373. os.environ['MMGEN_BOGUS_SEND'] = ''
  374. self.write_to_tmpfile('wallet_password',rt_pw)
  375. self.dfl_mmtype = 'C' if self.proto.coin == 'BCH' else 'B'
  376. self.burn_addr = make_burn_addr(self.proto)
  377. def __del__(self):
  378. os.environ['MMGEN_BOGUS_SEND'] = '1'
  379. def _add_comments_to_addr_file(self,addrfile,outfile,use_comments=False):
  380. silence()
  381. gmsg(f'Adding comments to address file {addrfile!r}')
  382. a = AddrList(self.proto,addrfile)
  383. for n,idx in enumerate(a.idxs(),1):
  384. if use_comments:
  385. a.set_comment(idx,get_comment())
  386. else:
  387. if n % 2: a.set_comment(idx,f'Test address {n}')
  388. af = a.get_file()
  389. af.format(add_comments=True)
  390. from mmgen.fileutil import write_data_to_file
  391. write_data_to_file(outfile,af.fmt_data,quiet=True,ignore_opt_outdir=True)
  392. end_silence()
  393. def setup(self):
  394. stop_test_daemons(self.proto.network_id,force=True,remove_datadir=True)
  395. from shutil import rmtree
  396. try: rmtree(joinpath(self.tr.data_dir,'regtest'))
  397. except: pass
  398. t = self.spawn('mmgen-regtest',['-n','setup'])
  399. for s in ('Starting','Creating','Creating','Creating','Mined','Setup complete'):
  400. t.expect(s)
  401. return t
  402. def daemon_version(self):
  403. t = self.spawn('mmgen-tool', ['--bob','daemon_version'])
  404. t.expect('version')
  405. return t
  406. def halving_calculator_bob(self):
  407. t = self.spawn('halving-calculator.py',['--bob'],cmd_dir='examples')
  408. t.expect('time until halving')
  409. return t
  410. def walletgen(self,user):
  411. t = self.spawn('mmgen-walletgen',['-q','-r0','-p1','--'+user])
  412. t.passphrase_new('new '+dfl_wcls.desc,rt_pw)
  413. t.label()
  414. t.expect('move it to the data directory? (Y/n): ','y')
  415. t.written_to_file(capfirst(dfl_wcls.desc))
  416. return t
  417. def walletgen_bob(self): return self.walletgen('bob')
  418. def walletgen_alice(self): return self.walletgen('alice')
  419. def _user_dir(self,user,coin=None):
  420. return joinpath(self.tr.data_dir,'regtest',coin or self.proto.coin.lower(),user)
  421. def _user_sid(self,user):
  422. return os.path.basename(get_file_with_ext(self._user_dir(user),'mmdat'))[:8]
  423. def _get_user_subsid(self,user,subseed_idx):
  424. fn = get_file_with_ext(self._user_dir(user),dfl_wcls.ext)
  425. silence()
  426. w = Wallet( fn=fn, passwd_file=os.path.join(self.tmpdir,'wallet_password') )
  427. end_silence()
  428. return w.seed.subseed(subseed_idx).sid
  429. def addrgen(self,user,wf=None,addr_range='1-5',subseed_idx=None,mmtypes=[]):
  430. from mmgen.addr import MMGenAddrType
  431. for mmtype in mmtypes or self.proto.mmtypes:
  432. t = self.spawn('mmgen-addrgen',
  433. ['--quiet','--'+user,'--type='+mmtype,f'--outdir={self._user_dir(user)}'] +
  434. ([wf] if wf else []) +
  435. (['--subwallet='+subseed_idx] if subseed_idx else []) +
  436. [addr_range],
  437. extra_desc='({})'.format( MMGenAddrType.mmtypes[mmtype].name ))
  438. t.passphrase(dfl_wcls.desc,rt_pw)
  439. t.written_to_file('Addresses')
  440. ok_msg()
  441. t.skip_ok = True
  442. return t
  443. def addrgen_bob(self): return self.addrgen('bob')
  444. def addrgen_alice(self): return self.addrgen('alice')
  445. def addrimport(self,user,sid=None,addr_range='1-5',num_addrs=5,mmtypes=[],batch=True,quiet=True):
  446. id_strs = { 'legacy':'', 'compressed':'-C', 'segwit':'-S', 'bech32':'-B' }
  447. if not sid: sid = self._user_sid(user)
  448. from mmgen.addr import MMGenAddrType
  449. for mmtype in mmtypes or self.proto.mmtypes:
  450. desc = MMGenAddrType.mmtypes[mmtype].name
  451. addrfile = joinpath(self._user_dir(user),
  452. '{}{}{}[{}]{x}.regtest.addrs'.format(
  453. sid,self.altcoin_pfx,id_strs[desc],addr_range,
  454. x='-α' if g.debug_utf8 else ''))
  455. if mmtype == self.proto.mmtypes[0] and user == 'bob':
  456. self._add_comments_to_addr_file(addrfile,addrfile,use_comments=True)
  457. t = self.spawn(
  458. 'mmgen-addrimport',
  459. args = (
  460. (['--quiet'] if quiet else []) +
  461. ['--'+user] +
  462. (['--batch'] if batch else []) +
  463. [addrfile] ),
  464. extra_desc = f'({desc})' )
  465. if g.debug:
  466. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  467. t.expect('Importing')
  468. if batch:
  469. t.expect(f'{num_addrs} addresses imported')
  470. else:
  471. t.expect(f'import completed OK')
  472. t.ok()
  473. t.skip_ok = True
  474. return t
  475. def addrimport_bob(self): return self.addrimport('bob')
  476. def addrimport_alice(self): return self.addrimport('alice',batch=False,quiet=False)
  477. def bob_import_miner_addr(self):
  478. if not self.deterministic:
  479. return 'skip'
  480. return self.spawn(
  481. 'mmgen-addrimport',
  482. [ '--bob', '--rescan', '--quiet', f'--address={self.miner_addr}' ] )
  483. def fund_wallet_deterministic(self,user,addr,utxo_nums,skip_passphrase=False):
  484. """
  485. the deterministic funding method using specific inputs
  486. """
  487. if not self.deterministic:
  488. return 'skip'
  489. self.write_to_tmpfile('miner.key',f'{self.miner_wif}\n')
  490. keyfile = joinpath(self.tmpdir,'miner.key')
  491. return self.user_txdo(
  492. 'bob', '40s',
  493. [ f'{addr},{rtFundAmt}', self.burn_addr ],
  494. utxo_nums,
  495. extra_args = [f'--keys-from-file={keyfile}'],
  496. skip_passphrase = skip_passphrase )
  497. def fund_bob_deterministic(self):
  498. return self.fund_wallet_deterministic( 'bob', f'{self._user_sid("bob")}:C:1', '1-11' )
  499. def fund_alice_deterministic(self):
  500. sid = self._user_sid('alice')
  501. mmtype = ('L','S')[self.proto.cap('segwit')]
  502. addr = self.get_addr_from_addrlist('alice',sid,mmtype,0,addr_range='1-5')
  503. return self.fund_wallet_deterministic( 'alice', addr, '1-11', skip_passphrase=True )
  504. def generate_extra_deterministic(self):
  505. if not self.deterministic:
  506. return 'skip'
  507. return self.generate(num_blocks=2) # do this so block count matches non-deterministic run
  508. async def bob_recreate_tracking_wallet(self):
  509. if not self.deterministic:
  510. return 'skip'
  511. self.spawn('',msg_only=True)
  512. from mmgen.proto.btc.regtest import MMGenRegtest
  513. rt = MMGenRegtest(self.proto.coin)
  514. await rt.stop()
  515. from shutil import rmtree
  516. imsg(f'Deleting Bob’s old tracking wallet')
  517. rmtree(os.path.join(rt.d.datadir,'regtest','wallets','bob'),ignore_errors=True)
  518. rt.init_daemon()
  519. rt.d.start(silent=True)
  520. imsg(f'Creating Bob’s new tracking wallet')
  521. await rt.rpc_call('createwallet','bob',True,True,None,False,False,False)
  522. await rt.stop()
  523. await rt.start()
  524. return 'ok'
  525. def addrimport_bob2(self):
  526. if not self.deterministic:
  527. return 'skip'
  528. return self.addrimport('bob')
  529. def fund_wallet(self,user,mmtype,amt,sid=None,addr_range='1-5'):
  530. if self.deterministic:
  531. return 'skip'
  532. if not sid:
  533. sid = self._user_sid(user)
  534. addr = self.get_addr_from_addrlist(user,sid,mmtype,0,addr_range=addr_range)
  535. t = self.spawn('mmgen-regtest', ['send',str(addr),str(amt)])
  536. t.expect(f'Sending {amt} miner {self.proto.coin}')
  537. t.expect('Mined 1 block')
  538. return t
  539. def fund_bob(self):
  540. return self.fund_wallet('bob','C',rtFundAmt)
  541. def fund_alice(self):
  542. return self.fund_wallet('alice',('L','S')[self.proto.cap('segwit')],rtFundAmt)
  543. def user_twview(self,user,chk,sort='age'):
  544. t = self.spawn('mmgen-tool',['--'+user,'twview','sort='+sort])
  545. if chk:
  546. t.expect(r'{}\b.*\D{}\b'.format(*chk),regex=True)
  547. return t
  548. def bob_twview1(self): return self.user_twview('bob', chk = ('1',rtAmts[0]) )
  549. def user_bal(self,user,bal,args=['showempty=1'],skip_check=False):
  550. t = self.spawn('mmgen-tool',['--'+user,'listaddresses'] + args)
  551. if not skip_check:
  552. cmp_or_die(f'{bal} {self.proto.coin}',strip_ansi_escapes(t.expect_getend('TOTAL: ')))
  553. return t
  554. def alice_bal1(self):
  555. return self.user_bal('alice',rtFundAmt)
  556. def alice_bal2(self):
  557. return self.user_bal('alice',rtBals[8])
  558. def bob_bal1(self):
  559. return self.user_bal('bob',rtFundAmt)
  560. def bob_bal2(self):
  561. return self.user_bal('bob',rtBals[0])
  562. def bob_bal2a(self):
  563. return self.user_bal('bob',rtBals[0],args=['showempty=1','age_fmt=confs'])
  564. def bob_bal2b(self):
  565. return self.user_bal('bob',rtBals[0],args=['showempty=1'])
  566. def bob_bal2c(self):
  567. return self.user_bal('bob',rtBals[0],args=['showempty=1','minconf=2','age_fmt=days'],skip_check=True)
  568. def bob_bal2d(self):
  569. return self.user_bal('bob',rtBals[0],args=['minconf=2'],skip_check=True)
  570. def bob_bal2e(self):
  571. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=amt'])
  572. def bob_bal2f(self):
  573. return self.user_bal('bob',rtBals[0],args=['showempty=0','sort=twmmid','reverse=1'])
  574. def bob_bal3(self):
  575. return self.user_bal('bob',rtBals[1])
  576. def bob_bal4(self):
  577. return self.user_bal('bob',rtBals[2])
  578. def bob_bal5(self):
  579. return self.user_bal('bob',rtBals[3])
  580. def bob_bal6(self):
  581. return self.user_bal('bob',rtBals[7])
  582. def bob_subwallet_addrgen1(self):
  583. return self.addrgen('bob',subseed_idx='29L',mmtypes=['C']) # 29L: 2FA7BBA8
  584. def bob_subwallet_addrgen2(self):
  585. return self.addrgen('bob',subseed_idx='127S',mmtypes=['C']) # 127S: '09E8E286'
  586. def subwallet_addrimport(self,user,subseed_idx):
  587. sid = self._get_user_subsid(user,subseed_idx)
  588. return self.addrimport(user,sid=sid,mmtypes=['C'])
  589. def bob_subwallet_addrimport1(self): return self.subwallet_addrimport('bob','29L')
  590. def bob_subwallet_addrimport2(self): return self.subwallet_addrimport('bob','127S')
  591. def bob_subwallet_fund(self):
  592. sid1 = self._get_user_subsid('bob','29L')
  593. sid2 = self._get_user_subsid('bob','127S')
  594. chg_addr = self._user_sid('bob') + (':B:1',':L:1')[self.proto.coin=='BCH']
  595. return self.user_txdo(
  596. user = 'bob',
  597. fee = rtFee[1],
  598. outputs_cl = [sid1+':C:2,0.29',sid2+':C:3,0.127',chg_addr],
  599. outputs_list = ('3','1')[self.proto.coin=='BCH'],
  600. extra_args = ['--subseeds=127'],
  601. used_chg_addr_resp = (None,'y')[self.proto.coin=='BCH'] )
  602. def bob_twview2(self):
  603. sid1 = self._get_user_subsid('bob','29L')
  604. return self.user_twview('bob',chk=(sid1+':C:2','0.29'),sort='twmmid')
  605. def bob_twview3(self):
  606. sid2 = self._get_user_subsid('bob','127S')
  607. return self.user_twview('bob',chk=(sid2+':C:3','0.127'),sort='amt')
  608. def bob_subwallet_txcreate(self):
  609. sid1 = self._get_user_subsid('bob','29L')
  610. sid2 = self._get_user_subsid('bob','127S')
  611. outputs_cl = [sid1+':C:5,0.0159',sid2+':C:5']
  612. t = self.spawn('mmgen-txcreate',['-d',self.tmpdir,'-B','--bob'] + outputs_cl)
  613. return self.txcreate_ui_common(t,
  614. menu = ['a'],
  615. inputs = ('1,2','2,3')[self.proto.coin=='BCH'],
  616. interactive_fee = '0.00001')
  617. def bob_subwallet_txsign(self):
  618. fn = get_file_with_ext(self.tmpdir,'rawtx')
  619. t = self.spawn('mmgen-txsign',['-d',self.tmpdir,'--bob','--subseeds=127',fn])
  620. t.view_tx('t')
  621. t.passphrase(dfl_wcls.desc,rt_pw)
  622. t.do_comment(None)
  623. t.expect('(Y/n): ','y')
  624. t.written_to_file('Signed transaction')
  625. return t
  626. def bob_subwallet_txdo(self):
  627. outputs_cl = [self._user_sid('bob')+':L:5']
  628. inputs = ('1,2','2,3')[self.proto.coin=='BCH']
  629. return self.user_txdo('bob',rtFee[5],outputs_cl,inputs,menu=['a'],extra_args=['--subseeds=127']) # sort: amt
  630. def bob_twview4(self):
  631. sid = self._user_sid('bob')
  632. return self.user_twview('bob',chk=(sid+':L:5',rtBals[9]),sort='twmmid')
  633. def user_txhist(self,user,args,expect):
  634. t = self.spawn('mmgen-tool',['--'+user,'txhist'] + args)
  635. res = strip_ansi_escapes(t.read()).replace('\r','')
  636. m = re.search(expect,res,re.DOTALL)
  637. assert m, f'Expected: {expect}'
  638. return t
  639. def bob_txhist1(self):
  640. return self.user_txhist('bob',
  641. args = ['sort=age'],
  642. expect = fr'\s1\).*\s{rtFundAmt}\s' )
  643. def bob_txhist2(self):
  644. return self.user_txhist('bob',
  645. args = ['sort=blockheight','reverse=1','age_fmt=block'],
  646. expect = fr'\s1\).*:{self.dfl_mmtype}:1\s' )
  647. def bob_txhist3(self):
  648. return self.user_txhist('bob',
  649. args = ['sort=blockheight','sinceblock=-7','age_fmt=block'],
  650. expect = fr'Displaying transactions since block 399.*\s6\)\s+405\s.*\s{rtBals[9]}\s.*:L:5.*\s7\)'
  651. )
  652. def bob_txhist4(self):
  653. return self.user_txhist('bob',
  654. args = ['sort=blockheight','sinceblock=399','age_fmt=block','detail=1'],
  655. expect = fr'Displaying transactions since block 399.*\s7\).*Block:.*406.*Value:.*{rtBals[10]}'
  656. )
  657. def bob_txhist_interactive(self):
  658. self.get_file_with_ext('out',delete_all=True)
  659. t = self.spawn('mmgen-tool',
  660. ['--bob',f'--outdir={self.tmpdir}','txhist','age_fmt=date_time','interactive=true'] )
  661. for resp in ('u','i','t','a','m','T','A','r','r','D','D','D','D','p','P','b','V'):
  662. t.expect('draw:\b',resp,regex=True)
  663. if t.pexpect_spawn:
  664. t.expect(r'Block:.*\b394\b',regex=True)
  665. time.sleep(1)
  666. t.send('q')
  667. time.sleep(0.2)
  668. t.send('b')
  669. t.expect('draw:\b','q',regex=True)
  670. else:
  671. txnum,idx = (8,1) if self.proto.coin == 'BCH' else (9,3)
  672. t.expect(f'\s{txnum}\).*Inputs:.*:L:{idx}.*Outputs \(3\):.*:C:2.*\s10\)','q',regex=True)
  673. return t
  674. def bob_getbalance(self,bals,confs=1):
  675. for i in range(len(bals['mmgen'])):
  676. assert Decimal(bals['mmgen'][i]) + Decimal(bals['nonmm'][i]) == Decimal(bals['total'][i])
  677. sid = self._user_sid('bob')
  678. t = self.spawn('mmgen-tool',['--bob','getbalance',f'minconf={confs}'])
  679. t.expect('Wallet')
  680. for k,lbl in (
  681. ('mmgen',f'{sid}:'),
  682. ('nonmm','Non-MMGen:'),
  683. ('total',f'TOTAL {self.proto.coin}')
  684. ):
  685. ret = strip_ansi_escapes(t.expect_getend(lbl + ' '))
  686. cmp_or_die(
  687. ' '.join(bals[k]),
  688. ' '.join(ret.split()),
  689. desc = k,
  690. )
  691. return t
  692. def bob_0conf0_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf0'],confs=0)
  693. def bob_0conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['0conf1'],confs=1)
  694. def bob_1conf1_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf1'],confs=1)
  695. def bob_1conf2_getbalance(self): return self.bob_getbalance(rtBals_gb['1conf2'],confs=2)
  696. def bob_nochg_burn(self):
  697. return self.user_txdo('bob',
  698. fee = '0.00009713',
  699. outputs_cl = [self.burn_addr],
  700. outputs_list = '1' )
  701. def bob_alice_bal(self):
  702. t = self.spawn('mmgen-regtest',['balances'])
  703. ret = t.expect_getend("Bob's balance:").strip()
  704. cmp_or_die(rtBals[4],ret)
  705. ret = t.expect_getend("Alice's balance:").strip()
  706. cmp_or_die(rtBals[5],ret)
  707. ret = t.expect_getend("Total balance:").strip()
  708. cmp_or_die(rtBals[6],ret)
  709. return t
  710. def user_txsend_status(self,user,tx_file,exp1='',exp2='',extra_args=[]):
  711. t = self.spawn('mmgen-txsend',['-d',self.tmpdir,'--'+user,'--status'] + extra_args + [tx_file])
  712. if exp1: t.expect(exp1,regex=True)
  713. if exp2: t.expect(exp2,regex=True)
  714. return t
  715. def user_txdo( self, user, fee, outputs_cl, outputs_list,
  716. extra_args = [],
  717. wf = None,
  718. do_label = False,
  719. bad_locktime = False,
  720. full_tx_view = False,
  721. menu = ['M'],
  722. skip_passphrase = False,
  723. used_chg_addr_resp = None ):
  724. t = self.spawn('mmgen-txdo',
  725. ['-d',self.tmpdir,'-B','--'+user] +
  726. (['--fee='+fee] if fee else []) +
  727. extra_args + ([],[wf])[bool(wf)] + outputs_cl)
  728. self.txcreate_ui_common(t,
  729. caller = 'txdo',
  730. menu = menu,
  731. inputs = outputs_list,
  732. file_desc = 'Signed transaction',
  733. interactive_fee = (tx_fee,'')[bool(fee)],
  734. add_comment = tx_comment_jp,
  735. view = 't',
  736. save = True,
  737. used_chg_addr_resp = used_chg_addr_resp )
  738. if not skip_passphrase:
  739. t.passphrase(dfl_wcls.desc,rt_pw)
  740. t.written_to_file('Signed transaction')
  741. self._do_confirm_send(t)
  742. s,exit_val = (('Transaction sent',0),("can't be included",1))[bad_locktime]
  743. t.expect(s)
  744. t.req_exit_val = exit_val
  745. return t
  746. def bob_split1(self):
  747. sid = self._user_sid('bob')
  748. outputs_cl = [sid+':C:1,100', sid+':L:2,200',sid+':'+rtBobOp3]
  749. return self.user_txdo('bob',rtFee[0],outputs_cl,'1',do_label=True,full_tx_view=True)
  750. def get_addr_from_addrlist(self,user,sid,mmtype,idx,addr_range='1-5'):
  751. id_str = { 'L':'', 'S':'-S', 'C':'-C', 'B':'-B' }[mmtype]
  752. ext = '{}{}{}[{}]{x}.regtest.addrs'.format(
  753. sid,self.altcoin_pfx,id_str,addr_range,x='-α' if g.debug_utf8 else '')
  754. addrfile = get_file_with_ext(self._user_dir(user),ext,no_dot=True)
  755. silence()
  756. addr = AddrList(self.proto,addrfile).data[idx].addr
  757. end_silence()
  758. return addr
  759. def _create_tx_outputs(self,user,data):
  760. sid = self._user_sid(user)
  761. return [self.get_addr_from_addrlist(user,sid,mmtype,idx-1)+amt_str for mmtype,idx,amt_str in data]
  762. def bob_rbf_1output_create(self):
  763. if not self.test_rbf:
  764. return 'skip'
  765. out_addr = self._create_tx_outputs('alice',(('B',5,''),))
  766. t = self.spawn('mmgen-txcreate',['-d',self.tr.trash_dir,'-B','--bob','--rbf'] + out_addr)
  767. return self.txcreate_ui_common(t,menu=[],inputs='3',interactive_fee='3s') # out amt: 199.99999343
  768. def bob_rbf_1output_bump(self):
  769. if not self.test_rbf:
  770. return 'skip'
  771. ext = '9343,3]{x}.regtest.rawtx'.format(x='-α' if g.debug_utf8 else '')
  772. txfile = get_file_with_ext(self.tr.trash_dir,ext,delete=False,no_dot=True)
  773. return self.user_txbump('bob',
  774. self.tr.trash_dir,
  775. txfile,
  776. '8s',
  777. has_label = False,
  778. signed_tx = False,
  779. one_output = True )
  780. def bob_send_maybe_rbf(self):
  781. outputs_cl = self._create_tx_outputs('alice',(('L',1,',60'),('C',1,',40'))) # alice_sid:L:1, alice_sid:C:1
  782. outputs_cl += [self._user_sid('bob')+':'+rtBobOp3]
  783. return self.user_txdo('bob',rtFee[1],outputs_cl,'3',
  784. extra_args = ([],['--rbf'])[self.proto.cap('rbf')],
  785. used_chg_addr_resp = 'y' )
  786. def bob_send_non_mmgen(self):
  787. outputs_cl = self._create_tx_outputs('alice',(
  788. (('L','S')[self.proto.cap('segwit')],2,',10'),
  789. (('L','S')[self.proto.cap('segwit')],3,'')
  790. )) # alice_sid:S:2, alice_sid:S:3
  791. keyfile = joinpath(self.tmpdir,'non-mmgen.keys')
  792. return self.user_txdo('bob',rtFee[3],outputs_cl,'1,4-10',
  793. extra_args=['--keys-from-file='+keyfile,'--vsize-adj=1.02'])
  794. def alice_send_estimatefee(self):
  795. outputs_cl = self._create_tx_outputs('bob',(('L',1,''),)) # bob_sid:L:1
  796. return self.user_txdo('alice',None,outputs_cl,'1') # fee=None
  797. def user_txbump(self,user,outdir,txfile,fee,add_args=[],has_label=True,signed_tx=True,one_output=False):
  798. if not self.proto.cap('rbf'):
  799. return 'skip'
  800. t = self.spawn('mmgen-txbump',
  801. ['-d',outdir,'--'+user,'--fee='+fee,'--output-to-reduce=c'] + add_args + [txfile])
  802. if not one_output:
  803. t.expect('OK? (Y/n): ','y') # output OK?
  804. t.expect('OK? (Y/n): ','y') # fee OK?
  805. t.do_comment(False,has_label=has_label)
  806. if signed_tx:
  807. t.passphrase(dfl_wcls.desc,rt_pw)
  808. t.written_to_file('Signed transaction')
  809. self.txsend_ui_common(t,caller='txdo',bogus_send=False,file_desc='Signed transaction')
  810. else:
  811. t.expect('Save fee-bumped transaction? (y/N): ','y')
  812. t.written_to_file('Fee-bumped transaction')
  813. return t
  814. def bob_rbf_bump(self):
  815. ext = ',{}]{x}.regtest.sigtx'.format(rtFee[1][:-1],x='-α' if g.debug_utf8 else '')
  816. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  817. return self.user_txbump('bob',self.tmpdir,txfile,rtFee[2],add_args=['--send'])
  818. def generate(self,num_blocks=1):
  819. int(num_blocks)
  820. t = self.spawn('mmgen-regtest',['generate',str(num_blocks)])
  821. t.expect(f'Mined {num_blocks} block')
  822. return t
  823. def _get_mempool(self):
  824. if not g.debug_utf8:
  825. disable_debug()
  826. ret = self.spawn('mmgen-regtest',['mempool']).read()
  827. if not g.debug_utf8:
  828. restore_debug()
  829. m = re.search(r'(\[\s*"[a-f0-9]{64}"\s*])',ret) # allow for extra output by handler at end
  830. return json.loads(m.group(1))
  831. def get_mempool1(self):
  832. mp = self._get_mempool()
  833. if len(mp) != 1:
  834. die(4,'Mempool has more or less than one TX!')
  835. self.write_to_tmpfile('rbf_txid',mp[0]+'\n')
  836. return 'ok'
  837. def bob_rbf_status(self,fee,exp1,exp2=''):
  838. if not self.proto.cap('rbf'):
  839. return 'skip'
  840. ext = ',{}]{x}.regtest.sigtx'.format(fee[:-1],x='-α' if g.debug_utf8 else '')
  841. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  842. return self.user_txsend_status('bob',txfile,exp1,exp2)
  843. def bob_rbf_status1(self):
  844. if not self.proto.cap('rbf'):
  845. return 'skip'
  846. return self.bob_rbf_status(rtFee[1],'in mempool, replaceable')
  847. def get_mempool2(self):
  848. if not self.proto.cap('rbf'):
  849. return 'skip'
  850. mp = self._get_mempool()
  851. if len(mp) != 1:
  852. die(4,'Mempool has more or less than one TX!')
  853. chk = self.read_from_tmpfile('rbf_txid')
  854. if chk.strip() == mp[0]:
  855. die(4,'TX in mempool has not changed! RBF bump failed')
  856. self.write_to_tmpfile('rbf_txid2',mp[0]+'\n')
  857. return 'ok'
  858. def bob_rbf_status2(self):
  859. if not self.proto.cap('rbf'):
  860. return 'skip'
  861. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  862. return self.bob_rbf_status(rtFee[1],
  863. 'Transaction has been replaced',f'{new_txid} in mempool')
  864. def bob_rbf_status3(self):
  865. if not self.proto.cap('rbf'):
  866. return 'skip'
  867. return self.bob_rbf_status(rtFee[2],'status: in mempool, replaceable')
  868. def bob_rbf_status4(self):
  869. if not self.proto.cap('rbf'):
  870. return 'skip'
  871. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  872. return self.bob_rbf_status(rtFee[1],
  873. 'Replacement transaction has 1 confirmation',
  874. f'Replacing transactions:\s+{new_txid}' )
  875. def bob_rbf_status5(self):
  876. if not self.proto.cap('rbf'):
  877. return 'skip'
  878. return self.bob_rbf_status(rtFee[2],'Transaction has 1 confirmation')
  879. def bob_rbf_status6(self):
  880. if not self.proto.cap('rbf'):
  881. return 'skip'
  882. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  883. return self.bob_rbf_status(rtFee[1],
  884. 'Replacement transaction has 2 confirmations',
  885. f'Replacing transactions:\s+{new_txid}' )
  886. def _gen_pairs(self,n):
  887. from mmgen.tool.api import tool_api
  888. t = tool_api()
  889. t.init_coin(self.proto.coin,self.proto.network)
  890. def gen_addr(Type):
  891. t.addrtype = Type
  892. wif = t.hex2wif(getrandhex(32))
  893. return ( wif, t.wif2addr(wif) )
  894. return [gen_addr('legacy')] + [gen_addr('compressed') for i in range(n-1)]
  895. def bob_pre_import(self):
  896. pairs = self._gen_pairs(5)
  897. self.write_to_tmpfile('non-mmgen.keys','\n'.join([a[0] for a in pairs])+'\n')
  898. self.write_to_tmpfile('non-mmgen.addrs','\n'.join([a[1] for a in pairs])+'\n')
  899. return self.user_txdo('bob',rtFee[4],[pairs[0][1]],'3')
  900. def user_import(self,user,args,nAddr):
  901. t = self.spawn('mmgen-addrimport',['--'+user]+args)
  902. if g.debug:
  903. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  904. t.expect(f'Importing {nAddr} address')
  905. if '--rescan' in args:
  906. if not '--quiet' in args:
  907. t.expect('Continue? (Y/n): ','y')
  908. t.expect('Rescanning block')
  909. return t
  910. def bob_import_addr(self):
  911. addr = self.read_from_tmpfile('non-mmgen.addrs').split()[0]
  912. return self.user_import('bob',['--quiet','--address='+addr],nAddr=1)
  913. def bob_import_list_rescan_aio(self):
  914. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  915. return self.user_import('bob',['--rescan','--rpc-backend=aio','--addrlist',addrfile],nAddr=5)
  916. def bob_resolve_addr(self):
  917. mmaddr = '{}:C:1'.format(self._user_sid('bob'))
  918. t = self.spawn('mmgen-tool',['--bob','resolve_address',mmaddr])
  919. coinaddr = t.read().split()[0].strip()
  920. t = self.spawn('mmgen-tool',['--bob','resolve_address',coinaddr],no_msg=True)
  921. mmaddr_res = t.read().split()[0].strip()
  922. assert mmaddr == mmaddr_res, f'{mmaddr} != {mmaddr_res}'
  923. return t
  924. def bob_import_list(self):
  925. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  926. return self.user_import('bob',['--quiet','--addrlist',addrfile],nAddr=5)
  927. def bob_import_list_rescan(self):
  928. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  929. return self.user_import('bob',['--quiet','--rescan','--addrlist',addrfile],nAddr=5)
  930. def bob_rescan_addr(self):
  931. sid = self._user_sid('bob')
  932. t = self.spawn('mmgen-tool',['--bob','rescan_address',f'{sid}:C:1'])
  933. t.expect('Found 1 unspent output')
  934. t.expect('updated successfully')
  935. return t
  936. def _usr_rescan_blockchain(self,user,add_args,expect):
  937. t = self.spawn('mmgen-tool',[f'--{user}','rescan_blockchain'] + add_args)
  938. t.expect(f'Scanning blocks {expect}')
  939. t.expect('Done')
  940. return t
  941. def bob_rescan_blockchain_all(self):
  942. return self._usr_rescan_blockchain('bob',[],'300-396')
  943. def bob_rescan_blockchain_gb(self):
  944. return self._usr_rescan_blockchain('bob',['start_block=0','stop_block=0'],'0-0')
  945. def bob_rescan_blockchain_one(self):
  946. return self._usr_rescan_blockchain('bob',['start_block=300','stop_block=300'],'300-300')
  947. def bob_rescan_blockchain_ss(self):
  948. return self._usr_rescan_blockchain('bob',['start_block=300','stop_block=302'],'300-302')
  949. def bob_twexport(self,add_args=[]):
  950. t = self.spawn('mmgen-tool',['--bob',f'--outdir={self.tmpdir}','twexport'] + add_args)
  951. t.written_to_file('JSON data')
  952. return t
  953. def bob_twexport_noamt(self):
  954. return self.bob_twexport(add_args=['include_amts=0'])
  955. def bob_twexport_pretty(self):
  956. return self.bob_twexport(add_args=['pretty=1'])
  957. def bob_edit_json_twdump(self):
  958. self.spawn('',msg_only=True)
  959. from mmgen.tw.json import TwJSON
  960. fn = TwJSON.Base(self.proto).dump_fn
  961. text = json.loads(self.read_from_tmpfile(fn))
  962. text['data']['entries'][3][3] = f'edited comment [фубар] [{gr_uc}]'
  963. self.write_to_tmpfile( fn, json.dumps(text,indent=4) )
  964. return 'ok'
  965. def carol_twimport(self,add_args=[],add_parms=[],expect_str=None):
  966. from mmgen.tw.json import TwJSON
  967. fn = joinpath( self.tmpdir, TwJSON.Base(self.proto).dump_fn )
  968. t = self.spawn('mmgen-tool', add_args + ['--carol','twimport',fn] + add_parms)
  969. t.expect('(y/N): ','y')
  970. if expect_str:
  971. t.expect(expect_str)
  972. elif 'batch=true' in add_parms:
  973. t.expect('{} addresses imported'.format(10 if self.proto.coin == 'BCH' else 20))
  974. else:
  975. t.expect('import completed OK')
  976. t.expect('Found 1 unspent output')
  977. return t
  978. def carol_twimport_nochksum(self):
  979. return self.carol_twimport(add_args=['--rpc-backend=aio'],add_parms=['ignore_checksum=true'])
  980. def carol_twimport_batch(self):
  981. return self.carol_twimport(add_parms=['batch=true'])
  982. def carol_twimport_pretty(self):
  983. return self.carol_twimport(add_parms=['ignore_checksum=true'],expect_str='ignoring incorrect checksum')
  984. def carol_listaddresses(self):
  985. return self.spawn('mmgen-tool',['--carol','listaddresses','showempty=1'])
  986. async def carol_delete_wallet(self):
  987. imsg(f'Unloading Carol’s tracking wallet')
  988. t = self.spawn('mmgen-regtest',['cli','unloadwallet','carol'])
  989. t.ok()
  990. from mmgen.rpc import rpc_init
  991. rpc = await rpc_init(self.proto)
  992. wdir = joinpath(rpc.daemon.network_datadir,'wallets','carol')
  993. from shutil import rmtree
  994. imsg(f'Deleting Carol’s tracking wallet')
  995. rmtree(wdir)
  996. return 'silent'
  997. def bob_split2(self):
  998. addrs = self.read_from_tmpfile('non-mmgen.addrs').split()
  999. amts = (1.12345678,2.87654321,3.33443344,4.00990099,5.43214321)
  1000. outputs1 = list(map('{},{}'.format,addrs,amts))
  1001. sid = self._user_sid('bob')
  1002. l1,l2 = (
  1003. (':S',':B') if 'B' in self.proto.mmtypes else
  1004. (':S',':S') if self.proto.cap('segwit') else
  1005. (':L',':L') )
  1006. outputs2 = [sid+':C:2,6.333', sid+':L:3,6.667',sid+l1+':4,0.123',sid+l2+':5']
  1007. return self.user_txdo('bob',rtFee[5],outputs1+outputs2,'1-2')
  1008. def user_add_comment(self,user,addr,comment):
  1009. t = self.spawn('mmgen-tool',['--'+user,'add_label',addr,comment])
  1010. t.expect('Added label.*in tracking wallet',regex=True)
  1011. return t
  1012. def user_remove_comment(self,user,addr):
  1013. t = self.spawn('mmgen-tool',['--'+user,'remove_label',addr])
  1014. t.expect('Removed label.*in tracking wallet',regex=True)
  1015. return t
  1016. def bob_add_comment(self):
  1017. sid = self._user_sid('bob')
  1018. return self.user_add_comment('bob',sid+':C:1',tw_comment_lat_cyr_gr)
  1019. def alice_add_comment1(self):
  1020. sid = self._user_sid('alice')
  1021. return self.user_add_comment('alice',sid+':C:1','Original Label - 月へ')
  1022. def alice_add_comment2(self):
  1023. sid = self._user_sid('alice')
  1024. return self.user_add_comment('alice',sid+':C:1','Replacement Label')
  1025. def _user_chk_comment(self,user,addr,comment,extra_args=[]):
  1026. t = self.spawn('mmgen-tool',['--'+user,'listaddresses','all_labels=1']+extra_args)
  1027. ret = strip_ansi_escapes(t.expect_getend(addr)).strip().split(None,2)[2]
  1028. cmp_or_die( # squeezed display, double-width chars, so truncate to min field width
  1029. ret[:3].strip(),
  1030. comment[:3].strip())
  1031. return t
  1032. def alice_add_comment_coinaddr(self):
  1033. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  1034. t = self.spawn('mmgen-tool',['--alice','listaddress',mmid,'wide=true'],no_msg=True)
  1035. addr = [i for i in strip_ansi_escapes(t.read()).splitlines() if re.search(rf'\b{mmid}\b',i)][0].split()[3]
  1036. return self.user_add_comment('alice',addr,'Label added using coin address of MMGen address')
  1037. def alice_chk_comment_coinaddr(self):
  1038. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  1039. return self._user_chk_comment('alice',mmid,'Label added using coin address of MMGen address')
  1040. def alice_add_comment_badaddr(self,addr,reply,exit_val):
  1041. if os.getenv('PYTHONOPTIMIZE'):
  1042. omsg(yellow(f'PYTHONOPTIMIZE set, skipping test {self.test_name!r}'))
  1043. return 'skip'
  1044. t = self.spawn('mmgen-tool',['--alice','add_label',addr,'(none)'])
  1045. t.expect(reply,regex=True)
  1046. t.req_exit_val = exit_val
  1047. return t
  1048. def alice_add_comment_badaddr1(self):
  1049. return self.alice_add_comment_badaddr( rt_pw, 'invalid address', 2 )
  1050. def alice_add_comment_badaddr2(self):
  1051. addr = init_proto(self.proto.coin,network='mainnet').pubhash2addr(bytes(20),False) # mainnet zero address
  1052. return self.alice_add_comment_badaddr( addr, 'invalid address', 2 )
  1053. def alice_add_comment_badaddr3(self):
  1054. addr = self._user_sid('alice') + ':C:123'
  1055. return self.alice_add_comment_badaddr( addr, f'MMGen address {addr!r} not found in tracking wallet', 2 )
  1056. def alice_add_comment_badaddr4(self):
  1057. addr = self.proto.pubhash2addr(bytes(20),False) # regtest (testnet) zero address
  1058. return self.alice_add_comment_badaddr( addr, f'Coin address {addr!r} not found in tracking wallet', 2 )
  1059. def alice_remove_comment1(self):
  1060. sid = self._user_sid('alice')
  1061. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1062. return self.user_remove_comment('alice',mmid)
  1063. def alice_chk_comment1(self):
  1064. sid = self._user_sid('alice')
  1065. return self._user_chk_comment('alice',sid+':C:1','Original Label - 月へ')
  1066. def alice_chk_comment2(self):
  1067. sid = self._user_sid('alice')
  1068. return self._user_chk_comment('alice',sid+':C:1','Replacement Label',extra_args=['age_fmt=block'])
  1069. def alice_edit_comment1(self): return self.user_edit_comment('alice','4',tw_comment_lat_cyr_gr)
  1070. def alice_edit_comment2(self): return self.user_edit_comment('alice','3',tw_comment_zh)
  1071. def alice_chk_comment3(self):
  1072. sid = self._user_sid('alice')
  1073. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1074. return self._user_chk_comment('alice',mmid,tw_comment_lat_cyr_gr,extra_args=['age_fmt=date'])
  1075. def alice_chk_comment4(self):
  1076. sid = self._user_sid('alice')
  1077. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1078. return self._user_chk_comment('alice',mmid,'-',extra_args=['age_fmt=date_time'])
  1079. def user_edit_comment(self,user,output,comment):
  1080. t = self.spawn('mmgen-txcreate',['-B','--'+user,'-i'])
  1081. t.expect(r'add \[l\]abel:.','M',regex=True)
  1082. t.expect(r'add \[l\]abel:.','l',regex=True)
  1083. t.expect(r"Enter unspent.*return to main menu\):.",output+'\n',regex=True)
  1084. t.expect(r"Enter label text.*:.",comment+'\n',regex=True)
  1085. t.expect(r'\[q\]uit view, .*?:.','q',regex=True)
  1086. return t
  1087. def alice_listaddresses(self,args,expect):
  1088. t = self.spawn('mmgen-tool',['--alice','listaddresses','showempty=1'] + args)
  1089. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  1090. t.expect(expect_str,regex=True)
  1091. return t
  1092. def alice_listaddresses1(self):
  1093. return self.alice_listaddresses(
  1094. args = [],
  1095. expect = (rtAmts[1],r'\d+') )
  1096. def alice_listaddresses_days(self):
  1097. return self.alice_listaddresses(
  1098. args = ['age_fmt=days'],
  1099. expect = (rtAmts[1],r'\d+') )
  1100. def alice_listaddresses_date(self):
  1101. return self.alice_listaddresses(
  1102. args = ['age_fmt=date'],
  1103. expect = (rtAmts[1],pat_date) )
  1104. def alice_listaddresses_date_time(self):
  1105. return self.alice_listaddresses(
  1106. args = ['age_fmt=date_time'],
  1107. expect = (rtAmts[1],pat_date_time) )
  1108. def alice_twview(self,args,expect):
  1109. t = self.spawn('mmgen-tool',['--alice','twview'] + args)
  1110. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  1111. t.expect(expect_str,regex=True)
  1112. return t
  1113. def alice_twview1(self):
  1114. return self.alice_twview(
  1115. args = [],
  1116. expect = (rtAmts[0],r'\d+') )
  1117. def alice_twview_days(self):
  1118. return self.alice_twview(
  1119. args = ['age_fmt=days'],
  1120. expect = (rtAmts[0],r'\d+') )
  1121. def alice_twview_date(self):
  1122. return self.alice_twview(
  1123. args = ['age_fmt=date'],
  1124. expect = (rtAmts[0],pat_date) )
  1125. def alice_twview_date_time(self):
  1126. return self.alice_twview(
  1127. args = ['age_fmt=date_time'],
  1128. expect = (rtAmts[0],pat_date_time) )
  1129. def alice_txcreate_info(self,pexpect_spawn=False):
  1130. t = self.spawn('mmgen-txcreate',['--alice','-Bi'],pexpect_spawn=pexpect_spawn)
  1131. pats = (
  1132. ( '\d+', 'w'),
  1133. ( '\d+', 'D'),
  1134. ( '\d+', 'D'),
  1135. ( '\d+', 'D'),
  1136. ( pat_date, 'q'),
  1137. )
  1138. for d,s in pats:
  1139. t.expect(
  1140. r'\D{}\D.*\b{}\b'.format( rtAmts[0], d ),
  1141. s,
  1142. regex=True )
  1143. if t.pexpect_spawn and s == 'w':
  1144. t.expect(r'Total.*','q',regex=True,delay=1 if opt.exact_output else t.send_delay)
  1145. time.sleep(t.send_delay)
  1146. t.send('e')
  1147. return t
  1148. def alice_txcreate_info_term(self):
  1149. if self.skip_for_win():
  1150. return 'skip'
  1151. return self.alice_txcreate_info(pexpect_spawn=True)
  1152. def bob_msgcreate(self):
  1153. sid1 = self._user_sid('bob')
  1154. sid2 = self._get_user_subsid('bob','29L')
  1155. return self.spawn(
  1156. 'mmgen-msg', [
  1157. '--bob',
  1158. f'--outdir={self.tmpdir}',
  1159. 'create',
  1160. '16/3/2022 Earthquake strikes Fukushima coast',
  1161. f'{sid1}:{self.dfl_mmtype}:1-4',
  1162. f'{sid2}:C:3-7,87,98'
  1163. ])
  1164. def bob_msgsign(self,wallets=[]):
  1165. fn = get_file_with_ext(self.tmpdir,'rawmsg.json')
  1166. t = self.spawn(
  1167. 'mmgen-msg', [
  1168. '--bob',
  1169. f'--outdir={self.tmpdir}',
  1170. 'sign',
  1171. fn
  1172. ] + wallets )
  1173. if not wallets:
  1174. t.passphrase(dfl_wcls.desc,rt_pw)
  1175. return t
  1176. def bob_walletconv_words(self):
  1177. t = self.spawn(
  1178. 'mmgen-walletconv', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=words' ] )
  1179. t.passphrase(dfl_wcls.desc,rt_pw)
  1180. t.written_to_file('data')
  1181. return t
  1182. def bob_subwalletgen_bip39(self):
  1183. t = self.spawn(
  1184. 'mmgen-subwalletgen', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=bip39', '29L' ] )
  1185. t.passphrase(dfl_wcls.desc,rt_pw)
  1186. t.written_to_file('data')
  1187. return t
  1188. def bob_msgsign_userwallet(self):
  1189. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1190. return self.bob_msgsign([fn1])
  1191. def bob_msgsign_userwallets(self):
  1192. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1193. fn2 = get_file_with_ext(self.tmpdir,'bip39')
  1194. return self.bob_msgsign([fn2,fn1])
  1195. def bob_msgverify(self,addr=None,ext='sigmsg.json',cmd='verify',msgfile=None):
  1196. return self.spawn(
  1197. 'mmgen-msg', [
  1198. '--bob',
  1199. f'--outdir={self.tmpdir}',
  1200. cmd,
  1201. msgfile or get_file_with_ext(self.tmpdir,ext),
  1202. ] + ([addr] if addr else []) )
  1203. def bob_msgverify_raw(self):
  1204. t = self.bob_msgverify(ext='rawmsg.json')
  1205. t.expect('No signatures')
  1206. t.req_exit_val = 1
  1207. return t
  1208. def bob_msgverify_single(self):
  1209. sid = self._user_sid('bob')
  1210. return self.bob_msgverify(addr=f'{sid}:{self.dfl_mmtype}:1')
  1211. def bob_msgexport(self,addr=None):
  1212. t = self.bob_msgverify( addr=addr, cmd='export' )
  1213. t.written_to_file('data')
  1214. return t
  1215. def bob_msgexport_single(self):
  1216. sid = self._user_sid('bob')
  1217. return self.bob_msgexport(addr=f'{sid}:{self.dfl_mmtype}:1')
  1218. def bob_msgverify_export(self):
  1219. return self.bob_msgverify(
  1220. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1221. )
  1222. def bob_msgverify_export_single(self):
  1223. sid = self._user_sid('bob')
  1224. mmid = f'{sid}:{self.dfl_mmtype}:1'
  1225. args = [ '--bob', '--color=0', 'listaddress', mmid, 'wide=true' ]
  1226. imsg(f'Running mmgen-tool {fmt_list(args,fmt="bare")}')
  1227. t = self.spawn('mmgen-tool', args, no_msg=True)
  1228. addr = t.expect_getend(mmid).split()[1]
  1229. t.close()
  1230. return self.bob_msgverify(
  1231. addr = addr,
  1232. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1233. )
  1234. def bob_split3(self):
  1235. if not self.proto.cap('segwit'):
  1236. return 'skip'
  1237. sid = self._user_sid('bob')
  1238. return self.user_txdo(
  1239. user = 'bob',
  1240. fee = '23s',
  1241. outputs_cl = [sid+':C:5,0.0135', sid+':L:4'],
  1242. outputs_list = '1' )
  1243. def _usr_auto_chg(self,user,arg,include_dest=True,choices=1):
  1244. dest = [self.burn_addr+',0.01'] if include_dest else []
  1245. t = self.spawn(
  1246. 'mmgen-txcreate',
  1247. ['-d',self.tr.trash_dir,'-B',f'--{user}', arg] + dest)
  1248. return self.txcreate_ui_common(t,
  1249. menu = [],
  1250. inputs = '1',
  1251. interactive_fee = '20s',
  1252. auto_chg_arg = arg,
  1253. auto_chg_choices = choices )
  1254. def bob_auto_chg1(self):
  1255. return self._usr_auto_chg( 'bob', self._user_sid('bob') + ':C' )
  1256. def bob_auto_chg2(self):
  1257. if not self.proto.cap('segwit'):
  1258. return 'skip'
  1259. return self._usr_auto_chg( 'bob', self._user_sid('bob') + ':B' )
  1260. def bob_auto_chg3(self):
  1261. if not self.proto.cap('segwit'):
  1262. return 'skip'
  1263. return self._usr_auto_chg( 'bob', self._user_sid('bob') + ':S' )
  1264. def bob_auto_chg4(self):
  1265. return self._usr_auto_chg( 'bob', self._user_sid('bob') + ':C', include_dest=False )
  1266. def bob_auto_chg_addrtype1(self):
  1267. return self._usr_auto_chg( 'bob', 'C', choices=3 )
  1268. def bob_auto_chg_addrtype2(self):
  1269. if not self.proto.cap('segwit'):
  1270. return 'skip'
  1271. return self._usr_auto_chg( 'bob', 'B', choices=1 )
  1272. def bob_auto_chg_addrtype3(self):
  1273. if not self.proto.cap('segwit'):
  1274. return 'skip'
  1275. return self._usr_auto_chg( 'bob', 'S', choices=1 )
  1276. def bob_auto_chg_addrtype4(self):
  1277. return self._usr_auto_chg( 'bob', 'C', choices=3, include_dest=False )
  1278. def _usr_auto_chg_bad(self,user,al_id,expect):
  1279. t = self.spawn(
  1280. 'mmgen-txcreate',
  1281. ['-d',self.tr.trash_dir,'-B',f'--{user}', self.burn_addr+',0.01', al_id] )
  1282. t.req_exit_val = 2
  1283. t.expect(expect)
  1284. return t
  1285. def bob_auto_chg_bad1(self):
  1286. return self._usr_auto_chg_bad(
  1287. 'bob',
  1288. 'FFFFFFFF:C',
  1289. 'contains no addresses' )
  1290. def bob_auto_chg_bad2(self):
  1291. return self._usr_auto_chg_bad(
  1292. 'bob',
  1293. '00000000:C',
  1294. 'contains no addresses' )
  1295. def bob_auto_chg_bad3(self):
  1296. return self._usr_auto_chg_bad(
  1297. 'bob',
  1298. self._user_sid('bob') + ':L',
  1299. 'contains no unused addresses from address list' )
  1300. def bob_auto_chg_bad4(self):
  1301. return self._usr_auto_chg_bad(
  1302. 'bob',
  1303. 'L',
  1304. 'contains no unused addresses of address type' )
  1305. def stop(self):
  1306. if opt.no_daemon_stop:
  1307. self.spawn('',msg_only=True)
  1308. msg_r('(leaving daemon running by user request)')
  1309. return 'ok'
  1310. else:
  1311. return self.spawn('mmgen-regtest',['stop'])