package delivery

import (
	"encoding/json"
	"reflect"
	"strings"
	"testing"
	"time"
)

func composeAsk() StepAsk {
	return StepAsk{ID: "mh3k2x9qa1b2c5", Kind: AskCheck, Language: AskGo, Asker: "mesh-delivery-assigner",
		At: time.Date(2026, 10, 24, 3, 0, 0, 0, time.UTC),
		Compose: &ComposeJob{Fetch: map[string]any{"repository": "novox/mesh-sdk", "commit": askCommit},
			Dir: "go", Package: "git.novox.be/novox/mesh-sdk/go/cmd/mesh-compose",
			Request: json.RawMessage(`{"v":1,"cases":[{"name":"change","manifests":{"demo":{"digest":"d1"}}}]}`), Reader: "mesh-sdk head"}}
}

// 1622: a compose ask encodes and decodes with every field.
func TestAComposeAskRoundTrips(t *testing.T) {
	a := composeAsk()
	raw, err := EncodeStepAsk(a)
	if err != nil {
		t.Fatal(err)
	}
	got, err := DecodeStepAsk(raw)
	if err != nil {
		t.Fatal(err)
	}
	a.V = StepAskVersion
	if !reflect.DeepEqual(got, a) {
		t.Fatalf("round trip:\n got %+v\nwant %+v", got, a)
	}
}

// 1622: a compose ask goes only on the Go seat's check stream, holds no other job beside it, fetches a full commit,
// builds a package in a clean directory of the repository and carries a request object.
func TestAComposeAskIsRefusedWhereItDoesNotBelong(t *testing.T) {
	for name, change := range map[string]func(*StepAsk){
		"on the delivery stream":  func(a *StepAsk) { a.Kind = AskDelivery },
		"on the recheck stream":   func(a *StepAsk) { a.Kind = AskRecheck },
		"on the Node seat":        func(a *StepAsk) { a.Language = AskNode },
		"beside a check":          func(a *StepAsk) { a.Check = checkAsk().Check },
		"with a short commit":     func(a *StepAsk) { a.Compose.Fetch["commit"] = "0123456" },
		"in no directory":         func(a *StepAsk) { a.Compose.Dir = "" },
		"outside the repository":  func(a *StepAsk) { a.Compose.Dir = "../x" },
		"with no package":         func(a *StepAsk) { a.Compose.Package = "" },
		"with no request":         func(a *StepAsk) { a.Compose.Request = nil },
		"with a request not JSON": func(a *StepAsk) { a.Compose.Request = json.RawMessage(`[1]`) },
	} {
		a := composeAsk()
		change(&a)
		if _, err := EncodeStepAsk(a); err == nil {
			t.Errorf("a compose ask %s is encoded", name)
		}
	}
}

// 1622/AC3: a composer is kept under one key per repository, commit, directory, package and toolchain, so two asks of
// one head build it once on a node, and another head or toolchain builds its own.
func TestAComposerIsKeptByWhatItWasBuiltFrom(t *testing.T) {
	tc := ToolchainUsed{Version: "go1.26.0", Recipe: "3"}
	k := ComposerKey("novox/mesh-sdk", askCommit, "go", "p", tc)
	if k != ComposerKey("novox/mesh-sdk", askCommit, "go", "p", tc) || !strings.HasPrefix(k, "composer-") || len(k) != len("composer-")+16 {
		t.Fatalf("key = %q", k)
	}
	for _, other := range []string{
		ComposerKey("novox/mesh-sdk", strings.Repeat("1", 40), "go", "p", tc),
		ComposerKey("novox/mesh-controller", askCommit, ".", "p", tc),
		ComposerKey("novox/mesh-sdk", askCommit, "go", "p", ToolchainUsed{Version: "go1.26.1", Recipe: "3"}),
	} {
		if other == k {
			t.Errorf("two composers built from different inputs share the key %s", k)
		}
	}
}