+ * This list MAY contain as little as one item, as much as an entire
+ * block, or any amount between those extremes.
+ * This list MUST NOT contain more than one block.
*/
- com.hedera.hapi.block.stream.BlockItem block_item = 1;
+ repeated com.hedera.hapi.block.stream.BlockItem block_items = 1;
}
/**
@@ -143,24 +121,24 @@ message PublishStreamResponse {
}
/**
- * Acknowledgement for a single `BlockItem`.
+ * Acknowledgement for a single repeated `BlockItem`.
* Most nodes are expected to implement this acknowledgement only for
* debugging and development purposes.
*
* If a node implements single item acknowledgement, the block node SHALL
- * send one `ItemAcknowledgement` for each `BlockItem` received
+ * send one `ItemAcknowledgement` for each repeated `BlockItem` received
* and verified.
*/
message ItemAcknowledgement {
/**
- * A SHA2-384 hash of the `BlockItem` received.
+ * A SHA2-384 hash of the `BlockItem`s received.
*
* This field is REQUIRED.
* A source system MUST verify that this value matches its own internal
* calculated hash value, and MUST end the stream if the values do not
* match.
*/
- bytes item_hash = 1;
+ bytes items_hash = 1;
}
/**
@@ -539,15 +517,41 @@ message SubscribeStreamResponse {
SubscribeStreamResponseCode status = 1;
/**
- * A stream response item containing a single `BlockItem`.
+ * A stream response item containing one or more `BlockItem`s.
*
- * The full response SHALL consist of many `block_item` messages
+ * The full response SHALL consist of many `block_items` messages
* followed by a single `status` message.
*/
- com.hedera.hapi.block.stream.BlockItem block_item = 2;
+ SubscribeStreamResponseSet block_items = 2;
}
}
+/**
+ * A wrapper message to permit repeated block items in a response.
+ * This message is required so that we can return ordered lists of block
+ * items to a subscriber.
+ *
+ * Each `SubscribeStreamResponseSet` MUST contain at least one `BlockItem`,
+ * and MAY contain up to one full block.
+ * A single `SubscribeStreamResponseSet` SHALL NOT contain block items from
+ * more than one block.
+ * If a `BlockHeader` is present in a `SubscribeStreamResponseSet`, that item
+ * MUST be the first item in the list.
+ * If a `BlockProof` is present in a `SubscribeStreamResponseSet`, that item
+ * MUST be the last item in the list.
+ */
+message SubscribeStreamResponseSet {
+ /**
+ * An ordered list of `BlockItem`s.
+ * This list supports sending block items to subscribers in batches
+ * for greater channel efficiency.
+ *
+ * The full response SHALL consist of many of these collections + * followed by a single `status` message. + */ + repeated com.hedera.hapi.block.stream.BlockItem block_items = 1; +} + /** * An enumeration indicating the status of this request. * @@ -790,9 +794,9 @@ message BlockNodeVersions { } /** - * Remote procedure calls (RPCs) for the Block Node. + * Remote procedure calls (RPCs) for the Block Node ancillary services. */ -service BlockStreamService { +service BlockNodeService { /** * Read the status of this block node server. *
@@ -800,14 +804,25 @@ service BlockStreamService { * data or a state snapshot. */ rpc serverStatus(ServerStatusRequest) returns (ServerStatusResponse); +} +/** + * Remote procedure calls (RPCs) for the Block Node block services. + */ +service BlockAccessService { /** * Read a single block from the block node. *
* The request SHALL describe the block number of the block to retrieve. */ rpc singleBlock(SingleBlockRequest) returns (SingleBlockResponse); +} +/** + * Remote procedure calls (RPCs) for the Block Node state snapshot + * and query services. + */ +service StateService { /** * Read a state snapshot from the block node. *
@@ -818,6 +833,12 @@ service BlockStreamService { */ rpc stateSnapshot(StateSnapshotRequest) returns (StateSnapshotResponse); +} + +/** + * Remote procedure calls (RPCs) for the Block Node stream services. + */ +service BlockStreamService { /** * Publish a stream of blocks. *
diff --git a/block/stream/output/smart_contract_service.proto b/block/stream/output/smart_contract_service.proto index 81062c26..b8d4ebd9 100644 --- a/block/stream/output/smart_contract_service.proto +++ b/block/stream/output/smart_contract_service.proto @@ -50,6 +50,16 @@ import "sidecar_file.proto"; * the original transaction. */ message CallContractOutput { + /** + * A list of additional outputs. + *
+ * This field MAY record one or more additional outputs and smart
+ * contract state changes produced during the ethereum call
+ * transaction handling.
+ * This field SHALL NOT be set if the transaction handling did not
+ * produce additional outputs.
+ * This field is not settled and MAY be removed or modified.
+ */
repeated proto.TransactionSidecarRecord sidecars = 1;
/**
@@ -68,6 +78,16 @@ message CallContractOutput {
* the original transaction.
*/
message CreateContractOutput {
+ /**
+ * A list of additional outputs.
+ *
+ * This field MAY record one or more additional outputs and smart
+ * contract state changes produced during the ethereum call
+ * transaction handling.
+ * This field SHALL NOT be set if the transaction handling did not
+ * produce additional outputs.
+ * This field is not settled and MAY be removed or modified.
+ */
repeated proto.TransactionSidecarRecord sidecars = 1;
/**