|
2 | 2 |
|
3 | 3 | const PeerInfo = require('peer-info')
|
4 | 4 | const PeerID = require('peer-id')
|
5 |
| -const dht = require('ipfs-api/src/dht') |
6 |
| -const swarm = require('ipfs-api/src/swarm') |
7 |
| -const refs = require('ipfs-api/src/refs') |
8 |
| -const defaultConfig = require('ipfs-api/src/utils/default-config') |
| 5 | +const dht = require('ipfs-http-client/src/dht') |
| 6 | +const swarm = require('ipfs-http-client/src/swarm') |
| 7 | +const refs = require('ipfs-http-client/src/files-regular/refs') |
| 8 | +const defaultConfig = require('ipfs-http-client/src/utils/default-config') |
9 | 9 | const series = require('async/series')
|
10 | 10 | const parallel = require('async/parallel')
|
11 | 11 | const reflect = require('async/reflect')
|
@@ -79,31 +79,9 @@ class DelegatedContentRouting {
|
79 | 79 |
|
80 | 80 | options.maxTimeout = options.maxTimeout || DEFAULT_MAX_TIMEOUT
|
81 | 81 |
|
82 |
| - this.dht.findprovs(key.toBaseEncodedString(), { |
| 82 | + this.dht.findProvs(key.toString(), { |
83 | 83 | timeout: `${options.maxTimeout}ms` // The api requires specification of the time unit (s/ms)
|
84 |
| - }, (err, results) => { |
85 |
| - if (err) { |
86 |
| - return callback(err) |
87 |
| - } |
88 |
| - |
89 |
| - // cleanup result from ipfs-api |
90 |
| - const infos = [] |
91 |
| - results |
92 |
| - .filter((res) => Boolean(res.Responses)) |
93 |
| - .forEach((res) => { |
94 |
| - res.Responses.forEach((raw) => { |
95 |
| - const info = new PeerInfo( |
96 |
| - PeerID.createFromB58String(raw.ID) |
97 |
| - ) |
98 |
| - if (raw.Addrs) { |
99 |
| - raw.Addrs.forEach((addr) => info.multiaddrs.add(addr)) |
100 |
| - } |
101 |
| - infos.push(info) |
102 |
| - }) |
103 |
| - }) |
104 |
| - |
105 |
| - callback(null, infos) |
106 |
| - }) |
| 84 | + }, callback) |
107 | 85 | }
|
108 | 86 |
|
109 | 87 | /**
|
@@ -138,7 +116,7 @@ class DelegatedContentRouting {
|
138 | 116 | cb()
|
139 | 117 | }),
|
140 | 118 | (cb) => {
|
141 |
| - this.refs(key.toBaseEncodedString(), { recursive: true }, cb) |
| 119 | + this.refs(key.toString(), { recursive: true }, cb) |
142 | 120 | }
|
143 | 121 | ], (err) => callback(err))
|
144 | 122 | }
|
|
0 commit comments