upd: moved the bot part to a relative subfolder

1 files changed, 0 insertions, 70 deletions

diff --git a/src/timer.cpp b/src/timer.cpp
deleted file mode 100644
index 055dde0..0000000
--- a/src/timer.cpp
+++ /dev/null
@@ -1,70 +0,0 @@
-#include "timer.hpp"
-
-#include <chrono>
-#include <pqxx/pqxx>
-#include <string>
-#include <thread>
-
-#include "config.hpp"
-#include "irc/client.hpp"
-#include "utils/chrono.hpp"
-
-namespace bot {
-  void create_timer_thread(irc::Client *irc_client,
-                           Configuration *configuration) {
-    while (true) {
-      pqxx::connection conn(GET_DATABASE_CONNECTION_URL_POINTER(configuration));
-      pqxx::work *work = new pqxx::work(conn);
-
-      pqxx::result timers = work->exec(
-          "SELECT id, interval_sec, message, channel_id, last_executed_at FROM "
-          "timers");
-
-      for (const auto &timer : timers) {
-        int id = timer[0].as<int>();
-        int interval_sec = timer[1].as<int>();
-        std::string message = timer[2].as<std::string>();
-        int channel_id = timer[3].as<int>();
-
-        // it could be done in sql query
-        std::chrono::system_clock::time_point last_executed_at =
-            utils::chrono::string_to_time_point(timer[4].as<std::string>());
-        auto now = std::chrono::system_clock::now();
-        auto now_time_it = std::chrono::system_clock::to_time_t(now);
-        auto now_tm = std::gmtime(&now_time_it);
-        now = std::chrono::system_clock::from_time_t(std::mktime(now_tm));
-
-        auto difference = std::chrono::duration_cast<std::chrono::seconds>(
-            now - last_executed_at);
-
-        if (difference.count() > interval_sec) {
-          pqxx::result channels = work->exec(
-              "SELECT alias_name, opted_out_at FROM channels WHERE id = " +
-              std::to_string(channel_id));
-
-          if (!channels.empty() && channels[0][1].is_null()) {
-            std::string alias_name = channels[0][0].as<std::string>();
-
-            irc_client->say(alias_name, message);
-          }
-
-          work->exec(
-              "UPDATE timers SET last_executed_at = timezone('utc', now()) "
-              "WHERE "
-              "id = " +
-              std::to_string(id));
-
-          work->commit();
-
-          delete work;
-          work = new pqxx::work(conn);
-        }
-      }
-
-      delete work;
-      conn.close();
-
-      std::this_thread::sleep_for(std::chrono::seconds(1));
-    }
-  }
-}