Add Logging
This commit is contained in:
@@ -18,6 +18,10 @@ MessageHandler::~MessageHandler()
|
|||||||
|
|
||||||
void MessageHandler::HandleMessage(const std::string& message)
|
void MessageHandler::HandleMessage(const std::string& message)
|
||||||
{
|
{
|
||||||
|
std::stringstream ss;
|
||||||
|
ss << "Message Received: " << message << std::endl;
|
||||||
|
Logging::Log(Logging::Severity::Info, ss.str());
|
||||||
|
|
||||||
nlohmann::json data = nlohmann::json::parse(message);
|
nlohmann::json data = nlohmann::json::parse(message);
|
||||||
|
|
||||||
if (data.contains("code"))
|
if (data.contains("code"))
|
||||||
|
|||||||
@@ -46,7 +46,21 @@ void WebSocketSubscription::OpenWebSocket()
|
|||||||
request.Headers(RequestHeaders());
|
request.Headers(RequestHeaders());
|
||||||
request.Data(data.dump());
|
request.Data(data.dump());
|
||||||
|
|
||||||
std::string returnValue = m_httpClient.Open(request);
|
try
|
||||||
|
{
|
||||||
|
m_httpClient.Open(request);
|
||||||
|
}
|
||||||
|
catch (const std::exception& e)
|
||||||
|
{
|
||||||
|
std::stringstream ss;
|
||||||
|
ss << "Error Opening Websocket: " << std::endl;
|
||||||
|
ss << "Type : " << typeid(e).name() << std::endl;
|
||||||
|
ss << "ERROR: " << e.what() << std::endl;
|
||||||
|
|
||||||
|
Logging::Log(Logging::Severity::Error, ss.str());
|
||||||
|
|
||||||
|
throw std::runtime_error("Error Connecting to Toon WebService.");
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void WebSocketSubscription::WebSocketStatus()
|
void WebSocketSubscription::WebSocketStatus()
|
||||||
@@ -75,6 +89,10 @@ void WebSocketSubscription::CloseWebSocket()
|
|||||||
request.Headers(RequestHeaders());
|
request.Headers(RequestHeaders());
|
||||||
|
|
||||||
std::string returnValue = m_httpClient.Open(request);
|
std::string returnValue = m_httpClient.Open(request);
|
||||||
|
|
||||||
|
std::stringstream ss;
|
||||||
|
ss << "Closing Websocket: " << returnValue << std::endl;
|
||||||
|
Logging::Log(Logging::Severity::Info, ss.str());
|
||||||
}
|
}
|
||||||
|
|
||||||
std::vector<std::string> WebSocketSubscription::RequestHeaders()
|
std::vector<std::string> WebSocketSubscription::RequestHeaders()
|
||||||
|
|||||||
Reference in New Issue
Block a user