From cd95d8a5a2504188aa6584d38b714540dfe4ee8a Mon Sep 17 00:00:00 2001 From: Aleksandr Soloshenko Date: Fri, 23 Feb 2024 00:04:30 +0700 Subject: [PATCH] [logging][messages] log message state update errors --- internal/sms-gateway/services/messages.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/internal/sms-gateway/services/messages.go b/internal/sms-gateway/services/messages.go index 635ac41..2a2a785 100644 --- a/internal/sms-gateway/services/messages.go +++ b/internal/sms-gateway/services/messages.go @@ -53,7 +53,7 @@ func NewMessagesService(params MessagesServiceParams) *MessagesService { return &MessagesService{ Messages: params.Messages, PushSvc: params.PushSvc, - Logger: params.Logger, + Logger: params.Logger.Named("MessagesService"), idgen: idgen, } } @@ -206,7 +206,9 @@ func (s *MessagesService) filterTimeouted(messages []models.Message) []models.Me v.Recipients[i].State = models.MessageStateFailed v.Recipients[i].Error = types.AsPointer(ErrorTTLExpired) } - s.Messages.UpdateState(&v) + if err := s.Messages.UpdateState(&v); err != nil { + s.Logger.Error("Can't update message state", zap.Error(err)) + } } } return result