Function TestWriteHandlers

internal/relationtuple/transact_server_test.go:28–486

(t *testing.T)

)

func TestWriteHandlers(t *testing.T) {
	r := httprouterx.NewTestRouterAdmin(t)
	reg := driver.NewSqliteTestRegistry(t, false)

	var nspaces []*namespace.Namespace
	addNamespace := func(t *testing.T) *namespace.Namespace {
		n := &namespace.Namespace{
			Name: t.Name(),
		}
		nspaces = append(nspaces, n)

		require.NoError(t, reg.Config(t.Context()).Set(config.KeyNamespaces, nspaces))

		return n
	}

	h := relationtuple.NewHandler(reg)
	h.RegisterWriteRoutes(r)
	h.RegisterReadRoutes(r.ToPublic())
	ts := httptest.NewServer(r)
	defer ts.Close()

	t.Run("method=create", func(t *testing.T) {
		doCreate := func(raw []byte) *http.Response {
			req, err := http.NewRequest(http.MethodPut, ts.URL+relationtuple.WriteRouteBase, bytes.NewBuffer(raw))
			require.NoError(t, err)
			resp, err := ts.Client().Do(req)
			require.NoError(t, err)

			return resp
		}

		t.Run("case=creates tuple", func(t *testing.T) {
			nspace := addNamespace(t)

			rt := &ketoapi.RelationTuple{
				Namespace: nspace.Name,
				Object:    "obj",
				Relation:  "rel",
				SubjectID: new("subj"),
			}
			payload, err := json.Marshal(rt)
			require.NoError(t, err)

			resp := doCreate(payload)

			assert.Equal(t, http.StatusCreated, resp.StatusCode)

			body, err := io.ReadAll(resp.Body)
			require.NoError(t, err)

			assert.JSONEq(t, string(payload), string(body))

			t.Run("check=is contained in the manager", func(t *testing.T) {
				mapped, err := reg.Mapper().FromTuple(t.Context(), rt)
				require.NoError(t, err)
				// set a size > 1 just to make sure it gets all
				actualRTs, _, err := reg.RelationTupleManager().GetRelationTuples(t.Context(), mapped[0].ToQuery(), keysetpagination.WithSize(10))