diff --git a/market/mk12/cidgravity.go b/market/mk12/cidgravity.go index f795ccda8..4724cc5cc 100644 --- a/market/mk12/cidgravity.go +++ b/market/mk12/cidgravity.go @@ -106,9 +106,9 @@ const cidGravityMinerCheckLabel = "cidg-miner-status-check" const agentName = "curio" var commonHeaders = http.Header{ - "X-Agent": []string{"curio-market-storage-filter"}, - "X-Agent-Version": []string{"1.0"}, - "Content-Type": []string{"application/json"}, + "X-CIDgravity-Agent": []string{"CIDgravity-storage-Connector"}, + "X-CIDgravity-Version": []string{"1.0"}, + "Content-Type": []string{"application/json"}, } func (m *MK12) cidGravityCheck(ctx context.Context, deal *ProviderDealState) (bool, string, error) { @@ -130,6 +130,9 @@ func (m *MK12) cidGravityCheck(ctx context.Context, deal *ProviderDealState) (bo } if lableStr == cidGravityMinerCheckLabel { req, err = http.NewRequest("POST", cidGravityMinerCheckUrl, bytes.NewBuffer(data)) + if err != nil { + return false, "", xerrors.Errorf("Error creating request: %v", err) + } } } else { req, err = http.NewRequest("POST", cidGravityDealCheckUrl, bytes.NewBuffer(data)) @@ -140,6 +143,8 @@ func (m *MK12) cidGravityCheck(ctx context.Context, deal *ProviderDealState) (bo // Add necessary headers req.Header = commonHeaders + req.Header.Set("X-API-KEY", m.cfg.Market.StorageMarketConfig.MK12.CIDGravityToken) + req.Header.Set("X-Address-ID", deal.ClientDealProposal.Proposal.Provider.String()) req.Header.Set("Authorization", m.cfg.Market.StorageMarketConfig.MK12.CIDGravityToken) // Execute the request