2012-01-19 08:11:36 -08:00
#!/usr/bin/env python
#
# Electrum - lightweight Bitcoin client
# Copyright (C) 2011 thomasv@gitorious
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
2012-08-23 18:21:17 -07:00
import sys
import base64
import os
import re
import hashlib
import copy
import operator
import ast
import threading
import random
import aes
2012-10-20 17:57:31 -07:00
import Queue
2012-10-22 08:18:07 -07:00
import time
2012-01-19 08:11:36 -08:00
2013-02-23 02:35:46 -08:00
from util import print_msg , print_error , user_dir , format_satoshis
2012-10-19 05:55:01 -07:00
from bitcoin import *
2012-07-06 21:45:57 -07:00
2012-02-14 03:45:39 -08:00
# URL decode
_ud = re . compile ( ' % ([0-9a-hA-H] {2} ) ' , re . MULTILINE )
urldecode = lambda x : _ud . sub ( lambda m : chr ( int ( m . group ( 1 ) , 16 ) ) , x )
2012-10-19 05:55:01 -07:00
# AES encryption
2012-01-19 08:11:36 -08:00
EncodeAES = lambda secret , s : base64 . b64encode ( aes . encryptData ( secret , s ) )
DecodeAES = lambda secret , e : aes . decryptData ( secret , base64 . b64decode ( e ) )
2013-02-23 02:35:46 -08:00
def pw_encode ( s , password ) :
if password :
secret = Hash ( password )
return EncodeAES ( secret , s )
else :
return s
def pw_decode ( s , password ) :
if password is not None :
secret = Hash ( password )
try :
d = DecodeAES ( secret , s )
except :
raise BaseException ( ' Invalid password ' )
return d
else :
return s
2012-01-19 08:11:36 -08:00
2012-02-05 22:48:52 -08:00
from version import ELECTRUM_VERSION , SEED_VERSION
2012-01-19 08:11:36 -08:00
class Wallet :
2012-10-11 11:10:12 -07:00
def __init__ ( self , config = { } ) :
2012-01-19 08:11:36 -08:00
2012-10-11 11:10:12 -07:00
self . config = config
2012-01-19 08:11:36 -08:00
self . electrum_version = ELECTRUM_VERSION
2013-01-29 05:53:13 -08:00
self . gap_limit_for_change = 3 # constant
2012-01-19 08:11:36 -08:00
# saved fields
2012-10-11 11:10:12 -07:00
self . seed_version = config . get ( ' seed_version ' , SEED_VERSION )
self . gap_limit = config . get ( ' gap_limit ' , 5 )
self . use_change = config . get ( ' use_change ' , True )
self . fee = int ( config . get ( ' fee ' , 100000 ) )
self . num_zeros = int ( config . get ( ' num_zeros ' , 0 ) )
self . use_encryption = config . get ( ' use_encryption ' , False )
self . addresses = config . get ( ' addresses ' , [ ] ) # receiving addresses visible for user
self . change_addresses = config . get ( ' change_addresses ' , [ ] ) # addresses used as change
self . seed = config . get ( ' seed ' , ' ' ) # encrypted
2013-01-23 23:11:48 -08:00
self . labels = config . get ( ' labels ' , { } )
2012-10-11 11:10:12 -07:00
self . aliases = config . get ( ' aliases ' , { } ) # aliases for addresses
self . authorities = config . get ( ' authorities ' , { } ) # trusted addresses
self . frozen_addresses = config . get ( ' frozen_addresses ' , [ ] )
self . prioritized_addresses = config . get ( ' prioritized_addresses ' , [ ] )
self . receipts = config . get ( ' receipts ' , { } ) # signed URIs
2013-01-23 23:11:48 -08:00
self . addressbook = config . get ( ' contacts ' , [ ] )
2012-10-11 11:10:12 -07:00
self . imported_keys = config . get ( ' imported_keys ' , { } )
2012-11-04 06:47:19 -08:00
self . history = config . get ( ' addr_history ' , { } ) # address -> list(txid, height)
2013-02-22 10:22:22 -08:00
self . tx_height = config . get ( ' tx_height ' , { } )
2012-01-19 08:11:36 -08:00
2013-02-23 02:35:46 -08:00
master_public_key = config . get ( ' master_public_key ' , ' ' )
self . sequence = DeterministicSequence ( master_public_key )
2013-02-22 10:22:22 -08:00
self . transactions = { }
tx = config . get ( ' transactions ' , { } )
try :
for k , v in tx . items ( ) : self . transactions [ k ] = Transaction ( v )
except :
print_msg ( " Warning: Cannot deserialize transactions. skipping " )
self . requested_amounts = config . get ( ' requested_amounts ' , { } )
2012-11-28 06:38:44 -08:00
2012-01-19 08:11:36 -08:00
# not saved
2012-11-16 05:39:31 -08:00
self . prevout_values = { } # my own transaction outputs
2012-11-03 01:17:40 -07:00
self . spent_outputs = [ ]
2012-10-11 11:10:12 -07:00
self . receipt = None # next receipt
2012-03-23 08:34:34 -07:00
self . banner = ' '
2012-05-04 02:14:07 -07:00
2012-10-26 01:02:09 -07:00
# spv
self . verifier = None
2012-10-14 22:43:00 -07:00
# there is a difference between wallet.up_to_date and interface.is_up_to_date()
# interface.is_up_to_date() returns true when all requests have been answered and processed
# wallet.up_to_date is true when the wallet is synchronized (stronger requirement)
2012-11-20 12:36:06 -08:00
2012-03-28 05:22:46 -07:00
self . up_to_date = False
2012-03-31 02:47:16 -07:00
self . lock = threading . Lock ( )
2012-03-24 05:15:23 -07:00
self . tx_event = threading . Event ( )
2012-03-23 08:34:34 -07:00
2012-10-11 11:10:12 -07:00
if self . seed_version != SEED_VERSION :
raise ValueError ( " This wallet seed is deprecated. Please run upgrade.py for a diagnostic. " )
2012-11-03 01:17:40 -07:00
for tx_hash in self . transactions . keys ( ) :
self . update_tx_outputs ( tx_hash )
2012-11-20 12:36:06 -08:00
def set_up_to_date ( self , b ) :
with self . lock : self . up_to_date = b
def is_up_to_date ( self ) :
with self . lock : return self . up_to_date
2012-04-01 08:50:12 -07:00
2012-11-22 04:10:01 -08:00
def update ( self ) :
self . up_to_date = False
self . interface . poke ( ' synchronizer ' )
2012-11-22 11:14:42 -08:00
while not self . is_up_to_date ( ) : time . sleep ( 0.1 )
2012-11-03 01:17:40 -07:00
2013-01-05 12:28:12 -08:00
def import_key ( self , sec , password ) :
2013-02-23 02:35:46 -08:00
# check password
seed = self . decode_seed ( password )
2013-02-21 07:26:26 -08:00
address = address_from_private_key ( sec )
2013-01-05 12:28:12 -08:00
if address in self . all_addresses ( ) :
raise BaseException ( ' Address already in wallet ' )
2012-12-31 01:41:02 -08:00
# store the originally requested keypair into the imported keys table
2013-02-23 02:35:46 -08:00
self . imported_keys [ address ] = pw_encode ( sec , password )
2013-01-05 12:28:12 -08:00
return address
2012-12-31 01:41:02 -08:00
2012-10-11 11:10:12 -07:00
2013-02-03 06:08:26 -08:00
def init_seed ( self , seed ) :
2013-02-03 06:12:40 -08:00
if self . seed : raise BaseException ( " a seed exists " )
2013-02-03 06:08:26 -08:00
if not seed :
2013-02-24 01:16:14 -08:00
seed = random_seed ( 128 )
2013-02-03 06:08:26 -08:00
self . seed = seed
self . config . set_key ( ' seed ' , self . seed , True )
self . config . set_key ( ' seed_version ' , self . seed_version , True )
self . init_mpk ( self . seed )
2012-01-19 08:11:36 -08:00
def init_mpk ( self , seed ) :
# public key
2013-02-23 02:35:46 -08:00
self . sequence = DeterministicSequence . from_seed ( seed )
self . config . set_key ( ' master_public_key ' , self . sequence . master_public_key , True )
2012-01-19 08:11:36 -08:00
def all_addresses ( self ) :
return self . addresses + self . change_addresses + self . imported_keys . keys ( )
def is_mine ( self , address ) :
return address in self . all_addresses ( )
def is_change ( self , address ) :
return address in self . change_addresses
def is_valid ( self , addr ) :
ADDRESS_RE = re . compile ( ' [1-9A-HJ-NP-Za-km-z] { 26,} \\ Z ' )
if not ADDRESS_RE . match ( addr ) : return False
try :
2013-01-30 11:13:31 -08:00
addrtype , h = bc_address_to_hash_160 ( addr )
2012-01-19 08:11:36 -08:00
except :
return False
2013-01-30 11:13:31 -08:00
return addr == hash_160_to_bc_address ( h , addrtype )
2012-01-19 08:11:36 -08:00
2013-02-23 02:35:46 -08:00
def get_master_public_key ( self ) :
return self . sequence . master_public_key
2013-02-25 00:05:45 -08:00
def get_address_index ( self , address ) :
2013-02-23 02:35:46 -08:00
if address in self . imported_keys . keys ( ) :
raise BaseException ( " imported key " )
if address in self . addresses :
n = self . addresses . index ( address )
for_change = False
elif address in self . change_addresses :
n = self . change_addresses . index ( address )
for_change = True
2013-02-25 00:05:45 -08:00
return n , for_change
2012-01-19 08:11:36 -08:00
2013-02-25 00:05:45 -08:00
def get_public_key ( self , address ) :
n , for_change = self . get_address_index ( address )
2013-02-23 02:35:46 -08:00
return self . sequence . get_pubkey ( n , for_change )
2012-01-19 08:11:36 -08:00
2013-02-23 02:35:46 -08:00
def decode_seed ( self , password ) :
seed = pw_decode ( self . seed , password )
self . sequence . check_seed ( seed )
return seed
2012-02-06 09:10:30 -08:00
def get_private_key ( self , address , password ) :
2013-02-22 08:27:19 -08:00
2013-02-23 02:35:46 -08:00
# decode seed in any case, in order to test the password
2013-02-22 08:27:19 -08:00
seed = self . decode_seed ( password )
2012-01-19 08:11:36 -08:00
if address in self . imported_keys . keys ( ) :
2013-02-23 02:35:46 -08:00
return pw_decode ( self . imported_keys [ address ] , password )
2012-01-19 08:11:36 -08:00
else :
if address in self . addresses :
n = self . addresses . index ( address )
for_change = False
elif address in self . change_addresses :
n = self . change_addresses . index ( address )
for_change = True
else :
2013-02-21 05:18:12 -08:00
raise BaseException ( " unknown address " , address )
2013-02-23 02:35:46 -08:00
return self . sequence . get_private_key ( n , for_change , seed )
2012-01-19 08:11:36 -08:00
2012-02-01 11:27:03 -08:00
def sign_message ( self , address , message , password ) :
2013-02-22 08:27:19 -08:00
sec = self . get_private_key ( address , password )
2013-02-22 07:17:46 -08:00
key = regenerate_key ( sec )
compressed = is_compressed ( sec )
return key . sign_message ( message , compressed , address )
2012-03-23 12:58:54 -07:00
def create_new_address ( self , for_change ) :
2012-01-19 08:11:36 -08:00
n = len ( self . change_addresses ) if for_change else len ( self . addresses )
2012-10-01 09:31:54 -07:00
address = self . get_new_address ( n , for_change )
2012-01-19 08:11:36 -08:00
if for_change :
self . change_addresses . append ( address )
else :
self . addresses . append ( address )
2012-02-21 05:36:45 -08:00
self . history [ address ] = [ ]
2012-10-01 09:31:54 -07:00
return address
def get_new_address ( self , n , for_change ) :
2013-02-23 02:35:46 -08:00
pubkey = self . sequence . get_pubkey ( n , for_change )
address = public_key_to_bc_address ( pubkey . decode ( ' hex ' ) )
print_msg ( address )
2012-02-21 05:36:45 -08:00
return address
2012-06-07 09:52:29 -07:00
def change_gap_limit ( self , value ) :
if value > = self . gap_limit :
self . gap_limit = value
self . save ( )
2012-10-26 15:02:52 -07:00
self . interface . poke ( ' synchronizer ' )
2012-06-07 09:52:29 -07:00
return True
elif value > = self . min_acceptable_gap ( ) :
k = self . num_unused_trailing_addresses ( )
n = len ( self . addresses ) - k + value
self . addresses = self . addresses [ 0 : n ]
self . gap_limit = value
self . save ( )
return True
else :
return False
def num_unused_trailing_addresses ( self ) :
k = 0
for a in self . addresses [ : : - 1 ] :
if self . history . get ( a ) : break
k = k + 1
return k
def min_acceptable_gap ( self ) :
# fixme: this assumes wallet is synchronized
n = 0
nmax = 0
k = self . num_unused_trailing_addresses ( )
for a in self . addresses [ 0 : - k ] :
if self . history . get ( a ) :
n = 0
else :
n + = 1
if n > nmax : nmax = n
2012-06-07 09:59:28 -07:00
return nmax + 1
2012-06-07 09:52:29 -07:00
2012-01-19 08:11:36 -08:00
2013-01-29 05:53:13 -08:00
def address_is_old ( self , address ) :
age = - 1
h = self . history . get ( address , [ ] )
if h == [ ' * ' ] :
return True
for tx_hash , tx_height in h :
if tx_height == 0 :
tx_age = 0
else :
tx_age = self . verifier . height - tx_height + 1
if tx_age > age :
age = tx_age
return age > 2
2012-02-22 06:39:06 -08:00
2012-01-19 08:11:36 -08:00
2013-01-29 05:53:13 -08:00
def synchronize_sequence ( self , addresses , n , for_change ) :
new_addresses = [ ]
2012-01-19 08:11:36 -08:00
while True :
if len ( self . addresses ) < n :
2013-01-29 05:53:13 -08:00
new_addresses . append ( self . create_new_address ( for_change ) )
2012-01-19 08:11:36 -08:00
continue
2013-01-29 05:53:13 -08:00
if map ( lambda a : self . address_is_old ( a ) , addresses [ - n : ] ) == n * [ False ] :
2012-01-19 08:11:36 -08:00
break
else :
2013-01-29 05:53:13 -08:00
new_addresses . append ( self . create_new_address ( for_change ) )
return new_addresses
2012-01-19 08:11:36 -08:00
2013-01-29 05:53:13 -08:00
def synchronize ( self ) :
2013-02-23 02:35:46 -08:00
if not self . sequence . master_public_key :
2013-01-29 05:53:13 -08:00
return [ ]
new_addresses = [ ]
new_addresses + = self . synchronize_sequence ( self . addresses , self . gap_limit , False )
new_addresses + = self . synchronize_sequence ( self . change_addresses , self . gap_limit_for_change , True )
2012-03-23 12:58:54 -07:00
return new_addresses
2012-02-22 06:39:06 -08:00
2012-03-23 08:34:34 -07:00
2012-01-19 08:11:36 -08:00
def is_found ( self ) :
2013-01-29 05:53:13 -08:00
return ( len ( self . change_addresses ) > self . gap_limit_for_change ) or ( len ( self . addresses ) > self . gap_limit )
2012-01-19 08:11:36 -08:00
def fill_addressbook ( self ) :
2012-11-03 01:17:40 -07:00
for tx_hash , tx in self . transactions . items ( ) :
2013-02-22 10:22:22 -08:00
is_send , _ , _ = self . get_tx_value ( tx )
2012-11-16 05:39:31 -08:00
if is_send :
2013-02-25 09:17:02 -08:00
for o in tx . outputs :
2012-11-04 11:53:27 -08:00
addr = o . get ( ' address ' )
if not self . is_mine ( addr ) and addr not in self . addressbook :
self . addressbook . append ( addr )
2012-01-19 08:11:36 -08:00
# redo labels
2012-11-04 11:53:27 -08:00
# self.update_tx_labels()
2012-01-19 08:11:36 -08:00
2012-06-07 07:14:08 -07:00
def get_address_flags ( self , addr ) :
flags = " C " if self . is_change ( addr ) else " I " if addr in self . imported_keys . keys ( ) else " - "
flags + = " F " if addr in self . frozen_addresses else " P " if addr in self . prioritized_addresses else " - "
return flags
2012-01-19 08:11:36 -08:00
2013-02-22 10:22:22 -08:00
def get_tx_value ( self , tx , addresses = None ) :
2012-11-03 01:17:40 -07:00
if addresses is None : addresses = self . all_addresses ( )
2013-02-22 10:22:22 -08:00
return tx . get_value ( addresses , self . prevout_values )
2012-11-16 05:39:31 -08:00
def get_tx_details ( self , tx_hash ) :
import datetime
if not tx_hash : return ' '
tx = self . transactions . get ( tx_hash )
2013-02-23 03:11:32 -08:00
is_mine , v , fee = self . get_tx_value ( tx )
2012-12-05 06:16:52 -08:00
conf , timestamp = self . verifier . get_confirmations ( tx_hash )
2013-02-18 12:12:39 -08:00
if timestamp :
2012-11-16 05:39:31 -08:00
time_str = datetime . datetime . fromtimestamp ( timestamp ) . isoformat ( ' ' ) [ : - 3 ]
else :
time_str = ' pending '
2013-02-23 03:11:32 -08:00
inputs = map ( lambda x : x . get ( ' address ' ) , tx . inputs )
outputs = map ( lambda x : x . get ( ' address ' ) , tx . d [ ' outputs ' ] )
2012-11-16 05:39:31 -08:00
tx_details = " Transaction Details " + " \n \n " \
+ " Transaction ID: \n " + tx_hash + " \n \n " \
+ " Status: %d confirmations \n " % conf
if is_mine :
if fee :
2012-11-23 06:35:54 -08:00
tx_details + = " Amount sent: %s \n " % format_satoshis ( v - fee , False ) \
2012-11-16 05:39:31 -08:00
+ " Transaction fee: %s \n " % format_satoshis ( fee , False )
else :
tx_details + = " Amount sent: %s \n " % format_satoshis ( v , False ) \
+ " Transaction fee: unknown \n "
else :
tx_details + = " Amount received: %s \n " % format_satoshis ( v , False ) \
2012-11-03 01:17:40 -07:00
2012-11-16 05:39:31 -08:00
tx_details + = " Date: %s \n \n " % time_str \
+ " Inputs: \n - " + ' \n - ' . join ( inputs ) + " \n \n " \
+ " Outputs: \n - " + ' \n - ' . join ( outputs )
r = self . receipts . get ( tx_hash )
if r :
tx_details + = " \n _______________________________________ " \
+ ' \n \n Signed URI: ' + r [ 2 ] \
+ " \n \n Signed by: " + r [ 0 ] \
+ ' \n \n Signature: ' + r [ 1 ]
return tx_details
2012-11-03 01:17:40 -07:00
def update_tx_outputs ( self , tx_hash ) :
tx = self . transactions . get ( tx_hash )
2013-02-22 10:22:22 -08:00
i = 0
for item in tx . outputs :
addr , value = item
key = tx_hash + ' : %d ' % i
2012-11-03 01:17:40 -07:00
with self . lock :
2013-02-22 10:22:22 -08:00
self . prevout_values [ key ] = value
i + = 1
2012-11-03 01:17:40 -07:00
2013-02-22 10:22:22 -08:00
for item in tx . inputs :
2012-11-03 01:17:40 -07:00
if self . is_mine ( item . get ( ' address ' ) ) :
key = item [ ' prevout_hash ' ] + ' : %d ' % item [ ' prevout_n ' ]
self . spent_outputs . append ( key )
2012-11-22 04:10:01 -08:00
def get_addr_balance ( self , address ) :
assert self . is_mine ( address )
h = self . history . get ( address , [ ] )
2012-11-14 06:33:44 -08:00
if h == [ ' * ' ] : return 0 , 0
2012-01-19 08:11:36 -08:00
c = u = 0
2012-12-28 08:57:33 -08:00
received_coins = [ ] # list of coins received at address
2012-11-22 04:24:44 -08:00
for tx_hash , tx_height in h :
2013-02-22 10:22:22 -08:00
tx = self . transactions . get ( tx_hash )
if not tx : continue
i = 0
for item in tx . outputs :
addr , value = item
2012-12-28 08:57:33 -08:00
if addr == address :
2013-02-22 10:22:22 -08:00
key = tx_hash + ' : %d ' % i
2012-12-28 08:57:33 -08:00
received_coins . append ( key )
2013-02-22 10:22:22 -08:00
i + = 1
2012-11-22 04:24:44 -08:00
2012-11-03 01:17:40 -07:00
for tx_hash , tx_height in h :
2013-02-22 10:22:22 -08:00
tx = self . transactions . get ( tx_hash )
if not tx : continue
2012-11-22 04:10:01 -08:00
v = 0
2013-02-22 10:22:22 -08:00
for item in tx . inputs :
2012-11-22 04:10:01 -08:00
addr = item . get ( ' address ' )
if addr == address :
key = item [ ' prevout_hash ' ] + ' : %d ' % item [ ' prevout_n ' ]
value = self . prevout_values . get ( key )
if key in received_coins :
v - = value
2013-02-22 10:22:22 -08:00
i = 0
for item in tx . outputs :
addr , value = item
key = tx_hash + ' : %d ' % i
2012-11-22 04:10:01 -08:00
if addr == address :
2013-02-22 10:22:22 -08:00
v + = value
i + = 1
2012-11-16 05:39:31 -08:00
2012-11-03 01:17:40 -07:00
if tx_height :
2012-01-19 08:11:36 -08:00
c + = v
else :
u + = v
return c , u
def get_balance ( self ) :
conf = unconf = 0
for addr in self . all_addresses ( ) :
c , u = self . get_addr_balance ( addr )
conf + = c
unconf + = u
return conf , unconf
2013-02-23 04:18:15 -08:00
def get_unspent_coins ( self , domain = None ) :
2012-01-19 08:11:36 -08:00
coins = [ ]
2013-02-23 04:18:15 -08:00
if domain is None : domain = self . all_addresses ( )
2012-02-10 04:23:39 -08:00
for addr in domain :
2012-11-03 01:17:40 -07:00
h = self . history . get ( addr , [ ] )
2012-11-15 00:14:24 -08:00
if h == [ ' * ' ] : continue
2012-11-15 03:14:29 -08:00
for tx_hash , tx_height in h :
2012-11-03 01:17:40 -07:00
tx = self . transactions . get ( tx_hash )
2013-02-23 03:07:46 -08:00
for output in tx . d . get ( ' outputs ' ) :
2012-11-03 01:17:40 -07:00
if output . get ( ' address ' ) != addr : continue
key = tx_hash + " : %d " % output . get ( ' index ' )
if key in self . spent_outputs : continue
output [ ' tx_hash ' ] = tx_hash
coins . append ( output )
2013-02-23 04:18:15 -08:00
return coins
2012-11-03 01:17:40 -07:00
2012-06-06 06:40:57 -07:00
2013-02-23 04:18:15 -08:00
def choose_tx_inputs ( self , amount , fixed_fee , from_addr = None ) :
""" todo: minimize tx size """
total = 0
fee = self . fee if fixed_fee is None else fixed_fee
coins = [ ]
prioritized_coins = [ ]
domain = [ from_addr ] if from_addr else self . all_addresses ( )
for i in self . frozen_addresses :
if i in domain : domain . remove ( i )
for i in self . prioritized_addresses :
if i in domain : domain . remove ( i )
coins = self . get_unspent_coins ( domain )
prioritized_coins = self . get_unspent_coins ( self . prioritized_addresses )
2012-06-06 06:40:57 -07:00
2012-01-19 08:11:36 -08:00
inputs = [ ]
2012-06-06 06:40:57 -07:00
coins = prioritized_coins + coins
2012-11-03 01:17:40 -07:00
for item in coins :
addr = item . get ( ' address ' )
2012-01-19 08:11:36 -08:00
v = item . get ( ' value ' )
total + = v
2013-02-21 05:18:12 -08:00
item [ ' pubkeysig ' ] = [ ( None , None ) ]
inputs . append ( item )
2012-01-19 08:11:36 -08:00
fee = self . fee * len ( inputs ) if fixed_fee is None else fixed_fee
if total > = amount + fee : break
else :
2012-06-08 04:14:25 -07:00
#print "not enough funds: %s %s"%(format_satoshis(total), format_satoshis(fee))
2012-01-19 08:11:36 -08:00
inputs = [ ]
return inputs , total , fee
2012-12-05 07:41:39 -08:00
def add_tx_change ( self , outputs , amount , fee , total , change_addr = None ) :
2012-01-19 08:11:36 -08:00
change_amount = total - ( amount + fee )
if change_amount != 0 :
# normally, the update thread should ensure that the last change address is unused
2012-02-07 19:22:18 -08:00
if not change_addr :
2013-01-29 05:53:13 -08:00
change_addr = self . change_addresses [ - self . gap_limit_for_change ]
2013-01-22 01:29:37 -08:00
# Insert the change output at a random position in the outputs
posn = random . randint ( 0 , len ( outputs ) )
outputs [ posn : posn ] = [ ( change_addr , change_amount ) ]
2012-01-19 08:11:36 -08:00
return outputs
2012-11-07 00:37:14 -08:00
def get_history ( self , address ) :
2012-10-20 17:57:31 -07:00
with self . lock :
2012-11-07 00:37:14 -08:00
return self . history . get ( address )
def get_status ( self , h ) :
2012-11-03 01:17:40 -07:00
if not h : return None
2012-11-14 06:33:44 -08:00
if h == [ ' * ' ] : return ' * '
2012-11-03 01:17:40 -07:00
status = ' '
for tx_hash , height in h :
status + = tx_hash + ' : %d : ' % height
return hashlib . sha256 ( status ) . digest ( ) . encode ( ' hex ' )
2012-03-30 05:15:05 -07:00
2012-03-31 02:47:16 -07:00
2013-02-22 10:22:22 -08:00
def receive_tx_callback ( self , tx_hash , tx , tx_height ) :
2012-11-07 11:25:23 -08:00
if not self . check_new_tx ( tx_hash , tx ) :
2012-11-07 11:46:18 -08:00
raise BaseException ( " error: received transaction is not consistent with history " % tx_hash )
2012-11-07 11:25:23 -08:00
with self . lock :
self . transactions [ tx_hash ] = tx
2013-02-22 10:22:22 -08:00
self . tx_height [ tx_hash ] = tx_height
2012-11-07 11:25:23 -08:00
2013-02-22 10:22:22 -08:00
#tx_height = tx.get('height')
2012-11-18 02:34:52 -08:00
if self . verifier and tx_height > 0 :
self . verifier . add ( tx_hash , tx_height )
2012-11-15 01:34:56 -08:00
2012-11-04 11:53:27 -08:00
self . update_tx_outputs ( tx_hash )
2012-11-03 01:17:40 -07:00
self . save ( )
def receive_history_callback ( self , addr , hist ) :
2012-11-07 11:25:23 -08:00
2012-11-23 06:35:54 -08:00
if not self . check_new_history ( addr , hist ) :
raise BaseException ( " error: received history for %s is not consistent with known transactions " % addr )
2012-11-07 11:25:23 -08:00
2012-11-03 01:17:40 -07:00
with self . lock :
self . history [ addr ] = hist
2012-03-31 02:47:16 -07:00
self . save ( )
2012-11-14 06:33:44 -08:00
if hist != [ ' * ' ] :
2012-11-05 11:40:57 -08:00
for tx_hash , tx_height in hist :
if tx_height > 0 :
2012-11-15 03:14:29 -08:00
# add it in case it was previously unconfirmed
2012-11-18 02:34:52 -08:00
if self . verifier : self . verifier . add ( tx_hash , tx_height )
2012-11-15 03:14:29 -08:00
# set the height in case it changed
2013-02-22 10:22:22 -08:00
txh = self . tx_height . get ( tx_hash )
2013-02-24 00:39:43 -08:00
if txh is not None and txh != tx_height :
2013-02-22 10:22:22 -08:00
print_error ( " changing height for tx " , tx_hash )
self . tx_height [ tx_hash ] = tx_height
2012-11-03 01:17:40 -07:00
2012-11-07 11:25:23 -08:00
2012-01-19 08:11:36 -08:00
def get_tx_history ( self ) :
2012-10-20 17:57:31 -07:00
with self . lock :
2013-02-22 10:22:22 -08:00
history = self . transactions . items ( )
2013-02-23 04:29:03 -08:00
history . sort ( key = lambda x : self . tx_height . get ( x [ 0 ] ) if self . tx_height . get ( x [ 0 ] ) else 1e12 )
2012-11-16 05:39:31 -08:00
result = [ ]
balance = 0
2013-02-22 10:22:22 -08:00
for tx_hash , tx in history :
is_mine , v , fee = self . get_tx_value ( tx )
2012-11-16 05:39:31 -08:00
if v is not None : balance + = v
c , u = self . get_balance ( )
if balance != c + u :
v_str = format_satoshis ( c + u - balance , True , self . num_zeros )
result . append ( ( ' ' , 1000 , 0 , c + u - balance , None , c + u - balance , None ) )
balance = c + u - balance
2013-02-22 10:22:22 -08:00
for tx_hash , tx in history :
2013-01-02 02:39:44 -08:00
conf , timestamp = self . verifier . get_confirmations ( tx_hash ) if self . verifier else ( None , None )
2013-02-22 10:22:22 -08:00
is_mine , value , fee = self . get_tx_value ( tx )
2012-11-23 06:35:54 -08:00
if value is not None :
balance + = value
2012-11-16 05:39:31 -08:00
result . append ( ( tx_hash , conf , is_mine , value , fee , balance , timestamp ) )
return result
2012-01-19 08:11:36 -08:00
2012-11-05 02:08:16 -08:00
def get_label ( self , tx_hash ) :
label = self . labels . get ( tx_hash )
is_default = ( label == ' ' ) or ( label is None )
if is_default : label = self . get_default_label ( tx_hash )
return label , is_default
2013-02-23 02:50:09 -08:00
2012-11-03 01:17:40 -07:00
def get_default_label ( self , tx_hash ) :
tx = self . transactions . get ( tx_hash )
2012-11-18 02:34:52 -08:00
default_label = ' '
2012-11-03 01:17:40 -07:00
if tx :
2013-02-22 10:22:22 -08:00
is_mine , _ , _ = self . get_tx_value ( tx )
2012-11-16 05:39:31 -08:00
if is_mine :
2013-02-22 10:22:22 -08:00
for o in tx . outputs :
o_addr , _ = o
2012-06-10 02:37:11 -07:00
if not self . is_mine ( o_addr ) :
2012-08-12 13:52:28 -07:00
try :
default_label = self . labels [ o_addr ]
except KeyError :
default_label = o_addr
2012-01-19 08:11:36 -08:00
else :
2013-02-22 10:22:22 -08:00
for o in tx . outputs :
o_addr , _ = o
2012-01-19 08:11:36 -08:00
if self . is_mine ( o_addr ) and not self . is_change ( o_addr ) :
2012-05-19 02:01:45 -07:00
break
else :
2013-02-22 10:22:22 -08:00
for o in tx . outputs :
o_addr , _ = o
2012-05-19 02:01:45 -07:00
if self . is_mine ( o_addr ) :
break
else :
o_addr = None
if o_addr :
dest_label = self . labels . get ( o_addr )
2012-08-12 13:52:28 -07:00
try :
default_label = self . labels [ o_addr ]
except KeyError :
default_label = o_addr
2012-05-19 02:01:45 -07:00
2012-11-03 01:17:40 -07:00
return default_label
2012-01-19 08:11:36 -08:00
2012-12-05 07:41:39 -08:00
def mktx ( self , outputs , label , password , fee = None , change_addr = None , from_addr = None ) :
for address , x in outputs :
assert self . is_valid ( address )
amount = sum ( map ( lambda x : x [ 1 ] , outputs ) )
2012-02-10 04:23:39 -08:00
inputs , total , fee = self . choose_tx_inputs ( amount , fee , from_addr )
2012-01-19 08:11:36 -08:00
if not inputs :
2012-08-23 18:16:27 -07:00
raise ValueError ( " Not enough funds " )
2012-06-16 09:45:17 -07:00
2012-06-17 00:51:15 -07:00
if not self . use_change and not change_addr :
2013-02-21 05:18:12 -08:00
change_addr = inputs [ - 1 ] [ ' address ' ]
2012-11-26 06:08:35 -08:00
print_error ( " Sending change to " , change_addr )
2012-12-05 07:41:39 -08:00
outputs = self . add_tx_change ( outputs , amount , fee , total , change_addr )
2012-01-19 08:11:36 -08:00
2013-02-24 12:31:11 -08:00
tx = Transaction . from_io ( inputs , outputs )
2013-02-25 00:05:45 -08:00
for i in range ( len ( tx . inputs ) ) :
addr = tx . inputs [ i ] [ ' address ' ]
n , is_change = self . get_address_index ( addr )
2013-02-25 00:34:47 -08:00
tx . input_info [ i ] [ ' electrumKeyID ' ] = ( n , is_change )
2013-02-25 00:05:45 -08:00
2012-12-05 09:18:47 -08:00
if not self . seed :
2013-02-24 12:31:11 -08:00
return tx
2012-12-05 09:18:47 -08:00
2013-02-24 12:31:11 -08:00
self . sign_tx ( tx , password )
2012-12-05 07:41:39 -08:00
for address , x in outputs :
if address not in self . addressbook and not self . is_mine ( address ) :
2012-12-06 01:36:05 -08:00
self . addressbook . append ( address )
2012-12-05 07:41:39 -08:00
2012-01-19 08:11:36 -08:00
if label :
2013-02-25 09:50:12 -08:00
self . labels [ tx . hash ( ) ] = label
2012-02-10 04:44:10 -08:00
2012-01-19 08:11:36 -08:00
return tx
2013-02-24 12:31:11 -08:00
def sign_tx ( self , tx , password ) :
2013-02-21 05:18:12 -08:00
private_keys = { }
for txin in tx . inputs :
addr = txin [ ' address ' ]
2013-02-22 08:27:19 -08:00
sec = self . get_private_key ( addr , password )
2013-02-22 04:40:42 -08:00
private_keys [ addr ] = sec
2013-02-21 05:18:12 -08:00
tx . sign ( private_keys )
2012-12-05 09:18:47 -08:00
2012-01-19 08:11:36 -08:00
def sendtx ( self , tx ) :
2012-10-13 23:25:09 -07:00
# synchronous
h = self . send_tx ( tx )
self . tx_event . wait ( )
2012-11-22 04:12:17 -08:00
return self . receive_tx ( h )
2012-10-13 23:25:09 -07:00
def send_tx ( self , tx ) :
# asynchronous
2012-03-24 05:15:23 -07:00
self . tx_event . clear ( )
2013-02-25 09:15:14 -08:00
self . interface . send ( [ ( ' blockchain.transaction.broadcast ' , [ str ( tx ) ] ) ] , ' synchronizer ' )
return tx . hash ( )
2012-10-13 23:25:09 -07:00
def receive_tx ( self , tx_hash ) :
2012-03-24 05:15:23 -07:00
out = self . tx_result
2012-01-19 08:11:36 -08:00
if out != tx_hash :
return False , " error: " + out
2012-02-03 08:38:43 -08:00
if self . receipt :
self . receipts [ tx_hash ] = self . receipt
self . receipt = None
2012-01-19 08:11:36 -08:00
return True , out
2012-02-06 08:59:31 -08:00
def read_alias ( self , alias ) :
2012-02-03 06:45:41 -08:00
# this might not be the right place for this function.
import urllib
2012-02-06 14:45:21 -08:00
m1 = re . match ( ' ([ \ w \ - \ .]+)@(( \ w[ \ w \ -]+ \ .)+[ \ w \ -]+) ' , alias )
m2 = re . match ( ' (( \ w[ \ w \ -]+ \ .)+[ \ w \ -]+) ' , alias )
if m1 :
2012-10-01 06:10:51 -07:00
url = ' https:// ' + m1 . group ( 2 ) + ' /bitcoin.id/ ' + m1 . group ( 1 )
2012-02-06 14:45:21 -08:00
elif m2 :
2012-10-01 06:10:51 -07:00
url = ' https:// ' + alias + ' /bitcoin.id '
2012-02-03 06:45:41 -08:00
else :
2012-02-06 14:45:21 -08:00
return ' '
try :
lines = urllib . urlopen ( url ) . readlines ( )
except :
return ' '
2012-02-03 07:39:27 -08:00
2012-02-06 14:45:21 -08:00
# line 0
line = lines [ 0 ] . strip ( ) . split ( ' : ' )
if len ( line ) == 1 :
auth_name = None
target = signing_addr = line [ 0 ]
else :
target , auth_name , signing_addr , signature = line
msg = " alias: %s : %s : %s " % ( alias , target , auth_name )
print msg , signature
2013-02-22 08:50:56 -08:00
EC_KEY . verify_message ( signing_addr , signature , msg )
2012-02-06 14:45:21 -08:00
# other lines are signed updates
for line in lines [ 1 : ] :
line = line . strip ( )
if not line : continue
line = line . split ( ' : ' )
previous = target
print repr ( line )
target , signature = line
2013-02-22 08:50:56 -08:00
EC_KEY . verify_message ( previous , signature , " alias: %s : %s " % ( alias , target ) )
2012-02-06 14:45:21 -08:00
if not self . is_valid ( target ) :
2012-08-23 18:17:30 -07:00
raise ValueError ( " Invalid bitcoin address " )
2012-02-06 14:45:21 -08:00
return target , signing_addr , auth_name
2012-02-13 05:52:59 -08:00
2012-05-16 23:32:49 -07:00
def update_password ( self , seed , old_password , new_password ) :
2012-04-09 02:38:21 -07:00
if new_password == ' ' : new_password = None
self . use_encryption = ( new_password != None )
2013-02-23 02:35:46 -08:00
self . seed = pw_encode ( seed , new_password )
2013-02-03 06:08:26 -08:00
self . config . set_key ( ' seed ' , self . seed , True )
2012-02-13 05:52:59 -08:00
for k in self . imported_keys . keys ( ) :
a = self . imported_keys [ k ]
2013-02-23 02:35:46 -08:00
b = pw_decode ( a , old_password )
c = pw_encode ( b , new_password )
2012-02-13 05:56:31 -08:00
self . imported_keys [ k ] = c
self . save ( )
2012-02-14 00:52:03 -08:00
def get_alias ( self , alias , interactive = False , show_message = None , question = None ) :
try :
target , signing_address , auth_name = self . read_alias ( alias )
except BaseException , e :
# raise exception if verify fails (verify the chain)
if interactive :
2012-05-16 10:20:21 -07:00
show_message ( " Alias error: " + str ( e ) )
2012-02-14 00:52:03 -08:00
return
print target , signing_address , auth_name
if auth_name is None :
a = self . aliases . get ( alias )
if not a :
msg = " Warning: the alias ' %s ' is self-signed. \n The signing address is %s . \n \n Do you want to add this alias to your list of contacts? " % ( alias , signing_address )
if interactive and question ( msg ) :
self . aliases [ alias ] = ( signing_address , target )
else :
target = None
else :
if signing_address != a [ 0 ] :
msg = " Warning: the key of alias ' %s ' has changed since your last visit! It is possible that someone is trying to do something nasty!!! \n Do you accept to change your trusted key? " % alias
if interactive and question ( msg ) :
self . aliases [ alias ] = ( signing_address , target )
else :
target = None
else :
if signing_address not in self . authorities . keys ( ) :
msg = " The alias: ' %s ' links to %s \n \n Warning: this alias was signed by an unknown key. \n Signing authority: %s \n Signing address: %s \n \n Do you want to add this key to your list of trusted keys? " % ( alias , target , auth_name , signing_address )
if interactive and question ( msg ) :
self . authorities [ signing_address ] = auth_name
else :
target = None
if target :
self . aliases [ alias ] = ( signing_address , target )
return target
2012-02-14 03:45:39 -08:00
2012-02-14 04:49:05 -08:00
def parse_url ( self , url , show_message , question ) :
2012-02-14 03:45:39 -08:00
o = url [ 8 : ] . split ( ' ? ' )
address = o [ 0 ]
if len ( o ) > 1 :
params = o [ 1 ] . split ( ' & ' )
else :
params = [ ]
amount = label = message = signature = identity = ' '
for p in params :
k , v = p . split ( ' = ' )
uv = urldecode ( v )
if k == ' amount ' : amount = uv
elif k == ' message ' : message = uv
elif k == ' label ' : label = uv
elif k == ' signature ' :
identity , signature = uv . split ( ' : ' )
url = url . replace ( ' & %s = %s ' % ( k , v ) , ' ' )
else :
print k , v
2012-06-08 14:15:08 -07:00
if label and self . labels . get ( address ) != label :
if question ( ' Give label " %s " to address %s ? ' % ( label , address ) ) :
if address not in self . addressbook and address not in self . all_addresses ( ) :
self . addressbook . append ( address )
self . labels [ address ] = label
2012-02-14 04:49:05 -08:00
if signature :
if re . match ( ' ^(|([ \ w \ - \ .]+)@)(( \ w[ \ w \ -]+ \ .)+[ \ w \ -]+)$ ' , identity ) :
signing_address = self . get_alias ( identity , True , show_message , question )
elif self . is_valid ( identity ) :
signing_address = identity
else :
signing_address = None
if not signing_address :
return
try :
2013-02-22 08:50:56 -08:00
EC_KEY . verify_message ( signing_address , signature , url )
2012-02-14 04:49:05 -08:00
self . receipt = ( signing_address , signature , url )
except :
2012-02-14 08:17:59 -08:00
show_message ( ' Warning: the URI contains a bad signature. \n The identity of the recipient cannot be verified. ' )
2012-02-14 04:49:05 -08:00
address = amount = label = identity = message = ' '
if re . match ( ' ^(|([ \ w \ - \ .]+)@)(( \ w[ \ w \ -]+ \ .)+[ \ w \ -]+)$ ' , address ) :
2012-02-14 08:16:28 -08:00
payto_address = self . get_alias ( address , True , show_message , question )
2012-02-14 04:49:05 -08:00
if payto_address :
address = address + ' < ' + payto_address + ' > '
2012-02-14 04:38:47 -08:00
return address , amount , label , message , signature , identity , url
2012-03-23 08:34:34 -07:00
2012-03-23 09:46:48 -07:00
2012-06-07 02:18:11 -07:00
def freeze ( self , addr ) :
if addr in self . all_addresses ( ) and addr not in self . frozen_addresses :
2012-06-07 02:21:53 -07:00
self . unprioritize ( addr )
2012-06-07 02:18:11 -07:00
self . frozen_addresses . append ( addr )
2012-10-12 08:40:37 -07:00
self . config . set_key ( ' frozen_addresses ' , self . frozen_addresses , True )
2012-06-07 02:18:11 -07:00
return True
else :
return False
2012-05-02 05:21:58 -07:00
2012-06-07 02:18:11 -07:00
def unfreeze ( self , addr ) :
if addr in self . all_addresses ( ) and addr in self . frozen_addresses :
self . frozen_addresses . remove ( addr )
2012-10-12 08:40:37 -07:00
self . config . set_key ( ' frozen_addresses ' , self . frozen_addresses , True )
2012-06-07 02:18:11 -07:00
return True
else :
return False
2012-03-30 05:15:05 -07:00
2012-06-07 02:18:11 -07:00
def prioritize ( self , addr ) :
2012-06-07 02:25:23 -07:00
if addr in self . all_addresses ( ) and addr not in self . prioritized_addresses :
self . unfreeze ( addr )
2012-06-07 02:18:11 -07:00
self . prioritized_addresses . append ( addr )
2012-10-12 08:40:37 -07:00
self . config . set_key ( ' prioritized_addresses ' , self . prioritized_addresses , True )
2012-06-07 02:18:11 -07:00
return True
else :
return False
def unprioritize ( self , addr ) :
if addr in self . all_addresses ( ) and addr in self . prioritized_addresses :
self . prioritized_addresses . remove ( addr )
2012-10-12 08:40:37 -07:00
self . config . set_key ( ' prioritized_addresses ' , self . prioritized_addresses , True )
2012-06-07 02:18:11 -07:00
return True
else :
return False
2012-10-11 11:10:12 -07:00
def save ( self ) :
2013-02-22 10:22:22 -08:00
tx = { }
for k , v in self . transactions . items ( ) :
tx [ k ] = str ( v )
2012-10-11 11:10:12 -07:00
s = {
' use_encryption ' : self . use_encryption ,
' use_change ' : self . use_change ,
' fee ' : self . fee ,
' addresses ' : self . addresses ,
' change_addresses ' : self . change_addresses ,
2012-11-04 06:47:19 -08:00
' addr_history ' : self . history ,
2012-10-11 11:10:12 -07:00
' labels ' : self . labels ,
' contacts ' : self . addressbook ,
' imported_keys ' : self . imported_keys ,
' aliases ' : self . aliases ,
' authorities ' : self . authorities ,
' receipts ' : self . receipts ,
' num_zeros ' : self . num_zeros ,
' frozen_addresses ' : self . frozen_addresses ,
' prioritized_addresses ' : self . prioritized_addresses ,
' gap_limit ' : self . gap_limit ,
2013-02-22 10:22:22 -08:00
' transactions ' : tx ,
' tx_height ' : self . tx_height ,
2012-11-28 06:38:44 -08:00
' requested_amounts ' : self . requested_amounts ,
2012-10-11 11:10:12 -07:00
}
for k , v in s . items ( ) :
self . config . set_key ( k , v )
self . config . save ( )
2012-10-20 17:57:31 -07:00
2012-10-26 01:02:09 -07:00
def set_verifier ( self , verifier ) :
self . verifier = verifier
2012-11-15 03:14:29 -08:00
2012-11-16 01:18:35 -08:00
# review stored transactions and send them to the verifier
# (they are not necessarily in the history, because history items might have have been pruned)
2012-11-15 01:34:56 -08:00
for tx_hash , tx in self . transactions . items ( ) :
2013-02-22 10:22:22 -08:00
tx_height = self . tx_height [ tx_hash ]
2012-11-15 01:34:56 -08:00
if tx_height < 1 :
print_error ( " skipping " , tx_hash , tx_height )
continue
if tx_height > 0 :
self . verifier . add ( tx_hash , tx_height )
2012-11-16 01:18:35 -08:00
# review transactions that are in the history
2012-11-15 03:14:29 -08:00
for addr , hist in self . history . items ( ) :
if hist == [ ' * ' ] : continue
for tx_hash , tx_height in hist :
if tx_height > 0 :
# add it in case it was previously unconfirmed
self . verifier . add ( tx_hash , tx_height )
# set the height in case it changed
2013-02-22 10:22:22 -08:00
txh = self . tx_height . get ( tx_hash )
2013-02-24 00:39:43 -08:00
if txh is not None and txh != tx_height :
2013-02-22 10:22:22 -08:00
print_error ( " changing height for tx " , tx_hash )
self . tx_height [ tx_hash ] = tx_height
2012-11-07 11:25:23 -08:00
def check_new_history ( self , addr , hist ) :
2012-11-23 06:35:54 -08:00
# check that all tx in hist are relevant
if hist != [ ' * ' ] :
for tx_hash , height in hist :
tx = self . transactions . get ( tx_hash )
if not tx : continue
2013-02-22 10:22:22 -08:00
if not tx . has_address ( addr ) :
2012-11-23 06:35:54 -08:00
return False
# check that we are not "orphaning" a transaction
2012-11-23 08:11:32 -08:00
old_hist = self . history . get ( addr , [ ] )
2012-11-23 06:35:54 -08:00
if old_hist == [ ' * ' ] : return True
for tx_hash , height in old_hist :
if tx_hash in map ( lambda x : x [ 0 ] , hist ) : continue
found = False
for _addr , _hist in self . history . items ( ) :
if _addr == addr : continue
if _hist == [ ' * ' ] : continue
_tx_hist = map ( lambda x : x [ 0 ] , _hist )
if tx_hash in _tx_hist :
found = True
break
if not found :
tx = self . transactions . get ( tx_hash )
2013-01-29 04:19:00 -08:00
# tx might not be there
if not tx : continue
2012-11-23 06:35:54 -08:00
# already verified?
2013-02-22 10:22:22 -08:00
if self . tx_height . get ( tx_hash ) :
2012-11-23 06:35:54 -08:00
continue
# unconfirmed tx
print_error ( " new history is orphaning transaction: " , tx_hash )
# check that all outputs are not mine, request histories
ext_requests = [ ]
for o in tx . get ( ' outputs ' ) :
_addr = o . get ( ' address ' )
2012-11-24 11:32:50 -08:00
# assert not self.is_mine(_addr)
2012-11-23 06:35:54 -08:00
ext_requests . append ( ( ' blockchain.address.get_history ' , [ _addr ] ) )
ext_h = self . interface . synchronous_get ( ext_requests )
height = None
for h in ext_h :
if h == [ ' * ' ] : continue
for item in h :
if item . get ( ' tx_hash ' ) == tx_hash :
height = item . get ( ' height ' )
2013-02-22 10:22:22 -08:00
self . tx_height [ tx_hash ] = height
2012-11-23 06:35:54 -08:00
if height :
print_error ( " found height for " , tx_hash , height )
self . verifier . add ( tx_hash , height )
else :
print_error ( " removing orphaned tx from history " , tx_hash )
self . transactions . pop ( tx_hash )
2012-11-07 11:25:23 -08:00
return True
def check_new_tx ( self , tx_hash , tx ) :
# 1 check that tx is referenced in addr_history.
addresses = [ ]
for addr , hist in self . history . items ( ) :
2012-11-14 06:33:44 -08:00
if hist == [ ' * ' ] : continue
2012-11-07 11:25:23 -08:00
for txh , height in hist :
if txh == tx_hash :
addresses . append ( addr )
if not addresses :
return False
# 2 check that referencing addresses are in the tx
for addr in addresses :
2013-02-22 10:22:22 -08:00
if not tx . has_address ( addr ) :
2012-11-07 11:25:23 -08:00
return False
return True
2012-10-20 17:57:31 -07:00
class WalletSynchronizer ( threading . Thread ) :
def __init__ ( self , wallet , config ) :
threading . Thread . __init__ ( self )
2012-12-05 01:24:30 -08:00
self . daemon = True
2012-10-20 17:57:31 -07:00
self . wallet = wallet
self . interface = self . wallet . interface
self . interface . register_channel ( ' synchronizer ' )
2012-11-20 12:36:06 -08:00
self . wallet . interface . register_callback ( ' connected ' , lambda : self . wallet . set_up_to_date ( False ) )
2012-10-22 06:01:13 -07:00
self . wallet . interface . register_callback ( ' connected ' , lambda : self . interface . send ( [ ( ' server.banner ' , [ ] ) ] , ' synchronizer ' ) )
2012-10-27 10:20:50 -07:00
self . was_updated = True
2012-11-05 14:10:38 -08:00
self . running = False
self . lock = threading . Lock ( )
def stop ( self ) :
with self . lock : self . running = False
2012-11-24 11:31:07 -08:00
self . interface . poke ( ' synchronizer ' )
2012-11-05 14:10:38 -08:00
def is_running ( self ) :
with self . lock : return self . running
2012-10-20 17:57:31 -07:00
def synchronize_wallet ( self ) :
new_addresses = self . wallet . synchronize ( )
if new_addresses :
self . subscribe_to_addresses ( new_addresses )
2012-11-07 11:25:23 -08:00
self . wallet . up_to_date = False
return
2012-10-20 17:57:31 -07:00
2012-11-07 11:25:23 -08:00
if not self . interface . is_up_to_date ( ' synchronizer ' ) :
2012-11-20 12:36:06 -08:00
if self . wallet . is_up_to_date ( ) :
self . wallet . set_up_to_date ( False )
2012-10-27 10:20:50 -07:00
self . was_updated = True
2012-11-07 11:25:23 -08:00
return
2012-10-20 17:57:31 -07:00
2012-11-20 12:36:06 -08:00
self . wallet . set_up_to_date ( True )
2012-11-07 11:25:23 -08:00
self . was_updated = True
2012-10-20 17:57:31 -07:00
2012-11-07 11:25:23 -08:00
2012-10-20 17:57:31 -07:00
def subscribe_to_addresses ( self , addresses ) :
messages = [ ]
for addr in addresses :
messages . append ( ( ' blockchain.address.subscribe ' , [ addr ] ) )
self . interface . send ( messages , ' synchronizer ' )
def run ( self ) :
2012-11-05 14:10:38 -08:00
with self . lock : self . running = True
2012-11-03 01:17:40 -07:00
requested_tx = [ ]
2012-11-04 07:59:50 -08:00
missing_tx = [ ]
2012-11-06 23:45:53 -08:00
requested_histories = { }
2012-11-04 07:59:50 -08:00
# request any missing transactions
for history in self . wallet . history . values ( ) :
2012-11-14 06:33:44 -08:00
if history == [ ' * ' ] : continue
2012-11-04 07:59:50 -08:00
for tx_hash , tx_height in history :
if self . wallet . transactions . get ( tx_hash ) is None and ( tx_hash , tx_height ) not in missing_tx :
missing_tx . append ( ( tx_hash , tx_height ) )
print_error ( " missing tx " , missing_tx )
2012-10-22 08:18:07 -07:00
# wait until we are connected, in case the user is not connected
while not self . interface . is_connected :
time . sleep ( 1 )
# request banner, because 'connected' event happens before this thread is started
2012-10-22 06:01:13 -07:00
self . interface . send ( [ ( ' server.banner ' , [ ] ) ] , ' synchronizer ' )
2012-10-20 17:57:31 -07:00
# subscriptions
self . subscribe_to_addresses ( self . wallet . all_addresses ( ) )
2012-11-05 14:10:38 -08:00
while self . is_running ( ) :
2012-10-20 17:57:31 -07:00
# 1. send new requests
self . synchronize_wallet ( )
2012-11-04 07:59:50 -08:00
for tx_hash , tx_height in missing_tx :
if ( tx_hash , tx_height ) not in requested_tx :
self . interface . send ( [ ( ' blockchain.transaction.get ' , [ tx_hash , tx_height ] ) ] , ' synchronizer ' )
requested_tx . append ( ( tx_hash , tx_height ) )
missing_tx = [ ]
2012-10-27 10:20:50 -07:00
if self . was_updated :
2012-10-22 04:43:58 -07:00
self . interface . trigger_callback ( ' updated ' )
2012-10-27 10:20:50 -07:00
self . was_updated = False
2012-10-22 04:43:58 -07:00
2012-10-20 17:57:31 -07:00
# 2. get a response
2012-11-24 11:31:07 -08:00
r = self . interface . get_response ( ' synchronizer ' )
2012-11-05 14:10:38 -08:00
2012-11-24 11:31:07 -08:00
# poke sends None. (needed during stop)
if not r : continue
2012-10-20 17:57:31 -07:00
# 3. handle response
method = r [ ' method ' ]
params = r [ ' params ' ]
2012-11-14 06:33:44 -08:00
result = r . get ( ' result ' )
error = r . get ( ' error ' )
if error :
print " error " , r
continue
2012-10-20 17:57:31 -07:00
if method == ' blockchain.address.subscribe ' :
addr = params [ 0 ]
2012-11-07 00:37:14 -08:00
if self . wallet . get_status ( self . wallet . get_history ( addr ) ) != result :
2012-12-14 10:32:10 -08:00
if requested_histories . get ( addr ) is None :
self . interface . send ( [ ( ' blockchain.address.get_history ' , [ addr ] ) ] , ' synchronizer ' )
requested_histories [ addr ] = result
2012-11-06 23:45:53 -08:00
2012-10-20 17:57:31 -07:00
elif method == ' blockchain.address.get_history ' :
addr = params [ 0 ]
2012-11-15 03:14:29 -08:00
print_error ( " receiving history " , addr , result )
2012-11-14 06:33:44 -08:00
if result == [ ' * ' ] :
assert requested_histories . pop ( addr ) == ' * '
self . wallet . receive_history_callback ( addr , result )
else :
hist = [ ]
# check that txids are unique
txids = [ ]
for item in result :
tx_hash = item [ ' tx_hash ' ]
if tx_hash not in txids :
txids . append ( tx_hash )
hist . append ( ( tx_hash , item [ ' height ' ] ) )
if len ( hist ) != len ( result ) :
2012-11-15 00:14:24 -08:00
raise BaseException ( " error: server sent history with non-unique txid " , result )
2012-11-14 06:33:44 -08:00
# check that the status corresponds to what was announced
rs = requested_histories . pop ( addr )
if self . wallet . get_status ( hist ) != rs :
raise BaseException ( " error: status mismatch: %s " % addr )
2012-11-07 00:37:14 -08:00
2012-11-14 06:33:44 -08:00
# store received history
self . wallet . receive_history_callback ( addr , hist )
# request transactions that we don't have
for tx_hash , tx_height in hist :
if self . wallet . transactions . get ( tx_hash ) is None :
if ( tx_hash , tx_height ) not in requested_tx and ( tx_hash , tx_height ) not in missing_tx :
missing_tx . append ( ( tx_hash , tx_height ) )
2012-11-03 01:17:40 -07:00
elif method == ' blockchain.transaction.get ' :
tx_hash = params [ 0 ]
tx_height = params [ 1 ]
2013-02-21 05:18:12 -08:00
assert tx_hash == hash_encode ( Hash ( result . decode ( ' hex ' ) ) )
tx = Transaction ( result )
2013-02-22 10:22:22 -08:00
self . wallet . receive_tx_callback ( tx_hash , tx , tx_height )
2012-10-27 10:20:50 -07:00
self . was_updated = True
2012-11-04 07:59:50 -08:00
requested_tx . remove ( ( tx_hash , tx_height ) )
2013-02-22 10:22:22 -08:00
print_error ( " received tx: " , tx )
2012-11-03 01:17:40 -07:00
2012-10-20 17:57:31 -07:00
elif method == ' blockchain.transaction.broadcast ' :
self . wallet . tx_result = result
self . wallet . tx_event . set ( )
2012-10-22 02:34:21 -07:00
elif method == ' server.banner ' :
self . wallet . banner = result
2013-02-01 09:22:36 -08:00
self . interface . trigger_callback ( ' banner ' )
2012-10-20 17:57:31 -07:00
else :
2012-10-22 02:34:21 -07:00
print_error ( " Error: Unknown message: " + method + " , " + repr ( params ) + " , " + repr ( result ) )
2012-10-20 17:57:31 -07:00
2012-11-04 07:59:50 -08:00
if self . was_updated and not requested_tx :
2012-10-22 04:43:58 -07:00
self . interface . trigger_callback ( ' updated ' )
2012-10-27 10:20:50 -07:00
self . was_updated = False
2012-10-22 04:43:58 -07:00
2012-10-20 17:57:31 -07:00