Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
SCP-5027 wip on e2e tests for get transactions
- Loading branch information
Showing
4 changed files
with
221 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
189 changes: 189 additions & 0 deletions
189
marlowe-integration-tests/test/Language/Marlowe/Runtime/Web/GetTransactions.hs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,189 @@ | ||
| module Language.Marlowe.Runtime.Web.GetTransactions | ||
| where | ||
|
|
||
| import Control.Monad.IO.Class (MonadIO(liftIO)) | ||
|
|
||
| import Control.Exception (throw) | ||
| import Data.Proxy (Proxy(Proxy)) | ||
| import qualified Language.Marlowe.Runtime.ChainSync.Api as Chain | ||
| import Language.Marlowe.Runtime.Integration.Common | ||
| import qualified Language.Marlowe.Runtime.Web as Web | ||
| import Language.Marlowe.Runtime.Web.Client (Page(..), getContracts, getTransactions) | ||
| import Language.Marlowe.Runtime.Web.Common (applyCloseTransaction, createCloseContract) | ||
| import Language.Marlowe.Runtime.Web.Server.DTO (ToDTO(toDTO)) | ||
| import Network.HTTP.Types (Status(..)) | ||
| import Servant.Client (ClientError(FailureResponse)) | ||
| import Servant.Client.Streaming (ResponseF(Response, responseStatusCode)) | ||
| import Servant.Pagination (Range(..), RangeOrder(..)) | ||
| import Test.Hspec (Spec, describe, focus, it, shouldBe) | ||
| import Test.Integration.Marlowe.Local (withLocalMarloweRuntime) | ||
|
|
||
| spec :: Spec | ||
| spec = describe "GET /contracts/{contractId}/transactions" do | ||
| getTransactionsValidSpec | ||
| getTransactionsInvalidSpec | ||
| getTransactionsValidNextPageSpec | ||
|
|
||
| getTransactionsValidSpec :: Spec | ||
| getTransactionsValidSpec = describe "Valid GET /contracts/{contractId}/transactions" do | ||
| noTransactionsValidSpec | ||
| singleTransactionValidSpec | ||
| multipleTransactionsValidSpec | ||
|
|
||
| getTransactionsInvalidSpec :: Spec | ||
| getTransactionsInvalidSpec = describe "Invalid GET /contracts/{contractId}/transactions" do | ||
| invalidTxIdSpec | ||
|
|
||
| getTransactionsValidNextPageSpec :: Spec | ||
| getTransactionsValidNextPageSpec = describe "Valid Pagination of GET /contracts/{contractId}/transactions" do | ||
| firstPageAscValidSpec | ||
| secondPageAscValidSpec | ||
| firstPageDescValidSpec | ||
| secondPageDescValidSpec | ||
|
|
||
| firstPageAscValidSpec :: Spec | ||
| firstPageAscValidSpec = it "returns the first page of contract headers in ascending order" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet1 <- getGenesisWallet 0 | ||
| wallet2 <- getGenesisWallet 1 | ||
| wallet3 <- getGenesisWallet 2 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| expectedContractId1 <- createCloseContract wallet1 | ||
| expectedContractId2 <- createCloseContract wallet2 | ||
| _ <- createCloseContract wallet3 | ||
| let | ||
| testRange = Range | ||
| { | ||
| rangeValue = Just expectedContractId1 | ||
| , rangeOffset = 0 | ||
| , rangeLimit = 2 | ||
| , rangeOrder = RangeAsc | ||
| , rangeField = Proxy | ||
| } | ||
| Page {..} <-getContracts $ Just testRange | ||
|
|
||
| liftIO $ fmap (\Web.ContractHeader{..} -> contractId) items `shouldBe` [expectedContractId1, expectedContractId2] | ||
|
|
||
| secondPageAscValidSpec :: Spec | ||
| secondPageAscValidSpec = it "returns the second page of contract headers in ascending order" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet1 <- getGenesisWallet 0 | ||
| wallet2 <- getGenesisWallet 1 | ||
| wallet3 <- getGenesisWallet 2 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| expectedContractId1 <- createCloseContract wallet1 | ||
| expectedContractId2 <- createCloseContract wallet2 | ||
| expectedContractId3 <- createCloseContract wallet3 | ||
| let | ||
| testRange = Range | ||
| { | ||
| rangeValue = Just expectedContractId1 | ||
| , rangeOffset = 1 | ||
| , rangeLimit = 2 | ||
| , rangeOrder = RangeAsc | ||
| , rangeField = Proxy | ||
| } | ||
| Page {..} <-getContracts $ Just testRange | ||
|
|
||
| liftIO $ fmap (\Web.ContractHeader{..} -> contractId) items `shouldBe` [expectedContractId2, expectedContractId3] | ||
|
|
||
| firstPageDescValidSpec :: Spec | ||
| firstPageDescValidSpec = it "returns the first page of contract headers in descending order" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet1 <- getGenesisWallet 0 | ||
| wallet2 <- getGenesisWallet 1 | ||
| wallet3 <- getGenesisWallet 2 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| _ <- createCloseContract wallet1 | ||
| expectedContractId2 <- createCloseContract wallet2 | ||
| expectedContractId3 <- createCloseContract wallet3 | ||
| let | ||
| testRange = Range | ||
| { | ||
| rangeValue = Just expectedContractId3 | ||
| , rangeOffset = 0 | ||
| , rangeLimit = 2 | ||
| , rangeOrder = RangeDesc | ||
| , rangeField = Proxy | ||
| } | ||
| Page {..} <-getContracts $ Just testRange | ||
|
|
||
| liftIO $ fmap (\Web.ContractHeader{..} -> contractId) items `shouldBe` [expectedContractId3, expectedContractId2] | ||
|
|
||
| secondPageDescValidSpec :: Spec | ||
| secondPageDescValidSpec = it "returns the second page of contract headers in descending order" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet1 <- getGenesisWallet 0 | ||
| wallet2 <- getGenesisWallet 1 | ||
| wallet3 <- getGenesisWallet 2 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| expectedContractId1 <- createCloseContract wallet1 | ||
| expectedContractId2 <- createCloseContract wallet2 | ||
| expectedContractId3 <- createCloseContract wallet3 | ||
| let | ||
| testRange = Range | ||
| { | ||
| rangeValue = Just expectedContractId3 | ||
| , rangeOffset = 1 | ||
| , rangeLimit = 2 | ||
| , rangeOrder = RangeDesc | ||
| , rangeField = Proxy | ||
| } | ||
| Page {..} <-getContracts $ Just testRange | ||
|
|
||
| liftIO $ fmap (\Web.ContractHeader{..} -> contractId) items `shouldBe` [expectedContractId2, expectedContractId1] | ||
|
|
||
|
|
||
| noTransactionsValidSpec :: Spec | ||
| noTransactionsValidSpec = it "returns an empty list when no transactions exist" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet <- getGenesisWallet 0 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| sampleContractId <- createCloseContract wallet | ||
| Page {..}<- getTransactions sampleContractId Nothing | ||
| liftIO $ fmap (\Web.TxHeader{..} -> transactionId) items `shouldBe` [] | ||
|
|
||
| singleTransactionValidSpec :: Spec | ||
| singleTransactionValidSpec = it "returns a list with single Tx header" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet <- getGenesisWallet 0 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| sampleContractId <- createCloseContract wallet | ||
| expectedTxId <- applyCloseTransaction wallet sampleContractId | ||
| Page {..}<- getTransactions sampleContractId Nothing | ||
|
|
||
| liftIO $ fmap (\Web.TxHeader{..} -> transactionId) items `shouldBe` [expectedTxId] | ||
|
|
||
| multipleTransactionsValidSpec :: Spec | ||
| multipleTransactionsValidSpec = focus $ it "returns a list with multiple Tx headers" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| wallet1 <- getGenesisWallet 0 | ||
| wallet2 <- getGenesisWallet 1 | ||
|
|
||
| either throw pure =<< runWebClient do | ||
| expectedContractId1 <- createCloseContract wallet1 | ||
| _ <- applyCloseTransaction wallet1 expectedContractId1 | ||
| expectedContractId2 <- createCloseContract wallet2 | ||
| expectedTxId <- applyCloseTransaction wallet2 expectedContractId2 | ||
| Page {..}<- getTransactions expectedContractId2 Nothing | ||
| liftIO $ fmap (\Web.TxHeader{..} -> transactionId) items `shouldBe` [expectedTxId] | ||
|
|
||
|
|
||
| invalidTxIdSpec :: Spec | ||
| invalidTxIdSpec = it "returns an error message" $ withLocalMarloweRuntime $ runIntegrationTest do | ||
| result <- runWebClient do | ||
| let | ||
| invalidRange = Range | ||
| { | ||
| rangeValue = Just $ Web.TxOutRef (toDTO @Chain.TxId "0000000000000000000000000000000000000000000000000000000000000000") 1 | ||
| , rangeOffset = 0 | ||
| , rangeLimit = 1 | ||
| , rangeOrder = RangeAsc | ||
| , rangeField = Proxy | ||
| } | ||
| getContracts $ Just invalidRange | ||
|
|
||
| case result of | ||
| Left (FailureResponse _ Response { responseStatusCode = Status { statusCode = 416 } } ) -> pure () | ||
| _ -> fail $ "Expected 416 response code - got " <> show result | ||
|
|
||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters