1+ import static com .authzed .api .v1 .CheckDebugTrace .Permissionship .PERMISSIONSHIP_HAS_PERMISSION ;
12import static org .junit .Assert .assertEquals ;
23import static org .junit .Assert .assertNotNull ;
34import static org .junit .Assert .assertTrue ;
78import java .util .Random ;
89import java .util .Set ;
910
11+ import com .authzed .api .v1 .*;
1012import com .authzed .grpcutil .BearerToken ;
1113
1214import org .junit .Test ;
1315
1416import io .grpc .ManagedChannel ;
1517import io .grpc .ManagedChannelBuilder ;
16- import com .authzed .api .v1 .PermissionsServiceGrpc ;
17- import com .authzed .api .v1 .SchemaServiceGrpc ;
18- import com .authzed .api .v1 .Core .ObjectReference ;
19- import com .authzed .api .v1 .Core .Relationship ;
20- import com .authzed .api .v1 .Core .RelationshipUpdate ;
21- import com .authzed .api .v1 .Core .SubjectReference ;
22- import com .authzed .api .v1 .Core .ZedToken ;
23- import com .authzed .api .v1 .PermissionService ;
24- import com .authzed .api .v1 .PermissionService .CheckPermissionRequest ;
25- import com .authzed .api .v1 .PermissionService .CheckPermissionResponse ;
26- import com .authzed .api .v1 .PermissionService .CheckPermissionResponse .Permissionship ;
27- import com .authzed .api .v1 .SchemaServiceOuterClass .ReadSchemaRequest ;
28- import com .authzed .api .v1 .SchemaServiceOuterClass .ReadSchemaResponse ;
29- import com .authzed .api .v1 .SchemaServiceOuterClass .WriteSchemaRequest ;
30- import com .authzed .api .v1 .PermissionService .Consistency ;
31- import com .authzed .api .v1 .PermissionService .WriteRelationshipsRequest ;
32- import com .authzed .api .v1 .PermissionService .WriteRelationshipsResponse ;
3318
3419public class V1ClientTest {
3520 private static final String target = "localhost:50051" ;
@@ -60,6 +45,9 @@ public void testSchemaService() {
6045 ReadSchemaResponse readResponse = schemaService .readSchema (readRequest );
6146 assertTrue (readResponse .getSchemaText ().indexOf ("test/article" ) > 0 );
6247 }
48+
49+ // For an example with flow control, see
50+ // https://github.com/grpc/grpc-java/blob/9071c1ad7c842f4e73b6ae95b71f11c517b177a4/examples/src/main/java/io/grpc/examples/manualflowcontrol/ManualFlowControlClient.java
6351 @ Test
6452 public void testCheckPermission () {
6553 // Initialize services
@@ -103,7 +91,7 @@ public void testCheckPermission() {
10391 .build ();
10492
10593 CheckPermissionResponse checkResponse = permissionsService .checkPermission (checkRequest );
106- assertEquals (Permissionship .PERMISSIONSHIP_HAS_PERMISSION , checkResponse .getPermissionship ());
94+ assertEquals (CheckPermissionResponse . Permissionship .PERMISSIONSHIP_HAS_PERMISSION , checkResponse .getPermissionship ());
10795 }
10896
10997 @ Test
@@ -127,7 +115,7 @@ public void testLookupResources() {
127115 ZedToken zedToken = ZedToken .newBuilder ()
128116 .setToken (tokenVal )
129117 .build ();
130- PermissionService . LookupResourcesRequest lookupResourcesRequest = PermissionService . LookupResourcesRequest .newBuilder ()
118+ LookupResourcesRequest lookupResourcesRequest = LookupResourcesRequest .newBuilder ()
131119 .setConsistency (
132120 Consistency .newBuilder ()
133121 .setAtLeastAsFresh (zedToken )
@@ -144,7 +132,7 @@ public void testLookupResources() {
144132 .setPermission ("can_comment" )
145133 .build ();
146134
147- Iterator <PermissionService . LookupResourcesResponse > resp = permissionsService .lookupResources (lookupResourcesRequest );
135+ Iterator <LookupResourcesResponse > resp = permissionsService .lookupResources (lookupResourcesRequest );
148136 Set <String > resources = new HashSet <>();
149137 resp .forEachRemaining (lookupResourcesResponse -> {
150138 resources .add (lookupResourcesResponse .getResourceObjectId ());
0 commit comments