66 lines
2.4 KiB
Go
66 lines
2.4 KiB
Go
package main
|
|
|
|
import (
|
|
"io"
|
|
"os"
|
|
"strings"
|
|
"testing"
|
|
|
|
"git.novox.be/novox/mesh-sdk/go/catalogue"
|
|
)
|
|
|
|
// Issue 1638 (novox/hq ADR 0480 clause 7), taken in with mesh-sdk's container `groups`: the controller sends a container's
|
|
// groups only to a node-engine that reports the capability container-groups, and holds the module on any other, naming it.
|
|
|
|
const n8nWithAGroup = `{"module":"n8n","version":"1",
|
|
"config":{"media-gid":{"type":"number","minimum":1,"required":true,"description":"the group that owns the media library"}},
|
|
"resources":[{"id":"server","type":"container","name":"n8n",
|
|
"image":"n8nio/n8n@sha256:4846eb2f4b874ab04cde7fc1e249d2ddaec66e9aea64439beb2972cfea88e3c0",
|
|
"groups":["${config:media-gid}"]}]}`
|
|
|
|
// printedBy runs reportUnhostable and returns what it printed.
|
|
func printedBy(t *testing.T, node string, plan catalogue.Resolution) string {
|
|
t.Helper()
|
|
stdout := os.Stdout
|
|
r, w, err := os.Pipe()
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
os.Stdout = w
|
|
reportUnhostable(node, plan)
|
|
w.Close()
|
|
os.Stdout = stdout
|
|
out, _ := io.ReadAll(r)
|
|
return string(out)
|
|
}
|
|
|
|
// 1638/AC1: a node that reports the capability gets the module; one that does not has it held, the capability named.
|
|
func TestAModuleWithGroupsIsHeldOnANodeThatDoesNotReportTheCapability(t *testing.T) {
|
|
m, err := catalogue.ParseManifest([]byte(n8nWithAGroup))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
shelf := catalogue.Shelf{"n8n": m}
|
|
reads := catalogue.Node{Name: "ace", Capabilities: map[string]bool{"container-runtime": true, "container-groups": true}}
|
|
old := catalogue.Node{Name: "g14", Capabilities: map[string]bool{"container-runtime": true}}
|
|
|
|
got, err := catalogue.Resolve(shelf, []string{"n8n"}, reads, catalogue.World{})
|
|
if err != nil || len(got.Unhostable) != 0 || len(got.Modules) != 1 {
|
|
t.Fatalf("a node that reads groups: %v, held %+v", err, got.Unhostable)
|
|
}
|
|
if out := printedBy(t, "ace", got); out != "" {
|
|
t.Errorf("a node that reads groups was told: %q", out)
|
|
}
|
|
|
|
got, err = catalogue.Resolve(shelf, []string{"n8n"}, old, catalogue.World{})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if len(got.Modules) != 0 || len(got.Unhostable) != 1 {
|
|
t.Fatalf("n8n was sent to a node that does not report container-groups: hosted %d, held %+v", len(got.Modules), got.Unhostable)
|
|
}
|
|
if out := printedBy(t, "g14", got); !strings.Contains(out, "n8n") || !strings.Contains(out, "container-groups") {
|
|
t.Errorf("the hold does not name the module and the capability: %q", out)
|
|
}
|
|
}
|