update to the latest oatpp API.

Author: lganzzzo

async-server-rooms/src/rooms/Peer.cpp

@@ -58,7 +58,7 @@ oatpp::async::CoroutineStarter Peer::readMessage(const std::shared_ptr<AsyncWebS
   if(size == 0) { // message transfer finished
 
     auto wholeMessage = m_messageBuffer.toString();
-    m_messageBuffer.clear();
+    m_messageBuffer.setCurrentPosition(0);
 
     m_room->sendMessage(m_nickname + ": " + wholeMessage);
 

async-server-rooms/src/rooms/Peer.hpp

@@ -17,7 +17,7 @@ class Peer : public oatpp::websocket::AsyncWebSocket::Listener {
   /**
    * Buffer for messages. Needed for multi-frame messages.
    */
-  oatpp::data::stream::ChunkedBuffer m_messageBuffer;
+  oatpp::data::stream::BufferOutputStream m_messageBuffer;
 
   /**
    * Lock for synchronization of writes to the web socket.

async-server/src/websocket/WSListener.cpp

@@ -24,7 +24,7 @@ oatpp::async::CoroutineStarter WSListener::readMessage(const std::shared_ptr<Asy
   if(size == 0) { // message transfer finished
 
     auto wholeMessage = m_messageBuffer.toString();
-    m_messageBuffer.clear();
+    m_messageBuffer.setCurrentPosition(0);
 
     OATPP_LOGD(TAG, "onMessage message='%s'", wholeMessage->c_str());
 

async-server/src/websocket/WSListener.hpp

@@ -15,7 +15,7 @@ class WSListener : public oatpp::websocket::AsyncWebSocket::Listener {
   /**
    * Buffer for messages. Needed for multi-frame messages.
    */
-  oatpp::data::stream::ChunkedBuffer m_messageBuffer;
+  oatpp::data::stream::BufferOutputStream m_messageBuffer;
 public:
 
   /**

client-binance.com/src/WSListener.cpp

@@ -22,7 +22,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
   if(size == 0) { // message transfer finished
 
     auto wholeMessage = m_messageBuffer.toString();
-    m_messageBuffer.clear();
+    m_messageBuffer.setCurrentPosition(0);
     onCompleteMessage(wholeMessage);
 
   } else if(size > 0) { // message frame received

client-binance.com/src/WSListener.hpp

@@ -15,7 +15,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
   /**
    * Buffer for messages. Needed for multi-frame messages.
    */
-  oatpp::data::stream::ChunkedBuffer m_messageBuffer;
+  oatpp::data::stream::BufferOutputStream m_messageBuffer;
 public:
 
   /**

client-mbedtls/src/WSListener.cpp

@@ -23,7 +23,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
   if(size == 0) { // message transfer finished
 
     auto wholeMessage = m_messageBuffer.toString();
-    m_messageBuffer.clear();
+    m_messageBuffer.setCurrentPosition(0);
 
     OATPP_LOGD(TAG, "on message received '%s'", wholeMessage->c_str());
 

client-mbedtls/src/WSListener.hpp

@@ -16,7 +16,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
   /**
    * Buffer for messages. Needed for multi-frame messages.
    */
-  oatpp::data::stream::ChunkedBuffer m_messageBuffer;
+  oatpp::data::stream::BufferOutputStream m_messageBuffer;
 public:
 
   WSListener(std::mutex& writeMutex)

client/src/WSListener.cpp

@@ -23,7 +23,7 @@ void WSListener::readMessage(const WebSocket& socket, v_uint8 opcode, p_char8 da
   if(size == 0) { // message transfer finished
 
     auto wholeMessage = m_messageBuffer.toString();
-    m_messageBuffer.clear();
+    m_messageBuffer.setCurrentPosition(0);
 
     OATPP_LOGD(TAG, "on message received '%s'", wholeMessage->c_str());
 

client/src/WSListener.hpp

@@ -16,7 +16,7 @@ class WSListener : public oatpp::websocket::WebSocket::Listener {
   /**
    * Buffer for messages. Needed for multi-frame messages.
    */
-  oatpp::data::stream::ChunkedBuffer m_messageBuffer;
+  oatpp::data::stream::BufferOutputStream m_messageBuffer;
 public:
 
   WSListener(std::mutex& writeMutex)