fn emitInOf

use std.orm { Db }

@table("orders")
data Order {
  @pk id: i64
  userId: u64
}

data OrderPlaced { id: i64 }

topic OrderEvents: OrderPlaced

cluster demo {
  role store { journal }
}

// inside atomic(db) the event goes to the outbox of the transaction and is published after the commit
fn place(db: Db, o: Order) db {
  atomic(db) {
    db.insert(o)
    emit OrderEvents(OrderPlaced{ id: o.id })
  }
}