Add types for transactions certified through consensus

crates/sui-types/src/executable_transaction.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 
 use crate::messages_checkpoint::CheckpointSequenceNumber;
+use crate::messages_consensus::{AuthorityIndex, Round, TransactionIndex};
 use crate::{committee::EpochId, crypto::AuthorityStrongQuorumSignInfo};
 
 use crate::message_envelope::{Envelope, TrustedEnvelope, VerifiedEnvelope};
@@ -23,6 +24,9 @@ pub enum CertificateProof {
     QuorumExecuted(EpochId),
     /// Transaction generated by the system, for example Clock update transaction
     SystemTransaction(EpochId),
+    /// Validity was proven through consensus. Round, authority and transaction index indicate
+    /// the position of the transaction in the consensus DAG for debugging.
+    Consensus(EpochId, Round, AuthorityIndex, TransactionIndex),
 }
 
 impl CertificateProof {
@@ -38,11 +42,21 @@ impl CertificateProof {
         Self::SystemTransaction(epoch)
     }
 
+    pub fn new_from_consensus(
+        epoch: EpochId,
+        round: Round,
+        authority: AuthorityIndex,
+        transaction_index: TransactionIndex,
+    ) -> Self {
+        Self::Consensus(epoch, round, authority, transaction_index)
+    }
+
     pub fn epoch(&self) -> EpochId {
         match self {
             Self::Checkpoint(epoch, _)
             | Self::QuorumExecuted(epoch)
-            | Self::SystemTransaction(epoch) => *epoch,
+            | Self::SystemTransaction(epoch)
+            | Self::Consensus(epoch, _, _, _) => *epoch,
             Self::Certified(sig) => sig.epoch,
         }
     }

crates/sui-types/src/message_envelope.rs

@@ -10,6 +10,7 @@ use crate::crypto::{
 use crate::error::SuiResult;
 use crate::executable_transaction::CertificateProof;
 use crate::messages_checkpoint::CheckpointSequenceNumber;
+use crate::messages_consensus::{AuthorityIndex, Round, TransactionIndex};
 use crate::transaction::SenderSignedData;
 use fastcrypto::traits::KeyPair;
 use once_cell::sync::OnceCell;
@@ -452,6 +453,31 @@ impl<T: Message> VerifiedEnvelope<T, CertificateProof> {
         })
     }
 
+    pub fn new_from_consensus(
+        transaction: VerifiedEnvelope<T, EmptySignInfo>,
+        epoch: EpochId,
+        round: Round,
+        authority: AuthorityIndex,
+        transaction_index: TransactionIndex,
+    ) -> Self {
+        let inner = transaction.into_inner();
+        let Envelope {
+            digest,
+            data,
+            auth_signature: _,
+        } = inner;
+        VerifiedEnvelope::new_unchecked(Envelope {
+            digest,
+            data,
+            auth_signature: CertificateProof::new_from_consensus(
+                epoch,
+                round,
+                authority,
+                transaction_index,
+            ),
+        })
+    }
+
     pub fn epoch(&self) -> EpochId {
         self.auth_signature.epoch()
     }

crates/sui-types/src/messages_consensus.rs

@@ -4,9 +4,7 @@
 use crate::base_types::{AuthorityName, ObjectRef, TransactionDigest};
 use crate::base_types::{ConciseableName, ObjectID, SequenceNumber};
 use crate::digests::ConsensusCommitDigest;
-use crate::messages_checkpoint::{
-    CheckpointSequenceNumber, CheckpointSignatureMessage, CheckpointTimestamp,
-};
+use crate::messages_checkpoint::{CheckpointSequenceNumber, CheckpointSignatureMessage};
 use crate::supported_protocol_versions::{
     Chain, SupportedProtocolVersions, SupportedProtocolVersionsWithHashes,
 };
@@ -24,16 +22,29 @@ use std::hash::{Hash, Hasher};
 use std::sync::Arc;
 use std::time::{SystemTime, UNIX_EPOCH};
 
+/// The index of an authority in the consensus committee.
+/// The value should be the same in Sui committee.
+pub type AuthorityIndex = u32;
+
+/// Consensus round number.
+pub type Round = u32;
+
+/// The index of a transaction in a consensus block.
+pub type TransactionIndex = u16;
+
+/// Consensus timestamp in ms.
+pub type ConsensusTimestampMs = u64;
+
 /// Only commit_timestamp_ms is passed to the move call currently.
 /// However we include epoch and round to make sure each ConsensusCommitPrologue has a unique tx digest.
 #[derive(Debug, PartialEq, Eq, Hash, Clone, Serialize, Deserialize)]
 pub struct ConsensusCommitPrologue {
     /// Epoch of the commit prologue transaction
     pub epoch: u64,
-    /// Consensus round of the commit
+    /// Consensus round of the commit. Using u64 for compatibility.
     pub round: u64,
     /// Unix timestamp from consensus
-    pub commit_timestamp_ms: CheckpointTimestamp,
+    pub commit_timestamp_ms: ConsensusTimestampMs,
 }
 
 #[derive(Debug, PartialEq, Eq, Hash, Clone, Serialize, Deserialize)]
@@ -43,7 +54,7 @@ pub struct ConsensusCommitPrologueV2 {
     /// Consensus round of the commit
     pub round: u64,
     /// Unix timestamp from consensus
-    pub commit_timestamp_ms: CheckpointTimestamp,
+    pub commit_timestamp_ms: ConsensusTimestampMs,
     /// Digest of consensus output
     pub consensus_commit_digest: ConsensusCommitDigest,
 }
@@ -65,7 +76,7 @@ pub struct ConsensusCommitPrologueV3 {
     /// are multiple consensus commits per round.
     pub sub_dag_index: Option<u64>,
     /// Unix timestamp from consensus
-    pub commit_timestamp_ms: CheckpointTimestamp,
+    pub commit_timestamp_ms: ConsensusTimestampMs,
     /// Digest of consensus output
     pub consensus_commit_digest: ConsensusCommitDigest,
     /// Stores consensus handler determined shared object version assignments.