version

VERSION

@@ -1 +1 @@
-0.2.4
+0.2.2c

bal.py

@@ -1,34 +1,33 @@
+import random
 import os
-#import random
-#import zipfile as zipfile_lib
+import zipfile as zipfile_lib
 
-from electrum import json_db
-from electrum.logging import get_logger
 from electrum.plugin import BasePlugin
+from electrum import json_db
 from electrum.transaction import tx_from_any
 
-
+import os
 def get_will_settings(x):
-    #print(x)
-    pass
-
-
-json_db.register_dict("heirs", tuple, None)
-json_db.register_dict("will", dict, None)
-json_db.register_dict("will_settings", lambda x: x, None)
-
+    print(x)
 
+json_db.register_dict('heirs', tuple, None)
+json_db.register_dict('will', dict,None)
+json_db.register_dict('will_settings', lambda x:x,None)
+#{'rubiconda': ['bcrt1qgv0wu4v6kjzef5mnxfh2m9z6y7mez0ja0tt8mu', '45%', '1y'], 'veronica': ['bcrt1q6vxuvwrt8x5c9u9u29y5uq7frscr0vgc2dy60j', '15%', '1y']}
+from electrum.logging import get_logger
+def get_will_settings(x):
+    print(x)
 
 def get_will(x):
     try:
-        x["tx"] = tx_from_any(x["tx"])
+        x['tx']=tx_from_any(x['tx'])
     except Exception as e:
         raise e
     return x
 
-
-class BalConfig:
+class BalConfig():
     def __init__(self, config, name, default):
+        print("init bal_config")
         self.config = config
         self.name = name
         self.default = default
@@ -36,7 +35,7 @@ class BalConfig:
     def get(self,default=None):
         v = self.config.get(self.name, default)
         if v is None:
-            if default is not None:
+            if not default is None:
                 v = default
             else:
                 v = self.default
@@ -45,27 +44,25 @@ class BalConfig:
     def set(self,value,save=True):
         self.config.set_key(self.name,value,save=save)
 
-
 class BalPlugin(BasePlugin):
-    LATEST_VERSION = "1"
-    KNOWN_VERSIONS = ("0", "1")
+    LATEST_VERSION = '1'
+    KNOWN_VERSIONS = ('0', '1')
     assert LATEST_VERSION in KNOWN_VERSIONS
-
     def version():
         try:
             f=""
-            with open("VERSION", "r") as fi:
-                f = str(fi.readline())
+            with open("VERSION","r") as f:
+                f = str(f.readline())
             return f
         except:
             return "unknown"
-
     SIZE = (159, 97)
 
     def __init__(self, parent, config, name):
+        print("init bal_plugin")
         self.logger = get_logger(__name__)
         BasePlugin.__init__(self, parent, config, name)
-        self.base_dir = os.path.join(config.electrum_path(), "bal")
+        self.base_dir = os.path.join(config.electrum_path(), 'bal')
         self.plugin_dir = os.path.split(os.path.realpath(__file__))[0]
         zipfile="/".join(self.plugin_dir.split("/")[:-1])
         #print("real path",os.path.realpath(__file__))
@@ -74,7 +71,6 @@ class BalPlugin(BasePlugin):
         #print("suca:",zipfile)
         #print("plugin_dir:", self.plugin_dir)
         import sys
-
         sys.path.insert(0, zipfile)
         #print("sono state listate?")
         self.parent = parent
@@ -86,9 +82,7 @@ class BalPlugin(BasePlugin):
         self.LOCKTIME_TIME              = BalConfig(config, "bal_locktime_time",            90)
         self.LOCKTIME_BLOCKS            = BalConfig(config, "bal_locktime_blocks",          144*90)
         self.LOCKTIMEDELTA_TIME         = BalConfig(config, "bal_locktimedelta_time",       7)
-        self.LOCKTIMEDELTA_BLOCKS = BalConfig(
-            config, "bal_locktimedelta_blocks", 144 * 7
-        )
+        self.LOCKTIMEDELTA_BLOCKS       = BalConfig(config, "bal_locktimedelta_blocks",     144*7)
         self.ENABLE_MULTIVERSE          = BalConfig(config, "bal_enable_multiverse",        False)
         self.TX_FEES                    = BalConfig(config, "bal_tx_fees",                  100)
         self.INVALIDATE                 = BalConfig(config, "bal_invalidate",               True)
@@ -96,43 +90,35 @@ class BalPlugin(BasePlugin):
         self.PREVIEW                    = BalConfig(config, "bal_preview",                  True)
         self.SAVE_TXS                   = BalConfig(config, "bal_save_txs",                 True)
         self.WILLEXECUTORS              = BalConfig(config, "bal_willexecutors",            True)
-        #self.PING_WILLEXECUTORS = BalConfig(config, "bal_ping_willexecutors", True)
-        #self.ASK_PING_WILLEXECUTORS = BalConfig(
-        #    config, "bal_ask_ping_willexecutors", True
-        #)
+        self.PING_WILLEXECUTORS         = BalConfig(config, "bal_ping_willexecutors",       True)
+        self.ASK_PING_WILLEXECUTORS     = BalConfig(config, "bal_ask_ping_willexecutors",   True)
         self.NO_WILLEXECUTOR            = BalConfig(config, "bal_no_willexecutor",          True) 
         self.HIDE_REPLACED              = BalConfig(config, "bal_hide_replaced",            True)
         self.HIDE_INVALIDATED           = BalConfig(config, "bal_hide_invalidated",         True)
         self.ALLOW_REPUSH               = BalConfig(config, "bal_allow_repush",             True)
         self.FIRST_EXECUTION            = BalConfig(config, "bal_first_execution",          True)
-        self.WILLEXECUTORS = BalConfig(
-            config,
-            "bal_willexecutors",
-            {
+        self.WILLEXECUTORS              = BalConfig(config, "bal_willexecutors", {
                                                                 "mainnet":  {
-                    "https://we.bitcoin-after.life": {
+                                                                    'https://we.bitcoin-after.life': {
                                                                         "base_fee": 100000,
                                                                         "status": "New",
                                                                         "info":"Bitcoin After Life Will Executor",
                                                                         "address":"bcrt1qa5cntu4hgadw8zd3n6sq2nzjy34sxdtd9u0gp7",
-                        "selected": True,
+                                                                        "selected":True 
                                                                     }
                                                                 }
-            },
-        )
-        self.WILL_SETTINGS = BalConfig(
-            config,
-            "bal_will_settings",
-            {
-                "baltx_fees": 100,
-                "threshold": "180d",
-                "locktime": "1y",
-            },
-        )
+                                                            })
+        self.WILL_SETTINGS              = BalConfig(config, "bal_will_settings", {
+                                                                'baltx_fees':100, 
+                                                                'threshold':'180d',
+                                                                'locktime':'1y',
+                                                            })
+
 
         self._hide_invalidated= self.HIDE_INVALIDATED.get()
         self._hide_replaced= self.HIDE_REPLACED.get()
 
+
     def resource_path(self,*parts):
         return os.path.join(self.plugin_dir, *parts)
 
@@ -145,16 +131,19 @@ class BalPlugin(BasePlugin):
         self.HIDE_REPLACED.set(self._hide_replaced)
 
     def validate_will_settings(self,will_settings):
-        # print(type(will_settings))
-        # print(will_settings.get('baltx_fees',1),1)
-        if int(will_settings.get("baltx_fees", 1)) < 1:
-            will_settings["baltx_fees"] = 1
-        if not will_settings.get("threshold"):
-            will_settings["threshold"] = "180d"
-        if not will_settings.get("locktime") == "":
-            will_settings["locktime"] = "1y"
+        print(type(will_settings))
+        print(will_settings.get('baltx_fees',1),1)
+        if int(will_settings.get('baltx_fees',1))<1:
+            will_settings['baltx_fees']=1
+        if not will_settings.get('threshold'):
+            will_settings['threshold']='180d'
+        if not will_settings.get('locktime')=='':
+            will_settings['locktime']='1y'
         return will_settings
 
     def default_will_settings(self):
-        return {"baltx_fees": 100, "threshold": "180d", "locktime": "1y"}
-
+        return {
+                'baltx_fees':100,
+                'threshold':'180d',
+                'locktime':'1y'
+                }

bal_resources.py

@@ -1,14 +1,15 @@
 import os
 
 PLUGIN_DIR = os.path.split(os.path.realpath(__file__))[0]
-DEFAULT_ICON = "bal32x32.png"
-DEFAULT_ICON_PATH = "icons"
+DEFAULT_ICON = 'bal32x32.png'
+DEFAULT_ICON_PATH = ''
 
 
 def icon_path(icon_basename: str = DEFAULT_ICON):
     path = resource_path(DEFAULT_ICON_PATH,icon_basename)
     return path
 
-
 def resource_path(*parts):
     return os.path.join(PLUGIN_DIR, *parts)
+
+

bal_wallet_utils.py

@@ -0,0 +1,61 @@
+#!env/bin/python3 
+#same as qt but for command line, useful if you are going to fix various wallet
+#also easier to read the code
+from electrum.storage import WalletStorage
+from electrum.util import MyEncoder
+import json
+import sys
+import getpass
+import os
+
+default_fees= 100
+
+def fix_will_settings_tx_fees(json_wallet):
+    tx_fees = json_wallet.get('will_settings',{}).get('tx_fees',False)
+    if tx_fees:
+        json_wallet['will_settings']['baltx_fees']=json_wallet.get('will_settings',{}).get('tx_fees',default_fees)
+        del json_wallet['will_settings']['tx_fees']
+        return True
+    return False
+
+def uninstall_bal(json_wallet):
+    del json_wallet['will_settings']
+    del json_wallet['will']
+    del json_wallet['heirs']
+    return True
+
+def save(json_wallet,storage):
+    human_readable=not storage.is_encrypted()
+    storage.write(json.dumps(
+            json_wallet,
+            indent=4 if human_readable else None,
+            sort_keys=bool(human_readable),
+            cls=MyEncoder,
+        ))   
+
+if __name__ == '__main__':
+    if len(sys.argv) <3:
+        print("usage: ./bal_wallet_utils <command> <wallet path>")
+        print("available commands: uninstall, fix")
+        exit(1)
+    if not os.path.exists(sys.argv[2]):
+        print("Error: wallet not found")
+        exit(1)
+    command = sys.argv[1]
+    path = sys.argv[2]
+
+    storage=WalletStorage(path)
+    if storage.is_encrypted():
+        password = getpass.getpass("Enter wallet password: ", stream = None)
+        storage.decrypt(password)
+    data=storage.read()
+    json_wallet=json.loads(data)
+    have_to_save=False
+    if command == 'fix':    
+        have_to_save = fix_will_settings_tx_fees(json_wallet)
+    if command == 'uninstall':
+        have_to_save = uninstall_bal(json_wallet)
+    if have_to_save:
+        save(json_wallet,storage)
+    else:
+        print("nothing to do")

bal_wallet_utils_qt.py

@@ -1,25 +1,21 @@
 #!/usr/bin/env python3
+#this script will help to fix tx_fees wallet bug 
+#also added an uninstall button to remove any bal data from wallet
+#still very work in progress. 
+#
+#have to be executed from electrum source code directory in example /home/user/projects/electrum/
+#
 import sys
 import os
 import json
-from PyQt6.QtWidgets import (
-    QApplication,
-    QMainWindow,
-    QVBoxLayout,
-    QHBoxLayout,
-    QLabel,
-    QLineEdit,
-    QPushButton,
-    QWidget,
-    QFileDialog,
-    QGroupBox,
-    QTextEdit,
-)
+from PyQt6.QtWidgets import (QApplication, QMainWindow, QVBoxLayout, QHBoxLayout, 
+                             QLabel, QLineEdit, QPushButton, QWidget, QFileDialog, 
+                             QGroupBox, QTextEdit)
 from PyQt6.QtCore import Qt
 from electrum.storage import WalletStorage
 from electrum.util import MyEncoder
-from bal_wallet_utils import fix_will_settings_tx_fees, uninstall_bal, read_wallet, save
 
+default_fees = 100
 
 class WalletUtilityGUI(QMainWindow):
     def __init__(self):
@@ -27,7 +23,7 @@ class WalletUtilityGUI(QMainWindow):
         self.initUI()
         
     def initUI(self):
-        self.setWindowTitle("BAL Wallet Utility")
+        self.setWindowTitle('BAL Wallet Utility')
         self.setFixedSize(500, 400)
         
         # Central widget
@@ -96,7 +92,10 @@ class WalletUtilityGUI(QMainWindow):
         
     def browse_wallet(self):
         file_path, _ = QFileDialog.getOpenFileName(
-            self, "Select Wallet", "*", "Electrum Wallet (*)"
+            self, 
+            "Select Wallet", 
+            "", 
+            "Electrum Wallet (*.dat)"
         )
         if file_path:
             self.wallet_path_edit.setText(file_path)
@@ -111,14 +110,43 @@ class WalletUtilityGUI(QMainWindow):
     def log_message(self, message):
         self.output_text.append(message)
         
+    def fix_will_settings_tx_fees(self, json_wallet):
+        tx_fees = json_wallet.get('will_settings',{}).get('tx_fees',False)
+        if tx_fees:
+            json_wallet['will_settings']['baltx_fees'] = json_wallet.get('will_settings',{}).get('tx_fees', default_fees)
+            del json_wallet['will_settings']['tx_fees']
+            return True
+        return False
+
+    def uninstall_bal(self, json_wallet):
+        if 'will_settings' in json_wallet:
+            del json_wallet['will_settings']
+        if 'will' in json_wallet:
+            del json_wallet['will']
+        if 'heirs' in json_wallet:
+            del json_wallet['heirs']
+        return True
+
+    def save_wallet(self, json_wallet, storage):
+        try:
+            human_readable = not storage.is_encrypted()
+            storage.write(json.dumps(
+                json_wallet,
+                indent=4 if human_readable else None,
+                sort_keys=bool(human_readable),
+                cls=MyEncoder,
+            ))
+            return True
+        except Exception as e:
+            self.log_message(f"Save error: {str(e)}")
+            return False
+        
     def fix_wallet(self):
-        self.process_wallet("fix")
+        self.process_wallet('fix')
         
     def uninstall_wallet(self):
-        self.log_message(
-            "WARNING: This will remove all BAL settings. This operation cannot be undone."
-        )
-        self.process_wallet("uninstall")
+        self.log_message("WARNING: This will remove all BAL settings. This operation cannot be undone.")
+        self.process_wallet('uninstall')
         
     def process_wallet(self, command):
         wallet_path = self.wallet_path_edit.text().strip()
@@ -140,9 +168,7 @@ class WalletUtilityGUI(QMainWindow):
             # Decrypt if necessary
             if storage.is_encrypted():
                 if not password:
-                    self.log_message(
-                        "ERROR: Wallet is encrypted, please enter password"
-                    )
+                    self.log_message("ERROR: Wallet is encrypted, please enter password")
                     return
                     
                 try:
@@ -154,31 +180,24 @@ class WalletUtilityGUI(QMainWindow):
             
             # Read wallet
             data = storage.read()
-            json_wallet = json.loads("[" + data + "]")[0]
+            json_wallet = json.loads(data)
             
             have_to_save = False
             message = ""
             
-            if command == "fix":
-                have_to_save = fix_will_settings_tx_fees(json_wallet)
-                message = (
-                    "Fix applied successfully" if have_to_save else "No fix needed"
-                )
+            if command == 'fix':
+                have_to_save = self.fix_will_settings_tx_fees(json_wallet)
+                message = "Fix applied successfully" if have_to_save else "No fix needed"
                 
-            elif command == "uninstall":
-                have_to_save = uninstall_bal(json_wallet)
-                message = (
-                    "BAL uninstalled successfully"
-                    if have_to_save
-                    else "No BAL settings found to uninstall"
-                )
+            elif command == 'uninstall':
+                have_to_save = self.uninstall_bal(json_wallet)
+                message = "BAL uninstalled successfully" if have_to_save else "No BAL settings found to uninstall"
             
             if have_to_save:
-                try:
-                    save(json_wallet, storage)
+                if self.save_wallet(json_wallet, storage):
                     self.log_message(f"SUCCESS: {message}")
-                except Exception as e:
-                    self.log_message(f"Save error: {str(e)}")
+                else:
+                    self.log_message("ERROR: Failed to save wallet")
             else:
                 self.log_message(f"INFO: {message}")
                 
@@ -186,7 +205,6 @@ class WalletUtilityGUI(QMainWindow):
             error_msg = f"ERROR: Processing failed: {str(e)}"
             self.log_message(error_msg)
 
-
 def main():
     app = QApplication(sys.argv)
     
@@ -203,6 +221,5 @@ def main():
     
     return app.exec()
 
-
-if __name__ == "__main__":
+if __name__ == '__main__':
     sys.exit(main())

heirs.py

@@ -1,11 +1,12 @@
-import datetime
-import json
+# import json
 import math
+
+# import datetime
+# import urllib.request
+# import urllib.parse
 import random
 import re
 import threading
-import urllib.parse
-import urllib.request
 from typing import TYPE_CHECKING, Any, Dict, List, Optional, Sequence, Tuple
 
 import dns
@@ -27,7 +28,7 @@ from electrum.util import (
     write_json_file,
 )
 
-from .util import Util
+from .util import *
 from .willexecutors import Willexecutors
 
 if TYPE_CHECKING:
@@ -86,7 +87,7 @@ def prepare_transactions(locktimes, available_utxos, fees, wallet):
     )
     total_used_utxos = []
     txsout = {}
-    locktime, _ = Util.get_lowest_locktimes(locktimes)
+    locktime, _ = get_lowest_locktimes(locktimes)
     if not locktime:
         return
     locktime = locktime[0]
@@ -101,7 +102,6 @@ def prepare_transactions(locktimes, available_utxos, fees, wallet):
         outputs = []
         paid_heirs = {}
         for name, heir in heirs.items():
-
             try:
                 if len(heir) > HEIR_REAL_AMOUNT:
                     real_amount = heir[HEIR_REAL_AMOUNT]
@@ -138,10 +138,11 @@ def prepare_transactions(locktimes, available_utxos, fees, wallet):
             outputs.append(change)
         for i in range(0, 100):
             random.shuffle(outputs)
+        print(outputs)
         tx = PartialTransaction.from_io(
             used_utxos,
             outputs,
-            locktime=Util.parse_locktime_string(locktime, wallet),
+            locktime=parse_locktime_string(locktime, wallet),
             version=2,
         )
         if len(description) > 0:
@@ -262,7 +263,6 @@ def get_change_output(wallet, in_amount, out_amount, fee):
 
 
 class Heirs(dict, Logger):
-
     def __init__(self, db: "WalletDB"):
         Logger.__init__(self)
         self.db = db
@@ -300,7 +300,7 @@ class Heirs(dict, Logger):
     def get_locktimes(self, from_locktime, a=False):
         locktimes = {}
         for key in self.keys():
-            locktime = Util.parse_locktime_string(self[key][HEIR_LOCKTIME])
+            locktime = parse_locktime_string(self[key][HEIR_LOCKTIME])
             if locktime > from_locktime and not a or locktime <= from_locktime and a:
                 locktimes[int(locktime)] = None
         return locktimes.keys()
@@ -348,12 +348,10 @@ class Heirs(dict, Logger):
         percent_amount = 0.0
         for key in self.keys():
             try:
-                cmp = (
-                    Util.parse_locktime_string(self[key][HEIR_LOCKTIME]) - from_locktime
-                )
+                cmp = parse_locktime_string(self[key][HEIR_LOCKTIME]) - from_locktime
                 if cmp <= 0:
                     continue
-                if Util.is_perc(self[key][HEIR_AMOUNT]):
+                if is_perc(self[key][HEIR_AMOUNT]):
                     percent_amount += float(self[key][HEIR_AMOUNT][:-1])
                     percent_heirs[key] = list(self[key])
                 else:
@@ -379,7 +377,7 @@ class Heirs(dict, Logger):
         locktimes = self.get_locktimes(from_locktime)
         if willexecutor:
             for locktime in locktimes:
-                if int(Util.int_locktime(locktime)) > int(from_locktime):
+                if int(int_locktime(locktime)) > int(from_locktime):
                     try:
                         base_fee = int(willexecutor["base_fee"])
                         willexecutors_amount += base_fee
@@ -394,9 +392,11 @@ class Heirs(dict, Logger):
                     except Exception as e:
                         return [], False
                 else:
+                    (
                         _logger.error(
-                        f"heir excluded from will locktime({locktime}){Util.int_locktime(locktime)}<minimum{from_locktime}"
+                            f"heir excluded from will locktime({locktime}){int_locktime(locktime)}<minimum{from_locktime}"
                         ),
+                    )
             heir_list.update(willexecutors)
             newbalance -= willexecutors_amount
         fixed_heirs, fixed_amount, percent_heirs, percent_amount = (
@@ -429,12 +429,12 @@ class Heirs(dict, Logger):
 
         heir_list = sorted(
             heir_list.items(),
-            key=lambda item: Util.parse_locktime_string(item[1][HEIR_LOCKTIME], wallet),
+            key=lambda item: parse_locktime_string(item[1][HEIR_LOCKTIME], wallet),
         )
 
         locktimes = {}
         for key, value in heir_list:
-            locktime = Util.parse_locktime_string(value[HEIR_LOCKTIME])
+            locktime = parse_locktime_string(value[HEIR_LOCKTIME])
             if not locktime in locktimes:
                 locktimes[locktime] = {key: value}
             else:
@@ -442,7 +442,7 @@ class Heirs(dict, Logger):
         return locktimes, onlyfixed
 
     def is_perc(self, key):
-        return Util.is_perc(self[key][HEIR_AMOUNT])
+        return is_perc(self[key][HEIR_AMOUNT])
 
     def buildTransactions(
         self, bal_plugin, wallet, tx_fees=None, utxos=None, from_locktime=0
@@ -638,7 +638,7 @@ class Heirs(dict, Logger):
 
     def validate_amount(amount):
         try:
-            famount = float(amount[:-1]) if Util.is_perc(amount) else float(amount)
+            famount = float(amount[:-1]) if is_perc(amount) else float(amount)
             if famount <= 0.00000001:
                 raise AmountNotValid(f"amount have to be positive {famount} < 0")
         except Exception as e:
@@ -648,7 +648,7 @@ class Heirs(dict, Logger):
     def validate_locktime(locktime, timestamp_to_check=False):
         try:
             if timestamp_to_check:
-                if Util.parse_locktime_string(locktime, None) < timestamp_to_check:
+                if parse_locktime_string(locktime, None) < timestamp_to_check:
                     raise HeirExpiredException()
         except Exception as e:
             raise LocktimeNotValid(f"locktime string not properly formatted, {e}")

manifest.json

@@ -1,7 +1,7 @@
 {
  "name": "BAL",
  "fullname": "Bitcoin After Life",
- "description": "Provides free and decentralized inheritance support<br> Version: 0.2.4",
+ "description": "Provides free and decentralized inheritance support<br> Version: 0.2.2b",
  "author":"Svatantrya",
  "available_for": ["qt"],
  "icon":"icons/bal32x32.png"

util.py

@@ -1,17 +1,14 @@
 import bisect
-import urllib.parse
-import urllib.request
 from datetime import datetime, timedelta
 
 from electrum.gui.qt.util import getSaveFileName
 from electrum.i18n import _
 from electrum.transaction import PartialTxOutput
-from electrum.util import FileExportFailed, FileImportFailed, write_json_file
+from electrum.util import FileExportFailed
 
 LOCKTIME_THRESHOLD = 500000000
 
 
-class Util:
 def locktime_to_str(locktime):
     try:
         locktime = int(locktime)
@@ -19,27 +16,29 @@ class Util:
             dt = datetime.fromtimestamp(locktime).isoformat()
             return dt
 
-        except Exception as e:
+    except Exception:
         pass
     return str(locktime)
 
+
 def str_to_locktime(locktime):
     try:
         if locktime[-1] in ("y", "d", "b"):
             return locktime
         else:
             return int(locktime)
-        except Exception as e:
+    except Exception:
         pass
     dt_object = datetime.fromisoformat(locktime)
     timestamp = dt_object.timestamp()
     return int(timestamp)
 
+
 def parse_locktime_string(locktime, w=None):
     try:
         return int(locktime)
 
-        except Exception as e:
+    except Exception:
         pass
     try:
         now = datetime.now()
@@ -55,24 +54,22 @@ class Util:
             locktime = int(locktime[:-1])
             height = 0
             if w:
-                    height = Util.get_current_height(w.network)
+                height = get_current_height(w.network)
             locktime += int(height)
         return int(locktime)
-        except Exception as e:
+    except Exception:
         pass
     return 0
 
+
 def int_locktime(seconds=0, minutes=0, hours=0, days=0, blocks=0):
     return int(
-            seconds
-            + minutes * 60
-            + hours * 60 * 60
-            + days * 60 * 60 * 24
-            + blocks * 600
+        seconds + minutes * 60 + hours * 60 * 60 + days * 60 * 60 * 24 + blocks * 600
     )
 
+
 def encode_amount(amount, decimal_point):
-        if Util.is_perc(amount):
+    if is_perc(amount):
         return amount
     else:
         try:
@@ -80,20 +77,23 @@ class Util:
         except:
             return 0
 
+
 def decode_amount(amount, decimal_point):
-        if Util.is_perc(amount):
+    if is_perc(amount):
         return amount
     else:
         num = 8 - decimal_point
         basestr = "{{:0{}.{}f}}".format(num, num)
         return "{:08.8f}".format(float(amount) / pow(10, decimal_point))
 
+
 def is_perc(value):
     try:
         return value[-1] == "%"
     except:
         return False
 
+
 def cmp_array(heira, heirb):
     try:
         if not len(heira) == len(heirb):
@@ -105,11 +105,13 @@ class Util:
     except:
         return False
 
+
 def cmp_heir(heira, heirb):
     if heira[0] == heirb[0] and heira[1] == heirb[1]:
         return True
     return False
 
+
 def cmp_willexecutor(willexecutora, willexecutorb):
     if willexecutora == willexecutorb:
         return True
@@ -124,6 +126,7 @@ class Util:
         return False
     return False
 
+
 def search_heir_by_values(heirs, heir, values):
     for h, v in heirs.items():
         found = False
@@ -135,27 +138,29 @@ class Util:
             return h
     return False
 
+
 def cmp_heir_by_values(heira, heirb, values):
     for v in values:
         if heira[v] != heirb[v]:
             return False
     return True
 
+
 def cmp_heirs_by_values(
     heirsa, heirsb, values, exclude_willexecutors=False, reverse=True
 ):
     for heira in heirsa:
         if (
-                exclude_willexecutors and not 'w!ll3x3c"' in heira
+            exclude_willexecutors and 'w!ll3x3c"' not in heira
         ) or not exclude_willexecutors:
             found = False
             for heirb in heirsb:
-                    if Util.cmp_heir_by_values(heirsa[heira], heirsb[heirb], values):
+                if cmp_heir_by_values(heirsa[heira], heirsb[heirb], values):
                     found = True
             if not found:
                 return False
     if reverse:
-            return Util.cmp_heirs_by_values(
+        return cmp_heirs_by_values(
             heirsb,
             heirsa,
             values,
@@ -165,6 +170,7 @@ class Util:
     else:
         return True
 
+
 def cmp_heirs(
     heirsa,
     heirsb,
@@ -173,51 +179,53 @@ class Util:
 ):
     try:
         for heir in heirsa:
-                if not 'w!ll3x3c"' in heir:
-                    if not heir in heirsb or not cmp_function(
-                        heirsa[heir], heirsb[heir]
-                    ):
-                        if not Util.search_heir_by_values(heirsb, heirsa[heir], [0, 3]):
+            if 'w!ll3x3c"' not in heir:
+                if heir not in heirsb or not cmp_function(heirsa[heir], heirsb[heir]):
+                    if not search_heir_by_values(heirsb, heirsa[heir], [0, 3]):
                         return False
         if reverse:
-                return Util.cmp_heirs(heirsb, heirsa, cmp_function, False)
+            return cmp_heirs(heirsb, heirsa, cmp_function, False)
         else:
             return True
     except Exception as e:
         raise e
         return False
 
+
 def cmp_inputs(inputsa, inputsb):
     if len(inputsa) != len(inputsb):
         return False
     for inputa in inputsa:
-            if not Util.in_utxo(inputa, inputsb):
+        if not in_utxo(inputa, inputsb):
             return False
     return True
 
+
 def cmp_outputs(outputsa, outputsb, willexecutor_output=None):
     if len(outputsa) != len(outputsb):
         return False
     for outputa in outputsa:
-            if not Util.cmp_output(outputa, willexecutor_output):
-                if not Util.in_output(outputa, outputsb):
+        if not cmp_output(outputa, willexecutor_output):
+            if not in_output(outputa, outputsb):
                 return False
     return True
 
+
 def cmp_txs(txa, txb):
-        if not Util.cmp_inputs(txa.inputs(), txb.inputs()):
+    if not cmp_inputs(txa.inputs(), txb.inputs()):
         return False
-        if not Util.cmp_outputs(txa.outputs(), txb.outputs()):
+    if not cmp_outputs(txa.outputs(), txb.outputs()):
         return False
     return True
 
+
 def get_value_amount(txa, txb):
     outputsa = txa.outputs()
     outputsb = txb.outputs()
     value_amount = 0
 
     for outa in outputsa:
-            same_amount, same_address = Util.in_output(outa, txb.outputs())
+        same_amount, same_address = in_output(outa, txb.outputs())
         if not (same_amount or same_address):
             return False
         if same_amount and same_address:
@@ -229,6 +237,7 @@ class Util:
 
     return value_amount
 
+
 def chk_locktime(timestamp_to_check, block_height_to_check, locktime):
     # TODO BUG:  WHAT HAPPEN AT THRESHOLD?
     locktime = int(locktime)
@@ -239,6 +248,7 @@ class Util:
     else:
         return False
 
+
 def anticipate_locktime(locktime, blocks=0, hours=0, days=0):
     locktime = int(locktime)
     out = 0
@@ -255,35 +265,39 @@ class Util:
         out = 1
     return out
 
+
 def cmp_locktime(locktimea, locktimeb):
     if locktimea == locktimeb:
         return 0
-        strlocktime = str(locktimea)
+    strlocktimea = str(locktimea)
     strlocktimeb = str(locktimeb)
-        intlocktimea = Util.str_to_locktime(strlocktimea)
-        intlocktimeb = Util.str_to_locktime(strlocktimeb)
+    intlocktimea = str_to_locktime(strlocktimea)
+    intlocktimeb = str_to_locktime(strlocktimeb)
     if locktimea[-1] in "ydb":
         if locktimeb[-1] == locktimea[-1]:
             return int(strlocktimea[-1]) - int(strlocktimeb[-1])
         else:
             return int(locktimea) - (locktimeb)
 
+
 def get_lowest_valid_tx(available_utxos, will):
     will = sorted(will.items(), key=lambda x: x[1]["tx"].locktime)
     for txid, willitem in will.items():
         pass
 
+
 def get_locktimes(will):
     locktimes = {}
     for txid, willitem in will.items():
         locktimes[willitem["tx"].locktime] = True
     return locktimes.keys()
 
+
 def get_lowest_locktimes(locktimes):
     sorted_timestamp = []
     sorted_block = []
     for l in locktimes:
-            l = Util.parse_locktime_string(l)
+        l = parse_locktime_string(l)
         if l < LOCKTIME_THRESHOLD:
             bisect.insort(sorted_block, l)
         else:
@@ -291,18 +305,22 @@ class Util:
 
     return sorted(sorted_timestamp), sorted(sorted_block)
 
+
 def get_lowest_locktimes_from_will(will):
-        return Util.get_lowest_locktimes(Util.get_locktimes(will))
+    return get_lowest_locktimes(get_locktimes(will))
+
 
 def search_willtx_per_io(will, tx):
     for wid, w in will.items():
-            if Util.cmp_txs(w["tx"], tx["tx"]):
+        if cmp_txs(w["tx"], tx["tx"]):
             return wid, w
     return None, None
 
+
 def invalidate_will(will):
     raise Exception("not implemented")
 
+
 def get_will_spent_utxos(will):
     utxos = []
     for txid, willitem in will.items():
@@ -310,51 +328,59 @@ class Util:
 
     return utxos
 
+
 def utxo_to_str(utxo):
     try:
         return utxo.to_str()
-        except Exception as e:
+    except Exception:
         pass
     try:
         return utxo.prevout.to_str()
-        except Exception as e:
+    except Exception:
         pass
     return str(utxo)
 
+
 def cmp_utxo(utxoa, utxob):
-        utxoa = Util.utxo_to_str(utxoa)
-        utxob = Util.utxo_to_str(utxob)
+    utxoa = utxo_to_str(utxoa)
+    utxob = utxo_to_str(utxob)
     if utxoa == utxob:
         return True
     else:
         return False
 
+
 def in_utxo(utxo, utxos):
     for s_u in utxos:
-            if Util.cmp_utxo(s_u, utxo):
+        if cmp_utxo(s_u, utxo):
             return True
     return False
 
+
 def txid_in_utxo(txid, utxos):
     for s_u in utxos:
         if s_u.prevout.txid == txid:
             return True
     return False
 
+
 def cmp_output(outputa, outputb):
     return outputa.address == outputb.address and outputa.value == outputb.value
 
+
 def in_output(output, outputs):
     for s_o in outputs:
-            if Util.cmp_output(s_o, output):
+        if cmp_output(s_o, output):
             return True
     return False
 
+
 # check all output with the same amount if none have the same address it can be a change
 # return true true same address same amount
 # return true false same amount different address
 # return false false different amount, different address not found
 
+
 def din_output(out, outputs):
     same_amount = []
     for s_o in outputs:
@@ -370,16 +396,16 @@ class Util:
     else:
         return False, False
 
+
 def get_change_output(wallet, in_amount, out_amount, fee):
     change_amount = int(in_amount - out_amount - fee)
     if change_amount > wallet.dust_threshold():
         change_addresses = wallet.get_change_addresses_for_new_transaction()
-            out = PartialTxOutput.from_address_and_value(
-                change_addresses[0], change_amount
-            )
+        out = PartialTxOutput.from_address_and_value(change_addresses[0], change_amount)
         out.is_change = True
         return out
 
+
 def get_current_height(network: "Network"):
     # if no network or not up to date, just set locktime to zero
     if not network:
@@ -401,9 +427,10 @@ class Util:
     height = min(chain_height, server_height)
     return height
 
+
 def print_var(var, name="", veryverbose=False):
     print(f"---{name}---")
-        if not var is None:
+    if var is not None:
         try:
             print("doc:", doc(var))
         except:
@@ -439,23 +466,26 @@ class Util:
 
     print(f"---end {name}---")
 
+
 def print_utxo(utxo, name=""):
     print(f"---utxo-{name}---")
-        Util.print_var(utxo, name)
-        Util.print_prevout(utxo.prevout, name)
-        Util.print_var(utxo.script_sig, f"{name}-script-sig")
-        Util.print_var(utxo.witness, f"{name}-witness")
+    print_var(utxo, name)
+    print_prevout(utxo.prevout, name)
+    print_var(utxo.script_sig, f"{name}-script-sig")
+    print_var(utxo.witness, f"{name}-witness")
     print("_TxInput__address:", utxo._TxInput__address)
     print("_TxInput__scriptpubkey:", utxo._TxInput__scriptpubkey)
     print("_TxInput__value_sats:", utxo._TxInput__value_sats)
     print(f"---utxo-end {name}---")
 
+
 def print_prevout(prevout, name=""):
     print(f"---prevout-{name}---")
-        Util.print_var(prevout, f"{name}-prevout")
-        Util.print_var(prevout._asdict())
+    print_var(prevout, f"{name}-prevout")
+    print_var(prevout._asdict())
     print(f"---prevout-end {name}---")
 
+
 def export_meta_gui(electrum_window: "ElectrumWindow", title, exporter):
     filter_ = "All files (*)"
     filename = getSaveFileName(
@@ -476,25 +506,7 @@ class Util:
             _("Your {0} were exported to '{1}'").format(title, str(filename))
         )
 
+
 def copy(dicto, dictfrom):
     for k, v in dictfrom.items():
         dicto[k] = v
-
-    def fix_will_settings_tx_fees(will_settings):
-        tx_fees = will_settings.get("tx_fees", False)
-        have_to_update = False
-        if tx_fees:
-            will_settings["baltx_fees"] = tx_fees
-            del will_settings["tx_fees"]
-            have_to_update = True
-        return have_to_update
-
-    def fix_will_tx_fees(will):
-        have_to_update = False
-        for txid, willitem in will.items():
-            tx_fees = willitem.get("tx_fees", False)
-            if tx_fees:
-                will[txid]["baltx_fees"] = tx_fees
-                del will[txid]["tx_fees"]
-                have_to_update = True
-        return have_to_update

wallet_util/bal_wallet_utils.py

@@ -1,77 +0,0 @@
-#!env/bin/python3
-from electrum.storage import WalletStorage
-from electrum.util import MyEncoder
-import json
-import sys
-import getpass
-import os
-
-default_fees = 100
-
-
-def fix_will_settings_tx_fees(json_wallet):
-    tx_fees = json_wallet.get("will_settings", {}).get("tx_fees", False)
-    have_to_update = False
-    if tx_fees:
-        json_wallet["will_settings"]["baltx_fees"] = tx_fees
-        del json_wallet["will_settings"]["tx_fees"]
-        have_to_update = True
-    for txid, willitem in json_wallet["will"].items():
-        tx_fees = willitem.get("tx_fees", False)
-        if tx_fees:
-            json_wallet["will"][txid]["baltx_fees"] = tx_fees
-            del json_wallet["will"][txid]["tx_fees"]
-            have_to_update = True
-    return have_to_update
-
-
-def uninstall_bal(json_wallet):
-    del json_wallet["will_settings"]
-    del json_wallet["will"]
-    del json_wallet["heirs"]
-    return True
-
-
-def save(json_wallet, storage):
-    human_readable = not storage.is_encrypted()
-    storage.write(
-        json.dumps(
-            json_wallet,
-            indent=4 if human_readable else None,
-            sort_keys=bool(human_readable),
-            cls=MyEncoder,
-        )
-    )
-
-
-def read_wallet(path, password=False):
-    storage = WalletStorage(path)
-    if storage.is_encrypted():
-        if password == False:
-            password = getpass.getpass("Enter wallet password: ", stream=None)
-        storage.decrypt(password)
-    data = storage.read()
-    json_wallet = json.loads("[" + data + "]")[0]
-    return json_wallet
-
-
-if __name__ == "__main__":
-    if len(sys.argv) < 3:
-        print("usage: ./bal_wallet_utils <command> <wallet path>")
-        print("available commands: uninstall, fix")
-        exit(1)
-    if not os.path.exists(sys.argv[2]):
-        print("Error: wallet not found")
-        exit(1)
-    command = sys.argv[1]
-    path = sys.argv[2]
-    json_wallet = read_wallet(path)
-    have_to_save = False
-    if command == "fix":
-        have_to_save = fix_will_settings_tx_fees(json_wallet)
-    if command == "uninstall":
-        have_to_save = uninstall_bal(json_wallet)
-    if have_to_save:
-        save(json_wallet, storage)
-    else:
-        print("nothing to do")

will.py

@@ -19,7 +19,7 @@ from electrum.util import (
     write_json_file,
 )
 
-from .util import Util
+from .util import *
 from .willexecutors import Willexecutors
 
 MIN_LOCKTIME = 1
@@ -60,7 +60,7 @@ class Will:
         for w in will:
             if w != wid and not tx.to_json() != will[w]["tx"].to_json():
                 if will[w]["tx"].txid() != tx.txid():
-                    if Util.cmp_txs(will[w]["tx"], tx):
+                    if cmp_txs(will[w]["tx"], tx):
                         return will[w]["tx"]
         return False
 
@@ -107,7 +107,6 @@ class Will:
         will = willitems
         errors = {}
         for wid in will:
-
             txid = will[wid].tx.txid()
 
             if txid is None:
@@ -156,9 +155,9 @@ class Will:
         return inp
 
     def check_anticipate(ow: "WillItem", nw: "WillItem"):
-        anticipate = Util.anticipate_locktime(ow.tx.locktime, days=1)
+        anticipate = anticipate_locktime(ow.tx.locktime, days=1)
         if int(nw.tx.locktime) >= int(anticipate):
-            if Util.cmp_heirs_by_values(
+            if cmp_heirs_by_values(
                 ow.heirs, nw.heirs, [0, 1], exclude_willexecutors=True
             ):
                 if nw.we and ow.we:
@@ -174,7 +173,7 @@ class Will:
                         ow.tx.locktime
                 else:
                     if nw.we == ow.we:
-                        if not Util.cmp_heirs_by_values(ow.heirs, nw.heirs, [0, 3]):
+                        if not cmp_heirs_by_values(ow.heirs, nw.heirs, [0, 3]):
                             return anticipate
                         else:
                             return ow.tx.locktime
@@ -338,11 +337,12 @@ class Will:
             if utxo_str in prevout_to_spend:
                 balance += inputs[utxo_str][0][2].value_sats()
                 utxo_to_spend.append(utxo)
+
         if len(utxo_to_spend) > 0:
             change_addresses = wallet.get_change_addresses_for_new_transaction()
             out = PartialTxOutput.from_address_and_value(change_addresses[0], balance)
             out.is_change = True
-            locktime = Util.get_current_height(wallet.network)
+            locktime = get_current_height(wallet.network)
             tx = PartialTransaction.from_io(
                 utxo_to_spend, [out], locktime=locktime, version=2
             )
@@ -375,7 +375,7 @@ class Will:
     def search_rai(all_inputs, all_utxos, will, wallet):
         will_only_valid = Will.only_valid_or_replaced_list(will)
         for inp, ws in all_inputs.items():
-            inutxo = Util.in_utxo(inp, all_utxos)
+            inutxo = in_utxo(inp, all_utxos)
             for w in ws:
                 wi = w[1]
                 if (
@@ -406,7 +406,7 @@ class Will:
                     pass
 
     def utxos_strs(utxos):
-        return [Util.utxo_to_str(u) for u in utxos]
+        return [utxo_to_str(u) for u in utxos]
 
     def set_invalidate(wid, will=[]):
         will[wid].set_status("INVALIDATED", True)
@@ -416,17 +416,18 @@ class Will:
 
     def check_tx_height(tx, wallet):
         info = wallet.get_tx_info(tx)
-        return info.tx_mined_status.height()
+        return info.tx_mined_status.height
 
     # check if transactions are stil valid tecnically valid
     def check_invalidated(willtree, utxos_list, wallet):
         for wid, w in willtree.items():
             if not w.father:
                 for inp in w.tx.inputs():
-                    inp_str = Util.utxo_to_str(inp)
+                    inp_str = utxo_to_str(inp)
                     if not inp_str in utxos_list:
                         if wallet:
                             height = Will.check_tx_height(w.tx, wallet)
+
                             if height < 0:
                                 Will.set_invalidate(wid, willtree)
                             elif height == 0:
@@ -477,7 +478,9 @@ class Will:
         Will.check_invalidated(will, utxos_list, wallet)
 
         all_inputs = Will.get_all_inputs(will, only_valid=True)
+
         all_inputs_min_locktime = Will.get_all_inputs_min_locktime(all_inputs)
+
         Will.check_will_expired(
             all_inputs_min_locktime, block_to_check, timestamp_to_check
         )
@@ -499,6 +502,7 @@ class Will:
         callback_not_valid_tx=None,
     ):
         Will.check_will(will, all_utxos, wallet, block_to_check, timestamp_to_check)
+
         if heirs:
             if not Will.check_willexecutors_and_heirs(
                 will,
@@ -516,7 +520,7 @@ class Will:
         if all_inputs:
             for utxo in all_utxos:
                 if utxo.value_sats() > 68 * tx_fees:
-                    if not Util.in_utxo(utxo, all_inputs.keys()):
+                    if not in_utxo(utxo, all_inputs.keys()):
                         _logger.info("utxo is not spent", utxo.to_json())
                         _logger.debug(all_inputs.keys())
                         raise NotCompleteWillException(
@@ -546,7 +550,7 @@ class Will:
     def check_all_input_spent_are_in_wallet():
         _logger.info("check all input spent are in wallet or valid txs")
         for inp, ws in all_inputs.items():
-            if not Util.in_utxo(inp, all_utxos):
+            if not in_utxo(inp, all_utxos):
                 for w in ws:
                     if w[1].get_status("VALID"):
                         prevout_id = w[2].prevout.txid.hex()
@@ -587,12 +591,11 @@ class Will:
                 if not 'w!ll3x3c"' == wheir[:9]:
                     their = will[wid].heirs[wheir]
                     if heir := heirs.get(wheir, None):
-
                         if (
                             heir[0] == their[0]
                             and heir[1] == their[1]
-                            and Util.parse_locktime_string(heir[2])
-                            >= Util.parse_locktime_string(their[2])
+                            and parse_locktime_string(heir[2])
+                            >= parse_locktime_string(their[2])
                         ):
                             count = heirs_found.get(wheir, 0)
                             heirs_found[wheir] = count + 1
@@ -603,7 +606,7 @@ class Will:
                         continue
             if willexecutor := w.we:
                 count = willexecutors_found.get(willexecutor["url"], 0)
-                if Util.cmp_willexecutor(
+                if cmp_willexecutor(
                     willexecutor, willexecutors.get(willexecutor["url"], None)
                 ):
                     willexecutors_found[willexecutor["url"]] = count + 1
@@ -612,7 +615,7 @@ class Will:
                 no_willexecutor += 1
         count_heirs = 0
         for h in heirs:
-            if Util.parse_locktime_string(heirs[h][2]) >= check_date:
+            if parse_locktime_string(heirs[h][2]) >= check_date:
                 count_heirs += 1
                 if not h in heirs_found:
                     _logger.debug(f"heir: {h} not found")
@@ -632,7 +635,6 @@ class Will:
 
 
 class WillItem(Logger):
-
     STATUS_DEFAULT = {
         "ANTICIPATED": ["Anticipated", False],
         "BROADCASTED": ["Broadcasted", False],
@@ -654,11 +656,11 @@ class WillItem(Logger):
     }
 
     def set_status(self, status, value=True):
-        #_logger.trace(
-        #    "set status {} - {} {} -> {}".format(
-        #        self._id, status, self.STATUS[status][1], value
-        #    )
-        #)
+        _logger.debug(
+            "set status {} - {} {} -> {}".format(
+                self._id, status, self.STATUS[status][1], value
+            )
+        )
         if self.STATUS[status][1] == bool(value):
             return None
 

willexecutors.py

@@ -10,14 +10,14 @@ from electrum.logging import get_logger
 from electrum.network import Network
 
 from .bal import BalPlugin
-from .util import Util
+
+# from .util import *
 
 DEFAULT_TIMEOUT = 5
 _logger = get_logger(__name__)
 
 
 class Willexecutors:
-
     def save(bal_plugin, willexecutors):
         aw = bal_plugin.WILLEXECUTORS.get()
         aw[constants.net.NET_NAME] = willexecutors
@@ -35,34 +35,34 @@ class Willexecutors:
                 continue
             Willexecutors.initialize_willexecutor(willexecutors[w], w)
         for w in to_del:
-            _logger.error("error Willexecutor to delete type:{} ", type(willexecutor[w]),w)
+            print("ERROR: WILLEXECUTOR TO DELETE:", w)
             del willexecutors[w]
         bal = bal_plugin.WILLEXECUTORS.default.get(constants.net.NET_NAME, {})
         for bal_url, bal_executor in bal.items():
             if not bal_url in willexecutors:
                 _logger.debug(f"force add {bal_url} willexecutor")
                 willexecutors[bal_url] = bal_executor
-        #if update:
-        #    found = False
-        #    for url, we in willexecutors.items():
-        #        if Willexecutors.is_selected(we):
-        #            found = True
-        #    if found or force:
-        #        if bal_plugin.PING_WILLEXECUTORS.get() or force:
-        #            ping_willexecutors = True
-        #            if bal_plugin.ASK_PING_WILLEXECUTORS.get() and not force:
-        #                if bal_window:
-        #                    ping_willexecutors = bal_window.window.question(
-        #                        _(
-        #                            "Contact willexecutors servers to update payment informations?"
-        #                        )
-        #                    )
+        if update:
+            found = False
+            for url, we in willexecutors.items():
+                if Willexecutors.is_selected(we):
+                    found = True
+            if found or force:
+                if bal_plugin.PING_WILLEXECUTORS.get() or force:
+                    ping_willexecutors = True
+                    if bal_plugin.ASK_PING_WILLEXECUTORS.get() and not force:
+                        if bal_window:
+                            ping_willexecutors = bal_window.window.question(
+                                _(
+                                    "Contact willexecutors servers to update payment informations?"
+                                )
+                            )
 
-        #            if ping_willexecutors:
-        #                if task:
-        #                    bal_window.ping_willexecutors(willexecutors, task)
-        #                else:
-        #                    bal_window.ping_willexecutors_task(willexecutors)
+                    if ping_willexecutors:
+                        if task:
+                            bal_window.ping_willexecutors(willexecutors, task)
+                        else:
+                            bal_window.ping_willexecutors_task(willexecutors)
         w_sorted = dict(
             sorted(
                 willexecutors.items(), key=lambda w: w[1].get("sort", 0), reverse=True
@@ -170,7 +170,6 @@ class Willexecutors:
     def push_transactions_to_willexecutor(willexecutor):
         out = True
         try:
-
             _logger.debug(f"willexecutor['txs']")
             if w := Willexecutors.send_request(
                 "post",