backend: update flake.lock and flake.nix for async pipeline operation…

…; add findAllFromKvRedis function (#697)
nammayatri · Dec 3, 2024 · 1ad649c · 1ad649c
1 parent bc9bcf2
commit 1ad649c
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 3 deletions.
diff --git a/flake.lock b/flake.lock
diff --git a/lib/mobility-core/src/Kernel/Beam/Functions.hs b/lib/mobility-core/src/Kernel/Beam/Functions.hs
@@ -29,6 +29,7 @@ module Kernel.Beam.Functions
     findAllWithKVAndConditionalDB,
     findOneWithKVRedis,
     logQueryData,
+    findAllFromKvRedis,
   )
 where
 
@@ -317,6 +318,26 @@ findAllWithKVAndConditionalDB where' orderBy = do
       pure $ catMaybes res'
     Left err -> throwError $ InternalError $ show err
 
+findAllFromKvRedis ::
+  forall table m r a.
+  ( BeamTableFlow table m,
+    CacheFlow m r,
+    EsqDBFlow m r,
+    FromTType' (table Identity) a
+  ) =>
+  Where Postgres table ->
+  Maybe (OrderBy table) ->
+  m [a]
+findAllFromKvRedis where' orderBy = do
+  updatedMeshConfig <- setMeshConfig (modelTableName @table) (modelSchemaName @table) meshConfig
+  dbConf' <- getReadDBConfigInternal (modelTableName @table)
+  result <- KV.findAllFromKvRedis dbConf' updatedMeshConfig where' orderBy
+  case result of
+    Right res -> do
+      res' <- mapM fromTType' res
+      pure $ catMaybes res'
+    Left err -> throwError $ InternalError $ show err
+
 -- findAllWithOptions --
 
 findAllWithOptionsKV ::