func()

in websocketserver/websocketserver.go [267:291]


func (s *Server) handleMessageType(msg common.Message) (*common.Response, error) {
	n := s.namespaces[msg.Namespace]
	if n == nil {
		return nil, fmt.Errorf("namespace %s is not registered", msg.Namespace)
	}

	switch msg.Code {
	case common.Connect:
		if n.connectHandler == nil {
			return nil, nil
		}

		return n.connectHandler(s.conn), nil
	case common.Disconnect:
		if n.disconnectHandler == nil {
			return nil, nil
		}

		return n.disconnectHandler(s.conn), nil
	case common.Event:
		return s.callEventHandler(msg.EventName, n, msg.Payload)
	default:
		return nil, fmt.Errorf("invalid message")
	}
}