Include metadata_registry in the E2E regression tests

analyzer/metadata_registry/metadata_registry.go

@@ -32,31 +32,34 @@ const MetadataRegistryAnalyzerName = "metadata_registry"
 type processor struct {
 	target storage.TargetStorage
 	logger *log.Logger
+
+	regCfg registry.GitConfig
 }
 
 var _ item.ItemProcessor[struct{}] = (*processor)(nil)
 
 func NewAnalyzer(
-	cfg config.ItemBasedAnalyzerConfig,
+	cfg config.MetadataRegistryConfig,
 	target storage.TargetStorage,
 	logger *log.Logger,
 ) (analyzer.Analyzer, error) {
 	logger.Info("Starting metadata_registry analyzer")
 	if cfg.Interval == 0 {
 		cfg.Interval = 2 * time.Minute
 	}
-	if cfg.Interval < time.Minute {
-		return nil, fmt.Errorf("invalid interval %s, metadata registry interval must be at least 1 minute", cfg.Interval)
-	}
 	logger = logger.With("analyzer", MetadataRegistryAnalyzerName)
 	p := &processor{
 		target: target,
 		logger: logger,
+		regCfg: registry.NewGitConfig(),
+	}
+	if cfg.RepositoryBranch != "" {
+		p.regCfg.Branch = cfg.RepositoryBranch
 	}
 
 	return item.NewAnalyzer[struct{}](
 		MetadataRegistryAnalyzerName,
-		cfg,
+		cfg.ItemBasedAnalyzerConfig,
 		p,
 		target,
 		logger,
@@ -68,7 +71,7 @@ func (p *processor) GetItems(ctx context.Context, limit uint64) ([]struct{}, err
 }
 
 func (p *processor) ProcessItem(ctx context.Context, batch *storage.QueryBatch, item struct{}) error {
-	gp, err := registry.NewGitProvider(registry.NewGitConfig())
+	gp, err := registry.NewGitProvider(p.regCfg)
 	if err != nil {
 		return fmt.Errorf("failed to create Git registry provider: %s", err)
 	}

cmd/analyzer/analyzer.go

@@ -612,7 +612,7 @@ func NewService(cfg *config.AnalysisConfig) (*Service, error) { //nolint:gocyclo
 	}
 	if cfg.Analyzers.MetadataRegistry != nil {
 		analyzers, err = addAnalyzer(analyzers, err, "" /*syncTag*/, func() (A, error) {
-			return metadata_registry.NewAnalyzer(cfg.Analyzers.MetadataRegistry.ItemBasedAnalyzerConfig, dbClient, logger)
+			return metadata_registry.NewAnalyzer(*cfg.Analyzers.MetadataRegistry, dbClient, logger)
 		})
 	}
 	if cfg.Analyzers.ValidatorStakingHistory != nil {

config/config.go

@@ -523,13 +523,12 @@ type EvmAbiAnalyzerConfig struct {
 // MetadataRegistryConfig is the configuration for the metadata registry analyzer.
 type MetadataRegistryConfig struct {
 	ItemBasedAnalyzerConfig `koanf:",squash"`
+
+	RepositoryBranch string `koanf:"repository_branch"`
 }
 
 // Validate validates the configuration.
 func (cfg *MetadataRegistryConfig) Validate() error {
-	if cfg.Interval < time.Minute {
-		return fmt.Errorf("metadata registry interval must be at least 1 minute")
-	}
 	return nil
 }