Here is yur modified code so far, ugly as hell lol:
Code:
################################################################################
#
# Copyright (C) 2012, Ian Coleman
# Distributed under the GNU Affero General Public License (AGPL v3)
# See http://www.gnu.org/licenses/agpl.html
#
################################################################################
from twisted.web import server
from twisted.internet import reactor
from txjsonrpc.web import jsonrpc
import decimal
import os
RPC_PORT = 7070
STANDARD_FEE = 0.0005 # BTC
class Wallet_Json_Rpc_Server(jsonrpc.JSONRPC):
def __init__(self, wallet):
self.wallet = wallet
def jsonrpc_getnewaddress(self):
addr = self.wallet.getNextUnusedAddress()
return addr.getAddrStr()
def jsonrpc_getbalance(self):
int_balance = self.wallet.getBalance()
decimal_balance = decimal.Decimal(int_balance) / decimal.Decimal(ONE_BTC)
return float(decimal_balance)
def jsonrpc_getreceivedbyaddress(self, address):
if CLI_OPTIONS.offline:
raise ValueError('Cannot get received amount when offline')
# Only gets correct amount for addresses in the wallet, otherwise 0
addr160 = addrStr_to_hash160(address)
txs = self.wallet.getAddrTxLedger(addr160)
balance = sum([x.getValue() for x in txs if x.getValue() > 0])
decimal_balance = decimal.Decimal(balance) / decimal.Decimal(ONE_BTC)
float_balance = float(decimal_balance)
return float_balance
def jsonrpc_sendtoaddress(self, bitcoinaddress, amount):
if CLI_OPTIONS.offline:
raise ValueError('Cannot create transactions when offline')
return self.create_unsigned_transaction(bitcoinaddress, amount)
def jsonrpc_listtransactions(self, p_count=10, p_from=0):
#TODO this needs more work
result2 = []
txs = self.wallet.getTxLedger('blk')
#txs = json.dumps(txs)
#id_le_pairs = [[le] for le in txs]
for x in txs:
#result.append('{')
account = ''
txHashBin = x.getTxHash()#hex_to_binary(x.getTxHash())
cppTx = TheBDM.getTxByHash(txHashBin)
pytx = PyTx().unserialize(cppTx.serialize())
for txout in pytx.outputs:
scrType = getTxOutScriptType(txout.binScript)
if not scrType in (TXOUT_SCRIPT_STANDARD, TXOUT_SCRIPT_COINBASE):
continue
address = hash160_to_addrStr(TxOutScriptExtractAddr160(txout.binScript))
if x.getValue() < 0:
category = 'send'
else:
category = 'receive'
amount = x.getValue()
confirmations = TheBDM.getTopBlockHeader().getBlockHeight() - x.getBlockNum()+1
blockhash = ''
blockindex = ''#x.getBlockNum()
txid = str(binary_to_hex(x.getTxHash()))
time = ''#x.getTxTime()
result = {'account':account,'address':address,'category':category,'amount':amount,'confirmations':confirmations,'blockhash':blockhash,'blockindex':blockindex,'txid':txid,'time:':time}
#result.append('}')
result2.append(result)
#print addr
#dumpObj(x)
#result = json.dumps(result)
return result2
# https://bitcointalk.org/index.php?topic=92496.msg1126310#msg1126310
def create_unsigned_transaction(self, bitcoinaddress_str, amount_to_send_btc):
# Get unspent TxOutList and select the coins
addr160_recipient = addrStr_to_hash160(bitcoinaddress_str)
totalSend, fee = long(amount_to_send_btc * ONE_BTC), (STANDARD_FEE * ONE_BTC)
spendBal = self.wallet.getBalance('Spendable')
utxoList = self.wallet.getTxOutList('Spendable')
utxoSelect = PySelectCoins(utxoList, totalSend, fee)
minFeeRec = calcMinSuggestedFees(utxoSelect, totalSend, fee)[1]
if fee
raise NotEnoughCoinsError, "You can't afford the fee!"
utxoSelect = PySelectCoins(utxoList, totalSend, minFeeRec)
fee = minFeeRec
if len(utxoSelect)==0:
raise CoinSelectError, "Somehow, coin selection failed. This shouldn't happen"
totalSelected = sum([u.getValue() for u in utxoSelect])
totalChange = totalSelected - (totalSend + fee)
outputPairs = []
outputPairs.append( [addr160_recipient, totalSend] )
if totalChange > 0:
outputPairs.append( [self.wallet.getNextUnusedAddress().getAddr160(), totalChange] )
random.shuffle(outputPairs)
txdp = PyTxDistProposal().createFromTxOutSelection(utxoSelect, outputPairs)
return txdp.serializeAscii()
def jsonrpc_createCombinedLedger(self, wltIDList=None, withZeroConf=True):
"""
Create a ledger to display on the main screen, that consists of ledger
entries of any SUBSET of available wallets.
"""
start = RightNow()
self.combinedLedger = []
totalFunds = 0
spendFunds = 0
unconfFunds = 0
currBlk = 0xffffffff
if TheBDM.isInitialized():
currBlk = TheBDM.getTopBlockHeader().getBlockHeight()
wlt = self.waldlet
totalFunds += wlt.getBalance('Total')
spendFunds += wlt.getBalance('Spendable')
unconfFunds += wlt.getBalance('Unconfirmed')
self.combinedLedger.sort(key=lambda x: x[LEDGERCOLS.UnixTime], reverse=True)
self.ledgerSize = len(self.combinedLedger)
print totalFunds
return
class Armory_Daemon():
def __init__(self):
print "Reading wallet file"
self.wallet = self.find_wallet()
self.loadBlockchain()
use_blockchain = not CLI_OPTIONS.offline
print "Initialising server"
reactor.listenTCP(RPC_PORT, server.Site(Wallet_Json_Rpc_Server(self.wallet)))
self.NetworkingFactory = ArmoryClientFactory( \
func_loseConnect=self.showOfflineMsg, \
func_madeConnect=self.showOnlineMsg, \
func_newTx=self.newTxFunc)
reactor.connectTCP('127.0.0.1', BITCOIN_PORT, self.NetworkingFactory)
reactor.callLater(5, self.Heartbeat)
self.start()
def start(self):
print "Server started"
reactor.run()
def newTxFunc(self, pytxObj):
# Cut down version from ArmoryQt.py
TheBDM.addNewZeroConfTx(pytxObj.serialize(), long(RightNow()), True)
TheBDM.rescanWalletZeroConf(self.wallet.cppWallet)
# TODO set up a 'subscribe' feature so these notifications can be
# pushed out to interested parties.
# From here down is display purposes only, copied from ArmoryQt.py
message = "New TX"
le = self.wallet.cppWallet.calcLedgerEntryForTxStr(pytxObj.serialize())
if not le.isSentToSelf():
txref = TheBDM.getTxByHash(le.getTxHash())
nOut = txref.getNumTxOut()
recips = [txref.getTxOut(i).getRecipientAddr() for i in range(nOut)]
values = [txref.getTxOut(i).getValue() for i in range(nOut)]
idxMine = filter(lambda i: self.wallet.hasAddr(recips[i]), range(nOut))
idxOther = filter(lambda i: not self.wallet.hasAddr(recips[i]), range(nOut))
mine = [(recips[i],values[i]) for i in idxMine]
other = [(recips[i],values[i]) for i in idxOther]
# Collected everything we need to display, now construct it and do it
if le.getValue()>0:
# Received!
message = 'Bitcoins Received!'
totalStr = coin2str( sum([mine[i][1] for i in range(len(mine))]), maxZeros=1)
message += '\nAmount: \t%s BTC' % totalStr.strip()
if len(mine)==1:
message += '\nAddress:\t%s' % hash160_to_addrStr(mine[0][0])
addrComment = self.wallet.getComment(mine[0][0])
#if addrComment:
#message += '\n%s...' % addrComment[:24]
else:
message += '\n'
elif le.getValue()<0:
# Sent!
message = 'Bitcoins Sent!'
totalStr = coin2str( sum([other[i][1] for i in range(len(other))]), maxZeros=1)
message += '\nAmount: \t%s BTC' % totalStr.strip()
if len(other)==1:
message += 'Sent To:\t%s' % hash160_to_addrStr(other[0][0])
addrComment = self.wallet.getComment(other[0][0])
#if addrComment:
#message += '\n%s...' % addrComment[:24]
else:
dispLines.append('')
else:
amt = self.determineSentToSelfAmt(le, self.wallet)[0]
message = 'Wallet "%s" just sent %s BTC to itself!' % \
(self.wallet.labelName, coin2str(amt,maxZeros=1).strip())
print message
def determineSentToSelfAmt(self, le, wlt):
"""
NOTE: this method works ONLY because we always generate a new address
whenever creating a change-output, which means it must have a
higher chainIndex than all other addresses. If you did something
creative with this tx, this may not actually work.
"""
amt = 0
if TheBDM.isInitialized() and le.isSentToSelf():
txref = TheBDM.getTxByHash(le.getTxHash())
if not txref.isInitialized():
return (0, 0)
if txref.getNumTxOut()==1:
return (txref.getTxOut(0).getValue(), -1)
maxChainIndex = -5
txOutChangeVal = 0
txOutIndex = -1
valSum = 0
for i in range(txref.getNumTxOut()):
valSum += txref.getTxOut(i).getValue()
addr160 = txref.getTxOut(i).getRecipientAddr()
addr = wlt.getAddrByHash160(addr160)
if addr and addr.chainIndex > maxChainIndex:
maxChainIndex = addr.chainIndex
txOutChangeVal = txref.getTxOut(i).getValue()
txOutIndex = i
amt = valSum - txOutChangeVal
return (amt, txOutIndex)
def showOfflineMsg(self):
print "Offline - not tracking blockchain"
def showOnlineMsg(self):
print "Online - tracking blockchain"
def find_wallet(self):
fnames = os.listdir(os.getcwd())
for fname in fnames:
is_wallet = fname[-7:] == ".wallet"
is_watchonly = fname.find("watchonly") > -1
is_backup = fname.find("backup") > -1
if(is_wallet and is_watchonly and not is_backup):
wallet = PyBtcWallet().readWalletFile(fname)
# Register all wallets with TheBDM
TheBDM.registerWallet( wallet.cppWallet )
print "Using wallet file %s" % fname
return wallet
raise ValueError('Unable to locate a watch-only wallet in %s' % os.getcwd())
def loadBlockchain(self):
print "Loading blockchain"
BDM_LoadBlockchainFile()
self.latestBlockNum = TheBDM.getTopBlockHeader().getBlockHeight()
# Now that theb blockchain is loaded, let's populate the wallet info
if TheBDM.isInitialized():
mempoolfile = os.path.join(ARMORY_HOME_DIR,'mempool.bin')
self.checkMemoryPoolCorruption(mempoolfile)
TheBDM.enableZeroConf(mempoolfile)
# self.statusBar().showMessage('Syncing wallets with blockchain...')
print "Syncing wallets with blockchain..."
print "Syncing wallet: ", self.wallet.uniqueIDB58
self.wallet.setBlockchainSyncFlag(BLOCKCHAIN_READONLY)
self.wallet.syncWithBlockchain()
#self.createCombinedLedger()
#self.ledgerSize = len(self.combinedLedger)
#self.statusBar().showMessage('Blockchain loaded, wallets sync\'d!', 10000)
def checkMemoryPoolCorruption(self, mempoolname):
if not os.path.exists(mempoolname):
return
memfile = open(mempoolname, 'r')
memdata = memfile.read()
memfile.close()
binunpacker = BinaryUnpacker(memdata)
try:
while binunpacker.getRemainingSize() > 0:
binunpacker.get(UINT64)
PyTx().unserialize(binunpacker)
except:
os.remove(mempoolname);
LOGWARN('Memory pool file was corrupt. Deleted. (no further action is needed)')
def Heartbeat(self, nextBeatSec=2):
"""
This method is invoked when the app is initialized, and will
run every 2 seconds, or whatever is specified in the nextBeatSec
argument.
"""
# Check for new blocks in the blk0001.dat file
if TheBDM.isInitialized():
newBlks = TheBDM.readBlkFileUpdate()
self.topTimestamp = TheBDM.getTopBlockHeader().getTimestamp()
if newBlks>0:
self.latestBlockNum = TheBDM.getTopBlockHeader().getBlockHeight()
LOGINFO('New Block! : %d', self.latestBlockNum)
didAffectUs = False
prevLedgerSize = len(self.wallet.getTxLedger())
self.wallet.syncWithBlockchain()
TheBDM.rescanWalletZeroConf(self.cppWallet)
self.wallet.checkWalletLockTimeout()
reactor.callLater(nextBeatSec, self.Heartbeat)
## {{{ http://code.activestate.com/recipes/137951/ (r1)
def printDict(di, format="%-25s %s"):
for (key, val) in di.items():
print format % (str(key)+':', val)
def delchars(str, chars):
"""Returns a string for which all occurrences of characters in
chars have been removed."""
# Translate demands a mapping string of 256 characters;
# whip up a string that will leave all characters unmolested.
identity = ''.join([chr(x) for x in range(256)])
return str.translate(identity, chars)
## end of http://code.activestate.com/recipes/137951/ }}}
if __name__ == "__main__":
from armoryengine import *
rpc_server = Armory_Daemon()
#
# Copyright (C) 2012, Ian Coleman
# Distributed under the GNU Affero General Public License (AGPL v3)
# See http://www.gnu.org/licenses/agpl.html
#
################################################################################
from twisted.web import server
from twisted.internet import reactor
from txjsonrpc.web import jsonrpc
import decimal
import os
RPC_PORT = 7070
STANDARD_FEE = 0.0005 # BTC
class Wallet_Json_Rpc_Server(jsonrpc.JSONRPC):
def __init__(self, wallet):
self.wallet = wallet
def jsonrpc_getnewaddress(self):
addr = self.wallet.getNextUnusedAddress()
return addr.getAddrStr()
def jsonrpc_getbalance(self):
int_balance = self.wallet.getBalance()
decimal_balance = decimal.Decimal(int_balance) / decimal.Decimal(ONE_BTC)
return float(decimal_balance)
def jsonrpc_getreceivedbyaddress(self, address):
if CLI_OPTIONS.offline:
raise ValueError('Cannot get received amount when offline')
# Only gets correct amount for addresses in the wallet, otherwise 0
addr160 = addrStr_to_hash160(address)
txs = self.wallet.getAddrTxLedger(addr160)
balance = sum([x.getValue() for x in txs if x.getValue() > 0])
decimal_balance = decimal.Decimal(balance) / decimal.Decimal(ONE_BTC)
float_balance = float(decimal_balance)
return float_balance
def jsonrpc_sendtoaddress(self, bitcoinaddress, amount):
if CLI_OPTIONS.offline:
raise ValueError('Cannot create transactions when offline')
return self.create_unsigned_transaction(bitcoinaddress, amount)
def jsonrpc_listtransactions(self, p_count=10, p_from=0):
#TODO this needs more work
result2 = []
txs = self.wallet.getTxLedger('blk')
#txs = json.dumps(txs)
#id_le_pairs = [[le] for le in txs]
for x in txs:
#result.append('{')
account = ''
txHashBin = x.getTxHash()#hex_to_binary(x.getTxHash())
cppTx = TheBDM.getTxByHash(txHashBin)
pytx = PyTx().unserialize(cppTx.serialize())
for txout in pytx.outputs:
scrType = getTxOutScriptType(txout.binScript)
if not scrType in (TXOUT_SCRIPT_STANDARD, TXOUT_SCRIPT_COINBASE):
continue
address = hash160_to_addrStr(TxOutScriptExtractAddr160(txout.binScript))
if x.getValue() < 0:
category = 'send'
else:
category = 'receive'
amount = x.getValue()
confirmations = TheBDM.getTopBlockHeader().getBlockHeight() - x.getBlockNum()+1
blockhash = ''
blockindex = ''#x.getBlockNum()
txid = str(binary_to_hex(x.getTxHash()))
time = ''#x.getTxTime()
result = {'account':account,'address':address,'category':category,'amount':amount,'confirmations':confirmations,'blockhash':blockhash,'blockindex':blockindex,'txid':txid,'time:':time}
#result.append('}')
result2.append(result)
#print addr
#dumpObj(x)
#result = json.dumps(result)
return result2
# https://bitcointalk.org/index.php?topic=92496.msg1126310#msg1126310
def create_unsigned_transaction(self, bitcoinaddress_str, amount_to_send_btc):
# Get unspent TxOutList and select the coins
addr160_recipient = addrStr_to_hash160(bitcoinaddress_str)
totalSend, fee = long(amount_to_send_btc * ONE_BTC), (STANDARD_FEE * ONE_BTC)
spendBal = self.wallet.getBalance('Spendable')
utxoList = self.wallet.getTxOutList('Spendable')
utxoSelect = PySelectCoins(utxoList, totalSend, fee)
minFeeRec = calcMinSuggestedFees(utxoSelect, totalSend, fee)[1]
if fee
raise NotEnoughCoinsError, "You can't afford the fee!"
utxoSelect = PySelectCoins(utxoList, totalSend, minFeeRec)
fee = minFeeRec
if len(utxoSelect)==0:
raise CoinSelectError, "Somehow, coin selection failed. This shouldn't happen"
totalSelected = sum([u.getValue() for u in utxoSelect])
totalChange = totalSelected - (totalSend + fee)
outputPairs = []
outputPairs.append( [addr160_recipient, totalSend] )
if totalChange > 0:
outputPairs.append( [self.wallet.getNextUnusedAddress().getAddr160(), totalChange] )
random.shuffle(outputPairs)
txdp = PyTxDistProposal().createFromTxOutSelection(utxoSelect, outputPairs)
return txdp.serializeAscii()
def jsonrpc_createCombinedLedger(self, wltIDList=None, withZeroConf=True):
"""
Create a ledger to display on the main screen, that consists of ledger
entries of any SUBSET of available wallets.
"""
start = RightNow()
self.combinedLedger = []
totalFunds = 0
spendFunds = 0
unconfFunds = 0
currBlk = 0xffffffff
if TheBDM.isInitialized():
currBlk = TheBDM.getTopBlockHeader().getBlockHeight()
wlt = self.waldlet
totalFunds += wlt.getBalance('Total')
spendFunds += wlt.getBalance('Spendable')
unconfFunds += wlt.getBalance('Unconfirmed')
self.combinedLedger.sort(key=lambda x: x[LEDGERCOLS.UnixTime], reverse=True)
self.ledgerSize = len(self.combinedLedger)
print totalFunds
return
class Armory_Daemon():
def __init__(self):
print "Reading wallet file"
self.wallet = self.find_wallet()
self.loadBlockchain()
use_blockchain = not CLI_OPTIONS.offline
print "Initialising server"
reactor.listenTCP(RPC_PORT, server.Site(Wallet_Json_Rpc_Server(self.wallet)))
self.NetworkingFactory = ArmoryClientFactory( \
func_loseConnect=self.showOfflineMsg, \
func_madeConnect=self.showOnlineMsg, \
func_newTx=self.newTxFunc)
reactor.connectTCP('127.0.0.1', BITCOIN_PORT, self.NetworkingFactory)
reactor.callLater(5, self.Heartbeat)
self.start()
def start(self):
print "Server started"
reactor.run()
def newTxFunc(self, pytxObj):
# Cut down version from ArmoryQt.py
TheBDM.addNewZeroConfTx(pytxObj.serialize(), long(RightNow()), True)
TheBDM.rescanWalletZeroConf(self.wallet.cppWallet)
# TODO set up a 'subscribe' feature so these notifications can be
# pushed out to interested parties.
# From here down is display purposes only, copied from ArmoryQt.py
message = "New TX"
le = self.wallet.cppWallet.calcLedgerEntryForTxStr(pytxObj.serialize())
if not le.isSentToSelf():
txref = TheBDM.getTxByHash(le.getTxHash())
nOut = txref.getNumTxOut()
recips = [txref.getTxOut(i).getRecipientAddr() for i in range(nOut)]
values = [txref.getTxOut(i).getValue() for i in range(nOut)]
idxMine = filter(lambda i: self.wallet.hasAddr(recips[i]), range(nOut))
idxOther = filter(lambda i: not self.wallet.hasAddr(recips[i]), range(nOut))
mine = [(recips[i],values[i]) for i in idxMine]
other = [(recips[i],values[i]) for i in idxOther]
# Collected everything we need to display, now construct it and do it
if le.getValue()>0:
# Received!
message = 'Bitcoins Received!'
totalStr = coin2str( sum([mine[i][1] for i in range(len(mine))]), maxZeros=1)
message += '\nAmount: \t%s BTC' % totalStr.strip()
if len(mine)==1:
message += '\nAddress:\t%s' % hash160_to_addrStr(mine[0][0])
addrComment = self.wallet.getComment(mine[0][0])
#if addrComment:
#message += '\n%s...' % addrComment[:24]
else:
message += '\n
elif le.getValue()<0:
# Sent!
message = 'Bitcoins Sent!'
totalStr = coin2str( sum([other[i][1] for i in range(len(other))]), maxZeros=1)
message += '\nAmount: \t%s BTC' % totalStr.strip()
if len(other)==1:
message += 'Sent To:\t%s' % hash160_to_addrStr(other[0][0])
addrComment = self.wallet.getComment(other[0][0])
#if addrComment:
#message += '\n%s...' % addrComment[:24]
else:
dispLines.append('
else:
amt = self.determineSentToSelfAmt(le, self.wallet)[0]
message = 'Wallet "%s" just sent %s BTC to itself!' % \
(self.wallet.labelName, coin2str(amt,maxZeros=1).strip())
print message
def determineSentToSelfAmt(self, le, wlt):
"""
NOTE: this method works ONLY because we always generate a new address
whenever creating a change-output, which means it must have a
higher chainIndex than all other addresses. If you did something
creative with this tx, this may not actually work.
"""
amt = 0
if TheBDM.isInitialized() and le.isSentToSelf():
txref = TheBDM.getTxByHash(le.getTxHash())
if not txref.isInitialized():
return (0, 0)
if txref.getNumTxOut()==1:
return (txref.getTxOut(0).getValue(), -1)
maxChainIndex = -5
txOutChangeVal = 0
txOutIndex = -1
valSum = 0
for i in range(txref.getNumTxOut()):
valSum += txref.getTxOut(i).getValue()
addr160 = txref.getTxOut(i).getRecipientAddr()
addr = wlt.getAddrByHash160(addr160)
if addr and addr.chainIndex > maxChainIndex:
maxChainIndex = addr.chainIndex
txOutChangeVal = txref.getTxOut(i).getValue()
txOutIndex = i
amt = valSum - txOutChangeVal
return (amt, txOutIndex)
def showOfflineMsg(self):
print "Offline - not tracking blockchain"
def showOnlineMsg(self):
print "Online - tracking blockchain"
def find_wallet(self):
fnames = os.listdir(os.getcwd())
for fname in fnames:
is_wallet = fname[-7:] == ".wallet"
is_watchonly = fname.find("watchonly") > -1
is_backup = fname.find("backup") > -1
if(is_wallet and is_watchonly and not is_backup):
wallet = PyBtcWallet().readWalletFile(fname)
# Register all wallets with TheBDM
TheBDM.registerWallet( wallet.cppWallet )
print "Using wallet file %s" % fname
return wallet
raise ValueError('Unable to locate a watch-only wallet in %s' % os.getcwd())
def loadBlockchain(self):
print "Loading blockchain"
BDM_LoadBlockchainFile()
self.latestBlockNum = TheBDM.getTopBlockHeader().getBlockHeight()
# Now that theb blockchain is loaded, let's populate the wallet info
if TheBDM.isInitialized():
mempoolfile = os.path.join(ARMORY_HOME_DIR,'mempool.bin')
self.checkMemoryPoolCorruption(mempoolfile)
TheBDM.enableZeroConf(mempoolfile)
# self.statusBar().showMessage('Syncing wallets with blockchain...')
print "Syncing wallets with blockchain..."
print "Syncing wallet: ", self.wallet.uniqueIDB58
self.wallet.setBlockchainSyncFlag(BLOCKCHAIN_READONLY)
self.wallet.syncWithBlockchain()
#self.createCombinedLedger()
#self.ledgerSize = len(self.combinedLedger)
#self.statusBar().showMessage('Blockchain loaded, wallets sync\'d!', 10000)
def checkMemoryPoolCorruption(self, mempoolname):
if not os.path.exists(mempoolname):
return
memfile = open(mempoolname, 'r')
memdata = memfile.read()
memfile.close()
binunpacker = BinaryUnpacker(memdata)
try:
while binunpacker.getRemainingSize() > 0:
binunpacker.get(UINT64)
PyTx().unserialize(binunpacker)
except:
os.remove(mempoolname);
LOGWARN('Memory pool file was corrupt. Deleted. (no further action is needed)')
def Heartbeat(self, nextBeatSec=2):
"""
This method is invoked when the app is initialized, and will
run every 2 seconds, or whatever is specified in the nextBeatSec
argument.
"""
# Check for new blocks in the blk0001.dat file
if TheBDM.isInitialized():
newBlks = TheBDM.readBlkFileUpdate()
self.topTimestamp = TheBDM.getTopBlockHeader().getTimestamp()
if newBlks>0:
self.latestBlockNum = TheBDM.getTopBlockHeader().getBlockHeight()
LOGINFO('New Block! : %d', self.latestBlockNum)
didAffectUs = False
prevLedgerSize = len(self.wallet.getTxLedger())
self.wallet.syncWithBlockchain()
TheBDM.rescanWalletZeroConf(self.cppWallet)
self.wallet.checkWalletLockTimeout()
reactor.callLater(nextBeatSec, self.Heartbeat)
## {{{ http://code.activestate.com/recipes/137951/ (r1)
def printDict(di, format="%-25s %s"):
for (key, val) in di.items():
print format % (str(key)+':', val)
def delchars(str, chars):
"""Returns a string for which all occurrences of characters in
chars have been removed."""
# Translate demands a mapping string of 256 characters;
# whip up a string that will leave all characters unmolested.
identity = ''.join([chr(x) for x in range(256)])
return str.translate(identity, chars)
## end of http://code.activestate.com/recipes/137951/ }}}
if __name__ == "__main__":
from armoryengine import *
rpc_server = Armory_Daemon()
