9a38c4d2a1
Previously, during early-startup (until configure_logging(config) is called in run_electrum), - the stderr log handler lost all log messages below warning level, and - the file log handler lost all log messages regardless of log level We now instead start buffering log messages in memory as soon as electrum.logging is imported. The buffer is dumped into the stderr and file log handlers when they are fully set up, and then the buffer is discarded (and the temporary log handler is removed). Note that messages are not logged until configure_logging() is called. Previously WARNING/ERROR messages would get logged immediately to stderr, but not anymore. This was changed so that the order of the log messages can be kept intact. (if we log WARNINGs immediately, but need to delay INFOs until the config is available, messages would either be out of order or alternatively there would be duplicates) Relatedly, we now follow the recommendation of the python docs re logging for libraries [0]: we try to only configure logging if running via run_electrum (the main script) and not when e.g. a 3rd party script imports electrum. [0]: https://docs.python.org/3/howto/logging.html#configuring-logging-for-a-library
247 lines
8.1 KiB
Python
247 lines
8.1 KiB
Python
from decimal import Decimal
|
|
import getpass
|
|
import datetime
|
|
import logging
|
|
|
|
from electrum import util
|
|
from electrum import WalletStorage, Wallet
|
|
from electrum.wallet_db import WalletDB
|
|
from electrum.util import format_satoshis
|
|
from electrum.bitcoin import is_address, COIN
|
|
from electrum.transaction import PartialTxOutput
|
|
from electrum.network import TxBroadcastError, BestEffortRequestFailed
|
|
|
|
_ = lambda x:x # i18n
|
|
|
|
# minimal fdisk like gui for console usage
|
|
# written by rofl0r, with some bits stolen from the text gui (ncurses)
|
|
|
|
|
|
class ElectrumGui:
|
|
|
|
def __init__(self, config, daemon, plugins):
|
|
self.config = config
|
|
self.network = daemon.network
|
|
storage = WalletStorage(config.get_wallet_path())
|
|
if not storage.file_exists:
|
|
print("Wallet not found. try 'electrum create'")
|
|
exit()
|
|
if storage.is_encrypted():
|
|
password = getpass.getpass('Password:', stream=None)
|
|
storage.decrypt(password)
|
|
|
|
db = WalletDB(storage.read(), manual_upgrades=False)
|
|
|
|
self.done = 0
|
|
self.last_balance = ""
|
|
|
|
self.str_recipient = ""
|
|
self.str_description = ""
|
|
self.str_amount = ""
|
|
self.str_fee = ""
|
|
|
|
self.wallet = Wallet(db, storage, config=config)
|
|
self.wallet.start_network(self.network)
|
|
self.contacts = self.wallet.contacts
|
|
|
|
util.register_callback(self.on_network, ['wallet_updated', 'network_updated', 'banner'])
|
|
self.commands = [_("[h] - displays this help text"), \
|
|
_("[i] - display transaction history"), \
|
|
_("[o] - enter payment order"), \
|
|
_("[p] - print stored payment order"), \
|
|
_("[s] - send stored payment order"), \
|
|
_("[r] - show own receipt addresses"), \
|
|
_("[c] - display contacts"), \
|
|
_("[b] - print server banner"), \
|
|
_("[q] - quit")]
|
|
self.num_commands = len(self.commands)
|
|
|
|
def on_network(self, event, *args):
|
|
if event in ['wallet_updated', 'network_updated']:
|
|
self.updated()
|
|
elif event == 'banner':
|
|
self.print_banner()
|
|
|
|
def main_command(self):
|
|
self.print_balance()
|
|
c = input("enter command: ")
|
|
if c == "h" : self.print_commands()
|
|
elif c == "i" : self.print_history()
|
|
elif c == "o" : self.enter_order()
|
|
elif c == "p" : self.print_order()
|
|
elif c == "s" : self.send_order()
|
|
elif c == "r" : self.print_addresses()
|
|
elif c == "c" : self.print_contacts()
|
|
elif c == "b" : self.print_banner()
|
|
elif c == "n" : self.network_dialog()
|
|
elif c == "e" : self.settings_dialog()
|
|
elif c == "q" : self.done = 1
|
|
else: self.print_commands()
|
|
|
|
def updated(self):
|
|
s = self.get_balance()
|
|
if s != self.last_balance:
|
|
print(s)
|
|
self.last_balance = s
|
|
return True
|
|
|
|
def print_commands(self):
|
|
self.print_list(self.commands, "Available commands")
|
|
|
|
def print_history(self):
|
|
width = [20, 40, 14, 14]
|
|
delta = (80 - sum(width) - 4)/3
|
|
format_str = "%"+"%d"%width[0]+"s"+"%"+"%d"%(width[1]+delta)+"s"+"%" \
|
|
+ "%d"%(width[2]+delta)+"s"+"%"+"%d"%(width[3]+delta)+"s"
|
|
messages = []
|
|
|
|
for hist_item in reversed(self.wallet.get_history()):
|
|
if hist_item.tx_mined_status.conf:
|
|
timestamp = hist_item.tx_mined_status.timestamp
|
|
try:
|
|
time_str = datetime.datetime.fromtimestamp(timestamp).isoformat(' ')[:-3]
|
|
except Exception:
|
|
time_str = "unknown"
|
|
else:
|
|
time_str = 'unconfirmed'
|
|
|
|
label = self.wallet.get_label_for_txid(hist_item.txid)
|
|
messages.append(format_str % (time_str, label, format_satoshis(delta, whitespaces=True),
|
|
format_satoshis(hist_item.balance, whitespaces=True)))
|
|
|
|
self.print_list(messages[::-1], format_str%(_("Date"), _("Description"), _("Amount"), _("Balance")))
|
|
|
|
|
|
def print_balance(self):
|
|
print(self.get_balance())
|
|
|
|
def get_balance(self):
|
|
if self.wallet.network.is_connected():
|
|
if not self.wallet.up_to_date:
|
|
msg = _("Synchronizing...")
|
|
else:
|
|
c, u, x = self.wallet.get_balance()
|
|
msg = _("Balance")+": %f "%(Decimal(c) / COIN)
|
|
if u:
|
|
msg += " [%f unconfirmed]"%(Decimal(u) / COIN)
|
|
if x:
|
|
msg += " [%f unmatured]"%(Decimal(x) / COIN)
|
|
else:
|
|
msg = _("Not connected")
|
|
|
|
return(msg)
|
|
|
|
|
|
def print_contacts(self):
|
|
messages = map(lambda x: "%20s %45s "%(x[0], x[1][1]), self.contacts.items())
|
|
self.print_list(messages, "%19s %25s "%("Key", "Value"))
|
|
|
|
def print_addresses(self):
|
|
messages = map(lambda addr: "%30s %30s "%(addr, self.wallet.get_label(addr)), self.wallet.get_addresses())
|
|
self.print_list(messages, "%19s %25s "%("Address", "Label"))
|
|
|
|
def print_order(self):
|
|
print("send order to " + self.str_recipient + ", amount: " + self.str_amount \
|
|
+ "\nfee: " + self.str_fee + ", desc: " + self.str_description)
|
|
|
|
def enter_order(self):
|
|
self.str_recipient = input("Pay to: ")
|
|
self.str_description = input("Description : ")
|
|
self.str_amount = input("Amount: ")
|
|
self.str_fee = input("Fee: ")
|
|
|
|
def send_order(self):
|
|
self.do_send()
|
|
|
|
def print_banner(self):
|
|
for i, x in enumerate(self.wallet.network.banner.split('\n')):
|
|
print(x)
|
|
|
|
def print_list(self, lst, firstline):
|
|
lst = list(lst)
|
|
self.maxpos = len(lst)
|
|
if not self.maxpos: return
|
|
print(firstline)
|
|
for i in range(self.maxpos):
|
|
msg = lst[i] if i < len(lst) else ""
|
|
print(msg)
|
|
|
|
|
|
def main(self):
|
|
while self.done == 0: self.main_command()
|
|
|
|
def do_send(self):
|
|
if not is_address(self.str_recipient):
|
|
print(_('Invalid Bitcoin address'))
|
|
return
|
|
try:
|
|
amount = int(Decimal(self.str_amount) * COIN)
|
|
except Exception:
|
|
print(_('Invalid Amount'))
|
|
return
|
|
try:
|
|
fee = int(Decimal(self.str_fee) * COIN)
|
|
except Exception:
|
|
print(_('Invalid Fee'))
|
|
return
|
|
|
|
if self.wallet.has_password():
|
|
password = self.password_dialog()
|
|
if not password:
|
|
return
|
|
else:
|
|
password = None
|
|
|
|
c = ""
|
|
while c != "y":
|
|
c = input("ok to send (y/n)?")
|
|
if c == "n": return
|
|
|
|
try:
|
|
tx = self.wallet.mktx(outputs=[PartialTxOutput.from_address_and_value(self.str_recipient, amount)],
|
|
password=password,
|
|
fee=fee)
|
|
except Exception as e:
|
|
print(repr(e))
|
|
return
|
|
|
|
if self.str_description:
|
|
self.wallet.set_label(tx.txid(), self.str_description)
|
|
|
|
print(_("Please wait..."))
|
|
try:
|
|
self.network.run_from_another_thread(self.network.broadcast_transaction(tx))
|
|
except TxBroadcastError as e:
|
|
msg = e.get_message_for_gui()
|
|
print(msg)
|
|
except BestEffortRequestFailed as e:
|
|
msg = repr(e)
|
|
print(msg)
|
|
else:
|
|
print(_('Payment sent.'))
|
|
#self.do_clear()
|
|
#self.update_contacts_tab()
|
|
|
|
def network_dialog(self):
|
|
print("use 'electrum setconfig server/proxy' to change your network settings")
|
|
return True
|
|
|
|
|
|
def settings_dialog(self):
|
|
print("use 'electrum setconfig' to change your settings")
|
|
return True
|
|
|
|
def password_dialog(self):
|
|
return getpass.getpass()
|
|
|
|
|
|
# XXX unused
|
|
|
|
def run_receive_tab(self, c):
|
|
#if c == 10:
|
|
# out = self.run_popup('Address', ["Edit label", "Freeze", "Prioritize"])
|
|
return
|
|
|
|
def run_contacts_tab(self, c):
|
|
pass
|