mirror of
https://github.com/hanzoai/team.git
synced 2026-09-30 01:57:35 +00:00
fa36e8d0c3
- 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. --------- Co-authored-by: Hanzo Dev <[email protected]>
102 lines
3.4 KiB
Go
102 lines
3.4 KiB
Go
// 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"
|
|
"github.com/mattermost/mattermost/server/public/shared/request"
|
|
)
|
|
|
|
const (
|
|
OneHourMillis = 60 * 60 * 1000
|
|
)
|
|
|
|
// NotifySessionsExpired is called periodically from the job server to notify any mobile sessions that have expired.
|
|
func (a *App) NotifySessionsExpired() error {
|
|
if !a.canSendPushNotifications() {
|
|
return nil
|
|
}
|
|
|
|
// Get all mobile sessions that expired within the last hour.
|
|
sessions, err := a.ch.srv.Store().Session().GetSessionsExpired(OneHourMillis, true, true)
|
|
if err != nil {
|
|
a.CountNotificationReason(model.NotificationStatusError, model.NotificationTypePush, model.NotificationReasonFetchError, model.NotificationNoPlatform)
|
|
a.Log().LogM(mlog.MlvlNotificationError, "Cannot get sessions expired",
|
|
mlog.String("type", model.NotificationTypePush),
|
|
mlog.String("status", model.NotificationStatusError),
|
|
mlog.String("reason", model.NotificationReasonFetchError),
|
|
mlog.Err(err),
|
|
)
|
|
return model.NewAppError("NotifySessionsExpired", "app.session.analytics_session_count.app_error", nil, "", http.StatusInternalServerError).Wrap(err)
|
|
}
|
|
|
|
msg := &model.PushNotification{
|
|
Version: model.PushMessageV2,
|
|
Type: model.PushTypeSession,
|
|
}
|
|
|
|
for _, session := range sessions {
|
|
tmpMessage := msg.DeepCopy()
|
|
tmpMessage.SetDeviceIdAndPlatform(session.DeviceId)
|
|
tmpMessage.AckId = model.NewId()
|
|
tmpMessage.Message = a.getSessionExpiredPushMessage(session)
|
|
|
|
rctx := request.EmptyContext(a.Log().With(
|
|
mlog.String("type", model.NotificationTypePush),
|
|
mlog.String("ack_id", tmpMessage.AckId),
|
|
mlog.String("push_type", tmpMessage.Type),
|
|
mlog.String("user_id", session.UserId),
|
|
mlog.String("device_id", tmpMessage.DeviceId),
|
|
mlog.String("post_id", msg.PostId),
|
|
))
|
|
|
|
errPush := a.sendToPushProxy(rctx, tmpMessage, session)
|
|
if errPush != nil {
|
|
reason := model.NotificationReasonPushProxySendError
|
|
if errPush.Error() == notificationErrorRemoveDevice {
|
|
reason = model.NotificationReasonPushProxyRemoveDevice
|
|
}
|
|
a.CountNotificationReason(model.NotificationStatusError, model.NotificationTypePush, reason, tmpMessage.Platform)
|
|
rctx.Logger().LogM(mlog.MlvlNotificationError, "Failed to send to push proxy",
|
|
mlog.String("status", model.NotificationStatusNotSent),
|
|
mlog.String("reason", reason),
|
|
mlog.Err(errPush),
|
|
)
|
|
continue
|
|
}
|
|
|
|
rctx.Logger().LogM(mlog.MlvlNotificationTrace, "Notification sent to push proxy",
|
|
mlog.String("status", model.PushSendSuccess),
|
|
)
|
|
|
|
if a.Metrics() != nil {
|
|
a.Metrics().IncrementPostSentPush()
|
|
}
|
|
|
|
err = a.ch.srv.Store().Session().UpdateExpiredNotify(session.Id, true)
|
|
if err != nil {
|
|
mlog.Error("Failed to update ExpiredNotify flag", mlog.String("sessionid", session.Id), mlog.Err(err))
|
|
}
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func (a *App) getSessionExpiredPushMessage(session *model.Session) string {
|
|
locale := model.DefaultLocale
|
|
user, err := a.GetUser(session.UserId)
|
|
if err == nil {
|
|
locale = user.Locale
|
|
}
|
|
T := i18n.GetUserTranslations(locale)
|
|
|
|
siteName := *a.Config().TeamSettings.SiteName
|
|
props := map[string]any{"siteName": siteName, "hoursCount": *a.Config().ServiceSettings.SessionLengthMobileInHours}
|
|
|
|
return T("api.push_notifications.session.expired", props)
|
|
}
|