blobs.js

var BlobsHttp = require('multiblob-http')
var Stack = require('stack')
var URL = require('url')
var pull = require('pull-stream')
var BoxStream = require('pull-box-stream')
var zeros = new Buffer(24); zeros.fill(0)

module.exports = function (sbot, opts) {
  var prefix = opts.prefix

  var handler = BlobsHttp(sbot.blobs, prefix, {size: false, transform: function (q) {
    if(q.unbox && /\.boxs$/.test(q.unbox)) {
      var key = new Buffer(q.unbox.replace(/\s/g, '+'), 'base64')
      if(key.length !== 32)
          return function (read) {
            return function (abort, cb) {
              read(new Error('key must be 32 bytes long'), cb)
            }
          }
      return BoxStream.createUnboxStream(
        new Buffer(key, 'base64'),
        zeros
      )
    }
    return pull.through()
  }})

  return function (req, res, next) {
    if(req.url.substring(0, prefix.length) !== prefix) return next()
    if(!(req.method === "GET" || req.method == 'HEAD')) return next()

    var u = URL.parse('http://makeurlparseright.com'+req.url)
    var hash = decodeURIComponent(u.pathname.substring((prefix+'/get/').length))
    //check if we don't already have this, tell blobs we want it, if necessary.
    sbot.blobs.has(hash, function (err, has) {
      if(has) handler(req, res, next)
      else sbot.blobs.want(hash, function (err, has) {
        handler(req, res, next)
      })
    })
  }
}