Add executed_transaction_count to consensus spec

Author: matan-starkware

p2p/proto/consensus/consensus.md

@@ -46,6 +46,7 @@ The standard order for a Proposals (following the init):
 1. [ProposalInit][ProposalInitLink] - once
 1. [BlockInfo][BlockInfoLink] - once, required to execute the transactions.
 1. [TransactionBatch][TransactionBatchLink] - multiple
+1. [TransactionsFin][TransactionsFinLink] - once
 1. [ProposalCommitment][ProposalCommitmentLink] - once
 1. [ProposalFin][ProposalFinLink] - once
 
@@ -146,6 +147,7 @@ Field which identifies a stream of messages.
 [ProposalInitLink]: consensus.proto#L58
 [ProposalFinLink]: consensus.proto#L66
 [TransactionBatchLink]: consensus.proto#L70
-[StreamMessageLink]: consensus.proto#L76
-[ProposalCommitmentLink]: consensus.proto#L85
-[BlockInfoLink]: consensus.proto#L111
+[TransactionsFinLink]: consensus.proto#L82
+[StreamMessageLink]: consensus.proto#L94
+[ProposalCommitmentLink]: consensus.proto#L103
+[BlockInfoLink]: consensus.proto#L129

p2p/proto/consensus/consensus.proto

@@ -47,11 +47,12 @@ message ConsensusStreamId {
 // Messages which make up a Proposal stream.
 message ProposalPart {
     oneof messages {
-        ProposalInit       init         = 1;
-        ProposalFin        fin          = 2;
-        BlockInfo          block_info   = 3;
-        TransactionBatch   transactions = 4;
-        ProposalCommitment commitment   = 5;
+        ProposalInit       init            = 1;
+        ProposalFin        fin             = 2;
+        BlockInfo          block_info      = 3;
+        TransactionBatch   transactions    = 4;
+        TransactionsFin    transaction_fin = 5;
+        ProposalCommitment commitment      = 6;
     }
 }
 
@@ -71,6 +72,12 @@ message TransactionBatch {
     repeated ConsensusTransaction transactions = 1;
 }
 
+// Marks the completion of the transaction streaming.
+message TransactionsFin {
+    // Total number of transactions executed in the proposal.
+    uint64 executed_transaction_count = 1;
+}
+
 // The content and stream_id are generic fields. The user of the stream can choose to pass whatever
 // message that they want. The messages are then encoded in bytes.
 message StreamMessage {