ts_ethdev.py 31 KB

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