add ability to specify x500 of node to add. (#3528)

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/NetworkBuilder.kt

@@ -7,7 +7,6 @@ import net.corda.bootstrapper.notaries.NotaryCopier
 import net.corda.bootstrapper.notaries.NotaryFinder
 import java.io.File
 import java.util.concurrent.CompletableFuture
-import java.util.concurrent.ConcurrentHashMap
 
 interface NetworkBuilder {
 
@@ -23,7 +22,6 @@ interface NetworkBuilder {
     fun onNodePushed(callback: (PushedNode) -> Unit): NetworkBuilder
     fun onNodeInstance(callback: (NodeInstance) -> Unit): NetworkBuilder
 
-    fun withNodeCounts(map: Map<String, Int>): NetworkBuilder
     fun withNetworkName(networtName: String): NetworkBuilder
     fun withBasedir(baseDir: File): NetworkBuilder
     fun withBackend(backendType: Backend.BackendType): NetworkBuilder
@@ -104,11 +102,6 @@ private class NetworkBuilderImpl : NetworkBuilder {
         return this
     }
 
-    override fun withNodeCounts(map: Map<String, Int>): NetworkBuilder {
-        nodeCounts = ConcurrentHashMap(map.entries.map { it.key.toLowerCase() to it.value }.toMap())
-        return this
-    }
-
     override fun withNetworkName(networtName: String): NetworkBuilder {
         this.networkName = networtName
         return this

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/cli/CommandLineInterface.kt

@@ -8,6 +8,7 @@ import net.corda.bootstrapper.context.Context
 import net.corda.bootstrapper.nodes.NodeAdder
 import net.corda.bootstrapper.nodes.NodeInstantiator
 import net.corda.bootstrapper.toSingleFuture
+import net.corda.core.identity.CordaX500Name
 import net.corda.core.utilities.getOrThrow
 import java.io.File
 
@@ -23,7 +24,6 @@ class CommandLineInterface {
             val (_, context) = NetworkBuilder.instance()
                     .withBasedir(baseDir)
                     .withNetworkName(networkName)
-                    .withNodeCounts(parsedArgs.nodes)
                     .onNodeBuild { builtNode -> println("Built node: ${builtNode.name} to image: ${builtNode.localImageId}") }
                     .onNodePushed { pushedNode -> println("Pushed node: ${pushedNode.name} to: ${pushedNode.remoteImageName}") }
                     .onNodeInstance { instance ->
@@ -40,7 +40,7 @@ class CommandLineInterface {
             val (_, instantiator, _) = Backend.fromContext(context, cacheDir)
             val nodeAdder = NodeAdder(context, NodeInstantiator(instantiator, context))
             parsedArgs.nodesToAdd.map {
-                nodeAdder.addNode(context, Constants.ALPHA_NUMERIC_ONLY_REGEX.replace(it.toLowerCase(), ""))
+                nodeAdder.addNode(context, Constants.ALPHA_NUMERIC_ONLY_REGEX.replace(it.key.toLowerCase(), ""), CordaX500Name.parse(it.value))
             }.toSingleFuture().getOrThrow()
             persistContext(contextFile, objectMapper, context)
         }

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/cli/CommandParsers.kt

@@ -20,11 +20,9 @@ open class CliParser {
     @Option(names = ["-b", "--backend"], description = ["The backend to use when instantiating nodes"])
     var backendType: Backend.BackendType = Backend.BackendType.LOCAL_DOCKER
 
-    @Option(names = ["--nodes"], split = ":", description = ["The number of each node to create. NodeX:2 will create two instances of NodeX"])
-    var nodes: MutableMap<String, Int> = hashMapOf()
 
-    @Option(names = ["--add", "-a"])
+    @Option(names = ["--add"], split = ":", description = ["The node to add. Format is <Name>:<X500>. Eg; \"Node1:O=Bank A, L=New York, C=US, OU=Org Unit, CN=Service Name\""])
-    var nodesToAdd: MutableList<String> = arrayListOf()
+    var nodesToAdd: MutableMap<String, String> = hashMapOf()
 
     fun isNew(): Boolean {
         return nodesToAdd.isEmpty()

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/gui/BootstrapperView.kt

@@ -21,6 +21,7 @@ import net.corda.bootstrapper.baseArgs
 import net.corda.bootstrapper.context.Context
 import net.corda.bootstrapper.nodes.*
 import net.corda.bootstrapper.notaries.NotaryFinder
+import net.corda.core.identity.CordaX500Name
 import org.apache.commons.lang3.RandomStringUtils
 import org.controlsfx.control.SegmentedButton
 import tornadofx.*
@@ -70,7 +71,6 @@ class BootstrapperView : View("Corda Network Builder") {
                     }
                 }
 
-                val nodeCount = controller.foundNodes.map { it.id to it.count }.toMap()
                 val result = NetworkBuilder.instance()
                         .withBasedir(controller.baseDir.get())
                         .withNetworkName(networkName)
@@ -81,7 +81,6 @@ class BootstrapperView : View("Corda Network Builder") {
                         .onNodeInstancesRequested(controller::addInstanceRequests)
                         .onNodeInstance(controller::addInstance)
                         .withBackend(selectedBackEnd)
-                        .withNodeCounts(nodeCount)
                         .withBackendOptions(backendParams)
                         .build()
 
@@ -118,6 +117,10 @@ class BootstrapperView : View("Corda Network Builder") {
             enableWhen { controller.networkContext.isNotNull }
             action {
                 templateChoiceBox.selectionModel.selectedItem?.let { nodeToAdd ->
+
+                    val textInputDialog = TextInputDialog("O=Bank A, L=New York, C=US, OU=Org Unit, CN=Service Name")
+                    textInputDialog.title = "X500 of node to add"
+                    val x500ToUse = textInputDialog.showAndWait().orElseGet { null }
                     val context = controller.networkContext.value
                     runLater {
                         val (_, instantiator, _) = Backend.fromContext(
@@ -125,7 +128,7 @@ class BootstrapperView : View("Corda Network Builder") {
                                 File(controller.baseDir.get(), Constants.BOOTSTRAPPER_DIR_NAME))
                         val nodeAdder = NodeAdder(context, NodeInstantiator(instantiator, context))
                         controller.addInstanceRequest(nodeToAdd)
-                        nodeAdder.addNode(context, nodeToAdd).handleAsync { instanceInfo, t ->
+                        nodeAdder.addNode(context, nodeToAdd, x500ToUse?.let { CordaX500Name.parse(it) }).handleAsync { instanceInfo, t ->
                             t?.let {
                                 GuiUtils.showException("Failed", "Failed to add node", it)
                             }
@@ -263,10 +266,6 @@ class BootstrapperView : View("Corda Network Builder") {
             compareValues(o1.nodeType.toString() + o1.templateId, o2.nodeType.toString() + o2.templateId) * -1
         })
 
-        fun clear() {
-            networkContext.set(null)
-        }
-
         fun clearAll() {
             networkContext.set(null)
             foundNodes.clear()

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/nodes/NodeAdder.kt

@@ -2,17 +2,18 @@ package net.corda.bootstrapper.nodes
 
 import net.corda.bootstrapper.containers.instance.InstanceInfo
 import net.corda.bootstrapper.context.Context
+import net.corda.core.identity.CordaX500Name
 import java.util.concurrent.CompletableFuture
 
 class NodeAdder(val context: Context,
                 val nodeInstantiator: NodeInstantiator) {
 
-    fun addNode(context: Context, nodeGroupName: String): CompletableFuture<InstanceInfo> {
+    fun addNode(context: Context, nodeGroupName: String, x500ToAdd: CordaX500Name?): CompletableFuture<InstanceInfo> {
         return synchronized(context) {
             val nodeGroup = context.nodes[nodeGroupName]!!
             val nodeInfo = nodeGroup.iterator().next()
             val currentNodeSize = nodeGroup.size
-            val newInstanceX500 = nodeInfo.groupX500!!.copy(commonName = nodeInfo.groupX500.commonName + (currentNodeSize)).toString()
+            val newInstanceX500 = x500ToAdd?.toString() ?: nodeInfo.groupX500!!.copy(commonName = nodeInfo.groupX500.commonName + (currentNodeSize)).toString()
             val newInstanceName = nodeGroupName + (currentNodeSize)
             val nextNodeInfo = nodeInfo.copy(
                     instanceX500 = newInstanceX500,

tools/network-bootstrapper/src/main/kotlin/net/corda/bootstrapper/nodes/NodeBuilder.kt

@@ -21,10 +21,10 @@ open class NodeBuilder {
         val copiedNodeConfig = copiedNode.copiedNodeConfig
         val nodeDir = copiedNodeConfig.parentFile
         if (!copiedNodeConfig.exists()) {
-            throw IllegalStateException("There is no nodeConfig for dir: " + copiedNodeConfig)
+            throw IllegalStateException("There is no nodeConfig for dir: $copiedNodeConfig")
         }
         val nodeConfig = ConfigFactory.parseFile(copiedNodeConfig)
-        LOG.info("starting to build docker image for: " + nodeDir)
+        LOG.info("starting to build docker image for: $nodeDir")
         val nodeImageId = localDockerClient.buildImageCmd()
                 .withDockerfile(File(nodeDir, "Dockerfile"))
                 .withBaseDirectory(nodeDir)