container_test.go RawHistoryFolder

1// SPDX-License-Identifier: MIT
2
3package integration
4
5import (
6	"os"
7	"os/exec"
8	"strings"
9	"testing"
10
11	"bnema.dev/ermite-runner/internal/sandbox"
12	"bnema.dev/ermite-runner/internal/sandbox/drivers"
13)
14
15func TestContainerStubExecutor(t *testing.T) {
16	if os.Getenv("ERMITE_RUNNER_IT_CONTAINER") != "1" {
17		t.Skip("set ERMITE_RUNNER_IT_CONTAINER=1 (needs a rootful Docker daemon and the runner image; see README)")
18	}
19	need(t, "docker")
20	needNetAdmin(t)
21	ctx := ctxWithLog(t)
22	cfg := loadConfig(t, sandbox.Container)
23	// A rootless daemon is refused with a clear error: nothing to test there.
24	probe, err := drivers.Factories().Container(ctx, cfg)
25	if err != nil {
26		if strings.Contains(err.Error(), "rootless") {
27			t.Skipf("the Docker daemon is rootless, as designed the driver refuses it: %v", err)
28		}
29		t.Fatal(err)
30	}
31	// The probe holds the host-wide lock: release it before the scenario takes it.
32	if err := probe.Close(); err != nil {
33		t.Fatal(err)
34	}
35	scenario(t, ctx, cfg, sandbox.Container, func(t *testing.T, sb sandbox.Sandbox) {
36		out, err := exec.Command("docker", "ps", "-q", "--filter", "label="+sandbox.LabelJob).Output()
37		if err != nil {
38			t.Fatal(err)
39		}
40		ids := strings.Fields(string(out))
41		if len(ids) == 0 {
42			t.Fatal("no job container to kill")
43		}
44		if b, err := exec.Command("docker", append([]string{"kill"}, ids...)...).CombinedOutput(); err != nil {
45			t.Fatalf("docker kill: %v: %s", err, b)
46		}
47	})
48}