larger bulk insert

Layr-Labs · Dec 7, 2024 · 7df463e · 7df463e
1 parent 6fe6952
commit 7df463e
Showing 1 changed file with 13 additions and 13 deletions.
diff --git a/pkg/indexer/restakedStrategies.go b/pkg/indexer/restakedStrategies.go
@@ -89,11 +89,11 @@ func (idx *Indexer) getAndInsertRestakedStrategies(
 		zap.Int("count", len(results)),
 		zap.Uint64("blockNumber", blockNumber),
 	)
+	strategiesToInsert := make([]*storage.OperatorRestakedStrategies, 0)
 	for _, result := range results {
 		avs := result.Avs
 		operator := result.Operator
 
-		strategiesToInsert := make([]*storage.OperatorRestakedStrategies, 0)
 		for _, restakedStrategy := range result.Results {
 			strategiesToInsert = append(strategiesToInsert, &storage.OperatorRestakedStrategies{
 				AvsDirectoryAddress: strings.ToLower(avsDirectoryAddress),
@@ -104,20 +104,20 @@ func (idx *Indexer) getAndInsertRestakedStrategies(
 				Strategy:            restakedStrategy.String(),
 			})
 		}
-		inserted, err := idx.MetadataStore.BulkInsertOperatorRestakedStrategies(strategiesToInsert)
-		if err != nil {
-			idx.Logger.Sugar().Errorw("Failed to save restaked strategies",
-				zap.Error(err),
-				zap.String("avsDirectoryAddress", avsDirectoryAddress),
-				zap.Uint64("blockNumber", blockNumber),
-			)
-			return err
-		}
-		idx.Logger.Sugar().Infow("Inserted restaked strategies",
-			zap.Int("insertedCount", len(inserted)),
-			zap.Int("inputCount", len(strategiesToInsert)),
+	}
+	inserted, err := idx.MetadataStore.BulkInsertOperatorRestakedStrategies(strategiesToInsert)
+	if err != nil {
+		idx.Logger.Sugar().Errorw("Failed to save restaked strategies",
+			zap.Error(err),
+			zap.String("avsDirectoryAddress", avsDirectoryAddress),
+			zap.Uint64("blockNumber", blockNumber),
 		)
+		return err
 	}
+	idx.Logger.Sugar().Infow("Inserted restaked strategies",
+		zap.Int("insertedCount", len(inserted)),
+		zap.Int("inputCount", len(strategiesToInsert)),
+	)
 	return nil
 }