stv0g/spectrum2
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Reconnect to Slack RTM when disconnected with an error

Browse source
This commit is contained in:
Jan Kaluza 2015-12-28 09:17:41 +01:00
parent 61f2419ba4
commit f592dc0ef3
2 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
include/transport/WebSocketClient.h
View file

@ -66,6 +66,7 @@ class WebSocketClient {
void handleDNSResult(const std::vector<Swift::HostAddress>&, boost::optional<Swift::DomainNameResolveError>); void handleDNSResult(const std::vector<Swift::HostAddress>&, boost::optional<Swift::DomainNameResolveError>);
void handleDataRead(boost::shared_ptr<Swift::SafeByteArray> data); void handleDataRead(boost::shared_ptr<Swift::SafeByteArray> data);
void handleConnected(bool error); void handleConnected(bool error);
void handleDisconnected(const boost::optional<Swift::Connection::Error> &error);
void connectServer(); void connectServer();

10
libtransport/WebSocketClient.cpp
View file

@ -208,10 +208,20 @@ void WebSocketClient::handleConnected(bool error) {
m_conn->write(Swift::createSafeByteArray(req)); m_conn->write(Swift::createSafeByteArray(req));
} }
void WebSocketClient::handleDisconnected(const boost::optional<Swift::Connection::Error> &error) {
if (!error) {
return;
}
LOG4CXX_ERROR(logger, "Disconected from " << m_host << ". Will reconnect in 1 second.");
m_reconnectTimer->start();
}
void WebSocketClient::handleDNSResult(const std::vector<Swift::HostAddress> &addrs, boost::optional<Swift::DomainNameResolveError>) { void WebSocketClient::handleDNSResult(const std::vector<Swift::HostAddress> &addrs, boost::optional<Swift::DomainNameResolveError>) {
m_conn = m_tlsConnectionFactory->createConnection(); m_conn = m_tlsConnectionFactory->createConnection();
m_conn->onDataRead.connect(boost::bind(&WebSocketClient::handleDataRead, this, _1)); m_conn->onDataRead.connect(boost::bind(&WebSocketClient::handleDataRead, this, _1));
m_conn->onConnectFinished.connect(boost::bind(&WebSocketClient::handleConnected, this, _1)); m_conn->onConnectFinished.connect(boost::bind(&WebSocketClient::handleConnected, this, _1));
m_conn->onDisconnected.connect(boost::bind(&WebSocketClient::handleDisconnected, this, _1));
m_conn->connect(Swift::HostAddressPort(addrs[0], 443)); m_conn->connect(Swift::HostAddressPort(addrs[0], 443));
} }