-
Notifications
You must be signed in to change notification settings - Fork 198
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Speedy: building transactions with rollback (#8983)
* WIP
add LF examples to test try-catch & throw
add (integer) info to template for created contracts
call {begin,end,abort,rollback}Try during speedy on-ledger execution
add test to exercise abortTry
changelog_begin
changelog_end
* share boilerplate in test setup
* test value of created contracts, not just the count
* naming
* avoid Scenarios in tests. Just working directly with Update expressions
* use machine.withOnLedger, so crash if we are not- Loading branch information
1 parent
98410e7
commit 7514074
Showing
4 changed files
with
236 additions
and
6 deletions.
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
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
187 changes: 187 additions & 0 deletions
187
daml-lf/interpreter/src/test/scala/com/digitalasset/daml/lf/speedy/RollbackTest.scala
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,187 @@ | ||
| // Copyright (c) 2021 Digital Asset (Switzerland) GmbH and/or its affiliates. All rights reserved. | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| package com.daml.lf | ||
| package speedy | ||
|
|
||
| import com.daml.lf.PureCompiledPackages | ||
| import com.daml.lf.data.ImmArray | ||
| import com.daml.lf.data.Ref.Party | ||
| import com.daml.lf.language.Ast._ | ||
| import com.daml.lf.speedy.Compiler.FullStackTrace | ||
| import com.daml.lf.speedy.PartialTransaction._ | ||
| import com.daml.lf.speedy.SResult._ | ||
| import com.daml.lf.testing.parser.Implicits._ | ||
| import com.daml.lf.transaction.Node | ||
| import com.daml.lf.transaction.SubmittedTransaction | ||
| import com.daml.lf.validation.Validation | ||
| import com.daml.lf.value.Value | ||
| import com.daml.lf.value.Value._ | ||
|
|
||
| import org.scalatest.matchers.should.Matchers | ||
| import org.scalatest.prop.TableDrivenPropertyChecks | ||
| import org.scalatest.wordspec.AnyWordSpec | ||
|
|
||
| class ExceptionTest extends AnyWordSpec with Matchers with TableDrivenPropertyChecks { | ||
|
|
||
| private def typeAndCompile(pkg: Package): PureCompiledPackages = { | ||
| val rawPkgs = Map(defaultParserParameters.defaultPackageId -> pkg) | ||
| Validation.checkPackage(rawPkgs, defaultParserParameters.defaultPackageId, pkg) | ||
| data.assertRight( | ||
| PureCompiledPackages(rawPkgs, Compiler.Config.Default.copy(stacktracing = FullStackTrace)) | ||
| ) | ||
| } | ||
|
|
||
| private def runUpdateExprGetTx( | ||
| pkgs1: PureCompiledPackages | ||
| )(e: Expr, party: Party): SubmittedTransaction = { | ||
| def transactionSeed: crypto.Hash = crypto.Hash.hashPrivateKey("RollbackTest.scala") | ||
| val machine = Speedy.Machine.fromUpdateExpr(pkgs1, transactionSeed, e, party) | ||
| val res = machine.run() | ||
| res match { | ||
| case _: SResultFinalValue => | ||
| machine.withOnLedger("RollbackTest") { onLedger => | ||
| onLedger.ptx.finish match { | ||
| case IncompleteTransaction(_) => | ||
| sys.error("unexpected IncompleteTransaction") | ||
| case CompleteTransaction(tx) => | ||
| tx | ||
| } | ||
| } | ||
| case _ => | ||
| sys.error(s"unexpected res: $res") | ||
| } | ||
| } | ||
|
|
||
| val pkgs: PureCompiledPackages = typeAndCompile(p""" | ||
| module M { | ||
|
|
||
| record @serializable MyException = { message: Text } ; | ||
|
|
||
| exception MyException = { | ||
| message \(e: M:MyException) -> M:MyException {message} e | ||
| }; | ||
|
|
||
| record @serializable T1 = { party: Party, info: Int64 } ; | ||
| template (record : T1) = { | ||
| precondition True, | ||
| signatories Cons @Party [(M:T1 {party} record)] (Nil @Party), | ||
| observers Nil @Party, | ||
| agreement "Agreement", | ||
| choices { | ||
| } | ||
| }; | ||
|
|
||
| val create0 : Party -> Update Unit = \(party: Party) -> | ||
| upure @Unit (); | ||
|
|
||
| val create1 : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 } | ||
| in upure @Unit (); | ||
|
|
||
| val create2 : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 } | ||
| in upure @Unit (); | ||
|
|
||
| val create3 : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 }; | ||
| x3: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 300 } | ||
| in upure @Unit (); | ||
|
|
||
| val create3nested : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| u1: Unit <- | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 } | ||
| in upure @Unit (); | ||
| x3: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 300 } | ||
| in upure @Unit (); | ||
|
|
||
| val create3catchNoThrow : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| u1: Unit <- | ||
| try @Unit | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 } | ||
| in upure @Unit () | ||
| catch e -> Some @(Update Unit) (upure @Unit ()) | ||
| ; | ||
| x3: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 300 } | ||
| in upure @Unit (); | ||
|
|
||
| val create3throwAndCatch : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| u1: Unit <- | ||
| try @Unit | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 } | ||
| in throw @(Update Unit) @M:MyException (M:MyException {message = "oops"}) | ||
| catch e -> Some @(Update Unit) (upure @Unit ()) | ||
| ; | ||
| x3: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 300 } | ||
| in upure @Unit (); | ||
|
|
||
| val create3throwAndOuterCatch : Party -> Update Unit = \(party: Party) -> | ||
| ubind | ||
| u1: Unit <- | ||
| try @Unit | ||
| try @Unit | ||
| ubind | ||
| x1: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 100 }; | ||
| x2: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 200 } | ||
| in throw @(Update Unit) @M:MyException (M:MyException {message = "oops"}) | ||
| catch e -> None @(Update Unit) | ||
| catch e -> Some @(Update Unit) (upure @Unit ()) | ||
| ; | ||
| x3: ContractId M:T1 <- create @M:T1 M:T1 { party = party, info = 300 } | ||
| in upure @Unit (); | ||
|
|
||
| } | ||
| """) | ||
|
|
||
| val testCases = Table[String, List[Long]]( | ||
| ("expression", "expected-number-of-contracts"), | ||
| ("create0", Nil), | ||
| ("create1", List(100)), | ||
| ("create2", List(100, 200)), | ||
| ("create3", List(100, 200, 300)), | ||
| ("create3nested", List(100, 200, 300)), | ||
| ("create3catchNoThrow", List(100, 200, 300)), | ||
| ("create3throwAndCatch", List(300)), | ||
| ("create3throwAndOuterCatch", List(300)), | ||
| ) | ||
|
|
||
| forEvery(testCases) { (exp: String, expected: List[Long]) => | ||
| s"""$exp, contracts expected: $expected """ in { | ||
| val party = Party.assertFromString("Alice") | ||
| val lit: PrimLit = PLParty(party) | ||
| val arg: Expr = EPrimLit(lit) | ||
| val example: Expr = EApp(e"M:$exp", arg) | ||
| val tx: SubmittedTransaction = runUpdateExprGetTx(pkgs)(example, party) | ||
| val ids: Seq[Long] = contractValuesInOrder(tx) | ||
| ids shouldBe expected | ||
| } | ||
| } | ||
|
|
||
| private def contractValuesInOrder(tx: SubmittedTransaction): Seq[Long] = { | ||
| tx.fold(Vector.empty[Long]) { | ||
| case (acc, (_, create: Node.NodeCreate[Value.ContractId])) => | ||
| create.arg match { | ||
| case ValueRecord(_, ImmArray(_, (Some("info"), ValueInt64(n)))) => | ||
| acc :+ n | ||
| case _ => | ||
| sys.error(s"unexpected create.arg: ${create.arg}") | ||
| } | ||
| case (acc, _) => acc | ||
| } | ||
| } | ||
|
|
||
| } |