Browse Source

fix issues highlighted by flake8

master
undeath 7 years ago
parent
commit
03ee77b96b
No known key found for this signature in database
GPG Key ID: F0DF5443BD2F3520
  1. 3
      jmbase/test/test_commands.py
  2. 4
      jmbitcoin/jmbitcoin/secp256k1_main.py
  3. 1
      jmbitcoin/test/test_tx_serialize.py
  4. 6
      jmclient/jmclient/btc.py
  5. 14
      jmclient/jmclient/electruminterface.py
  6. 4
      jmclient/jmclient/maker.py
  7. 8
      jmclient/jmclient/podle.py
  8. 4
      jmclient/jmclient/taker_utils.py
  9. 5
      jmclient/jmclient/yieldgenerator.py
  10. 4
      jmclient/test/test_client_protocol.py
  11. 4
      jmclient/test/test_commitment_utils.py
  12. 4
      jmclient/test/test_configure.py
  13. 7
      jmclient/test/test_maker.py
  14. 7
      jmclient/test/test_podle.py
  15. 10
      jmclient/test/test_taker.py
  16. 5
      jmclient/test/test_tx_creation.py
  17. 2
      jmdaemon/jmdaemon/daemon_protocol.py
  18. 2
      jmdaemon/jmdaemon/irc.py
  19. 12
      jmdaemon/jmdaemon/message_channel.py
  20. 5
      jmdaemon/jmdaemon/orderbookwatch.py
  21. 2
      jmdaemon/jmdaemon/socks.py
  22. 6
      jmdaemon/test/test_daemon_protocol.py
  23. 15
      jmdaemon/test/test_irc_messaging.py
  24. 13
      jmdaemon/test/test_message_channel.py
  25. 9
      scripts/add-utxo.py
  26. 34
      scripts/joinmarket-qt.py
  27. 1
      scripts/obwatch/ob-watcher.py
  28. 11
      scripts/sendpayment.py
  29. 8
      scripts/sendtomany.py
  30. 16
      scripts/tumbler.py
  31. 4
      scripts/yg-privacyenhanced.py
  32. 3
      scripts/yield-generator-basic.py
  33. 9
      test/ygrunner.py

3
jmbase/test/test_commands.py

@ -1,12 +1,11 @@
#! /usr/bin/env python #! /usr/bin/env python
from __future__ import print_function from __future__ import print_function
from twisted.internet import protocol, reactor from twisted.internet import protocol, reactor, task
from twisted.internet.error import (ConnectionLost, ConnectionAborted, from twisted.internet.error import (ConnectionLost, ConnectionAborted,
ConnectionClosed, ConnectionDone) ConnectionClosed, ConnectionDone)
from twisted.protocols.amp import UnknownRemoteError from twisted.protocols.amp import UnknownRemoteError
from twisted.protocols import amp from twisted.protocols import amp
from twisted.trial import unittest from twisted.trial import unittest
from twisted.internet import reactor, task
from jmbase.commands import * from jmbase.commands import *

4
jmbitcoin/jmbitcoin/secp256k1_main.py

@ -32,10 +32,6 @@ if sys.version_info.major == 2:
256: ''.join([chr(x) for x in range(256)]) 256: ''.join([chr(x) for x in range(256)])
} }
def bin_dbl_sha256(s):
bytes_to_hash = from_string_to_bytes(s)
return hashlib.sha256(hashlib.sha256(bytes_to_hash).digest()).digest()
def lpad(msg, symbol, length): def lpad(msg, symbol, length):
if len(msg) >= length: if len(msg) >= length:
return msg return msg

1
jmbitcoin/test/test_tx_serialize.py

@ -1,4 +1,3 @@
import sys
import jmbitcoin as btc import jmbitcoin as btc
import pytest import pytest
import json import json

6
jmclient/jmclient/btc.py

@ -7,8 +7,6 @@ BTC_P2SH_VBYTE = {"mainnet": 0x05, "testnet": 0xc4}
PODLE_COMMIT_FILE = None PODLE_COMMIT_FILE = None
from jmbase.support import get_log from jmbase.support import get_log
import binascii, sys, re, hashlib, base64
from pprint import pformat
log = get_log() log = get_log()
#Required only for PoDLE calculation: #Required only for PoDLE calculation:
@ -68,7 +66,7 @@ except ImportError:
#Electrum specific code starts here #Electrum specific code starts here
import electrum.bitcoin as ebt import electrum.bitcoin as ebt
import electrum.transaction as etr import electrum.transaction as etr
from ecdsa.ecdsa import curve_secp256k1, generator_secp256k1, point_is_valid from ecdsa.ecdsa import point_is_valid
from ecdsa.util import string_to_number, sigdecode_der, sigencode_der from ecdsa.util import string_to_number, sigdecode_der, sigencode_der
from ecdsa import VerifyingKey, BadSignatureError, BadDigestError from ecdsa import VerifyingKey, BadSignatureError, BadDigestError
from ecdsa.curves import SECP256k1 from ecdsa.curves import SECP256k1
@ -193,7 +191,7 @@ except ImportError:
try: try:
verified = ecdsa_pub.verify_digest(sig, txforsig, verified = ecdsa_pub.verify_digest(sig, txforsig,
sigdecode = sigdecode_der) sigdecode = sigdecode_der)
except BadSignatureError, BadDigestError: except (BadSignatureError, BadDigestError):
return False return False
return True return True

14
jmclient/jmclient/electruminterface.py

@ -15,8 +15,8 @@ from twisted.internet import reactor, task, defer
from .blockchaininterface import BlockchainInterface from .blockchaininterface import BlockchainInterface
from .configure import get_p2sh_vbyte from .configure import get_p2sh_vbyte
from .support import get_log from .support import get_log
from .electrum_data import (get_default_ports, get_default_servers, from .electrum_data import get_default_servers, set_electrum_testnet,\
set_electrum_testnet, DEFAULT_PROTO) DEFAULT_PROTO
log = get_log() log = get_log()
@ -290,19 +290,19 @@ class ElectrumInterface(BlockchainInterface):
tah[i]['synced'] = True tah[i]['synced'] = True
#Having updated this specific record, check if the entire batch from start_index #Having updated this specific record, check if the entire batch from start_index
#has been synchronized #has been synchronized
if all([tah[i]['synced'] for i in range(start_index, start_index + self.BATCH_SIZE)]): if all([tah[j]['synced'] for j in range(start_index, start_index + self.BATCH_SIZE)]):
#check if unused goes back as much as gaplimit *and* we are ahead of any #check if unused goes back as much as gaplimit *and* we are ahead of any
#existing index_cache from the wallet file; if both true, end, else, continue #existing index_cache from the wallet file; if both true, end, else, continue
#to next batch #to next batch
if all([tah[i]['used'] is False for i in range( if all([tah[j]['used'] is False for j in range(
start_index + self.BATCH_SIZE - wallet.gap_limit, start_index + self.BATCH_SIZE - wallet.gap_limit,
start_index + self.BATCH_SIZE)]): start_index + self.BATCH_SIZE)]):
last_used_addr = None last_used_addr = None
#to find last used, note that it may be in the *previous* batch; #to find last used, note that it may be in the *previous* batch;
#may as well just search from the start, since it takes no time. #may as well just search from the start, since it takes no time.
for i in range(start_index + self.BATCH_SIZE): for j in range(start_index + self.BATCH_SIZE):
if tah[i]['used']: if tah[j]['used']:
last_used_addr = tah[i]['addr'] last_used_addr = tah[j]['addr']
if last_used_addr: if last_used_addr:
wallet.set_next_index( wallet.set_next_index(
mixdepth, forchange, mixdepth, forchange,

4
jmclient/jmclient/maker.py

@ -214,8 +214,8 @@ class Maker(object):
self.offerlist.remove(order[0]) self.offerlist.remove(order[0])
if len(to_announce) > 0: if len(to_announce) > 0:
for ann in to_announce: for ann in to_announce:
oldorder_s = [order for order in self.offerlist oldorder_s = [o for o in self.offerlist
if order['oid'] == ann['oid']] if o['oid'] == ann['oid']]
if len(oldorder_s) > 0: if len(oldorder_s) > 0:
self.offerlist.remove(oldorder_s[0]) self.offerlist.remove(oldorder_s[0])
self.offerlist += to_announce self.offerlist += to_announce

8
jmclient/jmclient/podle.py

@ -3,13 +3,15 @@ from __future__ import print_function
#Proof Of Discrete Logarithm Equivalence #Proof Of Discrete Logarithm Equivalence
#For algorithm steps, see https://gist.github.com/AdamISZ/9cbba5e9408d23813ca8 #For algorithm steps, see https://gist.github.com/AdamISZ/9cbba5e9408d23813ca8
import os import os
import sys
import hashlib import hashlib
import json import json
import binascii import binascii
from btc import multiply, add_pubkeys, getG, podle_PublicKey,\
podle_PrivateKey, encode, decode, N, podle_PublicKey_class
PODLE_COMMIT_FILE = None PODLE_COMMIT_FILE = None
from btc import (multiply, add_pubkeys, getG, podle_PublicKey, podle_PrivateKey,
encode, decode, N,
podle_PublicKey_class, podle_PrivateKey_class)
def set_commitment_file(file_loc): def set_commitment_file(file_loc):

4
jmclient/jmclient/taker_utils.py

@ -1,5 +1,4 @@
from __future__ import absolute_import, print_function from __future__ import absolute_import, print_function
from jmclient import schedule_to_text, human_readable_schedule_entry
import logging import logging
import pprint import pprint
import os import os
@ -7,7 +6,8 @@ import time
import numbers import numbers
from binascii import hexlify, unhexlify from binascii import hexlify, unhexlify
from .configure import get_log, jm_single, validate_address from .configure import get_log, jm_single, validate_address
from .schedule import human_readable_schedule_entry, tweak_tumble_schedule from .schedule import human_readable_schedule_entry, tweak_tumble_schedule,\
schedule_to_text
from .wallet import BaseWallet, estimate_tx_fee from .wallet import BaseWallet, estimate_tx_fee
from .btc import deserialize, mktx, serialize, txhash from .btc import deserialize, mktx, serialize, txhash
log = get_log() log = get_log()

5
jmclient/jmclient/yieldgenerator.py

@ -7,9 +7,8 @@ import time
import abc import abc
from twisted.python.log import startLogging from twisted.python.log import startLogging
from optparse import OptionParser from optparse import OptionParser
from jmclient import (Maker, jm_single, get_network, load_program_config, get_log, from jmclient import Maker, jm_single, load_program_config, get_log,\
sync_wallet, JMClientProtocolFactory, sync_wallet, JMClientProtocolFactory, start_reactor, calc_cj_fee
start_reactor, calc_cj_fee, WalletError)
from .wallet_utils import open_test_wallet_maybe, get_wallet_path from .wallet_utils import open_test_wallet_maybe, get_wallet_path
jlog = get_log() jlog = get_log()

4
jmclient/test/test_client_protocol.py

@ -2,8 +2,8 @@
from __future__ import absolute_import from __future__ import absolute_import
'''test client-protocol interfacae.''' '''test client-protocol interfacae.'''
from jmclient import (get_schedule, load_program_config, start_reactor, from jmclient import load_program_config, Taker, get_log,\
Taker, get_log, JMClientProtocolFactory, jm_single) JMClientProtocolFactory, jm_single
from jmclient.client_protocol import JMTakerClientProtocol from jmclient.client_protocol import JMTakerClientProtocol
from twisted.python.log import msg as tmsg from twisted.python.log import msg as tmsg
from twisted.internet import protocol, reactor, task from twisted.internet import protocol, reactor, task

4
jmclient/test/test_commitment_utils.py

@ -5,8 +5,7 @@ import pytest
from jmclient import (load_program_config, jm_single) from jmclient import (load_program_config, jm_single)
from jmclient.commitment_utils import get_utxo_info, validate_utxo_data from jmclient.commitment_utils import get_utxo_info, validate_utxo_data
from taker_test_data import (t_utxos_by_mixdepth, t_selected_utxos, t_orderbook,
t_maker_response, t_chosen_orders, t_dummy_ext)
def test_get_utxo_info(): def test_get_utxo_info():
load_program_config() load_program_config()
@ -55,4 +54,3 @@ def test_get_utxo_info():
retval = validate_utxo_data(utxodatas, False) retval = validate_utxo_data(utxodatas, False)
assert not retval assert not retval
dbci.setQUSFail(False) dbci.setQUSFail(False)

4
jmclient/test/test_configure.py

@ -3,9 +3,7 @@ from __future__ import absolute_import
'''test configure module.''' '''test configure module.'''
import pytest import pytest
from jmclient import (load_program_config, jm_single, get_irc_mchannels, from jmclient import load_program_config, jm_single, get_irc_mchannels
BTC_P2PK_VBYTE, BTC_P2SH_VBYTE, validate_address,
JsonRpcConnectionError)
from jmclient.configure import (get_config_irc_channel, get_p2sh_vbyte, from jmclient.configure import (get_config_irc_channel, get_p2sh_vbyte,
get_p2pk_vbyte, get_blockchain_interface_instance) get_p2pk_vbyte, get_blockchain_interface_instance)
import os import os

7
jmclient/test/test_maker.py

@ -77,10 +77,9 @@ def get_address_generator(script_pre, script_post, vbyte):
counter += 1 counter += 1
def create_tx_and_offerlist(cj_addr, changeaddr, other_output_scripts, def create_tx_and_offerlist(cj_addr, cj_change_addr, other_output_scripts,
cj_script=None, cj_change_script=None, offertype='swreloffer'): cj_script=None, cj_change_script=None, offertype='swreloffer'):
assert len(other_output_scripts) % 2 == 0, "bug in test" assert len(other_output_scripts) % 2 == 0, "bug in test"
other_participant_count = len(other_output_scripts) // 2
cj_value = 100000000 cj_value = 100000000
maker_total_value = cj_value*3 maker_total_value = cj_value*3
@ -88,7 +87,7 @@ def create_tx_and_offerlist(cj_addr, changeaddr, other_output_scripts,
if cj_script is None: if cj_script is None:
cj_script = btc.address_to_script(cj_addr) cj_script = btc.address_to_script(cj_addr)
if cj_change_script is None: if cj_change_script is None:
changeaddr = btc.address_to_script(cj_change_addr) cj_change_script = btc.address_to_script(cj_change_addr)
inputs = create_tx_inputs(3) inputs = create_tx_inputs(3)
outputs = create_tx_outputs( outputs = create_tx_outputs(
@ -101,7 +100,7 @@ def create_tx_and_offerlist(cj_addr, changeaddr, other_output_scripts,
maker_utxos = [inputs[0]] maker_utxos = [inputs[0]]
tx = btc.deserialize(btc.mktx(inputs, outputs)) tx = btc.deserialize(btc.mktx(inputs, outputs))
offerlist = construct_tx_offerlist(cj_addr, changeaddr, maker_utxos, offerlist = construct_tx_offerlist(cj_addr, cj_change_addr, maker_utxos,
maker_total_value, cj_value, offertype) maker_total_value, cj_value, offertype)
return tx, offerlist return tx, offerlist

7
jmclient/test/test_podle.py

@ -7,10 +7,9 @@ import binascii
import json import json
import pytest import pytest
import copy import copy
from jmclient import (load_program_config, get_log, jm_single, generate_podle, from jmclient import load_program_config, get_log, jm_single, generate_podle,\
generate_podle_error_string, set_commitment_file, generate_podle_error_string, get_commitment_file, PoDLE,\
get_commitment_file, PoDLE, get_podle_commitments, get_podle_commitments, add_external_commitments, update_commitments
add_external_commitments, update_commitments)
from jmclient.podle import verify_all_NUMS, verify_podle, PoDLEError from jmclient.podle import verify_all_NUMS, verify_podle, PoDLEError
from commontest import make_wallets from commontest import make_wallets
log = get_log() log = get_log()

10
jmclient/test/test_taker.py

@ -9,11 +9,11 @@ import shutil
import pytest import pytest
import json import json
from base64 import b64encode from base64 import b64encode
from jmclient import ( from jmclient import load_program_config, jm_single, set_commitment_file,\
load_program_config, jm_single, set_commitment_file, get_commitment_file, get_commitment_file, SegwitLegacyWallet, Taker, VolatileStorage,\
SegwitLegacyWallet, Taker, VolatileStorage, get_p2sh_vbyte, get_network) get_network
from taker_test_data import (t_utxos_by_mixdepth, t_selected_utxos, t_orderbook, from taker_test_data import t_utxos_by_mixdepth, t_orderbook,\
t_maker_response, t_chosen_orders, t_dummy_ext) t_maker_response, t_chosen_orders, t_dummy_ext
class DummyWallet(SegwitLegacyWallet): class DummyWallet(SegwitLegacyWallet):

5
jmclient/test/test_tx_creation.py

@ -9,9 +9,8 @@ from commontest import make_wallets, make_sign_and_push
import jmbitcoin as bitcoin import jmbitcoin as bitcoin
import pytest import pytest
from jmclient import ( from jmclient import load_program_config, jm_single, sync_wallet,\
load_program_config, jm_single, sync_wallet, get_p2pk_vbyte, get_log, get_p2pk_vbyte, get_log
select_gradual, select, select_greedy, select_greediest, estimate_tx_fee)
log = get_log() log = get_log()
#just a random selection of pubkeys for receiving multisigs; #just a random selection of pubkeys for receiving multisigs;

2
jmdaemon/jmdaemon/daemon_protocol.py

@ -17,7 +17,7 @@ from twisted.internet import reactor, ssl
from twisted.internet.protocol import ServerFactory from twisted.internet.protocol import ServerFactory
from twisted.internet.error import (ConnectionLost, ConnectionAborted, from twisted.internet.error import (ConnectionLost, ConnectionAborted,
ConnectionClosed, ConnectionDone) ConnectionClosed, ConnectionDone)
from twisted.python import failure, log from twisted.python import log
import json import json
import threading import threading
import os import os

2
jmdaemon/jmdaemon/irc.py

@ -6,8 +6,6 @@ from twisted.internet.endpoints import TCP4ClientEndpoint
from twisted.application.internet import ClientService from twisted.application.internet import ClientService
from twisted.internet.ssl import ClientContextFactory from twisted.internet.ssl import ClientContextFactory
from twisted.words.protocols import irc from twisted.words.protocols import irc
from twisted.internet.error import (ConnectionLost, ConnectionAborted,
ConnectionClosed, ConnectionDone)
from jmdaemon.message_channel import MessageChannel from jmdaemon.message_channel import MessageChannel
from jmbase.support import get_log, chunks from jmbase.support import get_log, chunks
from txsocksx.client import SOCKS5ClientEndpoint from txsocksx.client import SOCKS5ClientEndpoint

12
jmdaemon/jmdaemon/message_channel.py

@ -3,11 +3,9 @@ from __future__ import print_function
import abc import abc
import base64 import base64
import threading import threading
from jmdaemon import ( from jmdaemon import encrypt_encode, decode_decrypt, COMMAND_PREFIX,\
encrypt_encode, decode_decrypt, COMMAND_PREFIX, ORDER_KEYS, NICK_HASH_LENGTH, NICK_MAX_ENCODED, plaintext_commands,\
NICK_HASH_LENGTH, NICK_MAX_ENCODED, JM_VERSION, JOINMARKET_NICK_HEADER, encrypted_commands, commitment_broadcast_list, offername_list
nickname, plaintext_commands, encrypted_commands, commitment_broadcast_list,
offername_list, public_commands, private_commands)
from jmbase.support import get_log from jmbase.support import get_log
from functools import wraps from functools import wraps
@ -156,8 +154,8 @@ class MessageChannelCollection(object):
may be some issues with intialization. may be some issues with intialization.
""" """
if mchannel not in self.mchannels: if mchannel not in self.mchannels:
self.mc_status[mc] = 0 self.mc_status[mchannel] = 0
self.nicks_seen[mc] = set() self.nicks_seen[mchannel] = set()
self.mchannels += mchannel self.mchannels += mchannel
self.mchannels = list(set(self.mchannels)) self.mchannels = list(set(self.mchannels))

5
jmdaemon/jmdaemon/orderbookwatch.py

@ -1,14 +1,9 @@
#! /usr/bin/env python #! /usr/bin/env python
from __future__ import absolute_import, print_function from __future__ import absolute_import, print_function
import base64
import pprint
import random
import sqlite3 import sqlite3
import sys import sys
import time
import threading import threading
import json
from decimal import InvalidOperation, Decimal from decimal import InvalidOperation, Decimal
from jmdaemon.protocol import JM_VERSION from jmdaemon.protocol import JM_VERSION

2
jmdaemon/jmdaemon/socks.py

@ -217,7 +217,7 @@ class socksocket(socket.socket):
if authstat[1] != "\x00": if authstat[1] != "\x00":
# Authentication failed # Authentication failed
self.close() self.close()
raise Socks5AuthError, (3, _socks5autherrors[3]) raise Socks5AuthError((3, _socks5autherrors[3]))
# Authentication succeeded # Authentication succeeded
else: else:
# Reaching here is always bad # Reaching here is always bad

6
jmdaemon/test/test_daemon_protocol.py

@ -2,11 +2,11 @@
from __future__ import absolute_import from __future__ import absolute_import
'''test daemon-protocol interfacae.''' '''test daemon-protocol interfacae.'''
from jmdaemon import (JMDaemonServerProtocolFactory, MessageChannelCollection) from jmdaemon import MessageChannelCollection
from jmdaemon.orderbookwatch import OrderbookWatch from jmdaemon.orderbookwatch import OrderbookWatch
from jmdaemon.daemon_protocol import JMDaemonServerProtocol from jmdaemon.daemon_protocol import JMDaemonServerProtocol
from jmdaemon.protocol import (COMMAND_PREFIX, ORDER_KEYS, NICK_HASH_LENGTH, from jmdaemon.protocol import NICK_HASH_LENGTH, NICK_MAX_ENCODED, JM_VERSION,\
NICK_MAX_ENCODED, JM_VERSION, JOINMARKET_NICK_HEADER) JOINMARKET_NICK_HEADER
from jmclient import (load_program_config, get_log, jm_single, get_irc_mchannels) from jmclient import (load_program_config, get_log, jm_single, get_irc_mchannels)
from twisted.python.log import msg as tmsg from twisted.python.log import msg as tmsg
from twisted.internet import protocol, reactor, task from twisted.internet import protocol, reactor, task

15
jmdaemon/test/test_irc_messaging.py

@ -2,21 +2,10 @@
from __future__ import absolute_import from __future__ import absolute_import
'''Tests of joinmarket bots end-to-end (including IRC and bitcoin) ''' '''Tests of joinmarket bots end-to-end (including IRC and bitcoin) '''
import subprocess
import signal
import os
import pytest
import time import time
import threading
import hashlib
from twisted.trial import unittest from twisted.trial import unittest
from twisted.internet import reactor, task, defer from twisted.internet import reactor, task
import jmbitcoin as btc from jmdaemon import IRCMessageChannel, MessageChannelCollection
from jmdaemon import (JOINMARKET_NICK_HEADER, NICK_HASH_LENGTH,
NICK_MAX_ENCODED, IRCMessageChannel,
MessageChannelCollection)
from jmdaemon.message_channel import CJPeerError
import jmdaemon
#needed for test framework #needed for test framework
from jmclient import (load_program_config, get_irc_mchannels, jm_single) from jmclient import (load_program_config, get_irc_mchannels, jm_single)

13
jmdaemon/test/test_message_channel.py

@ -3,17 +3,13 @@ from __future__ import absolute_import
'''test messagechannel management code.''' '''test messagechannel management code.'''
import pytest import pytest
from jmdaemon import (JMDaemonServerProtocolFactory, MessageChannelCollection) from jmdaemon import MessageChannelCollection
from jmdaemon.message_channel import MChannelThread from jmdaemon.message_channel import MChannelThread
from jmdaemon.orderbookwatch import OrderbookWatch from jmdaemon.orderbookwatch import OrderbookWatch
from jmdaemon.daemon_protocol import JMDaemonServerProtocol from jmdaemon.protocol import COMMAND_PREFIX, NICK_HASH_LENGTH,\
from jmdaemon.protocol import (COMMAND_PREFIX, ORDER_KEYS, NICK_HASH_LENGTH, NICK_MAX_ENCODED, JM_VERSION, JOINMARKET_NICK_HEADER
NICK_MAX_ENCODED, JM_VERSION, JOINMARKET_NICK_HEADER)
from jmclient import get_log from jmclient import get_log
import os
from jmbase.commands import *
from msgdata import * from msgdata import *
import json
import time import time
import hashlib import hashlib
import base64 import base64
@ -21,7 +17,8 @@ import traceback
import threading import threading
import jmbitcoin as bitcoin import jmbitcoin as bitcoin
from dummy_mc import DummyMessageChannel from dummy_mc import DummyMessageChannel
from twisted.internet import reactor
jlog = get_log() jlog = get_log()
def make_valid_nick(i=0): def make_valid_nick(i=0):

9
scripts/add-utxo.py

@ -14,11 +14,10 @@ from pprint import pformat
from optparse import OptionParser from optparse import OptionParser
import jmclient.btc as btc import jmclient.btc as btc
from jmclient import ( from jmclient import load_program_config, jm_single, get_p2pk_vbyte,\
load_program_config, jm_single, get_p2pk_vbyte, open_wallet, WalletError, open_wallet, sync_wallet, add_external_commitments, update_commitments,\
sync_wallet, add_external_commitments, generate_podle, update_commitments, PoDLE, get_podle_commitments, get_utxo_info, validate_utxo_data, quit,\
PoDLE, set_commitment_file, get_podle_commitments, get_utxo_info, get_wallet_path
validate_utxo_data, quit, get_wallet_path)
def add_ext_commitments(utxo_datas): def add_ext_commitments(utxo_datas):

34
scripts/joinmarket-qt.py

@ -20,12 +20,11 @@ Some widgets copied and modified from https://github.com/spesmilo/electrum
along with this program. If not, see <http://www.gnu.org/licenses/>. along with this program. If not, see <http://www.gnu.org/licenses/>.
''' '''
import sys, base64, textwrap, datetime, os, logging import sys, datetime, os, logging
import platform, csv, threading, time import platform, csv, threading, time
from decimal import Decimal from decimal import Decimal
from functools import partial
from PyQt4 import QtCore from PyQt4 import QtCore
from PyQt4.QtGui import * from PyQt4.QtGui import *
@ -52,24 +51,19 @@ JM_CORE_VERSION = '0.3.5'
#Version of this Qt script specifically #Version of this Qt script specifically
JM_GUI_VERSION = '7' JM_GUI_VERSION = '7'
from jmclient import ( from jmclient import load_program_config, get_network,\
load_program_config, get_network, open_test_wallet_maybe, get_wallet_path, open_test_wallet_maybe, get_wallet_path, get_p2sh_vbyte, get_p2pk_vbyte,\
get_p2sh_vbyte, get_p2pk_vbyte, jm_single, validate_address, get_log, jm_single, validate_address, get_log, weighted_order_choose, Taker,\
weighted_order_choose, Taker, JMClientProtocolFactory, WalletError, JMClientProtocolFactory, start_reactor, get_schedule, schedule_to_text,\
start_reactor, get_schedule, get_tumble_schedule, schedule_to_text, get_blockchain_interface_instance, direct_send,\
get_blockchain_interface_instance, sync_wallet, RegtestBitcoinCoreInterface, tumbler_taker_finished_update,\
direct_send, RegtestBitcoinCoreInterface, tweak_tumble_schedule, get_tumble_log, restart_wait, tumbler_filter_orders_callback,\
human_readable_schedule_entry, tumbler_taker_finished_update, wallet_generate_recover_bip39, wallet_display
get_tumble_log, restart_wait, tumbler_filter_orders_callback, from qtsupport import ScheduleWizard, TumbleRestartWizard, config_tips,\
wallet_generate_recover_bip39, wallet_display) config_types, QtHandler, XStream, Buttons, OkButton, CancelButton,\
PasswordDialog, MyTreeWidget, JMQtMessageBox, BLUE_FG,\
from qtsupport import (ScheduleWizard, TumbleRestartWizard, warnings, config_tips, donation_more_message
config_types, TaskThread, QtHandler, XStream, Buttons,
CloseButton, CopyButton, CopyCloseButton, OkButton,
CancelButton, check_password_strength,
update_password_strength, make_password_dialog,
PasswordDialog, MyTreeWidget, JMQtMessageBox, BLUE_FG,
donation_more_message)
from twisted.internet import task from twisted.internet import task
def satoshis_to_amt_str(x): def satoshis_to_amt_str(x):

1
scripts/obwatch/ob-watcher.py

@ -411,7 +411,6 @@ def get_dummy_nick():
an orderbook request, so no such need, but for better an orderbook request, so no such need, but for better
privacy, a conformant nick is created based on a random privacy, a conformant nick is created based on a random
pseudo-pubkey.""" pseudo-pubkey."""
import binascii
nick_pkh_raw = hashlib.sha256(os.urandom(10)).digest()[:NICK_HASH_LENGTH] nick_pkh_raw = hashlib.sha256(os.urandom(10)).digest()[:NICK_HASH_LENGTH]
nick_pkh = btc.changebase(nick_pkh_raw, 256, 58) nick_pkh = btc.changebase(nick_pkh_raw, 256, 58)
#right pad to maximum possible; b58 is not fixed length. #right pad to maximum possible; b58 is not fixed length.

11
scripts/sendpayment.py

@ -12,12 +12,11 @@ import sys
from twisted.internet import reactor from twisted.internet import reactor
import pprint import pprint
from jmclient import ( from jmclient import Taker, load_program_config, get_schedule,\
Taker, load_program_config, get_schedule, JMClientProtocolFactory, JMClientProtocolFactory, start_reactor, validate_address, jm_single,\
start_reactor, validate_address, jm_single, WalletError, choose_orders, cheapest_order_choose, weighted_order_choose, sync_wallet,\
choose_sweep_orders, cheapest_order_choose, weighted_order_choose, RegtestBitcoinCoreInterface, estimate_tx_fee, direct_send,\
sync_wallet, RegtestBitcoinCoreInterface, estimate_tx_fee, direct_send, open_test_wallet_maybe, get_wallet_path
open_test_wallet_maybe, get_wallet_path)
from twisted.python.log import startLogging from twisted.python.log import startLogging
from jmbase.support import get_log from jmbase.support import get_log
from cli_options import get_sendpayment_parser from cli_options import get_sendpayment_parser

8
scripts/sendtomany.py

@ -9,9 +9,11 @@ for other reasons).
from pprint import pformat from pprint import pformat
from optparse import OptionParser from optparse import OptionParser
import jmclient.btc as btc import jmclient.btc as btc
from jmclient import (load_program_config, estimate_tx_fee, jm_single, from jmclient import load_program_config, estimate_tx_fee, jm_single,\
get_p2sh_vbyte, get_p2pk_vbyte, validate_address, get_log, get_p2pk_vbyte, validate_address, get_log, get_utxo_info,\
get_utxo_info, validate_utxo_data, quit) validate_utxo_data, quit
log = get_log() log = get_log()
def sign(utxo, priv, destaddrs, segwit=True): def sign(utxo, priv, destaddrs, segwit=True):

16
scripts/tumbler.py

@ -6,14 +6,12 @@ from twisted.internet import reactor
import os import os
import pprint import pprint
from twisted.python.log import startLogging from twisted.python.log import startLogging
from jmclient import ( from jmclient import Taker, load_program_config, get_schedule,\
Taker, load_program_config, get_schedule, weighted_order_choose, weighted_order_choose, JMClientProtocolFactory, start_reactor, jm_single,\
JMClientProtocolFactory, start_reactor, validate_address, jm_single, get_wallet_path, open_test_wallet_maybe, sync_wallet,\
get_wallet_path, open_test_wallet_maybe, WalletError, sync_wallet, get_tumble_schedule, RegtestBitcoinCoreInterface, schedule_to_text,\
get_tumble_schedule, RegtestBitcoinCoreInterface, estimate_tx_fee, restart_waiter, get_tumble_log, tumbler_taker_finished_update,\
tweak_tumble_schedule, human_readable_schedule_entry, schedule_to_text, tumbler_filter_orders_callback
restart_waiter, get_tumble_log, tumbler_taker_finished_update,
tumbler_filter_orders_callback)
from jmbase.support import get_log from jmbase.support import get_log
from cli_options import get_tumbler_parser from cli_options import get_tumbler_parser
log = get_log() log = get_log()
@ -26,7 +24,7 @@ def main():
(options, args) = get_tumbler_parser().parse_args() (options, args) = get_tumbler_parser().parse_args()
options = vars(options) options = vars(options)
if len(args) < 1: if len(args) < 1:
parser.error('Needs a wallet file') print('Error: Needs a wallet file')
sys.exit(0) sys.exit(0)
load_program_config() load_program_config()
#Load the wallet #Load the wallet

4
scripts/yg-privacyenhanced.py

@ -3,8 +3,8 @@ from __future__ import absolute_import, print_function
import random import random
from jmclient import (YieldGenerator, YieldGeneratorBasic, ygmain, get_log, from jmclient import YieldGeneratorBasic, ygmain, get_log, jm_single
jm_single, calc_cj_fee)
# This is a maker for the purposes of generating a yield from held bitcoins # This is a maker for the purposes of generating a yield from held bitcoins
# while maximising the difficulty of spying on blockchain activity. # while maximising the difficulty of spying on blockchain activity.

3
scripts/yield-generator-basic.py

@ -2,8 +2,7 @@
from __future__ import absolute_import, print_function from __future__ import absolute_import, print_function
from jmclient import (YieldGenerator, YieldGeneratorBasic, ygmain, get_log, from jmclient import YieldGeneratorBasic, ygmain, get_log
jm_single, calc_cj_fee)
"""THESE SETTINGS CAN SIMPLY BE EDITED BY HAND IN THIS FILE: """THESE SETTINGS CAN SIMPLY BE EDITED BY HAND IN THIS FILE:
""" """

9
test/ygrunner.py

@ -13,14 +13,11 @@ from __future__ import absolute_import, print_function
--nirc=2 -s test/ygrunner.py --nirc=2 -s test/ygrunner.py
''' '''
from common import make_wallets from common import make_wallets
import os
import pytest import pytest
import sys
import time
import random import random
from jmclient import (YieldGeneratorBasic, ygmain, load_program_config, from jmclient import YieldGeneratorBasic, load_program_config, jm_single,\
jm_single, sync_wallet, JMClientProtocolFactory, sync_wallet, JMClientProtocolFactory, start_reactor
start_reactor)
class MaliciousYieldGenerator(YieldGeneratorBasic): class MaliciousYieldGenerator(YieldGeneratorBasic):
"""Overrides, randomly, some maker functions """Overrides, randomly, some maker functions

Loading…
Cancel
Save