package main

import (
	"bytes"
	"context"
	"strings"
	"testing"

	"github.com/carlosframework/platform/internal/release"
	"github.com/carlosframework/platform/internal/updatewords"
)

func runAuthorize(t *testing.T, answer string, args ...string) string {
	t.Helper()
	var out bytes.Buffer
	prevOut, prevIn := stdout, authorizeInput
	stdout, authorizeInput = &out, strings.NewReader(answer)
	t.Cleanup(func() { stdout, authorizeInput = prevOut, prevIn })
	runReleasesAuthorize(args)
	return out.String()
}

func TestReleasesAuthorizeAsksThenSigns(t *testing.T) {
	s, pub := directDigestStore(t) // plan 1's helper: km v1 shipped and promoted to stable
	ctx := context.Background()
	if err := s.Delete(ctx, release.PromotionRecordKey("bab", "km", "v1")); err != nil {
		t.Fatal(err)
	}
	out := runAuthorize(t, "no\n", "--account-id", "bab", "km", "v1")
	if !strings.Contains(out, "linux-amd64") || !strings.Contains(out, updatewords.Text("settings.authorize.aborted")) {
		t.Fatalf("answering no:\n%s", out)
	}
	if _, err := release.ReadPromotionRecord(ctx, s, pub, "bab", "km", "v1"); err == nil {
		t.Fatal("answering no wrote a record")
	}
	runAuthorize(t, "yes\n", "--account-id", "bab", "--app", "km", "v1")
	if rec, err := release.ReadPromotionRecord(ctx, s, pub, "bab", "km", "v1"); err != nil || !rec.Authorized {
		t.Fatalf("answering yes: %+v, %v", rec, err)
	}
	out = runAuthorize(t, "", "--account-id", "bab", "--yes", "km", "v1")
	if !strings.Contains(out, "already") {
		t.Fatalf("a second authorize:\n%s", out)
	}
}