PyBitmessage-2021-04-27/src/class_addressGenerator.py

400 lines
20 KiB
Python
Raw Normal View History

2017-09-21 17:24:51 +02:00
import time
2017-09-21 17:24:51 +02:00
import threading
import hashlib
2017-09-21 17:24:51 +02:00
from binascii import hexlify
2013-06-21 21:44:28 +02:00
from pyelliptic import arithmetic
2017-09-21 17:24:51 +02:00
from pyelliptic.openssl import OpenSSL
import tr
import queues
import state
2017-09-21 17:24:51 +02:00
import shared
import defaults
import highlevelcrypto
from bmconfigparser import BMConfigParser
from debug import logger
from addresses import decodeAddress, encodeAddress, encodeVarint
from helper_threading import StoppableThread
class addressGenerator(threading.Thread, StoppableThread):
def __init__(self):
# QThread.__init__(self, parent)
threading.Thread.__init__(self, name="addressGenerator")
self.initStop()
2017-09-21 17:24:51 +02:00
def stopThread(self):
try:
queues.addressGeneratorQueue.put(("stopThread", "data"))
except:
pass
super(addressGenerator, self).stopThread()
def run(self):
while state.shutdown == 0:
queueValue = queues.addressGeneratorQueue.get()
nonceTrialsPerByte = 0
payloadLengthExtraBytes = 0
live = True
2013-06-26 17:55:33 +02:00
if queueValue[0] == 'createChan':
2017-09-21 17:24:51 +02:00
command, addressVersionNumber, streamNumber, label, \
deterministicPassphrase, live = queueValue
2013-06-26 17:55:33 +02:00
eighteenByteRipe = False
numberOfAddressesToMake = 1
2013-09-18 06:04:01 +02:00
numberOfNullBytesDemandedOnFrontOfRipeHash = 1
2013-06-26 17:55:33 +02:00
elif queueValue[0] == 'joinChan':
2017-09-21 17:24:51 +02:00
command, chanAddress, label, deterministicPassphrase, \
live = queueValue
2013-06-26 17:55:33 +02:00
eighteenByteRipe = False
2013-07-22 07:10:22 +02:00
addressVersionNumber = decodeAddress(chanAddress)[1]
streamNumber = decodeAddress(chanAddress)[2]
2013-06-26 17:55:33 +02:00
numberOfAddressesToMake = 1
2013-09-18 06:04:01 +02:00
numberOfNullBytesDemandedOnFrontOfRipeHash = 1
2013-06-26 17:55:33 +02:00
elif len(queueValue) == 7:
2017-09-21 17:24:51 +02:00
command, addressVersionNumber, streamNumber, label, \
numberOfAddressesToMake, deterministicPassphrase, \
eighteenByteRipe = queueValue
try:
2017-09-21 17:24:51 +02:00
numberOfNullBytesDemandedOnFrontOfRipeHash = \
BMConfigParser().getint(
'bitmessagesettings',
'numberofnullbytesonaddress'
)
except:
if eighteenByteRipe:
numberOfNullBytesDemandedOnFrontOfRipeHash = 2
else:
2017-09-21 17:24:51 +02:00
# the default
numberOfNullBytesDemandedOnFrontOfRipeHash = 1
elif len(queueValue) == 9:
2017-09-21 17:24:51 +02:00
command, addressVersionNumber, streamNumber, label, \
numberOfAddressesToMake, deterministicPassphrase, \
eighteenByteRipe, nonceTrialsPerByte, \
payloadLengthExtraBytes = queueValue
try:
2017-09-21 17:24:51 +02:00
numberOfNullBytesDemandedOnFrontOfRipeHash = \
BMConfigParser().getint(
'bitmessagesettings',
'numberofnullbytesonaddress'
)
except:
if eighteenByteRipe:
numberOfNullBytesDemandedOnFrontOfRipeHash = 2
else:
2017-09-21 17:24:51 +02:00
# the default
numberOfNullBytesDemandedOnFrontOfRipeHash = 1
elif queueValue[0] == 'stopThread':
break
else:
2017-09-21 17:24:51 +02:00
logger.error(
'Programming error: A structure with the wrong number'
' of values was passed into the addressGeneratorQueue.'
' Here is the queueValue: %r\n', queueValue)
if addressVersionNumber < 3 or addressVersionNumber > 4:
2017-09-21 17:24:51 +02:00
logger.error(
'Program error: For some reason the address generator'
' queue has been given a request to create at least'
' one version %s address which it cannot do.\n',
addressVersionNumber)
if nonceTrialsPerByte == 0:
nonceTrialsPerByte = BMConfigParser().getint(
'bitmessagesettings', 'defaultnoncetrialsperbyte')
2017-09-21 17:24:51 +02:00
if nonceTrialsPerByte < \
defaults.networkDefaultProofOfWorkNonceTrialsPerByte:
nonceTrialsPerByte = \
defaults.networkDefaultProofOfWorkNonceTrialsPerByte
if payloadLengthExtraBytes == 0:
payloadLengthExtraBytes = BMConfigParser().getint(
'bitmessagesettings', 'defaultpayloadlengthextrabytes')
2017-09-21 17:24:51 +02:00
if payloadLengthExtraBytes < \
defaults.networkDefaultPayloadLengthExtraBytes:
payloadLengthExtraBytes = \
defaults.networkDefaultPayloadLengthExtraBytes
if command == 'createRandomAddress':
queues.UISignalQueue.put((
2017-09-21 17:24:51 +02:00
'updateStatusBar',
tr._translate(
"MainWindow", "Generating one new address")
))
# This next section is a little bit strange. We're going
# to generate keys over and over until we find one
# that starts with either \x00 or \x00\x00. Then when
# we pack them into a Bitmessage address, we won't store
# the \x00 or \x00\x00 bytes thus making the address shorter.
startTime = time.time()
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix = 0
potentialPrivSigningKey = OpenSSL.rand(32)
2017-09-21 17:24:51 +02:00
potentialPubSigningKey = highlevelcrypto.pointMult(
potentialPrivSigningKey)
while True:
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix += 1
potentialPrivEncryptionKey = OpenSSL.rand(32)
potentialPubEncryptionKey = highlevelcrypto.pointMult(
potentialPrivEncryptionKey)
ripe = hashlib.new('ripemd160')
sha = hashlib.new('sha512')
sha.update(
potentialPubSigningKey + potentialPubEncryptionKey)
ripe.update(sha.digest())
2013-09-18 06:04:01 +02:00
if ripe.digest()[:numberOfNullBytesDemandedOnFrontOfRipeHash] == '\x00' * numberOfNullBytesDemandedOnFrontOfRipeHash:
break
2017-09-21 17:24:51 +02:00
logger.info(
'Generated address with ripe digest: %s',
hexlify(ripe.digest()))
2015-01-08 23:11:30 +01:00
try:
2017-09-21 17:24:51 +02:00
logger.info(
'Address generator calculated %s addresses at %s'
' addresses per second before finding one with'
' the correct ripe-prefix.',
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix,
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix
/ (time.time() - startTime))
2015-01-08 23:11:30 +01:00
except ZeroDivisionError:
2017-09-21 17:24:51 +02:00
# The user must have a pretty fast computer.
# time.time() - startTime equaled zero.
2015-01-08 23:11:30 +01:00
pass
2017-09-21 17:24:51 +02:00
address = encodeAddress(
addressVersionNumber, streamNumber, ripe.digest())
2017-09-21 17:24:51 +02:00
# An excellent way for us to store our keys
# is in Wallet Import Format. Let us convert now.
# https://en.bitcoin.it/wiki/Wallet_import_format
privSigningKey = '\x80' + potentialPrivSigningKey
checksum = hashlib.sha256(hashlib.sha256(
privSigningKey).digest()).digest()[0:4]
privSigningKeyWIF = arithmetic.changebase(
privSigningKey + checksum, 256, 58)
privEncryptionKey = '\x80' + potentialPrivEncryptionKey
checksum = hashlib.sha256(hashlib.sha256(
privEncryptionKey).digest()).digest()[0:4]
privEncryptionKeyWIF = arithmetic.changebase(
privEncryptionKey + checksum, 256, 58)
BMConfigParser().add_section(address)
BMConfigParser().set(address, 'label', label)
BMConfigParser().set(address, 'enabled', 'true')
BMConfigParser().set(address, 'decoy', 'false')
BMConfigParser().set(address, 'noncetrialsperbyte', str(
nonceTrialsPerByte))
BMConfigParser().set(address, 'payloadlengthextrabytes', str(
payloadLengthExtraBytes))
BMConfigParser().set(
2017-09-21 17:24:51 +02:00
address, 'privsigningkey', privSigningKeyWIF)
BMConfigParser().set(
2017-09-21 17:24:51 +02:00
address, 'privencryptionkey', privEncryptionKeyWIF)
BMConfigParser().save()
# The API and the join and create Chan functionality
# both need information back from the address generator.
queues.apiAddressGeneratorReturnQueue.put(address)
queues.UISignalQueue.put((
2017-09-21 17:24:51 +02:00
'updateStatusBar',
tr._translate(
"MainWindow",
"Done generating address. Doing work necessary"
" to broadcast it...")
))
queues.UISignalQueue.put(('writeNewAddressToTable', (
label, address, streamNumber)))
shared.reloadMyAddressHashes()
if addressVersionNumber == 3:
queues.workerQueue.put((
'sendOutOrStoreMyV3Pubkey', ripe.digest()))
elif addressVersionNumber == 4:
queues.workerQueue.put((
'sendOutOrStoreMyV4Pubkey', address))
2017-09-21 17:24:51 +02:00
elif command == 'createDeterministicAddresses' \
or command == 'getDeterministicAddress' \
or command == 'createChan' or command == 'joinChan':
if len(deterministicPassphrase) == 0:
2017-09-21 17:24:51 +02:00
logger.warning(
'You are creating deterministic'
' address(es) using a blank passphrase.'
' Bitmessage will do it but it is rather stupid.')
if command == 'createDeterministicAddresses':
queues.UISignalQueue.put((
2017-09-21 17:24:51 +02:00
'updateStatusBar',
tr._translate(
"MainWindow",
"Generating %1 new addresses."
).arg(str(numberOfAddressesToMake))
))
signingKeyNonce = 0
encryptionKeyNonce = 1
2017-09-21 17:24:51 +02:00
# We fill out this list no matter what although we only
# need it if we end up passing the info to the API.
listOfNewAddressesToSendOutThroughTheAPI = []
2018-05-02 17:29:55 +02:00
for _ in range(numberOfAddressesToMake):
2017-09-21 17:24:51 +02:00
# This next section is a little bit strange. We're
# going to generate keys over and over until we find
# one that has a RIPEMD hash that starts with either
# \x00 or \x00\x00. Then when we pack them into a
# Bitmessage address, we won't store the \x00 or
# \x00\x00 bytes thus making the address shorter.
startTime = time.time()
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix = 0
while True:
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix += 1
potentialPrivSigningKey = hashlib.sha512(
2017-09-21 17:24:51 +02:00
deterministicPassphrase +
encodeVarint(signingKeyNonce)
).digest()[:32]
potentialPrivEncryptionKey = hashlib.sha512(
2017-09-21 17:24:51 +02:00
deterministicPassphrase +
encodeVarint(encryptionKeyNonce)
).digest()[:32]
potentialPubSigningKey = highlevelcrypto.pointMult(
potentialPrivSigningKey)
potentialPubEncryptionKey = highlevelcrypto.pointMult(
potentialPrivEncryptionKey)
signingKeyNonce += 2
encryptionKeyNonce += 2
ripe = hashlib.new('ripemd160')
sha = hashlib.new('sha512')
sha.update(
potentialPubSigningKey + potentialPubEncryptionKey)
ripe.update(sha.digest())
2013-09-18 06:04:01 +02:00
if ripe.digest()[:numberOfNullBytesDemandedOnFrontOfRipeHash] == '\x00' * numberOfNullBytesDemandedOnFrontOfRipeHash:
break
2017-09-21 17:24:51 +02:00
logger.info(
'Generated address with ripe digest: %s',
hexlify(ripe.digest()))
2015-01-08 23:11:30 +01:00
try:
2017-09-21 17:24:51 +02:00
logger.info(
'Address generator calculated %s addresses'
' at %s addresses per second before finding'
' one with the correct ripe-prefix.',
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix,
numberOfAddressesWeHadToMakeBeforeWeFoundOneWithTheCorrectRipePrefix /
(time.time() - startTime)
)
2015-01-08 23:11:30 +01:00
except ZeroDivisionError:
2017-09-21 17:24:51 +02:00
# The user must have a pretty fast computer.
# time.time() - startTime equaled zero.
2015-01-08 23:11:30 +01:00
pass
2017-09-21 17:24:51 +02:00
address = encodeAddress(
addressVersionNumber, streamNumber, ripe.digest())
saveAddressToDisk = True
2017-09-21 17:24:51 +02:00
# If we are joining an existing chan, let us check
# to make sure it matches the provided Bitmessage address
if command == 'joinChan':
if address != chanAddress:
2017-09-21 17:24:51 +02:00
listOfNewAddressesToSendOutThroughTheAPI.append(
'chan name does not match address')
2013-06-26 17:55:33 +02:00
saveAddressToDisk = False
if command == 'getDeterministicAddress':
saveAddressToDisk = False
2013-06-26 17:55:33 +02:00
if saveAddressToDisk and live:
2017-09-21 17:24:51 +02:00
# An excellent way for us to store our keys is
# in Wallet Import Format. Let us convert now.
# https://en.bitcoin.it/wiki/Wallet_import_format
privSigningKey = '\x80' + potentialPrivSigningKey
checksum = hashlib.sha256(hashlib.sha256(
privSigningKey).digest()).digest()[0:4]
privSigningKeyWIF = arithmetic.changebase(
privSigningKey + checksum, 256, 58)
privEncryptionKey = '\x80' + \
potentialPrivEncryptionKey
checksum = hashlib.sha256(hashlib.sha256(
privEncryptionKey).digest()).digest()[0:4]
privEncryptionKeyWIF = arithmetic.changebase(
privEncryptionKey + checksum, 256, 58)
try:
BMConfigParser().add_section(address)
2015-01-08 23:11:30 +01:00
addressAlreadyExists = False
except:
addressAlreadyExists = True
2017-09-21 17:24:51 +02:00
2015-01-08 23:11:30 +01:00
if addressAlreadyExists:
2017-09-21 17:24:51 +02:00
logger.info(
'%s already exists. Not adding it again.',
address
)
queues.UISignalQueue.put((
2017-09-21 17:24:51 +02:00
'updateStatusBar',
tr._translate(
"MainWindow",
"%1 is already in 'Your Identities'."
" Not adding it again."
).arg(address)
))
2015-01-08 23:11:30 +01:00
else:
2017-09-21 17:24:51 +02:00
logger.debug('label: %s', label)
BMConfigParser().set(address, 'label', label)
BMConfigParser().set(address, 'enabled', 'true')
BMConfigParser().set(address, 'decoy', 'false')
2017-09-21 17:24:51 +02:00
if command == 'joinChan' \
or command == 'createChan':
BMConfigParser().set(address, 'chan', 'true')
BMConfigParser().set(
2017-09-21 17:24:51 +02:00
address, 'noncetrialsperbyte',
str(nonceTrialsPerByte))
BMConfigParser().set(
2017-09-21 17:24:51 +02:00
address, 'payloadlengthextrabytes',
str(payloadLengthExtraBytes))
BMConfigParser().set(
address, 'privSigningKey',
privSigningKeyWIF)
BMConfigParser().set(
address, 'privEncryptionKey',
privEncryptionKeyWIF)
BMConfigParser().save()
2017-09-21 17:24:51 +02:00
queues.UISignalQueue.put((
'writeNewAddressToTable',
(label, address, str(streamNumber))
))
listOfNewAddressesToSendOutThroughTheAPI.append(
address)
2017-09-21 17:24:51 +02:00
shared.myECCryptorObjects[ripe.digest()] = \
highlevelcrypto.makeCryptor(
2016-03-23 23:26:57 +01:00
hexlify(potentialPrivEncryptionKey))
2013-09-15 03:06:26 +02:00
shared.myAddressesByHash[ripe.digest()] = address
2017-09-21 17:24:51 +02:00
tag = hashlib.sha512(hashlib.sha512(
encodeVarint(addressVersionNumber) +
encodeVarint(streamNumber) + ripe.digest()
).digest()).digest()[32:]
2013-09-15 03:06:26 +02:00
shared.myAddressesByTag[tag] = address
if addressVersionNumber == 3:
2017-09-21 17:24:51 +02:00
# If this is a chan address,
# the worker thread won't send out
# the pubkey over the network.
queues.workerQueue.put((
2017-09-21 17:24:51 +02:00
'sendOutOrStoreMyV3Pubkey', ripe.digest()))
elif addressVersionNumber == 4:
queues.workerQueue.put((
'sendOutOrStoreMyV4Pubkey', address))
queues.UISignalQueue.put((
2017-09-21 17:24:51 +02:00
'updateStatusBar',
tr._translate(
"MainWindow", "Done generating address")
))
elif saveAddressToDisk and not live \
and not BMConfigParser().has_section(address):
listOfNewAddressesToSendOutThroughTheAPI.append(
address)
# Done generating addresses.
2017-09-21 17:24:51 +02:00
if command == 'createDeterministicAddresses' \
or command == 'joinChan' or command == 'createChan':
queues.apiAddressGeneratorReturnQueue.put(
listOfNewAddressesToSendOutThroughTheAPI)
elif command == 'getDeterministicAddress':
queues.apiAddressGeneratorReturnQueue.put(address)
else:
raise Exception(
2017-09-21 17:24:51 +02:00
"Error in the addressGenerator thread. Thread was" +
" given a command it could not understand: " + command)
queues.addressGeneratorQueue.task_done()