CID gravity connector

cmd/curio/tasks/tasks.go

@@ -218,15 +218,10 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps, shutdownChan chan
 
 	{
 		// Market tasks
-		sc, err := slrLazy.Val()
-		if err != nil {
-			return nil, err
-		}
-
 		if cfg.Subsystems.EnableDealMarket {
 			// Main market poller should run on all nodes
-			dm := storage_market.NewCurioStorageDealMarket(miners, db, cfg, sc, full)
-			err = dm.StartMarket(ctx)
+			dm := storage_market.NewCurioStorageDealMarket(miners, db, cfg, si, full, as)
+			err := dm.StartMarket(ctx)
 			if err != nil {
 				return nil, err
 			}
@@ -249,6 +244,11 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps, shutdownChan chan
 			go libp2p.NewDealProvider(ctx, db, cfg, dm.MK12Handler, full, sender, miners, machine, shutdownChan)
 		}
 
+		sc, err := slrLazy.Val()
+		if err != nil {
+			return nil, err
+		}
+
 		idxMax := taskhelp.Max(cfg.Subsystems.IndexingMaxTasks)
 
 		indexingTask := indexing.NewIndexingTask(db, sc, iStore, pp, cfg, idxMax)

deps/config/types.go

@@ -693,6 +693,14 @@ type MK12Config struct {
 
 	// DenyOfflineDeals determines if the storage provider will accept offline deals
 	DenyOfflineDeals bool
+
+	// CIDGravityToken is the authorization token to use for CIDGravity filters.
+	// If empty then CIDGravity filters are not called.
+	CIDGravityToken string
+
+	// DefaultCIDGravityAccept when set to true till accept deals when CIDGravity service is not available.
+	// Default behaviors is to reject the deals
+	DefaultCIDGravityAccept bool
 }
 
 type PieceLocatorConfig struct {

documentation/en/configuration/default-curio-configuration.md

@@ -482,6 +482,18 @@ description: The default curio configuration
       # type: bool
       #DenyOfflineDeals = false
 
+      # CIDGravityToken is the authorization token to use for CIDGravity filters.
+      # If empty then CIDGravity filters are not called.
+      #
+      # type: string
+      #CIDGravityToken = ""
+
+      # DefaultCIDGravityAccept when set to true till accept deals when CIDGravity service is not available.
+      # Default behaviors is to reject the deals
+      #
+      # type: bool
+      #DefaultCIDGravityAccept = false
+
     [Market.StorageMarketConfig.IPNI]
       # Disable set whether to disable indexing announcement to the network and expose endpoints that
       # allow indexer nodes to process announcements. Default: False