habitica/src/app/party.coffee

_ = require('underscore')
schema = require './schema'

_subscriptions =
  party:
    query: null
    id: null
  members:
    query: null
    ids: null

module.exports.partySubscribe = partySubscribe = (model, id, cb) ->
  s = _subscriptions

  ###
  # Note, this tries to unsubscribe from previous similar subscriptions so we don't have a memory leak. However,
  # This causes the page to crash on refresh. We need to fix this in the future. Same goes for membersSubscribe
  if s.party.query? and id == s.party.id
    # No need to resubscribe, same parameters
    return cb(model.at('_party'))

  # already have a subscription, but we want a new one
  if s.party.query? and s.party.id != id
    s.party.query.unsubscribe()
    s.party.query = null
  ###

  # subscripe
  s.party.query = model.query('parties').withId(id)
  s.party.id = id
  s.party.query.subscribe (err, res) ->
    throw err if err
    p = res.at(0)
    model.ref '_party', p

    # FIXME this is the kicker right here. This isn't getting triggered, and it's the reason why we have to refresh
    # after every event. Get this working
    p.on '*', 'members', (ids) ->
      console.log("members listener got called")
      membersSubscribe model, ids

    membersSubscribe model, p.get('members'), (m) ->
      cb(p) if cb?


module.exports.membersSubscribe = membersSubscribe = (model, ids, cb) ->
  s = _subscriptions

  ### @see above
  if s.members.query? and !_.isEmpty(_.difference(s.members.ids, ids))
    # No need to resubscribe, same parameters
    return cb(model.at('_partyMembers'))

  # already have a subscription, but we want a new one
  if s.members.query? and _.isEmpty(_.difference(s.members.ids, ids))
    s.members.query.unsubscribe()
    s.members.query = null
  ###

  # subscripe
  s.members.query = model.query('users').party(ids)
  s.members.ids = ids
  s.members.query.subscribe (err, m) ->
    throw err if err
    model.ref '_partyMembers', m
    cb(m) if cb?

module.exports.app = (appExports, model) ->
  user = model.at('_user')

  model.on 'set', '_user.party.invitation', (id) ->
    partySubscribe(model, id) if id?

  appExports.partyCreate = ->
    newParty = model.get("_newParty")
    id = model.add 'parties', { name: newParty, leader: user.get('id'), members: [user.get('id')], invites:[] }
    user.set 'party', {current: id, invitation: null, leader: true}
    partySubscribe model, id

  appExports.partyInvite = ->
    id = model.get('_newPartyMember').replace(/[\s"]/g, '')
    return if _.isEmpty(id)

    obj = user.get()
    query = model.query('users').party([id])
    model.fetch query, (err, res) ->
      throw err if err
      u = res.at(0).get()
      if !u?.id?
        model.set "_view.partyError", "User with id #{id} not found."
        return
      else if u.party.current? or u.party.invitation?
        model.set "_view.partyError", "User already in a party or pending invitation."
        return
      else
        p = model.at '_party'
        p.push "invites", id
        model.set "users.#{id}.party.invitation", p.get('id')
        $.bootstrapGrowl "Invitation Sent."
        $('#party-modal').modal('hide')
        model.set '_newPartyMember', ''
        membersSubscribe model, p.get('members'), ->
          # TODO get subscriptions really working so we don't need to reload
          window.location.reload()

  appExports.partyAccept = ->
    invitation = user.get('party.invitation')
    partySubscribe model, invitation, (p) ->
      p.push 'members', user.get('id')
      user.set 'party.invitation', null
      user.set 'party.current', p.get('id')
      membersSubscribe model, p.get('members'), (m) ->
        window.location.reload()

  appExports.partyReject = ->
    user.set 'party.invitation', null
    model.set '_party', null

    # TODO splice parties.*.invites[key]
    # TODO notify sender

  appExports.partyLeave = ->
    id = user.set 'party.current', null
    p = model.at '_party'
    members = p.get('members')
    index = members.indexOf(user.get('id'))
    members.splice(index,1)
    p.set 'members', members
    if (members.length == 0)
      # last member out, kill the party
      model.del "parties.#{id}"
    #_subscriptions.party.query.unsubscribe()
    model.set '_party', null
    model.set '_partyMembers', null
    setTimeout window.location.reload, 1

  #exports.partyDisband = ->