diff options
12 files changed, 918 insertions, 0 deletions
diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/artifact_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/artifact_types.json new file mode 100644 index 000000000..a730e4893 --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/artifact_types.json @@ -0,0 +1,10 @@ +{ + "artifact_types" : { + "artifact-mapping-resource" : { + "description" : "Resource Mapping File used along with Configuration template", + "version" : "1.0.0", + "derived_from" : "tosca.artifacts.Implementation", + "file_ext" : [ "json" ] + } + } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/data_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/data_types.json new file mode 100644 index 000000000..1b8f2b31b --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/data_types.json @@ -0,0 +1,15 @@ +{ + "data_types" : { + "dt-uat-wf-properties" : { + "description" : "Dynamic DataType definition for workflow(uat-wf).", + "version" : "1.0.0", + "properties" : { + "service-instance-id" : { + "required" : true, + "type" : "string" + } + }, + "derived_from" : "tosca.datatypes.Dynamic" + } + } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/node_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/node_types.json new file mode 100644 index 000000000..e86405cee --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/node_types.json @@ -0,0 +1,185 @@ +{ + "node_types" : { + "component-resource-resolution" : { + "description" : "This is Resource Assignment Component API", + "version" : "1.0.0", + "attributes" : { + "assignment-params" : { + "description" : "Holds resolved template, resolution-summary or key-value", + "required" : true, + "type" : "string" + }, + "assignment-map" : { + "description" : "Holds resolved values for each artifact prefix eg. { vdns: { vnf-id: 123 } }", + "required" : true, + "type" : "map" + } + }, + "capabilities" : { + "component-node" : { + "type" : "tosca.capabilities.Node" + } + }, + "interfaces" : { + "ResourceResolutionComponent" : { + "operations" : { + "process" : { + "inputs" : { + "resolution-key" : { + "description" : "Key for service instance related correlation.", + "required" : false, + "type" : "string" + }, + "occurrence" : { + "description" : "Number of time to perform the resolution.", + "required" : false, + "type" : "integer", + "default" : 1 + }, + "store-result" : { + "description" : "Whether or not to store the output.", + "required" : false, + "type" : "boolean" + }, + "resource-type" : { + "description" : "Request type.", + "required" : false, + "type" : "string" + }, + "resolution-summary" : { + "description" : "Enable resolution-summary output", + "required" : false, + "type" : "boolean" + }, + "artifact-prefix-names" : { + "description" : "Template , Resource Assignment Artifact Prefix names", + "required" : true, + "type" : "list", + "entry_schema" : { + "type" : "string" + } + }, + "request-id" : { + "description" : "Request Id, Unique Id for the request.", + "required" : true, + "type" : "string" + }, + "resource-id" : { + "description" : "Resource Id.", + "required" : false, + "type" : "string" + }, + "action-name" : { + "description" : "Action Name of the process", + "required" : false, + "type" : "string" + }, + "dynamic-properties" : { + "description" : "Dynamic Json Content or DSL Json reference.", + "required" : false, + "type" : "json" + } + }, + "outputs" : { + "resource-assignment-params" : { + "required" : true, + "type" : "string" + }, + "resource-assignment-map" : { + "required" : true, + "type" : "string" + }, + "status" : { + "required" : true, + "type" : "string" + } + } + } + } + } + }, + "derived_from" : "tosca.nodes.Component" + }, + "component-script-executor" : { + "description" : "This is CLI Transaction Configuration Component API", + "version" : "1.0.0", + "attributes" : { + "response-data" : { + "required" : false, + "type" : "json" + } + }, + "capabilities" : { + "component-node" : { + "type" : "tosca.capabilities.Node" + } + }, + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "inputs" : { + "script-type" : { + "description" : "Script type, kotlin type is supported", + "required" : true, + "type" : "string", + "constraints" : [ { + "valid_values" : [ "kotlin", "jython", "internal" ] + } ], + "default" : "internal" + }, + "script-class-reference" : { + "description" : "Kotlin Script class name or jython script name.", + "required" : true, + "type" : "string" + }, + "instance-dependencies" : { + "description" : "Instance names to inject to Jython or Kotlin Script.", + "required" : true, + "type" : "list", + "entry_schema" : { + "type" : "string" + } + }, + "dynamic-properties" : { + "description" : "Dynamic Json Content or DSL Json reference.", + "required" : false, + "type" : "json" + } + }, + "outputs" : { + "response-data" : { + "description" : "Execution Response Data.", + "required" : false, + "type" : "string" + }, + "status" : { + "description" : "Status of the Component Execution ( success or failure )", + "required" : true, + "type" : "string" + } + } + } + } + } + }, + "derived_from" : "tosca.nodes.Component" + }, + "source-input" : { + "description" : "This is Input Resource Source Node Type", + "version" : "1.0.0", + "properties" : { }, + "derived_from" : "tosca.nodes.ResourceSource" + }, + "tosca.nodes.Component" : { + "description" : "This is default Component Node", + "version" : "1.0.0", + "derived_from" : "tosca.nodes.Root" + }, + "tosca.nodes.ResourceSource" : { + "description" : "TOSCA base type for Resource Sources", + "version" : "1.0.0", + "derived_from" : "tosca.nodes.Root" + } + } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/policy_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/policy_types.json new file mode 100644 index 000000000..1e44cc70a --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/policy_types.json @@ -0,0 +1,3 @@ +{ + "policy_types" : { } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/relationship_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/relationship_types.json new file mode 100644 index 000000000..4ddd7a57c --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/relationship_types.json @@ -0,0 +1,3 @@ +{ + "relationship_types" : { } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/resources_definition_types.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/resources_definition_types.json new file mode 100644 index 000000000..c7277c027 --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/resources_definition_types.json @@ -0,0 +1,18 @@ +{ + "input-source" : { + "tags" : "input-source", + "name" : "input-source", + "property" : { + "description" : "name of the ", + "type" : "string" + }, + "group" : "default", + "updated-by" : "brindasanth@onap.com", + "sources" : { + "input" : { + "type" : "source-input", + "properties" : { } + } + } + } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/uat-imperative-workflow.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/uat-imperative-workflow.json new file mode 100644 index 000000000..508d8b2e2 --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Definitions/uat-imperative-workflow.json @@ -0,0 +1,246 @@ +{ + "tosca_definitions_version" : "controller_blueprint_1_0_0", + "metadata" : { + "template_author" : "cds-dev", + "author-email" : "test@bell.ca", + "template_name" : "uat-imperative-workflow", + "template_version" : "1.0.0", + "template_tags" : "UAT, CBA, test", + "template_type" : "DEFAULT" + }, + "imports" : [ { + "file" : "Definitions/data_types.json" + }, { + "file" : "Definitions/relationship_types.json" + }, { + "file" : "Definitions/artifact_types.json" + }, { + "file" : "Definitions/node_types.json" + }, { + "file" : "Definitions/policy_types.json" + } ], + "dsl_definitions" : { }, + "topology_template" : { + "workflows" : { + "uat-wf" : { + "steps" : { + "assign" : { + "target" : "resource-resolution", + "on_success" : [ "deploy" ], + "on_failure" : [ "assign-recover" ] + }, + "assign-recover" : { + "target" : "execute-script-1", + "on_success" : [ "deploy" ], + "on_failure" : [ "collect" ] + }, + "deploy" : { + "target" : "execute-script-2", + "on_success" : [ "collect" ], + "on_failure" : [ "deploy-recover" ] + }, + "deploy-recover" : { + "target" : "execute-script-3", + "on_success" : [ "collect" ], + "on_failure" : [ "collect" ] + }, + "collect" : { + "target" : "collect-results" + } + }, + "inputs" : { + "service-instance-id" : { + "type" : "string" + }, + "failing-steps" : { + "type" : "json" + }, + "uat-wf-properties" : { + "description" : "Dynamic PropertyDefinition for workflow(uat-wf).", + "required" : true, + "type" : "dt-uat-wf-properties" + } + }, + "outputs" : { + "results" : { + "type" : "string", + "value" : { + "get_attribute" : [ "collect-results", "response-data" ] + } + } + } + }, + "uat-wf-parallel" : { + "steps" : { + "execute-A" : { + "target" : "execute-script-1", + "on_success" : [ "finalize" ], + "on_failure" : [ "clean-up" ] + }, + "execute-B" : { + "target" : "execute-script-2", + "on_success" : [ "finalize" ], + "on_failure" : [ "clean-up" ] + }, + "finalize" : { + "target" : "execute-script-3", + "on_success" : [ "clean-up" ], + "on_failure" : [ "clean-up" ] + }, + "clean-up" : { + "target" : "execute-script-4", + "on_success" : [ "collect" ], + "on_failure" : [ "collect" ] + }, + "collect" : { + "target" : "collect-results" + } + }, + "inputs" : { + "service-instance-id" : { + "type" : "string" + }, + "failing-steps" : { + "type" : "json" + } + }, + "outputs" : { + "results" : { + "type" : "string", + "value" : { + "get_attribute" : [ "collect-results", "response-data" ] + } + } + } + } + }, + "node_templates" : { + "resource-resolution" : { + "type" : "component-resource-resolution", + "interfaces" : { + "ResourceResolutionComponent" : { + "operations" : { + "process" : { + "inputs" : { + "artifact-prefix-names" : [ "assign" ], + "store-result" : false + } + } + } + } + }, + "artifacts" : { + "assign-mapping" : { + "type" : "artifact-mapping-resource", + "file" : "Templates/assign-mapping.json" + } + } + }, + "execute-script-1" : { + "type" : "component-script-executor", + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "implementation" : { + "primary" : "component-script", + "timeout" : 180, + "operation_host" : "SELF" + }, + "inputs" : { + "script-type" : "kotlin", + "script-class-reference" : "cba.cds.uat.TestScript" + }, + "outputs" : { } + } + } + } + } + }, + "execute-script-2" : { + "type" : "component-script-executor", + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "implementation" : { + "primary" : "component-script", + "timeout" : 180, + "operation_host" : "SELF" + }, + "inputs" : { + "script-type" : "kotlin", + "script-class-reference" : "cba.cds.uat.TestScript" + }, + "outputs" : { } + } + } + } + } + }, + "execute-script-3" : { + "type" : "component-script-executor", + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "implementation" : { + "primary" : "component-script", + "timeout" : 180, + "operation_host" : "SELF" + }, + "inputs" : { + "script-type" : "kotlin", + "script-class-reference" : "cba.cds.uat.TestScript" + }, + "outputs" : { } + } + } + } + } + }, + "execute-script-4" : { + "type" : "component-script-executor", + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "implementation" : { + "primary" : "component-script", + "timeout" : 180, + "operation_host" : "SELF" + }, + "inputs" : { + "script-type" : "kotlin", + "script-class-reference" : "cba.cds.uat.TestScript" + }, + "outputs" : { } + } + } + } + } + }, + "collect-results" : { + "type" : "component-script-executor", + "interfaces" : { + "ComponentScriptExecutor" : { + "operations" : { + "process" : { + "implementation" : { + "primary" : "component-script", + "timeout" : 180, + "operation_host" : "SELF" + }, + "inputs" : { + "script-type" : "kotlin", + "script-class-reference" : "cba.cds.uat.CollectorScript" + }, + "outputs" : { } + } + } + } + } + } + } + } +}
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/CollectorScript.kt b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/CollectorScript.kt new file mode 100644 index 000000000..28ce1494e --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/CollectorScript.kt @@ -0,0 +1,51 @@ +/* + * Copyright © 20201 Bell Canada. + * + * 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 cba.cds.uat + +import com.fasterxml.jackson.databind.JsonNode +import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput +import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction +import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.ComponentScriptExecutor +import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintProcessorException +import org.onap.ccsdk.cds.controllerblueprints.core.asJsonNode +import org.onap.ccsdk.cds.controllerblueprints.core.logger + +open class CollectorScript : AbstractScriptComponentFunction() { + + private val log = logger(CollectorScript::class) + + override suspend fun processNB(executionRequest: ExecutionServiceInput) { + bluePrintRuntimeService.bluePrintContext() + .serviceTemplate.topologyTemplate!!.nodeTemplates!! + .keys.filter { it.startsWith("execute-script") } + .associateWith { responseData(it) } + .let { it.asJsonNode() } + .also { log.info("Collected results: $it") } + .let { setAttribute(ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA, it) } + } + + private fun responseData(nodeTemplateName: String): JsonNode? { + return try { + bluePrintRuntimeService.getNodeTemplateAttributeValue(nodeTemplateName, + ComponentScriptExecutor.ATTRIBUTE_RESPONSE_DATA) + } catch (exception: BlueprintProcessorException) { null } + } + + override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) { + addError(runtimeException.message ?: "Failed without error message") + } +} diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/TestScript.kt b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/TestScript.kt new file mode 100644 index 000000000..af3ebffb1 --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Scripts/kotlin/TestScript.kt @@ -0,0 +1,58 @@ +/* + * Copyright © 20201 Bell Canada. + * + * 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 cba.cds.uat + +import com.fasterxml.jackson.databind.JsonNode +import org.onap.ccsdk.cds.blueprintsprocessor.core.api.data.ExecutionServiceInput +import org.onap.ccsdk.cds.blueprintsprocessor.services.execution.AbstractScriptComponentFunction +import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintException +import org.onap.ccsdk.cds.controllerblueprints.core.BlueprintProcessorException +import org.onap.ccsdk.cds.controllerblueprints.core.asJsonPrimitive +import org.onap.ccsdk.cds.controllerblueprints.core.logger + +open class TestScript : AbstractScriptComponentFunction() { + + private val log = logger(TestScript::class) + + private val FAILED = "FAILED".asJsonPrimitive() + private val SUCCEEDED = "SUCCEEDED".asJsonPrimitive() + + override suspend fun processNB(executionRequest: ExecutionServiceInput) { + val failingSteps = inputValue("failing-steps") + var shouldFail = false + if (failingSteps?.has(this.stepName) == true) { + shouldFail = failingSteps[this.stepName].asBoolean() + } + log.info("running step ${this.stepName}, should fail: $shouldFail") + setAttribute("response-data", if (shouldFail) FAILED else SUCCEEDED) + + if (shouldFail) { + throw BlueprintException("Step failed: ${this.stepName}") + } + } + + fun inputValue(name: String): JsonNode? { + return try { + return bluePrintRuntimeService.getInputValue(name) + } catch (e: BlueprintProcessorException) { null } + } + + override suspend fun recoverNB(runtimeException: RuntimeException, executionRequest: ExecutionServiceInput) { + log.info("Executing Recovery for step ${this.stepName}") + addError(runtimeException.message ?: "Failed without error message") + } +} diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/TOSCA-Metadata/TOSCA.meta b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/TOSCA-Metadata/TOSCA.meta new file mode 100644 index 000000000..33e51a78c --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/TOSCA-Metadata/TOSCA.meta @@ -0,0 +1,8 @@ +TOSCA-Meta-File-Version: 1.0.0 +CSAR-Version: 1.0 +Created-By: cds-dev +Entry-Definitions: Definitions/uat-imperative-workflow.json +Template-Tags: UAT, CBA, test +Template-Name: uat-imperative-workflow +Template-Version: 1.0.0 +Template-Type: DEFAULT
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Templates/assign-mapping.json b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Templates/assign-mapping.json new file mode 100644 index 000000000..57a0ad4f0 --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Templates/assign-mapping.json @@ -0,0 +1,13 @@ +[ + { + "name": "service-instance-id", + "input-param": true, + "property": { + "type": "string", + "required": true + }, + "dictionary-name": "input-source", + "dictionary-source": "input", + "dependencies": [] + } +]
\ No newline at end of file diff --git a/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Tests/uat.yaml b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Tests/uat.yaml new file mode 100644 index 000000000..3aab65e8a --- /dev/null +++ b/components/model-catalog/blueprint-model/uat-blueprints/imperative_workflow/Tests/uat.yaml @@ -0,0 +1,308 @@ +%YAML 1.1 +--- +# Imperative workflow UAT +# +# The CBA has 4 node-templates: execute-script-N(1..4), which all execute TestScript.kt +# The kotlin script will either succeed or fail depending on request input values +# example input: +# "uat-wf-request": { +# "service-instance-id": {}, +# "failing-steps": { +# "assign": true +# "deploy-recover": true +# } +# } +# The kotlin script will look for failing-steps[stepName], if value is present and true +# an exception will be thrown, causing the step to fail. +# +# All workflows end with running CollectorScripts.kt which will produce the final +# response payload with the execution results. +# +# "uat-wf-response": { +# "results": { +# "execute-script-1": null, (script was not executed) +# "execute-script-2": "SUCCEEDED", +# "execute-script-3": null, +# "execute-script-4": "FAILED" +# } +# } +# +# CBA WORKFLOWS +# uat-wf +# steps: step (target node-template) : outgoing edges +# assign (resource-resolution) : success -> deploy, failure -> assign-recover +# assign-recover (execute-script-1) : success -> deploy, failure -> collect +# deploy (execute-script-2) : success -> collect, failure -> deploy-recover +# deploy-recover (execute-script-3) : success -> collect, failure -> collect +# collect (collect-results) +# +# uat-wf-parallel - 2 parallel start nodes +# steps: step (target node-template) : outgoing edges +# execute-A (execute-script-1) : success -> finalize, failure -> clean-up +# execute-B (execute-script-2) : success -> finalize, failure -> clean-up +# finalize (execute-script-3) : success -> clean-up, failure -> clean-up +# clean-up (execute-script-4) : success -> collect, failure -> collect +# collect (collect-results) + +processes: +# Test cases for uat-wf + - name: uat-wf-happy-case + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf + mode: sync + payload: + uat-wf-request: + service-instance-id: test-123 + #Expected flow: assign -> deploy -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-response: + results: + execute-script-1: null + execute-script-2: SUCCEEDED + execute-script-3: null + execute-script-4: null + + - name: uat-wf-assign-fails + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf + mode: sync + payload: + uat-wf-request: + #service-instance-id: assign will fail when this is removed + #Expected flow: assign(fail) -> assign-recover -> deploy -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-response: + results: + execute-script-1: SUCCEEDED + execute-script-2: SUCCEEDED + execute-script-3: null + execute-script-4: null + + - name: uat-wf-assign-recover-fails + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf + mode: sync + payload: + uat-wf-request: + #service-instance-id: assign will fail when this is removed + failing-steps: + assign-recover: true + # Expected flow: assign(fail) -> assign-recover(fail) -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-response: + results: + execute-script-1: FAILED + execute-script-2: null + execute-script-3: null + execute-script-4: null + + - name: uat-wf-deploy-fail + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf + mode: sync + payload: + uat-wf-request: + service-instance-id: test-123 + failing-steps: + deploy: true + #Expected flow: assign -> deploy(fail) -> deploy-recover -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-response: + results: + execute-script-1: null + execute-script-2: FAILED + execute-script-3: SUCCEEDED + execute-script-4: null + + - name: uat-wf-assign-fail-and-deploy-fail + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf + mode: sync + payload: + uat-wf-request: + #service-instance-id: assign will fail when this is removed + failing-steps: + deploy: true + #Expected flow: assign(fail) -> assign-recover -> deploy(fail) -> deploy-recover -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-response: + results: + execute-script-1: SUCCEEDED + execute-script-2: FAILED + execute-script-3: SUCCEEDED + execute-script-4: null + +# Test cases for uat-wf-parallel + - name: uat-wf-parallel-happy-case + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf-parallel + mode: sync + payload: + uat-wf-parallel-request: + #Expected flow: execute-A, execute-B -> finalize -> clean-up -> collect + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-parallel-response: + results: + execute-script-1: SUCCEEDED + execute-script-2: SUCCEEDED + execute-script-3: SUCCEEDED + execute-script-4: SUCCEEDED + + - name: uat-wf-execute-script-1-fail + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf-parallel + mode: sync + payload: + uat-wf-parallel-request: + failing-steps: + execute-A: true + #Expected flow: execute-A (fail) ------> + # clean-up -> collect + # execute-B -> finalize -> + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-parallel-response: + results: + execute-script-1: FAILED + execute-script-2: SUCCEEDED + execute-script-3: SUCCEEDED + execute-script-4: SUCCEEDED + + - name: uat-wf-both-execute-scrips-fail + request: + commonHeader: &ch + originatorId: sdnc + requestId: "1234" + subRequestId: "1234-12234" + actionIdentifiers: &ai + blueprintName: uat-imperative-workflow + blueprintVersion: "1.0.0" + actionName: uat-wf-parallel + mode: sync + payload: + uat-wf-parallel-request: + failing-steps: + execute-A: true + execute-B: true + #Expected flow: execute-A (fail) -> + # clean-up -> collect + # execute-B (fail) -> + expectedResponse: + commonHeader: *ch + actionIdentifiers: *ai + status: + code: 200 + eventType: EVENT_COMPONENT_EXECUTED + errorMessage: null + message: success + payload: + uat-wf-parallel-response: + results: + execute-script-1: FAILED + execute-script-2: FAILED + execute-script-3: null + execute-script-4: SUCCEEDED
\ No newline at end of file |