Untitled

#include <iostream>

#include "../include/cinatra.hpp"

using namespace cinatra;


async_simple::coro::Lazy<void> test_websocket() {
  coro_http_client client{};
  client.on_ws_close([](std::string_view reason) {
    std::cout << "web socket close " << reason << std::endl;
  });
  client.on_ws_msg([](resp_data data) {
    if (data.net_err) {
      std::cout << data.net_err.message() << "\n";
      return;
    }
    std::cout << data.resp_body << std::endl;
  });

  bool r = co_await client.async_ws_connect("ws://192.168.16.1:8080/ws_echo");
  if (!r) {
    co_return;
  }

  auto data = co_await client.async_send_ws("test2fdsaf", true, opcode::binary);
  //auto data = co_await client.async_send_ws_chuncked(tmp, 3145728, false, opcode::binary);
  if (data.eof) {
    std::cout << "data complete" << std::endl;
  }

  auto result = co_await client.async_send_ws_close("ws close");
  std::cout << "close socket!\n";
}


int main() {
  async_simple::coro::syncAwait(test_websocket());
  return 0;
}