Function TestGetConsentRequest

consent/handler_test.go:164–227

(t *testing.T)

}

func TestGetConsentRequest(t *testing.T) {
	t.Parallel()

	reg := testhelpers.NewRegistryMemory(t)

	h := NewHandler(reg)
	r := httprouterx.NewTestRouterAdminWithPrefix(t)
	h.SetRoutes(r)
	ts := httptest.NewServer(r)
	defer ts.Close()

	cl := &client.Client{
		ID:   "test client id",
		Name: "test client name",
	}

	requestURL := "http://192.0.2.1"
	consentRequestID := "test consent request id"

	f := &flow.Flow{
		Client:           cl,
		RequestURL:       requestURL,
		RequestedAt:      time.Now(),
		State:            flow.FlowStateConsentUnused,
		NID:              reg.Persister().NetworkID(t.Context()),
		ConsentRequestID: sqlxx.NullString(consentRequestID),
	}

	unhandledChallenge, err := f.ToConsentChallenge(t.Context(), reg)
	require.NoError(t, err)

	t.Run("unhandled flow", func(t *testing.T) {
		resp, err := ts.Client().Get(ts.URL + "/admin" + ConsentPath + "?challenge=" + unhandledChallenge)
		require.NoError(t, err)
		require.EqualValues(t, http.StatusOK, resp.StatusCode)

		var result flow.OAuth2ConsentRequest
		require.NoError(t, json.NewDecoder(resp.Body).Decode(&result))
		assert.Equal(t, unhandledChallenge, result.Challenge)
		assert.Equal(t, requestURL, result.RequestURL)
		assert.NotNil(t, result.Client)
	})

	t.Run("handled flow", func(t *testing.T) {
		f.State = flow.FlowStateConsentUnused
		require.NoError(t, f.InvalidateConsentRequest())
		handledChallenge, err := f.ToConsentChallenge(t.Context(), reg)
		require.NoError(t, err)

		resp, err := ts.Client().Get(ts.URL + "/admin" + ConsentPath + "?challenge=" + handledChallenge)
		require.NoError(t, err)
		require.EqualValues(t, http.StatusGone, resp.StatusCode)

		var result flow.OAuth2RedirectTo
		require.NoError(t, json.NewDecoder(resp.Body).Decode(&result))
		assert.Equal(t, requestURL, result.RedirectTo)
	})