DMI Data AVC to use kafka headers
[cps.git] / integration-test / src / test / groovy / org / onap / cps / integration / base / FunctionalSpecBase.groovy
1 /*
2  *  ============LICENSE_START=======================================================
3  *  Copyright (C) 2023 Nordix Foundation
4  *  ================================================================================
5  *  Licensed under the Apache License, Version 2.0 (the 'License');
6  *  you may not use this file except in compliance with the License.
7  *  You may obtain a copy of the License at
8  *
9  *        http://www.apache.org/licenses/LICENSE-2.0
10  *
11  *  Unless required by applicable law or agreed to in writing, software
12  *  distributed under the License is distributed on an 'AS IS' BASIS,
13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  *  See the License for the specific language governing permissions and
15  *  limitations under the License.
16  *
17  *  SPDX-License-Identifier: Apache-2.0
18  *  ============LICENSE_END=========================================================
19  */
20
21 package org.onap.cps.integration.base
22
23 class FunctionalSpecBase extends CpsIntegrationSpecBase {
24
25     def static FUNCTIONAL_TEST_DATASPACE_1 = 'functionalTestDataspace1'
26     def static FUNCTIONAL_TEST_DATASPACE_2 = 'functionalTestDataspace2'
27     def static NUMBER_OF_ANCHORS_PER_DATASPACE_WITH_BOOKSTORE_DATA = 2
28     def static BOOKSTORE_ANCHOR_1 = 'bookstoreAnchor1'
29     def static BOOKSTORE_ANCHOR_2 = 'bookstoreAnchor2'
30
31     def static initialized = false
32
33     def setup() {
34         if (!initialized) {
35             setupBookstoreInfraStructure()
36             addBookstoreData()
37             initialized = true
38         }
39     }
40
41     def setupBookstoreInfraStructure() {
42         cpsAdminService.createDataspace(FUNCTIONAL_TEST_DATASPACE_1)
43         cpsAdminService.createDataspace(FUNCTIONAL_TEST_DATASPACE_2)
44         def bookstoreYangModelAsString = readResourceDataFile('bookstore/bookstore.yang')
45         cpsModuleService.createSchemaSet(FUNCTIONAL_TEST_DATASPACE_1, BOOKSTORE_SCHEMA_SET, [bookstore: bookstoreYangModelAsString])
46         cpsModuleService.createSchemaSet(FUNCTIONAL_TEST_DATASPACE_2, BOOKSTORE_SCHEMA_SET, [bookstore: bookstoreYangModelAsString])
47     }
48
49     def addBookstoreData() {
50         def bookstoreJsonData = readResourceDataFile('bookstore/bookstoreData.json')
51         addAnchorsWithData(NUMBER_OF_ANCHORS_PER_DATASPACE_WITH_BOOKSTORE_DATA, FUNCTIONAL_TEST_DATASPACE_1, BOOKSTORE_SCHEMA_SET, 'bookstoreAnchor', bookstoreJsonData)
52         addAnchorsWithData(NUMBER_OF_ANCHORS_PER_DATASPACE_WITH_BOOKSTORE_DATA, FUNCTIONAL_TEST_DATASPACE_2, BOOKSTORE_SCHEMA_SET, 'bookstoreAnchor', bookstoreJsonData)
53     }
54
55 }