Merge pull request #21 from enigma-commits/EulerHd/New-function-for-f…

…etching-entries-from-kv-only-with-conditional-db

Added a new function for conditional access to db

src/EulerHS/KVConnector/Flow.hs

@@ -20,7 +20,8 @@ module EulerHS.KVConnector.Flow
     findAllWithOptionsKVConnector',
     deleteWithKVConnector,
     deleteReturningWithKVConnector,
-    deleteAllReturningWithKVConnector
+    deleteAllReturningWithKVConnector,
+    findAllWithKVAndConditionalDBInternal
   )
  where
 
@@ -897,8 +898,8 @@ findAllWithOptionsKVConnector' :: forall be table beM m.
   Maybe Int ->
   Maybe Int ->
   m (MeshResult [table Identity])
-findAllWithOptionsKVConnector' dbConf meshCfg whereClause mbLimit mbOffset = 
-  findAllWithOptionsHelper dbConf meshCfg whereClause Nothing mbLimit mbOffset
+findAllWithOptionsKVConnector' dbConf meshCfg whereClause  = 
+  findAllWithOptionsHelper dbConf meshCfg whereClause Nothing 
 
 findAllWithKVConnector :: forall be table beM m.
   ( HasCallStack,
@@ -925,7 +926,7 @@ findAllWithKVConnector dbConf meshCfg whereClause = do
           let matchedKVLiveRows = findAllMatching whereClause (fst kvRows)
           dbRes <- runQuery dbConf findAllQuery
           case dbRes of
-            Right dbRows -> pure $ Right $ matchedKVLiveRows ++ (getUniqueDBRes dbRows (fst kvRows ++ snd kvRows))
+            Right dbRows -> pure $ Right $ matchedKVLiveRows ++ getUniqueDBRes dbRows (fst kvRows ++ snd kvRows)
             Left err     -> return $ Left $ MDBError err
         Left err -> return $ Left err  
     else do
@@ -934,6 +935,41 @@ findAllWithKVConnector dbConf meshCfg whereClause = do
   let source = if not isDisabled then KV_AND_SQL else SQL
   pure res
 
+findAllWithKVAndConditionalDBInternal :: forall be table beM m.
+  ( HasCallStack,
+    BeamRuntime be beM,
+    Model be table,
+    MeshMeta be table,
+    KVConnector (table Identity),
+    ToJSON (table Identity),
+    FromJSON (table Identity),
+    Serialize.Serialize (table Identity),
+    L.MonadFlow m, B.HasQBuilder be, BeamRunner beM) =>
+  DBConfig beM ->
+  MeshConfig ->
+  Where be table ->
+  m (MeshResult [table Identity])
+findAllWithKVAndConditionalDBInternal dbConf meshCfg whereClause  = do
+  let isDisabled = meshCfg.kvHardKilled
+  if not isDisabled 
+    then do
+      kvRes <- redisFindAll meshCfg whereClause
+      case kvRes of
+        Right kvRows -> do
+          let matchedKVLiveRows = findAllMatching whereClause (fst kvRows)
+          if not (null matchedKVLiveRows)
+            then pure $ Right matchedKVLiveRows
+            else do
+              let findAllQueryUpdated = DB.findRows (sqlSelect ! #where_ whereClause ! defaults)
+              dbRes <- runQuery dbConf findAllQueryUpdated
+              case dbRes of
+                Right dbRows -> pure $ Right $ getUniqueDBRes dbRows (snd kvRows)
+                Left err     -> return $ Left $ MDBError err
+        Left err -> return $ Left err
+    else do
+      let findAllQuery = DB.findRows (sqlSelect ! #where_ whereClause ! defaults)
+      mapLeft MDBError <$> runQuery dbConf findAllQuery
+
 redisFindAll :: forall be table beM m.
   ( HasCallStack,
     BeamRuntime be beM,
@@ -977,7 +1013,7 @@ deleteObjectRedis :: forall table be beM m.
     -- Show (table Identity), --debugging purpose
     L.MonadFlow m
   ) =>
-  MeshConfig -> Bool -> Where be table -> (table Identity) -> m (MeshResult (table Identity))
+  MeshConfig -> Bool -> Where be table -> table Identity -> m (MeshResult (table Identity))
 deleteObjectRedis meshCfg addPrimaryKeyToWhereClause whereClause obj = do
   time <- fromIntegral <$> L.getCurrentDateInMillis
   let pKeyText  = getLookupKeyByPKey obj