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.fetch (err, res) ->
      throw err if err
      u = res.at(0)
      uObj = u.get()

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

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


      # User in a party
      partiesQ = model.query('parties').withId(uObj.party.current)
      partiesQ.subscribe (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.subscribe (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}
    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', ''
        partySubscribe model

  appExports.partyAccept = ->
    user.set 'party.current', user.get('party.invitation')
    user.set 'party.invitation', null
    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)
      # last member out, kill the party
      model.del "parties.#{id}"
    model.set '_party', null
    model.set '_partyMembers', null
    setTimeout (-> window.location.reload true), 10
    return

    # This should handle not requiring a refresh, but alas.
    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


  #exports.partyDisband = ->