package console

import (
	"context"
	"fmt"
	"net/http"
	"net/url"
	"strings"
	"testing"

	"github.com/carlosframework/platform/internal/appconfig"
)

func TestAppSettingsShowsTheSwapCard(t *testing.T) {
	fx := newConsoleFixture(t)
	if _, err := appconfig.SetSwapPolicy(context.Background(), fx.rel, fx.sqid, "kass", "hold", 3); err != nil {
		t.Fatal(err)
	}
	c := signInPaul(t, fx)
	code, _, body := get(t, c, fx.u("/apps/kass/settings"))
	if code != http.StatusOK {
		t.Fatalf("settings = %d", code)
	}
	for _, want := range []string{swapCopy.Heading, `action="/a/` + fx.sqid + `/apps/kass/swap"`,
		`<option value="hold" selected>`, `name="swap_concurrency"`, `value="3"`} {
		if !strings.Contains(body, want) {
			t.Errorf("settings page lacks %q", want)
		}
	}
}

func TestAppSwapFormSaves(t *testing.T) {
	fx := newConsoleFixture(t)
	c := signInPaul(t, fx)
	csrf := sessionToken(t, fx, c)
	code, loc, _ := postForm(t, c, fx.u("/apps/kass/swap"),
		url.Values{"csrf": {csrf}, "swap": {"hold"}, "swap_concurrency": {"2"}})
	if code != http.StatusSeeOther || loc != fx.path("/apps/kass/settings") {
		t.Fatalf("save = %d -> %q", code, loc)
	}
	got, err := appconfig.GetSwapPolicy(context.Background(), fx.rel, fx.sqid, "kass")
	if err != nil || got != (appconfig.SwapPolicy{Swap: "hold", Concurrency: 2}) {
		t.Fatalf("stored = %+v, %v", got, err)
	}
	if n := serial(t, fx); n != 1 {
		t.Fatalf("serial = %d, want 1", n)
	}
	if _, _, body := get(t, c, fx.u("/apps/kass/settings")); !strings.Contains(body, fmt.Sprintf(swapCopy.Saved, "hold", 2)) {
		t.Errorf("no saved notice after the redirect")
	}
}

func TestAppSwapFormRefusesBadInput(t *testing.T) {
	fx := newConsoleFixture(t)
	c := signInPaul(t, fx)
	csrf := sessionToken(t, fx, c)
	for _, form := range []url.Values{
		{"csrf": {csrf}, "swap": {"fast"}, "swap_concurrency": {"1"}},
		{"csrf": {csrf}, "swap": {"hold"}, "swap_concurrency": {"0"}},
		{"csrf": {csrf}, "swap": {"hold"}, "swap_concurrency": {"two"}},
		{"csrf": {csrf}, "swap": {"hold"}},
	} {
		if code, _, _ := postForm(t, c, fx.u("/apps/kass/swap"), form); code != http.StatusSeeOther {
			t.Errorf("%v = %d, want a redirect with a notice", form, code)
		}
	}
	if got, _ := appconfig.GetSwapPolicy(context.Background(), fx.rel, fx.sqid, "kass"); got != (appconfig.SwapPolicy{Swap: "overlap", Concurrency: 1}) {
		t.Fatalf("a refused form stored %+v", got)
	}
}

func TestAppSwapFormNeedsCSRFAndMembership(t *testing.T) {
	fx := newConsoleFixture(t)
	c := signInPaul(t, fx)
	if code, _, _ := postForm(t, c, fx.u("/apps/kass/swap"), url.Values{"csrf": {"wrong"}, "swap": {"hold"}, "swap_concurrency": {"1"}}); code != http.StatusForbidden {
		t.Fatalf("bad csrf = %d", code)
	}
	csrf := sessionToken(t, fx, c)
	code, _, body := postForm(t, c, fx.u("/apps/no-such-app/swap"), url.Values{"csrf": {csrf}, "swap": {"hold"}, "swap_concurrency": {"1"}})
	if code != http.StatusNotFound || body != "404 page not found\n" {
		t.Fatalf("unknown app = %d %q", code, body)
	}
}