| sbot.jsView |
|---|
| 173 | 173 … | }), |
| 174 | 174 … | addBlob: rec.async((stream, cb) => { |
| 175 | 175 … | return pull( |
| 176 | 176 … | stream, |
| 177 | | - Hash(function (err, id) { |
| 178 | | - if (err) return cb(err) |
| 179 | | - |
| 180 | | - var start = Date.now() |
| 181 | | - var n = 5 |
| 182 | | - next() |
| 183 | | - |
| 184 | | - function next () { |
| 185 | | - setTimeout(function () { |
| 186 | | - sbot.blobs.has(id, function (_, has) { |
| 187 | | - if (has) return cb(null, id) |
| 188 | | - if (n--) next() |
| 189 | | - else cb(new Error('write failed')) |
| 190 | | - }) |
| 191 | | - }, Date.now() - start) |
| 192 | | - } |
| 193 | | - }), |
| 194 | | - sbot.blobs.add() |
| 177 … | + sbot.blobs.add(cb) |
| 195 | 178 … | ) |
| 196 | 179 … | }), |
| 197 | 180 … | gossipConnect: rec.async(function (opts, cb) { |
| 198 | 181 … | sbot.gossip.connect(opts, cb) |
| 250 | 233 … | |
| 251 | 234 … | } |
| 252 | 235 … | } |
| 253 | 236 … | } |
| 254 | | - |
| 255 | | -function Hash (onHash) { |
| 256 | | - var buffers = [] |
| 257 | | - return pull.through(function (data) { |
| 258 | | - buffers.push(typeof data === 'string' |
| 259 | | - ? new Buffer(data, 'utf8') |
| 260 | | - : data |
| 261 | | - ) |
| 262 | | - }, function (err) { |
| 263 | | - if (err && !onHash) throw err |
| 264 | | - var b = buffers.length > 1 ? Buffer.concat(buffers) : buffers[0] |
| 265 | | - var h = '&' + ssbKeys.hash(b) |
| 266 | | - onHash && onHash(err, h) |
| 267 | | - }) |
| 268 | | -} |