fraport/fradrive-old
Archived
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(avs): eliminate call to undefined in Esqueleto.Internals

Browse Source
This commit is contained in:
Steffen Jost 2023-07-13 16:08:57 +00:00
parent 256740e15e
commit 240c6f81f8
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/Jobs/Handler/SynchroniseAvs.hs
View File

@ -12,9 +12,9 @@ module Jobs.Handler.SynchroniseAvs
import Import import Import
import qualified Database.Esqueleto.Legacy as E hiding (upsert) -- import qualified Database.Esqueleto.Legacy as E hiding (upsert)
import qualified Database.Esqueleto.PostgreSQL as E -- import qualified Database.Esqueleto.PostgreSQL as E
import qualified Database.Esqueleto.Utils as E -- import qualified Database.Esqueleto.Utils as E
import qualified Data.Conduit.List as C import qualified Data.Conduit.List as C
import Jobs.Queue import Jobs.Queue
@ -63,12 +63,17 @@ dispatchJobSynchroniseAvsUser uid pause = JobHandlerException $ runDB $ workJobS
workJobSychronizeAvs :: UserId -> Maybe Day -> DB () workJobSychronizeAvs :: UserId -> Maybe Day -> DB ()
workJobSychronizeAvs uid pause = do workJobSychronizeAvs uid pause = do
now <- liftIO getCurrentTime now <- liftIO getCurrentTime
void $ E.upsert -- void $ E.upsert
AvsSync { avsSyncUser = uid -- AvsSync { avsSyncUser = uid
, avsSyncCreationTime = now -- , avsSyncCreationTime = now
, avsSyncPause = pause -- , avsSyncPause = pause
} -- }
[ \oldSync -> (AvsSyncPause E.=. E.greatest (E.val pause) (oldSync E.^. AvsSyncPause)) oldSync ] -- [ \oldSync -> (AvsSyncPause E.=. E.greatest (E.val pause) (oldSync E.^. AvsSyncPause)) oldSync ] -- causes Esqueleto to call undefined at Database.Esqueleto.Internal.Internal.renderUpdates:1308
maybeM
(insert_ AvsSync{avsSyncUser=uid, avsSyncCreationTime=now, avsSyncPause=pause})
(\Entity{entityKey=asid, entityVal=AvsSync{avsSyncPause=oldPause}} ->
update asid [AvsSyncPause =. max pause oldPause, AvsSyncCreationTime =. now])
(getBy $ UniqueAvsSyncUser uid)
queueJob' JobSynchroniseAvsQueue queueJob' JobSynchroniseAvsQueue
dispatchJobSynchroniseAvsQueue :: JobHandler UniWorX dispatchJobSynchroniseAvsQueue :: JobHandler UniWorX