fix: decode eventData from base64

Author: CahidArda

src/context/auto-executor.ts

@@ -356,7 +356,7 @@ export class AutoExecutor {
         body: JSON.stringify(waitBody),
         headers,
         method: "POST",
-        parseResponseAsJson: false
+        parseResponseAsJson: false,
       });
 
       throw new QStashWorkflowAbort(steps[0].stepName, steps[0]);

src/workflow-parser.test.ts

@@ -228,6 +228,7 @@ describe("Workflow Parser", () => {
     });
 
     test("should overwrite the out field of wait step", async () => {
+      const eventData = "notify-data";
       const timeoutStep: Step = {
         stepId: 1,
         stepName: "wait-step-name-1",
@@ -242,7 +243,7 @@ describe("Workflow Parser", () => {
         stepId: 2,
         stepName: "wait-step-name-2",
         stepType: "Wait",
-        out: "notify-data",
+        out: btoa(eventData),
         waitTimeout: false,
         waitEventId: "wait-event-2",
         concurrent: 1,
@@ -285,7 +286,7 @@ describe("Workflow Parser", () => {
       expect(steps[1].out).toEqual(timeoutResponse);
 
       const notifyResponse: WaitStepResponse = {
-        eventData: "notify-data",
+        eventData,
         timeout: false,
       };
       expect(steps[2].out).toEqual(notifyResponse);

src/workflow-parser.ts

@@ -71,7 +71,7 @@ const parsePayload = (rawPayload: string) => {
     // if event is a wait event, overwrite the out with WaitStepResponse:
     if (step.waitEventId) {
       const newOut: WaitStepResponse = {
-        eventData: step.out,
+        eventData: step.out ? decodeBase64(step.out as string) : undefined,
         timeout: step.waitTimeout ?? false,
       };
       step.out = newOut;