resolve peerid
Signed-off-by: Ignacio Hagopian <jsign.uy@gmail.com>
This commit is contained in:
parent
9d17e0be9d
commit
7fd082e941
@ -208,8 +208,13 @@ func (a *API) ClientFindData(ctx context.Context, root cid.Cid) ([]api.QueryOffe
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (a *API) ClientMinerQueryOffer(ctx context.Context, payload cid.Cid, miner address.Address) (api.QueryOffer, error) {
|
func (a *API) ClientMinerQueryOffer(ctx context.Context, payload cid.Cid, miner address.Address) (api.QueryOffer, error) {
|
||||||
|
mi, err := a.StateMinerInfo(ctx, miner, types.EmptyTSK)
|
||||||
|
if err != nil {
|
||||||
|
return api.QueryOffer{}, err
|
||||||
|
}
|
||||||
rp := retrievalmarket.RetrievalPeer{
|
rp := retrievalmarket.RetrievalPeer{
|
||||||
Address: miner,
|
Address: miner,
|
||||||
|
ID: mi.PeerId,
|
||||||
}
|
}
|
||||||
return a.makeRetrievalQuery(ctx, rp, payload, retrievalmarket.QueryParams{}), nil
|
return a.makeRetrievalQuery(ctx, rp, payload, retrievalmarket.QueryParams{}), nil
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user