yam-job (empty) → 0.1.0.0

raw patch · 5 files changed

+110/−0 lines, 5 filesdep +basedep +crondep +yam-appsetup-changed

Dependencies added: base, cron, yam-app

Files

• LICENSE +30/−0
• README.md +1/−0
• Setup.hs +2/−0
• src/Yam/Job.hs +52/−0
• yam-job.cabal +25/−0

@@ -0,0 +1,30 @@+Copyright Daniel YU (c) 2018++All rights reserved.++Redistribution and use in source and binary forms, with or without+modification, are permitted provided that the following conditions are met:++    * Redistributions of source code must retain the above copyright+      notice, this list of conditions and the following disclaimer.++    * Redistributions in binary form must reproduce the above+      copyright notice, this list of conditions and the following+      disclaimer in the documentation and/or other materials provided+      with the distribution.++    * Neither the name of Daniel YU nor the names of other+      contributors may be used to endorse or promote products derived+      from this software without specific prior written permission.++THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS+"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT+LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR+A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT+OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,+SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT+LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,+DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY+THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

@@ -0,0 +1,1 @@+# yam-job

@@ -0,0 +1,2 @@+import           Distribution.Simple+main = defaultMain

@@ -0,0 +1,52 @@+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE FlexibleInstances     #-}+{-# LANGUAGE OverloadedStrings     #-}+{-# LANGUAGE TypeSynonymInstances  #-}++module Yam.Job(+    YamJob(..)+  , MonadJob(..)+  , startJob+  ) where++import           Yam.App++import           System.Cron++data YamJob = YamJob+  { name :: Text+  , cron :: Text+  , func :: AppM IO ()+  }++class MonadIO m => MonadJob m where+  yamJobs :: m [(ThreadId, YamJob)]+  registerJob :: YamJob -> m ()+  killJobs :: m ()++keyJob :: Text+keyJob = "Extension.Job"++instance MonadIO m => MonadJob (AppM m) where+  yamJobs = getExtensionOrDefault [] keyJob+  killJobs = yamJobs >>= mapM_ go >> setExtension keyJob ([] :: [(ThreadId, YamJob)])+    where go (tid,job) = do infoLn $ "Stop job " <> name (job :: YamJob) <> "..."+                            liftIO $ killThread tid+  registerJob job = do+    let nm = name (job :: YamJob)+    infoLn $ "Register job " <> nm <> " with cron '" <> cron job <> "'"+    context  <- ask+    [thread] <- liftIO $ execSchedule+                      $ flip addJob (cron job)+                      $ do reqId <- randomHex 8+                           runAppM context $ withLoggerName (reqId <> " job." <> nm)+                                           $ do infoLn $ "Start job " <> nm+                                                func job+                                                infoLn $ "End job " <> nm+    jobs <- yamJobs+    setExtension keyJob ((thread,job):jobs)++startJob :: [YamJob] -> (YamContext -> IO YamContext) -> IO ()+startJob jobs initialize = do+  context <- defaultContext >>= initialize+  runAppM context $ mapM_ registerJob jobs

@@ -0,0 +1,25 @@+name:                yam-job+version:             0.1.0.0+description:         Job Module for Yam+homepage:            https://github.com/leptonyu/yam-job#readme+license:             BSD3+license-file:        LICENSE+author:              Daniel YU+maintainer:          i@icymint.me+copyright:           Copyright: (c) 2017 Daniel YU+category:            Web+build-type:          Simple+extra-source-files:  README.md+cabal-version:       >=1.10++library+  hs-source-dirs:      src+  exposed-modules:     Yam.Job+  build-depends:       base >= 4.7 && < 5+                     , yam-app+                     , cron+  default-language:    Haskell2010++source-repository head+  type:     git+  location: https://github.com/leptonyu/yam-job