-
Notifications
You must be signed in to change notification settings - Fork 3.6k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
chore: bring in core v0.11.x (v0.50 compatible) to v0.50 (#21298)
- Loading branch information
1 parent
624fe4a
commit e37404d
Showing
16 changed files
with
151 additions
and
3,050 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,123 +1,18 @@ | ||
| package appconfig | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "strings" | ||
|
|
||
| "github.com/cosmos/cosmos-proto/anyutil" | ||
| "google.golang.org/protobuf/encoding/protojson" | ||
| "google.golang.org/protobuf/proto" | ||
| protoreflect "google.golang.org/protobuf/reflect/protoreflect" | ||
| "google.golang.org/protobuf/reflect/protoregistry" | ||
| "google.golang.org/protobuf/types/known/anypb" | ||
| "sigs.k8s.io/yaml" | ||
|
|
||
| appv1alpha1 "cosmossdk.io/api/cosmos/app/v1alpha1" | ||
| "cosmossdk.io/core/internal" | ||
| "cosmossdk.io/depinject" | ||
| depinjectappconfig "cosmossdk.io/depinject/appconfig" | ||
| ) | ||
|
|
||
| // LoadJSON loads an app config in JSON format. | ||
| func LoadJSON(bz []byte) depinject.Config { | ||
| config := &appv1alpha1.Config{} | ||
| err := protojson.Unmarshal(bz, config) | ||
| if err != nil { | ||
| return depinject.Error(err) | ||
| } | ||
|
|
||
| return Compose(config) | ||
| } | ||
| var LoadJSON = depinjectappconfig.LoadJSON | ||
|
|
||
| // LoadYAML loads an app config in YAML format. | ||
| func LoadYAML(bz []byte) depinject.Config { | ||
| j, err := yaml.YAMLToJSON(bz) | ||
| if err != nil { | ||
| return depinject.Error(err) | ||
| } | ||
|
|
||
| return LoadJSON(j) | ||
| } | ||
| var LoadYAML = depinjectappconfig.LoadYAML | ||
|
|
||
| // WrapAny marshals a proto message into a proto Any instance | ||
| func WrapAny(config protoreflect.ProtoMessage) *anypb.Any { | ||
| cfg, err := anyutil.New(config) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
|
|
||
| return cfg | ||
| } | ||
| var WrapAny = depinjectappconfig.WrapAny | ||
|
|
||
| // Compose composes a v1alpha1 app config into a container option by resolving | ||
| // the required modules and composing their options. | ||
| func Compose(appConfig *appv1alpha1.Config) depinject.Config { | ||
| opts := []depinject.Config{ | ||
| depinject.Supply(appConfig), | ||
| } | ||
|
|
||
| for _, module := range appConfig.Modules { | ||
| if module.Name == "" { | ||
| return depinject.Error(fmt.Errorf("module is missing name")) | ||
| } | ||
|
|
||
| if module.Config == nil { | ||
| return depinject.Error(fmt.Errorf("module %q is missing a config object", module.Name)) | ||
| } | ||
|
|
||
| msgType, err := protoregistry.GlobalTypes.FindMessageByURL(module.Config.TypeUrl) | ||
| if err != nil { | ||
| return depinject.Error(err) | ||
| } | ||
|
|
||
| modules, err := internal.ModulesByProtoMessageName() | ||
| if err != nil { | ||
| return depinject.Error(err) | ||
| } | ||
|
|
||
| init, ok := modules[msgType.Descriptor().FullName()] | ||
| if !ok { | ||
| modDesc := proto.GetExtension(msgType.Descriptor().Options(), appv1alpha1.E_Module).(*appv1alpha1.ModuleDescriptor) | ||
| if modDesc == nil { | ||
| return depinject.Error(fmt.Errorf("no module registered for type URL %s and that protobuf type does not have the option %s\n\n%s", | ||
| module.Config.TypeUrl, appv1alpha1.E_Module.TypeDescriptor().FullName(), dumpRegisteredModules(modules))) | ||
| } | ||
|
|
||
| return depinject.Error(fmt.Errorf("no module registered for type URL %s, did you forget to import %s: find more information on how to make a module ready for app wiring: https://docs.cosmos.network/main/building-modules/depinject\n\n%s", | ||
| module.Config.TypeUrl, modDesc.GoImport, dumpRegisteredModules(modules))) | ||
| } | ||
|
|
||
| config := init.ConfigProtoMessage.ProtoReflect().Type().New().Interface() | ||
| err = anypb.UnmarshalTo(module.Config, config, proto.UnmarshalOptions{}) | ||
| if err != nil { | ||
| return depinject.Error(err) | ||
| } | ||
|
|
||
| opts = append(opts, depinject.Supply(config)) | ||
|
|
||
| for _, provider := range init.Providers { | ||
| opts = append(opts, depinject.ProvideInModule(module.Name, provider)) | ||
| } | ||
|
|
||
| for _, invoker := range init.Invokers { | ||
| opts = append(opts, depinject.InvokeInModule(module.Name, invoker)) | ||
| } | ||
|
|
||
| for _, binding := range module.GolangBindings { | ||
| opts = append(opts, depinject.BindInterfaceInModule(module.Name, binding.InterfaceType, binding.Implementation)) | ||
| } | ||
| } | ||
|
|
||
| for _, binding := range appConfig.GolangBindings { | ||
| opts = append(opts, depinject.BindInterface(binding.InterfaceType, binding.Implementation)) | ||
| } | ||
|
|
||
| return depinject.Configs(opts...) | ||
| } | ||
|
|
||
| func dumpRegisteredModules(modules map[protoreflect.FullName]*internal.ModuleInitializer) string { | ||
| var mods []string | ||
| for name := range modules { | ||
| mods = append(mods, " "+string(name)) | ||
| } | ||
| return fmt.Sprintf("registered modules are:\n%s", strings.Join(mods, "\n")) | ||
| } | ||
| var Compose = depinjectappconfig.Compose |
This file was deleted.
Oops, something went wrong.
Oops, something went wrong.