don't use retries, include checkpoints

Author: miparnisari

README.md

@@ -60,7 +60,7 @@ If you are using [Gradle] then add the following to your `build.gradle` file:
 
 ```groovy
 dependencies {
-    implementation "com.authzed.api:authzed:v1.3.0"
+    implementation "com.authzed.api:authzed:1.4.1"
     implementation 'io.grpc:grpc-api:1.72.0'
     implementation 'io.grpc:grpc-stub:1.72.0'
 }

examples/v1/CallingWatch.java

@@ -10,8 +10,6 @@
 import io.grpc.Status;
 import io.grpc.StatusRuntimeException;
 import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
 
 // Installation
 // https://search.maven.org/artifact/com.authzed.api/authzed
@@ -35,33 +33,14 @@ public static void main(String[] args) {
         ManagedChannel channel = ManagedChannelBuilder
                 .forTarget(target)
                 .useTransportSecurity() // if not using TLS, replace with .usePlaintext()
-                .disableServiceConfigLookUp()
-                .defaultServiceConfig(Map.of(
-                        "methodConfig", List.of(
-                                Map.of(
-                                        "name",  List.of(
-                                                Map.of(
-                                                        "service", "authzed.api.v1.WatchService",
-                                                        "method", "Watch"
-                                                )
-                                        ),
-                                        "retryPolicy", Map.of(
-                                                "maxAttempts", "5",
-                                                "initialBackoff", "1s",
-                                                "backoffMultiplier", "4.0",
-                                                "maxBackoff", "30s",
-                                                "retryableStatusCodes", List.of("UNAVAILABLE", "INTERNAL")
-                                        )
-                                )
-                        )
-                ))
                 .build();
 
         ZedToken lastZedToken = ZedToken.newBuilder().setToken("").build();
 
         while(true) {
             try {
                 WatchRequest.Builder builder = WatchRequest.newBuilder();
+                builder.addOptionalUpdateKinds(com.authzed.api.v1.WatchKind.WATCH_KIND_INCLUDE_CHECKPOINTS);
 
                 if (!lastZedToken.getToken().isEmpty()) {
                     builder.setOptionalStartCursor(lastZedToken);
@@ -73,21 +52,21 @@ public static void main(String[] args) {
 
                 while (watchStream.hasNext()) {
                     WatchResponse msg = watchStream.next();
-                    System.out.println("Received watch response: " + msg);
+                    if (msg.getUpdatesCount() > 0) {
+                        for (var update : msg.getUpdatesList()) {
+                            System.out.println("Received update: " + update);
+                        }
+                    } else {
+                        System.out.println("No changes made in SpiceDB");
+                    }
 
                     if (!msg.getChangesThrough().getToken().isEmpty()) {
                         lastZedToken = msg.getChangesThrough();
                     }
                 }
-
             } catch (Exception e) {
-                if (e instanceof StatusRuntimeException sre && (sre.getStatus().getCode().equals(Status.UNAVAILABLE.getCode()) ||
-                        sre.getStatus().getCode().equals(Status.INTERNAL.getCode()))) {
-                    // Stream probably got disconnected after inactivity. Retry
-                } else {
-                    System.out.println("Error calling watch: " + e.getMessage());
-                    return;
-                }
+                System.out.println("Error calling watch: " + e.getMessage());
+                return;
             }
         }
     }