Method subCommonReply

server/topic.go:336–371

subCommonReply generates a response to a subscription request

(h *Hub, sess *Session, pkt *MsgClientSub, sendInfo bool, created bool)

// subCommonReply generates a response to a subscription request
func (t *Topic) subCommonReply(h *Hub, sess *Session, pkt *MsgClientSub, sendInfo bool, created bool) error {
	log.Println("subCommonReply ", t.name)
	now := time.Now().UTC().Round(time.Millisecond)

	// The topic t is already initialized by the Hub

	var info, private interface{}
	var mode string

	if pkt.Sub != nil {
		if pkt.Sub.User != "" {
			log.Println("subCommonReply: msg.Sub.Sub.User is ", pkt.Sub.User)
			simpleByteSender(sess.send, ErrMalformed(pkt.Id, t.original, now))
			return errors.New("user id must not be specified")
		}

		info = pkt.Sub.Info
		mode = pkt.Sub.Mode
	}

	if pkt.Init != nil {
		private = pkt.Init.Private
	}

	if err := t.requestSub(h, sess, pkt.Id, mode, info, private); err != nil {
		return err
	}

	simpleByteSender(sess.send, NoErr(pkt.Id, t.original, now))

	if sendInfo {
		t.replyGetInfo(sess, pkt.Id, created)
	}

	return nil
}

// User requests or updates a self-subscription to a topic
//	h 		- hub