|
|
@ -252,14 +252,12 @@ func (c *Client) recv(state SMState, keepaliveQuit chan<- struct{}) (err error)
|
|
|
|
return errors.New("stream error: " + packet.Error.Local)
|
|
|
|
return errors.New("stream error: " + packet.Error.Local)
|
|
|
|
// Process Stream management nonzas
|
|
|
|
// Process Stream management nonzas
|
|
|
|
case stanza.SMRequest:
|
|
|
|
case stanza.SMRequest:
|
|
|
|
fmt.Println("MREMOND: inbound: ", state.Inbound)
|
|
|
|
|
|
|
|
answer := stanza.SMAnswer{XMLName: xml.Name{
|
|
|
|
answer := stanza.SMAnswer{XMLName: xml.Name{
|
|
|
|
Space: stanza.NSStreamManagement,
|
|
|
|
Space: stanza.NSStreamManagement,
|
|
|
|
Local: "a",
|
|
|
|
Local: "a",
|
|
|
|
}, H: state.Inbound}
|
|
|
|
}, H: state.Inbound}
|
|
|
|
c.Send(answer)
|
|
|
|
c.Send(answer)
|
|
|
|
default:
|
|
|
|
default:
|
|
|
|
fmt.Println(packet)
|
|
|
|
|
|
|
|
state.Inbound++
|
|
|
|
state.Inbound++
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|