Function TestManager

continuity/manager_test.go:42–331

(t *testing.T)

}

func TestManager(t *testing.T) {
	_, reg := pkg.NewFastRegistryWithMocks(t,
		configx.WithValues(testhelpers.DefaultIdentitySchemaConfig("file://../test/stub/identity/empty.schema.json")),
	)

	i := identity.NewIdentity("")
	require.NoError(t, reg.PrivilegedIdentityPool().CreateIdentity(t.Context(), i))

	newServer := func(t *testing.T, p continuity.Manager, tc *persisterTestCase) *httptest.Server {
		writer := herodot.NewJSONWriter(logrusx.New("", ""))
		router := http.NewServeMux()
		router.HandleFunc("PUT /{name}", func(w http.ResponseWriter, r *http.Request) {
			if err := p.Pause(r.Context(), w, r, r.PathValue("name"), tc.ro...); err != nil {
				writer.WriteError(w, r, err)
				return
			}
			w.WriteHeader(http.StatusNoContent)
		})

		router.HandleFunc("POST /{name}", func(w http.ResponseWriter, r *http.Request) {
			if err := p.Pause(r.Context(), w, r, r.PathValue("name"), tc.ro...); err != nil {
				writer.WriteError(w, r, err)
				return
			}

			c, err := p.Continue(r.Context(), w, r, r.PathValue("name"), tc.wo...)
			if err != nil {
				writer.WriteError(w, r, err)
				return
			}
			writer.Write(w, r, c)
		})

		router.HandleFunc("GET /{name}", func(w http.ResponseWriter, r *http.Request) {
			c, err := p.Continue(r.Context(), w, r, r.PathValue("name"), tc.ro...)
			if err != nil {
				writer.WriteError(w, r, err)
				return
			}
			writer.Write(w, r, c)
		})

		router.HandleFunc("DELETE /{name}", func(w http.ResponseWriter, r *http.Request) {
			err := p.Abort(r.Context(), w, r, r.PathValue("name"))
			if err != nil {
				writer.WriteError(w, r, err)
				return
			}
			w.WriteHeader(http.StatusNoContent)
		})

		ts := httptest.NewServer(router)
		t.Cleanup(ts.Close)
		return ts
	}

	newClient := func() *http.Client {
		return &http.Client{Jar: testhelpers.EasyCookieJar(t, nil)}