|
@@ -1,133 +0,0 @@
|
|
|
-#!/usr/bin/env python3
|
|
|
-# Convert MMGen 'v1' transaction file (extension '.raw' or '.sig')
|
|
|
-# to MMGen 'v3' ('.rawtx' or '.sigtx' + amounts as strings)
|
|
|
-
|
|
|
-import sys,os
|
|
|
-repo_root = os.path.split(os.path.abspath(os.path.dirname(sys.argv[0])))[0]
|
|
|
-sys.path = [repo_root] + sys.path
|
|
|
-
|
|
|
-from mmgen.common import *
|
|
|
-
|
|
|
-opts_data = lambda: {
|
|
|
- 'desc': "Convert MMGen transaction file from v1 format to v3 format",
|
|
|
- 'usage': "<tx file>",
|
|
|
- 'options': """
|
|
|
--h, --help Print this help message
|
|
|
--d, --outdir=d Output files to directory 'd' instead of working dir
|
|
|
--q, --quiet Write (and overwrite) files without prompting
|
|
|
--S, --stdout Write data to STDOUT instead of file
|
|
|
-"""
|
|
|
-}
|
|
|
-
|
|
|
-cmd_args = opts.init(opts_data)
|
|
|
-
|
|
|
-from mmgen.tx import *
|
|
|
-
|
|
|
-if len(cmd_args) != 1: opts.usage()
|
|
|
-def parse_tx_file(infile):
|
|
|
- from ast import literal_eval
|
|
|
-
|
|
|
- def eval_io_data(raw_data,desc):
|
|
|
- import re
|
|
|
- d = literal_eval(re.sub(r"[A-Za-z]+?\(('.+?')\)",r'\1',raw_data))
|
|
|
- assert type(d) == list,'{} data not a list!'.format(desc)
|
|
|
- assert len(d),'no {}!'.format(desc)
|
|
|
- for e in d: e['amount'] = g.proto.coin_amt(e['amount'])
|
|
|
- return d
|
|
|
-
|
|
|
- err_fmt = 'Invalid {} in transaction file'
|
|
|
- tx_data = get_lines_from_file(infile)
|
|
|
-
|
|
|
- try:
|
|
|
- err_str = 'number of lines'
|
|
|
- assert len(tx_data) in (4,5)
|
|
|
- if len(tx_data) == 5:
|
|
|
- metadata,tx_hex,inputs,outputs,comment = tx_data
|
|
|
- elif len(tx_data) == 4:
|
|
|
- metadata,tx_hex,inputs,outputs = tx_data
|
|
|
- comment = ''
|
|
|
- err_str = 'metadata'
|
|
|
- assert len(metadata.split()) == 3
|
|
|
- err_str = 'hex data'
|
|
|
- unhexlify(tx_hex)
|
|
|
- err_str = 'inputs data'
|
|
|
- inputs = eval_io_data(inputs,'inputs')
|
|
|
- err_str = 'btc-to-mmgen address map data'
|
|
|
- outputs = literal_eval(outputs)
|
|
|
- if comment:
|
|
|
- from mmgen.bitcoin import b58decode
|
|
|
- comment = b58decode(comment)
|
|
|
- if comment == False:
|
|
|
- err_str = 'encoded comment (not base58)'
|
|
|
- else:
|
|
|
- err_str = 'comment'
|
|
|
- comment = MMGenTXLabel(comment)
|
|
|
- except:
|
|
|
- die(2,err_fmt.format(err_str))
|
|
|
- else:
|
|
|
- return metadata.split(),tx_hex,inputs,outputs,comment
|
|
|
-
|
|
|
-def find_block_by_time(timestamp):
|
|
|
- secs = decode_timestamp(timestamp)
|
|
|
- block_num = g.rpch.getblockcount()
|
|
|
-# print 'secs:',secs, 'last block:',last_block
|
|
|
- top,bot = block_num,0
|
|
|
- m = 'Searching for block'
|
|
|
- msg_r(m)
|
|
|
- for i in range(40):
|
|
|
- msg_r('.')
|
|
|
- bhash = g.rpch.getblockhash(block_num)
|
|
|
- block = g.rpch.getblock(bhash)
|
|
|
-# print 'block_num:',block_num, 'mediantime:',block['mediantime'], 'target:',secs
|
|
|
- cur_secs = block['mediantime']
|
|
|
- if cur_secs > secs:
|
|
|
- top = block_num
|
|
|
- else:
|
|
|
- bot = block_num
|
|
|
- block_num = (top + bot) // 2
|
|
|
- if top - bot < 2:
|
|
|
- msg('\nFound: {} '.format(block_num))
|
|
|
- break
|
|
|
-
|
|
|
- return block_num
|
|
|
-
|
|
|
-tx = MMGenTX()
|
|
|
-
|
|
|
-metadata,tx.hex,inputs,outputs,tx.label = parse_tx_file(cmd_args[0])
|
|
|
-tx.txid,send_amt,tx.timestamp = metadata
|
|
|
-tx.send_amt = Decimal(send_amt)
|
|
|
-
|
|
|
-g.testnet = False
|
|
|
-g.rpc_host = 'localhost'
|
|
|
-rpc_init()
|
|
|
-
|
|
|
-for i in inputs:
|
|
|
- if not 'mmid' in i and 'account' in i:
|
|
|
- lbl = TwLabel(i['account'])
|
|
|
- i['mmid'] = lbl.mmid
|
|
|
- i['comment'] = lbl.comment
|
|
|
-
|
|
|
-tx.inputs = tx.MMGenTxInputList(tx.decode_io_oldfmt(inputs))
|
|
|
-
|
|
|
-if tx.marked_signed():
|
|
|
- msg('Transaction is signed')
|
|
|
-
|
|
|
-dec_tx = g.rpch.decoderawtransaction(tx.hex)
|
|
|
-tx.outputs = tx.MMGenTxOutputList(
|
|
|
- MMGenTX.MMGenTxOutput(addr=i['scriptPubKey']['addresses'][0],
|
|
|
- amt=g.proto.coin_amt(i['value']))
|
|
|
- for i in dec_tx['vout'])
|
|
|
-
|
|
|
-for e in tx.outputs:
|
|
|
- if e.addr in outputs:
|
|
|
- f = outputs[e.addr]
|
|
|
- e.mmid = f[0]
|
|
|
- if f[1]: e.label = f[1].decode('utf8')
|
|
|
- else:
|
|
|
- for f in tx.inputs:
|
|
|
- if e.addr == f.addr and f.mmid:
|
|
|
- e.mmid = f.mmid
|
|
|
- if f.label: e.label = f.label.decode('utf8')
|
|
|
-
|
|
|
-tx.blockcount = find_block_by_time(tx.timestamp)
|
|
|
-tx.write_to_file(ask_tty=False,ask_overwrite=not opt.quiet,ask_write=not opt.quiet)
|