diff --git a/cmd/openim-api/main.go b/cmd/openim-api/main.go index b52784ea1..f6db87353 100644 --- a/cmd/openim-api/main.go +++ b/cmd/openim-api/main.go @@ -49,11 +49,13 @@ func run(port int) error { if port == 0 { err := "port is empty" log.ZError(context.Background(), err, nil) + return fmt.Errorf(err) } rdb, err := cache.NewRedis() if err != nil { log.ZError(context.Background(), "Failed to initialize Redis", err) + return err } log.ZInfo(context.Background(), "api start init discov client") @@ -64,15 +66,18 @@ func run(port int) error { client, err = discovery_register.NewDiscoveryRegister(config.Config.Envs.Discovery) if err != nil { log.ZError(context.Background(), "Failed to initialize discovery register", err) + return err } if err = client.CreateRpcRootNodes(config.Config.GetServiceNames()); err != nil { log.ZError(context.Background(), "Failed to create RPC root nodes", err) + return err } log.ZInfo(context.Background(), "api register public config to discov") if err = client.RegisterConf2Registry(constant.OpenIMCommonConfigKey, config.Config.EncodeConfig()); err != nil { log.ZError(context.Background(), "Failed to register public config to discov", err) + return err } log.ZInfo(context.Background(), "api register public config to discov success") @@ -89,6 +94,7 @@ func run(port int) error { err = router.Run(address) if err != nil { log.ZError(context.Background(), "api run failed", err, "address", address) + return err } diff --git a/pkg/common/cmd/root.go b/pkg/common/cmd/root.go index d43f9c078..f220ab7c1 100644 --- a/pkg/common/cmd/root.go +++ b/pkg/common/cmd/root.go @@ -97,6 +97,7 @@ func (rc *RootCmd) applyOptions(opts ...func(*CmdOpts)) *CmdOpts { func (rc *RootCmd) initializeLogger(cmdOpts *CmdOpts) error { logConfig := config.Config.Log + return log.InitFromConfig( cmdOpts.loggerPrefixName,