mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-12-03 02:42:19 +08:00
fix: del the manager config and manger init statement
This commit is contained in:
parent
9527278239
commit
06982972d5
@ -243,9 +243,10 @@ push:
|
|||||||
#
|
#
|
||||||
# Built-in app manager user IDs
|
# Built-in app manager user IDs
|
||||||
# Built-in app manager nicknames
|
# Built-in app manager nicknames
|
||||||
|
# Attention, this configure is discarded. If you have used him before, configure your own
|
||||||
manager:
|
manager:
|
||||||
userID: [ "${MANAGER_USERID_1}", "${MANAGER_USERID_2}", "${MANAGER_USERID_3}" ]
|
userID:
|
||||||
nickname: [ "${NICKNAME_1}", "${NICKNAME_2}", "${NICKNAME_3}" ]
|
nickname:
|
||||||
|
|
||||||
# chatAdmin, use for send notification
|
# chatAdmin, use for send notification
|
||||||
#
|
#
|
||||||
@ -329,7 +330,7 @@ callback:
|
|||||||
timeout: ${CALLBACK_TIMEOUT}
|
timeout: ${CALLBACK_TIMEOUT}
|
||||||
failedContinue: ${CALLBACK_FAILED_CONTINUE}
|
failedContinue: ${CALLBACK_FAILED_CONTINUE}
|
||||||
afterSendSingleMsg:
|
afterSendSingleMsg:
|
||||||
enable: true
|
enable: ${CALLBACK_ENABLE}
|
||||||
timeout: ${CALLBACK_TIMEOUT}
|
timeout: ${CALLBACK_TIMEOUT}
|
||||||
failedContinue: ${CALLBACK_FAILED_CONTINUE}
|
failedContinue: ${CALLBACK_FAILED_CONTINUE}
|
||||||
beforeSendGroupMsg:
|
beforeSendGroupMsg:
|
||||||
|
|||||||
@ -477,12 +477,6 @@ This section involves setting up additional configuration variables for Websocke
|
|||||||
| JPNS_MASTER_SECRET | [User Defined] | JPNS Master Secret |
|
| JPNS_MASTER_SECRET | [User Defined] | JPNS Master Secret |
|
||||||
| JPNS_PUSH_URL | [User Defined] | JPNS Push Notification URL |
|
| JPNS_PUSH_URL | [User Defined] | JPNS Push Notification URL |
|
||||||
| JPNS_PUSH_INTENT | [User Defined] | JPNS Push Intent |
|
| JPNS_PUSH_INTENT | [User Defined] | JPNS Push Intent |
|
||||||
| MANAGER_USERID_1 | "openIM123456" | Administrator ID 1 |
|
|
||||||
| MANAGER_USERID_2 | "openIM654321" | Administrator ID 2 |
|
|
||||||
| MANAGER_USERID_3 | "openIMAdmin" | Administrator ID 3 |
|
|
||||||
| NICKNAME_1 | "system1" | Nickname 1 |
|
|
||||||
| NICKNAME_2 | "system2" | Nickname 2 |
|
|
||||||
| NICKNAME_3 | "system3" | Nickname 3 |
|
|
||||||
| IM_ADMIN_USERID | "imAdmin" | IM Administrator ID |
|
| IM_ADMIN_USERID | "imAdmin" | IM Administrator ID |
|
||||||
| IM_ADMIN_NAME | "imAdmin" | IM Administrator Nickname |
|
| IM_ADMIN_NAME | "imAdmin" | IM Administrator Nickname |
|
||||||
| MULTILOGIN_POLICY | "1" | Multi-login Policy |
|
| MULTILOGIN_POLICY | "1" | Multi-login Policy |
|
||||||
|
|||||||
@ -231,6 +231,9 @@ func (p *Pusher) Push2SuperGroup(ctx context.Context, groupID string, msg *sdkws
|
|||||||
if len(config.Config.Manager.UserID) > 0 {
|
if len(config.Config.Manager.UserID) > 0 {
|
||||||
ctx = mcontext.WithOpUserIDContext(ctx, config.Config.Manager.UserID[0])
|
ctx = mcontext.WithOpUserIDContext(ctx, config.Config.Manager.UserID[0])
|
||||||
}
|
}
|
||||||
|
if len(config.Config.Manager.UserID) == 0 && len(config.Config.IMAdmin.UserID) > 0 {
|
||||||
|
ctx = mcontext.WithOpUserIDContext(ctx, config.Config.IMAdmin.UserID[0])
|
||||||
|
}
|
||||||
defer func(groupID string) {
|
defer func(groupID string) {
|
||||||
if err = p.groupRpcClient.DismissGroup(ctx, groupID); err != nil {
|
if err = p.groupRpcClient.DismissGroup(ctx, groupID); err != nil {
|
||||||
log.ZError(ctx, "DismissGroup Notification clear members", err, "groupID", groupID)
|
log.ZError(ctx, "DismissGroup Notification clear members", err, "groupID", groupID)
|
||||||
|
|||||||
@ -111,6 +111,13 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg.
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
revokerUserID := mcontext.GetOpUserID(ctx)
|
revokerUserID := mcontext.GetOpUserID(ctx)
|
||||||
|
var flag bool
|
||||||
|
if len(config.Config.Manager.UserID) > 0 {
|
||||||
|
flag = utils.Contain(revokerUserID, config.Config.Manager.UserID...)
|
||||||
|
}
|
||||||
|
if len(config.Config.Manager.UserID) == 0 {
|
||||||
|
flag = utils.Contain(revokerUserID, config.Config.IMAdmin.UserID...)
|
||||||
|
}
|
||||||
tips := sdkws.RevokeMsgTips{
|
tips := sdkws.RevokeMsgTips{
|
||||||
RevokerUserID: revokerUserID,
|
RevokerUserID: revokerUserID,
|
||||||
ClientMsgID: msgs[0].ClientMsgID,
|
ClientMsgID: msgs[0].ClientMsgID,
|
||||||
@ -118,7 +125,7 @@ func (m *msgServer) RevokeMsg(ctx context.Context, req *msg.RevokeMsgReq) (*msg.
|
|||||||
Seq: req.Seq,
|
Seq: req.Seq,
|
||||||
SesstionType: msgs[0].SessionType,
|
SesstionType: msgs[0].SessionType,
|
||||||
ConversationID: req.ConversationID,
|
ConversationID: req.ConversationID,
|
||||||
IsAdminRevoke: utils.Contain(revokerUserID, config.Config.Manager.UserID...),
|
IsAdminRevoke: flag,
|
||||||
}
|
}
|
||||||
var recvID string
|
var recvID string
|
||||||
if msgs[0].SessionType == constant.SuperGroupChatType {
|
if msgs[0].SessionType == constant.SuperGroupChatType {
|
||||||
|
|||||||
@ -54,6 +54,9 @@ func (m *msgServer) messageVerification(ctx context.Context, data *msg.SendMsgRe
|
|||||||
if utils.IsContain(data.MsgData.SendID, config.Config.Manager.UserID) {
|
if utils.IsContain(data.MsgData.SendID, config.Config.Manager.UserID) {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
if utils.IsContain(data.MsgData.SendID, config.Config.IMAdmin.UserID) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
if data.MsgData.ContentType <= constant.NotificationEnd &&
|
if data.MsgData.ContentType <= constant.NotificationEnd &&
|
||||||
data.MsgData.ContentType >= constant.NotificationBegin {
|
data.MsgData.ContentType >= constant.NotificationBegin {
|
||||||
return nil
|
return nil
|
||||||
@ -91,6 +94,9 @@ func (m *msgServer) messageVerification(ctx context.Context, data *msg.SendMsgRe
|
|||||||
if utils.IsContain(data.MsgData.SendID, config.Config.Manager.UserID) {
|
if utils.IsContain(data.MsgData.SendID, config.Config.Manager.UserID) {
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
if utils.IsContain(data.MsgData.SendID, config.Config.IMAdmin.UserID) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
if data.MsgData.ContentType <= constant.NotificationEnd &&
|
if data.MsgData.ContentType <= constant.NotificationEnd &&
|
||||||
data.MsgData.ContentType >= constant.NotificationBegin {
|
data.MsgData.ContentType >= constant.NotificationBegin {
|
||||||
return nil
|
return nil
|
||||||
|
|||||||
@ -71,12 +71,6 @@ func Start(client registry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
users := make([]*tablerelation.UserModel, 0)
|
users := make([]*tablerelation.UserModel, 0)
|
||||||
if len(config.Config.Manager.UserID) != len(config.Config.Manager.Nickname) {
|
|
||||||
return errors.New("len(config.Config.Manager.AppManagerUid) != len(config.Config.Manager.Nickname)")
|
|
||||||
}
|
|
||||||
for k, v := range config.Config.Manager.UserID {
|
|
||||||
users = append(users, &tablerelation.UserModel{UserID: v, Nickname: config.Config.Manager.Nickname[k], AppMangerLevel: constant.AppAdmin})
|
|
||||||
}
|
|
||||||
if len(config.Config.IMAdmin.UserID) != len(config.Config.IMAdmin.Nickname) {
|
if len(config.Config.IMAdmin.UserID) != len(config.Config.IMAdmin.Nickname) {
|
||||||
return errors.New("len(config.Config.AppNotificationAdmin.AppManagerUid) != len(config.Config.AppNotificationAdmin.Nickname)")
|
return errors.New("len(config.Config.AppNotificationAdmin.AppManagerUid) != len(config.Config.AppNotificationAdmin.Nickname)")
|
||||||
}
|
}
|
||||||
|
|||||||
@ -349,12 +349,6 @@ def "JPNS_APP_KEY" "" # JPNS应用密钥
|
|||||||
def "JPNS_MASTER_SECRET" "" # JPNS主密钥
|
def "JPNS_MASTER_SECRET" "" # JPNS主密钥
|
||||||
def "JPNS_PUSH_URL" "" # JPNS推送URL
|
def "JPNS_PUSH_URL" "" # JPNS推送URL
|
||||||
def "JPNS_PUSH_INTENT" "" # JPNS推送意图
|
def "JPNS_PUSH_INTENT" "" # JPNS推送意图
|
||||||
def "MANAGER_USERID_1" "openIM123456" # 管理员ID 1
|
|
||||||
def "MANAGER_USERID_2" "openIM654321" # 管理员ID 2
|
|
||||||
def "MANAGER_USERID_3" "openIMAdmin" # 管理员ID 3
|
|
||||||
def "NICKNAME_1" "system1" # 昵称1
|
|
||||||
def "NICKNAME_2" "system2" # 昵称2
|
|
||||||
def "NICKNAME_3" "system3" # 昵称3
|
|
||||||
def "IM_ADMIN_USERID" "imAdmin" # IM管理员ID
|
def "IM_ADMIN_USERID" "imAdmin" # IM管理员ID
|
||||||
def "IM_ADMIN_NAME" "imAdmin" # IM管理员昵称
|
def "IM_ADMIN_NAME" "imAdmin" # IM管理员昵称
|
||||||
def "MULTILOGIN_POLICY" "1" # 多登录策略
|
def "MULTILOGIN_POLICY" "1" # 多登录策略
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user