Capturing Workflows

const thread = await threadify.start('User-Onboarding-cust-123');

thread, err := conn.Start(ctx, "User-Onboarding-cust-123", "")
if err != nil {
    log.Fatal(err)
}

thread = await connection.start("User-Onboarding-cust-123")

const step = thread.step('order_received');

// Execute business logic
const order = await receiveOrder();

// Record success with context
await step.addContext({ orderId: order.id, total: order.total }).success();

step := thread.Step("order_received")

// Execute business logic
order, err := receiveOrder()
if err != nil {
    log.Fatal(err)
}

// Record success with context
_, err = step.AddContext(map[string]any{"orderId": order.ID, "total": order.Total}).Success(ctx)
if err != nil {
    log.Fatal(err)
}

step = thread.step("order_received")

# Execute business logic
order = await receive_order()

# Record success with context
await step.add_context({"orderId": order.id, "total": order.total}).success()