ssb-blobs/index.js

var create = require('./create')
var path = require('path')
var Inject = require('./inject')
var Set = require('./set')
var Level = require('level')

exports.manifest = {
  get: 'source',
  getSlice: 'source',
  add: 'sink',
  rm: 'async',
  ls: 'source',
  has: 'async',
  size: 'async',
  meta: 'async',
  want: 'async',
  push: 'async',
  changes: 'source',
  createWants: 'source',
  help: 'sync'
}

exports.name = 'blobs'

exports.version = require('./package.json').version

exports.permissions = {
  anonymous: { allow: ['has', 'get', 'getSlice', 'changes', 'createWants'] }
}

exports.init = function (sbot, config) {
  const level = Level(path.join(config.path, 'blobs_push'), { valueEncoding: 'json' })

  var blobs = Inject(
    create(path.join(config.path, 'blobs')),
    Set(level),
    sbot.id,
    config.blobs
  )

  sbot.on('rpc:connect', function (rpc) {
    if (rpc.id === sbot.id) return
    blobs._onConnect(rpc, rpc.id)
  })

  sbot.close.hook(function (fn, args) {
    level.close(() => fn(...args))
  })

  return blobs
}