Added Abseil lib.

qoala101 · qoala101 · commit 758cb3a4c4b6 · 2022-09-23T20:28:22.000+03:00
Replaced all chrono time with absl.
diff --git a/.clangd b/.clangd
@@ -1,4 +1,3 @@
 ---
-
 Diagnostics:
-UnusedIncludes: Strict
+  UnusedIncludes: Strict
diff --git a/conanfile.txt b/conanfile.txt
@@ -1,4 +1,5 @@
 [requires]
+abseil/20220623.0
 aws-sdk-cpp/1.9.234
 cli11/2.2.0
 cpprestsdk/2.10.18
@@ -19,10 +20,11 @@ openssl/1.1.1q
 zlib/1.2.12
 
 [options]
-aws-sdk-cpp:dynamodb=True
+absl:shared=False
 
 aws-sdk-cpp:access-management=False
 aws-sdk-cpp:cognito-identity=False
+aws-sdk-cpp:dynamodb=True
 aws-sdk-cpp:iam=False
 aws-sdk-cpp:identity-management=False
 aws-sdk-cpp:kms=False
diff --git a/include/app/docker_test/common/app_dt_json_user_conversions.h b/include/app/docker_test/common/app_dt_json_user_conversions.h
@@ -1,6 +1,8 @@
 #ifndef STONKS_APP_DOCKER_TEST_COMMON_APP_DT_JSON_USER_CONVERSIONS_H_
 #define STONKS_APP_DOCKER_TEST_COMMON_APP_DT_JSON_USER_CONVERSIONS_H_
 
+#include <absl/time/time.h>
+
 #include "app_dt_types.h"
 #include "cpp_polymorphic_value.h"
 #include "network_i_json.h"
@@ -9,6 +11,10 @@ namespace stonks::network {
 template <typename T>
 [[nodiscard]] auto ParseFromJson(const IJson &json) -> T;
 
+template <>
+[[nodiscard]] auto ParseFromJson(const IJson &json) -> absl::Time;
+[[nodiscard]] auto ConvertToJson(absl::Time value) -> cpp::Pv<IJson>;
+
 template <>
 [[nodiscard]] auto ParseFromJson(const IJson &json)
     -> app::dt::SymbolPriceRecord;
diff --git a/include/app/docker_test/common/app_dt_types.h b/include/app/docker_test/common/app_dt_types.h
@@ -1,9 +1,8 @@
 #ifndef STONKS_APP_DOCKER_TEST_COMMON_APP_DT_TYPES_H_
 #define STONKS_APP_DOCKER_TEST_COMMON_APP_DT_TYPES_H_
 
-#include <chrono>
+#include <absl/time/time.h>
 
-#include "cpp_chrono.h"
 #include "cpp_typed_struct.h"
 
 namespace stonks::app::dt {
@@ -12,7 +11,7 @@ struct Symbol : public cpp::TypedStruct<std::string> {};
 struct Price : public cpp::TypedStruct<double> {};
 
 struct SymbolPriceRecord {
-  cpp::TimePoint time{};
+  absl::Time time{};
   Symbol symbol{};
   Price price{};
 };
diff --git a/include/cpp/aliases/cpp_chrono.h b/include/cpp/aliases/cpp_chrono.h
diff --git a/include/network/network_json_common_conversions.h b/include/network/network_json_common_conversions.h
@@ -8,7 +8,6 @@
 #include <optional>
 #include <vector>
 
-#include "cpp_chrono.h"
 #include "cpp_concepts.h"  // IWYU pragma: keep
 #include "cpp_message_exception.h"
 #include "cpp_optional.h"
@@ -28,10 +27,6 @@ template <>
 [[nodiscard]] auto ParseFromJson(const IJson &json) -> cpp::MessageException;
 [[nodiscard]] auto ConvertToJson(const std::exception &value) -> cpp::Pv<IJson>;
 
-template <>
-[[nodiscard]] auto ParseFromJson(const IJson &json) -> cpp::TimePoint;
-[[nodiscard]] auto ConvertToJson(cpp::TimePoint value) -> cpp::Pv<IJson>;
-
 template <cpp::IsTypedStruct T>
   requires Parsable<typename T::ValueType>
 [[nodiscard]] auto ParseFromJson(const IJson &json) -> T {
diff --git a/include/stonks/stonks_types.h b/include/stonks/stonks_types.h
@@ -1,7 +1,8 @@
 #ifndef STONKS_STONKS_STONKS_TYPES_H_
 #define STONKS_STONKS_STONKS_TYPES_H_
 
-#include <chrono>
+#include <absl/time/time.h>
+
 #include <string>
 
 #include "cpp_optional.h"
@@ -28,7 +29,7 @@ struct SymbolInfo {
 
 struct SymbolPriceTick {
   SymbolName symbol{};
-  std::chrono::milliseconds time{};
+  absl::Time time{};
   double buy_price{};
   double sell_price{};
 
@@ -42,8 +43,8 @@ struct SymbolPriceTick {
 };
 
 struct Period {
-  cpp::Opt<std::chrono::milliseconds> start_time{};
-  cpp::Opt<std::chrono::milliseconds> end_time{};
+  cpp::Opt<absl::Time> start_time{};
+  cpp::Opt<absl::Time> end_time{};
 };
 }  // namespace stonks
 
diff --git a/src/app/docker_test/common/CMakeLists.txt b/src/app/docker_test/common/CMakeLists.txt
@@ -1,3 +1,5 @@
+find_package(absl REQUIRED)
+
 add_library(libdockertestcommon
   app_dt_json_user_conversions.cc
   app_dt_pds_app_endpoints.cc
@@ -12,6 +14,8 @@ target_include_directories(libdockertestcommon
 )
 
 target_link_libraries(libdockertestcommon
+  PUBLIC absl::absl
+
   PRIVATE libapp
   PRIVATE libnetwork
 )
diff --git a/src/app/docker_test/common/app_dt_json_user_conversions.cc b/src/app/docker_test/common/app_dt_json_user_conversions.cc
@@ -1,8 +1,20 @@
 #include "app_dt_json_user_conversions.h"
 
+#include <cstdint>
+
+#include "network_json_basic_conversions.h"
 #include "network_json_conversions_facades.h"
 
 namespace stonks::network {
+template <>
+auto ParseFromJson(const IJson &json) -> absl::Time {
+  return absl::FromUnixMillis(ParseFromJson<int64_t>(json));
+}
+
+auto ConvertToJson(absl::Time value) -> cpp::Pv<IJson> {
+  return ConvertToJson(absl::ToUnixMillis(value));
+}
+
 template <>
 auto ParseFromJson(const IJson &json) -> app::dt::SymbolPriceRecord {
   return MakeFromJson<app::dt::SymbolPriceRecord>(json, "time", "symbol",
diff --git a/src/app/docker_test/persistent_db_server/app_dt_pds_db.cc b/src/app/docker_test/persistent_db_server/app_dt_pds_db.cc
@@ -1,9 +1,10 @@
 #include "app_dt_pds_db.h"
 
+#include <absl/time/time.h>
+
 #include <memory>
 
 #include "app_dt_pds_tables.h"
-#include "cpp_chrono.h"
 #include "not_null.hpp"
 #include "sqldb_as_values.h"
 #include "sqldb_qbf_insert_query_builder.h"
@@ -27,7 +28,7 @@ Db::Db(sqldb::IDb &db, const cpp::NnSp<sqldb::IQueryBuilder> &query_builder)
       }()} {}
 
 void Db::InsertSymbolPriceRecord(const SymbolPriceRecord &record) {
-  insert_symbol_price_record_statement_->Execute(
-      sqldb::AsValues(record.time.count(), record.symbol, record.price));
+  insert_symbol_price_record_statement_->Execute(sqldb::AsValues(
+      absl::ToUnixMillis(record.time), record.symbol, record.price));
 }
 }  // namespace stonks::app::dt::pds
diff --git a/src/app/docker_test/server_to_external_client/app_dt_stec_app.cc b/src/app/docker_test/server_to_external_client/app_dt_stec_app.cc
@@ -1,9 +1,10 @@
 #include "app_dt_stec_app.h"
 
+#include <absl/time/clock.h>
+
 #include <utility>
 
 #include "app_dt_stec_binance_types.h"
-#include "cpp_chrono.h"
 
 namespace stonks::app::dt::stec {
 App::App(binance::Client binance_client, PdsAppClient pds_app_client)
@@ -13,9 +14,8 @@ App::App(binance::Client binance_client, PdsAppClient pds_app_client)
 auto App::GetAveragePrice(Symbol symbol) const -> Price {
   auto price = Price{binance_client_.GetCurrentAveragePrice(symbol).price};
 
-  pds_app_client_.RecordSymbolPrice({.time = cpp::GetCurrentTime(),
-                                     .symbol = std::move(symbol),
-                                     .price = price});
+  pds_app_client_.RecordSymbolPrice(
+      {.time = absl::Now(), .symbol = std::move(symbol), .price = price});
 
   return price;
 }
diff --git a/src/cli/cli_run_scope.cc b/src/cli/cli_run_scope.cc
@@ -12,12 +12,14 @@
 
 namespace stonks::cli {
 RunScope::RunScope(cpp::NnSp<CLI::App> app) : app_{std::move(app)} {
-  fmt::print(R"(Started: {}
+  fmt::print(R"(Starting: {}
 )",
              app_->get_name());
 }
 
 RunScope::~RunScope() {
+  fmt::print(R"(Started. Waiting for interrupt.
+)");
   WaitForInterrupt();
   fmt::print(R"(Stopped: {}
 )",
diff --git a/src/cpp/CMakeLists.txt b/src/cpp/CMakeLists.txt
@@ -2,7 +2,6 @@ find_package(Microsoft.GSL REQUIRED)
 find_package(polymorphic_value REQUIRED)
 
 add_library(libcpp
-  aliases/cpp_chrono.cc
   cpp_message_exception.cc
 )
 
diff --git a/src/cpp/aliases/cpp_chrono.cc b/src/cpp/aliases/cpp_chrono.cc
diff --git a/src/network/network_json_common_conversions.cc b/src/network/network_json_common_conversions.cc
@@ -1,10 +1,8 @@
 #include "network_json_common_conversions.h"
 
-#include <cstdint>
 #include <string>
 #include <string_view>
 
-#include "cpp_chrono.h"
 #include "network_json_basic_conversions.h"
 #include "network_json_conversions_facades.h"
 
@@ -22,13 +20,4 @@ auto ParseFromJson(const IJson &json) -> cpp::MessageException {
 auto ConvertToJson(const std::exception &value) -> cpp::Pv<IJson> {
   return BuildJsonFrom("message", value.what());
 }
-
-template <>
-auto ParseFromJson(const IJson &json) -> cpp::TimePoint {
-  return cpp::TimePoint{ParseFromJson<int64_t>(json)};
-}
-
-auto ConvertToJson(cpp::TimePoint value) -> cpp::Pv<IJson> {
-  return ConvertToJson(value.count());
-}
 }  // namespace stonks::network
diff --git a/src/network/network_rest_client_request_builder.cc b/src/network/network_rest_client_request_builder.cc
@@ -1,10 +1,9 @@
 #include "network_rest_client_request_builder.h"
 
-#include <polymorphic_value.h>
-
 #include <gsl/assert>
 #include <string>
 #include <tuple>
+#include <type_traits>
 #include <utility>
 
 #include "cpp_move_if.h"
diff --git a/src/stonks/CMakeLists.txt b/src/stonks/CMakeLists.txt
@@ -1,3 +1,4 @@
+find_package(absl REQUIRED)
 find_package(range-v3 REQUIRED)
 
 add_library(libstonks
@@ -19,5 +20,6 @@ target_include_directories(libstonks
 target_link_libraries(libstonks
   PRIVATE librestsdk
   PRIVATE libsqlite
+  PRIVATE absl::absl
   PRIVATE range-v3::range-v3
 )
diff --git a/src/stonks/db/stonks_db.cc b/src/stonks/db/stonks_db.cc
@@ -1,6 +1,7 @@
 #include "stonks_db.h"
 
-#include <chrono>
+#include <absl/time/time.h>
+
 #include <compare>
 #include <limits>
 #include <memory>
@@ -33,22 +34,20 @@
 
 namespace stonks {
 namespace {
-[[nodiscard]] auto GetStartTime(const Period *period)
-    -> std::chrono::milliseconds {
+[[nodiscard]] auto GetStartTime(const Period *period) -> absl::Time {
   if ((period != nullptr) && period->start_time.has_value()) {
     return *period->start_time;
   }
 
-  return std::chrono::milliseconds::min();
+  return absl::InfinitePast();
 }
 
-[[nodiscard]] auto GetEndTime(const Period *period)
-    -> std::chrono::milliseconds {
+[[nodiscard]] auto GetEndTime(const Period *period) -> absl::Time {
   if ((period != nullptr) && period->end_time.has_value()) {
     return *period->end_time;
   }
 
-  return std::chrono::milliseconds::max();
+  return absl::InfiniteFuture();
 }
 
 [[nodiscard]] auto SymbolLess(const SymbolInfo &left, const SymbolInfo &right)
@@ -185,8 +184,8 @@ auto Db::SelectSymbolPriceTicks(const SymbolName *symbol, const Period *period,
                               ? &prepared_statements_->SelectSymbolPriceTicks()
                               : &prepared_statements_->SelectPriceTicks();
   auto values = [this, symbol, period, limit]() {
-    auto values = sqldb::AsValues(GetStartTime(period).count(),
-                                  GetEndTime(period).count());
+    auto values = sqldb::AsValues(absl::ToUnixMillis(GetStartTime(period)),
+                                  absl::ToUnixMillis(GetEndTime(period)));
 
     if (symbol != nullptr) {
       values.emplace_back(cache_.GetSymbolIdBySymbol(*symbol));
@@ -212,7 +211,7 @@ auto Db::SelectSymbolPriceTicks(const SymbolName *symbol, const Period *period,
   for (auto i = 0; i < num_rows; ++i) {
     price_ticks.emplace_back(SymbolPriceTick{
         .symbol = cache_.GetSymbolBySymbolId(symbol_id[i].GetInt64()),
-        .time = std::chrono::milliseconds{time[i].GetInt64()},
+        .time = absl::FromUnixMillis(time[i].GetInt64()),
         .buy_price = buy_price[i].GetDouble(),
         .sell_price = sell_price[i].GetDouble()});
   }
@@ -223,7 +222,7 @@ auto Db::SelectSymbolPriceTicks(const SymbolName *symbol, const Period *period,
 void Db::InsertSymbolPriceTick(const SymbolPriceTick &symbol_price_tick) {
   prepared_statements_->InsertPriceTick().Execute(sqldb::AsValues(
       cache_.GetSymbolIdBySymbol(symbol_price_tick.symbol),
-      symbol_price_tick.time.count(), symbol_price_tick.buy_price,
+      absl::ToUnixMillis(symbol_price_tick.time), symbol_price_tick.buy_price,
       symbol_price_tick.sell_price));
 }
 
diff --git a/test/CMakeLists.txt b/test/CMakeLists.txt
@@ -1,3 +1,4 @@
+find_package(absl REQUIRED)
 find_package(fmt REQUIRED)
 find_package(function2 REQUIRED)
 find_package(GTest REQUIRED)
@@ -46,6 +47,7 @@ target_link_libraries(unittests
   PRIVATE libspdlog
   PRIVATE libsqlite
   PRIVATE libstonks
+  PRIVATE absl::absl
   PRIVATE fmt::fmt
   PRIVATE function2::function2
   PRIVATE magic_enum::magic_enum
diff --git a/test/restsdk/test_restsdk_rest_request_sender.cc b/test/restsdk/test_restsdk_rest_request_sender.cc
diff --git a/test/stonks/test_stonks_stonks_db.cc b/test/stonks/test_stonks_stonks_db.cc

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+find_package(absl REQUIRED)`
	`2`	`+`
`1`	`3`	`add_library(libdockertestcommon`
`2`	`4`	`app_dt_json_user_conversions.cc`
`3`	`5`	`app_dt_pds_app_endpoints.cc`
`@@ -12,6 +14,8 @@ target_include_directories(libdockertestcommon`
`12`	`14`	`)`
`13`	`15`
`14`	`16`	`target_link_libraries(libdockertestcommon`
	`17`	`+ PUBLIC absl::absl`
	`18`	`+`
`15`	`19`	`PRIVATE libapp`
`16`	`20`	`PRIVATE libnetwork`
`17`	`21`	`)`
Original file line number	Diff line number	Diff line change
`@@ -2,7 +2,6 @@ find_package(Microsoft.GSL REQUIRED)`
`2`	`2`	`find_package(polymorphic_value REQUIRED)`
`3`	`3`
`4`	`4`	`add_library(libcpp`
`5`		`- aliases/cpp_chrono.cc`
`6`	`5`	`cpp_message_exception.cc`
`7`	`6`	`)`
`8`	`7`