fn emitInCondOf

use std.orm { Db }

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

data Placed {
  userId: str
  amount: i64
}

topic Events: Placed sharded by .userId

policy Events {
  allow publish if element.amount <= 100
}

cluster demo {
  role store { journal }
}

fn place(db: Db, o: Order) db {
  atomic(db) {
    db.insert(o)
    emit Events(Placed{ userId: o.userId, amount: 5 })
  }
}