@@ -17,7 +17,6 @@ import com.r3.corda.lib.tokens.workflows.internal.flows.distribution.UpdateDistr
17
17
import com.r3.corda.lib.tokens.workflows.internal.flows.distribution.getDistributionList
18
18
import com.r3.corda.lib.tokens.workflows.internal.flows.finality.ObserverAwareFinalityFlow
19
19
import com.r3.corda.lib.tokens.workflows.internal.flows.finality.ObserverAwareFinalityFlowHandler
20
- import com.r3.corda.lib.tokens.workflows.internal.schemas.DistributionRecord
21
20
import com.r3.corda.lib.tokens.workflows.utilities.getPreferredNotary
22
21
import com.r3.corda.lib.tokens.workflows.utilities.ourSigningKeys
23
22
import net.corda.core.contracts.Amount
@@ -37,6 +36,7 @@ import net.corda.core.transactions.TransactionBuilder
37
36
import net.corda.core.utilities.seconds
38
37
import net.corda.core.utilities.unwrap
39
38
import java.time.Duration
39
+ import java.util.*
40
40
41
41
// This is very simple test flow for DvP.
42
42
@CordaSerializable
@@ -94,11 +94,14 @@ class DvPFlowHandler(val otherSession: FlowSession) : FlowLogic<Unit>() {
94
94
}
95
95
}
96
96
97
+ @CordaSerializable
98
+ data class DistributionRecordSerial (val linearId : UUID , val party : Party )
99
+
97
100
@StartableByRPC
98
- class GetDistributionList (val housePtr : TokenPointer <House >) : FlowLogic<List<DistributionRecord >>() {
101
+ class GetDistributionList (val housePtr : TokenPointer <House >) : FlowLogic<List<DistributionRecordSerial >>() {
99
102
@Suspendable
100
- override fun call (): List <DistributionRecord > {
101
- return getDistributionList(serviceHub, housePtr.pointer.pointer)
103
+ override fun call (): List <DistributionRecordSerial > {
104
+ return getDistributionList(serviceHub, housePtr.pointer.pointer).map { DistributionRecordSerial (it.linearId, it.party) }
102
105
}
103
106
}
104
107
0 commit comments