const nest = require('depnest')
const { h, Array: MutantArray, map, Struct, computed, watch, throttle, resolve } = require('mutant')
const Month = require('marama')

const pull = require('pull-stream')
const { isMsg } = require('ssb-ref')

exports.gives = nest({
  'app.page.calendar': true,
  'app.html.menuItem': true
})

exports.needs = nest({
  'app.sync.goTo': 'first',
  'keys.sync.id': 'first',
  'message.html.render': 'first',
  'sbot.async.get': 'first',
  'sbot.pull.stream': 'first'
})

exports.create = (api) => {
  return nest({
    'app.html.menuItem': menuItem,
    'app.page.calendar': calendarPage
  })

  function menuItem () {
    return h('a', {
      'ev-click': () => api.app.sync.goTo({ page: 'calendar' })
    }, '/calendar')
  }

  function calendarPage (location) {
    const d = startOfDay()
    const state = Struct({
      today: d,
      year: d.getFullYear(),
      events: MutantArray([]),
      attending: MutantArray([]),
      range: Struct({
        gte: d,
        lt: endOfDay(d)
      })
    })

    watch(state.year, year => getGatherings(year, state.events, api))
    watchAttending(state.attending, api)

    const page = h('CalendarPage', { title: '/calendar' }, [
      Calendar(state),
      Events(state, api)
    ])

    page.scroll = (i) => scroll(state.range, i)

    return page
  }
}

function scroll (range, i) {
  const { gte, lt } = resolve(range)

  if (isMonthInterval(gte, lt)) {
    range.gte.set(new Date(gte.getFullYear(), gte.getMonth() + i, gte.getDate()))
    range.lt.set(new Date(lt.getFullYear(), lt.getMonth() + i, lt.getDate()))
    return
  }

  if (isWeekInterval(gte, lt)) {
    range.gte.set(new Date(gte.getFullYear(), gte.getMonth(), gte.getDate() + 7 * i))
    range.lt.set(new Date(lt.getFullYear(), lt.getMonth(), lt.getDate() + 7 * i))
    return
  }

  range.gte.set(new Date(gte.getFullYear(), gte.getMonth(), gte.getDate() + i))
  range.lt.set(new Date(lt.getFullYear(), lt.getMonth(), lt.getDate() + i))

  function isMonthInterval (gte, lt) {
    return gte.getDate() === 1 && // 1st of month
      lt.getDate() === 1 && // to the 1st of the month
      gte.getMonth() + 1 === lt.getMonth() && // one month gap
      gte.getFullYear() === lt.getFullYear()
  }

  function isWeekInterval (gte, lt) {
    return gte.getDay() === 1 && // from monday
      lt.getDay() === 1 && // to just inside monday
      new Date(gte.getFullYear(), gte.getMonth(), gte.getDate() + 7).toISOString() === lt.toISOString()
  }
}

function Events (state, api) {
  return h('CalendarEvents', computed([state.events, state.range], (events, range) => {
    const keys = events
      .filter(ev => ev.date >= range.gte && ev.date < range.lt)
      .sort((a, b) => a.date - b.date)
      .map(ev => ev.data.key)

    const gatherings = MutantArray([])

    pull(
      pull.values(keys),
      pull.asyncMap((key, cb) => {
        api.sbot.async.get(key, (err, value) => {
          if (err) return cb(err)
          cb(null, {key, value})
        })
      }),
      pull.drain(msg => gatherings.push(msg))
    )

    return map(gatherings, g => api.message.html.render(g))
  }))
}

function watchAttending (attending, api) {
  const myKey = api.keys.sync.id()

  const query = [{
    $filter: {
      value: {
        author: myKey,
        content: {
          type: 'about',
          about: { $is: 'string' },
          attendee: { link: myKey }
        }
      }
    }
  }, {
    $map: {
      key: ['value', 'content', 'about'], // gathering
      rm: ['value', 'content', 'attendee', 'remove']
    }
  }]

  const opts = { reverse: false, live: true, query }

  pull(
    api.sbot.pull.stream(server => server.query.read(opts)),
    pull.filter(m => !m.sync),
    pull.filter(Boolean),
    pull.drain(({ key, rm }) => {
      var hasKey = attending.includes(key)

      if (!hasKey && !rm) attending.push(key)
      else if (hasKey && rm) attending.delete(key)
    })
  )
}

function getGatherings (year, events, api) {
  // gatherings specify times with `about` messages which have a startDateTime
  // NOTE - this gets a window of about messages around the current year but does not gaurentee
  //        that we got all events in this year (e.g. something booked 6 months agead would be missed)
  const query = [{
    $filter: {
      value: {
        timestamp: { // ordered by published time
          $gt: Number(new Date(year - 1, 11, 1)),
          $lt: Number(new Date(year + 1, 0, 1))
        },
        content: {
          type: 'about',
          startDateTime: {
            epoch: {$gt: 0}
          }
        }
      }
    }
  }, {
    $map: {
      key: ['value', 'content', 'about'], // gathering
      date: ['value', 'content', 'startDateTime', 'epoch']
    }
  }]

  const opts = { reverse: false, live: true, query }

  pull(
    api.sbot.pull.stream(server => server.query.read(opts)),
    pull.filter(m => !m.sync),
    pull.filter(r => isMsg(r.key) && Number.isInteger(r.date)),
    pull.map(r => {
      return { key: r.key, date: new Date(r.date) }
    }),
    pull.drain(({ key, date }) => {
      var target = events.find(ev => ev.data.key === key)
      if (target && target.date <= date) events.delete(target)

      events.push({ date, data: { key } })
    })
  )
}

// Thanks to nomand for the inspiration and code (https://github.com/nomand/Letnice),
// Calendar takes events of format { date: Date, data: { attending: Boolean, ... } }

const MONTH_NAMES = [ 'Ja', 'Fe', 'Ma', 'Ap', 'Ma', 'Ju', 'Ju', 'Au', 'Se', 'Oc', 'No', 'De' ]

function Calendar (state) {
  // TODO assert events is an Array of object
  // of form { date, data }

  return h('Calendar', [
    h('div.header', [
      h('div.year', [
        state.year,
        h('a', { 'ev-click': () => state.year.set(state.year() - 1) }, '-'),
        h('a', { 'ev-click': () => state.year.set(state.year() + 1) }, '+')
      ])
    ]),
    h('div.months', computed(throttle(state, 100), ({ today, year, events, attending, range }) => {
      events = events.map(ev => {
        ev.data.attending = attending.includes(ev.data.key)
        return ev
      })

      return Array(12).fill(0).map((_, i) => {
        const setMonthRange = (ev) => {
          onSelect({
            gte: new Date(year, i, 1),
            lt: new Date(year, i + 1, 1)
          })
        }

        return h('div.month', [
          h('div.month-name', { 'ev-click': setMonthRange }, MONTH_NAMES[i]),
          Month({ year, month: i + 1, events, range, onSelect, styles: {weekFormat: 'columns'} })
        ])
      })
    }))
  ])

  function onSelect ({ gte, lt }) {
    state.range.set({ gte, lt })
  }
}

function startOfDay (d = new Date()) {
  return new Date(d.getFullYear(), d.getMonth(), d.getDate())
}

function endOfDay (d = new Date()) {
  return new Date(d.getFullYear(), d.getMonth(), d.getDate() + 1)
}