Method dispatch

server/session.go:150–209

Message received, dispatch

(raw []byte)

// Message received, dispatch
func (s *Session) dispatch(raw []byte) {
	var msg ClientComMessage

	log.Printf("Session.dispatch got '%s' from '%s'", raw, s.remoteAddr)

	timestamp := time.Now().UTC().Round(time.Millisecond)
	if err := json.Unmarshal(raw, &msg); err != nil {
		// Malformed message
		log.Println("Session.dispatch: " + err.Error())
		s.QueueOut(ErrMalformed("", "", timestamp))
		return
	}

	msg.from = s.uid.UserId()
	msg.timestamp = timestamp

	// Locking-unlocking is needed for long polling.
	// Should not affect performance
	s.rw.Lock()
	defer s.rw.Unlock()

	switch {
	case msg.Pub != nil:
		s.publish(&msg)
		log.Println("dispatch: Pub done")

	case msg.Sub != nil:
		s.subscribe(&msg)
		log.Println("dispatch: Sub done")

	case msg.Leave != nil:
		s.leave(&msg)
		log.Println("dispatch: Leave done")

	case msg.Login != nil:
		s.login(&msg)
		log.Println("dispatch: Login done")

	case msg.Get != nil:
		s.get(&msg)
		log.Println("dispatch: Get." + msg.Get.What + " done")

	case msg.Set != nil:
		s.set(&msg)
		log.Println("dispatch: Set." + msg.Set.What + " done")

	case msg.Del != nil:
		s.del(&msg)
		log.Println("dispatch: Del." + msg.Del.What + " done")

	case msg.Acc != nil:
		s.acc(&msg)
		log.Println("dispatch: Acc done")

	default:
		// Unknown message
		s.QueueOut(ErrMalformed("", "", msg.timestamp))
		log.Println("Session.dispatch: unknown message")