feat(collections): add NewJSONValueCodec
#19861
There are no files selected for viewing
| Original file line number | Diff line number | Diff line change | ||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| @@ -0,0 +1,58 @@ | ||||||||||||||||||||
| package collections | ||||||||||||||||||||
|
|
||||||||||||||||||||
| import ( | ||||||||||||||||||||
| "encoding/json" | ||||||||||||||||||||
| "fmt" | ||||||||||||||||||||
|
|
||||||||||||||||||||
| "cosmossdk.io/collections/codec" | ||||||||||||||||||||
| ) | ||||||||||||||||||||
|
|
||||||||||||||||||||
| func NewJSONValueCodec[T any]() codec.ValueCodec[T] { | ||||||||||||||||||||
| return jsonValue[T]{ | ||||||||||||||||||||
| typeName: fmt.Sprintf("%T", new(T)), | ||||||||||||||||||||
| } | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| type jsonValue[T any] struct { | ||||||||||||||||||||
| typeName string | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| // Decode implements codec.ValueCodec. | ||||||||||||||||||||
| func (jsonValue[T]) Decode(b []byte) (T, error) { | ||||||||||||||||||||
| var t T | ||||||||||||||||||||
| if err := json.Unmarshal(b, &t); err != nil { | ||||||||||||||||||||
| return t, err | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| return t, nil | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| // DecodeJSON implements codec.ValueCodec. | ||||||||||||||||||||
| func (jsonValue[T]) DecodeJSON(b []byte) (T, error) { | ||||||||||||||||||||
| var t T | ||||||||||||||||||||
| if err := json.Unmarshal(b, &t); err != nil { | ||||||||||||||||||||
| return t, err | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| return t, nil | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
Comment on lines
+30
to
+38
There was a problem hiding this comment. The - // DecodeJSON implements codec.ValueCodec.
- func (jsonValue[T]) DecodeJSON(b []byte) (T, error) {
- var t T
- if err := json.Unmarshal(b, &t); err != nil {
- return t, err
- }
-
- return t, nil
- }Committable suggestion
Suggested change
|
||||||||||||||||||||
|
|
||||||||||||||||||||
| // Encode implements codec.ValueCodec. | ||||||||||||||||||||
| func (jsonValue[T]) Encode(value T) ([]byte, error) { | ||||||||||||||||||||
| return json.Marshal(value) | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| // EncodeJSON implements codec.ValueCodec. | ||||||||||||||||||||
| func (jsonValue[T]) EncodeJSON(value T) ([]byte, error) { | ||||||||||||||||||||
| return json.Marshal(value) | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
Comment on lines
+45
to
+48
There was a problem hiding this comment. The - // EncodeJSON implements codec.ValueCodec.
- func (jsonValue[T]) EncodeJSON(value T) ([]byte, error) {
- return json.Marshal(value)
- }Committable suggestion
Suggested change
|
||||||||||||||||||||
|
|
||||||||||||||||||||
| // Stringify implements codec.ValueCodec. | ||||||||||||||||||||
| func (jsonValue[T]) Stringify(value T) string { | ||||||||||||||||||||
| return fmt.Sprintf("%v", value) | ||||||||||||||||||||
| } | ||||||||||||||||||||
|
|
||||||||||||||||||||
| // ValueType implements codec.ValueCodec. | ||||||||||||||||||||
| func (jv jsonValue[T]) ValueType() string { | ||||||||||||||||||||
| return fmt.Sprintf("json(%s)", jv.typeName) | ||||||||||||||||||||
| } | ||||||||||||||||||||
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ensure consistency in spacing after the PR links in the changelog entries.
Committable suggestion