Method set

server/session.go:487–523

(msg *ClientComMessage)

}

func (s *Session) set(msg *ClientComMessage) {
	log.Println("s.set: processing 'set." + msg.Set.What + "'")

	// Validate topic name
	original, expanded, err := s.validateTopicName(msg.Set.Id, msg.Set.Topic, msg.timestamp)
	if err != nil {
		s.QueueOut(err)
		return
	}

	sub, ok := s.subs[expanded]
	meta := &metaReq{
		topic: expanded,
		pkt:   msg,
		sess:  s,
		what:  parseMsgClientMeta(msg.Set.What)}

	if meta.what == 0 {
		s.QueueOut(ErrMalformed(msg.Set.Id, original, msg.timestamp))
		log.Println("s.set: invalid Set message action '" + msg.Set.What + "'")
	}

	if ok {
		if (meta.what&constMsgMetaInfo != 0 && msg.Set.Info == nil) ||
			(meta.what&constMsgMetaSub != 0 && msg.Set.Sub == nil) {

			s.QueueOut(ErrMalformed(msg.Set.Id, original, msg.timestamp))
			log.Println("s.set: payload missing for Set action '" + msg.Set.What + "'")
		} else {
			log.Println("s.set: sending to topic")
			sub.meta <- meta
		}
	} else {
		log.Println("s.set: can Set for subscribed topics only")
		s.QueueOut(ErrPermissionDenied(msg.Set.Id, original, msg.timestamp))
	}
}

func (s *Session) del(msg *ClientComMessage) {
	log.Println("s.del: processing 'set." + msg.Del.What + "'")