ts_ethdev.py 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773
  1. #!/usr/bin/env python3
  2. #
  3. # mmgen = Multi-Mode GENerator, command-line Bitcoin cold storage solution
  4. # Copyright (C)2013-2019 The MMGen Project <mmgen@tuta.io>
  5. #
  6. # This program is free software: you can redistribute it and/or modify
  7. # it under the terms of the GNU General Public License as published by
  8. # the Free Software Foundation, either version 3 of the License, or
  9. # (at your option) any later version.
  10. #
  11. # This program is distributed in the hope that it will be useful,
  12. # but WITHOUT ANY WARRANTY; without even the implied warranty of
  13. # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  14. # GNU General Public License for more details.
  15. #
  16. # You should have received a copy of the GNU General Public License
  17. # along with this program. If not, see <http://www.gnu.org/licenses/>.
  18. """
  19. ts_ethdev.py: Ethdev tests for the test.py test suite
  20. """
  21. import sys,os,subprocess,re,shutil
  22. from decimal import Decimal
  23. from mmgen.globalvars import g
  24. from mmgen.opts import opt
  25. from mmgen.util import die
  26. from mmgen.exception import *
  27. from test.common import *
  28. from test.test_py_d.common import *
  29. del_addrs = ('4','1')
  30. dfl_sid = '98831F3A'
  31. # The Parity dev address with lots of coins. Create with "ethkey -b info ''":
  32. dfl_addr = '00a329c0648769a73afac7f9381e08fb43dbea72'
  33. dfl_addr_chk = '00a329c0648769A73afAc7F9381E08FB43dBEA72'
  34. dfl_privkey = '4d5db4107d237df6a3d58ee5f70ae63d73d7658d4026f2eefd2f204c81682cb7'
  35. burn_addr = 'deadbeef'*5
  36. amt1 = '999999.12345689012345678'
  37. amt2 = '888.111122223333444455'
  38. parity_pid_fn = 'parity.pid'
  39. parity_key_fn = 'parity.devkey'
  40. # Token sends require varying amounts of gas, depending on compiler version
  41. solc_ver = re.search(r'Version:\s*(.*)',
  42. subprocess.Popen(['solc','--version'],stdout=subprocess.PIPE
  43. ).stdout.read().decode()).group(1)
  44. if re.match(r'\b0.5.1\b',solc_ver): # Raspbian Stretch
  45. vbal1 = '1.2288337'
  46. vbal2 = '99.997085083'
  47. vbal3 = '1.23142165'
  48. vbal4 = '127.0287837'
  49. elif re.match(r'\b0.5.3\b',solc_ver): # Ubuntu Bionic
  50. vbal1 = '1.2288487'
  51. vbal2 = '99.997092733'
  52. vbal3 = '1.23142915'
  53. vbal4 = '127.0287987'
  54. bals = {
  55. '1': [ ('98831F3A:E:1','123.456')],
  56. '2': [ ('98831F3A:E:1','123.456'),('98831F3A:E:11','1.234')],
  57. '3': [ ('98831F3A:E:1','123.456'),('98831F3A:E:11','1.234'),('98831F3A:E:21','2.345')],
  58. '4': [ ('98831F3A:E:1','100'),
  59. ('98831F3A:E:2','23.45495'),
  60. ('98831F3A:E:11','1.234'),
  61. ('98831F3A:E:21','2.345')],
  62. '5': [ ('98831F3A:E:1','100'),
  63. ('98831F3A:E:2','23.45495'),
  64. ('98831F3A:E:11','1.234'),
  65. ('98831F3A:E:21','2.345'),
  66. (burn_addr + '\s+Non-MMGen',amt1)],
  67. '8': [ ('98831F3A:E:1','0'),
  68. ('98831F3A:E:2','23.45495'),
  69. ('98831F3A:E:11',vbal1,'a'),
  70. ('98831F3A:E:12','99.99895'),
  71. ('98831F3A:E:21','2.345'),
  72. (burn_addr + '\s+Non-MMGen',amt1)],
  73. '9': [ ('98831F3A:E:1','0'),
  74. ('98831F3A:E:2','23.45495'),
  75. ('98831F3A:E:11',vbal1,'a'),
  76. ('98831F3A:E:12',vbal2),
  77. ('98831F3A:E:21','2.345'),
  78. (burn_addr + '\s+Non-MMGen',amt1)]
  79. }
  80. token_bals = {
  81. '1': [ ('98831F3A:E:11','1000','1.234')],
  82. '2': [ ('98831F3A:E:11','998.76544',vbal3,'a'),
  83. ('98831F3A:E:12','1.23456','0')],
  84. '3': [ ('98831F3A:E:11','110.654317776666555545',vbal1,'a'),
  85. ('98831F3A:E:12','1.23456','0')],
  86. '4': [ ('98831F3A:E:11','110.654317776666555545',vbal1,'a'),
  87. ('98831F3A:E:12','1.23456','0'),
  88. (burn_addr + '\s+Non-MMGen',amt2,amt1)],
  89. '5': [ ('98831F3A:E:11','110.654317776666555545',vbal1,'a'),
  90. ('98831F3A:E:12','1.23456','99.99895'),
  91. (burn_addr + '\s+Non-MMGen',amt2,amt1)],
  92. '6': [ ('98831F3A:E:11','110.654317776666555545',vbal1,'a'),
  93. ('98831F3A:E:12','0',vbal2),
  94. ('98831F3A:E:13','1.23456','0'),
  95. (burn_addr + '\s+Non-MMGen',amt2,amt1)]
  96. }
  97. token_bals_getbalance = {
  98. '1': (vbal4,'999999.12345689012345678'),
  99. '2': ('111.888877776666555545','888.111122223333444455')
  100. }
  101. from test.test_py_d.ts_base import *
  102. from test.test_py_d.ts_shared import *
  103. class TestSuiteEthdev(TestSuiteBase,TestSuiteShared):
  104. 'Ethereum transacting, token deployment and tracking wallet operations'
  105. networks = ('eth','etc')
  106. passthru_opts = ('coin',)
  107. tmpdir_nums = [22]
  108. cmd_group = (
  109. ('setup', 'Ethereum Parity dev mode tests for coin {} (start parity)'.format(g.coin)),
  110. ('addrgen', 'generating addresses'),
  111. ('addrimport', 'importing addresses'),
  112. ('addrimport_dev_addr', "importing Parity dev address 'Ox00a329c..'"),
  113. ('txcreate1', 'creating a transaction (spend from dev address to address :1)'),
  114. ('txsign1', 'signing the transaction'),
  115. ('txsign1_ni', 'signing the transaction (non-interactive)'),
  116. ('txsend1', 'sending the transaction'),
  117. ('bal1', 'the {} balance'.format(g.coin)),
  118. ('txcreate2', 'creating a transaction (spend from dev address to address :11)'),
  119. ('txsign2', 'signing the transaction'),
  120. ('txsend2', 'sending the transaction'),
  121. ('bal2', 'the {} balance'.format(g.coin)),
  122. ('txcreate3', 'creating a transaction (spend from dev address to address :21)'),
  123. ('txsign3', 'signing the transaction'),
  124. ('txsend3', 'sending the transaction'),
  125. ('bal3', 'the {} balance'.format(g.coin)),
  126. ('tx_status1', 'getting the transaction status'),
  127. ('txcreate4', 'creating a transaction (spend from MMGen address, low TX fee)'),
  128. ('txbump', 'bumping the transaction fee'),
  129. ('txsign4', 'signing the transaction'),
  130. ('txsend4', 'sending the transaction'),
  131. ('bal4', 'the {} balance'.format(g.coin)),
  132. ('txcreate5', 'creating a transaction (fund burn address)'),
  133. ('txsign5', 'signing the transaction'),
  134. ('txsend5', 'sending the transaction'),
  135. ('addrimport_burn_addr',"importing burn address"),
  136. ('bal5', 'the {} balance'.format(g.coin)),
  137. ('add_label', 'adding a UTF-8 label'),
  138. ('chk_label', 'the label'),
  139. ('remove_label', 'removing the label'),
  140. ('token_compile1', 'compiling ERC20 token #1'),
  141. ('token_deploy1a', 'deploying ERC20 token #1 (SafeMath)'),
  142. ('token_deploy1b', 'deploying ERC20 token #1 (Owned)'),
  143. ('token_deploy1c', 'deploying ERC20 token #1 (Token)'),
  144. ('tx_status2', 'getting the transaction status'),
  145. ('bal6', 'the {} balance'.format(g.coin)),
  146. ('token_compile2', 'compiling ERC20 token #2'),
  147. ('token_deploy2a', 'deploying ERC20 token #2 (SafeMath)'),
  148. ('token_deploy2b', 'deploying ERC20 token #2 (Owned)'),
  149. ('token_deploy2c', 'deploying ERC20 token #2 (Token)'),
  150. ('contract_deploy', 'deploying contract (create,sign,send)'),
  151. ('token_fund_users', 'transferring token funds from dev to user'),
  152. ('token_user_bals', 'show balances after transfer'),
  153. ('token_addrgen', 'generating token addresses'),
  154. ('token_addrimport_badaddr1','importing token addresses (no token address)'),
  155. ('token_addrimport_badaddr2','importing token addresses (bad token address)'),
  156. ('token_addrimport', 'importing token addresses'),
  157. ('bal7', 'the {} balance'.format(g.coin)),
  158. ('token_bal1', 'the {} balance and token balance'.format(g.coin)),
  159. ('token_txcreate1', 'creating a token transaction'),
  160. ('token_txsign1', 'signing the transaction'),
  161. ('token_txsend1', 'sending the transaction'),
  162. ('token_bal2', 'the {} balance and token balance'.format(g.coin)),
  163. ('token_txcreate2', 'creating a token transaction (to burn address)'),
  164. ('token_txbump', 'bumping the transaction fee'),
  165. ('token_txsign2', 'signing the transaction'),
  166. ('token_txsend2', 'sending the transaction'),
  167. ('token_bal3', 'the {} balance and token balance'.format(g.coin)),
  168. ('del_dev_addr', "deleting the dev address"),
  169. ('bal1_getbalance', 'the {} balance (getbalance)'.format(g.coin)),
  170. ('addrimport_token_burn_addr',"importing the token burn address"),
  171. ('token_bal4', 'the {} balance and token balance'.format(g.coin)),
  172. ('token_bal_getbalance','the token balance (getbalance)'),
  173. ('txcreate_noamt', 'creating a transaction (full amount send)'),
  174. ('txsign_noamt', 'signing the transaction'),
  175. ('txsend_noamt', 'sending the transaction'),
  176. ('bal8', 'the {} balance'.format(g.coin)),
  177. ('token_bal5', 'the token balance'),
  178. ('token_txcreate_noamt', 'creating a token transaction (full amount send)'),
  179. ('token_txsign_noamt', 'signing the transaction'),
  180. ('token_txsend_noamt', 'sending the transaction'),
  181. ('bal9', 'the {} balance'.format(g.coin)),
  182. ('token_bal6', 'the token balance'),
  183. ('listaddresses1', 'listaddresses'),
  184. ('listaddresses2', 'listaddresses minconf=999999999 (ignored)'),
  185. ('listaddresses3', 'listaddresses sort=age (ignored)'),
  186. ('listaddresses4', 'listaddresses showempty=1 sort=age (ignored)'),
  187. ('token_listaddresses1','listaddresses --token=mm1'),
  188. ('token_listaddresses2','listaddresses --token=mm1 showempty=1'),
  189. ('twview1','twview'),
  190. ('twview2','twview wide=1'),
  191. ('twview3','twview wide=1 sort=age (ignored)'),
  192. ('twview4','twview wide=1 minconf=999999999 (ignored)'),
  193. ('twview5','twview wide=1 minconf=0 (ignored)'),
  194. ('twview6','twview age_fmt=days (ignored)'),
  195. ('token_twview1','twview --token=mm1'),
  196. ('token_twview2','twview --token=mm1 wide=1'),
  197. ('token_twview3','twview --token=mm1 wide=1 sort=age (ignored)'),
  198. ('edit_label1','adding label to addr #{} in {} tracking wallet'.format(del_addrs[0],g.coin)),
  199. ('edit_label2','adding label to addr #{} in {} tracking wallet'.format(del_addrs[1],g.coin)),
  200. ('edit_label3','removing label from addr #{} in {} tracking wallet'.format(del_addrs[0],g.coin)),
  201. ('remove_addr1','removing addr #{} from {} tracking wallet'.format(del_addrs[0],g.coin)),
  202. ('remove_addr2','removing addr #{} from {} tracking wallet'.format(del_addrs[1],g.coin)),
  203. ('remove_token_addr1','removing addr #{} from {} token tracking wallet'.format(del_addrs[0],g.coin)),
  204. ('remove_token_addr2','removing addr #{} from {} token tracking wallet'.format(del_addrs[1],g.coin)),
  205. ('stop', 'stopping parity'),
  206. )
  207. @property
  208. def eth_args(self):
  209. return ['--outdir={}'.format(self.tmpdir),'--coin='+g.coin,'--rpc-port=8549','--quiet']
  210. def setup(self):
  211. self.spawn('',msg_only=True)
  212. os.environ['MMGEN_BOGUS_WALLET_DATA'] = ''
  213. if subprocess.call(['which','parity'],stdout=subprocess.PIPE) == 0:
  214. lf_arg = '--log-file=' + joinpath(self.tr.data_dir,'parity.log')
  215. ss = 'parity.*--log-file=test/data_dir.*/parity.log' # allow for UTF8_DEBUG
  216. try:
  217. pid = subprocess.check_output(['pgrep','-af',ss]).split()[0]
  218. os.kill(int(pid),9)
  219. except: pass
  220. # '--base-path' doesn't work together with daemon mode, so we have to clobber the main dev chain
  221. dc_dir = joinpath(os.environ['HOME'],'.local/share/io.parity.ethereum/chains/DevelopmentChain')
  222. shutil.rmtree(dc_dir,ignore_errors=True)
  223. bdir = joinpath(self.tr.data_dir,'parity')
  224. try: os.mkdir(bdir)
  225. except: pass
  226. opts = ['--ports-shift=4','--config=dev']
  227. redir = None if opt.exact_output else subprocess.PIPE
  228. pidfile = joinpath(self.tmpdir,parity_pid_fn)
  229. subprocess.check_call(['parity',lf_arg] + opts + ['daemon',pidfile],stderr=redir,stdout=redir)
  230. time.sleep(3) # race condition
  231. pid = self.read_from_tmpfile(parity_pid_fn)
  232. elif subprocess.call('netstat -tnl | grep -q 127.0.0.1:8549',shell=True) == 0:
  233. m1 = 'No parity executable found on system, but port 8549 is active!'
  234. m2 = 'Before continuing, you should probably run the command'
  235. m3 = 'test/test.py -X setup ethdev'
  236. m4 = 'on the remote host.'
  237. sys.stderr.write('{}\n{}\n{} {}\n'.format(m1,m2,cyan(m3),m4))
  238. confirm_continue()
  239. else:
  240. die(1,'No parity executable found!')
  241. return 'ok'
  242. def addrgen(self,addrs='1-3,11-13,21-23'):
  243. from mmgen.addr import MMGenAddrType
  244. t = self.spawn('mmgen-addrgen', self.eth_args + [dfl_words_file,addrs])
  245. t.written_to_file('Addresses')
  246. t.read()
  247. return t
  248. def addrimport(self,ext='21-23]{}.addrs',expect='9/9',add_args=[],bad_input=False):
  249. ext = ext.format('-α' if g.debug_utf8 else '')
  250. fn = self.get_file_with_ext(ext,no_dot=True,delete=False)
  251. t = self.spawn('mmgen-addrimport', self.eth_args[1:] + add_args + [fn])
  252. if bad_input:
  253. t.read()
  254. t.req_exit_val = 2
  255. return t
  256. if g.debug: t.expect("Type uppercase 'YES' to confirm: ",'YES\n')
  257. t.expect('Importing')
  258. t.expect(expect)
  259. t.read()
  260. return t
  261. def addrimport_one_addr(self,addr=None,extra_args=[]):
  262. t = self.spawn('mmgen-addrimport', self.eth_args[1:] + extra_args + ['--address='+addr])
  263. t.expect('OK')
  264. return t
  265. def addrimport_dev_addr(self):
  266. return self.addrimport_one_addr(addr=dfl_addr)
  267. def addrimport_burn_addr(self):
  268. return self.addrimport_one_addr(addr=burn_addr)
  269. def txcreate(self,args=[],menu=[],acct='1',non_mmgen_inputs=0,
  270. interactive_fee = '50G',
  271. eth_fee_res = None,
  272. fee_res_fs = '0.00105 {} (50 gas price in Gwei)',
  273. fee_desc = 'gas price' ):
  274. fee_res = fee_res_fs.format(g.coin)
  275. t = self.spawn('mmgen-txcreate', self.eth_args + ['-B'] + args)
  276. t.expect(r'add \[l\]abel, .*?:.','p', regex=True)
  277. t.written_to_file('Account balances listing')
  278. return self.txcreate_ui_common( t, menu=menu,
  279. input_sels_prompt = 'to spend from',
  280. inputs = acct,
  281. file_desc = 'Ethereum transaction',
  282. bad_input_sels = True,
  283. non_mmgen_inputs = non_mmgen_inputs,
  284. interactive_fee = interactive_fee,
  285. fee_res = fee_res,
  286. fee_desc = fee_desc,
  287. eth_fee_res = eth_fee_res,
  288. add_comment = ref_tx_label_jp )
  289. def txsign(self,ni=False,ext='{}.rawtx',add_args=[]):
  290. ext = ext.format('-α' if g.debug_utf8 else '')
  291. keyfile = joinpath(self.tmpdir,parity_key_fn)
  292. write_to_file(keyfile,dfl_privkey+'\n')
  293. txfile = self.get_file_with_ext(ext,no_dot=True)
  294. t = self.spawn( 'mmgen-txsign',
  295. self.eth_args
  296. + add_args
  297. + ([],['--yes'])[ni]
  298. + ['-k', keyfile, txfile, dfl_words_file] )
  299. return self.txsign_ui_common(t,ni=ni,has_label=True)
  300. def txsend(self,ni=False,bogus_send=False,ext='{}.sigtx',add_args=[]):
  301. ext = ext.format('-α' if g.debug_utf8 else '')
  302. txfile = self.get_file_with_ext(ext,no_dot=True)
  303. if not bogus_send: os.environ['MMGEN_BOGUS_SEND'] = ''
  304. t = self.spawn('mmgen-txsend', self.eth_args + add_args + [txfile])
  305. if not bogus_send: os.environ['MMGEN_BOGUS_SEND'] = '1'
  306. txid = self.txsend_ui_common(t,quiet=True,bogus_send=bogus_send,has_label=True)
  307. return t
  308. def txcreate1(self):
  309. # valid_keypresses = EthereumTwUnspentOutputs.key_mappings.keys()
  310. menu = ['a','d','r','M','D','e','m','m'] # include one invalid keypress, 'D'
  311. args = ['98831F3A:E:1,123.456']
  312. return self.txcreate(args=args,menu=menu,acct='1',non_mmgen_inputs=1)
  313. def txsign1(self): return self.txsign()
  314. def txsign1_ni(self): return self.txsign(ni=True)
  315. def txsend1(self): return self.txsend()
  316. def bal1(self): return self.bal(n='1')
  317. def txcreate2(self):
  318. args = ['98831F3A:E:11,1.234']
  319. return self.txcreate(args=args,acct='10',non_mmgen_inputs=1)
  320. def txsign2(self): return self.txsign(ni=True,ext='1.234,50000]{}.rawtx')
  321. def txsend2(self): return self.txsend(ext='1.234,50000]{}.sigtx')
  322. def bal2(self): return self.bal(n='2')
  323. def txcreate3(self):
  324. args = ['98831F3A:E:21,2.345']
  325. return self.txcreate(args=args,acct='10',non_mmgen_inputs=1)
  326. def txsign3(self): return self.txsign(ni=True,ext='2.345,50000]{}.rawtx')
  327. def txsend3(self): return self.txsend(ext='2.345,50000]{}.sigtx')
  328. def bal3(self): return self.bal(n='3')
  329. def tx_status(self,ext,expect_str):
  330. ext = ext.format('-α' if g.debug_utf8 else '')
  331. txfile = self.get_file_with_ext(ext,no_dot=True)
  332. t = self.spawn('mmgen-txsend', self.eth_args + ['--status',txfile])
  333. t.expect(expect_str)
  334. t.read()
  335. return t
  336. def tx_status1(self):
  337. return self.tx_status(ext='2.345,50000]{}.sigtx',expect_str='has 1 confirmation')
  338. def txcreate4(self):
  339. args = ['98831F3A:E:2,23.45495']
  340. interactive_fee='40G'
  341. fee_res_fs='0.00084 {} (40 gas price in Gwei)'
  342. return self.txcreate( args = args,
  343. acct = '1',
  344. non_mmgen_inputs = 0,
  345. interactive_fee = interactive_fee,
  346. fee_res_fs = fee_res_fs,
  347. eth_fee_res = True)
  348. def txbump(self,ext=',40000]{}.rawtx',fee='50G',add_args=[]):
  349. ext = ext.format('-α' if g.debug_utf8 else '')
  350. txfile = self.get_file_with_ext(ext,no_dot=True)
  351. t = self.spawn('mmgen-txbump', self.eth_args + add_args + ['--yes',txfile])
  352. t.expect('or gas price: ',fee+'\n')
  353. t.read()
  354. return t
  355. def txsign4(self): return self.txsign(ni=True,ext='.45495,50000]{}.rawtx')
  356. def txsend4(self): return self.txsend(ext='.45495,50000]{}.sigtx')
  357. def bal4(self): return self.bal(n='4')
  358. def txcreate5(self):
  359. args = [burn_addr + ','+amt1]
  360. return self.txcreate(args=args,acct='10',non_mmgen_inputs=1)
  361. def txsign5(self): return self.txsign(ni=True,ext=amt1+',50000]{}.rawtx')
  362. def txsend5(self): return self.txsend(ext=amt1+',50000]{}.sigtx')
  363. def bal5(self): return self.bal(n='5')
  364. bal_corr = Decimal('0.0000032') # gas use for token sends varies between ETH and ETC!
  365. def bal(self,n=None):
  366. t = self.spawn('mmgen-tool', self.eth_args + ['twview','wide=1'])
  367. for b in bals[n]:
  368. addr,amt,adj = b if len(b) == 3 else b + (False,)
  369. if adj and g.coin == 'ETC': amt = str(Decimal(amt) + self.bal_corr)
  370. pat = r'{}\s+{}\s'.format(addr,amt.replace('.',r'\.'))
  371. t.expect(pat,regex=True)
  372. t.read()
  373. return t
  374. def token_bal(self,n=None):
  375. t = self.spawn('mmgen-tool', self.eth_args + ['--token=mm1','twview','wide=1'])
  376. for b in token_bals[n]:
  377. addr,_amt1,_amt2,adj = b if len(b) == 4 else b + (False,)
  378. if adj and g.coin == 'ETC': _amt2 = str(Decimal(_amt2) + self.bal_corr)
  379. pat = r'{}\s+{}\s+{}\s'.format(addr,_amt1.replace('.',r'\.'),_amt2.replace('.',r'\.'))
  380. t.expect(pat,regex=True)
  381. t.read()
  382. return t
  383. def bal_getbalance(self,idx,etc_adj=False,extra_args=[]):
  384. bal1 = token_bals_getbalance[idx][0]
  385. bal2 = token_bals_getbalance[idx][1]
  386. bal1 = Decimal(bal1)
  387. if etc_adj and g.coin == 'ETC': bal1 += self.bal_corr
  388. t = self.spawn('mmgen-tool', self.eth_args + extra_args + ['getbalance'])
  389. t.expect(r'\n[0-9A-F]{8}: .* '+str(bal1),regex=True)
  390. t.expect(r'\nNon-MMGen: .* '+bal2,regex=True)
  391. total = t.expect_getend(r'\nTOTAL:\s+',regex=True).split()[0]
  392. t.read()
  393. assert Decimal(bal1) + Decimal(bal2) == Decimal(total)
  394. return t
  395. def add_label(self,addr='98831F3A:E:3',lbl=utf8_label):
  396. t = self.spawn('mmgen-tool', self.eth_args + ['add_label',addr,lbl])
  397. t.expect('Added label.*in tracking wallet',regex=True)
  398. return t
  399. def chk_label(self,addr='98831F3A:E:3',label_pat=utf8_label_pat):
  400. t = self.spawn('mmgen-tool', self.eth_args + ['listaddresses','all_labels=1'])
  401. t.expect(r'{}\s+\S{{30}}\S+\s+{}\s+'.format(addr,(label_pat or label)),regex=True)
  402. return t
  403. def remove_label(self,addr='98831F3A:E:3'):
  404. t = self.spawn('mmgen-tool', self.eth_args + ['remove_label',addr])
  405. t.expect('Removed label.*in tracking wallet',regex=True)
  406. return t
  407. def token_compile(self,token_data={}):
  408. self.spawn('',msg_only=True)
  409. cmd_args = ['--{}={}'.format(k,v) for k,v in list(token_data.items())]
  410. imsg("Compiling solidity token contract '{}' with 'solc'".format(token_data['symbol']))
  411. cmd = ['scripts/create-token.py','--coin='+g.coin,'--outdir='+self.tmpdir] + cmd_args + [dfl_addr_chk]
  412. imsg("Executing: {}".format(' '.join(cmd)))
  413. subprocess.check_output(cmd,stderr=subprocess.STDOUT)
  414. imsg("ERC20 token '{}' compiled".format(token_data['symbol']))
  415. return 'ok'
  416. def token_compile1(self):
  417. token_data = { 'name':'MMGen Token 1', 'symbol':'MM1', 'supply':10**26, 'decimals':18 }
  418. return self.token_compile(token_data)
  419. def token_compile2(self):
  420. token_data = { 'name':'MMGen Token 2', 'symbol':'MM2', 'supply':10**18, 'decimals':10 }
  421. return self.token_compile(token_data)
  422. def _rpc_init(self):
  423. g.proto.rpc_port = 8549
  424. rpc_init()
  425. def token_deploy(self,num,key,gas,mmgen_cmd='txdo',tx_fee='8G'):
  426. self._rpc_init()
  427. keyfile = joinpath(self.tmpdir,parity_key_fn)
  428. fn = joinpath(self.tmpdir,key+'.bin')
  429. os.environ['MMGEN_BOGUS_SEND'] = ''
  430. args = ['-B',
  431. '--tx-fee='+tx_fee,
  432. '--tx-gas={}'.format(gas),
  433. '--contract-data='+fn,
  434. '--inputs='+dfl_addr,
  435. '--yes' ]
  436. if mmgen_cmd == 'txdo': args += ['-k',keyfile]
  437. t = self.spawn( 'mmgen-'+mmgen_cmd, self.eth_args + args)
  438. if mmgen_cmd == 'txcreate':
  439. t.written_to_file('Ethereum transaction')
  440. ext = '[0,8000]{}.rawtx'.format('-α' if g.debug_utf8 else '')
  441. txfile = self.get_file_with_ext(ext,no_dot=True)
  442. t = self.spawn('mmgen-txsign', self.eth_args + ['--yes','-k',keyfile,txfile],no_msg=True)
  443. self.txsign_ui_common(t,ni=True)
  444. txfile = txfile.replace('.rawtx','.sigtx')
  445. t = self.spawn('mmgen-txsend', self.eth_args + [txfile],no_msg=True)
  446. os.environ['MMGEN_BOGUS_SEND'] = '1'
  447. txid = self.txsend_ui_common(t,caller=mmgen_cmd,quiet=True,bogus_send=False)
  448. addr = t.expect_getend('Contract address: ')
  449. from mmgen.altcoins.eth.tx import EthereumMMGenTX as etx
  450. assert etx.get_exec_status(txid,True) != 0,(
  451. "Contract '{}:{}' failed to execute. Aborting".format(num,key))
  452. if key == 'Token':
  453. self.write_to_tmpfile('token_addr{}'.format(num),addr+'\n')
  454. imsg('\nToken #{} ({}) deployed!'.format(num,addr))
  455. return t
  456. def token_deploy1a(self): return self.token_deploy(num=1,key='SafeMath',gas=200000)
  457. def token_deploy1b(self): return self.token_deploy(num=1,key='Owned',gas=250000)
  458. def token_deploy1c(self): return self.token_deploy(num=1,key='Token',gas=1100000,tx_fee='7G')
  459. def tx_status2(self):
  460. return self.tx_status(ext=g.coin+'[0,7000]{}.sigtx',expect_str='successfully executed')
  461. def bal6(self): return self.bal5()
  462. def token_deploy2a(self): return self.token_deploy(num=2,key='SafeMath',gas=200000)
  463. def token_deploy2b(self): return self.token_deploy(num=2,key='Owned',gas=250000)
  464. def token_deploy2c(self): return self.token_deploy(num=2,key='Token',gas=1100000)
  465. def contract_deploy(self): # test create,sign,send
  466. return self.token_deploy(num=2,key='SafeMath',gas=1100000,mmgen_cmd='txcreate')
  467. def token_transfer_ops(self,op,amt=1000):
  468. self.spawn('',msg_only=True)
  469. sid = dfl_sid
  470. from mmgen.tool import MMGenToolCmd
  471. usr_mmaddrs = ['{}:E:{}'.format(sid,i) for i in (11,21)]
  472. usr_addrs = [MMGenToolCmd().gen_addr(addr,dfl_words_file) for addr in usr_mmaddrs]
  473. self._rpc_init()
  474. from mmgen.altcoins.eth.contract import Token
  475. from mmgen.altcoins.eth.tx import EthereumMMGenTX as etx
  476. def do_transfer():
  477. for i in range(2):
  478. tk = Token(self.read_from_tmpfile('token_addr{}'.format(i+1)).strip())
  479. imsg_r('\n'+tk.info())
  480. imsg('dev token balance (pre-send): {}'.format(tk.balance(dfl_addr)))
  481. imsg('Sending {} {} to address {} ({})'.format(amt,g.coin,usr_addrs[i],usr_mmaddrs[i]))
  482. from mmgen.obj import ETHAmt
  483. txid = tk.transfer( dfl_addr, usr_addrs[i], amt, dfl_privkey,
  484. start_gas = ETHAmt(60000,'wei'),
  485. gasPrice = ETHAmt(8,'Gwei') )
  486. assert etx.get_exec_status(txid,True) != 0,'Transfer of token funds failed. Aborting'
  487. def show_bals():
  488. for i in range(2):
  489. tk = Token(self.read_from_tmpfile('token_addr{}'.format(i+1)).strip())
  490. imsg('Token: {}'.format(tk.symbol()))
  491. imsg('dev token balance: {}'.format(tk.balance(dfl_addr)))
  492. imsg('usr token balance: {} ({} {})'.format(
  493. tk.balance(usr_addrs[i]),usr_mmaddrs[i],usr_addrs[i]))
  494. silence()
  495. if op == 'show_bals': show_bals()
  496. elif op == 'do_transfer': do_transfer()
  497. end_silence()
  498. return 'ok'
  499. def token_fund_users(self):
  500. return self.token_transfer_ops(op='do_transfer')
  501. def token_user_bals(self):
  502. return self.token_transfer_ops(op='show_bals')
  503. def token_addrgen(self):
  504. self.addrgen(addrs='11-13')
  505. ok_msg()
  506. return self.addrgen(addrs='21-23')
  507. def token_addrimport_badaddr1(self):
  508. t = self.addrimport(ext='[11-13]{}.addrs',add_args=['--token=abc'],bad_input=True)
  509. t.req_exit_val = 2
  510. return t
  511. def token_addrimport_badaddr2(self):
  512. t = self.addrimport(ext='[11-13]{}.addrs',add_args=['--token='+'00deadbeef'*4],bad_input=True)
  513. t.req_exit_val = 2
  514. return t
  515. def token_addrimport(self):
  516. for n,r in ('1','11-13'),('2','21-23'):
  517. tk_addr = self.read_from_tmpfile('token_addr'+n).strip()
  518. t = self.addrimport(ext='['+r+']{}.addrs',expect='3/3',add_args=['--token='+tk_addr])
  519. t.p.wait()
  520. ok_msg()
  521. t.skip_ok = True
  522. return t
  523. def bal7(self): return self.bal5()
  524. def token_bal1(self): return self.token_bal(n='1')
  525. def token_txcreate(self,args=[],token='',inputs='1',fee='50G'):
  526. t = self.spawn('mmgen-txcreate', self.eth_args + ['--token='+token,'-B','--tx-fee='+fee] + args)
  527. return self.txcreate_ui_common( t,
  528. menu = [],
  529. inputs = inputs,
  530. input_sels_prompt = 'to spend from',
  531. file_desc = 'Ethereum token transaction',
  532. add_comment = ref_tx_label_lat_cyr_gr)
  533. def token_txsign(self,ext='',token=''):
  534. return self.txsign(ni=True,ext=ext,add_args=['--token='+token])
  535. def token_txsend(self,ext='',token=''):
  536. return self.txsend(ext=ext,add_args=['--token=mm1'])
  537. def token_txcreate1(self):
  538. return self.token_txcreate(args=['98831F3A:E:12,1.23456'],token='mm1')
  539. def token_txsign1(self):
  540. return self.token_txsign(ext='1.23456,50000]{}.rawtx',token='mm1')
  541. def token_txsend1(self):
  542. return self.token_txsend(ext='1.23456,50000]{}.sigtx',token='mm1')
  543. def token_bal2(self):
  544. return self.token_bal(n='2')
  545. def twview(self,args=[],expect_str='',tool_args=[],exit_val=0):
  546. t = self.spawn('mmgen-tool', self.eth_args + args + ['twview'] + tool_args)
  547. if expect_str:
  548. t.expect(expect_str,regex=True)
  549. t.read()
  550. t.req_exit_val = exit_val
  551. return t
  552. def token_txcreate2(self):
  553. return self.token_txcreate(args=[burn_addr+','+amt2],token='mm1')
  554. def token_txbump(self):
  555. return self.txbump(ext=amt2+',50000]{}.rawtx',fee='56G',add_args=['--token=mm1'])
  556. def token_txsign2(self):
  557. return self.token_txsign(ext=amt2+',50000]{}.rawtx',token='mm1')
  558. def token_txsend2(self):
  559. return self.token_txsend(ext=amt2+',50000]{}.sigtx',token='mm1')
  560. def token_bal3(self):
  561. return self.token_bal(n='3')
  562. def del_dev_addr(self):
  563. t = self.spawn('mmgen-tool', self.eth_args + ['remove_address',dfl_addr])
  564. t.read() # TODO
  565. return t
  566. def bal1_getbalance(self):
  567. return self.bal_getbalance('1',etc_adj=True)
  568. def addrimport_token_burn_addr(self):
  569. return self.addrimport_one_addr(addr=burn_addr,extra_args=['--token=mm1'])
  570. def token_bal4(self):
  571. return self.token_bal(n='4')
  572. def token_bal_getbalance(self):
  573. return self.bal_getbalance('2',extra_args=['--token=mm1'])
  574. def txcreate_noamt(self):
  575. return self.txcreate(args=['98831F3A:E:12'],eth_fee_res=True)
  576. def txsign_noamt(self):
  577. return self.txsign(ext='99.99895,50000]{}.rawtx')
  578. def txsend_noamt(self):
  579. return self.txsend(ext='99.99895,50000]{}.sigtx')
  580. def bal8(self): return self.bal(n='8')
  581. def token_bal5(self): return self.token_bal(n='5')
  582. def token_txcreate_noamt(self):
  583. return self.token_txcreate(args=['98831F3A:E:13'],token='mm1',inputs='2',fee='51G')
  584. def token_txsign_noamt(self):
  585. return self.token_txsign(ext='1.23456,51000]{}.rawtx',token='mm1')
  586. def token_txsend_noamt(self):
  587. return self.token_txsend(ext='1.23456,51000]{}.sigtx',token='mm1')
  588. def bal9(self): return self.bal(n='9')
  589. def token_bal6(self): return self.token_bal(n='6')
  590. def listaddresses(self,args=[],tool_args=['all_labels=1'],exit_val=0):
  591. t = self.spawn('mmgen-tool', self.eth_args + args + ['listaddresses'] + tool_args)
  592. t.read()
  593. t.req_exit_val = exit_val
  594. return t
  595. def listaddresses1(self):
  596. return self.listaddresses()
  597. def listaddresses2(self):
  598. return self.listaddresses(tool_args=['minconf=999999999'])
  599. def listaddresses3(self):
  600. return self.listaddresses(tool_args=['sort=age'])
  601. def listaddresses4(self):
  602. return self.listaddresses(tool_args=['sort=age','showempty=1'])
  603. def token_listaddresses1(self):
  604. return self.listaddresses(args=['--token=mm1'])
  605. def token_listaddresses2(self):
  606. return self.listaddresses(args=['--token=mm1'],tool_args=['showempty=1'])
  607. def twview1(self):
  608. return self.twview()
  609. def twview2(self):
  610. return self.twview(tool_args=['wide=1'])
  611. def twview3(self):
  612. return self.twview(tool_args=['wide=1','sort=age'])
  613. def twview4(self):
  614. return self.twview(tool_args=['wide=1','minconf=999999999'])
  615. def twview5(self):
  616. return self.twview(tool_args=['wide=1','minconf=0'])
  617. def twview6(self):
  618. return self.twview(tool_args=['age_fmt=days'])
  619. def token_twview1(self):
  620. return self.twview(args=['--token=mm1'])
  621. def token_twview2(self):
  622. return self.twview(args=['--token=mm1'],tool_args=['wide=1'])
  623. def token_twview3(self):
  624. return self.twview(args=['--token=mm1'],tool_args=['wide=1','sort=age'])
  625. def edit_label(self,out_num,args=[],action='l',label_text=None):
  626. t = self.spawn('mmgen-txcreate', self.eth_args + args + ['-B','-i'])
  627. p1,p2 = ('emove address:\b','return to main menu): ')
  628. p3,r3 = (p2,label_text+'\n') if label_text is not None else ('(y/N): ','y')
  629. p4,r4 = (('(y/N): ',),('y',)) if label_text == '' else ((),())
  630. for p,r in zip((p1,p1,p2,p3)+p4+(p1,p1),('M',action,out_num+'\n',r3)+r4+('M','q')):
  631. t.expect(p,r)
  632. return t
  633. def edit_label1(self):
  634. return self.edit_label(out_num=del_addrs[0],label_text='First added label-α')
  635. def edit_label2(self):
  636. return self.edit_label(out_num=del_addrs[1],label_text='Second added label')
  637. def edit_label3(self):
  638. return self.edit_label(out_num=del_addrs[0],label_text='')
  639. def remove_addr1(self):
  640. return self.edit_label(out_num=del_addrs[0],action='R')
  641. def remove_addr2(self):
  642. return self.edit_label(out_num=del_addrs[1],action='R')
  643. def remove_token_addr1(self):
  644. return self.edit_label(out_num=del_addrs[0],args=['--token=mm1'],action='R')
  645. def remove_token_addr2(self):
  646. return self.edit_label(out_num=del_addrs[1],args=['--token=mm1'],action='R')
  647. def stop(self):
  648. self.spawn('',msg_only=True)
  649. if subprocess.call(['which','parity'],stdout=subprocess.PIPE) == 0:
  650. pid = self.read_from_tmpfile(parity_pid_fn)
  651. if opt.no_daemon_stop:
  652. msg_r('(leaving daemon running by user request)')
  653. else:
  654. subprocess.check_call(['kill',pid])
  655. else:
  656. imsg('No parity executable found on system. Ignoring')
  657. return 'ok'