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

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

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(
      pull.values([key]),
      pull.asyncMap((key, cb) => api.sbot.async.get(key, cb)),
      pull.asyncMap((msg) => hydrate(msg, key, cb)),
      pull.drain(cb)
    )
  }
  
  function getAll() {
    return pull(
      api.sbot.pull.messagesByType({ type: 'bookclub', fillCache: true, keys: true })
    )
  }

  // 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.drain(msg => {
        if (msg.content.type !== "bookclub-update") return

        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, key, cb)
  {
    var book = {
      key: key,
      common: msg.content.common,
      subjective: {}
    }
    book.subjective[msg.author] = msg.content.subjective ||
      { rating: '', ratingType: '', review: '', shelve: '', genre: '' }

    applyAmends(book, cb)
  }
}