🐛 bug fix
This commit is contained in:
+1
-1
@@ -2,7 +2,7 @@
|
||||
## 描述
|
||||
该客户端用于支持 `client` 消息推送方式。
|
||||
|
||||
注意,为防止未授权的 WebSocket 连接,使用该消息推送方式你**必须**设置 ACCESS_TOKEN。
|
||||
注意,为防止未授权的 WebSocket 连接,使用该消息推送方式你应设置 ACCESS_TOKEN。
|
||||
|
||||
## 原理
|
||||
客户端启动后与 message-pusher 服务器建立一个 WebSocket 连接,通过该连接接受要推送消息,并调用系统的消息通知接口进行消息通知。
|
||||
|
||||
+1
-1
@@ -38,10 +38,10 @@ func main() {
|
||||
for {
|
||||
var message = new(Message)
|
||||
err = c.ReadJSON(message)
|
||||
log.Println("Get new message")
|
||||
if err != nil {
|
||||
log.Println("Error occurred when read message:", err)
|
||||
} else {
|
||||
log.Println("Get new message")
|
||||
Notify(message)
|
||||
}
|
||||
}
|
||||
|
||||
+1
-1
@@ -91,7 +91,7 @@ function checkPrefix(prefix) {
|
||||
|
||||
function registerWebSocket(prefix, token, ws) {
|
||||
let user = tokenStore.get(prefix);
|
||||
if (user && user.accessToken !== '' && user.accessToken === token) {
|
||||
if (user && user.accessToken === token) {
|
||||
updateTokenStore(prefix, 'ws', ws);
|
||||
} else {
|
||||
ws.terminate();
|
||||
|
||||
@@ -21,11 +21,6 @@ router.all('/:userPrefix/verify', (req, res, next) => {
|
||||
}
|
||||
});
|
||||
|
||||
router.get('/ws/:userPrefix/:token', async (ws, req) => {
|
||||
const userPrefix = req.params.userPrefix;
|
||||
const token = req.params.token;
|
||||
});
|
||||
|
||||
router.all('/:userPrefix/:description', async (req, res, next) => {
|
||||
const userPrefix = req.params.userPrefix;
|
||||
let message = {
|
||||
|
||||
Reference in New Issue
Block a user