package console

import (
	"context"
	"crypto/sha256"
	"encoding/hex"
	"strings"
	"testing"

	"git.novox.be/novox/mesh-sdk/go/stateobjects"
	"github.com/nats-io/nats.go"
	"github.com/nats-io/nats.go/jetstream"

	"github.com/novox/mesh-tools/node-tools/internal/bus"
	"github.com/novox/mesh-tools/node-tools/internal/meshtest"
)

// ADR 0666 §16: an answer a module sent as a reference is read from its sent store for the person asking; one the bus does
// not let the runner read is shown as its reference with its size and why it was not read.
func TestAnAnswerSentAsAReferenceIsReadForThePersonAsking(t *testing.T) {
	nc, err := nats.Connect(meshtest.URL(t))
	if err != nil {
		t.Fatal(err)
	}
	defer nc.Close()
	js, _ := jetstream.New(nc)
	obs, err := js.CreateObjectStore(context.Background(), jetstream.ObjectStoreConfig{Bucket: "m_sent-objects"})
	if err != nil {
		t.Fatal(err)
	}
	conn, err := bus.Connect(bus.Credential{URL: meshtest.URL(t), Module: "console", Node: "anchor"})
	if err != nil {
		t.Fatal(err)
	}
	defer conn.Close()
	body := []byte(`{"lines":"` + strings.Repeat("x", 3<<20) + `"}`)
	sum := sha256.Sum256(body)
	ref := stateobjects.Ref{Store: "m_sent-objects", Object: "tool.lines." + hex.EncodeToString(sum[:]), Size: int64(len(body)),
		Digest: hex.EncodeToString(sum[:]), Form: stateobjects.FormVersion}
	if _, err := obs.PutBytes(context.Background(), ref.Object, body); err != nil {
		t.Fatal(err)
	}
	if got, unread := resolveSent(conn, stateobjects.Wrap(ref)); unread != "" || string(got) != string(body) {
		t.Fatalf("read %d bytes of %d, %q", len(got), len(body), unread)
	}
	missing := ref
	missing.Store = "gone_sent-objects"
	wrapped := stateobjects.Wrap(missing)
	got, unread := resolveSent(conn, wrapped)
	if string(got) != string(wrapped) || !strings.Contains(unread, "3145") || !strings.Contains(unread, "gone_sent-objects") {
		t.Fatalf("an unread answer showed %q and %q", got, unread)
	}
	if got, unread := resolveSent(conn, []byte(`{"a":1}`)); unread != "" || string(got) != `{"a":1}` {
		t.Fatalf("a plain answer showed %q, %q", got, unread)
	}
}