DA5-22: Distribution and validation of draft transactions

gradle.properties

@@ -5,7 +5,7 @@ cordaProductVersion = 5.2.0
 # NOTE: update this each time this module contains a breaking change
 ## NOTE: currently this is a top level revision, so all API versions will line up, but this could be moved to
 ##   a per module property in which case module versions can change independently.
-cordaApiRevision = 17
+cordaApiRevision = 17-julia2
 
 # Main
 kotlin.stdlib.default.dependency = false

ledger/ledger-utxo/scans/corda-ledger-utxo-5.2.0.yaml

@@ -526,6 +526,18 @@ net.corda.v5.ledger.utxo.UtxoLedgerService:
           annotation:
             - NotNull
           type: net.corda.v5.application.messaging.FlowSession
+    receiveLedgerTransaction:
+      annotations:
+        - Suspendable
+        - NotNull
+      default: false
+      type: public abstract
+      returnType: net.corda.v5.ledger.utxo.transaction.UtxoLedgerTransaction
+      params:
+        session:
+          annotation:
+            - NotNull
+          type: net.corda.v5.application.messaging.FlowSession
     sendTransaction:
       annotations:
         - Suspendable
@@ -566,24 +578,52 @@ net.corda.v5.ledger.utxo.UtxoLedgerService:
         ledgerTransaction:
           annotation: []
           type: net.corda.v5.ledger.utxo.transaction.UtxoLedgerTransaction
-net.corda.v5.ledger.utxo.VisibilityChecker:
-  annotations:
-    - DoNotImplement
+    sendAsLedgerTransaction:
+      annotations:
+        - Suspendable
+      default: false
+      type: public abstract
+      returnType: void
+      params:
+        signedTransaction:
+          annotation:
+            - NotNull
+          type: net.corda.v5.ledger.utxo.transaction.UtxoSignedTransaction
+        sessions:
+          annotation:
+            - NotNull
+          type: java.util.List<net.corda.v5.application.messaging.FlowSession>
+net.corda.ledger.utxo.flow.impl.transaction.factory.UtxoLedgerTransactionFactory:
+  annotations: []
   type: public interface
   extends: []
   interface: true
   methods:
-    containsMySigningKeys:
+    create:
       annotations:
         - Suspendable
       default: false
-      type: public abstract
-      returnType: boolean
+      type: public
+      returnType: UtxoLedgerTransactionInternal
       params:
-        keys:
-          annotation:
-            - NotNull
-          type: Iterable<java.security.PublicKey>
+        wireTransaction:
+          annotation: []
+          type: WireTransaction
+    createWithStateAndRefs:
+      annotations: []
+      default: false
+      type: public
+      returnType: UtxoLedgerTransactionInternal
+      params:
+        wireTransaction:
+          annotation: []
+          type: WireTransaction
+        inputStateAndRefs:
+          annotation: []
+          type: List<StateAndRef<*>>
+        referenceStateAndRefs:
+          annotation: []
+          type: List<StateAndRef<*>>
 net.corda.v5.ledger.utxo.observer.TokenStateObserverContext:
   annotations: []
   type: public interface

ledger/ledger-utxo/src/main/java/net/corda/v5/ledger/utxo/UtxoLedgerService.java

@@ -283,6 +283,32 @@ UtxoSignedTransaction receiveTransaction(
             @NotNull FlowSession session
     );
 
+    /**
+     * Sends the wire transaction to counterparty sessions.
+     *
+     * @param sessions The counterparties who receive the transaction.
+     * @param signedTransaction The {@link UtxoSignedTransaction} to send.
+     * @throws CordaRuntimeException If transaction verification fails on the receiving sessions.
+     */
+    @Suspendable
+    void sendAsLedgerTransaction(
+            @NotNull UtxoSignedTransaction signedTransaction,
+            @NotNull List<FlowSession> sessions
+    );
+
+    /**
+     * Receives a verified transaction from the counterparty session and persists it to the vault.
+     *
+     * @param session The counterparty to receive a transaction from.
+     * @return the {@link UtxoLedgerTransaction} received from counterparty.
+     * @throws CordaRuntimeException If the transaction received fails verification.
+     */
+    @NotNull
+    @Suspendable
+    UtxoLedgerTransaction receiveLedgerTransaction(
+            @NotNull FlowSession session
+    );
+
     /**
      * Creates a query object for a vault named query with the given name. This query can be executed later by calling
      * {@link PagedQuery#execute()}.