Skip to content

Commit 0d1fe1f

Browse files
Version update to 2.0.0-rc4 including PR amendments.
1 parent cefd09e commit 0d1fe1f

File tree

11 files changed

+34
-18
lines changed

11 files changed

+34
-18
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ buildscript {
4242
}
4343

4444
group 'io.onixlabs'
45-
version '2.0.0-rc3'
45+
version '2.0.0-rc4'
4646

4747
subprojects {
4848
repositories {

onixlabs-corda-core-workflow/src/main/kotlin/io/onixlabs/corda/core/services/QueryDsl.kt

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

1717
package io.onixlabs.corda.core.services
1818

19+
import io.onixlabs.corda.core.toTypedClass
1920
import net.corda.core.contracts.ContractState
2021
import net.corda.core.contracts.StateRef
2122
import net.corda.core.contracts.UniqueIdentifier
@@ -28,6 +29,7 @@ import net.corda.core.node.services.vault.Sort
2829
import net.corda.core.node.services.vault.SortAttribute
2930
import net.corda.core.schemas.StatePersistable
3031
import kotlin.reflect.KProperty1
32+
import kotlin.reflect.jvm.javaType
3133
import kotlin.reflect.jvm.jvmErasure
3234

3335
/**
@@ -299,10 +301,11 @@ class QueryDsl<T : ContractState> internal constructor(
299301
* @param direction The sort direction of the sorted data.
300302
*/
301303
@QueryDslContext
302-
@Suppress("UNCHECKED_CAST")
303304
fun sortBy(property: KProperty1<out StatePersistable, *>, direction: Sort.Direction) {
304-
val receiver = property.parameters.first().type.jvmErasure.java as Class<out StatePersistable>
305-
sort(Sort(setOf(Sort.SortColumn(SortAttribute.Custom(receiver, property.name), direction))))
305+
val receiver = property.parameters.first().type.javaType.toTypedClass<StatePersistable>()
306+
val attribute = SortAttribute.Custom(receiver, property.name)
307+
val column = Sort.SortColumn(attribute, direction)
308+
sort(Sort(setOf(column)))
306309
}
307310

308311
/**

onixlabs-corda-core-workflow/src/main/kotlin/io/onixlabs/corda/core/services/QueryDslContext.kt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,4 +20,4 @@ package io.onixlabs.corda.core.services
2020
* Specifies that a function is contextually party of the query DSL.
2121
*/
2222
@DslMarker
23-
annotation class QueryDslContext
23+
annotation class QueryDslContext

onixlabs-corda-core-workflow/src/main/kotlin/io/onixlabs/corda/core/services/VaultSequence.kt

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -38,13 +38,19 @@ class VaultSequence<T : ContractState> internal constructor(
3838
private val sorting: Sort = DEFAULT_SORTING
3939
) : Sequence<StateAndRef<T>> {
4040

41-
internal constructor(service: VaultService<T>, queryDsl: QueryDsl<T>)
42-
: this(service, queryDsl.criteria, queryDsl.paging, queryDsl.sorting)
41+
internal constructor(service: VaultService<T>, queryDsl: QueryDsl<T>) : this(
42+
service = service,
43+
criteria = queryDsl.criteria,
44+
paging = queryDsl.paging,
45+
sorting = queryDsl.sorting
46+
)
4347

4448
/**
4549
* Gets the iterator which will evaluate the vault query.
4650
*
4751
* @return Returns an iterator for the [StateAndRef] instances returned by the vault query.
4852
*/
49-
override fun iterator(): Iterator<StateAndRef<T>> = service.queryBy(criteria, paging, sorting).states.iterator()
53+
override fun iterator(): Iterator<StateAndRef<T>> {
54+
return service.queryBy(criteria, paging, sorting).states.iterator()
55+
}
5056
}

onixlabs-corda-core-workflow/src/main/kotlin/io/onixlabs/corda/core/services/VaultService.kt

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,8 +21,10 @@ import net.corda.core.messaging.CordaRPCOps
2121
import net.corda.core.messaging.DataFeed
2222
import net.corda.core.node.ServiceHub
2323
import net.corda.core.node.services.Vault
24-
import net.corda.core.node.services.vault.*
24+
import net.corda.core.node.services.vault.PageSpecification
25+
import net.corda.core.node.services.vault.QueryCriteria
2526
import net.corda.core.node.services.vault.QueryCriteria.VaultQueryCriteria
27+
import net.corda.core.node.services.vault.Sort
2628

2729
/**
2830
* Represents a service for managing vault querying and tracking.
@@ -107,7 +109,9 @@ class VaultService<T : ContractState> private constructor(
107109
criteria: QueryCriteria = defaultQueryCriteria,
108110
paging: PageSpecification = DEFAULT_PAGE_SPECIFICATION,
109111
sorting: Sort = DEFAULT_SORTING
110-
): Vault.Page<T> = adapter.queryBy(criteria, paging, sorting)
112+
): Vault.Page<T> {
113+
return adapter.queryBy(criteria, paging, sorting)
114+
}
111115

112116
/**
113117
* Tracks changes in the vault given the specified criteria, paging and sorting.
@@ -121,5 +125,7 @@ class VaultService<T : ContractState> private constructor(
121125
criteria: QueryCriteria = defaultTrackingCriteria,
122126
paging: PageSpecification = DEFAULT_PAGE_SPECIFICATION,
123127
sorting: Sort = DEFAULT_SORTING
124-
): DataFeed<Vault.Page<T>, Vault.Update<T>> = adapter.trackBy(criteria, paging, sorting)
128+
): DataFeed<Vault.Page<T>, Vault.Update<T>> {
129+
return adapter.trackBy(criteria, paging, sorting)
130+
}
125131
}

onixlabs-corda-test-contract/src/main/kotlin/io/onixlabs/corda/test/contract/CustomerEntity.kt

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ class CustomerEntity(
4949

5050
/**
5151
* Since chain state previous state references should start at null,
52-
* including this in the schema allows queries for all new/unevolved states.
52+
* including this in the schema allows queries for all new/un-evolved states.
5353
*/
5454
@Column(name = "previous_state_ref")
5555
val previousStateRef: String? = null,
@@ -63,4 +63,4 @@ class CustomerEntity(
6363
override val migrationResource = "customer-schema.changelog-master"
6464
}
6565
}
66-
}
66+
}

onixlabs-corda-test-contract/src/main/kotlin/io/onixlabs/corda/test/contract/Reward.kt

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,8 @@ data class Reward(
5959

6060
private class CustomerResolver(private val reward: Reward) : AbstractSingularResolvable<Customer>() {
6161

62-
override val criteria: QueryCriteria = vaultQuery<Customer>(relevancyStatus = Vault.RelevancyStatus.ALL) {
62+
override val criteria: QueryCriteria = vaultQuery<Customer> {
63+
relevancyStatus(Vault.RelevancyStatus.ALL)
6364
linearIds(reward.customerLinearId)
6465
}
6566

onixlabs-corda-test-contract/src/main/resources/migration/customer-schema.changelog-master.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,4 +3,4 @@
33
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
44
xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.5.xsd">
55
<include file="migration/customer-schema.changelog-v1.xml"/>
6-
</databaseChangeLog>
6+
</databaseChangeLog>

onixlabs-corda-test-contract/src/main/resources/migration/customer-schema.changelog-v1.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,4 +35,4 @@
3535
constraintName="PK_onixlabs_customer_states"
3636
tableName="onixlabs_customer_states"/>
3737
</changeSet>
38-
</databaseChangeLog>
38+
</databaseChangeLog>

onixlabs-corda-test-contract/src/main/resources/migration/reward-schema.changelog-master.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,4 +3,4 @@
33
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
44
xsi:schemaLocation="http://www.liquibase.org/xml/ns/dbchangelog http://www.liquibase.org/xml/ns/dbchangelog/dbchangelog-3.5.xsd">
55
<include file="migration/reward-schema.changelog-v1.xml"/>
6-
</databaseChangeLog>
6+
</databaseChangeLog>

0 commit comments

Comments
 (0)