@@ -8,15 +8,15 @@ import { getIndexProviderPeerIdFromSmartContract } from './smart-contract-client
88 * @param {function } [options.rpcFn]
99 * @returns {Promise<string> } The chain head Cid
1010 */
11- async function getChainHead ( { maxAttempts = 5 , rpcFn } = { } ) {
11+ async function getChainHead ( { maxAttempts = 5 , rpcFn } = { } ) {
1212 try {
1313 const res = await retry ( ( ) => ( rpcFn ?? rpc ) ( 'Filecoin.ChainHead' ) , {
1414 // The maximum amount of attempts until failure.
1515 maxAttempts,
1616 // The initial and minimum amount of milliseconds between attempts.
1717 minTimeout : 5_000 ,
1818 // How much to backoff after each retry.
19- multiplier : 1.5
19+ multiplier : 1.5 ,
2020 } )
2121 return res . Cids
2222 } catch ( err ) {
@@ -35,12 +35,15 @@ async function getChainHead ({ maxAttempts = 5, rpcFn } = {}) {
3535 * @param {number } [options.maxAttempts]
3636 * @returns {Promise<string> } Miner's PeerId, e.g. `12D3KooWMsPmAA65yHAHgbxgh7CPkEctJHZMeM3rAvoW8CZKxtpG`
3737 */
38- export async function getIndexProviderPeerId ( minerId , { maxAttempts = 5 , smartContract, rpcFn } = { } ) {
38+ export async function getIndexProviderPeerId (
39+ minerId ,
40+ { maxAttempts = 5 , smartContract, rpcFn } = { } ,
41+ ) {
3942 try {
40- // Make a concurrent request to both sources: FilecoinMinerInfo and smart contract
43+ // Make a concurrent request to both sources: FilecoinMinerInfo and smart contract
4144 const [ minerInfoResult , contractResult ] = await Promise . all ( [
4245 getIndexProviderPeerIdFromFilecoinMinerInfo ( minerId , { maxAttempts, rpcFn } ) ,
43- getIndexProviderPeerIdFromSmartContract ( minerId , { smartContract } )
46+ getIndexProviderPeerIdFromSmartContract ( minerId , { smartContract } ) ,
4447 ] )
4548 // Check contract result first
4649 if ( contractResult ) {
@@ -55,11 +58,13 @@ export async function getIndexProviderPeerId (minerId, { maxAttempts = 5, smartC
5558 }
5659
5760 // Handle the case where both failed
58- throw new Error ( `Failed to obtain Miner's Index Provider PeerID.\nSmartContract query result: ${ contractResult } ${ minerInfoResult } )
61+ throw new Error (
62+ `Failed to obtain Miner's Index Provider PeerID.\nSmartContract query result: ${ contractResult } ${ minerInfoResult } ,
63+ )
5964 } catch ( error ) {
6065 console . error ( 'Error fetching PeerID:' , error )
6166 throw Error ( `Error fetching PeerID for miner ${ minerId } , {
62- cause : error
67+ cause : error ,
6368 } )
6469 }
6570}
@@ -71,7 +76,10 @@ export async function getIndexProviderPeerId (minerId, { maxAttempts = 5, smartC
7176 * @param {function } [options.rpcFn]
7277 * @returns {Promise<string> } Miner's PeerId, e.g. `12D3KooWMsPmAA65yHAHgbxgh7CPkEctJHZMeM3rAvoW8CZKxtpG`
7378 */
74- export async function getIndexProviderPeerIdFromFilecoinMinerInfo ( minerId , { maxAttempts = 5 , rpcFn } = { } ) {
79+ export async function getIndexProviderPeerIdFromFilecoinMinerInfo (
80+ minerId ,
81+ { maxAttempts = 5 , rpcFn } = { } ,
82+ ) {
7583 const chainHead = await getChainHead ( { maxAttempts, rpcFn } )
7684 try {
7785 const res = await retry ( ( ) => ( rpcFn ?? rpc ) ( 'Filecoin.StateMinerInfo' , minerId , chainHead ) , {
@@ -80,7 +88,7 @@ export async function getIndexProviderPeerIdFromFilecoinMinerInfo (minerId, { ma
8088 // The initial and minimum amount of milliseconds between attempts.
8189 minTimeout : 5_000 ,
8290 // How much to backoff after each retry.
83- multiplier : 1.5
91+ multiplier : 1.5 ,
8492 } )
8593 return res . PeerId
8694 } catch ( err ) {
@@ -97,23 +105,23 @@ export async function getIndexProviderPeerIdFromFilecoinMinerInfo (minerId, { ma
97105 * @param {string } method
98106 * @param {unknown[] } params
99107 */
100- async function rpc ( method , ...params ) {
108+ async function rpc ( method , ...params ) {
101109 const req = new Request ( RPC_URL , {
102110 method : 'POST' ,
103111 headers : {
104112 'content-type' : 'application/json' ,
105113 accepts : 'application/json' ,
106- authorization : `Bearer ${ RPC_AUTH }
114+ authorization : `Bearer ${ RPC_AUTH } ,
107115 } ,
108116 body : JSON . stringify ( {
109117 jsonrpc : '2.0' ,
110118 id : 1 ,
111119 method,
112- params
113- } )
120+ params,
121+ } ) ,
114122 } )
115123 const res = await fetch ( req , {
116- signal : AbortSignal . timeout ( 60_000 )
124+ signal : AbortSignal . timeout ( 60_000 ) ,
117125 } )
118126
119127 if ( ! res . ok ) {
0 commit comments