skip error if we could not find cyber links in tx events when process…

…ing wasm module

delivery/server/scraper.go

@@ -43,6 +43,8 @@ func (s *Server) startMetricsScrapper() {
 		statusMap map[string]int
 		ctx       = context.Background()
 		ticker    = time.NewTicker(1 * time.Minute)
+		blocks    []*model.Block
+		err       error
 	)
 
 	defer ticker.Stop()
@@ -53,10 +55,11 @@ func (s *Server) startMetricsScrapper() {
 			s.log.Info().Msg("stop metrics scraper")
 			return
 		case <-ticker.C:
-			if err := s.storage.Ping(ctx); err != nil {
+			if err = s.storage.Ping(ctx); err != nil {
 				continue
 			}
-			blocks, err := s.storage.GetAllBlocks(ctx)
+
+			blocks, err = s.storage.GetAllBlocks(ctx)
 			if err != nil {
 				s.log.Error().Err(err).Msg("can't get all blocks from storage")
 				continue
@@ -82,7 +85,8 @@ func (s *Server) startMetricsScrapper() {
 				statusMetric.With(prometheus.Labels{"status": statusName}).Set(float64(count))
 			}
 
-			count, err := s.storage.CountErrorMessages(ctx)
+			var count int64
+			count, err = s.storage.CountErrorMessages(ctx)
 			if err != nil {
 				s.log.Error().Err(err).Msg("can't get count of error messages")
 				continue

modules/wasm/message.go

@@ -26,6 +26,18 @@ func (m *Module) HandleMessage(ctx context.Context, index int, bostromMsg sdk.Ms
 		return nil
 	}
 
+	if err := m.findAndPublishCyberLink(ctx, tx, index); err != nil {
+		if errors.Is(err, types.ErrNoEventFound) || errors.Is(err, types.ErrNoAttributeFound) {
+			return nil
+		}
+
+		return err
+	}
+
+	return nil
+}
+
+func (m *Module) findAndPublishCyberLink(ctx context.Context, tx *types.Tx, index int) error {
 	event, err := tx.FindEventByType(index, graph.EventTypeCyberlink)
 	if err != nil {
 		return err

types/cosmos.go

@@ -18,7 +18,8 @@ import (
 )
 
 var (
-	ErrNoEventFound = errors.New("no event found")
+	ErrNoEventFound     = errors.New("no event found")
+	ErrNoAttributeFound = errors.New("no event with attribute")
 )
 
 type (
@@ -206,7 +207,7 @@ func (tx Tx) FindAttributeByKey(event sdk.StringEvent, attrKey string) (string,
 		}
 	}
 
-	return "", errors.New(fmt.Sprintf("no event with attribute %s found inside tx with hash %s", attrKey, tx.TxHash))
+	return "", fmt.Errorf("%w: %s found inside tx with hash %s", ErrNoAttributeFound, attrKey, tx.TxHash)
 }
 
 // Successful tells whether this tx is successful or not