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

…; add findAllFromKvRedis function
nammayatri · Dec 2, 2024 · 366dd31 · 366dd31
1 parent 9cc2912
commit 366dd31
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 4 deletions.
diff --git a/flake.lock b/flake.lock
diff --git a/flake.nix b/flake.nix
@@ -13,7 +13,7 @@
     prometheus-haskell.inputs.haskell-flake.follows = "common/haskell-flake";
 
     euler-hs = {
-      url = "github:nammayatri/euler-hs";
+      url = "github:nammayatri/euler-hs/backend/async-pipeline-operation";
       inputs.nixpkgs.follows = "nixpkgs";
       inputs.haskell-flake.follows = "haskell-flake";
     };

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 ::