depot/cluster/services/consul/test.nix

{
  testScript = ''
    import json

    start_all()

    with subtest("should form cluster"):
      nodes = [ n for n in machines if n != nowhere ]
      for machine in nodes:
        machine.succeed("systemctl start consul-ready.target")
      for machine in nodes:
        consulConfig = json.loads(machine.succeed("cat /etc/consul.json"))
        addr = consulConfig["addresses"]["http"]
        port = consulConfig["ports"]["http"]
        setEnv = f"CONSUL_HTTP_ADDR={addr}:{port} CONSUL_HTTP_TOKEN_FILE=/run/locksmith/consul-systemManagementToken"
        memberList = machine.succeed(f"{setEnv} consul members --status=alive")
        for machine2 in nodes:
          assert machine2.name in memberList
  '';
}