habitica/src/app/party.coffee

_ = require('underscore')
character = require './character'
browser = require './browser'

partyUnsubscribe = (model, cb) ->
  if window?
    throw "unsubscribe requires cb" unless cb?
    subs = model._subs()
    subs.concat cb
    model.unsubscribe.apply(model, subs)
  else
    cb()

###
  Subscribe to the user, the users's party (meta), and the party's members. 3 subscriptions.
  If the user is solo, just subscribe to the user. If in a an empty party, just subscribe to the party. If full party,
  subscribe to everything.

  Note a strange hack - later model.queries override previous model.queries'
  returned fields. Aka, we need this here otherwise we only get the "public" fields for the current user, which
  are defined in model.query('users').party(). So we need to subscribe to the main user last
###
module.exports.partySubscribe = partySubscribe = (model, cb) ->

  # unsubscribe from everything - we're starting over
  # partyUnsubscribe model, ->

  # Restart subscription to the main user
  selfQ = model.query('users').withId(model.get('_userId') or model.session.userId)
  selfQ.subscribe (err, self) ->
    throw err if err
    u = self.at(0)
    uObj = u.get()

    finished = ->
      model.unsubscribe selfQ, ->
        selfQ.subscribe (err, self) ->
          model.ref '_user', self.at(0)
          browser.resetDom(model) if window?
          cb() if cb?

    ## (1) User is solo, just return that subscription
    unless uObj.party?.current
      return finished()


    # User in a party
    partiesQ = model.query('parties').withId(uObj.party.current)
    partiesQ.fetch (err, res) ->
      throw err if err
      p = res.at(0)
      model.ref '_party', p
      ids = p.get('members')

      # 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")
      #  debugger
      #  membersSubscribe model, ids

      ## (2) Party has no members, just subscribe to the party itself
      if _.isEmpty(ids)
        return finished()

      else
        ## (3) Party has members, subscribe to those users too
        membersQ = model.query('users').party(ids)
        membersQ.fetch (err, members) ->
          throw err if err
          model.ref '_partyMembers', members
          finished()

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

  user.on 'set', 'flags.partyEnabled', (captures, args) ->
    return unless captures == true
    $('.main-avatar').popover('destroy') #remove previous popovers
    html = """
           <div class='party-system-popover'>
           <img src='/img/party-unlocked.png' style='float:right;padding:5px;' />
           Congratulations, you have unlocked the Party System! You can now group with your friends by adding their User Ids.
           <a href='#' onClick="$('.main-avatar').popover('hide');return false;">[Close]</a>
           </div>
           """
    $('.main-avatar').popover
      title: "Party System Unlocked"
      placement: 'bottom'
      trigger: 'manual'
      html: true
      content: html
    $('.main-avatar').popover 'show'

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

  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}, ->
      setTimeout (-> window.location.reload true), 10
#    partySubscribe model, -> $('#party-modal').modal('show')

  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', '', ->
          setTimeout (-> window.location.reload true), 10
        #partySubscribe model

  appExports.partyAccept = ->
    partyId = user.get('party.invitation')
    user.set 'party.invitation', null
    user.set 'party.current', partyId
#    model.push "parties.#{partyId}.members", user.get('id'), -> #FIXME why this not working?
    model.query('parties').withId(partyId).fetch (err, p) ->
      members = p.at(0).get('members')
      members.push user.get('id')
      p.at(0).set 'members', members, ->
        debugger
        window.location.reload true
#    partySubscribe model, ->
#      p = model.at('_party')
#      p.push 'members', user.get('id')

  appExports.partyReject = ->
    user.set 'party.invitation', null
    browser.resetDom(model)
    # 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)
        model.del "parties.#{id}" # last member out, kill the party
        setTimeout (-> window.location.reload true), 10
      else
        setTimeout (-> window.location.reload true), 10
#    model.set '_party', null
#    model.set '_partyMembers', null
#    partyUnsubscribe model, ->
#      selfQ = model.query('users').withId(model.get('_userId') or model.session.userId)
#      selfQ.subscribe (err, u) ->
#        model.ref '_user', u.at(0)
#        browser.resetDom model