main.cpp

//
// Created by skyitachi on 2019-07-29.
//

#include <uv.h>
#include <ws/WebSocketServer.h>
#include <boost/log/trivial.hpp>
#include <iostream>

using namespace ws;

int main() {
  
  WebSocketServer server(uv_default_loop());
  
  server.onConnection([](const WebSocketConnectionPtr& conn) {
    BOOST_LOG_TRIVIAL(info) << "websocket connection established";
    
    // 这里右值引用的参数意思是message是可以安全move的
    conn->onMessage([conn](String&& message, bool isBinary) {
      BOOST_LOG_TRIVIAL(info) << "receive message from client: " << message.size() << " content is " << message.c_str();
      // 由于sendMessage根本不会复制message, 虽然使用了移动的版本，也不会触发移动构造函数
      conn->sendMessage(std::move(message), isBinary);
    });
    
    conn->onPing([](String&& message) {
//      BOOST_LOG_TRIVIAL(info) << "receive ping";
    });
    
    conn->onPong([](String&& message) {
//      BOOST_LOG_TRIVIAL(info) << "receive pong";
    });
    
    conn->onClose([]() {
      BOOST_LOG_TRIVIAL(info) << "connection closed";
    });
  });
  
  int ret = server.Listen("0.0.0.0", 3000);
  
  if (ret) {
    BOOST_LOG_TRIVIAL(error) << "server listen error " << uv_strerror(ret);
  }
}