fix: tests (#114)

Author: CahidArda

src/client/index.test.ts

@@ -234,8 +234,9 @@ describe("workflow client", () => {
               "upstash-delay": "1s",
               "content-type": "application/json",
               "upstash-feature-set": "LazyFetch,InitialBody",
+              "upstash-telemetry-framework": "unknown",
               "upstash-telemetry-runtime": expect.stringMatching(/bun@/),
-              "upstash-telemetry-sdk": expect.stringMatching(/upstash-qstash-js@/),
+              "upstash-telemetry-sdk": expect.stringContaining("@upstash/workflow"),
               "upstash-workflow-sdk-version": "1",
             },
             body,
@@ -298,8 +299,9 @@ describe("workflow client", () => {
               "upstash-delay": "1s",
               "content-type": "application/json",
               "upstash-feature-set": "LazyFetch,InitialBody",
+              "upstash-telemetry-framework": "unknown",
               "upstash-telemetry-runtime": expect.stringMatching(/bun@/),
-              "upstash-telemetry-sdk": expect.stringMatching(/upstash-qstash-js@/),
+              "upstash-telemetry-sdk": expect.stringContaining("@upstash/workflow"),
               "upstash-workflow-sdk-version": "1",
             },
             body,
@@ -317,8 +319,9 @@ describe("workflow client", () => {
               "upstash-delay": "1s",
               "content-type": "application/json",
               "upstash-feature-set": "LazyFetch,InitialBody",
+              "upstash-telemetry-framework": "unknown",
               "upstash-telemetry-runtime": expect.stringMatching(/bun@/),
-              "upstash-telemetry-sdk": expect.stringMatching(/upstash-qstash-js@/),
+              "upstash-telemetry-sdk": expect.stringContaining("@upstash/workflow"),
               "upstash-workflow-sdk-version": "1",
               "upstash-failure-callback": "https://requestcatcher.com/api",
               "upstash-failure-callback-feature-set": "LazyFetch,InitialBody",
@@ -385,8 +388,9 @@ describe("workflow client", () => {
               "upstash-failure-callback-workflow-init": "false",
               "upstash-failure-callback-workflow-runid": `wfr_${myWorkflowRunId}`,
               "upstash-failure-callback-workflow-url": "https://requestcatcher.com/api",
+              "upstash-telemetry-framework": "unknown",
               "upstash-telemetry-runtime": expect.stringMatching(/bun@/),
-              "upstash-telemetry-sdk": expect.stringMatching(/upstash-qstash-js@/),
+              "upstash-telemetry-sdk": expect.stringContaining("@upstash/workflow"),
               "upstash-workflow-sdk-version": "1",
             },
             body,

src/client/index.ts

@@ -5,6 +5,7 @@ import { getWorkflowRunId } from "../utils";
 import { triggerFirstInvocation } from "../workflow-requests";
 import { WorkflowContext } from "../context";
 import { TriggerOptions, WorkflowRunLog, WorkflowRunLogs } from "./types";
+import { SDK_TELEMETRY } from "../constants";
 
 type ClientConfig = ConstructorParameters<typeof QStashClient>[0];
 
@@ -246,14 +247,14 @@ export class Client {
         url: option.url,
         workflowRunId: finalWorkflowRunId,
         retries: option.retries,
-        telemetry: undefined, // can't know workflow telemetry here
+        telemetry: { sdk: SDK_TELEMETRY },
         flowControl: option.flowControl,
         failureUrl,
       });
 
       return {
         workflowContext: context,
-        telemetry: undefined, // can't know workflow telemetry here
+        telemetry: { sdk: SDK_TELEMETRY },
         delay: option.delay,
       };
     });

src/types.ts

@@ -281,7 +281,7 @@ export type Telemetry = {
   /**
    * platform (such as nextjs/cloudflare)
    */
-  framework: string;
+  framework?: string;
   /**
    * node version
    */

src/workflow-requests.ts

@@ -427,7 +427,7 @@ export type HeadersResponse = {
 export const getTelemetryHeaders = (telemetry: Telemetry) => {
   return {
     [TELEMETRY_HEADER_SDK]: telemetry.sdk,
-    [TELEMETRY_HEADER_FRAMEWORK]: telemetry.framework,
+    [TELEMETRY_HEADER_FRAMEWORK]: telemetry.framework ?? "unknown",
     [TELEMETRY_HEADER_RUNTIME]: telemetry.runtime ?? "unknown",
   };
 };