b12f/nixpkgs
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

nixos/mosquitto: Port integration test to python

Browse source
This commit is contained in:
Jacek Galowicz 2019-11-20 18:33:36 +01:00
parent 6b2504f9f2
commit 855eb6f264
1 changed files with 28 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
nixos/tests/mosquitto.nix
View file

@ -1,4 +1,4 @@
import ./make-test.nix ({ pkgs, ... }:
import ./make-test-python.nix ({ pkgs, ... }:
let
port = 1888;
@ -52,37 +52,44 @@ in {
sub = args:
"(${cmd "sub"} -C 1 ${args} | tee ${file} &)";
in ''
startAll;
$server->waitForUnit("mosquitto.service");
$server->fail("test -f ${file}");
$client1->fail("test -f ${file}");
$client2->fail("test -f ${file}");
start_all()
server.wait_for_unit("mosquitto.service")
for machine in server, client1, client2:
machine.fail("test -f ${file}")
# QoS = 0, so only one subscribers should get it
$server->execute("${sub "-q 0"}");
server.execute(
"${sub "-q 0"}"
)
# we need to give the subscribers some time to connect
$client2->execute("sleep 5");
$client2->succeed("${cmd "pub"} -m FOO -q 0");
$server->waitUntilSucceeds("grep -q FOO ${file}");
$server->execute("rm ${file}");
client2.execute("sleep 5")
client2.succeed(
"${cmd "pub"} -m FOO -q 0"
)
server.wait_until_succeeds("grep -q FOO ${file}")
server.execute("rm ${file}")
# QoS = 1, so both subscribers should get it
$server->execute("${sub "-q 1"}");
$client1->execute("${sub "-q 1"}");
server.execute(
"${sub "-q 1"}"
)
client1.execute(
"${sub "-q 1"}"
)
# we need to give the subscribers some time to connect
$client2->execute("sleep 5");
$client2->succeed("${cmd "pub"} -m BAR -q 1");
client2.execute("sleep 5")
client2.succeed(
"${cmd "pub"} -m BAR -q 1"
)
$server->waitUntilSucceeds("grep -q BAR ${file}");
$server->execute("rm ${file}");
server.wait_until_succeeds("grep -q BAR ${file}")
server.execute("rm ${file}")
$client1->waitUntilSucceeds("grep -q BAR ${file}");
$client1->execute("rm ${file}");
client1.wait_until_succeeds("grep -q BAR ${file}")
client1.execute("rm ${file}")
'';
})