emscripten_websocket.h

Go to the documentation of this file.

#ifndef YAZE_APP_NET_WASM_EMSCRIPTEN_WEBSOCKET_H_
#define YAZE_APP_NET_WASM_EMSCRIPTEN_WEBSOCKET_H_
 
#ifdef __EMSCRIPTEN__
 
#include <emscripten/websocket.h>
 
#include "app/net/websocket_interface.h"
 
namespace yaze {
namespace net {
 
class EmscriptenWebSocket : public IWebSocket {
 public:
  EmscriptenWebSocket();
  ~EmscriptenWebSocket() override;
 
  absl::Status Connect(const std::string& url) override;
 
  absl::Status Send(const std::string& message) override;
 
  absl::Status SendBinary(const uint8_t* data, size_t length) override;
 
  absl::Status Close(int code = 1000,
                    const std::string& reason = "") override;
 
  WebSocketState GetState() const override { return state_; }
 
  void OnMessage(MessageCallback callback) override {
    message_callback_ = callback;
  }
 
  void OnBinaryMessage(BinaryMessageCallback callback) override {
    binary_message_callback_ = callback;
  }
 
  void OnOpen(OpenCallback callback) override {
    open_callback_ = callback;
  }
 
  void OnClose(CloseCallback callback) override {
    close_callback_ = callback;
  }
 
  void OnError(ErrorCallback callback) override {
    error_callback_ = callback;
  }
 
 private:
  // Emscripten WebSocket callbacks (static, with user data)
  static EM_BOOL OnOpenCallback(int eventType,
                                const EmscriptenWebSocketOpenEvent* websocketEvent,
                                void* userData);
 
  static EM_BOOL OnCloseCallback(int eventType,
                                 const EmscriptenWebSocketCloseEvent* websocketEvent,
                                 void* userData);
 
  static EM_BOOL OnErrorCallback(int eventType,
                                 const EmscriptenWebSocketErrorEvent* websocketEvent,
                                 void* userData);
 
  static EM_BOOL OnMessageCallback(int eventType,
                                   const EmscriptenWebSocketMessageEvent* websocketEvent,
                                   void* userData);
 
  // Emscripten WebSocket handle
  EMSCRIPTEN_WEBSOCKET_T socket_;
 
  // Track if socket is valid
  bool socket_valid_;
};
 
}  // namespace net
}  // namespace yaze
 
#endif  // __EMSCRIPTEN__
 
#endif  // YAZE_APP_NET_WASM_EMSCRIPTEN_WEBSOCKET_H_