feat(workflows-sdk): Allow primitive values to be passed as well as WorkflowDataProperties (#5953)

* feat(workflows-sdk): Allow primitive values to be passed as well as WorkflowDataProperties

* feat(workflows-sdk): improve playground tests

* Create nine-shrimps-reply.md

.changeset/nine-shrimps-reply.md

@@ -0,0 +1,5 @@
+---
+"@medusajs/workflows-sdk": patch
+---
+
+feat(workflows-sdk): Allow primitive values to be passed as well as WorkflowDataProperties

packages/workflows-sdk/src/utils/_playground.ts

@@ -1,14 +1,15 @@
 import { createStep, createWorkflow, StepResponse } from "./composer"
 
 const step1 = createStep("step1", async (input: {}, context) => {
-  console.log("step1", input) // Here the input will be `{}` and the createWorkflow does not have to provide an input
   return new StepResponse({ step1: "step1" })
 })
 
-const step2 = createStep("step2", async (input: string, context) => {
+const step2 = createStep(
-  console.log("step2", input) // Here the input will be the string value `step1`
+  "step2",
-  return new StepResponse({ step2: "step2" })
+  async (input: { test: string; test2: string }, context) => {
-})
+    return new StepResponse({ step2: input })
+  }
+)
 
 const step3 = createStep("step3", async () => {
   return new StepResponse({ step3: "step3" })
@@ -17,11 +18,11 @@ const step3 = createStep("step3", async () => {
 const workflow = createWorkflow("workflow", function () {
   const step1Res = step1()
   step3()
-  return step2(step1Res.step1)
+  return step2({ test: "test", test2: step1Res.step1 })
 })
 
 workflow()
   .run({})
   .then((res) => {
-    console.log(res.result) // result: { step2: "step2" }
+    console.log(res.result) // result: { step2: { test: "test", test2: "step1" } }
   })

packages/workflows-sdk/src/utils/composer/type.ts

@@ -29,8 +29,8 @@ export type StepFunction<TInput, TOutput = unknown> = (keyof TInput extends []
     {
       (
         input: TInput extends object
-          ? { [K in keyof TInput]: WorkflowData<TInput[K]> }
+          ? { [K in keyof TInput]: WorkflowData<TInput[K]> | TInput[K] }
-          : WorkflowData<TInput>
+          : WorkflowData<TInput> | TInput
       ): WorkflowData<{
         [K in keyof TOutput]: TOutput[K]
       }>