ct_regtest.py 69 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, command-line Bitcoin cold storage solution
  4. # Copyright (C)2013-2024 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.cmdtest_py_d.ct_regtest: Regtest tests for the cmdtest.py test suite
  20. """
  21. import sys,os,json,time,re
  22. from decimal import Decimal
  23. from mmgen.color import yellow
  24. from mmgen.util import msg_r,die,gmsg,capfirst,fmt_list
  25. from mmgen.protocol import init_proto
  26. from mmgen.addrlist import AddrList
  27. from mmgen.wallet import Wallet,get_wallet_cls
  28. from ..include.common import (
  29. cfg,
  30. imsg,
  31. omsg,
  32. stop_test_daemons,
  33. joinpath,
  34. silence,
  35. end_silence,
  36. cmp_or_die,
  37. strip_ansi_escapes,
  38. gr_uc,
  39. getrandhex
  40. )
  41. from .common import (
  42. ok_msg,
  43. get_file_with_ext,
  44. get_comment,
  45. tw_comment_lat_cyr_gr,
  46. tw_comment_zh,
  47. tx_comment_jp,
  48. get_env_without_debug_vars
  49. )
  50. from .ct_base import CmdTestBase
  51. from .ct_shared import CmdTestShared
  52. pat_date = r'\b\d\d-\d\d-\d\d\b'
  53. pat_date_time = r'\b\d\d\d\d-\d\d-\d\d\s+\d\d:\d\d\b'
  54. dfl_wcls = get_wallet_cls('mmgen')
  55. tx_fee = rtFundAmt = rtFee = rtBals = rtBals_gb = rtBobOp3 = rtAmts = {} # pylint
  56. rt_pw = 'abc-α'
  57. rt_data = {
  58. 'tx_fee': {'btc':'0.0001','bch':'0.001','ltc':'0.01'},
  59. 'rtFundAmt': {'btc':'500','bch':'500','ltc':'5500'},
  60. 'rtFee': {
  61. 'btc': ('20s','10s','60s','31s','10s','20s'),
  62. 'bch': ('20s','10s','60s','0.0001','10s','20s'),
  63. 'ltc': ('1000s','500s','1500s','0.05','400s','1000s')
  64. },
  65. 'rtBals': {
  66. 'btc': ('499.9999488','399.9998282','399.9998147','399.9996877',
  67. '52.99980410','946.99933647','999.99914057','52.9999',
  68. '946.99933647','0.4169328','6.24987417'),
  69. 'bch': ('499.9999484','399.9999194','399.9998972','399.9997692',
  70. '46.78890380','953.20966920','999.99857300','46.789',
  71. '953.2096692','0.4169328','39.58187387'),
  72. 'ltc': ('5499.99744','5399.994425','5399.993885','5399.987535',
  73. '52.98520500','10946.93753500','10999.92274000','52.99',
  74. '10946.937535','0.41364','6.24846787'),
  75. },
  76. 'rtBals_gb': {
  77. 'btc': {
  78. '0conf0': {
  79. 'mmgen': ('283.22339537','283.22339537'),
  80. 'nonmm': ('16.77647763','116.77629233'),
  81. 'total': ('299.999873','399.9996877'),
  82. },
  83. '0conf1': {
  84. 'mmgen': ('283.22339537','0'),
  85. 'nonmm': ('16.77647763','99.9998147'),
  86. 'total': ('299.999873','99.9998147'),
  87. },
  88. '1conf1': {
  89. 'mmgen': ('0','283.22339537'),
  90. 'nonmm': ('0','116.77629233'),
  91. 'total': ('0','399.9996877'),
  92. },
  93. '1conf2': {
  94. 'mmgen': ('0','283.22339537','0'),
  95. 'nonmm': ('0','16.77647763','99.9998147'),
  96. 'total': ('0','299.999873','99.9998147'),
  97. },
  98. },
  99. 'bch': {
  100. '0conf0': {
  101. 'mmgen': ('283.22339437','283.22339437'),
  102. 'nonmm': ('16.77647763','116.77637483'),
  103. 'total': ('299.999872','399.9997692'),
  104. },
  105. '0conf1': {
  106. 'mmgen': ('283.22339437','0'),
  107. 'nonmm': ('16.77647763','99.9998972'),
  108. 'total': ('299.999872','99.9998972'),
  109. },
  110. '1conf1': {
  111. 'mmgen': ('0','283.22339437'),
  112. 'nonmm': ('0','116.77637483'),
  113. 'total': ('0','399.9997692'),
  114. },
  115. '1conf2': {
  116. 'mmgen': ('0','283.22339437','0'),
  117. 'nonmm': ('0','16.77647763','99.9998972'),
  118. 'total': ('0','299.999872','99.9998972'),
  119. },
  120. },
  121. 'ltc': {
  122. '0conf0': {
  123. 'mmgen': ('283.21717237','283.21717237'),
  124. 'nonmm': ('16.77647763','5116.77036263'),
  125. 'total': ('299.99365','5399.987535'),
  126. },
  127. '0conf1': {
  128. 'mmgen': ('283.21717237','0'),
  129. 'nonmm': ('16.77647763','5099.993885'),
  130. 'total': ('299.99365','5099.993885'),
  131. },
  132. '1conf1': {
  133. 'mmgen': ('0','283.21717237'),
  134. 'nonmm': ('0','5116.77036263'),
  135. 'total': ('0','5399.987535'),
  136. },
  137. '1conf2': {
  138. 'mmgen': ('0','283.21717237','0'),
  139. 'nonmm': ('0','16.77647763','5099.993885'),
  140. 'total': ('0','299.99365','5099.993885'),
  141. },
  142. }
  143. },
  144. 'rtBobOp3': {'btc':'S:2','bch':'L:3','ltc':'S:2'},
  145. 'rtAmts': {
  146. 'btc': ('500','500'),
  147. 'bch': ('500','560'),
  148. 'ltc': ('5500','5500')
  149. }
  150. }
  151. def make_burn_addr(proto):
  152. from mmgen.tool.coin import tool_cmd
  153. return tool_cmd(
  154. cfg = cfg,
  155. cmdname = 'pubhash2addr',
  156. proto = proto,
  157. mmtype = 'compressed' ).pubhash2addr('00'*20)
  158. class CmdTestRegtest(CmdTestBase,CmdTestShared):
  159. 'transacting and tracking wallet operations via regtest mode'
  160. networks = ('btc','ltc','bch')
  161. passthru_opts = ('coin','rpc_backend')
  162. extra_spawn_args = ['--regtest=1']
  163. tmpdir_nums = [17]
  164. color = True
  165. deterministic = False
  166. test_rbf = False
  167. proto = None # pylint
  168. cmd_group_in = (
  169. ('setup', 'regtest (Bob and Alice) mode setup'),
  170. ('subgroup.misc', []),
  171. ('subgroup.init_bob', []),
  172. ('subgroup.init_alice', []),
  173. ('subgroup.fund_users', ['init_bob','init_alice']),
  174. ('subgroup.msg', ['init_bob']),
  175. ('subgroup.twexport', ['fund_users']),
  176. ('subgroup.rescan', ['fund_users']),
  177. ('subgroup.errors', ['fund_users']),
  178. ('subgroup.main', ['fund_users']),
  179. ('subgroup.twprune', ['main']),
  180. ('subgroup.txhist', ['main']),
  181. ('subgroup.label', ['main']),
  182. ('subgroup.view', ['label']),
  183. ('subgroup._auto_chg_deps', ['twexport','label']),
  184. ('subgroup.auto_chg', ['_auto_chg_deps']),
  185. ('stop', 'stopping regtest daemon'),
  186. )
  187. cmd_subgroups = {
  188. 'misc': (
  189. 'miscellaneous commands',
  190. ('daemon_version', 'mmgen-tool daemon_version'),
  191. ('halving_calculator_bob', 'halving calculator (Bob)'),
  192. ),
  193. 'init_bob': (
  194. 'creating Bob’s MMGen wallet and tracking wallet',
  195. ('bob_twview_noaddrs', 'viewing Bob’s unspent outputs (error, no addrs)'),
  196. ('bob_listaddrs_noaddrs', 'viewing Bob’s addresses (error, no addrs)'),
  197. ('walletgen_bob', 'wallet generation (Bob)'),
  198. ('addrgen_bob', 'address generation (Bob)'),
  199. ('addrimport_bob', "importing Bob's addresses"),
  200. ('bob_twview_nobal', 'viewing Bob’s unspent outputs (error, no balance)'),
  201. ('bob_listaddrs_nobal', 'viewing Bob’s addresses (OK, no balance)'),
  202. ),
  203. 'init_alice': (
  204. 'creating Alice’s MMGen wallet and tracking wallet',
  205. ('walletgen_alice', 'wallet generation (Alice)'),
  206. ('addrgen_alice', 'address generation (Alice)'),
  207. ('addrimport_alice', "importing Alice's addresses"),
  208. ),
  209. 'fund_users': (
  210. 'funding Bob and Alice’s wallets',
  211. ('bob_import_miner_addr', "importing miner’s coinbase addr into Bob’s wallet"),
  212. ('fund_bob_deterministic', "funding Bob’s first MMGen address (deterministic method)"),
  213. ('fund_alice_deterministic', "funding Alice’s first MMGen address (deterministic method)"),
  214. ('bob_recreate_tracking_wallet', 'creation of new tracking wallet (Bob)'),
  215. ('addrimport_bob2', "reimporting Bob's addresses"),
  216. ('fund_bob', "funding Bob's wallet"),
  217. ('fund_alice', "funding Alice's wallet"),
  218. ('generate', 'mining a block'),
  219. ('bob_bal1', "Bob's balance"),
  220. ('generate_extra_deterministic', "generate extra blocks for deterministic run"),
  221. ),
  222. 'msg': (
  223. 'message signing',
  224. ('bob_msgcreate', 'creating a message file for signing'),
  225. ('bob_msgsign', 'signing the message file (default wallet)'),
  226. ('bob_walletconv_words', 'creating an MMGen mnemonic wallet'),
  227. ('bob_subwalletgen_bip39', 'creating a BIP39 mnemonic subwallet'),
  228. ('bob_msgsign_userwallet', 'signing the message file (user-specified wallet)'),
  229. ('bob_msgsign_userwallets', 'signing the message file (user-specified wallets)'),
  230. ('bob_msgverify', 'verifying the message file (all addresses)'),
  231. ('bob_msgverify_raw', 'verifying the raw message file (all addresses)'),
  232. ('bob_msgverify_single', 'verifying the message file (single address)'),
  233. ('bob_msgexport_single', 'exporting the message file (single address)'),
  234. ('bob_msgexport', 'exporting the message file (all addresses)'),
  235. ('bob_msgverify_export', 'verifying the exported JSON data (all addresses)'),
  236. ('bob_msgverify_export_single', 'verifying the exported JSON data (single address)'),
  237. ),
  238. 'twexport': (
  239. 'exporting and importing tracking wallet to JSON',
  240. ('bob_twexport', 'exporting a tracking wallet to JSON'),
  241. ('carol_twimport', 'importing a tracking wallet JSON dump'),
  242. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  243. ('bob_twexport_noamt', 'exporting a tracking wallet to JSON (include_amts=0)'),
  244. ('carol_twimport_nochksum', 'importing a tracking wallet JSON dump (ignore_checksum=1)'),
  245. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  246. ('carol_twimport_batch', 'importing a tracking wallet JSON dump (batch=1)'),
  247. ('bob_twexport_pretty', 'exporting a tracking wallet to JSON (pretty=1)'),
  248. ('bob_edit_json_twdump', 'editing a tracking wallet JSON dump'),
  249. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  250. ('carol_twimport_pretty', 'importing an edited tracking wallet JSON dump (ignore_checksum=1)'),
  251. ('carol_listaddresses', 'viewing Carol’s tracking wallet'),
  252. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  253. ),
  254. 'rescan': (
  255. 'rescanning address and blockchain',
  256. ('bob_resolve_addr', 'resolving an address in the tracking wallet'),
  257. ('bob_rescan_addr', 'rescanning an address'),
  258. ('bob_rescan_blockchain_all', 'rescanning the blockchain (full rescan)'),
  259. ('bob_rescan_blockchain_gb', 'rescanning the blockchain (Genesis block)'),
  260. ('bob_rescan_blockchain_one', 'rescanning the blockchain (single block)'),
  261. ('bob_rescan_blockchain_ss', 'rescanning the blockchain (range of blocks)'),
  262. ),
  263. 'errors': (
  264. 'various error conditions',
  265. ('bob_bad_locktime1', 'broadcast of transaction with bad locktime (block)'),
  266. ('bob_bad_locktime2', 'broadcast of transaction with bad locktime (integer size)'),
  267. ('bob_bad_locktime3', 'broadcast of transaction with bad locktime (time)'),
  268. ),
  269. 'main': (
  270. 'creating, signing, sending and bumping transactions',
  271. ('bob_add_comment1', "adding an 80-screen-width label (lat+cyr+gr)"),
  272. ('bob_twview1', "viewing Bob's tracking wallet"),
  273. ('bob_split1', "splitting Bob's funds"),
  274. ('generate', 'mining a block'),
  275. ('bob_bal2', "Bob's balance"),
  276. ('bob_rbf_1output_create', 'creating RBF tx with one output'),
  277. ('bob_rbf_1output_bump', 'bumping RBF tx with one output'),
  278. ('bob_bal2a', "Bob's balance (age_fmt=confs)"),
  279. ('bob_bal2b', "Bob's balance (showempty=1)"),
  280. ('bob_bal2c', "Bob's balance (showempty=1 minconf=2 age_fmt=days)"),
  281. ('bob_bal2d', "Bob's balance (minconf=2)"),
  282. ('bob_bal2e', "Bob's balance (showempty=1 sort=age)"),
  283. ('bob_bal2f', "Bob's balance (showempty=1 sort=age,reverse)"),
  284. ('bob_send_maybe_rbf', 'sending funds to Alice (RBF, if supported)'),
  285. ('get_mempool1', 'mempool (before RBF bump)'),
  286. ('bob_rbf_status1', 'getting status of transaction'),
  287. ('bob_rbf_bump', 'bumping RBF transaction'),
  288. ('get_mempool2', 'mempool (after RBF bump)'),
  289. ('bob_rbf_status2', 'getting status of transaction after replacement'),
  290. ('bob_rbf_status3', 'getting status of replacement transaction (mempool)'),
  291. ('generate', 'mining a block'),
  292. ('bob_rbf_status4', 'getting status of transaction after confirmed (1) replacement'),
  293. ('bob_rbf_status5', 'getting status of replacement transaction (confirmed)'),
  294. ('generate', 'mining a block'),
  295. ('bob_rbf_status6', 'getting status of transaction after confirmed (2) replacement'),
  296. ('bob_bal3', "Bob's balance"),
  297. ('bob_pre_import', 'sending to non-imported address'),
  298. ('generate', 'mining a block'),
  299. ('bob_import_addr', 'importing non-MMGen address'),
  300. ('bob_bal4', "Bob's balance (after import)"),
  301. ('bob_import_list', 'importing flat address list'),
  302. ('bob_import_list_rescan', 'importing flat address list with --rescan'),
  303. ('bob_import_list_rescan_aio', 'importing flat address list with --rescan (aiohttp backend)'),
  304. ('bob_split2', "splitting Bob's funds"),
  305. ('bob_0conf0_getbalance', "Bob's balance (unconfirmed, minconf=0)"),
  306. ('bob_0conf1_getbalance', "Bob's balance (unconfirmed, minconf=1)"),
  307. ('generate', 'mining a block'),
  308. ('bob_1conf1_getbalance', "Bob's balance (confirmed, minconf=1)"),
  309. ('bob_1conf2_getbalance', "Bob's balance (confirmed, minconf=2)"),
  310. ('bob_bal5', "Bob's balance"),
  311. ('bob_send_non_mmgen', 'sending funds to Alice (from non-MMGen addrs)'),
  312. ('generate', 'mining a block'),
  313. ('alice_send_estimatefee', 'tx creation with no fee on command line'),
  314. ('generate', 'mining a block'),
  315. ('bob_bal6', "Bob's balance"),
  316. ('bob_subwallet_addrgen1', "generating Bob's addrs from subwallet 29L"),
  317. ('bob_subwallet_addrgen2', "generating Bob's addrs from subwallet 127S"),
  318. ('bob_subwallet_addrimport1', "importing Bob's addrs from subwallet 29L"),
  319. ('bob_subwallet_addrimport2', "importing Bob's addrs from subwallet 127S"),
  320. ('bob_subwallet_fund', "funding Bob's subwallet addrs"),
  321. ('generate', 'mining a block'),
  322. ('bob_twview2', "viewing Bob's tracking wallet"),
  323. ('bob_twview3', "viewing Bob's tracking wallet"),
  324. ('bob_subwallet_txcreate', 'creating a transaction with subwallet inputs'),
  325. ('bob_subwallet_txsign', 'signing a transaction with subwallet inputs'),
  326. ('bob_subwallet_txdo', "sending from Bob's subwallet addrs"),
  327. ('generate', 'mining a block'),
  328. ('bob_twview4', "viewing Bob's tracking wallet"),
  329. ('bob_alice_bal', "Bob and Alice's balances"),
  330. ('bob_nochg_burn', 'zero-change transaction to burn address'),
  331. ('generate', 'mining a block'),
  332. ),
  333. 'twprune': (
  334. 'exporting a pruned tracking wallet to JSON',
  335. ('bob_twprune_noask', 'pruning a tracking wallet'),
  336. ('bob_twprune_skip', 'pruning a tracking wallet (skip pruning)'),
  337. ('bob_twprune_all', 'pruning a tracking wallet (pruning all addrs)'),
  338. ('bob_twprune_skipamt', 'pruning a tracking wallet (skipping addrs with amt)'),
  339. ('bob_twprune_skipused', 'pruning a tracking wallet (skipping used addrs)'),
  340. ('bob_twprune_allamt', 'pruning a tracking wallet (pruning addrs with amt)'),
  341. ('bob_twprune_allused', 'pruning a tracking wallet (pruning used addrs)'),
  342. ('bob_twprune1', 'pruning a tracking wallet (selective prune)'),
  343. ('bob_twprune2', 'pruning a tracking wallet (selective prune)'),
  344. ('bob_twprune3', 'pruning a tracking wallet (selective prune)'),
  345. ('bob_twprune4', 'pruning a tracking wallet (selective prune)'),
  346. ('bob_twprune5', 'pruning a tracking wallet (selective prune)'),
  347. ('bob_twprune6', 'pruning a tracking wallet (selective prune)'),
  348. ),
  349. 'txhist': (
  350. 'viewing transaction history',
  351. ('bob_txhist1', "viewing Bob's transaction history (sort=age)"),
  352. ('bob_txhist2', "viewing Bob's transaction history (sort=blockheight reverse=1)"),
  353. ('bob_txhist3', "viewing Bob's transaction history (sort=blockheight sinceblock=-7)"),
  354. ('bob_txhist4', "viewing Bob's transaction history (sinceblock=399 detail=1)"),
  355. ('bob_txhist_interactive', "viewing Bob's transaction history (age_fmt=date_time interactive=true)"),
  356. ),
  357. 'label': (
  358. 'adding, removing and editing labels',
  359. ('alice_bal2', "Alice's balance"),
  360. ('alice_add_comment1', 'adding a label'),
  361. ('alice_chk_comment1', 'the label'),
  362. ('alice_add_comment2', 'adding a label'),
  363. ('alice_chk_comment2', 'the label'),
  364. ('alice_edit_comment1', 'editing a label (zh)'),
  365. ('alice_edit_comment2', 'editing a label (lat+cyr+gr)'),
  366. ('alice_chk_comment3', 'the label'),
  367. ('alice_remove_comment1', 'removing a label'),
  368. ('alice_chk_comment4', 'the label'),
  369. ('alice_add_comment_coinaddr', 'adding a label using the coin address'),
  370. ('alice_chk_comment_coinaddr', 'the label'),
  371. ('alice_add_comment_badaddr1', 'adding a label with invalid address'),
  372. ('alice_add_comment_badaddr2', 'adding a label with invalid address for this chain'),
  373. ('alice_add_comment_badaddr3', 'adding a label with wrong MMGen address'),
  374. ('alice_add_comment_badaddr4', 'adding a label with wrong coin address'),
  375. ),
  376. 'view': (
  377. 'viewing addresses and unspent outputs',
  378. ('alice_listaddresses_scroll', 'listaddresses (--scroll, interactive=1)'),
  379. ('alice_listaddresses_empty', 'listaddresses (no data)'),
  380. ('alice_listaddresses_menu', 'listaddresses (menu items)'),
  381. ('alice_listaddresses1', 'listaddresses'),
  382. ('alice_listaddresses_days', 'listaddresses (age_fmt=days)'),
  383. ('alice_listaddresses_date', 'listaddresses (age_fmt=date)'),
  384. ('alice_listaddresses_date_time', 'listaddresses (age_fmt=date_time)'),
  385. ('alice_twview1', 'twview'),
  386. ('alice_twview_days', 'twview (age_fmt=days)'),
  387. ('alice_twview_date', 'twview (age_fmt=date)'),
  388. ('alice_twview_date_time', 'twview (age_fmt=date_time)'),
  389. ('alice_txcreate_info', 'txcreate -i'),
  390. ('alice_txcreate_info_term', 'txcreate -i (pexpect_spawn)'),
  391. ('bob_send_to_alice_2addr', 'sending a TX to 2 addresses in Alice’s wallet'),
  392. ('bob_send_to_alice_reuse', 'sending a TX to a used address in Alice’s wallet'),
  393. ('generate', 'mining a block'),
  394. ('alice_twview_grouped', 'twview (testing ‘grouped’ option for TX and address)'),
  395. ),
  396. '_auto_chg_deps': (
  397. 'automatic change address selection dependencies',
  398. ('bob_auto_chg_split', 'splitting Bob’s funds (auto-chg-addr dependency)'),
  399. ('bob_auto_chg_generate', 'mining a block (auto-chg-addr dependency)'),
  400. ),
  401. 'auto_chg': (
  402. 'automatic change address selection',
  403. ('bob_auto_chg1', 'creating an automatic change address transaction (C)'),
  404. ('bob_auto_chg2', 'creating an automatic change address transaction (B)'),
  405. ('bob_auto_chg3', 'creating an automatic change address transaction (S)'),
  406. ('bob_auto_chg4', 'creating an automatic change address transaction (single address)'),
  407. ('bob_auto_chg_addrtype1', 'creating an automatic change address transaction by addrtype (C)'),
  408. ('bob_auto_chg_addrtype2', 'creating an automatic change address transaction by addrtype (B)'),
  409. ('bob_auto_chg_addrtype3', 'creating an automatic change address transaction by addrtype (S)'),
  410. ('bob_auto_chg_addrtype4', 'creating an automatic change address transaction by addrtype (single address)'),
  411. ('bob_add_comment_uua1', 'adding a comment for unused address in tracking wallet (C)'),
  412. ('bob_auto_chg5', 'creating an auto-chg-address TX, skipping unused address with label (C)'),
  413. ('bob_auto_chg_addrtype5', 'creating an auto-chg-address TX by addrtype, skipping unused address '
  414. 'with label (C)'),
  415. ('bob_auto_chg6', 'creating an auto-chg-address TX, using unused address with label (C)'),
  416. ('bob_auto_chg_addrtype6', 'creating an auto-chg-address TX by addrtype, using unused address with '
  417. 'label (C)'),
  418. ('bob_remove_comment_uua1', 'removing a comment for unused address in tracking wallet (C)'),
  419. ('bob_auto_chg_bad1', 'error handling for auto change address transaction (bad ID FFFFFFFF:C)'),
  420. ('bob_auto_chg_bad2', 'error handling for auto change address transaction (bad ID 00000000:C)'),
  421. ('bob_auto_chg_bad3', 'error handling for auto change address transaction (no unused addresses)'),
  422. ('bob_auto_chg_bad4', 'error handling for auto change address transaction by addrtype '
  423. '(no unused addresses)'),
  424. ('carol_twimport2', 'recreating Carol’s tracking wallet from JSON dump'),
  425. ('carol_rescan_blockchain', 'rescanning the blockchain (full rescan)'),
  426. ('carol_auto_chg1', 'creating an automatic change address transaction (C)'),
  427. ('carol_auto_chg2', 'creating an automatic change address transaction (B)'),
  428. ('carol_auto_chg3', 'creating an automatic change address transaction (S)'),
  429. ('carol_auto_chg_addrtype1', 'creating an automatic change address transaction by addrtype (C)'),
  430. ('carol_auto_chg_addrtype2', 'creating an automatic change address transaction by addrtype (B)'),
  431. ('carol_auto_chg_addrtype3', 'creating an automatic change address transaction by addrtype (S)'),
  432. ('carol_auto_chg_bad1', 'error handling for auto change address transaction (no unused addresses)'),
  433. ('carol_auto_chg_bad2', 'error handling for auto change address transaction by addrtype '
  434. '(no unused addresses)'),
  435. ('carol_delete_wallet', 'unloading and deleting Carol’s tracking wallet'),
  436. ),
  437. }
  438. def __init__(self,trunner,cfgs,spawn):
  439. CmdTestBase.__init__(self,trunner,cfgs,spawn)
  440. if trunner == None:
  441. return
  442. if self.proto.testnet:
  443. die(2,'--testnet and --regtest options incompatible with regtest test suite')
  444. self.proto = init_proto( cfg, self.proto.coin, network='regtest', need_amt=True )
  445. coin = self.proto.coin.lower()
  446. for k in rt_data:
  447. setattr( sys.modules[__name__], k, rt_data[k][coin] if coin in rt_data[k] else None )
  448. if self.proto.coin == 'BTC':
  449. self.test_rbf = True # tests are non-coin-dependent, so run just once for BTC
  450. if cfg.test_suite_deterministic:
  451. self.deterministic = True
  452. self.miner_addr = 'bcrt1qaq8t3pakcftpk095tnqfv5cmmczysls024atnd' # regtest.create_hdseed()
  453. self.miner_wif = 'cTyMdQ2BgfAsjopRVZrj7AoEGp97pKfrC2NkqLuwHr4KHfPNAKwp'
  454. self.spawn_env['MMGEN_BOGUS_SEND'] = ''
  455. self.write_to_tmpfile('wallet_password',rt_pw)
  456. self.dfl_mmtype = 'C' if self.proto.coin == 'BCH' else 'B'
  457. self.burn_addr = make_burn_addr(self.proto)
  458. self.user_sids = {}
  459. def _add_comments_to_addr_file(self,addrfile,outfile,use_comments=False):
  460. silence()
  461. gmsg(f'Adding comments to address file {addrfile!r}')
  462. a = AddrList( cfg, self.proto, addrfile )
  463. for n,idx in enumerate(a.idxs(),1):
  464. if use_comments:
  465. a.set_comment(idx,get_comment())
  466. else:
  467. if n % 2:
  468. a.set_comment(idx,f'Test address {n}')
  469. a.file.format(add_comments=True)
  470. from mmgen.fileutil import write_data_to_file
  471. write_data_to_file(
  472. cfg,
  473. outfile = outfile,
  474. data = a.file.fmt_data,
  475. quiet = True,
  476. ignore_opt_outdir = True )
  477. end_silence()
  478. def setup(self):
  479. stop_test_daemons(self.proto.network_id,force=True,remove_datadir=True)
  480. from shutil import rmtree
  481. try:
  482. rmtree(joinpath(self.tr.data_dir,'regtest'))
  483. except:
  484. pass
  485. t = self.spawn('mmgen-regtest',['-n','setup'])
  486. for s in ('Starting','Creating','Creating','Creating','Mined','Setup complete'):
  487. t.expect(s)
  488. return t
  489. def daemon_version(self):
  490. t = self.spawn('mmgen-tool', ['--bob','daemon_version'])
  491. t.expect('version')
  492. return t
  493. def halving_calculator_bob(self):
  494. t = self.spawn('halving-calculator.py',['--bob'],cmd_dir='examples')
  495. t.expect('time until halving')
  496. return t
  497. def walletgen(self,user):
  498. t = self.spawn('mmgen-walletgen',['-q','-r0','-p1','--'+user])
  499. t.passphrase_new('new '+dfl_wcls.desc,rt_pw)
  500. t.label()
  501. t.expect('move it to the data directory? (Y/n): ','y')
  502. t.written_to_file(capfirst(dfl_wcls.desc))
  503. return t
  504. def walletgen_bob(self):
  505. return self.walletgen('bob')
  506. def walletgen_alice(self):
  507. return self.walletgen('alice')
  508. def _user_dir(self,user,coin=None):
  509. return joinpath(self.tr.data_dir,'regtest',coin or self.proto.coin.lower(),user)
  510. def _user_sid(self,user):
  511. if user in self.user_sids:
  512. return self.user_sids[user]
  513. else:
  514. self.user_sids[user] = os.path.basename(get_file_with_ext(self._user_dir(user),'mmdat'))[:8]
  515. return self.user_sids[user]
  516. def _get_user_subsid(self,user,subseed_idx):
  517. fn = get_file_with_ext(self._user_dir(user),dfl_wcls.ext)
  518. silence()
  519. w = Wallet( cfg, fn=fn, passwd_file=os.path.join(self.tmpdir,'wallet_password') )
  520. end_silence()
  521. return w.seed.subseed(subseed_idx).sid
  522. def addrgen(
  523. self,
  524. user,
  525. wf = None,
  526. addr_range = '1-5',
  527. subseed_idx = None,
  528. mmtypes = []):
  529. from mmgen.addr import MMGenAddrType
  530. for mmtype in mmtypes or self.proto.mmtypes:
  531. t = self.spawn(
  532. 'mmgen-addrgen',
  533. ['--quiet','--'+user,'--type='+mmtype,f'--outdir={self._user_dir(user)}'] +
  534. ([wf] if wf else []) +
  535. (['--subwallet='+subseed_idx] if subseed_idx else []) +
  536. [addr_range],
  537. extra_desc = '({})'.format( MMGenAddrType.mmtypes[mmtype].name ))
  538. t.passphrase(dfl_wcls.desc,rt_pw)
  539. t.written_to_file('Addresses')
  540. ok_msg()
  541. t.skip_ok = True
  542. return t
  543. def addrgen_bob(self):
  544. return self.addrgen('bob')
  545. def addrgen_alice(self):
  546. return self.addrgen('alice')
  547. def addrimport(
  548. self,
  549. user,
  550. sid = None,
  551. addr_range = '1-5',
  552. num_addrs = 5,
  553. mmtypes = [],
  554. batch = True,
  555. quiet = True):
  556. id_strs = { 'legacy':'', 'compressed':'-C', 'segwit':'-S', 'bech32':'-B' }
  557. if not sid:
  558. sid = self._user_sid(user)
  559. from mmgen.addr import MMGenAddrType
  560. for mmtype in mmtypes or self.proto.mmtypes:
  561. desc = MMGenAddrType.mmtypes[mmtype].name
  562. addrfile = joinpath(self._user_dir(user),
  563. '{}{}{}[{}]{x}.regtest.addrs'.format(
  564. sid,self.altcoin_pfx,id_strs[desc],addr_range,
  565. x='-α' if cfg.debug_utf8 else ''))
  566. if mmtype == self.proto.mmtypes[0] and user == 'bob':
  567. self._add_comments_to_addr_file(addrfile,addrfile,use_comments=True)
  568. t = self.spawn(
  569. 'mmgen-addrimport',
  570. args = (
  571. (['--quiet'] if quiet else []) +
  572. ['--'+user] +
  573. (['--batch'] if batch else []) +
  574. [addrfile] ),
  575. extra_desc = f'({desc})' )
  576. if cfg.debug:
  577. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  578. t.expect('Importing')
  579. if batch:
  580. t.expect(f'{num_addrs} addresses imported')
  581. else:
  582. t.expect('import completed OK')
  583. t.ok()
  584. t.skip_ok = True
  585. return t
  586. def addrimport_bob(self):
  587. return self.addrimport('bob')
  588. def addrimport_alice(self):
  589. return self.addrimport('alice',batch=False,quiet=False)
  590. def bob_import_miner_addr(self):
  591. if not self.deterministic:
  592. return 'skip'
  593. return self.spawn(
  594. 'mmgen-addrimport',
  595. [ '--bob', '--rescan', '--quiet', f'--address={self.miner_addr}' ] )
  596. def fund_wallet_deterministic(self,addr,utxo_nums,skip_passphrase=False):
  597. """
  598. the deterministic funding method using specific inputs
  599. """
  600. if not self.deterministic:
  601. return 'skip'
  602. self.write_to_tmpfile('miner.key',f'{self.miner_wif}\n')
  603. keyfile = joinpath(self.tmpdir,'miner.key')
  604. return self.user_txdo(
  605. 'bob', '40s',
  606. [ f'{addr},{rtFundAmt}', self.burn_addr ],
  607. utxo_nums,
  608. extra_args = [f'--keys-from-file={keyfile}'],
  609. skip_passphrase = skip_passphrase )
  610. def fund_bob_deterministic(self):
  611. return self.fund_wallet_deterministic( f'{self._user_sid("bob")}:C:1', '1-11' )
  612. def fund_alice_deterministic(self):
  613. sid = self._user_sid('alice')
  614. mmtype = ('L','S')[self.proto.cap('segwit')]
  615. addr = self.get_addr_from_addrlist('alice',sid,mmtype,0,addr_range='1-5')
  616. return self.fund_wallet_deterministic( addr, '1-11', skip_passphrase=True )
  617. def generate_extra_deterministic(self):
  618. if not self.deterministic:
  619. return 'skip'
  620. return self.generate(num_blocks=2) # do this so block count matches non-deterministic run
  621. async def bob_recreate_tracking_wallet(self):
  622. if not self.deterministic:
  623. return 'skip'
  624. self.spawn('',msg_only=True)
  625. from mmgen.proto.btc.regtest import MMGenRegtest
  626. rt = MMGenRegtest(cfg,self.proto.coin)
  627. await rt.stop()
  628. from shutil import rmtree
  629. imsg('Deleting Bob’s old tracking wallet')
  630. rmtree(os.path.join(rt.d.datadir,'regtest','wallets','bob'),ignore_errors=True)
  631. rt.init_daemon()
  632. rt.d.start(silent=True)
  633. imsg('Creating Bob’s new tracking wallet')
  634. await rt.rpc_call('createwallet','bob',True,True,None,False,False,False)
  635. await rt.stop()
  636. await rt.start()
  637. return 'ok'
  638. def addrimport_bob2(self):
  639. if not self.deterministic:
  640. return 'skip'
  641. return self.addrimport('bob')
  642. def fund_wallet(self,user,mmtype,amt,sid=None,addr_range='1-5'):
  643. if self.deterministic:
  644. return 'skip'
  645. if not sid:
  646. sid = self._user_sid(user)
  647. addr = self.get_addr_from_addrlist(user,sid,mmtype,0,addr_range=addr_range)
  648. t = self.spawn('mmgen-regtest', ['send',str(addr),str(amt)])
  649. t.expect(f'Sending {amt} miner {self.proto.coin}')
  650. t.expect('Mined 1 block')
  651. return t
  652. def fund_bob(self):
  653. return self.fund_wallet('bob','C',rtFundAmt)
  654. def fund_alice(self):
  655. return self.fund_wallet('alice',('L','S')[self.proto.cap('segwit')],rtFundAmt)
  656. def user_twview(self, user, chk=None, expect=None, cmdline=['twview'], sort='age', exit_val=None):
  657. t = self.spawn('mmgen-tool',[f'--{user}'] + cmdline + ['sort='+sort])
  658. if chk:
  659. t.expect(r'{}\b.*\D{}\b'.format(*chk),regex=True)
  660. if expect:
  661. t.expect(expect)
  662. if exit_val:
  663. t.req_exit_val = exit_val
  664. return t
  665. def bob_twview_noaddrs(self):
  666. return self.user_twview('bob', expect='No spendable', exit_val=1)
  667. def bob_listaddrs_noaddrs(self):
  668. return self.user_twview('bob', cmdline=['listaddresses'], expect='No addresses', exit_val=1)
  669. def bob_twview_nobal(self):
  670. return self.user_twview('bob', expect='No spendable', exit_val=1)
  671. def bob_listaddrs_nobal(self):
  672. return self.user_twview('bob', cmdline=['listaddresses'], expect='TOTAL:')
  673. def bob_twview1(self):
  674. return self.user_twview('bob', chk = ('1',rtAmts[0]) )
  675. def user_bal(self,user,bal,args=['showempty=1'],skip_check=False):
  676. t = self.spawn('mmgen-tool',['--'+user,'listaddresses'] + args)
  677. if not skip_check:
  678. cmp_or_die(f'{bal} {self.proto.coin}',strip_ansi_escapes(t.expect_getend('TOTAL: ')))
  679. return t
  680. def alice_bal1(self):
  681. return self.user_bal('alice',rtFundAmt)
  682. def alice_bal2(self):
  683. return self.user_bal('alice',rtBals[8])
  684. def bob_bal1(self):
  685. return self.user_bal('bob',rtFundAmt)
  686. def bob_bal2(self):
  687. return self.user_bal('bob',rtBals[0])
  688. def bob_bal2a(self):
  689. return self.user_bal('bob',rtBals[0],args=['showempty=1','age_fmt=confs'])
  690. def bob_bal2b(self):
  691. return self.user_bal('bob',rtBals[0],args=['showempty=1'])
  692. def bob_bal2c(self):
  693. return self.user_bal('bob',rtBals[0],args=['showempty=1','minconf=2','age_fmt=days'],skip_check=True)
  694. def bob_bal2d(self):
  695. return self.user_bal('bob',rtBals[0],args=['minconf=2'],skip_check=True)
  696. def bob_bal2e(self):
  697. return self.user_bal('bob',rtBals[0],args=['showempty=1','sort=amt'])
  698. def bob_bal2f(self):
  699. return self.user_bal('bob',rtBals[0],args=['showempty=0','sort=twmmid','reverse=1'])
  700. def bob_bal3(self):
  701. return self.user_bal('bob',rtBals[1])
  702. def bob_bal4(self):
  703. return self.user_bal('bob',rtBals[2])
  704. def bob_bal5(self):
  705. return self.user_bal('bob',rtBals[3])
  706. def bob_bal6(self):
  707. return self.user_bal('bob',rtBals[7])
  708. def bob_subwallet_addrgen1(self):
  709. return self.addrgen('bob',subseed_idx='29L',mmtypes=['C']) # 29L: 2FA7BBA8
  710. def bob_subwallet_addrgen2(self):
  711. return self.addrgen('bob',subseed_idx='127S',mmtypes=['C']) # 127S: '09E8E286'
  712. def subwallet_addrimport(self,user,subseed_idx):
  713. sid = self._get_user_subsid(user,subseed_idx)
  714. return self.addrimport(user,sid=sid,mmtypes=['C'])
  715. def bob_subwallet_addrimport1(self):
  716. return self.subwallet_addrimport('bob','29L')
  717. def bob_subwallet_addrimport2(self):
  718. return self.subwallet_addrimport('bob','127S')
  719. def bob_subwallet_fund(self):
  720. sid1 = self._get_user_subsid('bob','29L')
  721. sid2 = self._get_user_subsid('bob','127S')
  722. chg_addr = self._user_sid('bob') + (':B:1',':L:1')[self.proto.coin=='BCH']
  723. return self.user_txdo(
  724. user = 'bob',
  725. fee = rtFee[1],
  726. outputs_cl = [sid1+':C:2,0.29',sid2+':C:3,0.127',chg_addr],
  727. outputs_list = ('3','1')[self.proto.coin=='BCH'],
  728. extra_args = ['--subseeds=127'],
  729. used_chg_addr_resp = (None,'y')[self.proto.coin=='BCH'] )
  730. def bob_twview2(self):
  731. sid1 = self._get_user_subsid('bob','29L')
  732. return self.user_twview('bob',chk=(sid1+':C:2','0.29'),sort='twmmid')
  733. def bob_twview3(self):
  734. sid2 = self._get_user_subsid('bob','127S')
  735. return self.user_twview('bob',chk=(sid2+':C:3','0.127'),sort='amt')
  736. def bob_subwallet_txcreate(self):
  737. sid1 = self._get_user_subsid('bob','29L')
  738. sid2 = self._get_user_subsid('bob','127S')
  739. outputs_cl = [sid1+':C:5,0.0159',sid2+':C:5']
  740. t = self.spawn('mmgen-txcreate',['-d',self.tmpdir,'-B','--bob'] + outputs_cl)
  741. return self.txcreate_ui_common(t,
  742. menu = ['a'],
  743. inputs = ('1,2','2,3')[self.proto.coin=='BCH'],
  744. interactive_fee = '0.00001')
  745. def bob_subwallet_txsign(self):
  746. fn = get_file_with_ext(self.tmpdir,'rawtx')
  747. t = self.spawn('mmgen-txsign',['-d',self.tmpdir,'--bob','--subseeds=127',fn])
  748. t.view_tx('t')
  749. t.passphrase(dfl_wcls.desc,rt_pw)
  750. t.do_comment(None)
  751. t.expect('(Y/n): ','y')
  752. t.written_to_file('Signed transaction')
  753. return t
  754. def bob_subwallet_txdo(self):
  755. outputs_cl = [self._user_sid('bob')+':L:5']
  756. inputs = ('1,2','2,3')[self.proto.coin=='BCH']
  757. return self.user_txdo('bob',rtFee[5],outputs_cl,inputs,menu=['a'],extra_args=['--subseeds=127']) # sort: amt
  758. def bob_twview4(self):
  759. sid = self._user_sid('bob')
  760. return self.user_twview('bob',chk=(sid+':L:5',rtBals[9]),sort='twmmid')
  761. def user_txhist(self,user,args,expect):
  762. t = self.spawn('mmgen-tool',['--'+user,'txhist'] + args)
  763. m = re.search( expect, t.read(strip_color=True), re.DOTALL )
  764. assert m, f'Expected: {expect}'
  765. return t
  766. def bob_txhist1(self):
  767. return self.user_txhist('bob',
  768. args = ['sort=age'],
  769. expect = fr'\s1\).*\s{rtFundAmt}\s' )
  770. def bob_txhist2(self):
  771. return self.user_txhist('bob',
  772. args = ['sort=blockheight','reverse=1','age_fmt=block'],
  773. expect = fr'\s1\).*:{self.dfl_mmtype}:1\s' )
  774. def bob_txhist3(self):
  775. return self.user_txhist('bob',
  776. args = ['sort=blockheight','sinceblock=-7','age_fmt=block'],
  777. expect = fr'Displaying transactions since block 399.*\s6\)\s+405\s.*\s{rtBals[9]}\s.*:L:5.*\s7\)'
  778. )
  779. def bob_txhist4(self):
  780. return self.user_txhist('bob',
  781. args = ['sort=blockheight','sinceblock=399','age_fmt=block','detail=1'],
  782. expect = fr'Displaying transactions since block 399.*\s7\).*Block:.*406.*Value:.*{rtBals[10]}'
  783. )
  784. def bob_txhist_interactive(self):
  785. self.get_file_with_ext('out',delete_all=True)
  786. t = self.spawn('mmgen-tool',
  787. ['--bob',f'--outdir={self.tmpdir}','txhist','age_fmt=date_time','interactive=true'] )
  788. for resp in ('u','i','t','a','m','T','A','r','r','D','D','D','D','p','P','n','V'):
  789. t.expect('draw:\b',resp,regex=True)
  790. if t.pexpect_spawn:
  791. t.expect(r'Block:.*394',regex=True)
  792. time.sleep(1)
  793. t.send('q')
  794. time.sleep(0.2)
  795. t.send('n')
  796. t.expect('draw:\b','q',regex=True)
  797. else:
  798. txnum,idx = (8,1) if self.proto.coin == 'BCH' else (9,3)
  799. t.expect(rf'\s{txnum}\).*Inputs:.*:L:{idx}.*Outputs \(3\):.*:C:2.*\s10\)','q',regex=True)
  800. return t
  801. def bob_getbalance(self,bals,confs=1):
  802. for i in range(len(bals['mmgen'])):
  803. assert Decimal(bals['mmgen'][i]) + Decimal(bals['nonmm'][i]) == Decimal(bals['total'][i])
  804. sid = self._user_sid('bob')
  805. t = self.spawn('mmgen-tool',['--bob','getbalance',f'minconf={confs}'])
  806. t.expect('Wallet')
  807. for k,lbl in (
  808. ('mmgen',f'{sid}:'),
  809. ('nonmm','Non-MMGen:'),
  810. ('total',f'TOTAL {self.proto.coin}')
  811. ):
  812. ret = strip_ansi_escapes(t.expect_getend(lbl + ' '))
  813. cmp_or_die(
  814. ' '.join(bals[k]),
  815. ' '.join(ret.split()),
  816. desc = k,
  817. )
  818. return t
  819. def bob_0conf0_getbalance(self):
  820. return self.bob_getbalance(rtBals_gb['0conf0'],confs=0)
  821. def bob_0conf1_getbalance(self):
  822. return self.bob_getbalance(rtBals_gb['0conf1'],confs=1)
  823. def bob_1conf1_getbalance(self):
  824. return self.bob_getbalance(rtBals_gb['1conf1'],confs=1)
  825. def bob_1conf2_getbalance(self):
  826. return self.bob_getbalance(rtBals_gb['1conf2'],confs=2)
  827. def bob_nochg_burn(self):
  828. return self.user_txdo('bob',
  829. fee = '0.00009713',
  830. outputs_cl = [self.burn_addr],
  831. outputs_list = '1' )
  832. def bob_alice_bal(self):
  833. t = self.spawn('mmgen-regtest',['balances'])
  834. ret = t.expect_getend("Bob's balance:").strip()
  835. cmp_or_die(rtBals[4],ret)
  836. ret = t.expect_getend("Alice's balance:").strip()
  837. cmp_or_die(rtBals[5],ret)
  838. ret = t.expect_getend("Total balance:").strip()
  839. cmp_or_die(rtBals[6],ret)
  840. return t
  841. def user_txsend_status(self,user,tx_file,exp1='',exp2='',extra_args=[]):
  842. t = self.spawn('mmgen-txsend',['-d',self.tmpdir,'--'+user,'--status'] + extra_args + [tx_file])
  843. if exp1:
  844. t.expect(exp1,regex=True)
  845. if exp2:
  846. t.expect(exp2,regex=True)
  847. return t
  848. def user_txdo( self,
  849. user,
  850. fee,
  851. outputs_cl,
  852. outputs_list,
  853. extra_args = [],
  854. wf = None,
  855. add_comment = tx_comment_jp,
  856. return_early = False,
  857. return_after_send = False,
  858. menu = ['M'],
  859. skip_passphrase = False,
  860. used_chg_addr_resp = None):
  861. t = self.spawn('mmgen-txdo',
  862. ['-d',self.tmpdir,'-B','--'+user] +
  863. (['--fee='+fee] if fee else []) +
  864. extra_args + ([],[wf])[bool(wf)] + outputs_cl)
  865. self.txcreate_ui_common(
  866. t,
  867. caller = 'txdo',
  868. menu = menu,
  869. inputs = outputs_list,
  870. file_desc = 'Signed transaction',
  871. interactive_fee = (tx_fee,'')[bool(fee)],
  872. add_comment = add_comment,
  873. return_early = return_early,
  874. view = 't',
  875. save = True,
  876. used_chg_addr_resp = used_chg_addr_resp)
  877. if return_early:
  878. return t
  879. if not skip_passphrase:
  880. t.passphrase(dfl_wcls.desc,rt_pw)
  881. t.written_to_file('Signed transaction')
  882. self._do_confirm_send(t)
  883. if return_after_send:
  884. return t
  885. t.expect('Transaction sent')
  886. return t
  887. def bob_split1(self):
  888. sid = self._user_sid('bob')
  889. outputs_cl = [sid+':C:1,100', sid+':L:2,200',sid+':'+rtBobOp3]
  890. return self.user_txdo('bob',rtFee[0],outputs_cl,'1',extra_args=['--locktime=500000001'])
  891. def get_addr_from_addrlist(self,user,sid,mmtype,idx,addr_range='1-5'):
  892. id_str = { 'L':'', 'S':'-S', 'C':'-C', 'B':'-B' }[mmtype]
  893. ext = '{}{}{}[{}]{x}.regtest.addrs'.format(
  894. sid,self.altcoin_pfx,id_str,addr_range,x='-α' if cfg.debug_utf8 else '')
  895. addrfile = get_file_with_ext(self._user_dir(user),ext,no_dot=True)
  896. silence()
  897. addr = AddrList( cfg, self.proto, addrfile ).data[idx].addr
  898. end_silence()
  899. return addr
  900. def _create_tx_outputs(self,user,data):
  901. sid = self._user_sid(user)
  902. return [self.get_addr_from_addrlist(user,sid,mmtype,idx-1)+amt_str for mmtype,idx,amt_str in data]
  903. def bob_rbf_1output_create(self):
  904. if not self.test_rbf:
  905. return 'skip'
  906. out_addr = self._create_tx_outputs('alice',(('B',5,''),))
  907. t = self.spawn('mmgen-txcreate',['-d',self.tr.trash_dir,'-B','--bob'] + out_addr)
  908. return self.txcreate_ui_common(t,menu=[],inputs='3',interactive_fee='3s') # out amt: 199.99999343
  909. def bob_rbf_1output_bump(self):
  910. if not self.test_rbf:
  911. return 'skip'
  912. ext = '9343,3]{x}.regtest.rawtx'.format(x='-α' if cfg.debug_utf8 else '')
  913. txfile = get_file_with_ext(self.tr.trash_dir,ext,delete=False,no_dot=True)
  914. return self.user_txbump('bob',
  915. self.tr.trash_dir,
  916. txfile,
  917. '8s',
  918. has_label = False,
  919. signed_tx = False,
  920. one_output = True )
  921. def bob_send_maybe_rbf(self):
  922. outputs_cl = self._create_tx_outputs('alice',(('L',1,',60'),('C',1,',40'))) # alice_sid:L:1, alice_sid:C:1
  923. outputs_cl += [self._user_sid('bob')+':'+rtBobOp3]
  924. return self.user_txdo('bob',rtFee[1],outputs_cl,'3',
  925. extra_args = (['--no-rbf'],[])[self.proto.cap('rbf')],
  926. used_chg_addr_resp = 'y' )
  927. def bob_send_non_mmgen(self):
  928. outputs_cl = self._create_tx_outputs('alice',(
  929. (('L','S')[self.proto.cap('segwit')],2,',10'),
  930. (('L','S')[self.proto.cap('segwit')],3,'')
  931. )) # alice_sid:S:2, alice_sid:S:3
  932. keyfile = joinpath(self.tmpdir,'non-mmgen.keys')
  933. return self.user_txdo('bob',rtFee[3],outputs_cl,'1,4-10',
  934. extra_args=['--keys-from-file='+keyfile,'--vsize-adj=1.02'])
  935. def alice_send_estimatefee(self):
  936. outputs_cl = self._create_tx_outputs('bob',(('L',1,''),)) # bob_sid:L:1
  937. return self.user_txdo('alice',None,outputs_cl,'1') # fee=None
  938. def user_txbump(
  939. self,
  940. user,
  941. outdir,
  942. txfile,
  943. fee,
  944. add_args = [],
  945. has_label = True,
  946. signed_tx = True,
  947. one_output = False):
  948. if not self.proto.cap('rbf'):
  949. return 'skip'
  950. t = self.spawn('mmgen-txbump',
  951. ['-d',outdir,'--'+user,'--fee='+fee,'--output-to-reduce=c'] + add_args + [txfile])
  952. if not one_output:
  953. t.expect('OK? (Y/n): ','y') # output OK?
  954. t.expect('OK? (Y/n): ','y') # fee OK?
  955. t.do_comment(False,has_label=has_label)
  956. if signed_tx:
  957. t.passphrase(dfl_wcls.desc,rt_pw)
  958. t.written_to_file('Signed transaction')
  959. self.txsend_ui_common(t,caller='txdo',bogus_send=False,file_desc='Signed transaction')
  960. else:
  961. t.expect('Save fee-bumped transaction? (y/N): ','y')
  962. t.written_to_file('Fee-bumped transaction')
  963. return t
  964. def bob_rbf_bump(self):
  965. ext = ',{}]{x}.regtest.sigtx'.format(rtFee[1][:-1],x='-α' if cfg.debug_utf8 else '')
  966. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  967. return self.user_txbump('bob',self.tmpdir,txfile,rtFee[2],add_args=['--send'])
  968. def generate(self,num_blocks=1):
  969. int(num_blocks)
  970. t = self.spawn('mmgen-regtest',['generate',str(num_blocks)])
  971. t.expect(f'Mined {num_blocks} block')
  972. return t
  973. def _get_mempool(self):
  974. ret = self.spawn(
  975. 'mmgen-regtest',
  976. ['mempool'],
  977. env = os.environ if cfg.debug_utf8 else get_env_without_debug_vars(),
  978. ).read()
  979. m = re.search(r'(\[\s*"[a-f0-9]{64}"\s*])',ret) # allow for extra output by handler at end
  980. return json.loads(m.group(1))
  981. def get_mempool1(self):
  982. mp = self._get_mempool()
  983. if len(mp) != 1:
  984. die(4,'Mempool has more or less than one TX!')
  985. self.write_to_tmpfile('rbf_txid',mp[0]+'\n')
  986. return 'ok'
  987. def bob_rbf_status(self,fee,exp1,exp2=''):
  988. if not self.proto.cap('rbf'):
  989. return 'skip'
  990. ext = ',{}]{x}.regtest.sigtx'.format(fee[:-1],x='-α' if cfg.debug_utf8 else '')
  991. txfile = self.get_file_with_ext(ext,delete=False,no_dot=True)
  992. return self.user_txsend_status('bob',txfile,exp1,exp2)
  993. def bob_rbf_status1(self):
  994. if not self.proto.cap('rbf'):
  995. return 'skip'
  996. return self.bob_rbf_status(rtFee[1],'in mempool, replaceable')
  997. def get_mempool2(self):
  998. if not self.proto.cap('rbf'):
  999. return 'skip'
  1000. mp = self._get_mempool()
  1001. if len(mp) != 1:
  1002. die(4,'Mempool has more or less than one TX!')
  1003. chk = self.read_from_tmpfile('rbf_txid')
  1004. if chk.strip() == mp[0]:
  1005. die(4,'TX in mempool has not changed! RBF bump failed')
  1006. self.write_to_tmpfile('rbf_txid2',mp[0]+'\n')
  1007. return 'ok'
  1008. def bob_rbf_status2(self):
  1009. if not self.proto.cap('rbf'):
  1010. return 'skip'
  1011. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  1012. return self.bob_rbf_status(rtFee[1],
  1013. 'Transaction has been replaced',f'{new_txid} in mempool')
  1014. def bob_rbf_status3(self):
  1015. if not self.proto.cap('rbf'):
  1016. return 'skip'
  1017. return self.bob_rbf_status(rtFee[2],'status: in mempool, replaceable')
  1018. def bob_rbf_status4(self):
  1019. if not self.proto.cap('rbf'):
  1020. return 'skip'
  1021. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  1022. return self.bob_rbf_status(rtFee[1],
  1023. 'Replacement transaction has 1 confirmation',
  1024. rf'Replacing transactions:\s+{new_txid}' )
  1025. def bob_rbf_status5(self):
  1026. if not self.proto.cap('rbf'):
  1027. return 'skip'
  1028. return self.bob_rbf_status(rtFee[2],'Transaction has 1 confirmation')
  1029. def bob_rbf_status6(self):
  1030. if not self.proto.cap('rbf'):
  1031. return 'skip'
  1032. new_txid = self.read_from_tmpfile('rbf_txid2').strip()
  1033. return self.bob_rbf_status(rtFee[1],
  1034. 'Replacement transaction has 2 confirmations',
  1035. rf'Replacing transactions:\s+{new_txid}' )
  1036. def _gen_pairs(self,n):
  1037. from mmgen.tool.api import tool_api
  1038. t = tool_api(cfg)
  1039. t.init_coin(self.proto.coin,self.proto.network)
  1040. def gen_addr(Type):
  1041. t.addrtype = Type
  1042. wif = t.hex2wif(getrandhex(32))
  1043. return ( wif, t.wif2addr(wif) )
  1044. return [gen_addr('legacy')] + [gen_addr('compressed') for i in range(n-1)]
  1045. def bob_pre_import(self):
  1046. pairs = self._gen_pairs(5)
  1047. self.write_to_tmpfile('non-mmgen.keys','\n'.join([a[0] for a in pairs])+'\n')
  1048. self.write_to_tmpfile('non-mmgen.addrs','\n'.join([a[1] for a in pairs])+'\n')
  1049. return self.user_txdo('bob',rtFee[4],[pairs[0][1]],'3')
  1050. def user_import(self,user,args,nAddr):
  1051. t = self.spawn('mmgen-addrimport',['--'+user]+args)
  1052. if cfg.debug:
  1053. t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  1054. t.expect(f'Importing {nAddr} address')
  1055. if '--rescan' in args:
  1056. if not '--quiet' in args:
  1057. t.expect('Continue? (Y/n): ','y')
  1058. t.expect('Rescanning block')
  1059. return t
  1060. def bob_import_addr(self):
  1061. addr = self.read_from_tmpfile('non-mmgen.addrs').split()[0]
  1062. return self.user_import('bob',['--quiet','--address='+addr],nAddr=1)
  1063. def bob_import_list_rescan_aio(self):
  1064. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  1065. return self.user_import('bob',['--rescan','--rpc-backend=aio','--addrlist',addrfile],nAddr=5)
  1066. def bob_resolve_addr(self):
  1067. mmaddr = '{}:C:1'.format(self._user_sid('bob'))
  1068. t = self.spawn('mmgen-tool',['--bob','resolve_address',mmaddr])
  1069. coinaddr = re.search(r'[0-9A-Za-z]{30,}', t.read())[0]
  1070. t = self.spawn('mmgen-tool',['--bob','resolve_address',coinaddr],no_msg=True)
  1071. mmaddr_res = re.search(r'[0-9A-F]{8}:C:1', t.read())[0]
  1072. assert mmaddr == mmaddr_res, f'{mmaddr} != {mmaddr_res}'
  1073. return t
  1074. def bob_import_list(self):
  1075. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  1076. return self.user_import('bob',['--quiet','--addrlist',addrfile],nAddr=5)
  1077. def bob_import_list_rescan(self):
  1078. addrfile = joinpath(self.tmpdir,'non-mmgen.addrs')
  1079. return self.user_import('bob',['--quiet','--rescan','--addrlist',addrfile],nAddr=5)
  1080. def bob_rescan_addr(self):
  1081. sid = self._user_sid('bob')
  1082. t = self.spawn('mmgen-tool',['--bob','rescan_address',f'{sid}:C:1'])
  1083. t.expect('Found 1 unspent output')
  1084. t.expect('updated successfully')
  1085. return t
  1086. def _usr_rescan_blockchain(self,user,add_args,expect=None):
  1087. t = self.spawn('mmgen-tool',[f'--{user}','rescan_blockchain'] + add_args)
  1088. if expect:
  1089. t.expect(f'Scanning blocks {expect}')
  1090. t.expect('Done')
  1091. return t
  1092. def bob_rescan_blockchain_all(self):
  1093. return self._usr_rescan_blockchain('bob',[],'300-396')
  1094. def bob_rescan_blockchain_gb(self):
  1095. return self._usr_rescan_blockchain('bob',['start_block=0','stop_block=0'],'0-0')
  1096. def bob_rescan_blockchain_one(self):
  1097. return self._usr_rescan_blockchain('bob',['start_block=300','stop_block=300'],'300-300')
  1098. def bob_rescan_blockchain_ss(self):
  1099. return self._usr_rescan_blockchain('bob',['start_block=300','stop_block=302'],'300-302')
  1100. def bob_twexport(self,add_args=[]):
  1101. t = self.spawn('mmgen-tool',['--bob',f'--outdir={self.tmpdir}','twexport'] + add_args)
  1102. t.written_to_file('JSON data')
  1103. return t
  1104. def bob_twexport_noamt(self):
  1105. return self.bob_twexport(add_args=['include_amts=0'])
  1106. def bob_twexport_pretty(self):
  1107. return self.bob_twexport(add_args=['pretty=1'])
  1108. def _bob_twprune(
  1109. self,
  1110. prune_spec,
  1111. npruned,
  1112. expect_menu = (),
  1113. expect = (),
  1114. expect2 = (),
  1115. warn_used = False,
  1116. non_segwit_ok = False):
  1117. if not (non_segwit_ok or self.proto.cap('segwit')):
  1118. return 'skip'
  1119. t = self.spawn(
  1120. 'mmgen-tool',
  1121. ['--bob',f'--outdir={self.tr.trash_dir}','twexport','prune=1']
  1122. + (['warn_used=1'] if warn_used else []) )
  1123. for s in expect_menu:
  1124. t.expect('prune list:\b',s)
  1125. t.expect('prune list:\b','p')
  1126. t.expect('addresses to prune: ',f'{prune_spec}\n')
  1127. for p,s in expect:
  1128. t.expect(p,s,regex=True)
  1129. t.expect('prune list:\b','q')
  1130. for p,s in expect2:
  1131. t.expect(p,s,regex=True)
  1132. if npruned:
  1133. t.expect(f'Pruned {npruned} addresses')
  1134. taddr = 35 if self.proto.cap('segwit') else 25
  1135. t.expect(f'Exporting {taddr-npruned} addresses')
  1136. t.written_to_file('JSON data')
  1137. return t
  1138. def bob_twprune_noask(self):
  1139. return self._bob_twprune(
  1140. expect_menu = 'a', # sort by amt to make address order deterministic
  1141. prune_spec = '35,12,18,3-5',
  1142. npruned = 6 )
  1143. def bob_twprune_all(self):
  1144. taddr = 35 if self.proto.cap('segwit') else 25
  1145. return self._bob_twprune(
  1146. prune_spec = f'1-{taddr}',
  1147. npruned = taddr,
  1148. expect = [('all with balance: ','P')],
  1149. non_segwit_ok = True )
  1150. def bob_twprune_skip(self):
  1151. return self._bob_twprune(
  1152. prune_spec = '',
  1153. npruned = 0,
  1154. non_segwit_ok = True )
  1155. def bob_twprune_skipamt(self):
  1156. return self._bob_twprune(
  1157. prune_spec = '1-35',
  1158. npruned = 32,
  1159. expect = [('all with balance: ','S')] )
  1160. def bob_twprune_skipused(self):
  1161. return self._bob_twprune(
  1162. prune_spec = '1-35',
  1163. npruned = 18,
  1164. expect = [('all used: ','S')],
  1165. warn_used = True )
  1166. def bob_twprune_allamt(self):
  1167. return self._bob_twprune(
  1168. prune_spec = '1-35',
  1169. npruned = 35,
  1170. expect = [('all with balance: ','P')],
  1171. expect2 = [('Warning: pruned address .* has a balance',None)] )
  1172. def bob_twprune_allused(self):
  1173. return self._bob_twprune(
  1174. prune_spec = '1-35',
  1175. npruned = 32,
  1176. expect = [('all used: ','P'),('all with balance: ','S')],
  1177. expect2 = [('Warning: pruned address .* used',None)],
  1178. warn_used = True )
  1179. @property
  1180. def _b_start(self):
  1181. """
  1182. SIDs sort non-deterministically, so we must search for start of main (not subseeds) group, i.e. ':B:1'
  1183. """
  1184. assert self.proto.cap('segwit')
  1185. if not hasattr(self,'_b_start_'):
  1186. t = self.spawn( 'mmgen-tool', ['--color=0','--bob','listaddresses'], no_msg=True )
  1187. self._b_start_ = int([e for e in t.read().split('\n') if ':B:1' in e][0].split()[0].rstrip(')'))
  1188. t.close()
  1189. return self._b_start_
  1190. def _bob_twprune_selected(self,resp,npruned):
  1191. if not self.proto.cap('segwit'):
  1192. return 'skip'
  1193. B = self._b_start
  1194. a,b,c,d,e,f = resp
  1195. return self._bob_twprune(
  1196. expect_menu = 'a', # sort by amt to make address order deterministic
  1197. prune_spec = f'31-32,{B+14},{B+9},{B}-{B+4}',
  1198. npruned = npruned,
  1199. expect = [
  1200. ('all used: ', a),
  1201. ('all used: ', b),
  1202. ('all with balance: ', c),
  1203. ('all with balance: ', d),
  1204. ('all used: ', e),
  1205. ('all used: ', f),
  1206. ],
  1207. warn_used = True )
  1208. def bob_twprune1(self):
  1209. return self._bob_twprune_selected(resp='sssssS',npruned=3)
  1210. def bob_twprune2(self):
  1211. return self._bob_twprune_selected(resp='sppPsS',npruned=3)
  1212. def bob_twprune3(self):
  1213. return self._bob_twprune_selected(resp='sssPpS',npruned=3)
  1214. def bob_twprune4(self):
  1215. return self._bob_twprune_selected(resp='sssPpP',npruned=9)
  1216. def bob_twprune5(self):
  1217. return self._bob_twprune_selected(resp='pppPpP',npruned=9)
  1218. def bob_twprune6(self):
  1219. return self._bob_twprune_selected(resp='sssSpP',npruned=7)
  1220. def bob_edit_json_twdump(self):
  1221. self.spawn('',msg_only=True)
  1222. from mmgen.tw.json import TwJSON
  1223. fn = TwJSON.Base(cfg,self.proto).dump_fn
  1224. text = json.loads(self.read_from_tmpfile(fn))
  1225. text['data']['entries'][3][3] = f'edited comment [фубар] [{gr_uc}]'
  1226. self.write_to_tmpfile( fn, json.dumps(text,indent=4) )
  1227. return 'ok'
  1228. def carol_twimport(
  1229. self,
  1230. rpc_backend = 'http',
  1231. add_parms = [],
  1232. expect_str = None,
  1233. expect_str2 = 'Found 1 unspent output'):
  1234. from mmgen.tw.json import TwJSON
  1235. fn = joinpath( self.tmpdir, TwJSON.Base(cfg,self.proto).dump_fn )
  1236. t = self.spawn(
  1237. 'mmgen-tool',
  1238. ([f'--rpc-backend={rpc_backend}'] if rpc_backend else [])
  1239. + ['--carol','twimport',fn]
  1240. + add_parms )
  1241. t.expect('(y/N): ','y')
  1242. if expect_str:
  1243. t.expect(expect_str)
  1244. elif 'batch=true' in add_parms:
  1245. t.expect('{} addresses imported'.format(10 if self.proto.coin == 'BCH' else 20))
  1246. else:
  1247. t.expect('import completed OK')
  1248. t.expect(expect_str2)
  1249. return t
  1250. def carol_twimport_nochksum(self):
  1251. return self.carol_twimport(rpc_backend=None,add_parms=['ignore_checksum=true'])
  1252. def carol_twimport_batch(self):
  1253. return self.carol_twimport(add_parms=['batch=true'])
  1254. def carol_twimport_pretty(self):
  1255. return self.carol_twimport(add_parms=['ignore_checksum=true'],expect_str='ignoring incorrect checksum')
  1256. def carol_listaddresses(self):
  1257. return self.spawn('mmgen-tool',['--carol','listaddresses','showempty=1'])
  1258. async def carol_delete_wallet(self):
  1259. imsg('Unloading Carol’s tracking wallet')
  1260. t = self.spawn('mmgen-regtest',['cli','unloadwallet','carol'])
  1261. t.ok()
  1262. from mmgen.rpc import rpc_init
  1263. rpc = await rpc_init(cfg,self.proto)
  1264. wdir = joinpath(rpc.daemon.network_datadir,'wallets','carol')
  1265. from shutil import rmtree
  1266. imsg('Deleting Carol’s tracking wallet')
  1267. rmtree(wdir)
  1268. return 'silent'
  1269. def bob_split2(self):
  1270. addrs = self.read_from_tmpfile('non-mmgen.addrs').split()
  1271. amts = (1.12345678,2.87654321,3.33443344,4.00990099,5.43214321)
  1272. outputs1 = list(map('{},{}'.format,addrs,amts))
  1273. sid = self._user_sid('bob')
  1274. l1,l2 = (
  1275. (':S',':B') if 'B' in self.proto.mmtypes else
  1276. (':S',':S') if self.proto.cap('segwit') else
  1277. (':L',':L') )
  1278. outputs2 = [sid+':C:2,6.333', sid+':L:3,6.667',sid+l1+':4,0.123',sid+l2+':5']
  1279. return self.user_txdo('bob',rtFee[5],outputs1+outputs2,'1-2')
  1280. def user_add_comment(self,user,addr,comment):
  1281. t = self.spawn('mmgen-tool',['--'+user,'add_label',addr,comment])
  1282. t.expect('Added label.*in tracking wallet',regex=True)
  1283. return t
  1284. def user_remove_comment(self,user,addr):
  1285. t = self.spawn('mmgen-tool',['--'+user,'remove_label',addr])
  1286. t.expect('Removed label.*in tracking wallet',regex=True)
  1287. return t
  1288. def bob_bad_locktime1(self):
  1289. return self._bob_bad_locktime(123456789, 'non-final', 2) # > current block height
  1290. def bob_bad_locktime2(self):
  1291. return self._bob_bad_locktime(7_000_000_000, 'invalid', 2, return_early=True) # > 4 bytes
  1292. def bob_bad_locktime3(self):
  1293. return self._bob_bad_locktime(0xffffffff, 'non-final', 2, return_early=False) # > cur time
  1294. def _bob_bad_locktime(self,locktime,expect,exit_val,return_early=False):
  1295. sid = self._user_sid('bob')
  1296. t = self.user_txdo(
  1297. user = 'bob',
  1298. fee = '20s',
  1299. outputs_cl = [self.burn_addr+',0.1', sid+':C:5'],
  1300. outputs_list = '1',
  1301. extra_args = [f'--locktime={locktime}'],
  1302. return_early = return_early,
  1303. add_comment = False,
  1304. return_after_send = True)
  1305. t.req_exit_val = exit_val
  1306. if expect:
  1307. t.expect(expect)
  1308. return t
  1309. def bob_add_comment1(self):
  1310. sid = self._user_sid('bob')
  1311. return self.user_add_comment('bob',sid+':C:1',tw_comment_lat_cyr_gr)
  1312. def alice_add_comment1(self):
  1313. sid = self._user_sid('alice')
  1314. return self.user_add_comment('alice',sid+':C:1','Original Label - 月へ')
  1315. def alice_add_comment2(self):
  1316. sid = self._user_sid('alice')
  1317. return self.user_add_comment('alice',sid+':C:1','Replacement Label')
  1318. def _user_chk_comment(self,user,addr,comment,extra_args=[]):
  1319. t = self.spawn('mmgen-tool',['--'+user,'listaddresses','all_labels=1']+extra_args)
  1320. ret = strip_ansi_escapes(t.expect_getend(addr)).strip().split(None,2)[2]
  1321. cmp_or_die( # squeezed display, double-width chars, so truncate to min field width
  1322. ret[:3].strip(),
  1323. comment[:3].strip())
  1324. return t
  1325. def alice_add_comment_coinaddr(self):
  1326. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  1327. t = self.spawn('mmgen-tool',['--alice','listaddress',mmid,'wide=true'],no_msg=True)
  1328. addr = [i for i in strip_ansi_escapes(t.read()).splitlines() if re.search(rf'\b{mmid}\b',i)][0].split()[3]
  1329. return self.user_add_comment('alice',addr,'Label added using coin address of MMGen address')
  1330. def alice_chk_comment_coinaddr(self):
  1331. mmid = self._user_sid('alice') + (':S:1',':L:1')[self.proto.coin=='BCH']
  1332. return self._user_chk_comment('alice',mmid,'Label added using coin address of MMGen address')
  1333. def alice_add_comment_badaddr(self,addr,reply,exit_val):
  1334. if os.getenv('PYTHONOPTIMIZE'):
  1335. omsg(yellow(f'PYTHONOPTIMIZE set, skipping test {self.test_name!r}'))
  1336. return 'skip'
  1337. t = self.spawn('mmgen-tool',['--alice','add_label',addr,'(none)'])
  1338. t.expect(reply,regex=True)
  1339. t.req_exit_val = exit_val
  1340. return t
  1341. def alice_add_comment_badaddr1(self):
  1342. return self.alice_add_comment_badaddr( rt_pw, 'invalid address', 2 )
  1343. def alice_add_comment_badaddr2(self):
  1344. # mainnet zero address:
  1345. addr = init_proto( cfg, self.proto.coin, network='mainnet' ).pubhash2addr(bytes(20),False)
  1346. return self.alice_add_comment_badaddr( addr, 'invalid address', 2 )
  1347. def alice_add_comment_badaddr3(self):
  1348. addr = self._user_sid('alice') + ':C:123'
  1349. return self.alice_add_comment_badaddr( addr, f'MMGen address {addr!r} not found in tracking wallet', 2 )
  1350. def alice_add_comment_badaddr4(self):
  1351. addr = self.proto.pubhash2addr(bytes(20),False) # regtest (testnet) zero address
  1352. return self.alice_add_comment_badaddr( addr, f'Coin address {addr!r} not found in tracking wallet', 2 )
  1353. def alice_remove_comment1(self):
  1354. sid = self._user_sid('alice')
  1355. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1356. return self.user_remove_comment('alice',mmid)
  1357. def alice_chk_comment1(self):
  1358. sid = self._user_sid('alice')
  1359. return self._user_chk_comment('alice',sid+':C:1','Original Label - 月へ')
  1360. def alice_chk_comment2(self):
  1361. sid = self._user_sid('alice')
  1362. return self._user_chk_comment('alice',sid+':C:1','Replacement Label',extra_args=['age_fmt=block'])
  1363. def alice_edit_comment1(self):
  1364. return self.user_edit_comment('alice','4',tw_comment_lat_cyr_gr)
  1365. def alice_edit_comment2(self):
  1366. return self.user_edit_comment('alice','3',tw_comment_zh)
  1367. def alice_chk_comment3(self):
  1368. sid = self._user_sid('alice')
  1369. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1370. return self._user_chk_comment('alice',mmid,tw_comment_lat_cyr_gr,extra_args=['age_fmt=date'])
  1371. def alice_chk_comment4(self):
  1372. sid = self._user_sid('alice')
  1373. mmid = sid + (':S:3',':L:3')[self.proto.coin=='BCH']
  1374. return self._user_chk_comment('alice',mmid,'-',extra_args=['age_fmt=date_time'])
  1375. def user_edit_comment(self,user,output,comment):
  1376. t = self.spawn('mmgen-txcreate',['-B','--'+user,'-i'])
  1377. t.expect(r'add \[l\]abel:.','M',regex=True)
  1378. t.expect(r'add \[l\]abel:.','l',regex=True)
  1379. t.expect(r"Enter unspent.*return to main menu\):.",output+'\n',regex=True)
  1380. t.expect(r"Enter label text.*:.",comment+'\n',regex=True)
  1381. t.expect(r'\[q\]uit menu, .*?:.','q',regex=True)
  1382. return t
  1383. def alice_listaddresses_scroll(self):
  1384. t = self.spawn(
  1385. 'mmgen-tool', [
  1386. '--alice',
  1387. '--scroll',
  1388. f'--outdir={self.tr.trash_dir}',
  1389. 'listaddresses',
  1390. 'interactive=1',
  1391. ]
  1392. )
  1393. t.expect('abel:\b','p')
  1394. ret = t.expect([ 'abel:\b', 'to confirm: ' ])
  1395. if ret == 1:
  1396. t.send('YES\n')
  1397. t.expect('abel:\b')
  1398. t.send('l')
  1399. t.expect(
  1400. 'main menu): ',
  1401. '{}\n'.format(2 if self.proto.coin == 'BCH' else 1) )
  1402. t.expect('for address.*: ','\n',regex=True)
  1403. t.expect('unchanged')
  1404. t.expect('abel:\b','q')
  1405. return t
  1406. def _alice_listaddresses_interactive(self,expect=(),expect_menu=()):
  1407. t = self.spawn('mmgen-tool',['--alice','listaddresses','interactive=1'])
  1408. for s in expect_menu:
  1409. t.expect('abel:\b',s)
  1410. for p,s in expect:
  1411. t.expect(p,s)
  1412. return t
  1413. def alice_listaddresses_empty(self):
  1414. return self._alice_listaddresses_interactive(expect_menu='uuEq')
  1415. def alice_listaddresses_menu(self):
  1416. return self._alice_listaddresses_interactive(expect_menu='aAMrDDDDLeq')
  1417. def alice_listaddresses(self,args,expect):
  1418. t = self.spawn('mmgen-tool',['--alice','listaddresses','showempty=1'] + args)
  1419. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  1420. t.expect(expect_str,regex=True)
  1421. return t
  1422. def alice_listaddresses1(self):
  1423. return self.alice_listaddresses(
  1424. args = [],
  1425. expect = (rtAmts[1],r'\d+') )
  1426. def alice_listaddresses_days(self):
  1427. return self.alice_listaddresses(
  1428. args = ['age_fmt=days'],
  1429. expect = (rtAmts[1],r'\d+') )
  1430. def alice_listaddresses_date(self):
  1431. return self.alice_listaddresses(
  1432. args = ['age_fmt=date'],
  1433. expect = (rtAmts[1],pat_date) )
  1434. def alice_listaddresses_date_time(self):
  1435. return self.alice_listaddresses(
  1436. args = ['age_fmt=date_time'],
  1437. expect = (rtAmts[1],pat_date_time) )
  1438. def alice_twview(self,args,expect):
  1439. t = self.spawn('mmgen-tool',['--alice','twview'] + args)
  1440. expect_str = r'\D{}\D.*\b{}'.format(*expect)
  1441. t.expect(expect_str,regex=True)
  1442. return t
  1443. def alice_twview1(self):
  1444. return self.alice_twview(
  1445. args = [],
  1446. expect = (rtAmts[0],r'\d+') )
  1447. def alice_twview_days(self):
  1448. return self.alice_twview(
  1449. args = ['age_fmt=days'],
  1450. expect = (rtAmts[0],r'\d+') )
  1451. def alice_twview_date(self):
  1452. return self.alice_twview(
  1453. args = ['age_fmt=date'],
  1454. expect = (rtAmts[0],pat_date) )
  1455. def alice_twview_date_time(self):
  1456. return self.alice_twview(
  1457. args = ['age_fmt=date_time'],
  1458. expect = (rtAmts[0],pat_date_time) )
  1459. def alice_txcreate_info(self,pexpect_spawn=False):
  1460. t = self.spawn('mmgen-txcreate',['--alice','-Bi'],pexpect_spawn=pexpect_spawn)
  1461. pats = (
  1462. ( r'\d+', 'w'),
  1463. ( r'\d+', 'D'),
  1464. ( r'\d+', 'D'),
  1465. ( r'\d+', 'D'),
  1466. ( pat_date, 'q'),
  1467. )
  1468. for d,s in pats:
  1469. t.expect(
  1470. r'\D{}\D.*\b{}\b'.format( rtAmts[0], d ),
  1471. s,
  1472. regex=True )
  1473. if t.pexpect_spawn and s == 'w':
  1474. t.expect(r'Total.*','q',regex=True,delay=1 if cfg.exact_output else t.send_delay)
  1475. time.sleep(t.send_delay)
  1476. t.send('e')
  1477. return t
  1478. def alice_txcreate_info_term(self):
  1479. if self.skip_for_win():
  1480. return 'skip'
  1481. return self.alice_txcreate_info(pexpect_spawn=True)
  1482. # send one TX to 2 addrs in Alice’s wallet - required for alice_twview_grouped()
  1483. def bob_send_to_alice_2addr(self):
  1484. outputs_cl = self._create_tx_outputs('alice',[('C',1,',0.02'),('C',2,',0.2')])
  1485. outputs_cl += [self._user_sid('bob')+':C:5']
  1486. return self.user_txdo('bob','25s',outputs_cl,'1')
  1487. # send to a used addr in Alice’s wallet - required for alice_twview_grouped()
  1488. def bob_send_to_alice_reuse(self):
  1489. outputs_cl = self._create_tx_outputs('alice',[('C',1,',0.0111')])
  1490. outputs_cl += [self._user_sid('bob')+':C:5']
  1491. return self.user_txdo('bob','25s',outputs_cl,'1')
  1492. def alice_twview_grouped(self):
  1493. t = self.spawn('mmgen-tool',['--alice','twview','interactive=1'])
  1494. prompt = 'abel:\b'
  1495. for s,dots in (
  1496. ('o',False),
  1497. ('M',False),
  1498. ('t',True),
  1499. ('q',True),
  1500. ):
  1501. if dots:
  1502. t.expect('........')
  1503. t.expect(prompt,s)
  1504. return t
  1505. def bob_msgcreate(self):
  1506. sid1 = self._user_sid('bob')
  1507. sid2 = self._get_user_subsid('bob','29L')
  1508. return self.spawn(
  1509. 'mmgen-msg', [
  1510. '--bob',
  1511. f'--outdir={self.tmpdir}',
  1512. 'create',
  1513. '16/3/2022 Earthquake strikes Fukushima coast',
  1514. f'{sid1}:{self.dfl_mmtype}:1-4',
  1515. f'{sid2}:C:3-7,87,98'
  1516. ])
  1517. def bob_msgsign(self,wallets=[]):
  1518. fn = get_file_with_ext(self.tmpdir,'rawmsg.json')
  1519. t = self.spawn(
  1520. 'mmgen-msg', [
  1521. '--bob',
  1522. f'--outdir={self.tmpdir}',
  1523. 'sign',
  1524. fn
  1525. ] + wallets )
  1526. if not wallets:
  1527. t.passphrase(dfl_wcls.desc,rt_pw)
  1528. return t
  1529. def bob_walletconv_words(self):
  1530. t = self.spawn(
  1531. 'mmgen-walletconv', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=words' ] )
  1532. t.passphrase(dfl_wcls.desc,rt_pw)
  1533. t.written_to_file('data')
  1534. return t
  1535. def bob_subwalletgen_bip39(self):
  1536. t = self.spawn(
  1537. 'mmgen-subwalletgen', [ '--bob', f'--outdir={self.tmpdir}', '--out-fmt=bip39', '29L' ] )
  1538. t.passphrase(dfl_wcls.desc,rt_pw)
  1539. t.written_to_file('data')
  1540. return t
  1541. def bob_msgsign_userwallet(self):
  1542. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1543. return self.bob_msgsign([fn1])
  1544. def bob_msgsign_userwallets(self):
  1545. fn1 = get_file_with_ext(self.tmpdir,'mmwords')
  1546. fn2 = get_file_with_ext(self.tmpdir,'bip39')
  1547. return self.bob_msgsign([fn2,fn1])
  1548. def bob_msgverify(self,addr=None,ext='sigmsg.json',cmd='verify',msgfile=None):
  1549. return self.spawn(
  1550. 'mmgen-msg', [
  1551. '--bob',
  1552. f'--outdir={self.tmpdir}',
  1553. cmd,
  1554. msgfile or get_file_with_ext(self.tmpdir,ext),
  1555. ] + ([addr] if addr else []) )
  1556. def bob_msgverify_raw(self):
  1557. t = self.bob_msgverify(ext='rawmsg.json')
  1558. t.expect('No signatures')
  1559. t.req_exit_val = 1
  1560. return t
  1561. def bob_msgverify_single(self):
  1562. sid = self._user_sid('bob')
  1563. return self.bob_msgverify(addr=f'{sid}:{self.dfl_mmtype}:1')
  1564. def bob_msgexport(self,addr=None):
  1565. t = self.bob_msgverify( addr=addr, cmd='export' )
  1566. t.written_to_file('data')
  1567. return t
  1568. def bob_msgexport_single(self):
  1569. sid = self._user_sid('bob')
  1570. return self.bob_msgexport(addr=f'{sid}:{self.dfl_mmtype}:1')
  1571. def bob_msgverify_export(self):
  1572. return self.bob_msgverify(
  1573. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1574. )
  1575. def bob_msgverify_export_single(self):
  1576. sid = self._user_sid('bob')
  1577. mmid = f'{sid}:{self.dfl_mmtype}:1'
  1578. args = [ '--bob', '--color=0', 'listaddress', mmid, 'wide=true' ]
  1579. imsg(f'Running mmgen-tool {fmt_list(args,fmt="bare")}')
  1580. t = self.spawn('mmgen-tool', args, no_msg=True)
  1581. addr = t.expect_getend(mmid).split()[1]
  1582. t.close()
  1583. return self.bob_msgverify(
  1584. addr = addr,
  1585. msgfile = os.path.join(self.tmpdir,'signatures.json')
  1586. )
  1587. def bob_auto_chg_split(self):
  1588. if not self.proto.cap('segwit'):
  1589. return 'skip'
  1590. sid = self._user_sid('bob')
  1591. return self.user_txdo(
  1592. user = 'bob',
  1593. fee = '23s',
  1594. outputs_cl = [sid+':C:5,0.0135', sid+':L:4'],
  1595. outputs_list = '1' )
  1596. def bob_auto_chg_generate(self):
  1597. if not self.proto.cap('segwit'):
  1598. return 'skip'
  1599. return self.generate()
  1600. def _usr_auto_chg(
  1601. self,
  1602. user,
  1603. mmtype,
  1604. idx,
  1605. by_mmtype = False,
  1606. include_dest = True,
  1607. ignore_labels = False):
  1608. if mmtype in ('S','B') and not self.proto.cap('segwit'):
  1609. return 'skip'
  1610. sid = self._user_sid('bob')
  1611. t = self.spawn(
  1612. 'mmgen-txcreate',
  1613. [f'--outdir={self.tr.trash_dir}', '--no-blank', f'--{user}'] +
  1614. (['--autochg-ignore-labels'] if ignore_labels else []) +
  1615. [mmtype if by_mmtype else f'{sid}:{mmtype}'] +
  1616. ([self.burn_addr+',0.01'] if include_dest else [])
  1617. )
  1618. return self.txcreate_ui_common(t,
  1619. menu = [],
  1620. inputs = '1',
  1621. interactive_fee = '20s',
  1622. auto_chg_addr = f'{sid}:{mmtype}:{idx}')
  1623. def bob_auto_chg1(self):
  1624. return self._usr_auto_chg( 'bob', 'C', '3' )
  1625. def bob_auto_chg2(self):
  1626. return self._usr_auto_chg( 'bob', 'B', '2' )
  1627. def bob_auto_chg3(self):
  1628. return self._usr_auto_chg( 'bob', 'S', '1' )
  1629. def bob_auto_chg4(self):
  1630. return self._usr_auto_chg( 'bob', 'C', '3', include_dest=False )
  1631. def bob_auto_chg_addrtype1(self):
  1632. return self._usr_auto_chg( 'bob', 'C', '3', True )
  1633. def bob_auto_chg_addrtype2(self):
  1634. return self._usr_auto_chg( 'bob', 'B', '2', True )
  1635. def bob_auto_chg_addrtype3(self):
  1636. return self._usr_auto_chg( 'bob', 'S', '1', True )
  1637. def bob_auto_chg_addrtype4(self):
  1638. return self._usr_auto_chg( 'bob', 'C', '3', True, include_dest=False )
  1639. def _bob_add_comment_uua(self,addrspec,comment):
  1640. sid = self._user_sid('bob')
  1641. return self.user_add_comment('bob',sid+addrspec,comment)
  1642. def bob_add_comment_uua1(self):
  1643. return self._bob_add_comment_uua(':C:3','comment for unused address')
  1644. def bob_auto_chg5(self):
  1645. return self._usr_auto_chg( 'bob', 'C', '4' )
  1646. def bob_auto_chg_addrtype5(self):
  1647. return self._usr_auto_chg( 'bob', 'C', '4', True )
  1648. def bob_auto_chg6(self):
  1649. return self._usr_auto_chg( 'bob', 'C', '3', ignore_labels=True )
  1650. def bob_auto_chg_addrtype6(self):
  1651. return self._usr_auto_chg( 'bob', 'C', '3', True, ignore_labels=True )
  1652. def _bob_remove_comment_uua(self,addrspec):
  1653. sid = self._user_sid('bob')
  1654. return self.user_remove_comment('bob',sid+addrspec)
  1655. def bob_remove_comment_uua1(self):
  1656. return self._bob_remove_comment_uua(':C:3')
  1657. def _usr_auto_chg_bad(self,user,al_id,expect):
  1658. t = self.spawn(
  1659. 'mmgen-txcreate',
  1660. ['-d',self.tr.trash_dir,'-B',f'--{user}', self.burn_addr+',0.01', al_id] )
  1661. t.req_exit_val = 2
  1662. t.expect(expect)
  1663. return t
  1664. def bob_auto_chg_bad1(self):
  1665. return self._usr_auto_chg_bad(
  1666. 'bob',
  1667. 'FFFFFFFF:C',
  1668. 'contains no addresses' )
  1669. def bob_auto_chg_bad2(self):
  1670. return self._usr_auto_chg_bad(
  1671. 'bob',
  1672. '00000000:C',
  1673. 'contains no addresses' )
  1674. def bob_auto_chg_bad3(self):
  1675. return self._usr_auto_chg_bad(
  1676. 'bob',
  1677. self._user_sid('bob') + ':L',
  1678. 'contains no unused addresses from address list' )
  1679. def bob_auto_chg_bad4(self):
  1680. return self._usr_auto_chg_bad(
  1681. 'bob',
  1682. 'L',
  1683. 'contains no unused addresses of address type' )
  1684. def carol_twimport2(self):
  1685. u,b = (4,3) if self.proto.cap('segwit') else (3,2)
  1686. return self.carol_twimport(
  1687. rpc_backend = None,
  1688. add_parms = ['ignore_checksum=true'],
  1689. expect_str2 = f'Found {u} unspent outputs in {b} blocks' )
  1690. def carol_rescan_blockchain(self):
  1691. return self._usr_rescan_blockchain('carol',[])
  1692. def carol_auto_chg1(self):
  1693. return self._usr_auto_chg( 'carol', 'C', '3' )
  1694. def carol_auto_chg2(self):
  1695. return self._usr_auto_chg( 'carol', 'B', '2' )
  1696. def carol_auto_chg3(self):
  1697. return self._usr_auto_chg( 'carol', 'S', '1' )
  1698. def carol_auto_chg_addrtype1(self):
  1699. return self._usr_auto_chg( 'carol', 'C', '3', True )
  1700. def carol_auto_chg_addrtype2(self):
  1701. return self._usr_auto_chg( 'carol', 'B', '2', True )
  1702. def carol_auto_chg_addrtype3(self):
  1703. return self._usr_auto_chg( 'carol', 'S', '1', True )
  1704. def carol_auto_chg_bad1(self):
  1705. return self._usr_auto_chg_bad(
  1706. 'carol',
  1707. self._user_sid('bob') + ':L',
  1708. 'contains no unused addresses from address list' )
  1709. def carol_auto_chg_bad2(self):
  1710. return self._usr_auto_chg_bad(
  1711. 'carol',
  1712. 'L',
  1713. 'contains no unused addresses of address type' )
  1714. def stop(self):
  1715. if cfg.no_daemon_stop:
  1716. self.spawn('',msg_only=True)
  1717. msg_r('(leaving daemon running by user request)')
  1718. return 'ok'
  1719. else:
  1720. return self.spawn('mmgen-regtest',['stop'])