2 * Copyright © 2017-2018 AT&T Intellectual Property.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.onap.ccsdk.cds.controllerblueprints.service.load
19 import com.att.eelf.configuration.EELFManager
20 import kotlinx.coroutines.Deferred
21 import kotlinx.coroutines.async
22 import kotlinx.coroutines.runBlocking
23 import org.apache.commons.lang3.StringUtils
24 import org.apache.commons.lang3.text.StrBuilder
25 import org.onap.ccsdk.cds.controllerblueprints.core.BluePrintException
26 import org.onap.ccsdk.cds.controllerblueprints.core.utils.JacksonUtils
27 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceDefinition
28 import org.onap.ccsdk.cds.controllerblueprints.service.domain.ResourceDictionary
29 import org.onap.ccsdk.cds.controllerblueprints.service.handler.ResourceDictionaryHandler
30 import org.springframework.stereotype.Service
32 import java.nio.charset.Charset
35 open class ResourceDictionaryLoadService(private val resourceDictionaryHandler: ResourceDictionaryHandler) {
37 private val log = EELFManager.getInstance().getLogger(ResourceDictionaryLoadService::class.java)
39 open fun loadPathsResourceDictionary(paths: List<String>) {
40 paths.forEach { loadPathResourceDictionary(it) }
43 open fun loadPathResourceDictionary(path: String) {
44 log.info(" *************************** loadResourceDictionary **********************")
45 val files = File(path).listFiles()
48 val errorBuilder = StrBuilder()
49 val deferredResults = mutableListOf<Deferred<Unit>>()
52 deferredResults += async {
53 loadResourceDictionary(errorBuilder, file)
57 for (deferredResult in deferredResults) {
58 deferredResult.await()
61 if (!errorBuilder.isEmpty) {
62 log.error(errorBuilder.toString())
67 private fun loadResourceDictionary(errorBuilder: StrBuilder, file: File) {
69 log.trace("Loading NodeType(${file.name}")
70 val definitionContent = file.readText(Charset.defaultCharset())
71 val resourceDefinition = JacksonUtils.readValue(definitionContent, ResourceDefinition::class.java)
72 if (resourceDefinition != null) {
74 checkNotNull(resourceDefinition.property) { "Failed to get Property Definition" }
75 val resourceDictionary = ResourceDictionary()
76 resourceDictionary.name = resourceDefinition.name
77 resourceDictionary.definition = resourceDefinition
79 checkNotNull(resourceDefinition.property) { "Property field is missing" }
80 resourceDictionary.description = resourceDefinition.property.description
81 resourceDictionary.dataType = resourceDefinition.property.type
83 if (resourceDefinition.property.entrySchema != null) {
84 resourceDictionary.entrySchema = resourceDefinition.property.entrySchema!!.type
86 resourceDictionary.updatedBy = resourceDefinition.updatedBy
88 if (StringUtils.isBlank(resourceDefinition.tags)) {
89 resourceDictionary.tags = (resourceDefinition.name + ", " + resourceDefinition.updatedBy
90 + ", " + resourceDefinition.updatedBy)
93 resourceDictionary.tags = resourceDefinition.tags
95 resourceDictionaryHandler.saveResourceDictionary(resourceDictionary)
97 log.trace("Resource dictionary(${file.name}) loaded successfully ")
99 throw BluePrintException("couldn't get dictionary from content information")
101 } catch (e: Exception) {
102 errorBuilder.appendln("Couldn't load Resource dictionary (${file.name}: ${e.message}")