mirror of
https://github.com/openimsdk/open-im-server.git
synced 2025-04-06 04:15:46 +08:00
40 lines
1.2 KiB
Go
40 lines
1.2 KiB
Go
package gate
|
|
|
|
import (
|
|
"Open_IM/pkg/common/config"
|
|
"Open_IM/pkg/grpc-etcdv3/getcdv3"
|
|
pbChat "Open_IM/pkg/proto/chat"
|
|
sdk_ws "Open_IM/pkg/proto/sdk_ws"
|
|
"strings"
|
|
)
|
|
|
|
var MaxPullMsgNum = 100
|
|
|
|
func (r *RPCServer) GenPullSeqList(currentSeq uint32, operationID string, userID string) ([]uint32, error) {
|
|
|
|
}
|
|
|
|
func (r *RPCServer) GetSingleMsgForPush(operationID string, msgData *sdk_ws.MsgData, pushToUserID string, platformID string) []*sdk_ws.MsgData {
|
|
seqList, err := r.GenPullSeqList(msgData.Seq, operationID, pushToUserID)
|
|
if err != nil {
|
|
return nil
|
|
}
|
|
rpcReq := sdk_ws.PullMessageBySeqListReq{}
|
|
rpcReq.SeqList = seqList
|
|
rpcReq.UserID = pushToUserID
|
|
rpcReq.OperationID = operationID
|
|
grpcConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImOfflineMessageName)
|
|
msgClient := pbChat.NewChatClient(grpcConn)
|
|
reply, err := msgClient.PullMessageBySeqList(context.Background(), &rpcReq)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *RPCServer) GetBatchMsgForPush(operationID string, msgData *sdk_ws.MsgData, pushToUserIDList []string, platformID string) map[string][]*sdk_ws.MsgData {
|
|
return nil
|
|
}
|
|
|
|
func (r *RPCServer) GetMaxSeq(userID string) (uint32, error) {
|
|
return 0, nil
|
|
}
|