Index Provider integration

api/api.go

@@ -1,5 +1,15 @@
 package api
 
+import (
+	"context"
+
+	datatransfer "github.com/filecoin-project/go-data-transfer"
+	"github.com/filecoin-project/go-fil-markets/retrievalmarket"
+	lapi "github.com/filecoin-project/lotus/api"
+	"github.com/ipfs/go-cid"
+	"github.com/libp2p/go-libp2p-core/peer"
+)
+
 //                       MODIFYING THE API INTERFACE
 //
 // When adding / changing methods in this file:
@@ -15,6 +25,30 @@ type Boost interface {
 	Market
 	Common
 	Net
+
+	// MethodGroup: LegacyMarket
+
+	MarketListRetrievalDeals(ctx context.Context) ([]retrievalmarket.ProviderDealState, error)                                    //perm:read
+	MarketSetRetrievalAsk(ctx context.Context, rask *retrievalmarket.Ask) error                                                   //perm:admin
+	MarketGetRetrievalAsk(ctx context.Context) (*retrievalmarket.Ask, error)                                                      //perm:read
+	MarketListDataTransfers(ctx context.Context) ([]lapi.DataTransferChannel, error)                                              //perm:write
+	MarketDataTransferUpdates(ctx context.Context) (<-chan lapi.DataTransferChannel, error)                                       //perm:write
+	MarketRestartDataTransfer(ctx context.Context, transferID datatransfer.TransferID, otherPeer peer.ID, isInitiator bool) error //perm:write
+
+	DealsConsiderOnlineStorageDeals(context.Context) (bool, error)      //perm:admin
+	DealsSetConsiderOnlineStorageDeals(context.Context, bool) error     //perm:admin
+	DealsConsiderOnlineRetrievalDeals(context.Context) (bool, error)    //perm:admin
+	DealsSetConsiderOnlineRetrievalDeals(context.Context, bool) error   //perm:admin
+	DealsPieceCidBlocklist(context.Context) ([]cid.Cid, error)          //perm:admin
+	DealsSetPieceCidBlocklist(context.Context, []cid.Cid) error         //perm:admin
+	DealsConsiderOfflineStorageDeals(context.Context) (bool, error)     //perm:admin
+	DealsSetConsiderOfflineStorageDeals(context.Context, bool) error    //perm:admin
+	DealsConsiderOfflineRetrievalDeals(context.Context) (bool, error)   //perm:admin
+	DealsSetConsiderOfflineRetrievalDeals(context.Context, bool) error  //perm:admin
+	DealsConsiderVerifiedStorageDeals(context.Context) (bool, error)    //perm:admin
+	DealsSetConsiderVerifiedStorageDeals(context.Context, bool) error   //perm:admin
+	DealsConsiderUnverifiedStorageDeals(context.Context) (bool, error)  //perm:admin
+	DealsSetConsiderUnverifiedStorageDeals(context.Context, bool) error //perm:admin
 }
 
 // DagstoreShardInfo is the serialized form of dagstore.DagstoreShardInfo that

api/market.go

@@ -3,9 +3,8 @@ package api
 import (
 	"context"
 
-	"github.com/google/uuid"
-
 	smtypes "github.com/filecoin-project/boost/storagemarket/types"
+	"github.com/google/uuid"
 )
 
 //                       MODIFYING THE API INTERFACE
@@ -24,6 +23,7 @@ type Market interface {
 
 	MarketDummyDeal(context.Context, smtypes.DealParams) (*ProviderDealRejectionInfo, error) //perm:admin
 	Deal(ctx context.Context, dealUuid uuid.UUID) (*smtypes.ProviderDealState, error)        //perm:admin
+	IndexerAnnounceAllDeals(ctx context.Context) error                                       //perm:admin
 }
 
 // ProviderDealRejectionInfo is the information sent by the Storage Provider

api/net.go

@@ -22,7 +22,6 @@ import (
 
 type Net interface {
 	// MethodGroup: Net
-
 	NetConnectedness(context.Context, peer.ID) (network.Connectedness, error) //perm:read
 	NetPeers(context.Context) ([]peer.AddrInfo, error)                        //perm:read
 	NetConnect(context.Context, peer.AddrInfo) error                          //perm:write

cli/cmd.go

@@ -8,4 +8,5 @@ import (
 var GetBoostAPI = cliutil.GetBoostAPI
 var GetFullNodeAPI = lcliutil.GetFullNodeAPI
 
+var ReqContext = cliutil.ReqContext
 var DaemonContext = cliutil.DaemonContext

cli/util/api.go

@@ -211,7 +211,7 @@ func GetBoostAPI(ctx *cli.Context, opts ...GetBoostOption) (api.Boost, jsonrpc.C
 func GetRawAPI(ctx *cli.Context, t repo.RepoType, version string) (string, http.Header, error) {
 	ainfo, err := GetAPIInfo(ctx, t)
 	if err != nil {
-		return "", nil, xerrors.Errorf("could not get API info for %s: %w", t, err)
+		return "", nil, xerrors.Errorf("could not get API info for %s: %w", t.Type(), err)
 	}
 
 	addr, err := ainfo.DialArgs(version)