Function convert_event_response

src/response.rs:283–304

(resp: hypersync_client::EventResponse)

}

pub fn convert_event_response(resp: hypersync_client::EventResponse) -> Result<EventResponse> {
    let data = resp
        .data
        .into_iter()
        .map(|event| Event {
            transaction: event.transaction.map(|v| Transaction::from(&*v)),
            block: event.block.map(|v| Block::from(&*v)),
            log: Log::from(&event.log),
        })
        .collect();

    Ok(EventResponse {
        archive_height: resp.archive_height.map(|v| v.try_into().unwrap()),
        next_block: resp.next_block.try_into().unwrap(),
        total_execution_time: resp.total_execution_time.try_into().unwrap(),
        data,
        rollback_guard: resp
            .rollback_guard
            .map(|rg| RollbackGuard::try_convert(rg).context("convert rollback guard"))
            .transpose()?,
    })
}