adding filtration for state contract

config-example.yaml

@@ -24,5 +24,4 @@ evm:
 
 relay:
   catchup_disabled: true
-  issuer_id: [ '', '' ]
-  disable_filtration: true
+  source_contract: 0x...

internal/config/relay.go

@@ -7,7 +7,8 @@ import (
 )
 
 type RelayConfig struct {
-	CatchupDisabled bool `fig:"catchup_disabled"`
+	CatchupDisabled bool   `fig:"catchup_disabled"`
+	SourceContract  string `fig:"source_contract"`
 }
 
 func (c *config) Relay() RelayConfig {

internal/services/ingester/state_transfer.go

@@ -14,18 +14,20 @@ import (
 )
 
 type stateIngester struct {
-	log        *logan.Entry
-	rarimocore rarimocore.QueryClient
-	storage    *pg.Storage
+	log            *logan.Entry
+	rarimocore     rarimocore.QueryClient
+	storage        *pg.Storage
+	sourceContract string
 }
 
 var _ Processor = &stateIngester{}
 
 func NewStateIngester(cfg config.Config) Processor {
 	return &stateIngester{
-		log:        cfg.Log(),
-		rarimocore: rarimocore.NewQueryClient(cfg.Cosmos()),
-		storage:    pg.New(cfg.DB()),
+		log:            cfg.Log(),
+		rarimocore:     rarimocore.NewQueryClient(cfg.Cosmos()),
+		storage:        pg.New(cfg.DB()),
+		sourceContract: cfg.Relay().SourceContract,
 	}
 }
 
@@ -106,6 +108,11 @@ func (s *stateIngester) trySave(ctx context.Context, operation rarimocore.Operat
 			})
 		}
 
+		if op.Contract != s.sourceContract {
+			s.log.WithField("operation_index", operation.Index).Info("Invalid state contract. Skipping")
+			return nil
+		}
+
 		err = s.storage.StateQ().UpsertCtx(ctx, &data.State{
 			ID:        op.State,
 			Operation: operation.Index,