Publishing from a transaction

await store.tx(async tx => {
	await tx.with(orders).set(id, order)
	await tx.with(events).under(id).publish({ kind: 'created' })
})

async def create(tx: tinystore.Tx) -> None:
    await tx.with_(orders).set(id, order)
    await tx.with_(events).under(id).publish(Created(kind="created"))


await store.tx(create)

err = store.Tx(ctx, func(tx *tinystore.Tx) error {
	if err := orders.In(tx).Set(ctx, id, order); err != nil {
		return err
	}
	return events.In(tx).Under(id).Publish(ctx, Created{Kind: "created"})
})

store.tx(|tx| -> tinystore::Result<()> {
    tx.with(&orders).set(&id, &order)?;
    tx.with(&events).under(&id).publish(&Created { kind: "created".into() })?;
    Ok(())
})?;

await db.tx(async tx => {
	const reply = await tx.one<{ id: number }>`insert into messages (chat_id, text) values (${chatId}, ${text}) returning id`
	await tx.with(events).under(chatId).publish({ kind: 'message', id: reply!.id })
})

async def reply(tx: tinystore.SqlTx) -> None:
    row = await tx.one("insert into messages (chat_id, text) values (?, ?) returning id", chat_id, text)
    await tx.with_(events).under(chat_id).publish(ChatEvent(kind="message", id=row["id"]))


await db.tx(reply)

err = db.Tx(ctx, func(tx *sqldb.Tx) error {
	id, err := sqldb.Scalar[int64](ctx, tx, `insert into messages (chat_id, text) values (?, ?) returning id`, chatID, text)
	if err != nil {
		return err
	}
	return events.In(tx).Under(chatID).Publish(ctx, ChatEvent{Kind: "message", ID: id})
})

db.tx(|tx| -> tinystore::Result<()> {
    let id: i64 = tx.scalar(sql!("insert into messages (chat_id, text) values (?, ?) returning id", chat_id, text))?;
    tx.with(&events).under(chat_id).publish(&ChatEvent { kind: "message".into(), id })?;
    Ok(())
})?;