feat: add API to list namespaces

internal/driver/daemon.go

@@ -9,6 +9,7 @@ import (
 	"strings"
 	"syscall"
 
+	"github.com/ory/keto/internal/namespace/namespacehandler"
 	"github.com/ory/keto/internal/schema"
 	rts "github.com/ory/keto/proto/ory/keto/relation_tuples/v1alpha2"
 
@@ -297,6 +298,7 @@ func (r *RegistryDefault) allHandlers() []Handler {
 			relationtuple.NewHandler(r),
 			check.NewHandler(r),
 			expand.NewHandler(r),
+			namespacehandler.New(r),
 			schema.NewHandler(r),
 		}
 	}

internal/e2e/cli_client_test.go

@@ -34,6 +34,13 @@ type cliClient struct {
 	c *cmdx.CommandExecuter
 }
 
+func (g *cliClient) queryNamespaces(t require.TestingT) (res ketoapi.GetNamespacesResponse) {
+	if t, ok := t.(*testing.T); ok {
+		t.Skip("not implemented for the CLI")
+	}
+	return
+}
+
 var _ client = (*cliClient)(nil)
 
 func (g *cliClient) oplCheckSyntax(t require.TestingT, _ []byte) []*ketoapi.ParseError {

internal/e2e/full_suit_test.go

@@ -37,6 +37,7 @@ type (
 		expand(t require.TestingT, r *ketoapi.SubjectSet, depth int) *ketoapi.Tree[*ketoapi.RelationTuple]
 		oplCheckSyntax(t require.TestingT, content []byte) []*ketoapi.ParseError
 		waitUntilLive(t require.TestingT)
+		queryNamespaces(t require.TestingT) ketoapi.GetNamespacesResponse
 	}
 )
 
@@ -88,6 +89,7 @@ func Test(t *testing.T) {
 					syntaxRemote: reg.Config(ctx).OPLSyntaxAPIListenOn(),
 				},
 			} {
+				cl := cl
 				t.Run(fmt.Sprintf("client=%T", cl), runCases(cl, namespaceTestMgr))
 
 				if tc, ok := cl.(transactClient); ok {

internal/e2e/grpc_client_test.go

@@ -28,6 +28,15 @@ type grpcClient struct {
 	ctx                                      context.Context
 }
 
+func (g *grpcClient) queryNamespaces(t require.TestingT) (apiResponse ketoapi.GetNamespacesResponse) {
+	client := rts.NewNamespacesServiceClient(g.readConn(t))
+	res, err := client.ListNamespaces(g.ctx, &rts.ListNamespacesRequest{})
+	require.NoError(t, err)
+	require.NoError(t, convert(res, &apiResponse))
+
+	return
+}
+
 var _ transactClient = (*grpcClient)(nil)
 
 func (g *grpcClient) conn(t require.TestingT, remote string) *grpc.ClientConn {

internal/e2e/helpers.go

@@ -2,6 +2,7 @@ package e2e
 
 import (
 	"context"
+	"encoding/json"
 	"testing"
 
 	"github.com/ory/keto/internal/x/dbx"
@@ -124,3 +125,13 @@ func startServer(ctx context.Context, t testing.TB, reg driver.Registry) func()
 		require.NoError(t, <-serverErr)
 	}
 }
+
+// convert the struct in `from` to the pointer in `to` using JSON mashal and unmarshal. from and toPtr must have the
+// same json field tags.
+func convert(from, toPtr any) error {
+	raw, err := json.Marshal(from)
+	if err != nil {
+		return err
+	}
+	return json.Unmarshal(raw, toPtr)
+}

internal/e2e/rest_client_test.go

@@ -33,6 +33,14 @@ type restClient struct {
 	readURL, writeURL, oplSyntaxURL string
 }
 
+func (rc *restClient) queryNamespaces(t require.TestingT) (res ketoapi.GetNamespacesResponse) {
+	body, code := rc.makeRequest(t, http.MethodGet, "/namespaces", "", rc.readURL)
+	assert.Equal(t, http.StatusOK, code, body)
+	require.NoError(t, json.Unmarshal([]byte(body), &res))
+
+	return
+}
+
 func (rc *restClient) oplCheckSyntax(t require.TestingT, content []byte) []*ketoapi.ParseError {
 	body, code := rc.makeRequest(t, http.MethodPost, schema.RouteBase, string(content), rc.oplSyntaxURL)
 	assert.Equal(t, http.StatusOK, code, body)

internal/e2e/sdk_client_test.go

@@ -20,6 +20,7 @@ type sdkClient struct {
 	wc httpclient.WriteApi
 	mc httpclient.MetadataApi
 	sc httpclient.SyntaxApi
+	nc httpclient.NamespacesApi
 
 	readRemote, writeRemote, syntaxRemote string
 }
@@ -78,6 +79,16 @@ func (c *sdkClient) getWriteClient() httpclient.WriteApi {
 	return c.wc
 }
 
+func (c *sdkClient) getNamespacesClient() httpclient.NamespacesApi {
+	if c.nc == nil {
+		cfg := httpclient.NewConfiguration()
+		cfg.Host = c.readRemote
+		cfg.Scheme = "http"
+		c.nc = httpclient.NewAPIClient(cfg).NamespacesApi
+	}
+	return c.nc
+}
+
 func (c *sdkClient) getOPLSyntaxClient() httpclient.SyntaxApi {
 	if c.sc == nil {
 		cfg := httpclient.NewConfiguration()
@@ -295,3 +306,11 @@ func (c *sdkClient) waitUntilLive(t require.TestingT) {
 	}
 	require.Equal(t, "ok", resp.Status)
 }
+
+func (c *sdkClient) queryNamespaces(t require.TestingT) (response ketoapi.GetNamespacesResponse) {
+	res, _, err := c.getNamespacesClient().GetNamespaces(c.requestCtx()).Execute()
+	require.NoError(t, err)
+	require.NoError(t, convert(res, &response))
+
+	return
+}

internal/e2e/testcases_test.go

@@ -20,6 +20,15 @@ func runCases(c client, m *namespaceTestManager) func(*testing.T) {
 	return func(t *testing.T) {
 		c.waitUntilLive(t)
 
+		t.Run("case=list namespaces", func(t *testing.T) {
+			first := namespace.Namespace{Name: "my namespace"}
+			second := namespace.Namespace{Name: "my other namespace"}
+			m.add(t, &first, &second)
+
+			resp := c.queryNamespaces(t)
+			assert.GreaterOrEqual(t, len(resp.Namespaces), 2)
+		})
+
 		t.Run("case=gets empty namespace", func(t *testing.T) {
 			n := &namespace.Namespace{Name: t.Name()}
 			m.add(t, n)