112 lines
3.5 KiB
Go
112 lines
3.5 KiB
Go
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"encoding/json"
|
|
"os"
|
|
"path/filepath"
|
|
"strings"
|
|
"testing"
|
|
|
|
"git.novox.be/novox/mesh-sdk/go/delivery"
|
|
|
|
"mesh-delivery-view/internal/view"
|
|
)
|
|
|
|
func serve(t *testing.T) string {
|
|
t.Helper()
|
|
m := view.New()
|
|
m.Apply(view.Entry{Bucket: view.AssignmentsBucket, Key: "a.x", Value: []byte(`{"node":"a","module":"x","build":"b1"}`)})
|
|
dir, err := os.MkdirTemp(os.Getenv("TMPDIR"), "c")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
t.Cleanup(func() { os.RemoveAll(dir) })
|
|
l, err := view.ListenSocket(filepath.Join(dir, "cli.sock"))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
go view.ServeSocket(ctx, l, m)
|
|
t.Cleanup(cancel)
|
|
return filepath.Join(dir, "cli.sock")
|
|
}
|
|
|
|
func TestPrintsATable(t *testing.T) { // 1134/AC6
|
|
var out, errOut bytes.Buffer
|
|
if code := run(nil, serve(t), &out, &errOut); code != 0 {
|
|
t.Fatalf("exit %d: %s", code, errOut.String())
|
|
}
|
|
if !strings.Contains(out.String(), "MODULE") || !strings.Contains(out.String(), "no have yet") {
|
|
t.Fatalf("table = %q", out.String())
|
|
}
|
|
}
|
|
|
|
func TestJSONFlag(t *testing.T) { // 1134/AC6
|
|
var out, errOut bytes.Buffer
|
|
if code := run([]string{"--json"}, serve(t), &out, &errOut); code != 0 {
|
|
t.Fatalf("exit %d: %s", code, errOut.String())
|
|
}
|
|
var s view.Snapshot
|
|
if err := json.Unmarshal(out.Bytes(), &s); err != nil || len(s.Rows) != 1 || s.Rows[0].Module != "x" {
|
|
t.Fatalf("json = %q, %v", out.String(), err)
|
|
}
|
|
}
|
|
|
|
func TestFailsLoudWhenTheViewIsNotThere(t *testing.T) { // 1134/AC6
|
|
var out, errOut bytes.Buffer
|
|
if code := run(nil, filepath.Join(os.Getenv("TMPDIR"), "none.sock"), &out, &errOut); code == 0 || errOut.Len() == 0 {
|
|
t.Fatalf("exit %d, stderr %q", code, errOut.String())
|
|
}
|
|
if code := run([]string{"--start"}, "", &out, &errOut); code != 2 {
|
|
t.Fatalf("an unknown flag must exit 2, got %d", code)
|
|
}
|
|
}
|
|
|
|
func TestPrintsTheCandidateGroupsAndTheFingerprintComparison(t *testing.T) { // 1241/AC6
|
|
m := view.New()
|
|
const head = "0123456789abcdef0123456789abcdef01234567"
|
|
cand, err := delivery.EncodeCandidate(delivery.Candidate{Group: "feat/x", Pulls: []delivery.CandidatePull{{Head: delivery.Head{Repository: "novox/mesh-delivery", Number: 12, Head: head}, Modules: []string{"a"}}},
|
|
HeadsHash: mustHash(t, delivery.Head{Repository: "novox/mesh-delivery", Number: 12, Head: head})})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
mod, err := delivery.EncodeModule(delivery.Module{None: "no tree", Repository: "novox/mesh-delivery", Commit: head})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
m.Apply(view.Entry{Bucket: delivery.CandidatesBucket, Key: "feat/x", Value: cand})
|
|
m.Apply(view.Entry{Bucket: delivery.ModulesBucket, Key: "a", Value: mod})
|
|
dir, err := os.MkdirTemp(os.Getenv("TMPDIR"), "c")
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
t.Cleanup(func() { os.RemoveAll(dir) })
|
|
l, err := view.ListenSocket(filepath.Join(dir, "cli.sock"))
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
ctx, cancel := context.WithCancel(context.Background())
|
|
go view.ServeSocket(ctx, l, m)
|
|
t.Cleanup(cancel)
|
|
var out, errOut bytes.Buffer
|
|
if code := run(nil, filepath.Join(dir, "cli.sock"), &out, &errOut); code != 0 {
|
|
t.Fatalf("exit %d: %s", code, errOut.String())
|
|
}
|
|
for _, want := range []string{"CANDIDATES", "feat/x", "novox/mesh-delivery#12", head[:12], "none", "no tree"} {
|
|
if !strings.Contains(out.String(), want) {
|
|
t.Errorf("the command's table lacks %q:\n%s", want, out.String())
|
|
}
|
|
}
|
|
}
|
|
|
|
func mustHash(t *testing.T, h delivery.Head) string {
|
|
t.Helper()
|
|
s, err := delivery.HeadsHash([]delivery.Head{h})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
return s
|
|
}
|