Create handler Alias (#577)

* Switch to 1.8.0
* Re-export common shortcuts for handlers
* Add common shortcuts for handlers.*.handler
* Apply lint rules

Author: igalshilman

package-lock.json

@@ -9,15 +9,23 @@
  * https://github.com/restatedev/sdk-typescript/blob/main/LICENSE
  */
 
-import * as restate from "@restatedev/restate-sdk";
+import {
+  createObjectHandler,
+  createObjectSharedHandler,
+  object,
+  type ObjectContext,
+  type ObjectSharedContext,
+  serde,
+  serve,
+} from "@restatedev/restate-sdk";
 
-export const counter = restate.object({
+export const counter = object({
   name: "counter",
   handlers: {
     /**
      * Add amount to the currently stored count
      */
-    add: async (ctx: restate.ObjectContext, amount: number) => {
+    add: async (ctx: ObjectContext, amount: number) => {
       const current = await ctx.get<number>("count");
       const updated = (current ?? 0) + amount;
       ctx.set("count", updated);
@@ -31,8 +39,8 @@ export const counter = restate.object({
      * These handlers can be executed concurrently to the exclusive handlers (i.e. add)
      * But they can not modify the state (set is missing from the ctx).
      */
-    current: restate.handlers.object.shared(
-      async (ctx: restate.ObjectSharedContext): Promise<number> => {
+    current: createObjectSharedHandler(
+      async (ctx: ObjectSharedContext): Promise<number> => {
         return (await ctx.get("count")) ?? 0;
       }
     ),
@@ -44,12 +52,12 @@ export const counter = restate.object({
      * to call that handler with binary data, you can use the following curl command:
      * curl -X POST -H "Content-Type: application/octet-stream" --data-binary 'hello' ${RESTATE_INGRESS_URL}/counter/mykey/binary
      */
-    binary: restate.handlers.object.exclusive(
+    binary: createObjectHandler(
       {
-        input: restate.serde.binary,
-        output: restate.serde.binary,
+        input: serde.binary,
+        output: serde.binary,
       },
-      async (ctx: restate.ObjectContext, data: Uint8Array) => {
+      async (ctx: ObjectContext, data: Uint8Array) => {
         // console.log("Received binary data", data);
         return data;
       }
@@ -59,4 +67,4 @@ export const counter = restate.object({
 
 export type Counter = typeof counter;
 
-restate.serve({ services: [counter] });
+serve({ services: [counter] });

packages/restate-sdk-examples/src/object.ts

@@ -20,7 +20,7 @@ const Greeting = z.object({
 const greeter = restate.service({
   name: "greeter",
   handlers: {
-    greet: restate.handlers.handler(
+    greet: restate.createServiceHandler(
       {
         input: serde.zod(Greeting),
         output: serde.zod(z.string()),

packages/restate-sdk-examples/src/zod_greeter.ts

@@ -124,3 +124,13 @@ export type {
   LogSource,
 } from "./logging/logger_transport.js";
 export type { EndpointOptions } from "./endpoint/types.js";
+
+// re-exporting createHandler shortcuts
+
+import { handlers } from "./types/rpc.js";
+
+export const createServiceHandler = handlers.handler;
+export const createObjectHandler = handlers.object.exclusive;
+export const createObjectSharedHandler = handlers.object.shared;
+export const createWorkflowHandler = handlers.workflow.workflow;
+export const createWorkflowSharedHandler = handlers.workflow.shared;