mirror of
https://github.com/corda/corda.git
synced 2025-05-31 14:40:52 +00:00
* Remove sslConfiguration from public constructor of CordaRPCClient * Address review comments * Update api-current.txt * sslConfiguration doesn't need to be a property # Conflicts: # .ci/api-current.txt
This commit is contained in:
parent
79fc4a42d7
commit
90c8b2a12a
@ -70,11 +70,24 @@ data class CordaRPCClientConfiguration(val connectionMaxRetryInterval: Duration)
|
|||||||
* @param configuration An optional configuration used to tweak client behaviour.
|
* @param configuration An optional configuration used to tweak client behaviour.
|
||||||
* @param sslConfiguration An optional [SSLConfiguration] used to enable secure communication with the server.
|
* @param sslConfiguration An optional [SSLConfiguration] used to enable secure communication with the server.
|
||||||
*/
|
*/
|
||||||
class CordaRPCClient @JvmOverloads constructor(
|
class CordaRPCClient private constructor(
|
||||||
hostAndPort: NetworkHostAndPort,
|
hostAndPort: NetworkHostAndPort,
|
||||||
configuration: CordaRPCClientConfiguration = CordaRPCClientConfiguration.DEFAULT,
|
configuration: CordaRPCClientConfiguration = CordaRPCClientConfiguration.DEFAULT,
|
||||||
sslConfiguration: SSLConfiguration? = null
|
sslConfiguration: SSLConfiguration? = null
|
||||||
) {
|
) {
|
||||||
|
@JvmOverloads
|
||||||
|
constructor(hostAndPort: NetworkHostAndPort, configuration: CordaRPCClientConfiguration = CordaRPCClientConfiguration.DEFAULT) : this(hostAndPort, configuration, null)
|
||||||
|
|
||||||
|
companion object {
|
||||||
|
internal fun createWithSsl(
|
||||||
|
hostAndPort: NetworkHostAndPort,
|
||||||
|
configuration: CordaRPCClientConfiguration = CordaRPCClientConfiguration.DEFAULT,
|
||||||
|
sslConfiguration: SSLConfiguration? = null
|
||||||
|
): CordaRPCClient {
|
||||||
|
return CordaRPCClient(hostAndPort, configuration, sslConfiguration)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
init {
|
init {
|
||||||
try {
|
try {
|
||||||
effectiveSerializationEnv
|
effectiveSerializationEnv
|
||||||
|
@ -0,0 +1,13 @@
|
|||||||
|
package net.corda.client.rpc.internal
|
||||||
|
|
||||||
|
import net.corda.client.rpc.CordaRPCClient
|
||||||
|
import net.corda.client.rpc.CordaRPCClientConfiguration
|
||||||
|
import net.corda.core.utilities.NetworkHostAndPort
|
||||||
|
import net.corda.nodeapi.internal.config.SSLConfiguration
|
||||||
|
|
||||||
|
/** Utility which exposes the internal Corda RPC constructor to other internal Corda components */
|
||||||
|
fun createCordaRPCClientWithSsl(
|
||||||
|
hostAndPort: NetworkHostAndPort,
|
||||||
|
configuration: CordaRPCClientConfiguration = CordaRPCClientConfiguration.DEFAULT,
|
||||||
|
sslConfiguration: SSLConfiguration? = null
|
||||||
|
) = CordaRPCClient.createWithSsl(hostAndPort, configuration, sslConfiguration)
|
@ -1,5 +1,7 @@
|
|||||||
package net.corda.client.rpc.internal
|
package net.corda.client.rpc.internal
|
||||||
|
|
||||||
|
import net.corda.client.rpc.CordaRPCClient
|
||||||
|
import net.corda.client.rpc.CordaRPCClientConfiguration
|
||||||
import net.corda.client.rpc.RPCConnection
|
import net.corda.client.rpc.RPCConnection
|
||||||
import net.corda.client.rpc.RPCException
|
import net.corda.client.rpc.RPCException
|
||||||
import net.corda.core.context.Actor
|
import net.corda.core.context.Actor
|
||||||
|
@ -1,6 +1,7 @@
|
|||||||
package net.corda.node.services.rpc
|
package net.corda.node.services.rpc
|
||||||
|
|
||||||
import net.corda.client.rpc.CordaRPCClient
|
import net.corda.client.rpc.CordaRPCClient
|
||||||
|
import net.corda.client.rpc.internal.createCordaRPCClientWithSsl
|
||||||
import net.corda.core.identity.CordaX500Name
|
import net.corda.core.identity.CordaX500Name
|
||||||
import net.corda.core.utilities.getOrThrow
|
import net.corda.core.utilities.getOrThrow
|
||||||
import net.corda.node.services.Permissions.Companion.all
|
import net.corda.node.services.Permissions.Companion.all
|
||||||
@ -33,7 +34,7 @@ class RpcSslTest {
|
|||||||
var successful = false
|
var successful = false
|
||||||
driver(isDebug = true, startNodesInProcess = true, portAllocation = PortAllocation.RandomFree) {
|
driver(isDebug = true, startNodesInProcess = true, portAllocation = PortAllocation.RandomFree) {
|
||||||
startNode(rpcUsers = listOf(user), customOverrides = nodeSslOptions.useSslRpcOverrides()).getOrThrow().use { node ->
|
startNode(rpcUsers = listOf(user), customOverrides = nodeSslOptions.useSslRpcOverrides()).getOrThrow().use { node ->
|
||||||
CordaRPCClient(node.rpcAddress, sslConfiguration = clientSslOptions).start(user.username, user.password).use { connection ->
|
createCordaRPCClientWithSsl(node.rpcAddress, sslConfiguration = clientSslOptions).start(user.username, user.password).use { connection ->
|
||||||
connection.proxy.apply {
|
connection.proxy.apply {
|
||||||
nodeInfo()
|
nodeInfo()
|
||||||
successful = true
|
successful = true
|
||||||
|
@ -6,6 +6,7 @@ import com.typesafe.config.Config
|
|||||||
import com.typesafe.config.ConfigFactory
|
import com.typesafe.config.ConfigFactory
|
||||||
import com.typesafe.config.ConfigRenderOptions
|
import com.typesafe.config.ConfigRenderOptions
|
||||||
import net.corda.client.rpc.CordaRPCClient
|
import net.corda.client.rpc.CordaRPCClient
|
||||||
|
import net.corda.client.rpc.internal.createCordaRPCClientWithSsl
|
||||||
import net.corda.cordform.CordformContext
|
import net.corda.cordform.CordformContext
|
||||||
import net.corda.cordform.CordformNode
|
import net.corda.cordform.CordformNode
|
||||||
import net.corda.core.concurrent.CordaFuture
|
import net.corda.core.concurrent.CordaFuture
|
||||||
@ -150,7 +151,7 @@ class DriverDSLImpl(
|
|||||||
private fun establishRpc(config: NodeConfig, processDeathFuture: CordaFuture<out Process>): CordaFuture<CordaRPCOps> {
|
private fun establishRpc(config: NodeConfig, processDeathFuture: CordaFuture<out Process>): CordaFuture<CordaRPCOps> {
|
||||||
val rpcAddress = config.corda.rpcOptions.address!!
|
val rpcAddress = config.corda.rpcOptions.address!!
|
||||||
val client = if (config.corda.rpcOptions.useSsl) {
|
val client = if (config.corda.rpcOptions.useSsl) {
|
||||||
CordaRPCClient(rpcAddress, sslConfiguration = config.corda.rpcOptions.sslConfig)
|
createCordaRPCClientWithSsl(rpcAddress, sslConfiguration = config.corda.rpcOptions.sslConfig)
|
||||||
} else {
|
} else {
|
||||||
CordaRPCClient(rpcAddress)
|
CordaRPCClient(rpcAddress)
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user