mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-06 04:15:46 +08:00
* Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * feat: add code lint * feat: add code lint * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * Script Refactoring * feat: code format * Script Refactoring * Script Refactoring * Script Refactoring * Adjust MinIO configuration settings * Adjust configuration settings * Adjust configuration settings * refactor: config change. * refactor: webhooks update. * Adjust configuration settings * refactor: webhooks update. * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * feat: s3 api addr * refactor: webhooks update. * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * Adjust configuration settings * refactor: webhooks update. * refactor: kafka update. * Simplify the Docker Compose configuration, remove unnecessary environment variables, and eliminate the gateway service. * refactor: kafka update. * refactor: kafka update. * Simplify the Docker Compose configuration, remove unnecessary environment variables, and eliminate the gateway service. * Simplify the Docker Compose configuration, remove unnecessary environment variables, and eliminate the gateway service. * Windows can compile and run. * Windows can compile and run. * refactor: kafka update. * feat: msg cache split * refactor: webhooks update * refactor: webhooks update * refactor: friends update * refactor: group update * refactor: third update * refactor: api update * refactor: crontab update * refactor: msggateway update * mage * mage * refactor: all module update. * check * refactor: all module update. * load config * load config * load config * load config * refactor: all module update. * refactor: all module update. * refactor: all module update. * refactor: all module update. * refactor: all module update. * Optimize Docker configuration and script. * refactor: all module update. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * refactor: all module update. * Optimize Docker configuration and script. * refactor: all module update. * refactor: all module update. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * update tools * update tools * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * update protocol * Optimize Docker configuration and script. * Optimize Docker configuration and script. * refactor: all module update. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * Optimize Docker configuration and script. * refactor: api remove token auth by redis directly. * Code Refactoring * refactor: websocket auth change to call rpc of auth. * refactor: kick online user and remove token change to call auth rpc. * refactor: kick online user and remove token change to call auth rpc. * refactor: remove msggateway redis. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor webhook * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor webhook * refactor: cmd update. * refactor: cmd update. * fix: runtime: goroutine stack exceeds * refactor: cmd update. * refactor notification * refactor notification * refactor * refactor: cmd update. * refactor: cmd update. * refactor * refactor * refactor * protojson * protojson * protojson * go mod * wrapperspb * refactor: cmd update. * refactor: cmd update. * refactor: cmd update. * refactor: context update. * refactor: websocket update info. * refactor: websocket update info. * refactor: websocket update info. * refactor: websocket update info. * refactor: api name change. * refactor: debug info. * refactor: debug info. * refactor: debug info. * fix: update file * refactor * refactor * refactor: debug info. * refactor: debug info. * refactor: debug info. * refactor: debug info. * refactor: debug info. * refactor: debug info. * fix: callback update. * fix: callback update. * refactor * fix: update message. * fix: msg cache timeout. * refactor * refactor * fix: push update. * fix: push update. * fix: push update. * fix: push update. * fix: push update. * fix: push update. * fix: push update. * fix: websocket handle error remove when upgrade error. --------- Co-authored-by: skiffer-git <44203734@qq.com> Co-authored-by: Xinwei Xiong (cubxxw) <3293172751nss@gmail.com> Co-authored-by: withchao <993506633@qq.com>
139 lines
4.4 KiB
Go
139 lines
4.4 KiB
Go
// Copyright © 2023 OpenIM. All rights reserved.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package convert
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/openimsdk/open-im-server/v3/pkg/common/db/table/relation"
|
|
pbgroup "github.com/openimsdk/protocol/group"
|
|
sdkws "github.com/openimsdk/protocol/sdkws"
|
|
)
|
|
|
|
func Db2PbGroupInfo(m *relation.GroupModel, ownerUserID string, memberCount uint32) *sdkws.GroupInfo {
|
|
return &sdkws.GroupInfo{
|
|
GroupID: m.GroupID,
|
|
GroupName: m.GroupName,
|
|
Notification: m.Notification,
|
|
Introduction: m.Introduction,
|
|
FaceURL: m.FaceURL,
|
|
OwnerUserID: ownerUserID,
|
|
CreateTime: m.CreateTime.UnixMilli(),
|
|
MemberCount: memberCount,
|
|
Ex: m.Ex,
|
|
Status: m.Status,
|
|
CreatorUserID: m.CreatorUserID,
|
|
GroupType: m.GroupType,
|
|
NeedVerification: m.NeedVerification,
|
|
LookMemberInfo: m.LookMemberInfo,
|
|
ApplyMemberFriend: m.ApplyMemberFriend,
|
|
NotificationUpdateTime: m.NotificationUpdateTime.UnixMilli(),
|
|
NotificationUserID: m.NotificationUserID,
|
|
}
|
|
}
|
|
|
|
func Pb2DbGroupRequest(req *pbgroup.GroupApplicationResponseReq, handleUserID string) *relation.GroupRequestModel {
|
|
return &relation.GroupRequestModel{
|
|
UserID: req.FromUserID,
|
|
GroupID: req.GroupID,
|
|
HandleResult: req.HandleResult,
|
|
HandledMsg: req.HandledMsg,
|
|
HandleUserID: handleUserID,
|
|
HandledTime: time.Now(),
|
|
}
|
|
}
|
|
|
|
func Db2PbCMSGroup(m *relation.GroupModel, ownerUserID string, ownerUserName string, memberCount uint32) *pbgroup.CMSGroup {
|
|
return &pbgroup.CMSGroup{
|
|
GroupInfo: Db2PbGroupInfo(m, ownerUserID, memberCount),
|
|
GroupOwnerUserID: ownerUserID,
|
|
GroupOwnerUserName: ownerUserName,
|
|
}
|
|
}
|
|
|
|
func Db2PbGroupMember(m *relation.GroupMemberModel) *sdkws.GroupMemberFullInfo {
|
|
return &sdkws.GroupMemberFullInfo{
|
|
GroupID: m.GroupID,
|
|
UserID: m.UserID,
|
|
RoleLevel: m.RoleLevel,
|
|
JoinTime: m.JoinTime.UnixMilli(),
|
|
Nickname: m.Nickname,
|
|
FaceURL: m.FaceURL,
|
|
// AppMangerLevel: m.AppMangerLevel,
|
|
JoinSource: m.JoinSource,
|
|
OperatorUserID: m.OperatorUserID,
|
|
Ex: m.Ex,
|
|
MuteEndTime: m.MuteEndTime.UnixMilli(),
|
|
InviterUserID: m.InviterUserID,
|
|
}
|
|
}
|
|
|
|
func Db2PbGroupRequest(m *relation.GroupRequestModel, user *sdkws.PublicUserInfo, group *sdkws.GroupInfo) *sdkws.GroupRequest {
|
|
return &sdkws.GroupRequest{
|
|
UserInfo: user,
|
|
GroupInfo: group,
|
|
HandleResult: m.HandleResult,
|
|
ReqMsg: m.ReqMsg,
|
|
HandleMsg: m.HandledMsg,
|
|
ReqTime: m.ReqTime.UnixMilli(),
|
|
HandleUserID: m.HandleUserID,
|
|
HandleTime: m.HandledTime.UnixMilli(),
|
|
Ex: m.Ex,
|
|
JoinSource: m.JoinSource,
|
|
InviterUserID: m.InviterUserID,
|
|
}
|
|
}
|
|
|
|
func Db2PbGroupAbstractInfo(
|
|
groupID string,
|
|
groupMemberNumber uint32,
|
|
groupMemberListHash uint64,
|
|
) *pbgroup.GroupAbstractInfo {
|
|
return &pbgroup.GroupAbstractInfo{
|
|
GroupID: groupID,
|
|
GroupMemberNumber: groupMemberNumber,
|
|
GroupMemberListHash: groupMemberListHash,
|
|
}
|
|
}
|
|
|
|
func Pb2DBGroupInfo(m *sdkws.GroupInfo) *relation.GroupModel {
|
|
return &relation.GroupModel{
|
|
GroupID: m.GroupID,
|
|
GroupName: m.GroupName,
|
|
Notification: m.Notification,
|
|
Introduction: m.Introduction,
|
|
FaceURL: m.FaceURL,
|
|
CreateTime: time.Now(),
|
|
Ex: m.Ex,
|
|
Status: m.Status,
|
|
CreatorUserID: m.CreatorUserID,
|
|
GroupType: m.GroupType,
|
|
NeedVerification: m.NeedVerification,
|
|
LookMemberInfo: m.LookMemberInfo,
|
|
ApplyMemberFriend: m.ApplyMemberFriend,
|
|
NotificationUpdateTime: time.UnixMilli(m.NotificationUpdateTime),
|
|
NotificationUserID: m.NotificationUserID,
|
|
}
|
|
}
|
|
|
|
// func Pb2DbGroupMember(m *sdkws.UserInfo) *relation.GroupMemberModel {
|
|
// return &relation.GroupMemberModel{
|
|
// UserID: m.UserID,
|
|
// Nickname: m.Nickname,
|
|
// FaceURL: m.FaceURL,
|
|
// Ex: m.Ex,
|
|
// }
|
|
//}
|