Skip to content

Commit 5ed937d

Browse files
Added @Suspendable annotations to TransactionBuilder extensions to ensure failures don't hang the node.
1 parent a1c357b commit 5ed937d

File tree

3 files changed

+12
-0
lines changed

3 files changed

+12
-0
lines changed

onixlabs-corda-identity-framework-workflow/src/main/kotlin/io/onixlabs/corda/identityframework/workflow/Extensions.TransactionBuilder.Accounts.kt

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package io.onixlabs.corda.identityframework.workflow
1818

19+
import co.paralleluniverse.fibers.Suspendable
1920
import io.onixlabs.corda.identityframework.contract.accounts.Account
2021
import io.onixlabs.corda.identityframework.contract.accounts.AccountContract
2122
import net.corda.core.contracts.StateAndRef
@@ -27,6 +28,7 @@ import net.corda.core.transactions.TransactionBuilder
2728
* @param account The account state to be created in the transaction.
2829
* @return Returns the current transaction builder.
2930
*/
31+
@Suspendable
3032
fun TransactionBuilder.addIssuedAccount(
3133
account: Account
3234
): TransactionBuilder = apply {
@@ -41,6 +43,7 @@ fun TransactionBuilder.addIssuedAccount(
4143
* @param newAccount The new account state to be created in the transaction.
4244
* @return Returns the current transaction builder.
4345
*/
46+
@Suspendable
4447
fun TransactionBuilder.addAmendedAccount(
4548
oldAccount: StateAndRef<Account>,
4649
newAccount: Account
@@ -56,6 +59,7 @@ fun TransactionBuilder.addAmendedAccount(
5659
* @param account The account state to be consumed in the transaction.
5760
* @return Returns the current transaction builder.
5861
*/
62+
@Suspendable
5963
fun TransactionBuilder.addRevokedAccount(
6064
account: StateAndRef<Account>
6165
): TransactionBuilder = apply {

onixlabs-corda-identity-framework-workflow/src/main/kotlin/io/onixlabs/corda/identityframework/workflow/Extensions.TransactionBuilder.Attestations.kt

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package io.onixlabs.corda.identityframework.workflow
1818

19+
import co.paralleluniverse.fibers.Suspendable
1920
import io.onixlabs.corda.identityframework.contract.attestations.Attestation
2021
import io.onixlabs.corda.identityframework.contract.attestations.AttestationContract
2122
import net.corda.core.contracts.StateAndRef
@@ -27,6 +28,7 @@ import net.corda.core.transactions.TransactionBuilder
2728
* @param attestation The attestation state to be created in the transaction.
2829
* @return Returns the current transaction builder.
2930
*/
31+
@Suspendable
3032
fun TransactionBuilder.addIssuedAttestation(
3133
attestation: Attestation<*>
3234
): TransactionBuilder = apply {
@@ -41,6 +43,7 @@ fun TransactionBuilder.addIssuedAttestation(
4143
* @param newAttestation The new attestation state to be created in the transaction.
4244
* @return Returns the current transaction builder.
4345
*/
46+
@Suspendable
4447
fun TransactionBuilder.addAmendedAttestation(
4548
oldAttestation: StateAndRef<Attestation<*>>,
4649
newAttestation: Attestation<*>
@@ -56,6 +59,7 @@ fun TransactionBuilder.addAmendedAttestation(
5659
* @param attestation The attestation state to be consumed in the transaction.
5760
* @return Returns the current transaction builder.
5861
*/
62+
@Suspendable
5963
fun TransactionBuilder.addRevokedAttestation(
6064
attestation: StateAndRef<Attestation<*>>
6165
): TransactionBuilder = apply {

onixlabs-corda-identity-framework-workflow/src/main/kotlin/io/onixlabs/corda/identityframework/workflow/Extensions.TransactionBuilder.Claims.kt

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package io.onixlabs.corda.identityframework.workflow
1818

19+
import co.paralleluniverse.fibers.Suspendable
1920
import io.onixlabs.corda.identityframework.contract.claims.CordaClaim
2021
import io.onixlabs.corda.identityframework.contract.claims.CordaClaimContract
2122
import net.corda.core.contracts.StateAndRef
@@ -27,6 +28,7 @@ import net.corda.core.transactions.TransactionBuilder
2728
* @param claim The claim state to be created in the transaction.
2829
* @return Returns the current transaction builder.
2930
*/
31+
@Suspendable
3032
fun TransactionBuilder.addIssuedClaim(
3133
claim: CordaClaim<*>
3234
): TransactionBuilder = apply {
@@ -41,6 +43,7 @@ fun TransactionBuilder.addIssuedClaim(
4143
* @param newClaim The new claim state to be created in the transaction.
4244
* @return Returns the current transaction builder.
4345
*/
46+
@Suspendable
4447
fun TransactionBuilder.addAmendedClaim(
4548
oldClaim: StateAndRef<CordaClaim<*>>,
4649
newClaim: CordaClaim<*>
@@ -56,6 +59,7 @@ fun TransactionBuilder.addAmendedClaim(
5659
* @param claim The claim state to be consumed in the transaction.
5760
* @return Returns the current transaction builder.
5861
*/
62+
@Suspendable
5963
fun TransactionBuilder.addRevokedClaim(
6064
claim: StateAndRef<CordaClaim<*>>
6165
): TransactionBuilder = apply {

0 commit comments

Comments
 (0)