Refactoring websocket client and server.

Sming/Services/CommandProcessing/CommandExecutor.cpp

@@ -31,7 +31,7 @@ CommandExecutor::CommandExecutor(Stream* reqStream) : CommandExecutor()
 	}
 }
 
-CommandExecutor::CommandExecutor(WebSocketConnection* reqSocket)
+CommandExecutor::CommandExecutor(WebsocketConnection* reqSocket)
 {
 	commandOutput = new CommandOutput(reqSocket);
 	if (commandHandler.getVerboseMode() != SILENT)

Sming/Services/CommandProcessing/CommandExecutor.h

@@ -20,7 +20,7 @@ class CommandExecutor
 public:
 	CommandExecutor(TcpClient* cmdClient);
 	CommandExecutor(Stream* reqStream);
-	CommandExecutor(WebSocketConnection* reqSocket);
+	CommandExecutor(WebsocketConnection* reqSocket);
 	~CommandExecutor();
 
 	int executorReceive(char *recvData, int recvSize);

Sming/Services/CommandProcessing/CommandOutput.cpp

@@ -17,7 +17,7 @@ CommandOutput::CommandOutput(Stream* reqStream)
 {
 }
 
-CommandOutput::CommandOutput(WebSocketConnection* reqSocket)
+CommandOutput::CommandOutput(WebsocketConnection* reqSocket)
 :  outputSocket(reqSocket)
 {
 }

Sming/Services/CommandProcessing/CommandOutput.h

@@ -12,21 +12,21 @@
 #include "Stream.h"
 #include "Print.h"
 #include "WiringFrameworkDependencies.h"
-#include "Network/Http/Websocket/WebSocketConnection.h"
+#include "Network/Http/Websocket/WebsocketConnection.h"
 
 class CommandOutput: public Print
 {
 public:
 	CommandOutput(TcpClient* reqClient);
 	CommandOutput(Stream* reqStream);
-	CommandOutput(WebSocketConnection* reqSocket);
+	CommandOutput(WebsocketConnection* reqSocket);
 	virtual ~CommandOutput();
 
 	size_t write(uint8_t outChar);
 
 	TcpClient* outputTcpClient = nullptr;
 	Stream*    outputStream = nullptr;
-	WebSocketConnection* outputSocket = nullptr;
+	WebsocketConnection* outputSocket = nullptr;
 	String tempSocket = "";
 };
 

Sming/SmingCore/Network/Http/HttpConnection.h

@@ -17,6 +17,12 @@
 #include "../Services/DateTime/DateTime.h"
 #include "Data/ObjectQueue.h"
 
+/** @defgroup   HTTP client connection
+ *  @brief      Provides http client connection
+ *  @ingroup    http
+ *  @{
+ */
+
 typedef ObjectQueue<HttpRequest, HTTP_REQUEST_POOL_SIZE> RequestQueue;
 
 class HttpConnection : public HttpConnectionBase
@@ -140,4 +146,5 @@ class HttpConnection : public HttpConnectionBase
 	HttpResponse response;
 };
 
+/** @} */
 #endif /* _SMING_CORE_NETWORK_HTTP_CONNECTION_H_ */

Sming/SmingCore/Network/Http/HttpConnectionBase.h

@@ -21,6 +21,12 @@
 #include "HttpResponse.h"
 #include "HttpRequest.h"
 
+/** @defgroup   HTTP base connection
+ *  @brief      Provides http base used for client and server connections
+ *  @ingroup    http
+ *  @{
+ */
+
 class HttpConnectionBase : public TcpClient
 {
 public:
@@ -36,6 +42,10 @@ class HttpConnectionBase : public TcpClient
 protected:
 	void resetHeaders();
 
+	/**
+	 * @brief Initializes the http parser for a specific type of HTTP message
+	 * @param http_parser_type
+	 */
 	virtual void init(http_parser_type type);
 
 	// HTTP parser methods
@@ -139,4 +149,5 @@ class HttpConnectionBase : public TcpClient
 	HttpConnectionState state = eHCS_Ready;
 };
 
+/** @} */
 #endif /* _SMING_CORE_NETWORK_HTTP_HTTPCONNECTIONBASE_H_ */

Sming/SmingCore/Network/Http/HttpServerConnection.h

@@ -19,6 +19,12 @@
 
 #include <functional>
 
+/** @defgroup   HTTP server connection
+ *  @brief      Provides http server connection
+ *  @ingroup    http
+ *  @{
+ */
+
 #ifndef HTTP_SERVER_EXPOSE_NAME
 #define HTTP_SERVER_EXPOSE_NAME 1
 #endif
@@ -46,7 +52,7 @@ class HttpServerConnection : public HttpConnectionBase
 
 	using TcpClient::send;
 
-	void setUpgdareCallback(HttpServerProtocolUpgradeCallback callback)
+	void setUpgradeCallback(HttpServerProtocolUpgradeCallback callback)
 	{
 		upgradeCallback = callback;
 	}
@@ -120,4 +126,5 @@ class HttpServerConnection : public HttpConnectionBase
 	HttpBodyParserDelegate bodyParser = 0;
 };
 
+/** @} */
 #endif /* _SMING_CORE_NETWORK_HTTP_HTTPSERVERCONNECTION_H_ */