From b2563e8d9627d4a85374a6595f00effe162c74c3 Mon Sep 17 00:00:00 2001
From: Mark Ross <6730333+krazkidd@users.noreply.github.com>
Date: Mon, 15 Jul 2024 22:35:30 -0700
Subject: [PATCH] Implement market API wrapper methods.

This is a partial implementation.
---
 include/api/Api.hpp    |  14 ++--
 src/api/Api.market.cpp | 178 +++++++++++++++++++++++++++++++++++++++++
 2 files changed, 187 insertions(+), 5 deletions(-)
 create mode 100644 src/api/Api.market.cpp

diff --git a/include/api/Api.hpp b/include/api/Api.hpp
index 280f14f..3b5b941 100644
--- a/include/api/Api.hpp
+++ b/include/api/Api.hpp
@@ -33,13 +33,13 @@ namespace kdeck
 
         // market
         std::shared_ptr<EventsResponse> GetEvents();
-        std::shared_ptr<EventResponse> GetEvent();
+        std::shared_ptr<EventResponse> GetEvent(std::string_view eventTicker);
         std::shared_ptr<MarketsResponse> GetMarkets();
         std::shared_ptr<TradesResponse> GetTrades();
-        std::shared_ptr<MarketResponse> GetMarket();
-        std::shared_ptr<MarketOrderbookResponse> GetMarketOrderbook();
-        std::shared_ptr<SeriesResponse> GetSeries();
-        std::shared_ptr<MarketCandlesticksResponse> GetMarketCandlesticks();
+        std::shared_ptr<MarketResponse> GetMarket(std::string_view marketTicker);
+        std::shared_ptr<MarketOrderbookResponse> GetMarketOrderbook(std::string_view marketTicker);
+        std::shared_ptr<SeriesResponse> GetSeries(std::string_view seriesTicker);
+        std::shared_ptr<MarketCandlesticksResponse> GetMarketCandlesticks(std::string_view seriesTicker, std::string_view marketTicker);
 
         // portfolio
         double GetBalance();
@@ -64,6 +64,10 @@ namespace kdeck
         std::shared_ptr<ExchangeScheduleResponse> schedule;
         std::shared_ptr<ExchangeStatusResponse> status;
 
+        // market
+        std::shared_ptr<EventsResponse> events;
+        std::shared_ptr<MarketsResponse> markets;
+
         // portfolio
         std::shared_ptr<PortfolioBalanceResponse> balance;
         std::shared_ptr<PortfolioPositionsResponse> positions;
diff --git a/src/api/Api.market.cpp b/src/api/Api.market.cpp
new file mode 100644
index 0000000..e6220e1
--- /dev/null
+++ b/src/api/Api.market.cpp
@@ -0,0 +1,178 @@
+#include <stdexcept>
+
+#include "api/Api.hpp"
+
+namespace kdeck
+{
+    class ErrorResponse;
+
+    class EventsResponse;
+    class EventResponse;
+    class MarketsResponse;
+    class TradesResponse;
+    class MarketOrderbookResponse;
+    class SeriesResponse;
+    class MarketCandlesticksResponse;
+
+    std::shared_ptr<EventsResponse> Api::GetEvents()
+    {
+        OATPP_LOGD("Api", "GetEvents");
+
+        auto req = EventsRequest::createShared();
+
+        ApiResult<EventsResponse> res = HandleResponse<EventsResponse>(_api->GetEvents(basePath, req));
+
+        if (std::holds_alternative<std::shared_ptr<EventsResponse>>(res))
+        {
+            events = std::get<std::shared_ptr<EventsResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        return events;
+    }
+
+    std::shared_ptr<EventResponse> Api::GetEvent(std::string_view eventTicker)
+    {
+        OATPP_LOGD("Api", "GetEvent");
+
+        auto req = EventRequest::createShared();
+
+        ApiResult<EventResponse> res = HandleResponse<EventResponse>(_api->GetEvent(basePath, std::string{eventTicker}, req));
+
+        if (std::holds_alternative<std::shared_ptr<EventResponse>>(res))
+        {
+            //TODO populate events
+            return std::get<std::shared_ptr<EventResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //TODO return events[eventTicker];
+    }
+
+    std::shared_ptr<MarketsResponse> Api::GetMarkets()
+    {
+        OATPP_LOGD("Api", "GetMarkets");
+
+        auto req = MarketsRequest::createShared();
+
+        ApiResult<MarketsResponse> res = HandleResponse<MarketsResponse>(_api->GetMarkets(basePath, login->token, req));
+
+        if (std::holds_alternative<std::shared_ptr<MarketsResponse>>(res))
+        {
+            markets = std::get<std::shared_ptr<MarketsResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        return markets;
+    }
+
+    std::shared_ptr<TradesResponse> Api::GetTrades()
+    {
+        OATPP_LOGD("Api", "GetTrades");
+
+        auto req = TradesRequest::createShared();
+
+        ApiResult<TradesResponse> res = HandleResponse<TradesResponse>(_api->GetTrades(basePath, req));
+
+        if (std::holds_alternative<std::shared_ptr<TradesResponse>>(res))
+        {
+            //TODO populate trades
+            return std::get<std::shared_ptr<TradesResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //TODO return trades;
+    }
+
+    std::shared_ptr<MarketResponse> Api::GetMarket(std::string_view marketTicker)
+    {
+        OATPP_LOGD("Api", "GetMarket");
+
+        ApiResult<MarketResponse> res = HandleResponse<MarketResponse>(_api->GetMarket(basePath, std::string{marketTicker}));
+
+        if (std::holds_alternative<std::shared_ptr<MarketResponse>>(res))
+        {
+            //TODO populate markets
+            return std::get<std::shared_ptr<MarketResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //TODO return markets[marketTicker];
+    }
+
+    std::shared_ptr<MarketOrderbookResponse> Api::GetMarketOrderbook(std::string_view marketTicker)
+    {
+        OATPP_LOGD("Api", "GetMarketOrderbook");
+
+        auto req = MarketOrderbookRequest::createShared();
+
+        ApiResult<MarketOrderbookResponse> res = HandleResponse<MarketOrderbookResponse>(_api->GetMarketOrderbook(basePath, login->token, std::string{marketTicker}, req));
+
+        if (std::holds_alternative<std::shared_ptr<MarketOrderbookResponse>>(res))
+        {
+            //TODO populate orderbooks
+            return std::get<std::shared_ptr<MarketOrderbookResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //TODO return orderbooks[marketTicker];
+    }
+
+    std::shared_ptr<SeriesResponse> Api::GetSeries(std::string_view seriesTicker)
+    {
+        OATPP_LOGD("Api", "GetSeries");
+
+        ApiResult<SeriesResponse> res = HandleResponse<SeriesResponse>(_api->GetSeries(basePath, std::string{seriesTicker}));
+
+        if (std::holds_alternative<std::shared_ptr<SeriesResponse>>(res))
+        {
+            //TODO populate series
+            return std::get<std::shared_ptr<SeriesResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //TODO return series[seriesTicker];
+    }
+
+    std::shared_ptr<MarketCandlesticksResponse> Api::GetMarketCandlesticks(std::string_view seriesTicker, std::string_view marketTicker)
+    {
+        OATPP_LOGD("Api", "GetMarketCandlesticks");
+
+        auto req = MarketCandlesticksRequest::createShared();
+
+        ApiResult<MarketCandlesticksResponse> res = HandleResponse<MarketCandlesticksResponse>(_api->GetMarketCandlesticks(basePath, login->token, std::string{seriesTicker}, std::string{marketTicker}, req));
+
+        if (std::holds_alternative<std::shared_ptr<MarketCandlesticksResponse>>(res))
+        {
+            //TODO populate candlesticks
+            return std::get<std::shared_ptr<MarketCandlesticksResponse>>(res);
+        }
+        else
+        {
+            throw std::runtime_error(std::get<std::shared_ptr<ErrorResponse>>(res)->error->message->c_str());
+        }
+
+        //return candlesticks[seriesTicker][marketTicker];
+    }
+}