mirror of
https://github.com/mattermost/mattermost.git
synced 2026-02-03 20:40:00 -05:00
36b00d9bb6
- Remove NotificationLogSettings configuration entirely - Add new notification-specific log levels (NotificationError, NotificationWarn, NotificationInfo, NotificationDebug, NotificationTrace) - Consolidate all notification logs into standard mattermost.log file - Update all notification logging code to use new multi-level logging (MlvlNotification*) - Remove notification logger infrastructure and support packet integration - Update test configurations and remove deprecated functionality tests - Add comprehensive tests for new notification log levels This change simplifies log analysis by unifying all application logging while maintaining flexibility through Advanced Logging configuration for administrators who need separate notification logs. 🤖 Generated with [Claude Code](https://claude.ai/code) --------- Co-authored-by: Claude <noreply@anthropic.com>
64 lines
1.9 KiB
Go
64 lines
1.9 KiB
Go
// Copyright (c) 2015-present Mattermost, Inc. All Rights Reserved.
|
|
// See LICENSE.txt for license information.
|
|
|
|
package wsapi
|
|
|
|
import (
|
|
"github.com/mattermost/mattermost/server/public/model"
|
|
"github.com/mattermost/mattermost/server/public/shared/mlog"
|
|
)
|
|
|
|
func (api *API) InitSystem() {
|
|
api.Router.Handle("ping", api.APIWebSocketHandler(ping))
|
|
api.Router.Handle(string(model.WebsocketPostedNotifyAck), api.APIWebSocketHandler(api.websocketNotificationAck))
|
|
}
|
|
|
|
func ping(req *model.WebSocketRequest) (map[string]any, *model.AppError) {
|
|
data := map[string]any{}
|
|
data["text"] = "pong"
|
|
data["version"] = model.CurrentVersion
|
|
data["server_time"] = model.GetMillis()
|
|
data["node_id"] = ""
|
|
|
|
return data, nil
|
|
}
|
|
|
|
func (api *API) websocketNotificationAck(req *model.WebSocketRequest) (map[string]any, *model.AppError) {
|
|
// Log the ACKs if necessary
|
|
api.App.Log().LogM(mlog.MlvlNotificationDebug, "Websocket notification acknowledgment",
|
|
mlog.String("type", model.NotificationTypeWebsocket),
|
|
mlog.String("user_id", req.Session.UserId),
|
|
mlog.Any("user_agent", req.Data["user_agent"]),
|
|
mlog.Any("post_id", req.Data["post_id"]),
|
|
mlog.Any("status", req.Data["status"]),
|
|
mlog.Any("reason", req.Data["reason"]),
|
|
mlog.Any("data", req.Data["data"]),
|
|
)
|
|
|
|
// Count metrics for websocket acks
|
|
api.App.CountNotificationAck(model.NotificationTypeWebsocket, model.NotificationNoPlatform)
|
|
|
|
status := req.Data["status"]
|
|
reason := req.Data["reason"]
|
|
if status == nil {
|
|
return nil, nil
|
|
}
|
|
|
|
notificationStatus := model.NotificationStatus(status.(string))
|
|
if reason == nil && notificationStatus != model.NotificationStatusSuccess {
|
|
return nil, nil
|
|
}
|
|
var notificationReason model.NotificationReason
|
|
if reason != nil {
|
|
notificationReason = model.NotificationReason(reason.(string))
|
|
}
|
|
|
|
api.App.CountNotificationReason(
|
|
notificationStatus,
|
|
model.NotificationTypeWebsocket,
|
|
notificationReason,
|
|
model.NotificationNoPlatform,
|
|
)
|
|
|
|
return nil, nil
|
|
}
|