path: root/ms/controllerblueprints/modules/blueprint-core/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/core/dsl/BluePrintTemplateDSLBuilder.kt

/*
 *  Copyright © 2019 IBM.
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 */

package org.onap.ccsdk.cds.controllerblueprints.core.dsl

import com.fasterxml.jackson.databind.JsonNode
import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintConstants
import org.onap.ccsdk.cds.controllerblueprints.core.asJsonType
import org.onap.ccsdk.cds.controllerblueprints.core.data.*

class TopologyTemplateBuilder {
    private var topologyTemplate = TopologyTemplate()
    private var nodeTemplates: MutableMap<String, NodeTemplate>? = null
    private var workflows: MutableMap<String, Workflow>? = null

    fun nodeTemplate(id: String, type: String, description: String, block: NodeTemplateBuilder.() -> Unit) {
        if (nodeTemplates == null)
            nodeTemplates = hashMapOf()
        nodeTemplates!![id] = NodeTemplateBuilder(id, type, description).apply(block).build()
    }

    fun nodeTemplate(nodeTemplate: NodeTemplate) {
        if (nodeTemplates == null)
            nodeTemplates = hashMapOf()
        nodeTemplates!![nodeTemplate.id!!] = nodeTemplate
    }

    fun nodeTemplateOperation(nodeTemplateName: String, type: String, interfaceName: String, description: String,
                              operationBlock: OperationAssignmentBuilder.() -> Unit) {
        if (nodeTemplates == null)
            nodeTemplates = hashMapOf()

        val nodeTemplateBuilder = NodeTemplateBuilder(nodeTemplateName, type, description)
        nodeTemplateBuilder.operation(interfaceName, "$description operation", operationBlock)
        nodeTemplates!![nodeTemplateName] = nodeTemplateBuilder.build()
    }

    fun workflow(id: String, description: String, block: WorkflowBuilder.() -> Unit) {
        if (workflows == null)
            workflows = hashMapOf()
        workflows!![id] = WorkflowBuilder(id, description).apply(block).build()
    }

    fun workflow(workflow: Workflow) {
        if (workflows == null)
            workflows = hashMapOf()
        workflows!![workflow.id!!] = workflow
    }

    //TODO("populate inputs, outputs")
    fun workflowNodeTemplate(actionName: String,
                             nodeTemplateType: String, description: String, block: NodeTemplateBuilder.() -> Unit) {
        if (nodeTemplates == null)
            nodeTemplates = hashMapOf()

        if (workflows == null)
            workflows = hashMapOf()

        val workflowBuilder = WorkflowBuilder(actionName, description)
        workflowBuilder.nodeTemplateStep(actionName, description)
        // Workflow name is NodeTemplate name
        workflows!![actionName] = workflowBuilder.build()

        nodeTemplates!![actionName] = NodeTemplateBuilder(actionName, nodeTemplateType, description).apply(block).build()
    }

    fun build(): TopologyTemplate {
        topologyTemplate.nodeTemplates = nodeTemplates
        topologyTemplate.workflows = workflows
        return topologyTemplate
    }
}

class NodeTemplateBuilder(private val id: String,
                          private val type: String,
                          private val description: String? = "") {
    private var nodeTemplate: NodeTemplate = NodeTemplate()
    private var properties: MutableMap<String, JsonNode>? = null
    private var interfaces: MutableMap<String, InterfaceAssignment>? = null
    private var artifacts: MutableMap<String, ArtifactDefinition>? = null
    private var capabilities: MutableMap<String, CapabilityAssignment>? = null
    private var requirements: MutableMap<String, RequirementAssignment>? = null

    fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
        if (properties == null)
            properties = hashMapOf()
        properties = PropertiesAssignmentBuilder().apply(block).build()
    }

    fun operation(interfaceName: String, description: String? = "",
                  block: OperationAssignmentBuilder.() -> Unit) {
        if (interfaces == null)
            interfaces = hashMapOf()

        val interfaceAssignment = InterfaceAssignment()
        val defaultOperationName = BluePrintConstants.DEFAULT_STEP_OPERATION
        interfaceAssignment.operations = hashMapOf()
        interfaceAssignment.operations!![defaultOperationName] =
                OperationAssignmentBuilder(defaultOperationName, description).apply(block).build()
        interfaces!![interfaceName] = interfaceAssignment
    }

    fun artifact(id: String, type: String, file: String) {
        if (artifacts == null)
            artifacts = hashMapOf()
        artifacts!![id] = ArtifactDefinitionBuilder(id, type, file).build()
    }

    fun artifact(id: String, type: String, file: String, block: ArtifactDefinitionBuilder.() -> Unit) {
        if (artifacts == null)
            artifacts = hashMapOf()
        artifacts!![id] = ArtifactDefinitionBuilder(id, type, file).apply(block).build()
    }

    fun artifacts(artifacts: MutableMap<String, ArtifactDefinition>?) {
        this.artifacts = artifacts
    }

    fun capability(id: String, block: CapabilityAssignmentBuilder.() -> Unit) {
        if (capabilities == null)
            capabilities = hashMapOf()
        capabilities!![id] = CapabilityAssignmentBuilder(id).apply(block).build()
    }

    fun capabilities(capabilities: MutableMap<String, CapabilityAssignment>?) {
        this.capabilities = capabilities
    }

    fun requirement(id: String, capability: String, node: String, relationship: String) {
        if (requirements == null)
            requirements = hashMapOf()
        requirements!![id] = RequirementAssignmentBuilder(id, capability, node, relationship).build()
    }

    fun requirements(requirements: MutableMap<String, RequirementAssignment>?) {
        this.requirements = requirements
    }

    fun build(): NodeTemplate {
        nodeTemplate.id = id
        nodeTemplate.type = type
        nodeTemplate.description = description
        nodeTemplate.properties = properties
        nodeTemplate.interfaces = interfaces
        nodeTemplate.artifacts = artifacts
        nodeTemplate.capabilities = capabilities
        nodeTemplate.requirements = requirements
        return nodeTemplate
    }
}

class ArtifactDefinitionBuilder(private val id: String, private val type: String, private val file: String) {

    private var artifactDefinition: ArtifactDefinition = ArtifactDefinition()
    private var properties: MutableMap<String, JsonNode>? = null

    fun repository(repository: String) {
        artifactDefinition.repository = repository
    }

    fun deployPath(deployPath: String) {
        artifactDefinition.deployPath = deployPath
    }

    fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
        if (properties == null)
            properties = hashMapOf()
        properties = PropertiesAssignmentBuilder().apply(block).build()
    }

    fun build(): ArtifactDefinition {
        artifactDefinition.id = id
        artifactDefinition.type = type
        artifactDefinition.file = file
        artifactDefinition.properties = properties
        return artifactDefinition
    }
}

class CapabilityAssignmentBuilder(private val id: String) {
    private var capabilityAssignment: CapabilityAssignment = CapabilityAssignment()
    private var attributes: MutableMap<String, JsonNode>? = null
    private var properties: MutableMap<String, JsonNode>? = null

    fun attributes(block: AttributesAssignmentBuilder.() -> Unit) {
        if (attributes == null)
            attributes = hashMapOf()
        attributes = AttributesAssignmentBuilder().apply(block).build()
    }

    fun properties(block: PropertiesAssignmentBuilder.() -> Unit) {
        if (properties == null)
            properties = hashMapOf()
        properties = PropertiesAssignmentBuilder().apply(block).build()
    }

    fun build(): CapabilityAssignment {
        capabilityAssignment.properties = properties
        capabilityAssignment.attributes = attributes
        return capabilityAssignment
    }
}

class RequirementAssignmentBuilder(private val id: String, private val capability: String,
                                   private val node: String,
                                   private val relationship: String) {
    private var requirementAssignment: RequirementAssignment = RequirementAssignment()

    fun build(): RequirementAssignment {
        requirementAssignment.id = id
        requirementAssignment.capability = capability
        requirementAssignment.node = node
        requirementAssignment.relationship = relationship
        return requirementAssignment
    }
}

class InterfaceAssignmentBuilder(private val id: String) {

    private var interfaceAssignment: InterfaceAssignment = InterfaceAssignment()
    private var operations: MutableMap<String, OperationAssignment>? = null

    fun operation(id: String, description: String? = "", block: OperationAssignmentBuilder.() -> Unit) {
        if (operations == null)
            operations = hashMapOf()
        operations!![id] = OperationAssignmentBuilder(id, description).apply(block).build()
    }

    fun build(): InterfaceAssignment {
        interfaceAssignment.id = id
        interfaceAssignment.operations = operations
        return interfaceAssignment
    }
}

class OperationAssignmentBuilder(private val id: String,
                                 private val description: String? = "") {

    private var operationAssignment: OperationAssignment = OperationAssignment()

    fun implementation(implementation: Implementation?) {
        operationAssignment.implementation = implementation
    }

    fun implementation(timeout: Int, operationHost: String? = BluePrintConstants.PROPERTY_SELF) {
        val implementation = Implementation().apply {
            this.operationHost = operationHost!!
            this.timeout = timeout
        }
        operationAssignment.implementation = implementation
    }

    fun inputs(inputs: MutableMap<String, JsonNode>?) {
        operationAssignment.inputs = inputs
    }

    fun inputs(block: PropertiesAssignmentBuilder.() -> Unit) {
        operationAssignment.inputs = PropertiesAssignmentBuilder().apply(block).build()
    }

    fun outputs(outputs: MutableMap<String, JsonNode>?) {
        operationAssignment.outputs = outputs
    }

    fun outputs(block: PropertiesAssignmentBuilder.() -> Unit) {
        operationAssignment.outputs = PropertiesAssignmentBuilder().apply(block).build()
    }

    fun build(): OperationAssignment {
        operationAssignment.id = id
        operationAssignment.description = description
        return operationAssignment
    }
}

class PropertiesAssignmentBuilder {
    private var properties: MutableMap<String, JsonNode> = hashMapOf()

    fun property(id: String, value: Any) {
        property(id, value.asJsonType())
    }

    fun property(id: String, value: JsonNode) {
        properties[id] = value
    }

    fun build(): MutableMap<String, JsonNode> {
        return properties
    }
}

class AttributesAssignmentBuilder {
    private var attributes: MutableMap<String, JsonNode> = hashMapOf()

    fun attribute(id: String, value: String) {
        attribute(id, value.asJsonType())
    }

    fun attribute(id: String, value: JsonNode) {
        attributes[id] = value
    }

    fun build(): MutableMap<String, JsonNode> {
        return attributes
    }
}