CORE-16615: introduce new api to find an unconsumed states

data/avro-schema/src/main/resources/avro/net/corda/data/ledger/persistence/FindUnconsumedVisibleExactStates.avsc

@@ -0,0 +1,13 @@
+{
+  "type": "record",
+  "name": "FindUnconsumedStatesByExactType",
+  "doc": "Retrieve the unconsumed visible states of specific type. This only retrieves exact type excluding its states of subclass unlike {@link FindUnconsumedStatesByExactType}. One of several types of ledger persistence request {@link LedgerPersistenceRequest}",
+  "namespace": "net.corda.data.ledger.persistence",
+  "fields": [
+    {
+      "name": "stateClassName",
+      "type": "string",
+      "doc": "The fully qualified state class name"
+    }
+  ]
+}

data/avro-schema/src/main/resources/avro/net/corda/data/ledger/persistence/LedgerPersistenceRequest.avsc

@@ -34,6 +34,7 @@
         "net.corda.data.ledger.persistence.PersistTransactionIfDoesNotExist",
         "net.corda.data.ledger.persistence.FindTransaction",
         "net.corda.data.ledger.persistence.FindUnconsumedStatesByType",
+        "net.corda.data.ledger.persistence.FindUnconsumedStatesByExactType",
         "net.corda.data.ledger.persistence.ResolveStateRefs",
         "net.corda.data.ledger.persistence.UpdateTransactionStatus",
         "net.corda.data.persistence.FindWithNamedQuery",

data/avro-schema/src/test/kotlin/net/corda/data/ledger/persistence/LedgerPersistenceRequestSchemaCompatibilityTest.kt

@@ -50,6 +50,7 @@ class LedgerPersistenceRequestSchemaCompatibilityTest {
                 "net.corda.data.ledger.persistence.PersistTransactionIfDoesNotExist",
                 "net.corda.data.ledger.persistence.FindTransaction",
                 "net.corda.data.ledger.persistence.FindUnconsumedStatesByType",
+                "net.corda.data.ledger.persistence.FindUnconsumedStatesByExactType",
                 "net.corda.data.ledger.persistence.ResolveStateRefs",
                 "net.corda.data.ledger.persistence.UpdateTransactionStatus",
                 "net.corda.data.persistence.FindWithNamedQuery",
@@ -74,6 +75,7 @@ class LedgerPersistenceRequestSchemaCompatibilityTest {
                     PersistTransactionIfDoesNotExist::class.java.name to PersistTransactionIfDoesNotExist.`SCHEMA$`,
                     FindTransaction::class.java.name to FindTransaction.`SCHEMA$`,
                     FindUnconsumedStatesByType::class.java.name to FindUnconsumedStatesByType.`SCHEMA$`,
+                    FindUnconsumedStatesByExactType::class.java.name to FindUnconsumedStatesByExactType.`SCHEMA$`,
                     ResolveStateRefs::class.java.name to ResolveStateRefs.`SCHEMA$`,
                     UpdateTransactionStatus::class.java.name to UpdateTransactionStatus.`SCHEMA$`,
                     FindWithNamedQuery::class.java.name to FindWithNamedQuery.`SCHEMA$`,

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

@@ -87,7 +87,8 @@ public interface UtxoLedgerService {
     UtxoFilteredTransactionBuilder filterSignedTransaction(@NotNull UtxoSignedTransaction transaction);
 
     /**
-     * Finds unconsumed states of the specified {@link ContractState} type in the vault.
+     * Finds unconsumed states and subclasses of the states of the specified {@link ContractState} type in the vault.
+     * Only use this if you really care about catching all child classes, it has poor performance.
      *
      * @param <T>  The underlying {@link ContractState} type.
      * @param type The {@link ContractState} type to find in the vault.
@@ -97,6 +98,17 @@ public interface UtxoLedgerService {
     @Suspendable
     <T extends ContractState> List<StateAndRef<T>> findUnconsumedStatesByType(@NotNull Class<T> type);
 
+    /**
+     * Finds unconsumed states of the specified {@link ContractState} type in the vault.
+     *
+     * @param <T>  The underlying {@link ContractState} type.
+     * @param type The {@link ContractState} type to find in the vault.
+     * @return Returns a {@link List} of {@link StateAndRef} of unconsumed states of the specified type, or an empty list if no states could be found.
+     */
+    @NotNull
+    @Suspendable
+    <T extends ContractState> List<StateAndRef<T>> findUnconsumedStatesByExactType(@NotNull Class<T> type);
+
     /**
      * Verifies, signs, collects signatures, records and broadcasts a {@link UtxoSignedTransaction} to participants and observers.
      *