From 11052951b74b9ad4b6a9412ae490086235f9154b Mon Sep 17 00:00:00 2001
From: Joris
Date: Sun, 3 Jan 2021 13:40:40 +0100
Subject: Rewrite in Rust

---
 server/src/Job/Daemon.hs | 37 -------------------------------------
 1 file changed, 37 deletions(-)
 delete mode 100644 server/src/Job/Daemon.hs

(limited to 'server/src/Job/Daemon.hs')

diff --git a/server/src/Job/Daemon.hs b/server/src/Job/Daemon.hs
deleted file mode 100644
index d8cd522..0000000
--- a/server/src/Job/Daemon.hs
+++ /dev/null
@@ -1,37 +0,0 @@
-module Job.Daemon
-  ( runDaemons
-  ) where
-
-import           Control.Concurrent (ThreadId, forkIO, threadDelay)
-import           Control.Monad      (forever)
-import           Data.Time.Clock    (UTCTime)
-
-import           Conf               (Conf)
-import           Job.Frequency      (Frequency (..), microSeconds)
-import           Job.Kind           (Kind (..))
-import           Job.Model          (actualizeLastCheck, actualizeLastExecution,
-                                     getLastExecution)
-import           Job.MonthlyPayment (monthlyPayment)
-import           Job.WeeklyReport   (weeklyReport)
-import qualified Model.Query        as Query
-import           Util.Time          (belongToCurrentMonth, belongToCurrentWeek)
-
-runDaemons :: Conf -> IO ()
-runDaemons conf = do
-  _ <- runDaemon MonthlyPayment EveryHour (fmap not . belongToCurrentMonth) monthlyPayment
-  _ <- runDaemon WeeklyReport EveryHour (fmap not . belongToCurrentWeek) (weeklyReport conf)
-  return ()
-
-runDaemon :: Kind -> Frequency -> (UTCTime -> IO Bool) -> (Maybe UTCTime -> IO UTCTime) -> IO ThreadId
-runDaemon kind frequency isLastExecutionTooOld runJob =
-  forkIO . forever $ do
-    mbLastExecution <- Query.run $ do
-      actualizeLastCheck kind
-      getLastExecution kind
-    hasToRun <- case mbLastExecution of
-      Just lastExecution -> isLastExecutionTooOld lastExecution
-      Nothing            -> return True
-    if hasToRun
-      then runJob mbLastExecution >>= (Query.run . actualizeLastExecution kind)
-      else return ()
-    threadDelay . microSeconds $ frequency
-- 
cgit v1.2.3