cleanup: next_addresses
This commit is contained in:
@@ -157,7 +157,7 @@ class Wallet:
|
|||||||
self.master_public_keys = storage.get('master_public_keys',{})
|
self.master_public_keys = storage.get('master_public_keys',{})
|
||||||
self.master_private_keys = storage.get('master_private_keys', {})
|
self.master_private_keys = storage.get('master_private_keys', {})
|
||||||
|
|
||||||
self.first_addresses = storage.get('first_addresses',{})
|
self.next_addresses = storage.get('next_addresses',{})
|
||||||
|
|
||||||
if self.seed_version < 4:
|
if self.seed_version < 4:
|
||||||
raise ValueError("This wallet seed is deprecated.")
|
raise ValueError("This wallet seed is deprecated.")
|
||||||
@@ -351,12 +351,12 @@ class Wallet:
|
|||||||
i = self.num_accounts(account_type)
|
i = self.num_accounts(account_type)
|
||||||
k = self.account_id(account_type,i)
|
k = self.account_id(account_type,i)
|
||||||
|
|
||||||
addr = self.first_addresses.get(k)
|
addr = self.next_addresses.get(k)
|
||||||
if not addr:
|
if not addr:
|
||||||
account_id, account = self.next_account(account_type)
|
account_id, account = self.next_account(account_type)
|
||||||
addr = account.first_address()
|
addr = account.first_address()
|
||||||
self.first_addresses[k] = addr
|
self.next_addresses[k] = addr
|
||||||
self.storage.put('first_addresses',self.first_addresses)
|
self.storage.put('next_addresses',self.next_addresses)
|
||||||
|
|
||||||
return addr
|
return addr
|
||||||
|
|
||||||
@@ -431,14 +431,15 @@ class Wallet:
|
|||||||
self.accounts[k] = BIP32_Account(v)
|
self.accounts[k] = BIP32_Account(v)
|
||||||
|
|
||||||
|
|
||||||
def addresses(self, include_change = True):
|
def addresses(self, include_change = True, next=False):
|
||||||
o = self.get_account_addresses(-1, include_change)
|
o = self.get_account_addresses(-1, include_change)
|
||||||
for a in self.accounts.keys():
|
for a in self.accounts.keys():
|
||||||
o += self.get_account_addresses(a, include_change)
|
o += self.get_account_addresses(a, include_change)
|
||||||
|
|
||||||
for addr in self.first_addresses.values():
|
if next:
|
||||||
if addr not in o:
|
for addr in self.next_addresses.values():
|
||||||
o += [addr]
|
if addr not in o:
|
||||||
|
o += [addr]
|
||||||
return o
|
return o
|
||||||
|
|
||||||
|
|
||||||
@@ -475,9 +476,6 @@ class Wallet:
|
|||||||
if address in self.imported_keys.keys():
|
if address in self.imported_keys.keys():
|
||||||
return -1, None
|
return -1, None
|
||||||
|
|
||||||
if address in self.first_addresses.values():
|
|
||||||
return -1, None
|
|
||||||
|
|
||||||
for account in self.accounts.keys():
|
for account in self.accounts.keys():
|
||||||
for for_change in [0,1]:
|
for for_change in [0,1]:
|
||||||
addresses = self.accounts[account].get_addresses(for_change)
|
addresses = self.accounts[account].get_addresses(for_change)
|
||||||
@@ -1425,7 +1423,7 @@ class WalletSynchronizer(threading.Thread):
|
|||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
|
|
||||||
# subscriptions
|
# subscriptions
|
||||||
self.subscribe_to_addresses(self.wallet.addresses(True))
|
self.subscribe_to_addresses(self.wallet.addresses(True, next=True))
|
||||||
|
|
||||||
while self.is_running():
|
while self.is_running():
|
||||||
# 1. create new addresses
|
# 1. create new addresses
|
||||||
|
|||||||
Reference in New Issue
Block a user