NetworkCommunication.cpp

#include <ImFusion/Core/ByteBuffer.h>
#include <ImFusion/GL/SharedImageSet.h>
#include <ImFusion/Stream/Network/WebsocketClient.h>
#include <ImFusion/Stream/Network/WebsocketServer.h>
#include <ImFusion/Stream/Serialization.h>
 
#include <iostream>
 
using namespace ImFusion;
 
int main()
{
// This example demonstrates a simple WebSocket server and client using the Network library.
// It shows how to set up a server that listens for incoming connections and a client that connects to the server.
// The server echoes back any messages it receives from the client and prints them to the console.
// Normally, you would only have either a server or a client in your application, but for demonstration purposes, both are included here.
 
// Create and start a WebSocket server listening on localhost (127.0.0.1) at port 12345.
Network::WebsocketServer<> websocketServer{"127.0.0.1", 12345};
websocketServer.run();
 
// Set up a handler for when the server receives a new message.
websocketServer.signalNewMessage.connect([&websocketServer](std::shared_ptr<std::string> msg) {
    std::cout << "Server received message: " << *msg << std::endl;
    // Echo the received message back to the client.
    websocketServer.sendMessage(*msg);
});
 
// Create a WebSocket client that will connect to the server at localhost:12345.
Network::WebsocketClient<> websocketClient{"127.0.0.1", 12345};
 
// Set up a handler for when the client receives a new message from the server.
websocketClient.signalNewMessage.connect([](std::shared_ptr<std::string> msg) {
    std::cout << "Client received message back: " << *msg << std::endl;
});
 
// Connect the client to the server, with a timeout of 10 seconds (10000 ms).
websocketClient.connect(10000);
 
// Send a message from the client to the server. The server replies the same message.
websocketClient.sendMessage("Hello world!");
 
// ... (other application logic can go here)
 
// At the end, disconnect the client and stop the server to clean up resources.
websocketClient.disconnect();
websocketServer.stop();
 

// Serialize any data for sending.
SharedImageSet imageToSend;    // Replace with your data
DataList dataToSend{&imageToSend};
std::optional<ByteBuffer> sendBuffer = Serialization::dataToByteBuffer(dataToSend);
if (sendBuffer)
{
    // E.g. send buffer via the network
}
 
// ...
 
// Deserialize byte buffer on receiver site.
ByteBufferView receiveByteBuffer;    // replace with your received serialized data
std::optional<OwningDataList> receivedData = Serialization::dataFromByteBuffer(receiveByteBuffer);
if (receivedData)
{
    auto receivedImage = receivedData->extractFirst<SharedImageSet>();
    // ...
}
}