added cpp example

examples/cpp_client_example/CMakeLists.txt

@@ -0,0 +1,33 @@
+cmake_minimum_required(VERSION 3.1)
+project(SocketIOClientExample)
+
+set(CMAKE_CXX_STANDARD 11)
+
+# Set the path to the Socket.IO Client C++ library
+set(SOCKET_IO_CLIENT_CPP_PATH /path/to/socket.io-client-cpp)
+
+# Add the Socket.IO Client C++ library include directory
+include_directories(${SOCKET_IO_CLIENT_CPP_PATH}/src)
+
+# Add the Socket.IO Client C++ library source files
+set(SOCKET_IO_CLIENT_CPP_SOURCE_FILES
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet_op.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet_op.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet_socket.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_packet_socket.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_streambuf.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_streambuf.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_socket.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_socket.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_socket_impl.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_socket_impl.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_client_impl.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/internal/sio_client_impl.cpp
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/sio_client.h
+    ${SOCKET_IO_CLIENT_CPP_PATH}/src/sio_client.cpp
+)
+
+# Add the executable target
+add_executable(SocketIOClientExample main.cpp ${SOCKET_IO_CLIENT_CPP_SOURCE_FILES})

examples/cpp_client_example/main.cpp

@@ -0,0 +1,131 @@
+#include <iostream>
+#include <string>
+#include <socket.io-client-cpp/src/sio_client.h>
+
+class SocketIOClient {
+public:
+    SocketIOClient(const std::string& serverUrl) : client_(sio::socket::create())
+    {
+        client_->set_open_listener([&]() {
+            onConnected();
+        });
+
+        client_->set_close_listener([&](sio::client::close_reason const& reason) {
+            onDisconnected();
+        });
+
+        client_->set_fail_listener([&]() {
+            onConnectionFailed();
+        });
+
+        client_->set_reconnect_listener([&](unsigned int reconnectionAttempts, unsigned int delay) {
+            onReconnecting(reconnectionAttempts, delay);
+        });
+
+        client_->set_socket_close_listener([&]() {
+            onSocketClosed();
+        });
+
+        client_->connect(serverUrl);
+    }
+
+    void generateText(const std::string& prompt)
+    {
+        sio::message::list messages;
+        messages.push(sio::string_message::create(prompt));
+        messages.push(sio::int_message::create(-1));
+        messages.push(sio::int_message::create(1024));
+        client_->socket()->emit("generate_text", messages);
+    }
+
+    void cancelGeneration()
+    {
+        client_->socket()->emit("cancel_generation");
+    }
+
+    void onConnected()
+    {
+        std::cout << "Connected to the LoLLMs server" << std::endl;
+        // Perform actions upon successful connection
+        // ...
+    }
+
+    void onDisconnected()
+    {
+        std::cout << "Disconnected from the server" << std::endl;
+        // Perform actions upon disconnection
+        // ...
+    }
+
+    void onConnectionFailed()
+    {
+        std::cout << "Connection to the server failed" << std::endl;
+        // Perform actions upon connection failure
+        // ...
+    }
+
+    void onReconnecting(unsigned int reconnectionAttempts, unsigned int delay)
+    {
+        std::cout << "Reconnecting to the server (attempt " << reconnectionAttempts << ") in " << delay << " milliseconds" << std::endl;
+        // Perform actions upon reconnection attempt
+        // ...
+    }
+
+    void onSocketClosed()
+    {
+        std::cout << "Socket closed" << std::endl;
+        // Perform actions upon socket closure
+        // ...
+    }
+
+private:
+    sio::client client_;
+};
+
+int main()
+{
+    // Create a SocketIOClient instance and connect to the server
+    SocketIOClient client("http://localhost:9601");
+
+    // Event handler for receiving generated text chunks
+    client.client_->socket()->on("text_chunk", [&](const sio::event& event) {
+        const std::string chunk = event.get_message()->get_string();
+        std::cout << "Received chunk: " << chunk << std::endl;
+        // Append the chunk to the output or perform any other required actions
+        // ...
+    });
+
+    // Event handler for receiving generated text
+    client.client_->socket()->on("text_generated", [&](const sio::event& event) {
+        const std::string text = event.get_message()->get_string();
+        std::cout << "Text generated: " << text << std::endl;
+        // Toggle button visibility or perform any other required actions
+        // ...
+    });
+
+    // Event handler for error during text generation
+    client.client_->socket()->on("buzzy", [&](const sio::event& event) {
+        const std::string error = event.get_message()->get_string();
+        std::cerr << "Server is busy. Wait for your turn. Error: " << error << std::endl;
+        // Handle the error or perform any other required actions
+        // ...
+    });
+
+    // Event handler for generation cancellation
+    client.client_->socket()->on("generation_canceled", [&](const sio::event& event) {
+        // Toggle button visibility or perform any other required actions
+        // ...
+    });
+
+    // Trigger the "generate_text" event when needed
+    std::string prompt = "Enter your prompt here";
+    client.generateText(prompt);
+
+    // Trigger the "cancel_generation" event when needed
+    client.cancelGeneration();
+
+    // Run the event loop
+    client.client_->sync_close();
+
+    return 0;
+}