package error_test

import (
	"fmt"
	"net/http"
	"net/http/httptest"
	"testing"

	"github.com/stretchr/testify/assert"

	"github.com/nais/wonderwall/pkg/cookie"
	errorhandler "github.com/nais/wonderwall/pkg/handler/error"
	"github.com/nais/wonderwall/pkg/ingress"
	mw "github.com/nais/wonderwall/pkg/middleware"
	"github.com/nais/wonderwall/pkg/mock"
	"github.com/nais/wonderwall/pkg/openid"
)

func TestHandler_Error(t *testing.T) {
	cfg := mock.Config()
	idp := mock.NewIdentityProvider(cfg)
	defer idp.Close()

	rpHandler := idp.RelyingPartyHandler.GetErrorHandler()

	for _, test := range []struct {
		name               string
		expectedStatusCode int
		fn                 func(w http.ResponseWriter, r *http.Request, cause error)
	}{
		{
			name:               "bad request",
			expectedStatusCode: http.StatusBadRequest,
			fn:                 rpHandler.BadRequest,
		},
		{
			name:               "internal error",
			expectedStatusCode: http.StatusInternalServerError,
			fn:                 rpHandler.InternalError,
		},
		{
			name:               "unauthorized",
			expectedStatusCode: http.StatusUnauthorized,
			fn:                 rpHandler.Unauthorized,
		},
	} {
		t.Run(test.name, func(t *testing.T) {
			r := idp.GetRequest(idp.RelyingPartyServer.URL)

			// should be automatically redirected to the retry URI until maximum attempts are exhausted
			for i := 0; i < errorhandler.MaxAutoRetryAttempts; i++ {
				w := httptest.NewRecorder()

				test.fn(w, r, fmt.Errorf("some error"))
				assert.Equal(t, http.StatusTemporaryRedirect, w.Result().StatusCode)

				// ensure cookie in request is set/updated
				for _, c := range w.Result().Cookies() {
					if c.Name == cookie.Retry {
						r.Header.Set("Cookie", fmt.Sprintf("%s=%s", c.Name, c.Value))
					}
				}
			}

			// should return an error response when maximum attempts are exhausted
			w := httptest.NewRecorder()
			test.fn(w, r, fmt.Errorf("some error"))
			assert.Equal(t, test.expectedStatusCode, w.Result().StatusCode)
		})
	}
}

func TestHandler_Retry(t *testing.T) {
	cfg := mock.Config()
	idp := mock.NewIdentityProvider(cfg)
	defer idp.Close()

	handler := idp.RelyingPartyHandler.GetErrorHandler()

	get := func(url string) *http.Request {
		return httptest.NewRequest(http.MethodGet, url, nil)
	}

	for _, test := range []struct {
		name        string
		request     *http.Request
		ingress     string
		loginCookie *openid.LoginCookie
		want        string
	}{
		{
			name:    "login path",
			request: get("/oauth2/login"),
			want:    "/oauth2/login?redirect=%2F",
		},
		{
			name:    "callback path",
			request: get("/oauth2/callback"),
			want:    "/oauth2/login?redirect=%2F",
		},
		{
			name:    "logout path",
			request: get("/oauth2/logout"),
			want:    "/oauth2/logout",
		},
		{
			name:    "front-channel logout path",
			request: get("/oauth2/logout/frontchannel"),
			want:    "/oauth2/logout/frontchannel",
		},
		{
			name:    "login with non-default ingress",
			request: get("/domene/oauth2/login"),
			ingress: "https://test.nav.no/domene",
			want:    "/domene/oauth2/login?redirect=%2Fdomene",
		},
		{
			name:    "logout with non-default ingress",
			request: get("/domene/oauth2/logout"),
			ingress: "https://test.nav.no/domene",
			want:    "/domene/oauth2/logout",
		},
		{
			name:        "login with cookie referer",
			request:     get("/oauth2/login"),
			loginCookie: &openid.LoginCookie{Referer: "/"},
			want:        "/oauth2/login?redirect=%2F",
		},
		{
			name:        "login with empty cookie referer",
			request:     get("/oauth2/login"),
			loginCookie: &openid.LoginCookie{Referer: ""},
			want:        "/oauth2/login?redirect=%2F",
		},
		{
			name:        "login with cookie referer on non-default ingress",
			request:     get("/domene/oauth2/login"),
			loginCookie: &openid.LoginCookie{Referer: "/domene/api/me"},
			ingress:     "https://test.nav.no/domene",
			want:        "/domene/oauth2/login?redirect=%2Fdomene%2Fapi%2Fme",
		},
		{
			name:    "login with redirect parameter set",
			request: get("/oauth2/login?redirect=/api/me"),
			want:    "/oauth2/login?redirect=%2Fapi%2Fme",
		},
		{
			name:    "login with redirect parameter set and query parameters",
			request: get("/oauth2/login?redirect=/api/me?a=b%26c=d"),
			want:    "/oauth2/login?redirect=%2Fapi%2Fme%3Fa%3Db%26c%3Dd",
		},
		{
			name:    "login with redirect parameter set on non-default ingress",
			request: get("/domene/oauth2/login?redirect=/api/me"),
			ingress: "https://test.nav.no/domene",
			want:    "/domene/oauth2/login?redirect=%2Fapi%2Fme",
		},
		{
			name:    "login with redirect parameter set to relative root on non-default ingress",
			request: get("/domene/oauth2/login?redirect=/"),
			ingress: "https://test.nav.no/domene",
			want:    "/domene/oauth2/login?redirect=%2F",
		},
		{
			name:    "login with redirect parameter set to absolute url",
			request: get("/oauth2/login?redirect=http://localhost:8080"),
			want:    "/oauth2/login?redirect=%2F",
		},
		{
			name:    "login with redirect parameter set to absolute url with trailing slash",
			request: get("/oauth2/login?redirect=http://localhost:8080/"),
			want:    "/oauth2/login?redirect=%2F",
		},
		{
			name:    "login with redirect parameter set to absolute url on non-default ingress",
			request: get("/domene/oauth2/login?redirect=http://localhost:8080/"),
			ingress: "https://test.nav.no/domene",
			want:    "/domene/oauth2/login?redirect=%2F",
		},
		{
			name:        "login with cookie referer takes precedence over redirect parameter",
			request:     get("/oauth2/login?redirect=/other"),
			loginCookie: &openid.LoginCookie{Referer: "/domene/api/me"},
			want:        "/oauth2/login?redirect=%2Fdomene%2Fapi%2Fme",
		},
	} {
		t.Run(test.name, func(t *testing.T) {
			if len(test.ingress) == 0 {
				test.ingress = mock.Ingress
			}

			idp.SetIngresses(test.ingress)

			ing, err := ingress.ParseIngress(test.ingress)
			assert.NoError(t, err)

			test.request = mw.RequestWithPath(test.request, ing.Path())

			retryURI := handler.Retry(test.request, test.loginCookie)
			assert.Equal(t, test.want, retryURI)
		})
	}
}