aboutsummaryrefslogtreecommitdiffhomepage
path: root/container/initdaemon_test.go
blob: 0f75498ea611c52e7ffacac7f220e0d05350ce42 (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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
package container

import (
	"os"
	"testing"

	"hakurei.app/check"
	"hakurei.app/internal/stub"
	"hakurei.app/message"
)

func TestEarlyTerminationError(t *testing.T) {
	t.Parallel()

	testCases := []struct {
		name string
		err  error
		want string
		msg  string
	}{
		{"exited", &earlyTerminationError{
			`daemon providing "/run/user/1971/pulse/native"`, 127 << 8,
		}, "exit status 127", `daemon providing "/run/user/1971/pulse/native" exit status 127`},
	}
	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			t.Parallel()

			if got := tc.err.Error(); got != tc.want {
				t.Errorf("Error: %q, want %q", got, tc.want)
			}
			if got := tc.err.(message.Error).Message(); got != tc.msg {
				t.Errorf("Message: %s, want %s", got, tc.msg)
			}
		})
	}
}

func TestDaemonOp(t *testing.T) {
	t.Parallel()

	checkSimple(t, "DaemonOp.late", []simpleTestCase{
		{"success", func(k *kstub) error {
			state := setupState{Params: &Params{Env: []string{"\x00"}}, Context: t.Context(), Msg: k}
			return (&DaemonOp{
				Target: check.MustAbs("/run/user/1971/pulse/native"),
				Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
				Args:   []string{"-v"},
			}).late(&state, k)
		}, stub.Expect{Calls: []stub.Call{
			call("isVerbose", stub.ExpectArgs{}, true, nil),
			call("verbosef", stub.ExpectArgs{"starting %s", []any{`daemon providing "/run/user/1971/pulse/native"`}}, nil, nil),
			call("start", stub.ExpectArgs{"/run/current-system/sw/bin/pipewire-pulse", []string{"/run/current-system/sw/bin/pipewire-pulse", "-v"}, []string{"\x00"}, "/"}, &os.Process{Pid: 0xcafe}, nil),
			call("stat", stub.ExpectArgs{"/run/user/1971/pulse/native"}, isDirFi(false), os.ErrNotExist),
			call("stat", stub.ExpectArgs{"/run/user/1971/pulse/native"}, isDirFi(false), os.ErrNotExist),
			call("stat", stub.ExpectArgs{"/run/user/1971/pulse/native"}, isDirFi(false), os.ErrNotExist),
			call("stat", stub.ExpectArgs{"/run/user/1971/pulse/native"}, isDirFi(false), nil),
			call("verbosef", stub.ExpectArgs{"daemon process %d ready", []any{0xcafe}}, nil, nil),
		}}, nil},
	})

	checkOpsValid(t, []opValidTestCase{
		{"nil", (*DaemonOp)(nil), false},
		{"zero", new(DaemonOp), false},
		{"valid", &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
			Args:   []string{"-v"},
		}, true},
	})

	checkOpsBuilder(t, []opsBuilderTestCase{
		{"pipewire-pulse", new(Ops).Daemon(
			check.MustAbs("/run/user/1971/pulse/native"),
			check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"), "-v",
		), Ops{
			&DaemonOp{
				Target: check.MustAbs("/run/user/1971/pulse/native"),
				Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
				Args:   []string{"-v"},
			},
		}},
	})

	checkOpIs(t, []opIsTestCase{
		{"zero", new(DaemonOp), new(DaemonOp), false},

		{"args differs", &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
			Args:   []string{"-v"},
		}, &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, false},

		{"path differs", &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire"),
		}, &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, false},

		{"target differs", &DaemonOp{
			Target: check.MustAbs("/run/user/65534/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, false},

		{"equals", &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
			Path:   check.MustAbs("/run/current-system/sw/bin/pipewire-pulse"),
		}, true},
	})

	checkOpMeta(t, []opMetaTestCase{
		{"pipewire-pulse", &DaemonOp{
			Target: check.MustAbs("/run/user/1971/pulse/native"),
		}, zeroString, `daemon providing "/run/user/1971/pulse/native"`},
	})
}