increase size of entity_type on cluster_messages table (#5345)

Author: tim-smart

.changeset/hot-cases-attend.md

@@ -0,0 +1,5 @@
+---
+"@effect/cluster": patch
+---
+
+increase size of entity_type on cluster_messages table

.changeset/hot-spies-occur.md

@@ -0,0 +1,6 @@
+---
+"@effect/workflow": patch
+"@effect/cluster": patch
+---
+
+log defects in Entity & Workflow proxy for HttpApi endpoints

packages/cluster/src/EntityProxy.ts

@@ -172,7 +172,10 @@ export const toHttpApiGroup = <const Name extends string, Type extends string, R
       .addSuccess(parentRpc.successSchema)
       .addError(Schema.Union(parentRpc.errorSchema, ...clientErrors))
       .annotateContext(parentRpc.annotations)
-    const endpointDiscard = HttpApiEndpoint.post(parentRpc._tag, `/${tagToPath(parentRpc._tag)}/:entityId/discard`)
+    const endpointDiscard = HttpApiEndpoint.post(
+      `${parentRpc._tag}Discard`,
+      `/${tagToPath(parentRpc._tag)}/:entityId/discard`
+    )
       .setPath(entityIdPath)
       .setPayload(parentRpc.payloadSchema)
       .addError(Schema.Union(...clientErrors))

packages/cluster/src/EntityProxyServer.ts

@@ -40,12 +40,33 @@ export const layerHttpApi = <
           .handle(
             parentRpc._tag as any,
             (({ path, payload }: { path: { entityId: string }; payload: any }) =>
-              (client(path.entityId) as any)[parentRpc._tag](payload)) as any
+              (client(path.entityId) as any as Record<string, (p: any) => Effect.Effect<any>>)[parentRpc._tag](
+                payload
+              ).pipe(
+                Effect.tapDefect(Effect.logError),
+                Effect.annotateLogs({
+                  module: "EntityProxyServer",
+                  entity: entity.type,
+                  entityId: path.entityId,
+                  method: parentRpc._tag
+                })
+              )) as any
           )
           .handle(
             `${parentRpc._tag}Discard` as any,
             (({ path, payload }: { path: { entityId: string }; payload: any }) =>
-              (client(path.entityId) as any)[parentRpc._tag](payload, { discard: true })) as any
+              (client(path.entityId) as any as Record<string, (p: any, o: {}) => Effect.Effect<any>>)[parentRpc._tag](
+                payload,
+                { discard: true }
+              ).pipe(
+                Effect.tapDefect(Effect.logError),
+                Effect.annotateLogs({
+                  module: "EntityProxyServer",
+                  entity: entity.type,
+                  entityId: path.entityId,
+                  method: `${parentRpc._tag}Discard`
+                })
+              )) as any
           ) as any
       }
       return handlers as HttpApiBuilder.Handlers<never, never, never>