func (c *_Conn) onSpecialRequest(topic *security.Topic, payload []byte) (ok bool) {
	var resp interface{}
	defer func() {
		if b, err := json.Marshal(resp); err == nil {
			c.SendMessage(&message.Message{
				Topic:   "unitdb/" + string(topic.Topic[:topic.Size]),
				Payload: b,
			})
		}
	}()

	// Check query
	resp = types.ErrNotFound
	if len(topic.Topic[:topic.Size]) < 1 {
		return
	}

	switch topic.Target() {
	case requestClientId:
		resp, ok = c.onClientIDRequest()
		return
	case requestKeygen:
		resp, ok = c.onKeyGen(payload)
		return
	default:
		return
	}
}
// onSpecialRequest processes an special request.
onSpecialRequest processes an special request.
// onSpecialRequest processes an special request .
func (c *_Conn) onSpecialRequest(topic *security.Topic, payload []byte) (ok bool) {
	var resp interface{}
	defer func() {
		if b, err := json.Marshal(resp); err == nil {
			c.SendMessage(&message.Message{
				Topic:   "unitdb/" + string(topic.Topic[:topic.Size]),
				Payload: b,
			})
		}
	}()
	resp = types.ErrNotFound
	if len(topic.Topic[:topic.Size]) < 1 {
		return
	}
	switch topic.Target() {
	case requestClientId:
		resp, ok = c.onClientIDRequest()
		return
	case requestKeygen:
		resp, ok = c.onKeyGen(payload)
		return
	default:
		return
	}
}
func ( c * _Conn ) onSpecialRequest ( topic * security . Topic , payload [ ] byte ) ( ok bool ) { var resp interface { } defer func ( ) { if b , err := json . Marshal ( resp ) ; err == nil { c . SendMessage ( & message . Message { Topic : " " + string ( topic . Topic [ : topic . Size ] ) , Payload : b , } ) } } ( ) resp = types . ErrNotFound if len ( topic . Topic [ : topic . Size ] ) < 1 { return } switch topic . Target ( ) { case requestClientId : resp , ok = c . onClientIDRequest ( ) return case requestKeygen : resp , ok = c . onKeyGen ( payload ) return default : return } }
onSpecialRequest processes an special request.
onSpecialRequest processes an special request .
// Check query