Function append

crates/database/src/events.rs:73–90

(
    ex: &mut PgTransaction<'_>,
    events: &[(EventIndex, Event)],
)

#[instrument(skip_all)]
pub async fn append(
    ex: &mut PgTransaction<'_>,
    events: &[(EventIndex, Event)],
) -> Result<(), sqlx::Error> {
    // TODO: there might be a more efficient way to do this like execute_many or
    // COPY but my tests show that even if we sleep during the transaction it
    // does not block other connections from using the database, so it's not
    // high priority.
    for (index, event) in events {
        match event {
            Event::Trade(event) => insert_trade(ex, index, event).await?,
            Event::Invalidation(event) => insert_invalidation(ex, index, event).await?,
            Event::Settlement(event) => insert_settlement(ex, index, event).await?,
            Event::PreSignature(event) => insert_presignature(ex, index, event).await?,
        };
    }
    Ok(())
}

#[instrument(skip_all)]
async fn insert_invalidation(