Remove tsc dependency and fix path route (#47)

* fix: nextjs path route

* fix: add test for context.cancel inside context.run

examples/nextjs/app/path/route.ts

@@ -1,5 +1,3 @@
-export const runtime = 'nodejs';
-
 import { serve } from '@upstash/workflow/nextjs'
 
 const someWork = (input: string) => {
@@ -9,7 +7,13 @@ const someWork = (input: string) => {
 export const { POST } = serve<string>(async (context) => {
   const input = context.requestPayload
   const result1 = await context.run('step1', async () => {
-    console.log(someWork(input));
+    const output = someWork(input)
+    console.log('step 1 input', input, 'output', output)
+    return output
+  })
+
+  await context.run('step2', async () => {
+    const output = someWork(result1)
+    console.log('step 2 input', result1, 'output', output)
   })
-}, {
-})
+})

package.json

@@ -96,7 +96,6 @@
     "husky": "^9.1.6",
     "next": "^14.2.14",
     "prettier": "3.3.3",
-    "tsc": "^2.0.4",
     "tsup": "^8.3.0",
     "typescript": "^5.6.3",
     "typescript-eslint": "^8.8.0"

src/workflow-requests.test.ts

@@ -172,6 +172,39 @@ describe("Workflow Requests", () => {
     expect(result.value).toBe("workflow-finished");
   });
 
+  test("should call onCancel if context.cancel is called inside context.run", async () => {
+    const workflowRunId = nanoid();
+    const token = "myToken";
+
+    const context = new WorkflowContext({
+      qstashClient: new Client({ baseUrl: MOCK_SERVER_URL, token }),
+      workflowRunId: workflowRunId,
+      initialPayload: undefined,
+      headers: new Headers({}) as Headers,
+      steps: [],
+      url: WORKFLOW_ENDPOINT,
+    });
+
+    const finished = new FinishState();
+    const result = await triggerRouteFunction({
+      onStep: async () => {
+        await context.run("should call cancel", async () => {
+          await context.cancel();
+        });
+      },
+      onCleanup: async () => {
+        throw new Error("shouldn't call");
+      },
+      onCancel: async () => {
+        finished.finish();
+      },
+    });
+    finished.check();
+    expect(result.isOk()).toBeTrue();
+    // @ts-expect-error value will be set since result isOk
+    expect(result.value).toBe("workflow-finished");
+  });
+
   test("should call publishJSON in triggerWorkflowDelete", async () => {
     const workflowRunId = nanoid();
     const token = "myToken";