Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
zhaominxu
Open-IM-Server
提交
292a8620
O
Open-IM-Server
项目概览
zhaominxu
/
Open-IM-Server
与 Fork 源项目一致
从无法访问的项目Fork
通知
2
Star
0
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
O
Open-IM-Server
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
提交
292a8620
编写于
12月 28, 2021
作者:
programor_guo
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
remove invalid token
上级
30024c98
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
24 addition
and
3 deletion
+24
-3
internal/api/chat/send_msg.go
internal/api/chat/send_msg.go
+1
-1
pkg/common/db/redisModel.go
pkg/common/db/redisModel.go
+7
-2
pkg/common/token_verify/jwt_token.go
pkg/common/token_verify/jwt_token.go
+16
-0
未找到文件。
internal/api/chat/send_msg.go
浏览文件 @
292a8620
...
...
@@ -44,7 +44,7 @@ func newUserSendMsgReq(token string, params *paramsUserSendMsg) *pbChat.SendMsgR
GroupID
:
params
.
Data
.
GroupID
,
ClientMsgID
:
params
.
Data
.
ClientMsgID
,
SenderPlatformID
:
params
.
SenderPlatformID
,
SenderNick
N
ame
:
params
.
SenderNickName
,
SenderNick
n
ame
:
params
.
SenderNickName
,
SenderFaceURL
:
params
.
SenderFaceURL
,
SessionType
:
params
.
Data
.
SessionType
,
MsgFrom
:
params
.
Data
.
MsgFrom
,
...
...
pkg/common/db/redisModel.go
浏览文件 @
292a8620
...
...
@@ -91,10 +91,15 @@ func (d *DataBases) SetTokenMapByUidPid(userID string, platformID int32, m map[s
_
,
err
:=
d
.
Exec
(
"hmset"
,
key
,
redis
.
Args
{}
.
Add
()
.
AddFlat
(
m
)
...
)
return
err
}
func
(
d
*
DataBases
)
DeleteTokenByUidPid
(
userID
string
,
platformID
int32
,
fields
[]
string
)
error
{
key
:=
uidPidToken
+
userID
+
":"
+
constant
.
PlatformIDToName
(
platformID
)
_
,
err
:=
d
.
Exec
(
"HDEL"
,
key
,
redis
.
Args
{}
.
Add
()
.
AddFlat
(
fields
)
...
)
return
err
}
func
(
d
*
DataBases
)
SetSingleConversationMsgOpt
(
userID
,
conversationID
string
,
opt
int
)
error
{
key
:=
conversationReceiveMessageOpt
+
userID
_
,
err
1
:=
d
.
Exec
(
"HSet"
,
key
,
conversationID
,
opt
)
return
err
1
_
,
err
:=
d
.
Exec
(
"HSet"
,
key
,
conversationID
,
opt
)
return
err
}
func
(
d
*
DataBases
)
GetSingleConversationMsgOpt
(
userID
,
conversationID
string
)
(
int
,
error
)
{
key
:=
conversationReceiveMessageOpt
+
userID
...
...
pkg/common/token_verify/jwt_token.go
浏览文件 @
292a8620
...
...
@@ -6,6 +6,7 @@ import (
commonDB
"Open_IM/pkg/common/db"
"Open_IM/pkg/common/log"
"Open_IM/pkg/utils"
"github.com/garyburd/redigo/redis"
"github.com/golang-jwt/jwt/v4"
"time"
)
...
...
@@ -43,6 +44,21 @@ func CreateToken(userID string, platformID int32) (string, int64, error) {
if
err
!=
nil
{
return
""
,
0
,
err
}
//remove Invalid token
m
,
err
:=
commonDB
.
DB
.
GetTokenMapByUidPid
(
userID
,
constant
.
PlatformIDToName
(
platformID
))
if
err
!=
nil
&&
err
!=
redis
.
ErrNil
{
return
""
,
0
,
err
}
var
deleteTokenKey
[]
string
for
k
,
v
:=
range
m
{
if
v
!=
constant
.
NormalToken
{
deleteTokenKey
=
append
(
deleteTokenKey
,
k
)
}
}
err
=
commonDB
.
DB
.
DeleteTokenByUidPid
(
userID
,
platformID
,
deleteTokenKey
)
if
err
!=
nil
{
return
""
,
0
,
err
}
err
=
commonDB
.
DB
.
AddTokenFlag
(
userID
,
platformID
,
tokenString
,
constant
.
NormalToken
)
if
err
!=
nil
{
return
""
,
0
,
err
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录