Function TestReadHandlers

internal/relationtuple/read_server_test.go:33–355

(t *testing.T)

)

func TestReadHandlers(t *testing.T) {
	ctx := context.Background()
	r := httprouterx.NewTestRouterPublic(t)
	reg := driver.NewSqliteTestRegistry(t, false)
	h := relationtuple.NewHandler(reg)
	h.RegisterReadRoutes(r)
	ts := httptest.NewServer(r)
	t.Cleanup(ts.Close)

	var newNamespace func(*testing.T) *namespace.Namespace
	{
		nspaces := 0
		newNamespace = func(t *testing.T) *namespace.Namespace {
			n := &namespace.Namespace{Name: fmt.Sprintf("relation tuple read test %d", nspaces)}
			nspaces++
			require.NoError(t, reg.Config(ctx).Set(config.KeyNamespaces, []*namespace.Namespace{n}))
			return n
		}
	}

	t.Run("method=get", func(t *testing.T) {
		t.Run("case=empty response is not nil", func(t *testing.T) {
			nspace := newNamespace(t)
			resp, err := ts.Client().Get(ts.URL + relationtuple.ReadRouteBase + "?" + url.Values{
				"namespace": {nspace.Name},
			}.Encode())
			require.NoError(t, err)
			require.Equal(t, http.StatusOK, resp.StatusCode)

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

			assert.Equal(t, "[]", gjson.GetBytes(body, "relation_tuples").Raw)

			var respMsg ketoapi.GetResponse
			require.NoError(t, json.Unmarshal(body, &respMsg))

			assert.Equal(t, ketoapi.GetResponse{
				RelationTuples: []*ketoapi.RelationTuple{},
				NextPageToken:  "",
			}, respMsg)
		})

		t.Run("case=returns tuples", func(t *testing.T) {
			nspace := newNamespace(t)
			tuples := []*ketoapi.RelationTuple{
				{
					Namespace: nspace.Name,
					Object:    "o1",
					Relation:  "r1",
					SubjectID: new("s1"),
				},
				{
					Namespace: nspace.Name,
					Object:    "o2",
					Relation:  "r2",
					SubjectSet: &ketoapi.SubjectSet{
						Namespace: nspace.Name,