Method handleSubscription

server/topic.go:284–333

Session subscribed to a topic, created == true if topic was just created and {pres} needs to be announced

(h *Hub, sreg *sessionJoin)

// Session subscribed to a topic, created == true if topic was just created and {pres} needs to be announced
func (t *Topic) handleSubscription(h *Hub, sreg *sessionJoin) error {

	getWhat := parseMsgClientMeta(sreg.pkt.Get)

	if err := t.subCommonReply(h, sreg.sess, sreg.pkt, (getWhat&constMsgMetaInfo != 0), sreg.created); err != nil {
		return err
	}

	// New P2P topic is a special case. It requires an invite/notification for the second person
	if sreg.created && t.cat == TopicCat_P2P {
		log.Println("about to generate invite for ", t.name)
		for uid, pud := range t.perUser {
			if uid != sreg.sess.uid {
				if pud.modeWant&types.ModeBanned != 0 {
					break
				}

				var action types.InviteAction
				if pud.modeWant == types.ModeNone {
					action = types.InvJoin
				} else {
					action = types.InvInfo
				}
				log.Println("sending invite to ", uid.UserId())
				h.route <- t.makeInvite(uid, uid, sreg.sess.uid, action, pud.modeWant, pud.modeGiven, nil /* Public */)
				break
			}
		}
	}

	if sreg.loaded {
		t.presPubTopicOnline()
	}

	if t.cat == TopicCat_Me {
		// User attached to !me topic, get the currect state of topics he is interested in
		t.presSnapshot()
	}

	if getWhat&constMsgMetaSub != 0 {
		// Send get.sub response as a separate {meta} packet
		t.replyGetSub(sreg.sess, sreg.pkt.Id)
	}

	if getWhat&constMsgMetaData != 0 {
		// Send get.data response as {data} packets
		t.replyGetData(sreg.sess, sreg.pkt.Id, sreg.pkt.Browse)
	}
	return nil
}

// subCommonReply generates a response to a subscription request
func (t *Topic) subCommonReply(h *Hub, sess *Session, pkt *MsgClientSub, sendInfo bool, created bool) error {