fn next_reconciliation_block( last_observed_block: Option<i64>, latest_block: u64, max_lag_blocks: u64, ) -> Result<u64>