add library

Author: NikolasHaimerl

lib/miner-info.js

@@ -23,10 +23,11 @@ const smartContractClient = new ethers.Contract(
  * @returns {Promise<string>} The peer ID of the miner.
  */
 export async function getMinerPeerId (minerId, { maxAttempts = 5 } = {}) {
-  const { peerId } = await getIndexProviderPeerId(minerId, smartContractClient, {
+  const { peerId, source } = await getIndexProviderPeerId(minerId, smartContractClient, {
     rpcUrl: RPC_URL,
     rpcAuth: RPC_AUTH,
     maxAttempts
   })
+  console.log(`Peer ID fetched from ${source}.`)
   return peerId
-}
+}

lib/spark.js

@@ -4,7 +4,7 @@ import { ActivityState } from './activity-state.js'
 import { SPARK_VERSION, MAX_CAR_SIZE, APPROX_ROUND_LENGTH_IN_MS } from './constants.js'
 import { queryTheIndex } from './ipni-client.js'
 import { assertOkResponse } from './http-assertions.js'
-import { getIndexProviderPeerId as defaultGetIndexProvider } from './miner-info.js'
+import { getMinerPeerId as defaultGetIndexProvider } from './miner-info.js'
 import { multiaddrToHttpUrl } from './multiaddr.js'
 import { Tasker } from './tasker.js'
 

manual-check.js

@@ -4,7 +4,7 @@
 //
 
 import Spark, { getRetrievalUrl } from './lib/spark.js'
-import { getIndexProviderPeerId as defaultGetIndexProvider } from './lib/miner-info.js'
+import { getMinerPeerId as defaultGetIndexProvider } from './lib/miner-info.js'
 
 // The task to check, replace with your own values
 const task = {

test.js

@@ -4,5 +4,4 @@ import './test/miner-info.test.js'
 import './test/multiaddr.test.js'
 
 import './test/integration.js'
-import './test/spark.js'
-import './test/smart-contract-client.test.js'
+import './test/spark.js'

test/miner-info.test.js

@@ -1,21 +1,28 @@
 import { test } from 'zinnia:test'
-import { assertMatch, AssertionError } from 'zinnia:assert'
-import { getIndexProviderPeerId } from '../lib/miner-info.js'
+import { assertMatch, AssertionError, assert, assertEquals } from 'zinnia:assert'
+import { getMinerPeerId } from '../lib/miner-info.js'
 
 const KNOWN_MINER_ID = 'f0142637'
 
 test('get peer id of a known miner', async () => {
-  const result = await getIndexProviderPeerId(KNOWN_MINER_ID)
+  const result = await getMinerPeerId(KNOWN_MINER_ID)
   assertMatch(result, /^12D3KooW/)
 })
 
 test('get peer id of a miner that does not exist', async () => {
   try {
-    const result = await getIndexProviderPeerId('f010', { maxAttempts: 1 })
+    const result = await getMinerPeerId('f010', { maxAttempts: 1 })
     throw new AssertionError(
-      `Expected "getIndexProviderPeerId()" to fail, but it resolved with "${result}" instead.`
+      `Expected "getMinerPeerId()" to fail, but it resolved with "${result}" instead.`
     )
   } catch (err) {
     assertMatch(err.toString(), /Error fetching index provider PeerID for miner f010/)
   }
 })
+
+test('getMinerPeerId returns correct peer id for miner f03303347', async () => {
+  const peerId = await getMinerPeerId('f03303347')
+
+  assert(typeof peerId === 'string', 'Expected peerId to be a string')
+  assertEquals(peerId, '12D3KooWJ91c6xQshrNe7QAXPFAaeRrHWq2UrgXGPf8UmMZMwyZ5')
+})