emscripten_http_client.h

Go to the documentation of this file.

#ifndef YAZE_APP_NET_WASM_EMSCRIPTEN_HTTP_CLIENT_H_
#define YAZE_APP_NET_WASM_EMSCRIPTEN_HTTP_CLIENT_H_
 
#ifdef __EMSCRIPTEN__
 
#include <mutex>
#include <condition_variable>
 
#include <emscripten/fetch.h>
 
#include "app/net/http_client.h"
 
namespace yaze {
namespace net {
 
class EmscriptenHttpClient : public IHttpClient {
 public:
  EmscriptenHttpClient();
  ~EmscriptenHttpClient() override;
 
  absl::StatusOr<HttpResponse> Get(
      const std::string& url,
      const Headers& headers = {}) override;
 
  absl::StatusOr<HttpResponse> Post(
      const std::string& url,
      const std::string& body,
      const Headers& headers = {}) override;
 
  absl::StatusOr<HttpResponse> Put(
      const std::string& url,
      const std::string& body,
      const Headers& headers = {}) override;
 
  absl::StatusOr<HttpResponse> Delete(
      const std::string& url,
      const Headers& headers = {}) override;
 
 private:
  struct FetchResult {
    bool completed = false;
    bool success = false;
    int status_code = 0;
    std::string body;
    Headers headers;
    std::string error_message;
    std::mutex mutex;
    std::condition_variable cv;
  };
 
  absl::StatusOr<HttpResponse> PerformFetch(
      const std::string& method,
      const std::string& url,
      const std::string& body = "",
      const Headers& headers = {});
 
  static void OnFetchSuccess(emscripten_fetch_t* fetch);
 
  static void OnFetchError(emscripten_fetch_t* fetch);
 
  static void OnFetchProgress(emscripten_fetch_t* fetch);
};
 
}  // namespace net
}  // namespace yaze
 
#endif  // __EMSCRIPTEN__
 
#endif  // YAZE_APP_NET_WASM_EMSCRIPTEN_HTTP_CLIENT_H_