Bump google.golang.org/grpc from 1.52.3 to 1.53.0

Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.52.3 to 1.53.0.
- [Release notes](https://github.com/grpc/grpc-go/releases)
- [Commits](https://github.com/grpc/grpc-go/compare/v1.52.3...v1.53.0)

---
updated-dependencies:
- dependency-name: google.golang.org/grpc
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

generate.go

@@ -1,3 +1,3 @@
 package service
 
-//go:generate protoc -I./proto -I. --go-grpc_out=paths=source_relative:./proto --go_out=paths=source_relative:./proto --go-micro_out=components=micro|grpc,standalone=true,debug=true,paths=source_relative:./micro proto/service.proto
+//go:generate protoc -I./proto -I. --go-grpc_out=paths=source_relative:./proto --go_out=paths=source_relative:./proto --go-micro_out=components=micro|rpc,standalone=true,debug=true,paths=source_relative:./micro proto/service.proto

go.mod

@@ -1,19 +1,10 @@
 module go.unistack.org/micro-config-service/v3
 
-go 1.18
+go 1.16
 
 require (
 	github.com/imdario/mergo v0.3.13
-	go.unistack.org/micro-server-http/v3 v3.10.13
-	go.unistack.org/micro/v3 v3.10.16
-	google.golang.org/grpc v1.52.3
+	go.unistack.org/micro/v3 v3.10.11
+	google.golang.org/grpc v1.53.0
 	google.golang.org/protobuf v1.28.1
 )
-
-require (
-	github.com/golang/protobuf v1.5.2 // indirect
-	golang.org/x/net v0.7.0 // indirect
-	golang.org/x/sys v0.5.0 // indirect
-	golang.org/x/text v0.7.0 // indirect
-	google.golang.org/genproto v0.0.0-20221118155620-16455021b5e6 // indirect
-)

micro/service_micro.pb.go

@@ -1,7 +1,5 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// versions:
-// - protoc-gen-go-micro v3.10.2
-// - protoc              v3.21.12
+// protoc-gen-go-micro version: v3.5.3
 // source: service.proto
 
 package servicepb
@@ -9,16 +7,19 @@ package servicepb
 import (
 	context "context"
 	proto "go.unistack.org/micro-config-service/v3/proto"
-	v3 "go.unistack.org/micro-server-http/v3"
+	api "go.unistack.org/micro/v3/api"
 	client "go.unistack.org/micro/v3/client"
 )
 
 var (
 	ConfigName = "Config"
+
+	ConfigEndpoints = []api.Endpoint{}
 )
-var (
-	ConfigServerEndpoints = []v3.EndpointMetadata{}
-)
+
+func NewConfigEndpoints() []api.Endpoint {
+	return ConfigEndpoints
+}
 
 type ConfigClient interface {
 	Load(ctx context.Context, req *proto.LoadRequest, opts ...client.CallOption) (*proto.LoadResponse, error)

micro/service_micro_rpc.pb.go

@@ -1,5 +1,5 @@
 // Code generated by protoc-gen-go-micro. DO NOT EDIT.
-// protoc-gen-go-micro version: v3.10.2
+// protoc-gen-go-micro version: v3.5.3
 // source: service.proto
 
 package servicepb
@@ -7,6 +7,7 @@ package servicepb
 import (
 	context "context"
 	proto "go.unistack.org/micro-config-service/v3/proto"
+	api "go.unistack.org/micro/v3/api"
 	client "go.unistack.org/micro/v3/client"
 	server "go.unistack.org/micro/v3/server"
 )
@@ -60,5 +61,8 @@ func RegisterConfigServer(s server.Server, sh ConfigServer, opts ...server.Handl
 	}
 	h := &configServer{sh}
 	var nopts []server.HandlerOption
+	for _, endpoint := range ConfigEndpoints {
+		nopts = append(nopts, api.WithEndpoint(&endpoint))
+	}
 	return s.Handle(s.NewHandler(&Config{h}, append(nopts, opts...)...))
 }

proto/service.pb.go

@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.26.0
-// 	protoc        v3.21.12
+// 	protoc        v3.17.3
 // source: service.proto
 
 package servicepb

proto/service_grpc.pb.go

@@ -1,8 +1,4 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
-// versions:
-// - protoc-gen-go-grpc v1.3.0
-// - protoc             v3.21.12
-// source: service.proto
 
 package servicepb
 
@@ -18,11 +14,6 @@ import (
 // Requires gRPC-Go v1.32.0 or later.
 const _ = grpc.SupportPackageIsVersion7
 
-const (
-	Config_Load_FullMethodName = "/service.Config/Load"
-	Config_Save_FullMethodName = "/service.Config/Save"
-)
-
 // ConfigClient is the client API for Config service.
 //
 // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
@@ -41,7 +32,7 @@ func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient {
 
 func (c *configClient) Load(ctx context.Context, in *LoadRequest, opts ...grpc.CallOption) (*LoadResponse, error) {
 	out := new(LoadResponse)
-	err := c.cc.Invoke(ctx, Config_Load_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, "/service.Config/Load", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -50,7 +41,7 @@ func (c *configClient) Load(ctx context.Context, in *LoadRequest, opts ...grpc.C
 
 func (c *configClient) Save(ctx context.Context, in *SaveRequest, opts ...grpc.CallOption) (*SaveResponse, error) {
 	out := new(SaveResponse)
-	err := c.cc.Invoke(ctx, Config_Save_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, "/service.Config/Save", in, out, opts...)
 	if err != nil {
 		return nil, err
 	}
@@ -99,7 +90,7 @@ func _Config_Load_Handler(srv interface{}, ctx context.Context, dec func(interfa
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: Config_Load_FullMethodName,
+		FullMethod: "/service.Config/Load",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ConfigServer).Load(ctx, req.(*LoadRequest))
@@ -117,7 +108,7 @@ func _Config_Save_Handler(srv interface{}, ctx context.Context, dec func(interfa
 	}
 	info := &grpc.UnaryServerInfo{
 		Server:     srv,
-		FullMethod: Config_Save_FullMethodName,
+		FullMethod: "/service.Config/Save",
 	}
 	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
 		return srv.(ConfigServer).Save(ctx, req.(*SaveRequest))

service.go

@@ -27,10 +27,6 @@ func (c *serviceConfig) Options() config.Options {
 }
 
 func (c *serviceConfig) Init(opts ...config.Option) error {
-	if err := config.DefaultBeforeInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
-		return err
-	}
-
 	for _, o := range opts {
 		o(&c.opts)
 	}
@@ -47,55 +43,39 @@ func (c *serviceConfig) Init(opts ...config.Option) error {
 
 	if cli == nil {
 		err := fmt.Errorf("missing client option")
+		c.opts.Logger.Error(c.opts.Context, err)
 		if !c.opts.AllowFail {
 			return err
 		}
-
-		if err := config.DefaultAfterInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
-			return err
-		}
-
 		return nil
 	}
 
 	if c.service == "" {
 		err := fmt.Errorf("missing Service option")
+		c.opts.Logger.Error(c.opts.Context, err)
 		if !c.opts.AllowFail {
 			return err
 		}
-
-		if err := config.DefaultAfterInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
-			return err
-		}
-
 		return nil
 	}
 
 	c.client = pbmicro.NewConfigClient(c.service, cli)
 
-	if err := config.DefaultAfterInit(c.opts.Context, c); err != nil && !c.opts.AllowFail {
-		return err
-	}
-
 	return nil
 }
 
 func (c *serviceConfig) Load(ctx context.Context, opts ...config.LoadOption) error {
-	if err := config.DefaultBeforeLoad(ctx, c); err != nil && !c.opts.AllowFail {
+	if err := config.DefaultBeforeLoad(ctx, c); err != nil {
 		return err
 	}
 
 	rsp, err := c.client.Load(ctx, &pb.LoadRequest{Service: c.service})
 	if err != nil {
+		c.opts.Logger.Errorf(ctx, "service load error: %v", err)
 		if !c.opts.AllowFail {
 			return fmt.Errorf("failed to load config: %w", err)
 		}
-
-		if err = config.DefaultAfterLoad(ctx, c); err != nil && !c.opts.AllowFail {
-			return err
-		}
-
-		return nil
+		return config.DefaultAfterLoad(ctx, c)
 	}
 
 	options := config.NewLoadOptions(opts...)
@@ -107,24 +87,22 @@ func (c *serviceConfig) Load(ctx context.Context, opts ...config.LoadOption) err
 		mopts = append(mopts, mergo.WithAppendSlice)
 	}
 
-	dst := c.opts.Struct
-	if options.Struct != nil {
-		dst = options.Struct
-	}
-
-	src, err := rutil.Zero(dst)
+	src, err := rutil.Zero(c.opts.Struct)
 	if err == nil {
 		err = c.opts.Codec.Unmarshal(rsp.Config, src)
 		if err == nil {
-			err = mergo.Merge(dst, src, mopts...)
+			err = mergo.Merge(c.opts.Struct, src, mopts...)
 		}
 	}
 
-	if err != nil && !c.opts.AllowFail {
-		return fmt.Errorf("failed to load config: %w", err)
+	if err != nil {
+		c.opts.Logger.Errorf(ctx, "service load error: %v", err)
+		if !c.opts.AllowFail {
+			return fmt.Errorf("failed to load config: %w", err)
+		}
 	}
 
-	if err := config.DefaultAfterLoad(ctx, c); err != nil && !c.opts.AllowFail {
+	if err := config.DefaultAfterLoad(ctx, c); err != nil {
 		return err
 	}
 
@@ -132,26 +110,22 @@ func (c *serviceConfig) Load(ctx context.Context, opts ...config.LoadOption) err
 }
 
 func (c *serviceConfig) Save(ctx context.Context, opts ...config.SaveOption) error {
-	if err := config.DefaultBeforeSave(ctx, c); err != nil && !c.opts.AllowFail {
+	if err := config.DefaultBeforeSave(ctx, c); err != nil {
 		return err
 	}
 
-	options := config.NewSaveOptions(opts...)
-
-	dst := c.opts.Struct
-	if options.Struct != nil {
-		dst = options.Struct
-	}
-
-	buf, err := c.opts.Codec.Marshal(dst)
+	buf, err := c.opts.Codec.Marshal(c.opts.Struct)
 	if err == nil {
 		_, err = c.client.Save(ctx, &pb.SaveRequest{Service: c.service, Config: buf})
 	}
-	if err != nil && !c.opts.AllowFail {
-		return fmt.Errorf("failed to save config: %w", err)
+	if err != nil {
+		c.opts.Logger.Errorf(ctx, "service save error: %v", err)
+		if !c.opts.AllowFail {
+			return fmt.Errorf("failed to save config: %w", err)
+		}
 	}
 
-	if err := config.DefaultAfterSave(ctx, c); err != nil && !c.opts.AllowFail {
+	if err := config.DefaultAfterSave(ctx, c); err != nil {
 		return err
 	}