From 8d2244aefe172b5b1e15a32ad23991945d128f3a Mon Sep 17 00:00:00 2001
From: Patrick Schönberger
Date: Sat, 8 Jan 2022 12:34:02 +0100
Subject: ws connect works

---
 src/ws.h | 143 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 143 insertions(+)
 create mode 100644 src/ws.h

(limited to 'src/ws.h')

diff --git a/src/ws.h b/src/ws.h
new file mode 100644
index 0000000..82d7976
--- /dev/null
+++ b/src/ws.h
@@ -0,0 +1,143 @@
+// #define _WEBSOCKETPP_CPP11_INTERNAL_
+// #define ASIO_STANDALONE
+// #include <websocketpp/config/asio_no_tls_client.hpp>
+// #include <websocketpp/client.hpp>
+
+// using client = websocketpp::client<websocketpp::config::asio_client>;
+
+#include "mongoose.h"
+
+#include "json.hpp"
+using json = nlohmann::json;
+
+#include <string>
+
+namespace ws
+{
+  // client c;
+
+  // void on_message(websocketpp::connection_hdl hdl, client::message_ptr msg) {
+  //   auto j = json::parse(msg->get_payload());
+  //   int op = j["op"].get<int>();
+
+  //   if (op == 0) {
+  //     json response = { { "op", 1 },
+  //                       { "d", {
+  //                           { "rpcVersion", 1 },
+  //                         } } };
+  //     auto responseStr = response.dump();
+  //     websocketpp::lib::error_code ec;
+  //     c.send(hdl, responseStr, websocketpp::frame::opcode::TEXT, ec);
+  //     if (ec)
+  //       MessageBoxA(NULL, ec.message().c_str(), "error", MB_OK);
+  //   } else if (op == 2) {
+  //     MessageBoxA(NULL, "hura", "connected", MB_OK);
+  //   }
+  // }
+
+  // void init()
+  // {
+  //   c.set_access_channels(websocketpp::log::alevel::all);
+  //   c.clear_access_channels(websocketpp::log::alevel::frame_payload);
+  //   c.set_error_channels(websocketpp::log::elevel::all);
+
+  //   // Initialize ASIO
+  //   c.init_asio();
+
+  //   // Register our message handler
+  //   c.set_message_handler(&on_message);
+  // }
+
+  // void connect(std::string address)
+  // {
+  //   websocketpp::lib::error_code ec;
+  //   client::connection_ptr con = c.get_connection(address, ec);
+  //   if (ec) {
+  //       std::cout << "could not create connection because: " << ec.message() << std::endl;
+  //       return;
+  //   }
+
+  //   c.connect(con);
+  // }
+
+  // void update()
+  // {
+  //   c.run_one();
+  // }
+
+
+
+
+
+  mg_mgr mgr;
+  mg_connection *c = nullptr;
+
+  bool done = false;
+
+  static void cb(struct mg_connection *c, int ev, void *ev_data, void *fn_data) {
+    if (ev == MG_EV_ERROR || ev == MG_EV_CLOSE) {
+      MessageBoxA(NULL, "", "Error", MB_OK);
+    } else if (ev == MG_EV_WS_OPEN) {
+      //mg_ws_send(c, "hello", 5, WEBSOCKET_OP_TEXT);
+    } else if (ev == MG_EV_WS_MSG) {
+      struct mg_ws_message *wm = (struct mg_ws_message *) ev_data;
+      std::string jsonStr(wm->data.ptr, wm->data.len);
+      auto msg = json::parse(jsonStr);
+      int op = msg["op"].get<int>();
+      
+      if (op == 0) {
+        json response = {
+          {"op", 1},
+          {"d", {
+            {"rpcVersion", 1},
+          }}
+        };
+        auto responseStr = response.dump();
+        MessageBoxA(NULL,
+          (std::string("is_client") + std::to_string(c->is_client) +
+          std::string(" is_accepted") + std::to_string(c->is_accepted) +
+          std::string(" is_readable") + std::to_string(c->is_readable) +
+          std::string(" is_writable") + std::to_string(c->is_writable)).c_str(),
+          "", MB_OK);
+        mg_ws_send(c, "{\"op\":1,\"d\":{\"rpcVersion\":1}}", 29, WEBSOCKET_OP_TEXT);
+      }
+      else if (op == 2)
+      {
+        MessageBoxA(NULL, "hura", "connected", MB_OK);
+      }
+    }
+
+    if (ev == MG_EV_ERROR || ev == MG_EV_CLOSE) {
+      done = true;
+    }
+  }
+
+  void init()
+  {
+    mg_mgr_init(&mgr);
+  }
+
+  void connect(std::string address)
+  {
+    c = mg_ws_connect(&mgr, address.c_str(), cb, nullptr, nullptr);
+  }
+
+  void update()
+  {
+    if (c && !done)
+      mg_mgr_poll(&mgr, 10);
+    else
+      MessageBoxA(NULL, "cant update", "Nio", MB_OK);
+  }
+
+  void identify()
+  {
+        MessageBoxA(NULL,
+          (std::string("is_client") + std::to_string(c->is_client) +
+          std::string(" is_accepted") + std::to_string(c->is_accepted) +
+          std::string(" is_readable") + std::to_string(c->is_readable) +
+          std::string(" is_writable") + std::to_string(c->is_writable)).c_str(),
+          "", MB_OK);
+    mg_ws_send(c, "{\"op\":1,\"d\":{\"rpcVersion\":1}}", 29, WEBSOCKET_OP_TEXT);
+  }
+}
\ No newline at end of file
-- 
cgit v1.2.3