from electrum.util import print_error import socket import requests import threading import hashlib import json try: import PyQt4 except Exception: sys.exit("Error: Could not import PyQt4 on Linux systems, you may try 'sudo apt-get install python-qt4'") from PyQt4.QtGui import * from PyQt4.QtCore import * import PyQt4.QtCore as QtCore import PyQt4.QtGui as QtGui import aes import base64 import electrum from electrum.plugins import BasePlugin, hook from electrum.i18n import _ from electrum_gui.qt import HelpButton, EnterButton from electrum_gui.qt.util import ThreadedButton, Buttons, CancelButton, OkButton class Plugin(BasePlugin): target_host = 'labelectrum.herokuapp.com' encode_password = None def fullname(self): return _('Label Sync') def description(self): return '%s\n\n%s%s%s' % (_("This plugin can sync your labels across multiple Electrum installs by using a remote database to save your data. Labels, transactions ids and addresses are encrypted before they are sent to the remote server. This code might increase the load of your wallet with a few microseconds as it will sync labels on each startup."), _("To get started visit"), " http://labelectrum.herokuapp.com/ ", _(" to sign up for an account.")) def version(self): return "0.2.1" def encode(self, message): encrypted = electrum.bitcoin.aes_encrypt_with_iv(self.encode_password, self.iv, message.encode('utf8')) encoded_message = base64.b64encode(encrypted) return encoded_message def decode(self, message): decoded_message = electrum.bitcoin.aes_decrypt_with_iv(self.encode_password, self.iv, base64.b64decode(message)).decode('utf8') return decoded_message @hook def init_qt(self, gui): self.window = gui.main_window if not self.auth_token(): # First run, throw plugin settings in your face self.load_wallet(self.window.wallet) if self.settings_dialog(): self.set_enabled(True) return True else: self.set_enabled(False) return False self.window.connect(self.window, SIGNAL('labels:pulled'), self.on_pulled) @hook def load_wallet(self, wallet): self.wallet = wallet mpk = ''.join(sorted(self.wallet.get_master_public_keys().values())) self.encode_password = hashlib.sha1(mpk).digest().encode('hex')[:32] self.iv = hashlib.sha256(self.encode_password).digest()[:16] self.wallet_id = hashlib.sha256(mpk).digest().encode('hex') addresses = [] for account in self.wallet.accounts.values(): for address in account.get_addresses(0): addresses.append(address) self.addresses = addresses if self.auth_token(): # If there is an auth token we can try to actually start syncing def do_pull_thread(): try: self.pull_thread() except: print_error("could not retrieve labels") t = threading.Thread(target=do_pull_thread) t.setDaemon(True) t.start() def auth_token(self): return self.config.get("plugin_label_api_key") def is_available(self): return True def requires_settings(self): return True @hook def set_label(self, item,label, changed): if self.encode_password is None: return if not changed: return bundle = {"label": {"external_id": self.encode(item), "text": self.encode(label)}} t = threading.Thread(target=self.do_request, args=["POST", False, bundle]) t.start() def settings_widget(self, window): return EnterButton(_('Settings'), self.settings_dialog) def settings_dialog(self): def check_for_api_key(api_key): if api_key and len(api_key) > 12: self.config.set_key("plugin_label_api_key", str(self.auth_token_edit.text())) self.upload.setEnabled(True) self.download.setEnabled(True) self.accept.setEnabled(True) else: self.upload.setEnabled(False) self.download.setEnabled(False) self.accept.setEnabled(False) d = QDialog() vbox = QVBoxLayout(d) layout = QGridLayout() vbox.addLayout(layout) layout.addWidget(QLabel("API Key: "), 0, 0) self.auth_token_edit = QLineEdit(self.auth_token()) self.auth_token_edit.textChanged.connect(check_for_api_key) layout.addWidget(QLabel("Label sync options: "),2,0) layout.addWidget(self.auth_token_edit, 0,1,1,2) decrypt_key_text = QLineEdit(self.encode_password) decrypt_key_text.setReadOnly(True) layout.addWidget(decrypt_key_text, 1,1) layout.addWidget(QLabel("Decryption key: "),1,0) layout.addWidget(HelpButton("This key can be used on the LabElectrum website to decrypt your data in case you want to review it online."),1,2) self.upload = ThreadedButton("Force upload", self.push_thread, self.done_processing) layout.addWidget(self.upload, 2, 1) self.download = ThreadedButton("Force download", self.pull_thread, self.done_processing) layout.addWidget(self.download, 2, 2) self.accept = OkButton(d, _("Done")) vbox.addLayout(Buttons(CancelButton(d), self.accept)) check_for_api_key(self.auth_token()) if d.exec_(): return True else: return False def on_pulled(self): wallet = self.wallet wallet.storage.put('labels', wallet.labels, True) self.window.labelsChanged.emit() def done_processing(self): QMessageBox.information(None, _("Labels synchronised"), _("Your labels have been synchronised.")) def do_request(self, method, is_batch=False, data=None): url = 'http://' + self.target_host + "/api/wallets/%s/%s?auth_token=%s" % (self.wallet_id, 'labels/batch.json' if is_batch else 'labels.json', self.auth_token()) kwargs = {'headers': {}} if method == 'GET' and data: kwargs['params'] = data elif method == 'POST' and data: kwargs['data'] = json.dumps(data) kwargs['headers']['Content-Type'] = 'application/json' response = requests.request(method, url, **kwargs) if response.status_code != 200: raise BaseException(response.status_code, response.text) response = response.json() if "error" in response: raise BaseException(response["error"]) return response def push_thread(self): bundle = {"labels": {}} for key, value in self.wallet.labels.iteritems(): try: encoded_key = self.encode(key) encoded_value = self.encode(value) except: print_error('cannot encode', repr(key), repr(value)) continue bundle["labels"][encoded_key] = encoded_value response = self.do_request("POST", True, bundle) self.window.emit(SIGNAL('labels:pushed')) def pull_thread(self, force = False): response = self.do_request("GET") result = {} for label in response: try: key = self.decode(label["external_id"]) value = self.decode(label["text"]) except: continue try: json.dumps(key) json.dumps(value) except: print_error('error: no json', key) continue result[key] = value wallet = self.wallet if not wallet: return for key, value in result.items(): if force or not wallet.labels.get(key): wallet.labels[key] = value self.window.emit(SIGNAL('labels:pulled')) print_error("received %d labels"%len(response))