IntenseWebs/mattermost
3
0
Fork 0
mirror of https://github.com/mattermost/mattermost.git synced 2025-02-25 18:55:24 -06:00
Code Issues Packages Projects Releases Wiki Activity

server/app: remove websocket_router.go (#24680)

Browse Source
This commit is contained in:
Ibrahim Serdar Acikgoz 2023-10-04 10:54:40 +03:00 committed by GitHub
parent a25aa43667
commit 8e7e5c8775
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 113 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

113
server/channels/app/websocket_router.go
View File

@ -1,113 +0,0 @@
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
// See LICENSE.txt for license information.
package app
// import (
// "net/http"
// "github.com/mattermost/mattermost/server/public/model"
// "github.com/mattermost/mattermost/server/public/shared/i18n"
// "github.com/mattermost/mattermost/server/public/shared/mlog"
// )
// type webSocketHandler interface {
// ServeWebSocket(*WebConn, *model.WebSocketRequest)
// }
// type WebSocketRouter struct {
// handlers map[string]webSocketHandler
// }
// func (wr *WebSocketRouter) Handle(action string, handler webSocketHandler) {
// wr.handlers[action] = handler
// }
// func (wr *WebSocketRouter) ServeWebSocket(conn *WebConn, r *model.WebSocketRequest) {
// if r.Action == "" {
// err := model.NewAppError("ServeWebSocket", "api.web_socket_router.no_action.app_error", nil, "", http.StatusBadRequest)
// returnWebSocketError(conn.App, conn, r, err)
// return
// }
// if r.Seq <= 0 {
// err := model.NewAppError("ServeWebSocket", "api.web_socket_router.bad_seq.app_error", nil, "", http.StatusBadRequest)
// returnWebSocketError(conn.App, conn, r, err)
// return
// }
// if r.Action == model.WebsocketAuthenticationChallenge {
// if conn.GetSessionToken() != "" {
// return
// }
// token, ok := r.Data["token"].(string)
// if !ok {
// conn.WebSocket.Close()
// return
// }
// session, err := conn.App.GetSession(token)
// if err != nil {
// conn.WebSocket.Close()
// return
// }
// conn.SetSession(session)
// conn.SetSessionToken(session.Token)
// conn.UserId = session.UserId
// conn.App.HubRegister(conn)
// conn.App.Srv().Go(func() {
// conn.App.SetStatusOnline(session.UserId, false)
// conn.App.UpdateLastActivityAtIfNeeded(*session)
// })
// resp := model.NewWebSocketResponse(model.StatusOk, r.Seq, nil)
// hub := conn.App.GetHubForUserId(conn.UserId)
// if hub == nil {
// return
// }
// hub.SendMessage(conn, resp)
// return
// }
// if !conn.IsAuthenticated() {
// err := model.NewAppError("ServeWebSocket", "api.web_socket_router.not_authenticated.app_error", nil, "", http.StatusUnauthorized)
// returnWebSocketError(conn.App, conn, r, err)
// return
// }
// handler, ok := wr.handlers[r.Action]
// if !ok {
// err := model.NewAppError("ServeWebSocket", "api.web_socket_router.bad_action.app_error", nil, "", http.StatusInternalServerError)
// returnWebSocketError(conn.App, conn, r, err)
// return
// }
// handler.ServeWebSocket(conn, r)
// }
// func returnWebSocketError(app *App, conn *WebConn, r *model.WebSocketRequest, err *model.AppError) {
// logF := mlog.Error
// if err.StatusCode >= http.StatusBadRequest && err.StatusCode < http.StatusInternalServerError {
// logF = mlog.Debug
// }
// logF(
// "websocket routing error.",
// mlog.Int64("seq", r.Seq),
// mlog.String("user_id", conn.UserId),
// mlog.String("system_message", err.SystemMessage(i18n.T)),
// mlog.Err(err),
// )
// hub := app.GetHubForUserId(conn.UserId)
// if hub == nil {
// return
// }
// err.DetailedError = ""
// errorResp := model.NewWebSocketError(r.Seq, err)
// hub.SendMessage(conn, errorResp)
// }