move network dialog in a new class; simplify interface.get_servers
[electrum-nvc.git] / electrum
index 75eaafa..0cd3539 100755 (executable)
--- a/electrum
+++ b/electrum
 # along with this program. If not, see <http://www.gnu.org/licenses/>.
 
 import re
-import sys, os, time, ast
+import pkgutil
+import sys, os, time, json
 import optparse
 import platform
+from decimal import Decimal
 
 try:
     import ecdsa  
@@ -31,89 +33,20 @@ try:
 except ImportError:
     sys.exit("Error: AES does not seem to be installed. Try 'sudo pip install slowaes'")
 
-try:
-    from lib import *
-except ImportError:
-    from electrum import *
-
-from decimal import Decimal
-
-known_commands = {
-    'help':'Prints this help',
-    'validateaddress':'Check that the address is valid', 
-    'balance': "Display the balance of your wallet or of an address.\nSyntax: balance [<address>]", 
-    'contacts': "Show your list of contacts", 
-    'create':'Create a wallet', 
-    'restore':'Restore a wallet', 
-    'payto':"""Create and broadcast a transaction.
-Syntax: payto <recipient> <amount> [label]
-<recipient> can be a bitcoin address or a label
-options:\n  --fee, -f: set transaction fee\n  --fromaddr, -s: send from address -\n  --changeaddr, -c: send change to address
-            """,
-    'sendrawtransaction':
-            'Broadcasts a transaction to the network. \nSyntax: sendrawtransaction <tx in hexadecimal>',
-    'password': 
-            "Changes your password",
-    'addresses':  
-            """Shows your list of addresses.
-options:
-  -a: show all addresses, including change addresses
-  -k: show private keys
-  -b: show the balance of addresses""",
-
-    'history':"Shows the transaction history",
-    'setlabel':'Assign a label to an item\nSyntax: label <tx_hash> <label>',
-    'mktx':
-        """Create a signed transaction, password protected.
-Syntax: mktx <recipient> <amount> [label]
-options:\n  --fee, -f: set transaction fee\n  --fromaddr, -s: send from address -\n  --changeaddr, -c: send change to address
-        """,
-    'get_seed':
-            "Print the generation seed of your wallet.",
-    'importprivkey': 
-            'Import a private key\nSyntax: importprivkey <privatekey>',
-    'signmessage':
-            'Signs a message with a key\nSyntax: signmessage <address> <message>\nIf you want to lead or end a message with spaces, or want double spaces inside the message make sure you quote the string. I.e. " Hello  This is a weird String "',
-    'verifymessage':
-             'Verifies a signature\nSyntax: verifymessage <address> <signature> <message>\nIf you want to lead or end a message with spaces, or want double spaces inside the message make sure you quote the string. I.e. " Hello  This is a weird String "',
-    'eval':  
-             "Run python eval() on an object\nSyntax: eval <expression>\nExample: eval \"wallet.aliases\"",
-    'get': 
-             "Get config parameter.",
-    'set': 
-             "Set config parameter.",
-    'deseed':
-            "Create a seedless, watching-only wallet.",
-    'freeze':'',
-    'unfreeze':'',
-    'prioritize':'',
-    'unprioritize':'',
-    'dumpprivkey':'similar to bitcoind\'s command',
-    'listunspent':'similar to bitcoind\'s command',
-    'createmultisig':'similar to bitcoind\'s command',
-    'createrawtransaction':'similar to bitcoind\'s command',
-    'decoderawtransaction':'similar to bitcoind\'s command',
-    'signrawtransaction':'similar to bitcoind\'s command',
-    'get_history': 'get history for an address'
-    
-    }
-
 
+is_local = os.path.dirname(os.path.realpath(__file__)) == os.getcwd()
+is_android = 'ANDROID_DATA' in os.environ
 
-offline_commands = [ 'password', 'mktx',
-                     'setlabel', 'contacts',
-                     'help', 'validateaddress',
-                     'signmessage', 'verifymessage',
-                     'eval', 'set', 'get', 'create', 'addresses',
-                     'importprivkey', 'get_seed',
-                     'deseed',
-                     'freeze','unfreeze',
-                     'prioritize','unprioritize',
-                     'dumpprivkey','listunspent',
-                     'createmultisig', 'createrawtransaction', 'decoderawtransaction', 'signrawtransaction'
-                     ]
+import __builtin__
+__builtin__.use_local_modules = is_local or is_android
 
+# load local module as electrum
+if __builtin__.use_local_modules:
+    import imp
+    imp.load_module('electrum', *imp.find_module('lib'))
+    imp.load_module('electrum_gui', *imp.find_module('gui'))
 
+from electrum import *
 
 # get password routine
 def prompt_password(prompt, confirm=True):
@@ -131,15 +64,15 @@ def prompt_password(prompt, confirm=True):
     return password
 
 def arg_parser():
-    usage = "usage: %prog [options] command\nCommands: "+ (', '.join(known_commands))
+    usage = "%prog [options] command" 
     parser = optparse.OptionParser(prog=usage)
     parser.add_option("-g", "--gui", dest="gui", help="User interface: qt, lite, gtk or text")
     parser.add_option("-w", "--wallet", dest="wallet_path", help="wallet path (default: electrum.dat)")
     parser.add_option("-o", "--offline", action="store_true", dest="offline", default=False, help="remain offline")
     parser.add_option("-a", "--all", action="store_true", dest="show_all", default=False, help="show all addresses")
-    parser.add_option("-b", "--balance", action="store_true", dest="show_balance", default=False, help="show the balance at listed addresses")
-    parser.add_option("-k", "--keys",action="store_true", dest="show_keys",default=False, help="show the private keys of listed addresses")
-    parser.add_option("-f", "--fee", dest="tx_fee", default="0.005", help="set tx fee")
+    parser.add_option("-b", "--balance", action="store_true", dest="show_balance", default=False, help="show the balance of listed addresses")
+    parser.add_option("-l", "--labels", action="store_true", dest="show_labels", default=False, help="show the labels of listed addresses")
+    parser.add_option("-f", "--fee", dest="tx_fee", default=None, help="set tx fee")
     parser.add_option("-F", "--fromaddr", dest="from_addr", default=None, help="set source address for payto/mktx. if it isn't in the wallet, it will ask for the private key unless supplied in the format public_key:private_key. It's not saved in the wallet.")
     parser.add_option("-c", "--changeaddr", dest="change_addr", default=None, help="set the change address for payto/mktx. default is a spare address, or the source address if it's not in the wallet")
     parser.add_option("-s", "--server", dest="server", default=None, help="set server host:port:protocol, where protocol is t or h")
@@ -155,11 +88,13 @@ if __name__ == '__main__':
 
     parser = arg_parser()
     options, args = parser.parse_args()
+    if options.portable and options.wallet_path is None:
+        options.wallet_path = os.path.join(os.path.dirname(os.path.realpath(__file__)), 'electrum.dat')
     set_verbosity(options.verbose)
 
     # config is an object passed to the various constructors (wallet, interface, gui)
-    if 'ANDROID_DATA' in os.environ:
-        config_options = {'wallet_path':"/sdcard/electrum.dat", 'portable':True, 'verbose':True, 'gui':'android'}
+    if is_android:
+        config_options = {'wallet_path':"/sdcard/electrum.dat", 'portable':True, 'verbose':True, 'gui':'android', 'auto_cycle':True}
     else:
         config_options = eval(str(options))
         for k, v in config_options.items():
@@ -173,6 +108,7 @@ if __name__ == '__main__':
     config = SimpleConfig(config_options)
     wallet = Wallet(config)
 
+
     if len(args)==0:
         url = None
         cmd = 'gui'
@@ -181,60 +117,33 @@ if __name__ == '__main__':
         cmd = 'gui'
     else:
         cmd = args[0]
-        firstarg = args[1] if len(args) > 1 else ''
        
-    #this entire if/else block is just concerned with importing the 
-    #right GUI toolkit based the GUI command line option given 
-    if cmd == 'gui':
-        pref_gui = config.get('gui','classic')
-
-        if pref_gui == 'gtk':
-            try:
-                import lib.gui as gui
-            except ImportError:
-                import electrum.gui as gui
-        elif pref_gui in ['classic', 'qt']:
-            try:
-                import lib.gui_qt as gui
-            except ImportError:
-                import electrum.gui_qt as gui
-        elif pref_gui == 'lite':
-              try:
-                  import lib.gui_lite as gui
-              except ImportError:
-                  import electrum.gui_lite as gui
-        elif pref_gui == 'text':
-              try:
-                  import lib.gui_text as gui
-              except ImportError:
-                  import electrum.gui_text as gui
-        elif pref_gui == 'android':
-              try:
-                  import lib.gui_android as gui
-              except ImportError:
-                  import electrum.gui_android as gui
-        else:
-            sys.exit("Error: Unknown GUI: " + pref_gui )
 
+    if cmd == 'gui':
+        gui_name = config.get('gui','classic')
+        try:
+            gui = __import__('electrum_gui.gui_' + gui_name, fromlist=['electrum_gui'])
+        except ImportError:
+            sys.exit("Error: Unknown GUI: " + gui_name )
         
         interface = Interface(config, True)
         wallet.interface = interface
-        interface.start()
-        if interface.is_connected:
-            interface.send([('server.peers.subscribe',[])])
 
-        set_language(config.get('language'))
         gui = gui.ElectrumGui(wallet, config)
 
         found = config.wallet_file_exists
         if not found:
             a = gui.restore_or_create()
             if not a: exit()
-            # select a server.
-            s = gui.network_dialog()
 
             if a =='create':
                 wallet.init_seed(None)
+                gui.show_seed()
+                if gui.verify_seed():
+                    wallet.save_seed()
+                else:
+                    exit()
+
             else:
                 # ask for seed and gap.
                 sg = gui.seed_dialog()
@@ -244,19 +153,23 @@ if __name__ == '__main__':
                 wallet.gap_limit = gap
                 if len(seed) == 128:
                     wallet.seed = ''
-                    wallet.sequence.master_public_key = seed
+                    wallet.init_sequence(str(seed))
                 else:
                     wallet.init_seed(str(seed))
+                    wallet.save_seed()
             
+            # select a server.
+            s = gui.network_dialog()
+            
+        interface.start(wait = False)
+        interface.send([('server.peers.subscribe',[])])
 
-            # generate the first addresses, in case we are offline
-            if s is None or a == 'create':
-                wallet.synchronize()
-            if a == 'create':
-                # display seed
-                gui.show_seed()
+        # generate the first addresses, in case we are offline
+        if not found and ( s is None or a == 'create'):
+            wallet.synchronize()
 
         verifier = WalletVerifier(interface, config)
+        verifier.start()
         wallet.set_verifier(verifier)
         synchronizer = WalletSynchronizer(wallet, config)
         synchronizer.start()
@@ -276,7 +189,6 @@ if __name__ == '__main__':
             gui.password_dialog()
 
         wallet.save()
-        verifier.start()
         gui.main(url)
         wallet.save()
 
@@ -307,7 +219,7 @@ if __name__ == '__main__':
         w_host, w_port, w_protocol = server.split(':')
         host = raw_input("server (default:%s):"%w_host)
         port = raw_input("port (default:%s):"%w_port)
-        protocol = raw_input("protocol [t=tcp;h=http;n=native] (default:%s):"%w_protocol)
+        protocol = raw_input("protocol [t=tcp;h=http] (default:%s):"%w_protocol)
         fee = raw_input("fee (default:%s):"%( str(Decimal(wallet.fee)/100000000)) )
         gap = raw_input("gap limit (default 5):")
         if host: w_host = host
@@ -329,17 +241,19 @@ if __name__ == '__main__':
 
             if len(seed) == 128:
                 wallet.seed = None
-                wallet.sequence.master_public_key = seed
+                wallet.init_sequence(str(seed))
             else:
-                wallet.seed = str(seed)
-                wallet.init_mpk( wallet.seed )
+                wallet.init_seed( str(seed) )
+                wallet.save_seed()
 
+            interface = Interface(config)
             if not options.offline:
-                interface = Interface(config)
-                interface.start()
+                if not interface.start(wait=True):
+                    print_msg("Not connected, aborting. Try option -o if you want to restore offline.")
+                    sys.exit(1)
                 wallet.interface = interface
-
                 verifier = WalletVerifier(interface, config)
+                verifier.start()
                 wallet.set_verifier(verifier)
 
                 print_msg("Recovering wallet...")
@@ -350,12 +264,14 @@ if __name__ == '__main__':
                 else:
                     print_msg("Warning: Found no history for this wallet")
             else:
+                interface.start(wait=False)
                 wallet.synchronize()
             wallet.fill_addressbook()
             wallet.save()
             print_msg("Wallet saved in '%s'"%wallet.config.path)
         else:
             wallet.init_seed(None)
+            wallet.save_seed()
             wallet.synchronize() # there is no wallet thread 
             wallet.save()
             print_msg("Your wallet generation seed is: " + wallet.seed)
@@ -367,30 +283,19 @@ if __name__ == '__main__':
         if password:
             wallet.update_password(wallet.seed, None, password)
 
+        # terminate
+        sys.exit(0)
 
-    # open session
-    if cmd not in offline_commands and not options.offline:
-        interface = Interface(config)
-        interface.register_callback('connected', lambda: sys.stderr.write("Connected to " + interface.connection_msg + "\n"))
-        interface.start()
-        wallet.interface = interface
-        verifier = WalletVerifier(interface, config)
-        wallet.set_verifier(verifier)
-        synchronizer = WalletSynchronizer(wallet, config)
-        synchronizer.start()
-        wallet.update()
-        wallet.save()
 
 
-                
     # important warning
-    if cmd=='addresses' and options.show_keys:
+    if cmd in ['dumpprivkey', 'dumpprivkeys']:
         print_msg("WARNING: ALL your private keys are secret.")
         print_msg("Exposing a single private key can compromise your entire wallet!")
         print_msg("In particular, DO NOT use 'redeem private key' services proposed by third parties.")
 
     # commands needing password
-    if cmd in protected_commands or ( cmd=='addresses' and options.show_keys):
+    if cmd in protected_commands:
         if wallet.use_encryption:
             password = prompt_password('Password:', False)
             if not password:
@@ -409,113 +314,79 @@ if __name__ == '__main__':
         password = None
 
 
-    # check and format the arguments
+    # add missing arguments, do type conversions
     if cmd == 'importprivkey':
         # See if they specificed a key on the cmd line, if not prompt
         if len(args) == 1:
             args[1] = prompt_password('Enter PrivateKey (will not echo):', False)
 
-    elif cmd == 'signmessage':
-        if len(args) < 3:
-            print_msg("Error: Invalid usage of signmessage.")
-            print_msg(known_commands[cmd])
-            sys.exit(1)
-        address = args[1]
-        message = ' '.join(args[2:])
-        if len(args) > 3:
-            print_msg("Warning: Message was reconstructed from several arguments:", repr(message))
-        args = [ cmd, address, message ]
-
-    elif cmd == 'verifymessage':
-        try:
-            address = args[1]
-            signature = args[2]
-            message = ' '.join(args[3:])
-        except:
-            print_msg("Error: Not all parameters were given, displaying help instead.")
-            print_msg(known_commands[cmd])
-            sys.exit(1)
-        if len(args) > 4:
-            print_msg("Warning: Message was reconstructed from several arguments:", repr(message))
-        args = [ cmd, address, signature, message]
-
     elif cmd == 'signrawtransaction':
-        
-        args = [ cmd, args[1], ast.literal_eval(args[2]) if len(args)>2 else [], ast.literal_eval(args[3]) if len(args)>3 else []]
+        args = [ cmd, args[1], json.loads(args[2]) if len(args)>2 else [], json.loads(args[3]) if len(args)>3 else []]
 
     elif cmd == 'createmultisig':
-        args = [ cmd, int(args[1]), ast.literal_eval(args[2])]
+        args = [ cmd, int(args[1]), json.loads(args[2])]
 
     elif cmd == 'createrawtransaction':
-        args = [ cmd, ast.literal_eval(args[1]), ast.literal_eval(args[2])]
-                
-    elif cmd == 'setlabel':
-        try:
-            tx = args[1]
-            label = ' '.join(args[2:])
-        except:
-            print_msg("Error. Syntax:  label <tx_hash> <text>")
-            sys.exit(1)
-        args = [ cmd, tx, label ]
+        args = [ cmd, json.loads(args[1]), json.loads(args[2])]
+
+    elif cmd == 'listaddresses':
+        args = [cmd, options.show_all, options.show_balance, options.show_labels]
 
     elif cmd in ['payto', 'mktx']:
+        domain = [options.from_addr] if options.from_addr else None
+        args = [ 'mktx', args[1], Decimal(args[2]), Decimal(options.tx_fee) if options.tx_fee else None, options.change_addr, domain ]
 
-        #is_temporary = False
-        from_addr = None
-        if options.from_addr:
-            from_addr = options.from_addr
-            if from_addr not in wallet.all_addresses():
-                #is_temporary = True
-                raise BaseException("address not in wallet")
+    elif cmd == 'help':
+        if len(args) < 2:
+            parser.print_help()
+            print_msg("Type 'electrum help <command>' to see the help for a specific command")
+            print_msg("Type 'electrum --help' to see the list of options")
 
-        try:
-            to_address = args[1]
-            amount = Decimal(args[2])
-            change_addr = None
-            label = ' '.join(args[3:])
-            if options.tx_fee: 
-                options.tx_fee = Decimal(options.tx_fee)
-        except:
-            firstarg = cmd
-            cmd = 'help'
-
-        #if from_addr and is_temporary:
-        #    if from_addr.find(":") == -1:
-        #        keypair = from_addr + ":" + prompt_password('Private key:', False)
-        #    else:
-        #        keypair = from_addr
-        #        from_addr = keypair.split(':')[0]
-        #    if not wallet.import_key(keypair,password):
-        #        print_msg("Error: Invalid key pair")
-        #        exit(1)
-        #    wallet.history[from_addr] = interface.retrieve_history(from_addr)
-        #    wallet.update_tx_history()
-        #    change_addr = from_addr
-
-        if options.change_addr:
-            change_addr = options.change_addr
-            
-        args = [ 'mktx', to_address, amount, options.tx_fee, options.change_addr, from_addr ]
 
-        #if is_temporary:
-        #    wallet.imported_keys.pop(from_addr)
-        #    del(wallet.history[from_addr])
-        #wallet.save()
+                
+
+    # check the number of arguments
+    min_args, max_args, description, syntax, options_syntax = known_commands[cmd]
+    if len(args) - 1 < min_args:
+        print_msg("Not enough arguments")
+        print_msg("Syntax:", syntax)
+        sys.exit(1)
+
+    if max_args >= 0 and len(args) - 1 > max_args:
+        print_msg("too many arguments", args)
+        print_msg("Syntax:", syntax)
+        sys.exit(1)
+
+    if max_args < 0:
+        if len(args) > min_args + 1:
+            message = ' '.join(args[min_args:])
+            print_msg("Warning: Final argument was reconstructed from several arguments:", repr(message))
+            args = args[0:min_args] + [ message ]
+        
 
 
 
+
+    # open session
+    if cmd not in offline_commands and not options.offline:
+        interface = Interface(config)
+        interface.register_callback('connected', lambda: sys.stderr.write("Connected to " + interface.connection_msg + "\n"))
+        if not interface.start(wait=True):
+            print_msg("Not connected, aborting.")
+            sys.exit(1)
+        wallet.interface = interface
+        verifier = WalletVerifier(interface, config)
+        verifier.start()
+        wallet.set_verifier(verifier)
+        synchronizer = WalletSynchronizer(wallet, config)
+        synchronizer.start()
+        wallet.update()
+        wallet.save()
+
+
     # run the command
-    if cmd == 'help':
-        cmd2 = firstarg
-        if cmd2 not in known_commands:
-            parser.print_help()
-            print_msg("Type 'electrum help <command>' to see the help for a specific command")
-            print_msg("Type 'electrum --help' to see the list of options")
-            print_msg("List of commands:", ', '.join(known_commands))
-        else:
-            print_msg(known_commands[cmd2])
 
-    elif cmd == 'deseed':
+    if cmd == 'deseed':
         if not wallet.seed:
             print_msg("Error: This wallet has no seed")
         else:
@@ -524,6 +395,7 @@ if __name__ == '__main__':
             if raw_input("Are you sure you want to continue? (y/n) ") in ['y','Y','yes']:
                 wallet.config.path = ns
                 wallet.seed = ''
+                wallet.use_encryption = False
                 wallet.config.set_key('seed','', True)
                 for k in wallet.imported_keys.keys(): wallet.imported_keys[k] = ''
                 wallet.save()
@@ -535,11 +407,11 @@ if __name__ == '__main__':
         print_msg(eval(args[1]))
         wallet.save()
 
-    elif cmd == 'get':
+    elif cmd == 'getconfig':
         key = args[1]
         print_msg(wallet.config.get(key))
 
-    elif cmd == 'set':
+    elif cmd == 'setconfig':
         key, value = args[1:3]
         if key not in ['seed', 'seed_version', 'master_public_key', 'use_encryption']:
             wallet.config.set_key(key, value, True)
@@ -547,41 +419,25 @@ if __name__ == '__main__':
         else:
             print_msg(False)
 
-    elif cmd in [ 'addresses']:
-        for addr in wallet.all_addresses():
-            if options.show_all or not wallet.is_change(addr):
-
-                flags = wallet.get_address_flags(addr)
-                label = wallet.labels.get(addr,'')
-                
-                if label: label = "\"%s\""%label
-
-                if options.show_balance:
-                    h = wallet.history.get(addr,[])
-                    #ni = no = 0
-                    #for item in h:
-                    #    if item['is_input']:  ni += 1
-                    #    else:              no += 1
-                    b = format_satoshis(wallet.get_addr_balance(addr)[0])
-                else: b=''
-                m_addr = "%34s"%addr
-                if options.show_keys:
-                    m_addr += ':' + str(wallet.get_private_key(addr, password))
-                print_msg(flags, m_addr, b, label)
-
-
     elif cmd == 'password':
         new_password = prompt_password('New password:')
         wallet.update_password(seed, password, new_password)
 
-
-
     else:
         cmd_runner = Commands(wallet, interface)
         func = eval('cmd_runner.' + cmd)
-        if password: 
-            args.append( password )
-        func(*args[1:])
+        cmd_runner.password = password
+        try:
+            result = func(*args[1:])
+        except BaseException, e:
+            print_msg("Error: " + str(e))
+            sys.exit(1)
+            
+        if type(result) == str:
+            util.print_msg(result)
+        elif result is not None:
+            util.print_json(result)
+            
         
 
     if cmd not in offline_commands and not options.offline: