a938bf2076811a6b301ad935e76c00666c2737ab
[policy/drools-pdp.git] /
1 /*-
2  * ============LICENSE_START=======================================================
3  * policy-management
4  * ================================================================================
5  * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved.
6  * ================================================================================
7  * Licensed under the Apache License, Version 2.0 (the "License");
8  * you may not use this file except in compliance with the License.
9  * You may obtain a copy of the License at
10  *
11  *      http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing, software
14  * distributed under the License is distributed on an "AS IS" BASIS,
15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16  * See the License for the specific language governing permissions and
17  * limitations under the License.
18  * ============LICENSE_END=========================================================
19  */
20
21 package org.onap.policy.drools.controller.internal;
22
23 import java.io.IOException;
24 import java.nio.file.Paths;
25 import org.junit.Assert;
26 import org.junit.BeforeClass;
27 import org.junit.Test;
28 import org.kie.api.builder.ReleaseId;
29 import org.onap.policy.drools.controller.DroolsController;
30 import org.onap.policy.drools.util.KieUtils;
31
32 public class MavenDroolsControllerTest {
33
34     private static final String JUNIT_ECHO_KSESSION = "echo";
35     private static final String JUNIT_ECHO_KMODULE_DRL_PATH = "src/test/resources/echo.drl";
36     private static final String JUNIT_ECHO_KMODULE_POM_PATH = "src/test/resources/echo.pom";
37     private static final String JUNIT_ECHO_KMODULE_PATH = "src/test/resources/echo.kmodule";
38     private static final String JUNIT_ECHO_KJAR_DRL_PATH =
39         "src/main/resources/kbEcho/org/onap/policy/drools/test/echo.drl";
40
41     private static volatile ReleaseId releaseId;
42
43     @BeforeClass
44     public static void setUp() throws IOException {
45         releaseId =
46             KieUtils.installArtifact(Paths.get(JUNIT_ECHO_KMODULE_PATH).toFile(),
47                 Paths.get(JUNIT_ECHO_KMODULE_POM_PATH).toFile(),
48                 JUNIT_ECHO_KJAR_DRL_PATH,
49                 Paths.get(JUNIT_ECHO_KMODULE_DRL_PATH).toFile());
50     }
51
52     @Test
53     public void stop() throws IOException, InterruptedException {
54         createDroolsController(10000L).stop();
55     }
56
57     @Test
58     public void shutdown() throws IOException, InterruptedException {
59         createDroolsController(10000L).shutdown();
60     }
61
62     @Test
63     public void lock() throws IOException, InterruptedException {
64         DroolsController controller = createDroolsController(30000L);
65
66         controller.lock();
67         Assert.assertTrue(controller.isLocked());
68
69         controller.unlock();
70         Assert.assertFalse(controller.isLocked());
71
72         controller.halt();
73         Assert.assertFalse(controller.isAlive());
74     }
75
76     private DroolsController createDroolsController(long courtesyStartTimeMs) throws InterruptedException {
77         DroolsController controller = new MavenDroolsController(releaseId.getGroupId(),
78             releaseId.getArtifactId(), releaseId.getVersion(), null, null);
79
80         Assert.assertFalse(controller.isAlive());
81         Assert.assertTrue(controller.isBrained());
82
83         controller.start();
84
85         Assert.assertTrue(controller.isAlive());
86         Assert.assertTrue(controller.isBrained());
87
88         Assert.assertEquals(releaseId.getGroupId(), controller.getGroupId());
89         Assert.assertEquals(releaseId.getArtifactId(), controller.getArtifactId());
90         Assert.assertEquals(releaseId.getVersion(), controller.getVersion());
91
92         Assert.assertEquals(releaseId.getGroupId(), controller.getContainer().getGroupId());
93         Assert.assertEquals(releaseId.getArtifactId(), controller.getContainer().getArtifactId());
94         Assert.assertEquals(releaseId.getVersion(), controller.getContainer().getVersion());
95
96         /* courtesy timer to allow full initialization from local maven repository */
97         Thread.sleep(courtesyStartTimeMs);
98
99         Assert.assertTrue(controller.getSessionNames().size() == 1);
100         Assert.assertEquals(JUNIT_ECHO_KSESSION, controller.getSessionNames().get(0));
101         Assert.assertTrue(controller.getCanonicalSessionNames().size() == 1);
102         Assert.assertTrue(controller.getCanonicalSessionNames().get(0).contains(JUNIT_ECHO_KSESSION));
103
104         return controller;
105     }
106 }