From a0cba0f53b7551bf04692af1e90a5dcf3cb4d150 Mon Sep 17 00:00:00 2001
From: CahidArda <cahidardaooz@hotmail.com>
Date: Tue, 9 Sep 2025 17:34:21 +0300
Subject: [PATCH] fix: initialize qstash client if it's not passed

---
 src/serve/options.ts | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/serve/options.ts b/src/serve/options.ts
index d404941..a219226 100644
--- a/src/serve/options.ts
+++ b/src/serve/options.ts
@@ -44,10 +44,12 @@ export const processOptions = <TResponse extends Response = Response, TInitialPa
   );
 
   return {
-    qstashClient: new Client({
-      baseUrl: environment.QSTASH_URL!,
-      token: environment.QSTASH_TOKEN!,
-    }),
+    qstashClient:
+      options?.qstashClient ??
+      new Client({
+        baseUrl: environment.QSTASH_URL!,
+        token: environment.QSTASH_TOKEN!,
+      }),
     onStepFinish: (workflowRunId, _finishCondition, detailedFinishCondition) => {
       if (detailedFinishCondition?.condition === "auth-fail") {
         console.error(AUTH_FAIL_MESSAGE);