[push] minor fixes

Author: capcom6

internal/sms-gateway/modules/push/service.go

@@ -70,7 +70,8 @@ func New(
 	}, nil
 }
 
-// Run runs the service with the provided context if a debounce is set.
+// Run starts a ticker that triggers the sendAll function every debounce interval.
+// It runs indefinitely until the provided context is canceled.
 func (s *Service) Run(ctx context.Context) {
 	ticker := time.NewTicker(s.config.Debounce)
 	defer ticker.Stop()
@@ -103,10 +104,12 @@ func (s *Service) Enqueue(token string, event types.Event) error {
 	}
 	wrapperData, err := wrapper.serialize()
 	if err != nil {
+		s.metrics.IncError(1)
 		return fmt.Errorf("can't serialize event wrapper: %w", err)
 	}
 
 	if err := s.events.Set(ctx, wrapper.key(), wrapperData); err != nil {
+		s.metrics.IncError(1)
 		return fmt.Errorf("can't add message to cache: %w", err)
 	}
 
@@ -189,12 +192,13 @@ func (s *Service) sendAll(ctx context.Context) {
 		wrapperData, err := wrapper.serialize()
 		if err != nil {
 			s.metrics.IncError(1)
-			s.logger.Info("Can't serialize event wrapper", zap.Error(err))
+			s.logger.Error("Can't serialize event wrapper", zap.Error(err))
 			continue
 		}
 
 		if setErr := s.events.SetOrFail(ctx, wrapper.key(), wrapperData); setErr != nil {
-			s.logger.Info("Can't set message to cache", zap.Error(setErr))
+			s.logger.Warn("Can't set message to cache", zap.Error(setErr))
+			continue
 		}
 
 		s.metrics.IncRetry(RetryOutcomeRetried)