Function TestHandlerSelfServiceSessionManagement

session/handler_test.go:858–1043

(t *testing.T)

}

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

	_, reg := pkg.NewFastRegistryWithMocks(t,
		configx.WithValues(testhelpers.DefaultIdentitySchemaConfig("file://./stub/identity.schema.json")),
	)
	ts, _, r, _ := testhelpers.NewKratosServerWithCSRFAndRouters(t, reg)

	var setup func(t *testing.T) (*http.Client, *identity.Identity, *Session)
	{
		// we limit the scope of the channels, so you cannot accidentally mess up a test case
		ident := make(chan *identity.Identity, 1)
		sess := make(chan *Session, 1)
		r.GET("/set", func(w http.ResponseWriter, r *http.Request) {
			h, s := testhelpers.MockSessionCreateHandlerWithIdentity(t, reg, <-ident)
			h(w, r)
			sess <- s
		})

		setup = func(t *testing.T) (*http.Client, *identity.Identity, *Session) {
			client := testhelpers.NewClientWithCookies(t)
			i := identity.NewIdentity("") // the identity is created by the handler

			ident <- i
			testhelpers.MockHydrateCookieClient(t, client, ts.URL+"/set")
			return client, i, <-sess
		}
	}

	t.Run("case=list should return pagination headers", func(t *testing.T) {
		client, i, _ := setup(t)

		numSessions := 5
		numSessionsActive := 2

		sess := make([]Session, numSessions)
		for j := range sess {
			require.NoError(t, faker.FakeData(&sess[j]))
			sess[j].Identity = i
			if j < numSessionsActive {
				sess[j].Active = true
			} else {
				sess[j].Active = false
			}
			require.NoError(t, reg.SessionPersister().UpsertSession(t.Context(), &sess[j]))
		}

		reqURL := ts.URL + "/sessions"
		req, _ := http.NewRequest("GET", reqURL, nil)
		res, err := client.Do(req)
		require.NoError(t, err)
		require.Equal(t, http.StatusOK, res.StatusCode)

		require.NotEqual(t, "", res.Header.Get("Link"))
	})

	t.Run("case=should return 200 and number after invalidating all other sessions", func(t *testing.T) {
		client, i, currSess := setup(t)