var pull = require('pull-stream')
var computed = require('mutant/computed')
var MutantPullReduce = require('mutant-pull-reduce')
var nest = require('depnest')
var ref = require('ssb-ref')

var throttle = require('mutant/throttle')

exports.needs = nest({
  'sbot.pull.userFeed': 'first'
})

exports.gives = nest({
  'channel.obs.subscribed': true,
  'sbot.hook.publish': true
})

exports.create = function (api) {
  var cache = {}
  var reducers = {}

  return nest({
    'channel.obs.subscribed': subscribed,
    'sbot.hook.publish': function (msg) {
      if (isChannelSubscription(msg)) {
        if (msg.value.content.channel && reducers[msg.value.author]) {
          reducers[msg.value.author].push(msg)
        }
      }
    }
  })

  function subscribed (userId) {
    if (!ref.isFeed(userId)) throw new Error('a feed id must be specified')
    if (cache[userId]) {
      return cache[userId]
    } else {
      var stream = pull(
        api.sbot.pull.userFeed({id: userId, live: true}),
        pull.filter((msg) => {
          return !msg.value || msg.value.content.type === 'channel'
        })
      )

      var latestTimestamps = {}

      var result = MutantPullReduce(stream, (result, msg) => {
        var c = msg.value.content
        if (c.type === 'channel' && typeof c.channel === 'string') {
          var channel = c.channel.trim()
          if (channel && msg.value.timestamp > (latestTimestamps[channel] || 0)) {
            if (channel) {
              if (typeof c.subscribed === 'boolean') {
                latestTimestamps[channel] = msg.value.timestamp
                if (c.subscribed) {
                  result.add(channel)
                } else {
                  result.delete(channel)
                }
              }
            }
          }
        }
        return result
      }, {
        startValue: new Set(),
        nextTick: true
      })

      reducers[userId] = result

      var instance = throttle(result, 2000)
      instance.sync = result.sync

      instance.has = function (value) {
        return computed(instance, x => x.has(value))
      }

      cache[userId] = instance
      return instance
    }
  }
}

function isChannelSubscription (msg) {
  return msg.value && msg.value.content && msg.value.content.type === 'channel'
}