Langlaufende Prozesse, die
wirklich fertig werden.

// onboarding.workflow.tsx — DESCRIPTOR (browser-safe)
import { workflow } from '@voltro/workflow/define'
import { Schema } from 'effect'

export const Onboarding = workflow({
  name:    'user.onboarding',
  payload: { userId: Schema.String },
  success: Schema.Struct({ ok: Schema.Boolean }),
})

// onboarding.workflow.server.tsx — EXECUTOR (server-only)
import { step, sleep } from '@voltro/workflow'
import { Effect, Schema } from 'effect'
import { generateText } from '@voltro/ai'
import type { AppContext } from '@voltro/runtime'

export default (ctx: AppContext) => ({ userId }) =>
  Effect.gen(function* () {
    const user = yield* step({
      name:    'load-user',
      success: Schema.Struct({ email: Schema.String, firstName: Schema.String }),
      execute: Effect.tryPromise(() =>
        ctx.store.select('users').where('id', userId).one()),
    })

    yield* step({
      name:    'send-welcome',
      execute: Effect.tryPromise(() =>
        ctx.store.insert('outbox', { to: user.email, template: 'welcome' })),
    })

    // Crash here? Resume replays from the journal —
    // the welcome won't be re-sent. Durable, not Effect.sleep.
    yield* sleep({ name: 'nudge-delay', duration: '1 day' })

    const nudge = yield* generateText({
      prompt: `Write a 1-sentence nudge for ${user.firstName}.`,
    })
    yield* step({
      name:    'send-nudge',
      execute: Effect.tryPromise(() =>
        ctx.store.insert('outbox', { to: user.email, body: nudge.text })),
    })

    return { ok: true }
  })