mirror of
https://github.com/corda/corda.git
synced 2025-05-30 14:14:29 +00:00
Merge fixes
This commit is contained in:
parent
8e4547c811
commit
31530b35c6
@ -47,6 +47,5 @@ interface Cordapp {
|
|||||||
val allFlows: List<Class<out FlowLogic<*>>>
|
val allFlows: List<Class<out FlowLogic<*>>>
|
||||||
val jarPath: URL
|
val jarPath: URL
|
||||||
val cordappClasses: List<String>
|
val cordappClasses: List<String>
|
||||||
val info: Info
|
|
||||||
val jarHash: SecureHash.SHA256
|
val jarHash: SecureHash.SHA256
|
||||||
}
|
}
|
||||||
|
@ -119,7 +119,7 @@ class FlowWorkerServiceHub(override val configuration: NodeConfiguration, overri
|
|||||||
identityService.database = database
|
identityService.database = database
|
||||||
}
|
}
|
||||||
|
|
||||||
override val networkMapCache = PersistentNetworkMapCache(database, identityService, myInfo.legalIdentities[0].name)
|
override val networkMapCache = PersistentNetworkMapCache(database, identityService)
|
||||||
private val checkpointStorage = DBCheckpointStorage()
|
private val checkpointStorage = DBCheckpointStorage()
|
||||||
@Suppress("LeakingThis")
|
@Suppress("LeakingThis")
|
||||||
override val validatedTransactions: WritableTransactionStorage = DBTransactionStorage(configuration.transactionCacheSizeBytes, database).tokenize()
|
override val validatedTransactions: WritableTransactionStorage = DBTransactionStorage(configuration.transactionCacheSizeBytes, database).tokenize()
|
||||||
|
@ -36,7 +36,10 @@ import net.corda.node.services.config.NodeConfiguration
|
|||||||
import net.corda.node.services.identity.PersistentIdentityService
|
import net.corda.node.services.identity.PersistentIdentityService
|
||||||
import net.corda.node.services.keys.PersistentKeyManagementService
|
import net.corda.node.services.keys.PersistentKeyManagementService
|
||||||
import net.corda.node.services.messaging.MessagingService
|
import net.corda.node.services.messaging.MessagingService
|
||||||
import net.corda.node.services.network.*
|
import net.corda.node.services.network.NetworkMapClient
|
||||||
|
import net.corda.node.services.network.NetworkMapUpdater
|
||||||
|
import net.corda.node.services.network.NodeInfoWatcher
|
||||||
|
import net.corda.node.services.network.PersistentNetworkMapCache
|
||||||
import net.corda.node.services.persistence.DBTransactionMappingStorage
|
import net.corda.node.services.persistence.DBTransactionMappingStorage
|
||||||
import net.corda.node.services.persistence.DBTransactionStorage
|
import net.corda.node.services.persistence.DBTransactionStorage
|
||||||
import net.corda.node.services.persistence.NodeAttachmentService
|
import net.corda.node.services.persistence.NodeAttachmentService
|
||||||
@ -84,7 +87,7 @@ class RpcWorkerServiceHub(override val configuration: NodeConfiguration, overrid
|
|||||||
identityService.database = database
|
identityService.database = database
|
||||||
}
|
}
|
||||||
|
|
||||||
override val networkMapCache = PersistentNetworkMapCache(database, identityService, myInfo.legalIdentities[0].name)
|
override val networkMapCache = PersistentNetworkMapCache(database, identityService)
|
||||||
@Suppress("LeakingThis")
|
@Suppress("LeakingThis")
|
||||||
override val validatedTransactions: WritableTransactionStorage = DBTransactionStorage(configuration.transactionCacheSizeBytes, database)
|
override val validatedTransactions: WritableTransactionStorage = DBTransactionStorage(configuration.transactionCacheSizeBytes, database)
|
||||||
private val networkMapClient: NetworkMapClient? = configuration.networkServices?.let { NetworkMapClient(it.networkMapURL, versionInfo) }
|
private val networkMapClient: NetworkMapClient? = configuration.networkServices?.let { NetworkMapClient(it.networkMapURL, versionInfo) }
|
||||||
|
@ -4,9 +4,9 @@ import net.corda.core.node.NodeInfo
|
|||||||
import net.corda.core.utilities.NetworkHostAndPort
|
import net.corda.core.utilities.NetworkHostAndPort
|
||||||
import net.corda.node.internal.configureDatabase
|
import net.corda.node.internal.configureDatabase
|
||||||
import net.corda.node.internal.schemas.NodeInfoSchemaV1
|
import net.corda.node.internal.schemas.NodeInfoSchemaV1
|
||||||
import net.corda.nodeapi.internal.persistence.CordaPersistence
|
|
||||||
import net.corda.node.services.identity.InMemoryIdentityService
|
import net.corda.node.services.identity.InMemoryIdentityService
|
||||||
import net.corda.nodeapi.internal.DEV_ROOT_CA
|
import net.corda.nodeapi.internal.DEV_ROOT_CA
|
||||||
|
import net.corda.nodeapi.internal.persistence.CordaPersistence
|
||||||
import net.corda.nodeapi.internal.persistence.DatabaseConfig
|
import net.corda.nodeapi.internal.persistence.DatabaseConfig
|
||||||
import net.corda.testing.core.*
|
import net.corda.testing.core.*
|
||||||
import net.corda.testing.internal.IntegrationTest
|
import net.corda.testing.internal.IntegrationTest
|
||||||
@ -22,7 +22,6 @@ class PersistentNetworkMapCacheTest : IntegrationTest() {
|
|||||||
private companion object {
|
private companion object {
|
||||||
val ALICE = TestIdentity(ALICE_NAME, 70)
|
val ALICE = TestIdentity(ALICE_NAME, 70)
|
||||||
val BOB = TestIdentity(BOB_NAME, 80)
|
val BOB = TestIdentity(BOB_NAME, 80)
|
||||||
val CHARLIE = TestIdentity(CHARLIE_NAME, 90)
|
|
||||||
|
|
||||||
@ClassRule
|
@ClassRule
|
||||||
@JvmField
|
@JvmField
|
||||||
@ -37,7 +36,7 @@ class PersistentNetworkMapCacheTest : IntegrationTest() {
|
|||||||
|
|
||||||
//Enterprise only - objects created in the setup method, below initialized with dummy values to avoid need for nullable type declaration
|
//Enterprise only - objects created in the setup method, below initialized with dummy values to avoid need for nullable type declaration
|
||||||
private var database = CordaPersistence(DatabaseConfig(), emptySet())
|
private var database = CordaPersistence(DatabaseConfig(), emptySet())
|
||||||
private var charlieNetMapCache = PersistentNetworkMapCache(database, InMemoryIdentityService(trustRoot = DEV_ROOT_CA.certificate), CHARLIE.name)
|
private var charlieNetMapCache = PersistentNetworkMapCache(database, InMemoryIdentityService(trustRoot = DEV_ROOT_CA.certificate))
|
||||||
|
|
||||||
@Before()
|
@Before()
|
||||||
fun setup() {
|
fun setup() {
|
||||||
|
@ -9,7 +9,6 @@ import net.corda.core.flows.*
|
|||||||
import net.corda.core.internal.*
|
import net.corda.core.internal.*
|
||||||
import net.corda.core.internal.cordapp.CordappImpl
|
import net.corda.core.internal.cordapp.CordappImpl
|
||||||
import net.corda.core.node.services.CordaService
|
import net.corda.core.node.services.CordaService
|
||||||
import net.corda.node.VersionInfo
|
|
||||||
import net.corda.core.schemas.MappedSchema
|
import net.corda.core.schemas.MappedSchema
|
||||||
import net.corda.core.serialization.SerializationCustomSerializer
|
import net.corda.core.serialization.SerializationCustomSerializer
|
||||||
import net.corda.core.serialization.SerializationWhitelist
|
import net.corda.core.serialization.SerializationWhitelist
|
||||||
@ -127,8 +126,7 @@ class JarScanningCordappLoader private constructor(private val cordappJarPaths:
|
|||||||
findAllFlows(this),
|
findAllFlows(this),
|
||||||
url.url,
|
url.url,
|
||||||
info,
|
info,
|
||||||
getJarHash(url.url),
|
getJarHash(url.url)
|
||||||
name
|
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -23,11 +23,6 @@ fun createTestManifest(name: String, title: String, version: String, vendor: Str
|
|||||||
return manifest
|
return manifest
|
||||||
}
|
}
|
||||||
|
|
||||||
internal fun createTestManifest(name: String, title: String, jarUUID: UUID): Manifest {
|
|
||||||
|
|
||||||
return createTestManifest(name, title, "test-$jarUUID", "R3")
|
|
||||||
}
|
|
||||||
|
|
||||||
operator fun Manifest.set(key: String, value: String) {
|
operator fun Manifest.set(key: String, value: String) {
|
||||||
mainAttributes.putValue(key, value)
|
mainAttributes.putValue(key, value)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user