tx-old2new.py 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137
  1. #!/usr/bin/env python
  2. import sys,os
  3. repo_root = os.path.split(os.path.abspath(os.path.dirname(sys.argv[0])))[0]
  4. sys.path = [repo_root] + sys.path
  5. from mmgen.common import *
  6. from mmgen.tool import *
  7. from mmgen.tx import *
  8. from mmgen.bitcoin import *
  9. from mmgen.obj import MMGenTXLabel
  10. from mmgen.seed import *
  11. from mmgen.term import do_pager
  12. help_data = {
  13. 'desc': "Convert MMGen transaction file from old format to new format",
  14. 'usage': "<tx file>",
  15. 'options': """
  16. -h, --help Print this help message
  17. """
  18. }
  19. import mmgen.opts
  20. cmd_args = opts.init(help_data)
  21. if len(cmd_args) != 1: opts.usage()
  22. def parse_tx_file(infile):
  23. err_str,err_fmt = '','Invalid %s in transaction file'
  24. tx_data = get_lines_from_file(infile)
  25. if len(tx_data) == 5:
  26. metadata,tx_hex,inputs_data,outputs_data,comment = tx_data
  27. elif len(tx_data) == 4:
  28. metadata,tx_hex,inputs_data,outputs_data = tx_data
  29. comment = ''
  30. else:
  31. err_str = 'number of lines'
  32. if not err_str:
  33. if len(metadata.split()) != 3:
  34. err_str = 'metadata'
  35. else:
  36. try: unhexlify(tx_hex)
  37. except: err_str = 'hex data'
  38. else:
  39. try: inputs_data = eval(inputs_data)
  40. except: err_str = 'inputs data'
  41. else:
  42. try: outputs_data = eval(outputs_data)
  43. except: err_str = 'btc-to-mmgen address map data'
  44. else:
  45. if comment:
  46. from mmgen.bitcoin import b58decode
  47. comment = b58decode(comment)
  48. if comment == False:
  49. err_str = 'encoded comment (not base58)'
  50. else:
  51. try:
  52. comment = MMGenTXLabel(comment)
  53. except:
  54. err_str = 'comment'
  55. if err_str:
  56. msg(err_fmt % err_str)
  57. sys.exit(2)
  58. else:
  59. return metadata.split(),tx_hex,inputs_data,outputs_data,comment
  60. def find_block_by_time(c,timestamp):
  61. secs = decode_timestamp(timestamp)
  62. block_num = c.getblockcount()
  63. # print 'secs:',secs, 'last block:',last_block
  64. top,bot = block_num,0
  65. m = 'Searching for block'
  66. msg_r(m)
  67. for i in range(40):
  68. msg_r('.')
  69. bhash = c.getblockhash(block_num)
  70. block = c.getblock(bhash)
  71. # print 'block_num:',block_num, 'mediantime:',block['mediantime'], 'target:',secs
  72. cur_secs = block['mediantime']
  73. if cur_secs > secs:
  74. top = block_num
  75. else:
  76. bot = block_num
  77. block_num = (top + bot) / 2
  78. if top - bot < 2:
  79. msg('\nFound: %s ' % block_num)
  80. break
  81. return block_num
  82. tx = MMGenTX()
  83. [tx.txid,send_amt,tx.timestamp],tx.hex,inputs,b2m_map,tx.label = parse_tx_file(cmd_args[0])
  84. tx.send_amt = Decimal(send_amt)
  85. c = bitcoin_connection()
  86. # attrs = 'txid','vout','amt','comment','mmid','addr','wif'
  87. #pp_msg(inputs)
  88. for i in inputs:
  89. if not 'mmid' in i and 'account' in i:
  90. from mmgen.tw import parse_tw_acct_label
  91. a,b = parse_tw_acct_label(i['account'])
  92. if a:
  93. i['mmid'] = a.decode('utf8')
  94. if b: i['comment'] = b.decode('utf8')
  95. #pp_msg(inputs)
  96. tx.inputs = tx.decode_io_oldfmt(inputs)
  97. if tx.check_signed(c):
  98. msg('Transaction is signed')
  99. dec_tx = c.decoderawtransaction(tx.hex)
  100. tx.outputs = [MMGenTxOutput(addr=i['scriptPubKey']['addresses'][0],amt=i['value'])
  101. for i in dec_tx['vout']]
  102. for e in tx.outputs:
  103. if e.addr in b2m_map:
  104. f = b2m_map[e.addr]
  105. e.mmid = f[0]
  106. if f[1]: e.label = f[1].decode('utf8')
  107. else:
  108. for f in tx.inputs:
  109. if e.addr == f.addr and f.mmid:
  110. e.mmid = f.mmid
  111. if f.label: e.label = f.label.decode('utf8')
  112. #for i in tx.inputs: print i
  113. #for i in tx.outputs: print i
  114. #die(1,'')
  115. tx.blockcount = find_block_by_time(c,tx.timestamp)
  116. tx.write_to_file(ask_write=False)