Upgrade codehike to v1

code_snippets/go/concepts/invocations.go

@@ -11,11 +11,11 @@ type MyService struct{}
 /*
 // <start_rpc_call>
 func (MyService) MyRestateHandler(ctx restate.Context) error {
-	// focus
+	// !focus
 	greet, err := restate.
-		// focus
+		// !focus
 		Service[string](ctx, "Greeter", "Greet").
-		// focus
+		// !focus
 		Request("Hi")
 	return err
 }
@@ -24,11 +24,11 @@ func (MyService) MyRestateHandler(ctx restate.Context) error {
 
 // <start_one_way_call>
 func (MyService) MyRestateHandler(ctx restate.Context) error {
-	// focus
+	// !focus
 	restate.
-		// focus
+		// !focus
 		ServiceSend(ctx, "Greeter", "Greet").
-		// focus
+		// !focus
 		Send("Hi")
 	return nil
 }
@@ -38,11 +38,11 @@ func (MyService) MyRestateHandler(ctx restate.Context) error {
 
 // <start_delayed_call>
 func (MyService) MyRestateHandler(ctx restate.Context) error {
-	// focus
+	// !focus
 	restate.
-		// focus
+		// !focus
 		ServiceSend(ctx, "Greeter", "Greet").
-		// focus
+		// !focus
 		Send("Hi", restate.WithDelay(1*time.Second))
 	return nil
 }

code_snippets/go/develop/codegen/proto/service.proto

@@ -3,7 +3,6 @@ syntax = "proto3";
 option go_package = "github.com/restatedev/documentation/code_snippets/go/codegen/proto";
 
 // <start_service>
-// service.proto
 package greeter;
 
 service Greeter {

code_snippets/java/src/main/java/concepts/invocations/DelayedCalls.java

@@ -12,25 +12,25 @@ public class DelayedCalls {
   // <start_delayed_call>
   @Handler
   public void myRestateHandler(Context ctx) {
-    // focus
+    // !focus
     GreeterServiceClient.fromContext(ctx)
-        // focus
+        // !focus
         .send(Duration.ofMillis(1000))
-        // focus
+        // !focus
         .greet("Hi");
   }
 
   // <end_delayed_call>
 
   // <start_delayed_call_java>
-  public void myJavaHandler(Context ctx) {
-    // focus
+  public void myJavaHandler() {
+    // !focus
     Client restate = Client.connect("http://localhost:8080");
-    // focus
+    // !focus
     GreeterServiceClient.fromClient(restate)
-        // focus
+        // !focus
         .send(Duration.ofMillis(1000))
-        // focus
+        // !focus
         .greet("Hi");
   }
   // <end_delayed_call_java>

code_snippets/java/src/main/java/concepts/invocations/OneWayCalls.java

@@ -11,25 +11,25 @@ public class OneWayCalls {
   // <start_one_way_call>
   @Handler
   public void myRestateHandler(Context ctx) {
-    // focus
+    // !focus
     GreeterServiceClient.fromContext(ctx)
-        // focus
+        // !focus
         .send()
-        // focus
+        // !focus
         .greet("Hi");
   }
 
   // <end_one_way_call>
 
   // <start_one_way_call_java>
-  public void myJavaHandler(Context ctx) {
-    // focus
+  public void myJavaHandler() {
+    // !focus
     Client restate = Client.connect("http://localhost:8080");
-    // focus
+    // !focus
     GreeterServiceClient.fromClient(restate)
-        // focus
+        // !focus
         .send()
-        // focus
+        // !focus
         .greet("Hi");
   }
   // <end_one_way_call_java>

code_snippets/java/src/main/java/concepts/invocations/RpcCalls.java

@@ -11,27 +11,27 @@ public class RpcCalls {
   // <start_rpc>
   @Handler
   public void myRestateHandler(Context ctx) {
-    // focus
+    // !focus
     String greet =
-        // focus
+        // !focus
         GreeterServiceClient.fromContext(ctx)
-            // focus
+            // !focus
             .greet("Hi")
-            // focus
+            // !focus
             .await();
   }
 
   // <end_rpc>
 
   // <start_rpc_java>
-  public void myJavaHandler(Context ctx) {
-    // focus
+  public void myJavaHandler() {
+    // !focus
     Client restate = Client.connect("http://localhost:8080");
-    // focus
+    // !focus
     String greet =
-        // focus
+        // !focus
         GreeterServiceClient.fromClient(restate)
-            // focus
+            // !focus
             .greet("Hi");
   }
   // <end_rpc_java>

code_snippets/java/src/main/java/develop/ServiceCommunication.java

@@ -59,7 +59,7 @@ private void oneWay(Context ctx) {
 
     // <start_one_way>
     MyServiceClient.fromContext(ctx)
-        // mark
+        // !mark
         .send()
         .myHandler(request);
     // <end_one_way>
@@ -70,7 +70,7 @@ private void delayedCall(Context ctx) {
 
     // <start_delayed>
     MyServiceClient.fromContext(ctx)
-        // mark
+        // !mark
         .send(Duration.ofSeconds(1))
         .myHandler(request);
     // <end_delayed>

code_snippets/java/src/main/java/develop/clients/Ingress.java

@@ -23,12 +23,12 @@ public void myOneWayCallHandler() {
     // <start_one_way_call_java>
     Client rs = Client.connect("http://localhost:8080");
     GreeterServiceClient.fromClient(rs)
-        // mark
+        // !mark
         .send()
         .greet("Hi");
 
     GreetCounterObjectClient.fromClient(rs, "Mary")
-        // mark
+        // !mark
         .send()
         .greet("Hi");
     // <end_one_way_call_java>
@@ -38,12 +38,12 @@ public void myDelayedOneWayCallHandler() {
     // <start_delayed_call_java>
     Client rs = Client.connect("http://localhost:8080");
     GreeterServiceClient.fromClient(rs)
-        // mark
+        // !mark
         .send(Duration.ofMillis(1000))
         .greet("Hi");
 
     GreetCounterObjectClient.fromClient(rs, "Mary")
-        // mark
+        // !mark
         .send(Duration.ofMillis(1000))
         .greet("Hi");
     // <end_delayed_call_java>
@@ -67,21 +67,21 @@ public void attach() {
     SendResponse handle =
         GreeterServiceClient.fromClient(rs)
             .send()
-            // mark
+            // !mark
             .greet("Hi", CallRequestOptions.DEFAULT.withIdempotency("abcde"));
 
     // ... do something else ...
 
     // Option 1: Attach later to retrieve the result
-    // mark
+    // !mark
     String greeting =
-        // mark
+        // !mark
         rs.invocationHandle(handle.getInvocationId(), JsonSerdes.STRING).attach();
 
     // Option 2: Peek to see if the result is ready
-    // mark
+    // !mark
     Output<String> output =
-        // mark
+        // !mark
         rs.invocationHandle(handle.getInvocationId(), JsonSerdes.STRING).getOutput();
     if (output.isReady()) {
       String result = output.getValue();

code_snippets/java/src/main/java/develop/workflows/UserManagementService.java

@@ -9,25 +9,25 @@ public class UserManagementService {
   // <start_here>
   @Handler
   public void setup(ObjectContext ctx, Email email) {
-    // focus
+    // !focus
     boolean result =
-        // focus
+        // !focus
         SignupWorkflowClient.fromContext(ctx, "someone")
-            // focus
+            // !focus
             .run(email)
-            // focus
+            // !focus
             .await();
   }
 
   @Handler
   public void queryStatus(ObjectContext ctx) {
-    // focus
+    // !focus
     String status =
-        // focus
+        // !focus
         SignupWorkflowClient.fromContext(ctx, "someone")
-            // focus
+            // !focus
             .getStatus()
-            // focus
+            // !focus
             .await();
   }
   // <end_here>

code_snippets/java/src/main/java/get_started/Tour.java

@@ -27,12 +27,12 @@ public void myFn(Context ctx) {
   // <start_uuid>
   @Handler
   public boolean handle(Context ctx, CheckoutRequest request) {
-    // mark
+    // !mark
     String idempotencyKey = ctx.random().nextUUID().toString();
-    // mark
+    // !mark
     System.out.println("My idempotency key: " + idempotencyKey);
 
-    // mark
+    // !mark
     throw new IllegalStateException("The handler failed");
   }
 
@@ -48,18 +48,18 @@ class CheckoutService {
   // <start_checkout>
   @Handler
   public boolean handle(Context ctx, CheckoutRequest request) {
-    // mark
+    // !mark
     double totalPrice = request.getTickets().size() * 40.0;
 
     String idempotencyKey = ctx.random().nextUUID().toString();
 
-    // mark
+    // !mark
     boolean success =
-        // mark
+        // !mark
         ctx.run(
-            // mark
+            // !mark
             JsonSerdes.BOOLEAN,
-            // mark
+            // !mark
             () -> PaymentClient.get().call(idempotencyKey, totalPrice));
 
     return success;

code_snippets/java/src/main/java/usecases/workflows/WorkflowSubmitter.java

@@ -8,20 +8,20 @@ public void submit(User user) {
     // <start_here>
     // import dev.restate.sdk.client.Client;
     Client rs = Client.connect("http://localhost:8080");
-    // mark
+    // !mark
     SignupWorkflowClient.fromClient(rs, user.getId())
-        // mark
+        // !mark
         .submit(user);
 
     // do something else, with workflow running in the background
 
     // attach back to the workflow
-    // mark
+    // !mark
     boolean result =
         SignupWorkflowClient.fromClient(rs, user.getId())
-            // mark
+            // !mark
             .workflowHandle()
-            // mark
+            // !mark
             .attach();
     // <end_here>
   }

code_snippets/kotlin/src/main/kotlin/develop/clients/Ingress.kt

@@ -24,12 +24,12 @@ class Ingress {
     // <start_one_way_call_kotlin>
     val rs = Client.connect("http://localhost:8080")
     GreeterServiceClient.fromClient(rs)
-        // mark
+        // !mark
         .send()
         .greet("Hi")
 
     GreetCounterObjectClient.fromClient(rs, "Mary")
-        // mark
+        // !mark
         .send()
         .greet("Hi")
     // <end_one_way_call_kotlin>
@@ -66,18 +66,18 @@ class Ingress {
     val handle: SendResponse =
         GreeterServiceClient.fromClient(rs)
             .send()
-            // mark
+            // !mark
             .greet("Hi", CallRequestOptions.DEFAULT.withIdempotency("abcde"))
 
     // ... do something else ...
 
     // Option 1: Attach later to retrieve the result
-    // mark(1:3)
+    // !mark(1:2)
     val greeting: String =
         rs.invocationHandle(handle.invocationId, KtSerdes.json<String>()).attach()
 
     // Option 2: Peek to see if the result is ready
-    // mark(1:3)
+    // !mark(1:2)
     val output: Output<String> =
         rs.invocationHandle(handle.invocationId, KtSerdes.json<String>()).output
     if (output.isReady) {

code_snippets/kotlin/src/main/kotlin/develop/workflows/UserManagementService.kt

@@ -9,13 +9,13 @@ class UserManagementService {
   // <start_here>
   @Handler
   suspend fun setup(ctx: ObjectContext, email: Email) {
-    // focus(1:3)
+    // !focus
     val result = SignupWorkflowClient.fromContext(ctx, "someone").run(email).await()
   }
 
   @Handler
   suspend fun queryStatus(ctx: ObjectContext) {
-    // focus(1:3)
+    // !focus
     val status = SignupWorkflowClient.fromContext(ctx, "someone").getStatus().await()
   }
   // <end_here>