From 0a46150bdc10f1ee42d3f7b9f3f919b052f40f3f Mon Sep 17 00:00:00 2001
From: "Xinwei Xiong (cubxxw)" <3293172751nss@gmail.com>
Date: Thu, 21 Mar 2024 12:31:15 +0800
Subject: [PATCH] feat: optimize openim code

---
 .golangci.yml                                        |  6 ------
 internal/api/route.go                                | 12 ++++++++----
 pkg/common/config/config.go                          |  3 +++
 .../discoveryregister/kubernetes/kubernetes.go       |  1 +
 4 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/.golangci.yml b/.golangci.yml
index 8c588aa57..ea839cc57 100644
--- a/.golangci.yml
+++ b/.golangci.yml
@@ -161,12 +161,6 @@ linters-settings:
     ignore-enum-members: ""
     # consider enums only in package scopes, not in inner scopes
     package-scope-only: false
-  exhaustivestruct:
-    struct-patterns:
-      - '*.Test'
-      - '*.Test2'
-      - '*.Embedded'
-      - '*.External'
 
   forbidigo:
   #   # Forbid the following identifiers (identifiers are written using regexp):
diff --git a/internal/api/route.go b/internal/api/route.go
index 28a9197c9..1140d619f 100644
--- a/internal/api/route.go
+++ b/internal/api/route.go
@@ -18,8 +18,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"github.com/go-playground/validator/v10"
-	"github.com/redis/go-redis/v9"
 	"net"
 	"net/http"
 	"os"
@@ -28,6 +26,9 @@ import (
 	"syscall"
 	"time"
 
+	"github.com/go-playground/validator/v10"
+	"github.com/redis/go-redis/v9"
+
 	"github.com/gin-gonic/gin"
 	"github.com/gin-gonic/gin/binding"
 	"github.com/openimsdk/open-im-server/v3/pkg/authverify"
@@ -52,11 +53,14 @@ import (
 
 func Start(ctx context.Context, config *config.GlobalConfig, port int, proPort int) error {
 	if port == 0 || proPort == 0 {
-		err := errors.New("port or proPort is empty")
-		wrappedErr := errs.WrapMsg(err, "validation error", "port", port, "proPort", proPort)
+		wrappedErr := errs.WrapMsg(errors.New("port or proPort is empty"), "validation error", "port", port, "proPort", proPort)
 		return wrappedErr
 	}
 
+	// redisConfig := &config.Redis{
+
+    // }
+
 	rdb, err := cache.NewRedis(ctx, &config.Redis)
 	if err != nil {
 		return err
diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go
index 1a5fa3eba..33ff554e8 100644
--- a/pkg/common/config/config.go
+++ b/pkg/common/config/config.go
@@ -63,6 +63,7 @@ type Zookeeper struct {
 	Username string   `yaml:"username"`
 	Password string   `yaml:"password"`
 }
+
 type Mongo struct {
 	Uri         string   `yaml:"uri"`
 	Address     []string `yaml:"address"`
@@ -71,6 +72,7 @@ type Mongo struct {
 	Password    string   `yaml:"password"`
 	MaxPoolSize int      `yaml:"maxPoolSize"`
 }
+
 type Redis struct {
 	ClusterMode    bool     `yaml:"clusterMode"`
 	Address        []string `yaml:"address"`
@@ -78,6 +80,7 @@ type Redis struct {
 	Password       string   `yaml:"password"`
 	EnablePipeline bool     `yaml:"enablePipeline"`
 }
+
 type Kafka struct {
 	Username     string   `yaml:"username"`
 	Password     string   `yaml:"password"`
diff --git a/pkg/common/discoveryregister/kubernetes/kubernetes.go b/pkg/common/discoveryregister/kubernetes/kubernetes.go
index 29a498b0b..b789bc48e 100644
--- a/pkg/common/discoveryregister/kubernetes/kubernetes.go
+++ b/pkg/common/discoveryregister/kubernetes/kubernetes.go
@@ -74,6 +74,7 @@ func (cli *K8sDR) GetConfFromRegistry(key string) ([]byte, error) {
 
 	return nil, nil
 }
+
 func (cli *K8sDR) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error) {
 	host, err := cli.gatewayHostConsistent.Get(userId)
 	if err != nil {