abci: Refactor CheckTx to notify of recheck (#3744)
As per #2127, this refactors the RequestCheckTx ProtoBuf struct to allow for a flag indicating whether a query is a recheck or not (and allows for possible future, more nuanced states).
In order to pass this extended information through to the ABCI app, the proxy.AppConnMempool (and, for consistency, the proxy.AppConnConsensus) interface seems to need to be refactored along with abcicli.Client.
And, as per this comment, I've made the following modification to the protobuf definition for the RequestCheckTx structure:
enum CheckTxType {
New = 0;
Recheck = 1;
}
message RequestCheckTx {
bytes tx = 1;
CheckTxType type = 2;
}
* Refactor ABCI CheckTx to notify of recheck
As per #2127, this refactors the `RequestCheckTx` ProtoBuf struct to allow for:
1. a flag indicating whether a query is a recheck or not (and allows for
possible future, more nuanced states)
2. an `additional_data` bytes array to provide information for those more
nuanced states.
In order to pass this extended information through to the ABCI app, the
`proxy.AppConnMempool` (and, for consistency, the
`proxy.AppConnConsensus`) interface seems to need to be refactored.
Commits:
* Fix linting issue
* Add CHANGELOG_PENDING entry
* Remove extraneous explicit initialization
* Update ABCI spec doc to include new CheckTx params
* Rename method param for consistency
* Rename CheckTxType enum values and remove additional_data param
6 years ago abci: Refactor CheckTx to notify of recheck (#3744)
As per #2127, this refactors the RequestCheckTx ProtoBuf struct to allow for a flag indicating whether a query is a recheck or not (and allows for possible future, more nuanced states).
In order to pass this extended information through to the ABCI app, the proxy.AppConnMempool (and, for consistency, the proxy.AppConnConsensus) interface seems to need to be refactored along with abcicli.Client.
And, as per this comment, I've made the following modification to the protobuf definition for the RequestCheckTx structure:
enum CheckTxType {
New = 0;
Recheck = 1;
}
message RequestCheckTx {
bytes tx = 1;
CheckTxType type = 2;
}
* Refactor ABCI CheckTx to notify of recheck
As per #2127, this refactors the `RequestCheckTx` ProtoBuf struct to allow for:
1. a flag indicating whether a query is a recheck or not (and allows for
possible future, more nuanced states)
2. an `additional_data` bytes array to provide information for those more
nuanced states.
In order to pass this extended information through to the ABCI app, the
`proxy.AppConnMempool` (and, for consistency, the
`proxy.AppConnConsensus`) interface seems to need to be refactored.
Commits:
* Fix linting issue
* Add CHANGELOG_PENDING entry
* Remove extraneous explicit initialization
* Update ABCI spec doc to include new CheckTx params
* Rename method param for consistency
* Rename CheckTxType enum values and remove additional_data param
6 years ago abci: Refactor CheckTx to notify of recheck (#3744)
As per #2127, this refactors the RequestCheckTx ProtoBuf struct to allow for a flag indicating whether a query is a recheck or not (and allows for possible future, more nuanced states).
In order to pass this extended information through to the ABCI app, the proxy.AppConnMempool (and, for consistency, the proxy.AppConnConsensus) interface seems to need to be refactored along with abcicli.Client.
And, as per this comment, I've made the following modification to the protobuf definition for the RequestCheckTx structure:
enum CheckTxType {
New = 0;
Recheck = 1;
}
message RequestCheckTx {
bytes tx = 1;
CheckTxType type = 2;
}
* Refactor ABCI CheckTx to notify of recheck
As per #2127, this refactors the `RequestCheckTx` ProtoBuf struct to allow for:
1. a flag indicating whether a query is a recheck or not (and allows for
possible future, more nuanced states)
2. an `additional_data` bytes array to provide information for those more
nuanced states.
In order to pass this extended information through to the ABCI app, the
`proxy.AppConnMempool` (and, for consistency, the
`proxy.AppConnConsensus`) interface seems to need to be refactored.
Commits:
* Fix linting issue
* Add CHANGELOG_PENDING entry
* Remove extraneous explicit initialization
* Update ABCI spec doc to include new CheckTx params
* Rename method param for consistency
* Rename CheckTxType enum values and remove additional_data param
6 years ago |
|
- syntax = "proto3";
- package tendermint.abci.types;
- option go_package = "github.com/tendermint/tendermint/abci/types";
-
- // For more information on gogo.proto, see:
- // https://github.com/gogo/protobuf/blob/master/extensions.md
- import "proto/crypto/merkle/types.proto";
- import "proto/types/types.proto";
- import "proto/crypto/keys/types.proto";
- import "proto/types/params.proto";
- import "google/protobuf/timestamp.proto";
- import "third_party/proto/gogoproto/gogo.proto";
-
- // This file is copied from http://github.com/tendermint/abci
- // NOTE: When using custom types, mind the warnings.
- // https://github.com/gogo/protobuf/blob/master/custom_types.md#warnings-and-issues
-
- //----------------------------------------
- // Request types
-
- message Request {
- oneof value {
- RequestEcho echo = 2;
- RequestFlush flush = 3;
- RequestInfo info = 4;
- RequestSetOption set_option = 5;
- RequestInitChain init_chain = 6;
- RequestQuery query = 7;
- RequestBeginBlock begin_block = 8;
- RequestCheckTx check_tx = 9;
- RequestDeliverTx deliver_tx = 19;
- RequestEndBlock end_block = 11;
- RequestCommit commit = 12;
- RequestListSnapshots list_snapshots = 13;
- RequestOfferSnapshot offer_snapshot = 14;
- RequestLoadSnapshotChunk load_snapshot_chunk = 15;
- RequestApplySnapshotChunk apply_snapshot_chunk = 16;
- }
- }
-
- message RequestEcho {
- string message = 1;
- }
-
- message RequestFlush {}
-
- message RequestInfo {
- string version = 1;
- uint64 block_version = 2;
- uint64 p2p_version = 3;
- }
-
- // nondeterministic
- message RequestSetOption {
- string key = 1;
- string value = 2;
- }
-
- message RequestInitChain {
- google.protobuf.Timestamp time = 1
- [(gogoproto.nullable) = false, (gogoproto.stdtime) = true];
- string chain_id = 2;
- ConsensusParams consensus_params = 3;
- repeated ValidatorUpdate validators = 4 [(gogoproto.nullable) = false];
- bytes app_state_bytes = 5;
- }
-
- message RequestQuery {
- bytes data = 1;
- string path = 2;
- int64 height = 3;
- bool prove = 4;
- }
-
- message RequestBeginBlock {
- bytes hash = 1;
- tendermint.proto.types.Header header = 2 [(gogoproto.nullable) = false];
- LastCommitInfo last_commit_info = 3 [(gogoproto.nullable) = false];
- repeated Evidence byzantine_validators = 4 [(gogoproto.nullable) = false];
- }
-
- enum CheckTxType {
- New = 0;
- Recheck = 1;
- }
-
- message RequestCheckTx {
- bytes tx = 1;
- CheckTxType type = 2;
- }
-
- message RequestDeliverTx {
- bytes tx = 1;
- }
-
- message RequestEndBlock {
- int64 height = 1;
- }
-
- message RequestCommit {}
-
- // lists available snapshots
- message RequestListSnapshots {
- }
-
- // offers a snapshot to the application
- message RequestOfferSnapshot {
- Snapshot snapshot = 1; // snapshot offered by peers
- bytes app_hash = 2; // light client-verified app hash for snapshot height
- }
-
- // loads a snapshot chunk
- message RequestLoadSnapshotChunk {
- uint64 height = 1;
- uint32 format = 2;
- uint32 chunk = 3;
- }
-
- // Applies a snapshot chunk
- message RequestApplySnapshotChunk {
- uint32 index = 1;
- bytes chunk = 2;
- string sender = 3;
- }
-
- //----------------------------------------
- // Response types
-
- message Response {
- oneof value {
- ResponseException exception = 1;
- ResponseEcho echo = 2;
- ResponseFlush flush = 3;
- ResponseInfo info = 4;
- ResponseSetOption set_option = 5;
- ResponseInitChain init_chain = 6;
- ResponseQuery query = 7;
- ResponseBeginBlock begin_block = 8;
- ResponseCheckTx check_tx = 9;
- ResponseDeliverTx deliver_tx = 10;
- ResponseEndBlock end_block = 11;
- ResponseCommit commit = 12;
- ResponseListSnapshots list_snapshots = 13;
- ResponseOfferSnapshot offer_snapshot = 14;
- ResponseLoadSnapshotChunk load_snapshot_chunk = 15;
- ResponseApplySnapshotChunk apply_snapshot_chunk = 16;
- }
- }
-
- // nondeterministic
- message ResponseException {
- string error = 1;
- }
-
- message ResponseEcho {
- string message = 1;
- }
-
- message ResponseFlush {}
-
- message ResponseInfo {
- string data = 1;
-
- string version = 2;
- uint64 app_version = 3;
-
- int64 last_block_height = 4;
- bytes last_block_app_hash = 5;
- }
-
- // nondeterministic
- message ResponseSetOption {
- uint32 code = 1;
- // bytes data = 2;
- string log = 3;
- string info = 4;
- }
-
- message ResponseInitChain {
- ConsensusParams consensus_params = 1;
- repeated ValidatorUpdate validators = 2 [(gogoproto.nullable) = false];
- }
-
- message ResponseQuery {
- uint32 code = 1;
- // bytes data = 2; // use "value" instead.
- string log = 3; // nondeterministic
- string info = 4; // nondeterministic
- int64 index = 5;
- bytes key = 6;
- bytes value = 7;
- tendermint.proto.crypto.merkle.ProofOps proof_ops = 8;
- int64 height = 9;
- string codespace = 10;
- }
-
- message ResponseBeginBlock {
- repeated Event events = 1
- [(gogoproto.nullable) = false, (gogoproto.jsontag) = "events,omitempty"];
- }
-
- message ResponseCheckTx {
- uint32 code = 1;
- bytes data = 2;
- string log = 3; // nondeterministic
- string info = 4; // nondeterministic
- int64 gas_wanted = 5;
- int64 gas_used = 6;
- repeated Event events = 7
- [(gogoproto.nullable) = false, (gogoproto.jsontag) = "events,omitempty"];
- string codespace = 8;
- }
-
- message ResponseDeliverTx {
- uint32 code = 1;
- bytes data = 2;
- string log = 3; // nondeterministic
- string info = 4; // nondeterministic
- int64 gas_wanted = 5;
- int64 gas_used = 6;
- repeated Event events = 7
- [(gogoproto.nullable) = false, (gogoproto.jsontag) = "events,omitempty"];
- string codespace = 8;
- }
-
- message ResponseEndBlock {
- repeated ValidatorUpdate validator_updates = 1
- [(gogoproto.nullable) = false];
- ConsensusParams consensus_param_updates = 2;
- repeated Event events = 3
- [(gogoproto.nullable) = false, (gogoproto.jsontag) = "events,omitempty"];
- }
-
- message ResponseCommit {
- // reserve 1
- bytes data = 2;
- int64 retain_height = 3;
- }
-
- message ResponseListSnapshots {
- repeated Snapshot snapshots = 1;
- }
-
- message ResponseOfferSnapshot {
- Result result = 1;
-
- enum Result {
- ACCEPT = 0; // Snapshot accepted, apply chunks
- ABORT = 1; // Abort all snapshot restoration
- REJECT = 2; // Reject this specific snapshot, try others
- REJECT_FORMAT = 3; // Reject all snapshots of this format, try others
- REJECT_SENDER = 4; // Reject all snapshots from the sender(s), try others
- }
- }
-
- message ResponseLoadSnapshotChunk {
- bytes chunk = 1;
- }
-
- message ResponseApplySnapshotChunk {
- Result result = 1;
- repeated uint32 refetch_chunks = 2; // Chunks to refetch and reapply
- repeated string reject_senders = 3; // Chunk senders to reject and ban
-
- enum Result {
- ACCEPT = 0; // Chunk successfully accepted
- ABORT = 1; // Abort all snapshot restoration
- RETRY = 2; // Retry chunk (combine with refetch and reject)
- RETRY_SNAPSHOT = 3; // Retry snapshot (combine with refetch and reject)
- REJECT_SNAPSHOT = 4; // Reject this snapshot, try others
- }
- }
-
- //----------------------------------------
- // Misc.
-
- // ConsensusParams contains all consensus-relevant parameters
- // that can be adjusted by the abci app
- message ConsensusParams {
- BlockParams block = 1;
- tendermint.proto.types.EvidenceParams evidence = 2;
- tendermint.proto.types.ValidatorParams validator = 3;
- }
-
- // BlockParams contains limits on the block size.
- message BlockParams {
- // Note: must be greater than 0
- int64 max_bytes = 1;
- // Note: must be greater or equal to -1
- int64 max_gas = 2;
- }
-
- message LastCommitInfo {
- int32 round = 1;
- repeated VoteInfo votes = 2 [(gogoproto.nullable) = false];
- }
-
- // EventAttribute represents an event to the indexing service.
- message EventAttribute {
- bytes key = 1;
- bytes value = 2;
- bool index = 3;
- }
-
- message Event {
- string type = 1;
- repeated EventAttribute attributes = 2 [
- (gogoproto.nullable) = false,
- (gogoproto.jsontag) = "attributes,omitempty"
- ];
- }
-
- // TxResult contains results of executing the transaction.
- //
- // One usage is indexing transaction results.
- message TxResult {
- int64 height = 1;
- uint32 Index = 2;
- bytes tx = 3;
- ResponseDeliverTx result = 4 [(gogoproto.nullable) = false];
- }
-
- //----------------------------------------
- // Blockchain Types
-
- message BlockID {
- bytes hash = 1;
- PartSetHeader parts_header = 2 [(gogoproto.nullable) = false];
- }
-
- message PartSetHeader {
- int32 total = 1;
- bytes hash = 2;
- }
-
- // Validator
- message Validator {
- bytes address = 1;
- // PubKey pub_key = 2 [(gogoproto.nullable)=false];
- int64 power = 3;
- }
-
- // ValidatorUpdate
- message ValidatorUpdate {
- tendermint.proto.crypto.keys.PublicKey pub_key = 1 [(gogoproto.nullable) = false];
- int64 power = 2;
- }
-
- // VoteInfo
- message VoteInfo {
- Validator validator = 1 [(gogoproto.nullable) = false];
- bool signed_last_block = 2;
- }
-
- message Evidence {
- string type = 1;
- Validator validator = 2 [(gogoproto.nullable) = false];
- int64 height = 3;
- google.protobuf.Timestamp time = 4 [
- (gogoproto.nullable) = false,
- (gogoproto.stdtime) = true
- ];
- int64 total_voting_power = 5;
- }
-
- //----------------------------------------
- // State Sync Types
-
- message Snapshot {
- uint64 height = 1; // The height at which the snapshot was taken
- uint32 format = 2; // The application-specific snapshot format
- uint32 chunks = 3; // Number of chunks in the snapshot
- bytes hash = 4; // Arbitrary snapshot hash, equal only if identical
- bytes metadata = 5; // Arbitrary application metadata
- }
-
- //----------------------------------------
- // Service Definition
-
- service ABCIApplication {
- rpc Echo(RequestEcho) returns (ResponseEcho);
- rpc Flush(RequestFlush) returns (ResponseFlush);
- rpc Info(RequestInfo) returns (ResponseInfo);
- rpc SetOption(RequestSetOption) returns (ResponseSetOption);
- rpc DeliverTx(RequestDeliverTx) returns (ResponseDeliverTx);
- rpc CheckTx(RequestCheckTx) returns (ResponseCheckTx);
- rpc Query(RequestQuery) returns (ResponseQuery);
- rpc Commit(RequestCommit) returns (ResponseCommit);
- rpc InitChain(RequestInitChain) returns (ResponseInitChain);
- rpc BeginBlock(RequestBeginBlock) returns (ResponseBeginBlock);
- rpc EndBlock(RequestEndBlock) returns (ResponseEndBlock);
- rpc ListSnapshots(RequestListSnapshots) returns (ResponseListSnapshots);
- rpc OfferSnapshot(RequestOfferSnapshot) returns (ResponseOfferSnapshot);
- rpc LoadSnapshotChunk(RequestLoadSnapshotChunk) returns (ResponseLoadSnapshotChunk);
- rpc ApplySnapshotChunk(RequestApplySnapshotChunk) returns (ResponseApplySnapshotChunk);
- }
|