Merge pull request #2608 from NorbertHeusser/split-client-tests
Split client python tests into test with/without TLS/PSKpull/2536/merge
Roger Light
3 years ago
committed by
GitHub
commit
7c295286ac
@ -0,0 +1,34 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_sub'] + args
|
||||
|
||||
sub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
if mosq_test.wait_for_subprocess(sub):
|
||||
print("sub not terminated")
|
||||
raise mosq_test.TestError(1)
|
||||
(stdo, stde) = sub.communicate()
|
||||
if sub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(sub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_sub --help' to see usage.\n"
|
||||
|
||||
# Missing args for TLS-PSK related options
|
||||
do_test(['--psk'], "Error: --psk argument given but no key specified.\n\n" + helps, 1)
|
||||
do_test(['--psk-identity'], "Error: --psk-identity argument given but no identity specified.\n\n" + helps, 1)
|
||||
@ -0,0 +1,42 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_sub'] + args
|
||||
|
||||
sub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
if mosq_test.wait_for_subprocess(sub):
|
||||
print("sub not terminated")
|
||||
raise mosq_test.TestError(1)
|
||||
(stdo, stde) = sub.communicate()
|
||||
if sub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(sub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_sub --help' to see usage.\n"
|
||||
|
||||
# Missing args for TLS related options
|
||||
do_test(['--cafile'], "Error: --cafile argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--capath'], "Error: --capath argument given but no directory specified.\n\n" + helps, 1)
|
||||
do_test(['--cert'], "Error: --cert argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--ciphers'], "Error: --ciphers argument given but no ciphers specified.\n\n" + helps, 1)
|
||||
do_test(['--key'], "Error: --key argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--keyform'], "Error: --keyform argument given but no keyform specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-alpn'], "Error: --tls-alpn argument given but no protocol specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine'], "Error: --tls-engine argument given but no engine_id specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine-kpass-sha1'], "Error: --tls-engine-kpass-sha1 argument given but no kpass sha1 specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-version'], "Error: --tls-version argument given but no version specified.\n\n" + helps, 1)
|
||||
@ -0,0 +1,40 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_pub'] + args
|
||||
|
||||
pub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
if mosq_test.wait_for_subprocess(pub):
|
||||
print("pub not terminated")
|
||||
raise mosq_test.TestError(1)
|
||||
(stdo, stde) = pub.communicate()
|
||||
if pub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(pub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_pub --help' to see usage.\n"
|
||||
|
||||
# Missing args
|
||||
do_test(['--psk'], "Error: --psk argument given but no key specified.\n\n" + helps, 1)
|
||||
do_test(['--psk-identity'], "Error: --psk-identity argument given but no identity specified.\n\n" + helps, 1)
|
||||
|
||||
# Invalid combinations
|
||||
do_test(['--cafile', 'file', '--psk', 'key'], "Error: Only one of --psk or --cafile/--capath may be used at once.\n" + helps, 1)
|
||||
do_test(['--capath', 'dir', '--psk', 'key'], "Error: Only one of --psk or --cafile/--capath may be used at once.\n" + helps, 1)
|
||||
do_test(['--psk', 'key'], "Error: --psk-identity required if --psk used.\n" + helps, 1)
|
||||
|
||||
@ -0,0 +1,52 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_pub'] + args
|
||||
|
||||
pub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
if mosq_test.wait_for_subprocess(pub):
|
||||
print("pub not terminated")
|
||||
raise mosq_test.TestError(1)
|
||||
(stdo, stde) = pub.communicate()
|
||||
if pub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(pub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_pub --help' to see usage.\n"
|
||||
|
||||
# Missing args
|
||||
do_test(['--cafile'], "Error: --cafile argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--capath'], "Error: --capath argument given but no directory specified.\n\n" + helps, 1)
|
||||
do_test(['--cert'], "Error: --cert argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--ciphers'], "Error: --ciphers argument given but no ciphers specified.\n\n" + helps, 1)
|
||||
do_test(['--key'], "Error: --key argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--keyform'], "Error: --keyform argument given but no keyform specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-alpn'], "Error: --tls-alpn argument given but no protocol specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine'], "Error: --tls-engine argument given but no engine_id specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine-kpass-sha1'], "Error: --tls-engine-kpass-sha1 argument given but no kpass sha1 specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-version'], "Error: --tls-version argument given but no version specified.\n\n" + helps, 1)
|
||||
|
||||
# Invalid combinations
|
||||
do_test(['--cert', 'file'], "Error: Both certfile and keyfile must be provided if one of them is set.\n" + helps, 1)
|
||||
do_test(['--key', 'file'], "Error: Both certfile and keyfile must be provided if one of them is set.\n" + helps, 1)
|
||||
do_test(['--keyform', 'file'], "Error: If keyform is set, keyfile must be also specified.\n" + helps, 1)
|
||||
do_test(['--tls-engine-kpass-sha1', 'hash'], "Error: when using tls-engine-kpass-sha1, both tls-engine and keyform must also be provided.\n" + helps, 1)
|
||||
|
||||
# Invalid values
|
||||
do_test(['-t','topic','-m','1', '--cafile', 'missing'], "Error: Problem setting TLS options: File not found.\n", 1)
|
||||
|
||||
@ -0,0 +1,32 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_rr'] + args
|
||||
|
||||
sub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
sub.wait()
|
||||
(stdo, stde) = sub.communicate()
|
||||
if sub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(sub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_rr --help' to see usage.\n"
|
||||
|
||||
# Missing args for TLS-PSK related options
|
||||
do_test(['--psk'], "Error: --psk argument given but no key specified.\n\n" + helps, 1)
|
||||
do_test(['--psk-identity'], "Error: --psk-identity argument given but no identity specified.\n\n" + helps, 1)
|
||||
@ -0,0 +1,40 @@
|
||||
#!/usr/bin/env python3
|
||||
|
||||
#
|
||||
|
||||
from mosq_test_helper import *
|
||||
|
||||
def do_test(args, stderr_expected, rc_expected):
|
||||
rc = 1
|
||||
|
||||
port = mosq_test.get_port()
|
||||
|
||||
env = {
|
||||
'LD_LIBRARY_PATH': mosq_test.get_build_root() + '/lib',
|
||||
'XDG_CONFIG_HOME':'/tmp/missing'
|
||||
}
|
||||
cmd = ['../../client/mosquitto_rr'] + args
|
||||
|
||||
sub = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, env=env)
|
||||
sub.wait()
|
||||
(stdo, stde) = sub.communicate()
|
||||
if sub.returncode != rc_expected:
|
||||
raise mosq_test.TestError(sub.returncode)
|
||||
if stderr_expected is not None and stde.decode('utf-8') != stderr_expected:
|
||||
raise mosq_test.TestError(stde)
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
helps = "\nUse 'mosquitto_rr --help' to see usage.\n"
|
||||
|
||||
# Missing args for TLS related options
|
||||
do_test(['--cafile'], "Error: --cafile argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--capath'], "Error: --capath argument given but no directory specified.\n\n" + helps, 1)
|
||||
do_test(['--cert'], "Error: --cert argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--ciphers'], "Error: --ciphers argument given but no ciphers specified.\n\n" + helps, 1)
|
||||
do_test(['--key'], "Error: --key argument given but no file specified.\n\n" + helps, 1)
|
||||
do_test(['--keyform'], "Error: --keyform argument given but no keyform specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-alpn'], "Error: --tls-alpn argument given but no protocol specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine'], "Error: --tls-engine argument given but no engine_id specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-engine-kpass-sha1'], "Error: --tls-engine-kpass-sha1 argument given but no kpass sha1 specified.\n\n" + helps, 1)
|
||||
do_test(['--tls-version'], "Error: --tls-version argument given but no version specified.\n\n" + helps, 1)
|
||||
Loading…
Reference in New Issue