|
|
|
@ -16,8 +16,9 @@ package msggateway
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"context"
|
|
|
|
|
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/db/cache"
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/common/tokenverify"
|
|
|
|
|
"github.com/OpenIMSDK/Open-IM-Server/pkg/errs"
|
|
|
|
|
|
|
|
|
|
"google.golang.org/grpc"
|
|
|
|
|
|
|
|
|
@ -82,6 +83,9 @@ func (s *Server) GetUsersOnlineStatus(
|
|
|
|
|
ctx context.Context,
|
|
|
|
|
req *msggateway.GetUsersOnlineStatusReq,
|
|
|
|
|
) (*msggateway.GetUsersOnlineStatusResp, error) {
|
|
|
|
|
if !tokenverify.IsAppManagerUid(ctx) {
|
|
|
|
|
return nil, errs.ErrNoPermission.Wrap("only app manager")
|
|
|
|
|
}
|
|
|
|
|
var resp msggateway.GetUsersOnlineStatusResp
|
|
|
|
|
for _, userID := range req.UserIDs {
|
|
|
|
|
clients, ok := s.LongConnServer.GetUserAllCons(userID)
|
|
|
|
|