Function TestCreateCmd

cmd/relationtuple/create_test.go:31–170

(t *testing.T)

}

func TestCreateCmd(t *testing.T) {
	nspace := &namespace.Namespace{Name: t.Name()}
	nspaceUser := &namespace.Namespace{Name: "User"}

	newCmd := func() *cobra.Command {
		cmd := &cobra.Command{
			Use: "keto",
		}
		RegisterCommandsRecursive(cmd)
		return cmd
	}

	otherNspace := &namespace.Namespace{Name: "other"}
	ts := client.NewTestServer(t, []*namespace.Namespace{nspace, nspaceUser, otherNspace}, newCmd)
	defer ts.Shutdown(t)

	createFile := func(t *testing.T, tuple any) string {
		dir := t.TempDir()

		data, err := json.Marshal(tuple)
		require.NoError(t, err)

		filename := randx.MustString(10, randx.AlphaLowerNum) + ".json"
		require.NoError(t, os.WriteFile(filepath.Join(dir, filename), data, 0o600))
		return filepath.Join(dir, filename)
	}

	type getTuple func() *ketoapi.RelationTuple

	fns := map[string]getTuple{
		"subjectID": func() *ketoapi.RelationTuple {
			return helpers.RandomTupleWithSubjectID(nspace.Name)
		},
		"subjectSet": func() *ketoapi.RelationTuple {
			return helpers.RandomTupleWithSubjectSet(nspace.Name, nspaceUser.Name)
		},
	}

	for name, createTuple := range fns {
		t.Run("case="+name, func(t *testing.T) {
			t.Run("case=creates single tuple from files", func(t *testing.T) {
				tuple1 := createTuple()
				tuple2 := createTuple()

				tmpFile := createFile(t, tuple1)
				tmpFile2 := createFile(t, []*ketoapi.RelationTuple{tuple2})

				stdOut := ts.Cmd.ExecNoErr(t, "relation-tuple", "create", "-f", tmpFile, "-f", tmpFile2)
				require.Equal(t, renderTable(NewAPICollection([]*ketoapi.RelationTuple{tuple1, tuple2})), stdOut)

				// assert that we can `get` it
				res1 := ts.Cmd.ExecNoErr(t, "relation-tuple", "get", "--namespace", tuple1.Namespace, "--object", tuple1.Object)
				require.Equal(t, renderTable(&responseOutput{
					RelationTuples: NewAPICollection([]*ketoapi.RelationTuple{tuple1}),
					IsLastPage:     true,
				}), res1)

				// assert that we can `get` it