Blueprints Processor Microservice

Implement basic blueprint service logic workflow execution engine.

Change-Id: Ifbbad70f2bdc4ba879b07d972083a411c7cc02f1
Issue-ID: CCSDK-672
Signed-off-by: Muthuramalingam, Brinda Santh(bs2796) <bs2796@att.com>

1 files changed, 17 insertions, 18 deletions

diff --git a/ms/blueprintsprocessor/modules/services/resolution-service/src/main/kotlin/org/onap/ccsdk/apps/blueprintsprocessor/services/resolution/ResourceResolutionService.kt b/ms/blueprintsprocessor/modules/services/resolution-service/src/main/kotlin/org/onap/ccsdk/apps/blueprintsprocessor/services/resolution/ResourceResolutionService.kt
index d442c96b..3ee7e41f 100644
--- a/ms/blueprintsprocessor/modules/services/resolution-service/src/main/kotlin/org/onap/ccsdk/apps/blueprintsprocessor/services/resolution/ResourceResolutionService.kt
+++ b/ms/blueprintsprocessor/modules/services/resolution-service/src/main/kotlin/org/onap/ccsdk/apps/blueprintsprocessor/services/resolution/ResourceResolutionService.kt
@@ -17,12 +17,11 @@
 

 package org.onap.ccsdk.apps.blueprintsprocessor.services.resolution

 

-import org.onap.ccsdk.apps.blueprintsprocessor.core.api.data.BlueprintProcessorException

-import org.onap.ccsdk.apps.blueprintsprocessor.core.factory.ResourceAssignmentProcessorFactory

 import org.onap.ccsdk.apps.blueprintsprocessor.core.api.data.ResourceResolutionInput

 import org.onap.ccsdk.apps.blueprintsprocessor.core.api.data.ResourceResolutionOutput

 import org.onap.ccsdk.apps.blueprintsprocessor.core.api.data.Status

-import org.onap.ccsdk.apps.controllerblueprints.core.format

+import org.onap.ccsdk.apps.blueprintsprocessor.core.factory.ResourceAssignmentProcessorFactory

+import org.onap.ccsdk.apps.controllerblueprints.core.BluePrintProcessorException

 import org.onap.ccsdk.apps.controllerblueprints.resource.dict.ResourceAssignment

 import org.onap.ccsdk.apps.controllerblueprints.resource.dict.utils.BulkResourceSequencingUtils

 import org.springframework.stereotype.Service

@@ -59,22 +58,22 @@ class ResourceResolutionService(private val resourceAssignmentProcessorFactory:
         val bulkSequenced = BulkResourceSequencingUtils.process(resourceAssignments)

 

         bulkSequenced.map { batchResourceAssignments ->

-            batchResourceAssignments.filter { it.name != "*" && it.name != "start"}

-            .map { resourceAssignment ->

-                val dictionarySource = resourceAssignment.dictionarySource

-                val processorInstanceName = "resource-assignment-processor-".plus(dictionarySource)

-                val resourceAssignmentProcessor = resourceAssignmentProcessorFactory.getInstance(processorInstanceName)

-                        ?: throw BlueprintProcessorException(format("failed to get resource processor for instance name({}) " +

-                                "for resource assignment({})", processorInstanceName, resourceAssignment.name))

-                try {

-                    resourceAssignmentProcessor.validate(resourceAssignment, context)

-                    resourceAssignmentProcessor.process(resourceAssignment, context)

-                } catch (e: Exception) {

-                    resourceAssignmentProcessor.errorHandle(resourceAssignment, context)

-                    throw BlueprintProcessorException(e)

-                }

+            batchResourceAssignments.filter { it.name != "*" && it.name != "start" }

+                    .map { resourceAssignment ->

+                        val dictionarySource = resourceAssignment.dictionarySource

+                        val processorInstanceName = "resource-assignment-processor-".plus(dictionarySource)

+                        val resourceAssignmentProcessor = resourceAssignmentProcessorFactory.getInstance(processorInstanceName)

+                                ?: throw BluePrintProcessorException("failed to get resource processor for instance name($processorInstanceName) " +

+                                        "for resource assignment(${resourceAssignment.name})")

+                        try {

+                            resourceAssignmentProcessor.validate(resourceAssignment, context)

+                            resourceAssignmentProcessor.process(resourceAssignment, context)

+                        } catch (e: Exception) {

+                            resourceAssignmentProcessor.errorHandle(resourceAssignment, context)

+                            throw BluePrintProcessorException(e)

+                        }

 

-            }

+                    }

         }

     }

 }