_ = 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 info like party name, member ids, etc), and the party's members. 3 subscriptions. 1) If the user is solo, just subscribe to the user. 2) If in a an empty party, just subscribe to the user & party meta. 3) If full party, subscribe to everything. ### module.exports.partySubscribe = partySubscribe = (page, model, params, next, 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 # see http://goo.gl/TPYIt selfQ.subscribe (err, self) -> return next(err) if err u = self.at(0) uObj = u.get() # Attempted handling for 'party of undefined' error, which is caused by bustedSession (see derby-auth). # Theoretically simply reloading the page should restore model.at('_userId') and the second load should work just fine # bustedSession victims might hit a redirection loop if I'm wrong :/ return page.redirect('/') unless uObj ## (1) User is solo, just return that subscription unless uObj.party?.current? model.ref '_user', u return cb() ### Note this strange hack - we subscribe to queries incrementally. First self, then party, then party members. Party members come with limited fields, so you can't hack their stuff. Strangely, subscribing to the members after already subscribing to self limits self's fields to the fields which members are limited to. As a result, we have to re-subscribe to self to get all the fields (otherwise everything breaks). Weirdly, this last subscription doesn't do the opposite - granting all the fields back to members. I dont' know what's going on here Another issue: `model.unsubscribe(selfQ)` would seem to mitigate the above, so we at least don't have a stray subscription floating around - but alas, it doesn't seem to work (or at least never calls the callback) ### finished = -> # model.unsubscribe selfQ, -> selfQ.subscribe (err, self) -> return next(err) if err model.ref '_user', self.at(0) cb() # User in a party partiesQ = model.query('parties').withId(uObj.party.current) partiesQ.fetch (err, res) -> return next(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) -> return next(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 = """
Congratulations, you have unlocked the Party System! You can now group with your friends by adding their User Ids. [Close]
""" $('.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}, -> window.location.reload 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', '', -> window.location.reload true #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, -> 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) # last member out, kill the party model.del "parties.#{id}", -> window.location.reload true else window.location.reload true # model.set '_party', null # model.set '_partyMembers', null # partyUnsubscribe model, -> # selfQ = model.query('users').withId model.get('_userId') #or model.session.userId # see http://goo.gl/TPYIt # selfQ.subscribe (err, u) -> # model.ref '_user', u.at(0) # browser.resetDom model