aboutsummaryrefslogtreecommitdiffstats
path: root/model/src/test/java/org/onap/policy/apex/model/basicmodel/handling/ApexModelReaderTest.java
blob: 1152771eaa5eb401fd8431d4cd038c6a30d3ef41 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
 * ============LICENSE_START=======================================================
 *  Copyright (C) 2016-2018 Ericsson. All rights reserved.
 *  Modifications Copyright (C) 2020,2022 Nordix Foundation
 *  Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved.
 * ================================================================================
 * 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.
 *
 * SPDX-License-Identifier: Apache-2.0
 * ============LICENSE_END=========================================================
 */

package org.onap.policy.apex.model.basicmodel.handling;

import static org.assertj.core.api.Assertions.assertThatThrownBy;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;

import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileReader;
import java.io.IOException;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.runners.MockitoJUnitRunner;
import org.onap.policy.apex.model.basicmodel.concepts.ApexException;
import org.onap.policy.apex.model.basicmodel.concepts.AxModel;

@RunWith(MockitoJUnitRunner.class)
public class ApexModelReaderTest {
    @Test
    public void testModelReader() throws IOException, ApexException {
        AxModel model = new DummyApexBasicModelCreator().getModel();
        AxModel invalidModel = new DummyApexBasicModelCreator().getInvalidModel();

        ApexModelWriter<AxModel> modelWriter = new ApexModelWriter<AxModel>(AxModel.class);
        modelWriter.setValidate(true);

        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        modelWriter.write(model, baos);

        ByteArrayOutputStream baosInvalid = new ByteArrayOutputStream();
        modelWriter.setValidate(false);
        modelWriter.write(invalidModel, baosInvalid);

        ApexModelReader<AxModel> modelReader = new ApexModelReader<AxModel>(AxModel.class, true);

        modelReader.setValidate(true);
        assertTrue(modelReader.isValidate());

        ByteArrayInputStream bais = new ByteArrayInputStream(baos.toByteArray());
        AxModel readModel = modelReader.read(bais);
        assertEquals(model, readModel);

        ByteArrayInputStream baisInvalid = new ByteArrayInputStream(baosInvalid.toByteArray());
        assertThatThrownBy(() -> modelReader.read(baisInvalid))
            .hasMessageStartingWith("Apex concept validation failed");
        modelReader.setValidate(false);
        assertFalse(modelReader.isValidate());

        ByteArrayInputStream bais2 = new ByteArrayInputStream(baos.toByteArray());
        AxModel readModel2 = modelReader.read(bais2);
        assertEquals(model, readModel2);

        ByteArrayOutputStream baosJson = new ByteArrayOutputStream();
        modelWriter.write(model, baosJson);

        ByteArrayInputStream baisJson = new ByteArrayInputStream(baosJson.toByteArray());
        AxModel readModelJson = modelReader.read(baisJson);
        assertEquals(model, readModelJson);

        String dummyString = "SomeDummyText";
        ByteArrayInputStream baisDummy = new ByteArrayInputStream(dummyString.getBytes());
        assertThatThrownBy(() -> modelReader.read(baisDummy))
            .hasMessageContaining("Unable to unmarshal Apex concept");
        ByteArrayInputStream nullBais = null;
        assertThatThrownBy(() -> modelReader.read(nullBais))
            .hasMessage("concept stream may not be null");

        assertThatThrownBy(() -> {
            FileInputStream fis = new FileInputStream(new File("somewhere/over/the/rainbow"));
            modelReader.read(fis);
        }).hasMessageContaining("rainbow");
        final File tempFile = File.createTempFile("Apex", "Dummy");
        BufferedReader br = new BufferedReader(new FileReader(tempFile));
        br.close();
        assertThatThrownBy(() -> modelReader.read(br))
             .hasMessage("Unable to read Apex concept ");
        tempFile.delete();
    }
}