const pull = require('pull-stream')
const nest = require('depnest')

exports.gives = nest({
  'book.pull': ['get', 'getAll', 'create', 'amend']
})

exports.needs = nest({
  'sbot.pull.messagesByType': 'first',
  'sbot.pull.links': 'first',
  'sbot.async.get': 'first'
})

exports.create = function (api) {

  return nest({
    'book.pull.get': get,
    'book.pull.getAll': getAll
  })
  
  function get(key, cb) {
    pull(
      api.sbot.async.get(key),
      pull.asyncMap(hydrate),
      pull.drain(cb)
    )
  }
  
  function getAll() {
    return pull(
      api.sbot.pull.messagesByType({ type: 'bookclub', fillCache: true, keys: false }),
      pull.asyncMap(hydrate)
    )
  }

  // internal

  function applyAmends(book, cb) {
    pull(
      api.sbot.pull.links({ dest: book.key }), // live: true
      pull.filter(data => data.key),
      pull.asyncMap((data, cb) => {
        api.sbot.async.get(data.key, cb)
      }),
      pull.collect((err, msgs) => { // for live use drain
        if (err) throw err

        msgs.forEach(msg => {
          book.common = Object.assign(book.common, msg.content.common)
          book.subjective[msg.author] = Object.assign(book.subjective[msg.author],
                                                      msg.content.subjective)
        })

        cb(book)
      })
    )
  }
  
  function hydrate(msg, cb)
  {
    var book = {
      key: msg.key,
      common: msg.content.common,
      subjective: {}
    }
    book.subjective[msg.author] = msg.content.subjective

    applyAmends(book, cb)
  }
}