feat(query): support usage of consistency parameter

Closes #379

README.md

@@ -981,10 +981,11 @@ fga query **check** <user> <relation> <object> [--condition] [--contextual-tuple
 * `--model-id`: Specifies the model id to target (optional)
 * `--contextual-tuple`: Contextual tuples (optional)
 * `--context`: Condition context (optional)
+* `--consistency`: Consistency preference (optional)
 
 ###### Example
 - `fga query check --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne can_view document:roadmap --contextual-tuple "user:anne can_view folder:product" --contextual-tuple "folder:product parent document:roadmap"`
-- `fga query check --store-id="01H4P8Z95KTXXEP6Z03T75Q984" user:anne can_view document:roadmap --context '{"ip_address":"127.0.0.1"}'`
+- `fga query check --store-id="01H4P8Z95KTXXEP6Z03T75Q984" user:anne can_view document:roadmap --context '{"ip_address":"127.0.0.1"}' --consistency="HIGHER_CONSISTENCY"`
 
 
 ###### Response
@@ -1004,10 +1005,11 @@ fga query **list-objects** <user> <relation> <object_type> [--contextual-tuple "
 * `--model-id`: Specifies the model id to target (optional)
 * `--contextual-tuple`: Contextual tuples (optional) (can be multiple)
 * `--context`: Condition context (optional)
+* `--consistency`: Consistency preference (optional)
 
 ###### Example
 - `fga query list-objects --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne can_view document --contextual-tuple "user:anne can_view folder:product" --contextual-tuple "folder:product parent document:roadmap"`
-- `fga query list-objects --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne can_view document --context '{"ip_address":"127.0.0.1"}`
+- `fga query list-objects --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne can_view document --context '{"ip_address":"127.0.0.1"} --consistency="HIGHER_CONSISTENCY"`
 
 ###### Response
 ```json5
@@ -1029,11 +1031,12 @@ fga query **list-relations** <user> <object> [--relation <relation>]* [--context
 * `--model-id`: Specifies the model id to target (optional)
 * `--contextual-tuple`: Contextual tuples (optional) (can be multiple)
 * `--context`: Condition context (optional)
+* `--consistency`: Consistency preference (optional)
 
 ###### Example
 - `fga query list-relations --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne document:roadmap --relation can_view`
 - `fga query list-relations --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne document:roadmap --relation can_view --contextual-tuple "user:anne can_view folder:product"`
-- `fga query list-relations --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne document:roadmap --relation can_view --context '{"ip_address":"127.0.0.1"}`
+- `fga query list-relations --store-id=01H0H015178Y2V4CX10C2KGHF4 user:anne document:roadmap --relation can_view --context '{"ip_address":"127.0.0.1"} --consistency="HIGHER_CONSISTENCY"`
 
 ###### Response
 ```json5
@@ -1052,6 +1055,7 @@ fga query **expand** <relation> <object> --store-id=<store-id> [--model-id=<mode
 ###### Parameters
 * `--store-id`: Specifies the store id
 * `--model-id`: Specifies the model id to target (optional)
+* `--consistency`: Consistency preference (optional)
 
 ###### Example
 `fga query expand --store-id=01H0H015178Y2V4CX10C2KGHF4 can_view document:roadmap`
@@ -1090,11 +1094,12 @@ fga query **list-users** --object <object> --relation <relation> --user-filter <
 * `--model-id`: Specifies the model id to target (optional)
 * `--contextual-tuple`: Contextual tuples (optional) (can be multiple)
 * `--context`: Condition context (optional)
+* `--consistency`: Consistency preference (optional)
 
 ###### Example
 - `fga query list-users --store-id=01H0H015178Y2V4CX10C2KGHF4 --object document:roadmap --relation can_view --user-filter user`
 - `fga query list-users --store-id=01H0H015178Y2V4CX10C2KGHF4 --object document:roadmap --relation can_view --user-filter user --contextual-tuple "user:anne can_view folder:product"`
-- `fga query list-users --store-id=01H0H015178Y2V4CX10C2KGHF4 --object document:roadmap --relation can_view --user-filter group#member --context '{"ip_address":"127.0.0.1"}`
+- `fga query list-users --store-id=01H0H015178Y2V4CX10C2KGHF4 --object document:roadmap --relation can_view --user-filter group#member --context '{"ip_address":"127.0.0.1"} --consistency="HIGHER_CONSISTENCY"`
 
 ###### Response
 ```json5

cmd/query/check.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"fmt"
 
+	openfga "github.com/openfga/go-sdk"
 	"github.com/openfga/go-sdk/client"
 	"github.com/spf13/cobra"
 
@@ -34,6 +35,7 @@ func check(
 	object string,
 	contextualTuples []client.ClientContextualTupleKey,
 	queryContext *map[string]interface{},
+	consistency *openfga.ConsistencyPreference,
 ) (*client.ClientCheckResponse, error) {
 	body := &client.ClientCheckRequest{
 		User:             user,
@@ -44,6 +46,11 @@ func check(
 	}
 	options := &client.ClientCheckOptions{}
 
+	// Don't set if UNSPECIFIED has been provided, it's the default anyway
+	if *consistency != openfga.CONSISTENCYPREFERENCE_UNSPECIFIED {
+		options.Consistency = consistency
+	}
+
 	response, err := fgaClient.Check(context.Background()).Body(*body).Options(*options).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to check due to %w", err)
@@ -76,7 +83,12 @@ var checkCmd = &cobra.Command{
 			return fmt.Errorf("error parsing query context for check: %w", err)
 		}
 
-		response, err := check(fgaClient, args[0], args[1], args[2], contextualTuples, queryContext)
+		consistency, err := cmdutils.ParseConsistencyFromCmd(cmd)
+		if err != nil {
+			return fmt.Errorf("error parsing consistency for check: %w", err)
+		}
+
+		response, err := check(fgaClient, args[0], args[1], args[2], contextualTuples, queryContext, consistency)
 		if err != nil {
 			return fmt.Errorf("failed to check due to %w", err)
 		}

cmd/query/check_test.go

@@ -47,7 +47,15 @@ func TestCheckWithError(t *testing.T) {
 
 	mockFgaClient.EXPECT().Check(context.Background()).Return(mockBody)
 
-	_, err := check(mockFgaClient, "user:foo", "writer", "doc:doc1", contextualTuples, queryContext)
+	_, err := check(
+		mockFgaClient,
+		"user:foo",
+		"writer",
+		"doc:doc1",
+		contextualTuples,
+		queryContext,
+		openfga.CONSISTENCYPREFERENCE_UNSPECIFIED.Ptr(),
+	)
 	if err == nil {
 		t.Error("Expect error but there is none")
 	}
@@ -91,7 +99,73 @@ func TestCheckWithNoError(t *testing.T) {
 
 	mockFgaClient.EXPECT().Check(context.Background()).Return(mockBody)
 
-	output, err := check(mockFgaClient, "user:foo", "writer", "doc:doc1", contextualTuples, queryContext)
+	output, err := check(
+		mockFgaClient,
+		"user:foo",
+		"writer",
+		"doc:doc1",
+		contextualTuples,
+		queryContext,
+		openfga.CONSISTENCYPREFERENCE_UNSPECIFIED.Ptr(),
+	)
+	if err != nil {
+		t.Error(err)
+	}
+
+	if *output != expectedResponse {
+		t.Errorf("Expected output %v actual %v", expectedResponse, *output)
+	}
+}
+
+func TestCheckWithConsistency(t *testing.T) {
+	t.Parallel()
+
+	mockCtrl := gomock.NewController(t)
+	defer mockCtrl.Finish()
+	mockFgaClient := mock_client.NewMockSdkClient(mockCtrl)
+
+	mockExecute := mock_client.NewMockSdkClientCheckRequestInterface(mockCtrl)
+
+	expectedResponse := client.ClientCheckResponse{
+		CheckResponse: openfga.CheckResponse{
+			Allowed: openfga.PtrBool(true),
+		},
+		HttpResponse: nil,
+	}
+
+	mockExecute.EXPECT().Execute().Return(&expectedResponse, nil)
+
+	mockRequest := mock_client.NewMockSdkClientCheckRequestInterface(mockCtrl)
+	options := client.ClientCheckOptions{
+		Consistency: openfga.CONSISTENCYPREFERENCE_HIGHER_CONSISTENCY.Ptr(),
+	}
+	mockRequest.EXPECT().Options(options).Return(mockExecute)
+
+	mockBody := mock_client.NewMockSdkClientCheckRequestInterface(mockCtrl)
+
+	contextualTuples := []client.ClientContextualTupleKey{
+		{User: "user:foo", Relation: "admin", Object: "doc:doc1"},
+	}
+	body := client.ClientCheckRequest{
+		User:             "user:foo",
+		Relation:         "writer",
+		Object:           "doc:doc1",
+		ContextualTuples: contextualTuples,
+		Context:          queryContext,
+	}
+	mockBody.EXPECT().Body(body).Return(mockRequest)
+
+	mockFgaClient.EXPECT().Check(context.Background()).Return(mockBody)
+
+	output, err := check(
+		mockFgaClient,
+		"user:foo",
+		"writer",
+		"doc:doc1",
+		contextualTuples,
+		queryContext,
+		openfga.CONSISTENCYPREFERENCE_HIGHER_CONSISTENCY.Ptr(),
+	)
 	if err != nil {
 		t.Error(err)
 	}

cmd/query/expand.go

@@ -20,20 +20,32 @@ import (
 	"context"
 	"fmt"
 
+	openfga "github.com/openfga/go-sdk"
 	"github.com/openfga/go-sdk/client"
 	"github.com/spf13/cobra"
 
 	"github.com/openfga/cli/internal/cmdutils"
 	"github.com/openfga/cli/internal/output"
 )
 
-func expand(fgaClient client.SdkClient, relation string, object string) (*client.ClientExpandResponse, error) {
+func expand(
+	fgaClient client.SdkClient,
+	relation string,
+	object string,
+	consistency *openfga.ConsistencyPreference,
+) (*client.ClientExpandResponse, error) {
 	body := &client.ClientExpandRequest{
 		Relation: relation,
 		Object:   object,
 	}
 
-	tuples, err := fgaClient.Expand(context.Background()).Body(*body).Execute()
+	options := &client.ClientExpandOptions{}
+
+	if *consistency != openfga.CONSISTENCYPREFERENCE_UNSPECIFIED {
+		options.Consistency = consistency
+	}
+
+	tuples, err := fgaClient.Expand(context.Background()).Body(*body).Options(*options).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to expand tuples due to %w", err)
 	}
@@ -56,7 +68,12 @@ var expandCmd = &cobra.Command{
 			return fmt.Errorf("failed to initialize FGA Client due to %w", err)
 		}
 
-		response, err := expand(fgaClient, args[0], args[1])
+		consistency, err := cmdutils.ParseConsistencyFromCmd(cmd)
+		if err != nil {
+			return fmt.Errorf("error parsing consistency for check: %w", err)
+		}
+
+		response, err := expand(fgaClient, args[0], args[1], consistency)
 		if err != nil {
 			return err
 		}

cmd/query/expand_test.go

@@ -7,6 +7,7 @@ import (
 	"reflect"
 	"testing"
 
+	openfga "github.com/openfga/go-sdk"
 	"github.com/openfga/go-sdk/client"
 	"go.uber.org/mock/gomock"
 
@@ -28,17 +29,21 @@ func TestExpandWithError(t *testing.T) {
 
 	mockExecute.EXPECT().Execute().Return(&expectedResponse, errMockExpand)
 
+	mockRequest := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
+	options := client.ClientExpandOptions{}
+	mockRequest.EXPECT().Options(options).Return(mockExecute)
+
 	mockBody := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
 
 	body := client.ClientExpandRequest{
 		Relation: "writer",
 		Object:   "doc:doc1",
 	}
-	mockBody.EXPECT().Body(body).Return(mockExecute)
+	mockBody.EXPECT().Body(body).Return(mockRequest)
 
 	mockFgaClient.EXPECT().Expand(context.Background()).Return(mockBody)
 
-	_, err := expand(mockFgaClient, "writer", "doc:doc1")
+	_, err := expand(mockFgaClient, "writer", "doc:doc1", openfga.CONSISTENCYPREFERENCE_UNSPECIFIED.Ptr())
 	if err == nil {
 		t.Error("Expect error but there is none")
 	}
@@ -62,17 +67,65 @@ func TestExpandWithNoError(t *testing.T) {
 
 	mockExecute.EXPECT().Execute().Return(&expectedResponse, nil)
 
+	mockRequest := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
+	options := client.ClientExpandOptions{}
+	mockRequest.EXPECT().Options(options).Return(mockExecute)
+
+	mockBody := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
+
+	body := client.ClientExpandRequest{
+		Relation: "writer",
+		Object:   "doc:doc1",
+	}
+	mockBody.EXPECT().Body(body).Return(mockRequest)
+
+	mockFgaClient.EXPECT().Expand(context.Background()).Return(mockBody)
+
+	output, err := expand(mockFgaClient, "writer", "doc:doc1", openfga.CONSISTENCYPREFERENCE_UNSPECIFIED.Ptr())
+	if err != nil {
+		t.Error(err)
+	}
+
+	if !(reflect.DeepEqual(*output, expectedResponse)) {
+		t.Errorf("Expect output response %v actual response %v", expandResponseTxt, *output)
+	}
+}
+
+func TestExpandWithConsistency(t *testing.T) {
+	t.Parallel()
+
+	mockCtrl := gomock.NewController(t)
+	defer mockCtrl.Finish()
+	mockFgaClient := mock_client.NewMockSdkClient(mockCtrl)
+
+	mockExecute := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
+
+	expandResponseTxt := `{"tree":{"root":{"name":"document:roadmap#viewer","union":{"nodes":[{"name": "document:roadmap#viewer","leaf":{"users":{"users":["user:81684243-9356-4421-8fbf-a4f8d36aa31b"]}}}]}}}}` //nolint:all
+
+	expectedResponse := client.ClientExpandResponse{}
+	if err := json.Unmarshal([]byte(expandResponseTxt), &expectedResponse); err != nil {
+		t.Fatalf("%v", err)
+	}
+
+	mockExecute.EXPECT().Execute().Return(&expectedResponse, nil)
+
+	mockRequest := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
+	options := client.ClientExpandOptions{
+		Consistency: openfga.CONSISTENCYPREFERENCE_HIGHER_CONSISTENCY.Ptr(),
+	}
+	mockRequest.EXPECT().Options(options).Return(mockExecute)
+
 	mockBody := mock_client.NewMockSdkClientExpandRequestInterface(mockCtrl)
 
 	body := client.ClientExpandRequest{
 		Relation: "writer",
 		Object:   "doc:doc1",
 	}
-	mockBody.EXPECT().Body(body).Return(mockExecute)
+	mockBody.EXPECT().Body(body).Return(mockRequest)
 
 	mockFgaClient.EXPECT().Expand(context.Background()).Return(mockBody)
 
-	output, err := expand(mockFgaClient, "writer", "doc:doc1")
+	output, err := expand(mockFgaClient, "writer", "doc:doc1", openfga.CONSISTENCYPREFERENCE_HIGHER_CONSISTENCY.Ptr())
 	if err != nil {
 		t.Error(err)
 	}

cmd/query/list-objects.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"fmt"
 
+	openfga "github.com/openfga/go-sdk"
 	"github.com/openfga/go-sdk/client"
 	"github.com/spf13/cobra"
 
@@ -35,6 +36,7 @@ func listObjects(
 	objectType string,
 	contextualTuples []client.ClientContextualTupleKey,
 	queryContext *map[string]interface{},
+	consistency *openfga.ConsistencyPreference,
 ) (*client.ClientListObjectsResponse, error) {
 	body := &client.ClientListObjectsRequest{
 		User:             user,
@@ -45,6 +47,10 @@ func listObjects(
 	}
 	options := &client.ClientListObjectsOptions{}
 
+	if *consistency != openfga.CONSISTENCYPREFERENCE_UNSPECIFIED {
+		options.Consistency = consistency
+	}
+
 	response, err := fgaClient.ListObjects(context.Background()).Body(*body).Options(*options).Execute()
 	if err != nil {
 		return nil, fmt.Errorf("failed to list objects due to %w", err)
@@ -75,10 +81,15 @@ var listObjectsCmd = &cobra.Command{
 
 		queryContext, err := cmdutils.ParseQueryContext(cmd, "context")
 		if err != nil {
-			return fmt.Errorf("error parsing query context for check: %w", err)
+			return fmt.Errorf("error parsing query context for listObjects: %w", err)
+		}
+
+		consistency, err := cmdutils.ParseConsistencyFromCmd(cmd)
+		if err != nil {
+			return fmt.Errorf("error parsing consistency for listObjects: %w", err)
 		}
 
-		response, err := listObjects(fgaClient, args[0], args[1], args[2], contextualTuples, queryContext)
+		response, err := listObjects(fgaClient, args[0], args[1], args[2], contextualTuples, queryContext, consistency)
 		if err != nil {
 			return fmt.Errorf("failed to list objects due to %w", err)
 		}