-
Notifications
You must be signed in to change notification settings - Fork 3.7k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(server/v2): refactor the server/v2 events (#21785)
(cherry picked from commit 01212de) # Conflicts: # client/v2/go.mod # client/v2/go.sum # collections/collections.go # collections/go.mod # collections/go.sum # collections/indexing.go # go.mod # go.sum # runtime/v2/go.mod # runtime/v2/go.sum # server/v2/cometbft/go.mod # server/v2/cometbft/go.sum # server/v2/go.mod # server/v2/go.sum # server/v2/stf/core_event_service.go # server/v2/stf/go.mod # server/v2/stf/go.sum # server/v2/stf/stf.go # server/v2/streaming/utils.go # simapp/go.mod # simapp/go.sum # simapp/v2/go.mod # simapp/v2/go.sum # tests/go.mod # tests/go.sum # x/accounts/defaults/base/go.mod # x/accounts/defaults/base/go.sum # x/accounts/defaults/lockup/go.mod # x/accounts/defaults/lockup/go.sum # x/accounts/defaults/multisig/go.mod # x/accounts/defaults/multisig/go.sum # x/accounts/go.mod # x/accounts/go.sum # x/authz/go.mod # x/authz/go.sum # x/bank/go.mod # x/bank/go.sum # x/circuit/go.mod # x/circuit/go.sum # x/consensus/go.mod # x/consensus/go.sum # x/distribution/go.mod # x/distribution/go.sum # x/epochs/go.mod # x/epochs/go.sum # x/evidence/go.mod # x/evidence/go.sum # x/feegrant/go.mod # x/feegrant/go.sum # x/gov/go.mod # x/gov/go.sum # x/group/go.mod # x/group/go.sum # x/mint/go.mod # x/mint/go.sum # x/nft/go.mod # x/nft/go.sum # x/params/go.mod # x/params/go.sum # x/protocolpool/go.mod # x/protocolpool/go.sum # x/slashing/go.mod # x/slashing/go.sum # x/staking/go.mod # x/staking/go.sum # x/upgrade/go.mod # x/upgrade/go.sum
- Loading branch information
1 parent
e42e270
commit 5797783
Showing
71 changed files
with
2,870 additions
and
66 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| package collections | ||
|
|
||
| import ( | ||
| "context" | ||
| "errors" | ||
| "io" | ||
| "math" | ||
|
|
||
| "cosmossdk.io/collections/codec" | ||
| "cosmossdk.io/schema" | ||
| ) | ||
|
|
||
| var ( | ||
| // ErrNotFound is returned when the provided key is not present in the StorageProvider. | ||
| ErrNotFound = errors.New("collections: not found") | ||
| // ErrEncoding is returned when something fails during key or value encoding/decoding. | ||
| ErrEncoding = codec.ErrEncoding | ||
| // ErrConflict is returned when there are conflicts, for example in UniqueIndex. | ||
| ErrConflict = errors.New("collections: conflict") | ||
| ) | ||
|
|
||
| // KEYS | ||
|
|
||
| var ( | ||
| // Uint16Key can be used to encode uint16 keys. Encoding is big endian to retain ordering. | ||
| Uint16Key = codec.NewUint16Key[uint16]() | ||
| // Uint32Key can be used to encode uint32 keys. Encoding is big endian to retain ordering. | ||
| Uint32Key = codec.NewUint32Key[uint32]() | ||
| // Uint64Key can be used to encode uint64 keys. Encoding is big endian to retain ordering. | ||
| Uint64Key = codec.NewUint64Key[uint64]() | ||
| // Int32Key can be used to encode int32 keys. Encoding retains ordering by toggling the MSB. | ||
| Int32Key = codec.NewInt32Key[int32]() | ||
| // Int64Key can be used to encode int64 keys. Encoding retains ordering by toggling the MSB. | ||
| Int64Key = codec.NewInt64Key[int64]() | ||
| // StringKey can be used to encode string keys. The encoding just converts the string | ||
| // to bytes. | ||
| // Non-terminality in multipart keys is handled by appending the StringDelimiter, | ||
| // this means that a string key when used as the non final part of a multipart key cannot | ||
| // contain the StringDelimiter. | ||
| // Lexicographical ordering is retained both in non and multipart keys. | ||
| StringKey = codec.NewStringKeyCodec[string]() | ||
| // BytesKey can be used to encode bytes keys. The encoding will just use | ||
| // the provided bytes. | ||
| // When used as the non-terminal part of a multipart key, we prefix the bytes key | ||
| // with a single byte representing the length of the key. This means two things: | ||
| // 1. When used in multipart keys the length can be at maximum 255 (max number that | ||
| // can be represented with a single byte). | ||
| // 2. When used in multipart keys the lexicographical ordering is lost due to the | ||
| // length prefixing. | ||
| // JSON encoding represents a bytes key as a hex encoded string. | ||
| BytesKey = codec.NewBytesKey[[]byte]() | ||
| // BoolKey can be used to encode booleans. It uses a single byte to represent the boolean. | ||
| // 0x0 is used to represent false, and 0x1 is used to represent true. | ||
| BoolKey = codec.NewBoolKey[bool]() | ||
| ) | ||
|
|
||
| // VALUES | ||
|
|
||
| var ( | ||
| // BoolValue implements a ValueCodec for bool. | ||
| BoolValue = codec.KeyToValueCodec(BoolKey) | ||
| // Uint16Value implements a ValueCodec for uint16. | ||
| Uint16Value = codec.KeyToValueCodec(Uint16Key) | ||
| // Uint32Value implements a ValueCodec for uint32. | ||
| Uint32Value = codec.KeyToValueCodec(Uint32Key) | ||
| // Uint64Value implements a ValueCodec for uint64. | ||
| Uint64Value = codec.KeyToValueCodec(Uint64Key) | ||
| // Int32Value implements a ValueCodec for int32. | ||
| Int32Value = codec.KeyToValueCodec(Int32Key) | ||
| // Int64Value implements a ValueCodec for int64. | ||
| Int64Value = codec.KeyToValueCodec(Int64Key) | ||
| // StringValue implements a ValueCodec for string. | ||
| StringValue = codec.KeyToValueCodec(StringKey) | ||
| // BytesValue implements a ValueCodec for bytes. | ||
| BytesValue = codec.KeyToValueCodec(BytesKey) | ||
| ) | ||
|
|
||
| // Collection is the interface that all collections implement. It will eventually | ||
| // include methods for importing/exporting genesis data and schema | ||
| // reflection for clients. | ||
| // NOTE: Unstable. | ||
| type Collection interface { | ||
| // GetName is the unique name of the collection within a schema. It must | ||
| // match format specified by NameRegex. | ||
| GetName() string | ||
|
|
||
| // GetPrefix is the unique prefix of the collection within a schema. | ||
| GetPrefix() []byte | ||
|
|
||
| // ValueCodec returns the codec used to encode/decode values of the collection. | ||
| ValueCodec() codec.UntypedValueCodec | ||
|
|
||
| genesisHandler | ||
|
|
||
| // collectionSchemaCodec returns the schema codec for this collection. | ||
| schemaCodec() (*collectionSchemaCodec, error) | ||
|
|
||
| // isSecondaryIndex indicates that this collection represents a secondary index | ||
| // in the schema and should be excluded from the module's user facing schema. | ||
| isSecondaryIndex() bool | ||
| } | ||
|
|
||
| // collectionSchemaCodec maps a collection to a schema object type and provides | ||
| // decoders and encoders to and from schema values and raw kv-store bytes. | ||
| type collectionSchemaCodec struct { | ||
| coll Collection | ||
| objectType schema.StateObjectType | ||
| keyDecoder func([]byte) (any, error) | ||
| valueDecoder func([]byte) (any, error) | ||
| } | ||
|
|
||
| // Prefix defines a segregation bytes namespace for specific collections objects. | ||
| type Prefix []byte | ||
|
|
||
| // Bytes returns the raw Prefix bytes. | ||
| func (n Prefix) Bytes() []byte { return n } | ||
|
|
||
| // NewPrefix returns a Prefix given the provided namespace identifier. | ||
| // In the same module, no prefixes should share the same starting bytes | ||
| // meaning that having two namespaces whose bytes representation is: | ||
| // p1 := []byte("prefix") | ||
| // p2 := []byte("prefix1") | ||
| // yields to iterations of p1 overlapping over p2. | ||
| // If a numeric prefix is provided, it must be between 0 and 255 (uint8). | ||
| // If out of bounds this function will panic. | ||
| // Reason for which this function is constrained to `int` instead of `uint8` is for | ||
| // API ergonomics, golang's type inference will infer int properly but not uint8 | ||
| // meaning that developers would need to write NewPrefix(uint8(number)) for numeric | ||
| // prefixes. | ||
| func NewPrefix[T interface{ int | string | []byte }](identifier T) Prefix { | ||
| i := any(identifier) | ||
| var prefix []byte | ||
| switch c := i.(type) { | ||
| case int: | ||
| if c > math.MaxUint8 || c < 0 { | ||
| panic("invalid integer prefix value: must be between 0 and 255") | ||
| } | ||
| prefix = []byte{uint8(c)} | ||
| case string: | ||
| prefix = []byte(c) | ||
| case []byte: | ||
| identifierCopy := make([]byte, len(c)) | ||
| copy(identifierCopy, c) | ||
| prefix = identifierCopy | ||
| } | ||
| return prefix | ||
| } | ||
|
|
||
| var _ Collection = (*collectionImpl[string, string])(nil) | ||
|
|
||
| // collectionImpl wraps a Map and implements Collection. This properly splits | ||
| // the generic and untyped Collection interface from the typed Map, which every | ||
| // collection builds on. | ||
| type collectionImpl[K, V any] struct { | ||
| m Map[K, V] | ||
| } | ||
|
|
||
| func (c collectionImpl[K, V]) ValueCodec() codec.UntypedValueCodec { | ||
| return codec.NewUntypedValueCodec(c.m.vc) | ||
| } | ||
|
|
||
| func (c collectionImpl[K, V]) GetName() string { return c.m.name } | ||
|
|
||
| func (c collectionImpl[K, V]) GetPrefix() []byte { return NewPrefix(c.m.prefix) } | ||
|
|
||
| func (c collectionImpl[K, V]) validateGenesis(r io.Reader) error { return c.m.validateGenesis(r) } | ||
|
|
||
| func (c collectionImpl[K, V]) importGenesis(ctx context.Context, r io.Reader) error { | ||
| return c.m.importGenesis(ctx, r) | ||
| } | ||
|
|
||
| func (c collectionImpl[K, V]) exportGenesis(ctx context.Context, w io.Writer) error { | ||
| return c.m.exportGenesis(ctx, w) | ||
| } | ||
|
|
||
| func (c collectionImpl[K, V]) defaultGenesis(w io.Writer) error { return c.m.defaultGenesis(w) } | ||
|
|
||
| func (c collectionImpl[K, V]) isSecondaryIndex() bool { return c.m.isSecondaryIndex } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| module cosmossdk.io/collections | ||
|
|
||
| go 1.23 | ||
|
|
||
| require ( | ||
| cosmossdk.io/core v1.0.0-alpha.3 | ||
| cosmossdk.io/core/testing v0.0.0-00010101000000-000000000000 | ||
| cosmossdk.io/schema v0.3.0 | ||
| github.com/stretchr/testify v1.9.0 | ||
| github.com/tidwall/btree v1.7.0 | ||
| pgregory.net/rapid v1.1.0 | ||
| ) | ||
|
|
||
| require ( | ||
| github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc // indirect | ||
| github.com/pmezard/go-difflib v1.0.0 // indirect | ||
| gopkg.in/yaml.v3 v3.0.1 // indirect | ||
| ) | ||
|
|
||
| replace cosmossdk.io/core/testing => ../core/testing |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,18 @@ | ||
| cosmossdk.io/core v1.0.0-alpha.3 h1:pnxaYAas7llXgVz1lM7X6De74nWrhNKnB3yMKe4OUUA= | ||
| cosmossdk.io/core v1.0.0-alpha.3/go.mod h1:3u9cWq1FAVtiiCrDPpo4LhR+9V6k/ycSG4/Y/tREWCY= | ||
| cosmossdk.io/schema v0.3.0 h1:01lcaM4trhzZ1HQTfTV8z6Ma1GziOZ/YmdzBN3F720c= | ||
| cosmossdk.io/schema v0.3.0/go.mod h1:RDAhxIeNB4bYqAlF4NBJwRrgtnciMcyyg0DOKnhNZQQ= | ||
| github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc h1:U9qPSI2PIWSS1VwoXQT9A3Wy9MM3WgvqSxFWenqJduM= | ||
| github.com/davecgh/go-spew v1.1.2-0.20180830191138-d8f796af33cc/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= | ||
| github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= | ||
| github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= | ||
| github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= | ||
| github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= | ||
| github.com/tidwall/btree v1.7.0 h1:L1fkJH/AuEh5zBnnBbmTwQ5Lt+bRJ5A8EWecslvo9iI= | ||
| github.com/tidwall/btree v1.7.0/go.mod h1:twD9XRA5jj9VUQGELzDO4HPQTNJsoWWfYEL+EUQ2cKY= | ||
| gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= | ||
| gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= | ||
| gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= | ||
| gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= | ||
| pgregory.net/rapid v1.1.0 h1:CMa0sjHSru3puNx+J0MIAuiiEV4N0qj8/cMWGBBCsjw= | ||
| pgregory.net/rapid v1.1.0/go.mod h1:PY5XlDGj0+V1FCq0o192FdRhpKHGTRIWBgqjDBTrq04= |
Oops, something went wrong.