Method process_proposal

fendermint/app/src/app.rs:793–841

Inspect a proposal and decide whether to vote on it.

(
        &self,
        request: request::ProcessProposal,
    )

    /// Inspect a proposal and decide whether to vote on it.
    async fn process_proposal(
        &self,
        request: request::ProcessProposal,
    ) -> AbciResult<response::ProcessProposal> {
        tracing::debug!(
            height = request.height.value(),
            time = request.time.to_string(),
            "process proposal"
        );
        let txs: Vec<_> = request.txs.into_iter().map(|tx| tx.to_vec()).collect();
        let size_txs = txs.iter().map(|tx| tx.len()).sum::<usize>();
        let num_txs = txs.len();

        let state = self
            .read_only_view(Some(request.height.value()))?
            .ok_or_else(|| anyhow!("exec state should be present"))?;

        let process_decision = self
            .messages_interpreter
            .attest_block_messages(state, txs)
            .await
            .context("failed to process proposal")?;

        let accept = process_decision == AttestMessagesResponse::Accept;

        emit(BlockProposalReceived {
            height: request.height.value(),
            hash: HexEncodableBlockHash(request.hash.into()),
            size: size_txs,
            tx_count: num_txs,
            validator: &request.proposer_address,
        });

        emit(BlockProposalEvaluated {
            height: request.height.value(),
            hash: HexEncodableBlockHash(request.hash.into()),
            size: size_txs,
            tx_count: num_txs,
            validator: &request.proposer_address,
            accept,
            reason: None,
        });

        if accept {
            Ok(response::ProcessProposal::Accept)
        } else {
            Ok(response::ProcessProposal::Reject)
        }
    }

    /// Execute and finalize an entire block (ABCI 2.0).
    async fn finalize_block(