auth.hpp

#pragma once
 
#include "./config.hpp"
#include "./network.hpp"
 
#include <mutex>
 
namespace algotradelib {
namespace tossinvest {
 
class TossAuth;

class TossAuth {
public:
  TossAuth(net::io_context& ioc, ssl::context& ctx, const TossConfig& config)
  : ioc_(ioc), ctx_(ctx), req_(config) {}

  virtual ~TossAuth() = default;

  std::string accessToken() {
    std::lock_guard<std::mutex> lock(mtx_);
    if (!rest_resp_.valid()) {
      refresh();
    }
    return rest_resp_.access_token_;
  }
 
private:
  net::io_context& ioc_;
  ssl::context& ctx_;
  TossConfig req_;
  TossRest rest_resp_;
  std::mutex mtx_;
 
  void refresh() {
    const std::string formbody = req_.to_form_urlencoded_body();
    TossHttpClient rest(ioc_, ctx_, "openapi.tossinvest.com", "443");
    auto response = rest.post("/oauth2/token", formbody, {{"Content-Type", "application/x-www-form-urlencoded"}});
    if (response.result_int() < 200 || response.result_int() >= 300) {
      throw std::runtime_error(
        "Token authentication failed with HTTP status " + std::to_string(response.result_int())
      );
    }
    const std::string resp = std::move(response.body());
    boost::system::error_code ec;
    const auto jv = json::parse(resp, ec);
    if (ec || !jv.is_object()) {
      // Not the body: a token reply that did not parse may still hold the token.
      throw std::runtime_error(
        "Token authentication failed: the reply is not a JSON object (" + std::to_string(resp.size()) + " bytes)"
      );
    }
    rest_resp_.from_json(jv.as_object());
  }
};
 
} // namespace tossinvest
} // namespace algotradelib