small fixes

Author: nicktrn

apps/proxy/src/events/queueEvent.ts

@@ -24,6 +24,7 @@ export async function queueEvent(request: Request, env: Env): Promise<Response>
     const anyBody = await request.json();
     const body = SendEventBodySchema.safeParse(anyBody);
     if (!body.success) {
+      fromZodError(body.error);
       return json(
         { error: generateErrorMessage(body.error.issues) },
         {

packages/cli-v3/src/workers/prod/entry-point.ts

@@ -226,7 +226,6 @@ class ProdWorker {
     await this.#prepareForWait("WAIT_FOR_TASK", willCheckpointAndRestore);
 
     if (willCheckpointAndRestore) {
-      // TODO: where's the timeout?
       // We need to replay this on next connection if we don't receive RESUME_AFTER_DEPENDENCY within a reasonable time
       if (!this.waitForTaskReplay) {
         this.waitForTaskReplay = {
@@ -398,7 +397,7 @@ class ProdWorker {
       // Workers with lazy attempt support set their friendly ID here
       this.attemptFriendlyId = message.execution.attempt.id;
     });
-    
+
     backgroundWorker.onWaitForDuration.attach(async (message) => {
       logger.log("onWaitForDuration", { ...message, drift: Date.now() - message.now });
 

packages/core/src/v3/zodSocket.ts

@@ -169,13 +169,9 @@ export class ZodSocketMessageHandler<TRPCCatalog extends ZodSocketMessageCatalog
         payload: messageWithVersion,
       });
 
-      // FIXME
       return {
         success: false,
-        reason: (parsedPayload.error instanceof ZodError
-          ? fromZodError(parsedPayload.error)
-          : parsedPayload.error
-        )?.toString(),
+        reason: fromZodError(parsedPayload.error).toString(),
       };
     }