mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-05-24 13:59:17 +08:00
tidy code
This commit is contained in:
parent
166ec71a28
commit
eb640157f2
@ -7,6 +7,7 @@ import (
|
|||||||
"Open_IM/pkg/grpc-etcdv3/getcdv3"
|
"Open_IM/pkg/grpc-etcdv3/getcdv3"
|
||||||
rpc "Open_IM/pkg/proto/auth"
|
rpc "Open_IM/pkg/proto/auth"
|
||||||
open_im_sdk "Open_IM/pkg/proto/sdk_ws"
|
open_im_sdk "Open_IM/pkg/proto/sdk_ws"
|
||||||
|
"Open_IM/pkg/utils"
|
||||||
"context"
|
"context"
|
||||||
"github.com/gin-gonic/gin"
|
"github.com/gin-gonic/gin"
|
||||||
"github.com/jinzhu/copier"
|
"github.com/jinzhu/copier"
|
||||||
@ -28,16 +29,15 @@ func UserRegister(c *gin.Context) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
req := &rpc.UserRegisterReq{UserInfo: &open_im_sdk.UserInfo{}}
|
req := &rpc.UserRegisterReq{UserInfo: &open_im_sdk.UserInfo{}}
|
||||||
//utils.CopyStructFields(*req.UserInfo, params)
|
utils.CopyStructFields(*req.UserInfo, params)
|
||||||
copier.Copy(req.UserInfo, ¶ms)
|
copier.Copy(req.UserInfo, ¶ms)
|
||||||
req.OperationID = params.OperationID
|
req.OperationID = params.OperationID
|
||||||
log.NewInfo(req.OperationID, "UserRegister args ", req.String())
|
log.NewInfo(req.OperationID, "UserRegister args ", req.String())
|
||||||
etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImAuthName)
|
etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImAuthName)
|
||||||
client := rpc.NewAuthClient(etcdConn)
|
client := rpc.NewAuthClient(etcdConn)
|
||||||
reply, err := client.UserRegister(context.Background(), req)
|
reply, err := client.UserRegister(context.Background(), req)
|
||||||
|
|
||||||
if err != nil || reply.CommonResp.ErrCode != 0 {
|
if err != nil || reply.CommonResp.ErrCode != 0 {
|
||||||
log.NewError("0", "UserRegister failed ", err, reply.CommonResp.ErrCode)
|
log.NewError(req.OperationID, "UserRegister failed ", err, reply.CommonResp.ErrCode)
|
||||||
c.JSON(http.StatusInternalServerError, gin.H{"errCode": 500, "errMsg": err.Error()})
|
c.JSON(http.StatusInternalServerError, gin.H{"errCode": 500, "errMsg": err.Error()})
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
@ -8,7 +8,7 @@ import (
|
|||||||
|
|
||||||
// copy a by b b->a
|
// copy a by b b->a
|
||||||
func CopyStructFields(a interface{}, b interface{}, fields ...string) (err error) {
|
func CopyStructFields(a interface{}, b interface{}, fields ...string) (err error) {
|
||||||
return copier.Copy(&a, &b)
|
return copier.Copy(a, b)
|
||||||
|
|
||||||
at := reflect.TypeOf(a)
|
at := reflect.TypeOf(a)
|
||||||
av := reflect.ValueOf(a)
|
av := reflect.ValueOf(a)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user