add integration tests to sync a wallet (via 'watchWallet')

cardano-wallet.cabal

@@ -203,6 +203,7 @@ test-suite integration
   main-is:
       Main.hs
   other-modules:
+      Cardano.WalletSpec
       Cardano.Wallet.Network.HttpBridgeSpec
       Cardano.Launcher
       Test.Integration.Framework.DSL

test/integration/Cardano/Wallet/Network/HttpBridgeSpec.hs

@@ -27,8 +27,8 @@ import Control.Monad.Trans.Except
     ( runExceptT )
 import Test.Hspec
     ( Spec
-    , afterAll
-    , beforeAll
+    , after
+    , before
     , describe
     , it
     , shouldReturn
@@ -43,7 +43,7 @@ port = 1337
 
 spec :: Spec
 spec = do
-    describe "Happy paths" $ beforeAll startBridge $ afterAll (cancel . fst) $ do
+    describe "Happy paths" $ before startBridge $ after (cancel . fst) $ do
         it "get from packed epochs" $ \(_, network) -> do
             let blocks = runExceptT $ nextBlocks network (SlotId 14 0)
             (fmap length <$> blocks)

test/integration/Cardano/WalletSpec.hs

@@ -0,0 +1,78 @@
+{-# LANGUAGE DataKinds #-}
+{-# LANGUAGE LambdaCase #-}
+{-# LANGUAGE TupleSections #-}
+{-# LANGUAGE TypeApplications #-}
+
+module Cardano.WalletSpec
+    ( spec
+    ) where
+
+import Prelude
+
+import Cardano.Launcher
+    ( Command (..), launch )
+import Cardano.Wallet
+    ( NewWallet (..), WalletLayer (..), mkWalletLayer )
+import Cardano.Wallet.Primitive.Mnemonic
+    ( EntropySize, entropyToMnemonic, genEntropy )
+import Cardano.Wallet.Primitive.Model
+    ( WalletName (..), currentTip )
+import Cardano.Wallet.Primitive.Types
+    ( SlotId (..) )
+import Control.Concurrent
+    ( threadDelay )
+import Control.Concurrent.Async
+    ( async, cancel )
+import Control.Monad
+    ( (>=>) )
+import Control.Monad.Fail
+    ( MonadFail )
+import Control.Monad.Trans.Except
+    ( ExceptT, runExceptT )
+import Test.Hspec
+    ( Spec, after, before, it, shouldSatisfy )
+
+import qualified Cardano.Wallet.DB.MVar as MVar
+import qualified Cardano.Wallet.Network.HttpBridge as HttpBridge
+
+spec :: Spec
+spec = do
+    before startBridge $ after closeBridge $ do
+        it "A newly created wallet can sync with the chain" $ \(_, wallet) -> do
+            mnemonicSentence <-
+                entropyToMnemonic <$> genEntropy @(EntropySize 15)
+            wid <- unsafeRunExceptT $ createWallet wallet NewWallet
+                { mnemonic = mnemonicSentence
+                , mnemonic2ndFactor = mempty
+                , name = WalletName "My Wallet"
+                , passphrase = mempty
+                , gap = minBound
+                }
+            handle <- async (watchWallet wallet wid)
+            threadDelay 5000000
+            cancel handle
+            tip <- currentTip <$> unsafeRunExceptT (getWallet wallet wid)
+            tip `shouldSatisfy` (> SlotId 0 0)
+  where
+    port = 1337
+    closeBridge = cancel . fst
+    startBridge = do
+        handle <- async $ launch
+            [ Command "cardano-http-bridge"
+                [ "start"
+                , "--port", show port
+                , "--template", "testnet"
+                ]
+                (return ())
+            ]
+        threadDelay 1000000
+        (handle,) <$> (mkWalletLayer
+            <$> MVar.newDBLayer
+            <*> HttpBridge.newNetworkLayer "testnet" port)
+
+unsafeRunExceptT :: (MonadFail m, Show e) => ExceptT e m a -> m a
+unsafeRunExceptT = runExceptT >=> \case
+    Left e ->
+        fail $ "unable to perform expect IO action: " <> show e
+    Right a ->
+        return a

test/integration/Main.hs

@@ -34,11 +34,13 @@ import Test.Integration.Framework.DSL
     )
 
 import qualified Cardano.Wallet.Network.HttpBridgeSpec as HttpBridge
+import qualified Cardano.WalletSpec as Wallet
 import qualified Data.Text as T
 
 main :: IO ()
 main = do
     hspec $ do
+        describe "Cardano.WalletSpec" Wallet.spec
         describe "Cardano.Wallet.Network.HttpBridge" HttpBridge.spec
 
         beforeAll (withWallet (newMVar . Context ())) $ do