novox/mesh-delivery
19
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Fold the seat verbs' test into the try tools test; pin the sdk head (issue 774)

Browse Source
This commit is contained in:
jschoubben
2026-10-28 21:54:47 +01:00
parent fc6d5dcbdb
commit 843a1589d7
1 changed files with 18 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/mesh-delivery-checker/cmd/mesh-delivery-checker-tools/main_test.go
+18 -38
View File
@@ -3,7 +3,6 @@ package main
import (
"encoding/json"
"errors"
"reflect"
"slices"
"strings"
"testing"
@@ -89,6 +88,24 @@ func TestTheTryToolsAskAndReadATry(t *testing.T) { // ADR 0501 §5, the agreed i
if err != nil || !strings.Contains(string(raw.(json.RawMessage)), `"state":"queued"`) {
t.Errorf("read = %s, %v", raw, err)
}
// The seat's verbs answer as the tools do (ADR 0547 §10, issue 774): the same ask is the same try, and the read is alike.
verbs := SeatTryTools(Trying{Tries: store, Ender: store, Now: func() time.Time { return time.Unix(1, 5) },
Trunks: func() (map[string]string, error) {
return map[string]string{"novox/mesh-delivery": strings.Repeat("a", 40)}, nil
}})
if len(verbs) != 3 || verbs[0].Name != Seat+".try" || verbs[1].Name != Seat+".try-read" || verbs[2].Name != Seat+".try-end" {
t.Fatalf("verbs = %+v", verbs)
}
again, err := verbs[0].Run(map[string]any{"repository": "novox/mesh-delivery", "head": strings.Repeat("1", 40), "trunk": "main"})
if err != nil || again.(map[string]any)["id"] != id {
t.Errorf("verb try = %v, %v, want the waiting try %s", again, err, id)
}
if viaVerb, err := verbs[1].Run(map[string]any{"id": id}); err != nil || string(viaVerb.(json.RawMessage)) != string(raw.(json.RawMessage)) {
t.Errorf("verb try-read = %s, %v; tool = %s", viaVerb, err, raw)
}
if _, err := verbs[0].Run(map[string]any{"repository": "novox/hq", "head": strings.Repeat("1", 40)}); err == nil {
t.Error("the verb tried a repository nothing checks")
}
// Issue 734: a try whose ask was lost is ended by hand with why, and its head is asked anew.
ended, err := tools[2].Run(map[string]any{"id": id, "why": "its ask was lost"})
if err != nil || ended.(map[string]any)["state"] != "error" {
@@ -102,40 +119,3 @@ func TestTheTryToolsAskAndReadATry(t *testing.T) { // ADR 0501 §5, the agreed i
t.Errorf("hq: %v", err)
}
}
// The seat's verbs answer as the tools do (ADR 0547 §10, issue 774): the same ask gives the same try, read and ended alike.
func TestTheSeatVerbsAnswerLikeTheTools(t *testing.T) {
store := &memStore{vals: map[string]json.RawMessage{}}
tr := Trying{Tries: store, Ender: store, Now: func() time.Time { return time.Unix(1, 5) },
Trunks: func() (map[string]string, error) {
return map[string]string{"novox/mesh-delivery": strings.Repeat("a", 40)}, nil
}}
tools, verbs := TryTools(tr), SeatTryTools(tr)
if len(verbs) != len(tools) {
t.Fatalf("%d verbs for %d tools", len(verbs), len(tools))
}
for i, want := range []string{"try", "try-read", "try-end"} {
if verbs[i].Name != Seat+"."+want {
t.Errorf("verb %d = %s", i, verbs[i].Name)
}
}
ask := map[string]any{"repository": "novox/mesh-delivery", "head": strings.Repeat("1", 40), "trunk": "main"}
a, err := tools[0].Run(ask)
if err != nil {
t.Fatal(err)
}
b, err := verbs[0].Run(ask) // a second ask of a head that waits is the first's answer
if err != nil || !reflect.DeepEqual(a, b) {
t.Errorf("verb try = %v, %v; tool = %v", b, err, a)
}
id := a.(map[string]any)["id"].(string)
ra, _ := tools[1].Run(map[string]any{"id": id})
rb, err := verbs[1].Run(map[string]any{"id": id})
if err != nil || !reflect.DeepEqual(ra, rb) {
t.Errorf("verb try-read = %v, %v; tool = %v", rb, err, ra)
}
if _, err := verbs[0].Run(map[string]any{"repository": "novox/hq", "head": strings.Repeat("1", 40)}); err == nil ||
err.Error() != "no level of novox/hq is checked by the checker" {
t.Errorf("hq: %v", err)
}
}