1// SPDX-License-Identifier: MIT
2
3package host
4
5import (
6 "testing"
7
8 "bnema.dev/ermite-api/gen/ermite"
9
10 "bnema.dev/ermite-runner/internal/cachesvc"
11 "bnema.dev/ermite-runner/internal/registryproxy"
12)
13
14// A job with neither a cache scope nor the results service gets the channel
15// for the registry proxy alone: its port and no token. Without the proxy, or
16// without the cache, it gets no channel.
17func TestRuntimeForRegistryOnly(t *testing.T) {
18 proxy, err := registryproxy.New(registryproxy.Config{Dir: t.TempDir(), Max: 1 << 20})
19 if err != nil {
20 t.Fatal(err)
21 }
22 withRegistry, err := cachesvc.New(cachesvc.Config{Dir: t.TempDir(), Registry: proxy})
23 if err != nil {
24 t.Fatal(err)
25 }
26 defer func() { _ = withRegistry.CloseAll() }()
27 without, err := cachesvc.New(cachesvc.Config{Dir: t.TempDir()})
28 if err != nil {
29 t.Fatal(err)
30 }
31 defer func() { _ = without.CloseAll() }()
32 // No repository in the contexts: the job has no cache scope.
33 j := &jobRun{job: &ermite.Job{JobId: "j1", TimeoutMinutes: 5}}
34 port, tok, mode, results := j.runtimeFor(&Runner{Cache: withRegistry})
35 if port != cachesvc.DefaultPort || tok != "" || mode != "" || results {
36 t.Fatalf("registry only: %d %q %q %v", port, tok, mode, results)
37 }
38 if p, _, _, _ := j.runtimeFor(&Runner{Cache: without}); p != 0 {
39 t.Fatal("proxy off still supplies a channel")
40 }
41 if p, _, _, _ := j.runtimeFor(&Runner{}); p != 0 {
42 t.Fatal("cache off still supplies a channel")
43 }
44 // A job with a cache scope still gets its token, proxy or not.
45 scoped := &jobRun{job: &ermite.Job{JobId: "j1", Ref: "refs/heads/main", TimeoutMinutes: 5}, contexts: `{"github":{"repository":"o/r"}}`}
46 if _, tok, mode, _ := scoped.runtimeFor(&Runner{Cache: withRegistry}); tok == "" || mode != "write" {
47 t.Fatalf("scoped job: %q %q", tok, mode)
48 }
49}