All checks were successful
		
		
	
	Test / Create distribution (push) Successful in 25s
				
			Test / Sandbox (push) Successful in 39s
				
			Test / Sandbox (race detector) (push) Successful in 40s
				
			Test / Hakurei (push) Successful in 43s
				
			Test / Hakurei (race detector) (push) Successful in 44s
				
			Test / Hpkg (push) Successful in 40s
				
			Test / Flake checks (push) Successful in 1m30s
				
			This is more useful now that state is tracked here. Signed-off-by: Ophestra <cat@gensokyo.uk>
		
			
				
	
	
		
			111 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
			
		
		
	
	
			111 lines
		
	
	
		
			3.7 KiB
		
	
	
	
		
			Python
		
	
	
	
	
	
import json
 | 
						|
import shlex
 | 
						|
 | 
						|
q = shlex.quote
 | 
						|
NODE_GROUPS = ["nodes", "floating_nodes"]
 | 
						|
 | 
						|
 | 
						|
def swaymsg(command: str = "", succeed=True, type="command"):
 | 
						|
    assert command != "" or type != "command", "Must specify command or type"
 | 
						|
    shell = q(f"swaymsg -t {q(type)} -- {q(command)}")
 | 
						|
    with machine.nested(
 | 
						|
            f"sending swaymsg {shell!r}" + " (allowed to fail)" * (not succeed)
 | 
						|
    ):
 | 
						|
        ret = (machine.succeed if succeed else machine.execute)(
 | 
						|
            f"su - alice -c {shell}"
 | 
						|
        )
 | 
						|
 | 
						|
    # execute also returns a status code, but disregard.
 | 
						|
    if not succeed:
 | 
						|
        _, ret = ret
 | 
						|
 | 
						|
    if not succeed and not ret:
 | 
						|
        return None
 | 
						|
 | 
						|
    parsed = json.loads(ret)
 | 
						|
    return parsed
 | 
						|
 | 
						|
 | 
						|
def walk(tree):
 | 
						|
    yield tree
 | 
						|
    for group in NODE_GROUPS:
 | 
						|
        for node in tree.get(group, []):
 | 
						|
            yield from walk(node)
 | 
						|
 | 
						|
 | 
						|
def wait_for_window(pattern):
 | 
						|
    def func(last_chance):
 | 
						|
        nodes = (node["name"] for node in walk(swaymsg(type="get_tree")))
 | 
						|
 | 
						|
        if last_chance:
 | 
						|
            nodes = list(nodes)
 | 
						|
            machine.log(f"Last call! Current list of windows: {nodes}")
 | 
						|
 | 
						|
        return any(pattern in name for name in nodes)
 | 
						|
 | 
						|
    retry(func)
 | 
						|
 | 
						|
 | 
						|
def collect_state_ui(name):
 | 
						|
    swaymsg(f"exec hakurei ps > '/tmp/{name}.ps'")
 | 
						|
    machine.copy_from_vm(f"/tmp/{name}.ps", "")
 | 
						|
    swaymsg(f"exec hakurei --json ps > '/tmp/{name}.json'")
 | 
						|
    machine.copy_from_vm(f"/tmp/{name}.json", "")
 | 
						|
    machine.screenshot(name)
 | 
						|
 | 
						|
 | 
						|
def check_state(name, enablements):
 | 
						|
    instances = json.loads(machine.succeed("sudo -u alice -i XDG_RUNTIME_DIR=/run/user/1000 hakurei --json ps"))
 | 
						|
    if len(instances) != 1:
 | 
						|
        raise Exception(f"unexpected state length {len(instances)}")
 | 
						|
    instance = instances[0]
 | 
						|
 | 
						|
    if len(instance['container']['args']) != 1 or not (instance['container']['args'][0].startswith("/nix/store/")) or f"hakurei-{name}-" not in (instance['container']['args'][0]):
 | 
						|
        raise Exception(f"unexpected args {instance['container']['args']}")
 | 
						|
 | 
						|
    if instance['enablements'] != enablements:
 | 
						|
        raise Exception(f"unexpected enablements {instance['enablements']}")
 | 
						|
 | 
						|
 | 
						|
start_all()
 | 
						|
machine.wait_for_unit("multi-user.target")
 | 
						|
 | 
						|
# To check hakurei's version:
 | 
						|
print(machine.succeed("sudo -u alice -i hakurei version"))
 | 
						|
 | 
						|
# Wait for Sway to complete startup:
 | 
						|
machine.wait_for_file("/run/user/1000/wayland-1")
 | 
						|
machine.wait_for_file("/tmp/sway-ipc.sock")
 | 
						|
 | 
						|
# Prepare hpkg directory:
 | 
						|
machine.succeed("install -dm 0700 -o alice -g users /var/lib/hakurei/1000")
 | 
						|
 | 
						|
# Install hpkg app:
 | 
						|
swaymsg("exec hpkg -v install /etc/foot.pkg && touch /tmp/hpkg-install-ok")
 | 
						|
machine.wait_for_file("/tmp/hpkg-install-ok")
 | 
						|
 | 
						|
# Start app (foot) with Wayland enablement:
 | 
						|
swaymsg("exec hpkg -v start org.codeberg.dnkl.foot")
 | 
						|
wait_for_window("hakurei@machine-foot")
 | 
						|
machine.send_chars("clear; wayland-info && touch /tmp/success-client\n")
 | 
						|
machine.wait_for_file("/tmp/hakurei.0/tmpdir/2/success-client")
 | 
						|
collect_state_ui("app_wayland")
 | 
						|
check_state("foot", {"wayland": True, "dbus": True, "pulse": True})
 | 
						|
# Verify acl on XDG_RUNTIME_DIR:
 | 
						|
print(machine.succeed("getfacl --absolute-names --omit-header --numeric /run/user/1000 | grep 1000002"))
 | 
						|
machine.send_chars("exit\n")
 | 
						|
machine.wait_until_fails("pgrep foot")
 | 
						|
# Verify acl cleanup on XDG_RUNTIME_DIR:
 | 
						|
machine.wait_until_fails("getfacl --absolute-names --omit-header --numeric /run/user/1000 | grep 1000002")
 | 
						|
 | 
						|
# Exit Sway and verify process exit status 0:
 | 
						|
swaymsg("exit", succeed=False)
 | 
						|
machine.wait_for_file("/tmp/sway-exit-ok")
 | 
						|
 | 
						|
# Print hakurei share and rundir contents:
 | 
						|
print(machine.succeed("find /tmp/hakurei.0 "
 | 
						|
    + "-path '/tmp/hakurei.0/runtime/*/*' -prune -o "
 | 
						|
    + "-path '/tmp/hakurei.0/tmpdir/*/*' -prune -o "
 | 
						|
    + "-print"))
 | 
						|
print(machine.succeed("find /run/user/1000/hakurei"))
 |