Backend/feat/master cloud forwarder

lib/mobility-core/mobility-core.cabal

@@ -132,6 +132,7 @@ library
       Kernel.External.Maps.OSRM.RoadsClient
       Kernel.External.Maps.Types
       Kernel.External.Maps.Utils
+      Kernel.External.MasterCloudForward
       Kernel.External.MultiModal
       Kernel.External.MultiModal.Interface
       Kernel.External.MultiModal.Interface.Google
@@ -155,6 +156,12 @@ library
       Kernel.External.Notification.PayTM.Client
       Kernel.External.Notification.PayTM.Types
       Kernel.External.Notification.Types
+      Kernel.External.PartnerSdk.Aarokya.Flow
+      Kernel.External.PartnerSdk.Aarokya.Types
+      Kernel.External.PartnerSdk.Interface
+      Kernel.External.PartnerSdk.Interface.Aarokya
+      Kernel.External.PartnerSdk.Interface.Types
+      Kernel.External.PartnerSdk.Types
       Kernel.External.Payment.Interface
       Kernel.External.Payment.Interface.Events.Types
       Kernel.External.Payment.Interface.Juspay
@@ -731,6 +738,163 @@ library
     , xmlbf
   default-language: Haskell2010
 
+executable master-cloud-forward-itest
+  main-is: Main.hs
+  other-modules:
+      Paths_mobility_core
+  hs-source-dirs:
+      test-integration
+  default-extensions:
+      ConstraintKinds
+      DataKinds
+      DefaultSignatures
+      DeriveAnyClass
+      DeriveFunctor
+      DeriveGeneric
+      DuplicateRecordFields
+      ExplicitNamespaces
+      FlexibleContexts
+      FlexibleInstances
+      FunctionalDependencies
+      GADTs
+      LambdaCase
+      MultiParamTypeClasses
+      MultiWayIf
+      NamedFieldPuns
+      NoImplicitPrelude
+      OverloadedLabels
+      OverloadedStrings
+      PatternSynonyms
+      PolyKinds
+      RankNTypes
+      RecordWildCards
+      ScopedTypeVariables
+      TupleSections
+      TypeApplications
+      TypeFamilies
+      TypeOperators
+      ViewPatterns
+      BlockArguments
+      TypeSynonymInstances
+      UndecidableInstances
+  ghc-options: -fwrite-ide-info -hiedir=.hie -Wall -Wcompat -Widentities -fhide-source-paths -Werror -fplugin=RecordDotPreprocessor -Wwarn=ambiguous-fields
+  build-depends:
+      aeson
+    , aeson-casing
+    , async
+    , base >=4.7 && <5
+    , base64
+    , base64-bytestring
+    , beam-core
+    , beam-mysql
+    , beam-postgres
+    , bimap
+    , bytestring
+    , case-insensitive
+    , casing
+    , cassava
+    , cereal
+    , clickhouse-haskell
+    , clock
+    , concurrency
+    , containers
+    , cryptonite
+    , data-default-class
+    , deriving-aeson
+    , dhall
+    , directory
+    , double-conversion
+    , either
+    , esqueleto
+    , euler-hs
+    , exceptions
+    , extra
+    , fast-logger
+    , filepath
+    , fmt
+    , formatting
+    , generic-lens
+    , geojson
+    , hashable
+    , hedis
+    , hex-text
+    , hspec
+    , http-api-data
+    , http-client
+    , http-client-tls
+    , http-media
+    , http-types
+    , hw-kafka-client
+    , insert-ordered-containers
+    , jwt
+    , kleene
+    , lattices
+    , lens
+    , memory
+    , mobility-core
+    , monad-logger
+    , morpheus-graphql-client
+    , mtl
+    , network
+    , openapi3
+    , parsec
+    , passetto-client
+    , persistent
+    , persistent-postgresql
+    , postgresql-migration
+    , postgresql-simple
+    , process
+    , prometheus-client
+    , prometheus-metrics-ghc
+    , prometheus-proc
+    , random
+    , random-strings
+    , record-dot-preprocessor
+    , record-hasfield
+    , regex-compat
+    , resource-pool
+    , safe
+    , safe-exceptions
+    , safe-money
+    , scientific
+    , sequelize
+    , servant
+    , servant-client
+    , servant-client-core
+    , servant-multipart
+    , servant-multipart-api
+    , servant-multipart-client
+    , servant-openapi3
+    , servant-server
+    , singletons-th
+    , slack-web
+    , split
+    , stm
+    , string-conversions
+    , tasty
+    , tasty-hunit
+    , template-haskell
+    , text
+    , text-conversions
+    , time
+    , tinylog
+    , transformers
+    , universum
+    , unix
+    , unliftio
+    , unliftio-core
+    , unordered-containers
+    , uuid
+    , vector
+    , wai
+    , wai-app-static
+    , wai-middleware-prometheus
+    , warp
+    , xml-conduit
+    , xml-types
+    , xmlbf
+  default-language: Haskell2010
+
 test-suite mobility-core-tests
   type: exitcode-stdio-1.0
   main-is: Main.hs

lib/mobility-core/package.yaml

@@ -187,3 +187,13 @@ tests:
       - test/src
     dependencies:
       - mobility-core
+
+executables:
+  master-cloud-forward-itest:
+    main: Main.hs
+    source-dirs:
+      - test-integration
+    dependencies:
+      - mobility-core
+      - async
+      - http-client-tls

lib/mobility-core/src/Kernel/Beam/Connection/EnvVars.hs

@@ -70,3 +70,8 @@ getRunInMasterLTSRedisCell :: IO Bool
 getRunInMasterLTSRedisCell = do
   envVal <- lookupEnv "RUN_IN_MASTER_LTS_REDIS_CELL"
   pure (fromMaybe False (readMaybe =<< envVal))
+
+getClusterMGetAsyncEnabled :: IO Bool
+getClusterMGetAsyncEnabled = do
+  envVal <- lookupEnv "CLUSTER_MGET_ASYNC_ENABLED"
+  pure (fromMaybe False (readMaybe =<< envVal))