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")
}
}