mirror of
https://git.wownero.com/wownero/wownero.git
synced 2024-08-15 01:03:23 +00:00
c7bfdc3566
It allows one to connect to a running daemon or wallet, and use its RPC API from python. Usage: python -i console.py <port> It will detect whether it's talking to a daemon or wallet and initialize itself accordingly.
135 lines
4 KiB
Python
Executable file
135 lines
4 KiB
Python
Executable file
#!/usr/bin/env python
|
|
|
|
from __future__ import print_function
|
|
import sys
|
|
import time
|
|
import subprocess
|
|
from signal import SIGTERM
|
|
import socket
|
|
import string
|
|
import os
|
|
|
|
USAGE = 'usage: functional_tests_rpc.py <python> <srcdir> <builddir> [<tests-to-run> | all]'
|
|
DEFAULT_TESTS = ['daemon_info', 'blockchain', 'wallet_address', 'integrated_address', 'mining', 'transfer', 'txpool', 'multisig', 'cold_signing', 'sign_message', 'proofs']
|
|
try:
|
|
python = sys.argv[1]
|
|
srcdir = sys.argv[2]
|
|
builddir = sys.argv[3]
|
|
except:
|
|
print(USAGE)
|
|
sys.exit(1)
|
|
|
|
try:
|
|
sys.argv[4]
|
|
except:
|
|
print(USAGE)
|
|
print('Available tests: ' + string.join(DEFAULT_TESTS, ', '))
|
|
print('Or run all with "all"')
|
|
sys.exit(0)
|
|
|
|
try:
|
|
tests = sys.argv[4:]
|
|
if tests == ['all']:
|
|
tests = DEFAULT_TESTS
|
|
except:
|
|
tests = DEFAULT_TESTS
|
|
|
|
N_MONERODS = 1
|
|
N_WALLETS = 4
|
|
|
|
monerod_base = [builddir + "/bin/monerod", "--regtest", "--fixed-difficulty", "1", "--offline", "--no-igd", "--p2p-bind-port", "monerod_p2p_port", "--rpc-bind-port", "monerod_rpc_port", "--zmq-rpc-bind-port", "monerod_zmq_port", "--non-interactive", "--disable-dns-checkpoints", "--check-updates", "disabled", "--rpc-ssl", "disabled", "--log-level", "1"]
|
|
wallet_base = [builddir + "/bin/monero-wallet-rpc", "--wallet-dir", builddir + "/functional-tests-directory", "--rpc-bind-port", "wallet_port", "--disable-rpc-login", "--rpc-ssl", "disabled", "--daemon-ssl", "disabled", "--daemon-port", "18180", "--log-level", "1"]
|
|
|
|
command_lines = []
|
|
processes = []
|
|
outputs = []
|
|
ports = []
|
|
|
|
for i in range(N_MONERODS):
|
|
command_lines.append([str(18180+i) if x == "monerod_rpc_port" else str(18280+i) if x == "monerod_p2p_port" else str(18380+i) if x == "monerod_zmq_port" else x for x in monerod_base])
|
|
outputs.append(open(builddir + '/tests/functional_tests/monerod' + str(i) + '.log', 'a+'))
|
|
ports.append(18180+i)
|
|
|
|
for i in range(N_WALLETS):
|
|
command_lines.append([str(18090+i) if x == "wallet_port" else x for x in wallet_base])
|
|
outputs.append(open(builddir + '/tests/functional_tests/wallet' + str(i) + '.log', 'a+'))
|
|
ports.append(18090+i)
|
|
|
|
print('Starting servers...')
|
|
try:
|
|
PYTHONPATH = os.environ['PYTHONPATH'] if 'PYTHONPATH' in os.environ else ''
|
|
if len(PYTHONPATH) > 0:
|
|
PYTHONPATH += ':'
|
|
PYTHONPATH += srcdir + '/../../utils/python-rpc'
|
|
os.environ['PYTHONPATH'] = PYTHONPATH
|
|
for i in range(len(command_lines)):
|
|
#print('Running: ' + str(command_lines[i]))
|
|
processes.append(subprocess.Popen(command_lines[i], stdout = outputs[i]))
|
|
except Exception, e:
|
|
print('Error: ' + str(e))
|
|
sys.exit(1)
|
|
|
|
def kill():
|
|
for i in range(len(processes)):
|
|
try: processes[i].send_signal(SIGTERM)
|
|
except: pass
|
|
|
|
# wait for error/startup
|
|
for i in range(10):
|
|
time.sleep(1)
|
|
all_open = True
|
|
for port in ports:
|
|
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
|
|
s.settimeout(1)
|
|
if s.connect_ex(('127.0.0.1', port)) != 0:
|
|
all_open = False
|
|
break
|
|
s.close()
|
|
if all_open:
|
|
break
|
|
|
|
if not all_open:
|
|
print('Failed to start wallet or daemon')
|
|
kill()
|
|
sys.exit(1)
|
|
|
|
PASS = []
|
|
FAIL = []
|
|
for test in tests:
|
|
try:
|
|
print('[TEST STARTED] ' + test)
|
|
cmd = [python, srcdir + '/' + test + ".py"]
|
|
subprocess.check_call(cmd)
|
|
PASS.append(test)
|
|
print('[TEST PASSED] ' + test)
|
|
except:
|
|
FAIL.append(test)
|
|
print('[TEST FAILED] ' + test)
|
|
pass
|
|
|
|
print('Stopping servers...')
|
|
kill()
|
|
|
|
# wait for exit, the poll method does not work (https://bugs.python.org/issue2475) so we wait, possibly forever if the process hangs
|
|
if True:
|
|
for p in processes:
|
|
p.wait()
|
|
else:
|
|
for i in range(10):
|
|
n_returncode = 0
|
|
for p in processes:
|
|
p.poll()
|
|
if p.returncode:
|
|
n_returncode += 1
|
|
if n_returncode == len(processes):
|
|
print('All done: ' + string.join([x.returncode for x in processes], ', '))
|
|
break
|
|
time.sleep(1)
|
|
for p in processes:
|
|
if not p.returncode:
|
|
print('Failed to stop process')
|
|
|
|
if len(FAIL) == 0:
|
|
print('Done, ' + str(len(PASS)) + '/' + str(len(tests)) + ' tests passed')
|
|
else:
|
|
print('Done, ' + str(len(FAIL)) + '/' + str(len(tests)) + ' tests failed: ' + string.join(FAIL, ', '))
|