Durable Jobs workflows

stackshift.job<{ userId: string; email: string }>('userOnboarding', async ({ payload, step }) => {
  const { userId, email } = payload

  const user = await step.run('create-user', () => {
    return createUser({ id: userId, email })
  })

  await step.run('send-verification-email', () => {
    return sendVerificationEmail(user.email)
  })

  const event = await step.waitForEvent<{ userId: string }>('email.verified', {
    correlationKey: `user:${userId}`,
    timeout: '24h',
    onTimeout: 'fail',
  })

  await step.run('unlock-account', () => {
    return unlockAccount(event.payload.userId)
  })

  return { onboarded: true }
})

client.Job("userOnboarding", func(ctx context.Context, job stackshift.JobContext) (any, error) {
  var payload struct {
    UserID string `json:"userId"`
    Email  string `json:"email"`
  }
  _ = json.Unmarshal(job.Payload, &payload)

  _, err := job.Step.Run(ctx, "send-verification-email", func(context.Context, stackshift.HandlerInvocation) (any, error) {
    return nil, sendVerificationEmail(payload.Email)
  })
  if err != nil { return nil, err }

  event, err := job.Step.WaitForEvent(ctx, "email.verified", stackshift.WaitForEventOptions{
    CorrelationKey: "user:" + payload.UserID,
    Timeout: "24h",
    OnTimeout: "fail",
  })
  if err != nil { return nil, err }

  _, err = job.Step.Run(ctx, "unlock-account", func(context.Context, stackshift.HandlerInvocation) (any, error) {
    return nil, unlockAccount(event.Payload)
  })
  if err != nil { return nil, err }

  return map[string]any{"onboarded": true}, nil
})