blob: 552ff24ff282134ce25710b0827cd9b4df34f75d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
{ config, lib, ... }:
{
name = "olivetin";
meta.maintainers = with lib.maintainers; [ defelo ];
nodes.machine = {
services.olivetin = {
enable = true;
settings = {
actions = [
{
id = "hello_world";
title = "Say Hello";
shell = "echo -n 'Hello World!' | tee /tmp/result";
}
];
};
extraConfigFiles = [
(builtins.toFile "secrets.yaml" ''
actions:
- id: secret
title: Secret Action
shell: echo -n secret > /tmp/result2
'')
];
};
};
interactive.nodes.machine = {
services.olivetin.settings.ListenAddressSingleHTTPFrontend = "0.0.0.0:8000";
networking.firewall.allowedTCPPorts = [ 8000 ];
virtualisation.forwardPorts = [
{
from = "host";
host.port = 8000;
guest.port = 8000;
}
];
};
testScript = ''
import json
import shlex
machine.wait_for_unit("olivetin.service")
machine.wait_for_open_port(8000)
def start_action(action):
if "${config.nodes.machine.services.olivetin.package.releaseSeries}" == "2k":
cmd = f"curl http://localhost:8000/api/StartActionByGetAndWait/{action}"
else:
req = {"actionId": action}
cmd = f"curl -H 'Content-Type: application/json' http://localhost:8000/api/olivetin.api.v1.OliveTinApiService/StartActionAndWait -d {shlex.quote(json.dumps(req))}"
return json.loads(machine.succeed(cmd))
response = start_action("hello_world")
assert response["logEntry"]["exitCode"] == 0
assert response["logEntry"]["output"] == "Hello World!"
assert machine.succeed("cat /tmp/result") == "Hello World!"
response = start_action("secret")
assert response["logEntry"]["exitCode"] == 0
assert machine.succeed("cat /tmp/result2") == "secret"
'';
}
|
