diff options
Diffstat (limited to 'engine-d/src/test/java/org/onap')
11 files changed, 961 insertions, 0 deletions
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/EngineDActiveAppTest.java b/engine-d/src/test/java/org/onap/holmes/engine/EngineDActiveAppTest.java new file mode 100644 index 0000000..362211b --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/EngineDActiveAppTest.java @@ -0,0 +1,27 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+package org.onap.holmes.engine;
+
+/**
+ * Created by Administrator on 2017/2/20.
+ */
+
+public class EngineDActiveAppTest {
+ public static void main(String[] args) throws Exception {
+ String filePath = "C:\\correlation-engine.yml";
+ new EngineDActiveApp().run(new String[]{"server", filePath});
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/EnginedAppConfigTest.java b/engine-d/src/test/java/org/onap/holmes/engine/EnginedAppConfigTest.java new file mode 100644 index 0000000..9642474 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/EnginedAppConfigTest.java @@ -0,0 +1,75 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine;
+
+import io.dropwizard.db.DataSourceFactory;
+import org.hamcrest.core.IsEqual;
+import org.hamcrest.core.IsNull;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.holmes.common.config.MQConfig;
+import org.powermock.api.easymock.PowerMock;
+
+public class EnginedAppConfigTest {
+
+ private EngineDAppConfig engineAppConfig;
+
+ @Before
+ public void setUp() {
+ engineAppConfig = new EngineDAppConfig();
+ }
+
+ @Test
+ public void getMqConfig() {
+ MQConfig mqConfig = PowerMock.createMock(MQConfig.class);
+ engineAppConfig.setMqConfig(mqConfig);
+ Assert.assertThat(engineAppConfig.getMqConfig(), IsNull.notNullValue());
+ }
+
+ @Test
+ public void setMqConfig() {
+ MQConfig mqConfig = PowerMock.createMock(MQConfig.class);
+ engineAppConfig.setMqConfig(mqConfig);
+ Assert.assertThat(engineAppConfig.getMqConfig(), IsEqual.equalTo(mqConfig));
+ }
+
+ @Test
+ public void getDataSourceFactory() {
+ Assert.assertThat(engineAppConfig.getDataSourceFactory(), IsNull.<DataSourceFactory>notNullValue());
+ }
+
+ @Test
+ public void setDataSourceFactory() {
+ DataSourceFactory database = new DataSourceFactory();
+ engineAppConfig.setDataSourceFactory(database);
+ Assert.assertThat(engineAppConfig.getDataSourceFactory(), IsEqual.equalTo(database));
+ }
+
+ @Test
+ public void getApidescription() {
+ final String apidescription = "Holmes rule management rest API";
+ Assert.assertThat(engineAppConfig.getApidescription(), IsEqual.equalTo(apidescription));
+ }
+
+ @Test
+ public void setApidescription() {
+ final String apidescription = "set api description";
+ engineAppConfig.setApidescription(apidescription);
+ Assert.assertThat(engineAppConfig.getApidescription(), IsEqual.equalTo(apidescription));
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/db/CorrelationRuleDaoTest.java b/engine-d/src/test/java/org/onap/holmes/engine/db/CorrelationRuleDaoTest.java new file mode 100644 index 0000000..128f58a --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/db/CorrelationRuleDaoTest.java @@ -0,0 +1,48 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.db;
+
+import org.easymock.EasyMock;
+import org.hamcrest.core.IsNull;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.holmes.common.api.entity.CorrelationRule;
+import org.powermock.api.easymock.PowerMock;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class CorrelationRuleDaoTest {
+ private CorrelationRuleDao correlationRuleDao;
+
+ @Before
+ public void setUp() {
+ correlationRuleDao = PowerMock.createMock(CorrelationRuleDao.class);
+ }
+
+ @Test
+ public void queryRuleByEnable() {
+ int enable = 0;
+ EasyMock.expect(correlationRuleDao.queryRuleByEnable(EasyMock.anyInt())).andReturn(new ArrayList<CorrelationRule>());
+ PowerMock.replayAll();
+ List<CorrelationRule> correlationRules = correlationRuleDao.queryRuleByEnable(enable);
+ PowerMock.verifyAll();
+ Assert.assertThat(correlationRules, IsNull.<List<CorrelationRule>>notNullValue());
+ }
+
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/db/mapper/CorrelationRuleMapperTest.java b/engine-d/src/test/java/org/onap/holmes/engine/db/mapper/CorrelationRuleMapperTest.java new file mode 100644 index 0000000..acf62c6 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/db/mapper/CorrelationRuleMapperTest.java @@ -0,0 +1,57 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.db.mapper;
+
+import org.junit.Test;
+import org.powermock.api.easymock.PowerMock;
+
+import java.sql.Date;
+import java.sql.ResultSet;
+import java.util.Properties;
+
+import static org.easymock.EasyMock.expect;
+
+public class CorrelationRuleMapperTest {
+
+ @Test
+ public void map() throws Exception {
+ CorrelationRuleMapper mapper = new CorrelationRuleMapper();
+ ResultSet resultSet = PowerMock.createMock(ResultSet.class);
+
+ expect(resultSet.getString("name")).andReturn("");
+ expect(resultSet.getString("rid")).andReturn("");
+ expect(resultSet.getString("description")).andReturn("");
+ expect(resultSet.getInt("enable")).andReturn(0);
+ expect(resultSet.getInt("templateID")).andReturn(0);
+ expect(resultSet.getString("engineID")).andReturn("");
+ expect(resultSet.getString("engineType")).andReturn("");
+ expect(resultSet.getString("creator")).andReturn("");
+ expect(resultSet.getDate("createTime")).andReturn(new Date(System.currentTimeMillis()));
+ expect(resultSet.getString("updator")).andReturn("");
+ expect(resultSet.getDate("updateTime")).andReturn(new Date(System.currentTimeMillis()));
+ expect(resultSet.getObject("params")).andReturn(new Properties());
+ expect(resultSet.getString("content")).andReturn("");
+ expect(resultSet.getString("vendor")).andReturn("");
+ expect(resultSet.getString("package")).andReturn("");
+
+ PowerMock.replayAll();
+
+ mapper.map(0, resultSet, null);
+
+ PowerMock.verify();
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/manager/DroolsEngineTest.java b/engine-d/src/test/java/org/onap/holmes/engine/manager/DroolsEngineTest.java new file mode 100644 index 0000000..5487177 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/manager/DroolsEngineTest.java @@ -0,0 +1,320 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.manager;
+
+import static org.easymock.EasyMock.anyBoolean;
+import static org.easymock.EasyMock.anyInt;
+import static org.easymock.EasyMock.anyObject;
+import static org.easymock.EasyMock.expect;
+
+import java.lang.reflect.Method;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Locale;
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.Destination;
+import javax.jms.JMSException;
+import javax.jms.MessageConsumer;
+import javax.jms.Session;
+import javax.jms.Topic;
+import org.apache.activemq.command.ActiveMQObjectMessage;
+import org.drools.KnowledgeBase;
+import org.drools.KnowledgeBaseConfiguration;
+import org.drools.KnowledgeBaseFactory;
+import org.drools.conf.EventProcessingOption;
+import org.drools.runtime.StatefulKnowledgeSession;
+import org.easymock.EasyMock;
+import org.glassfish.hk2.api.IterableProvider;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.onap.holmes.engine.request.DeployRuleRequest;
+import org.onap.holmes.common.api.entity.CorrelationRule;
+import org.onap.holmes.common.api.stat.Alarm;
+import org.onap.holmes.common.config.MQConfig;
+import org.onap.holmes.common.constant.AlarmConst;
+import org.onap.holmes.common.exception.CorrelationException;
+import org.onap.holmes.engine.wrapper.RuleMgtWrapper;
+import org.powermock.api.easymock.PowerMock;
+import org.powermock.modules.junit4.rule.PowerMockRule;
+import org.powermock.reflect.Whitebox;
+
+public class DroolsEngineTest {
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+
+ @Rule
+ public PowerMockRule powerMockRule = new PowerMockRule();
+
+ private RuleMgtWrapper ruleMgtWrapper;
+
+ private KnowledgeBase kbase;
+
+ private KnowledgeBaseConfiguration kconf;
+
+ private StatefulKnowledgeSession ksession;
+
+ private IterableProvider<MQConfig> mqConfigProvider;
+
+ private ConnectionFactory connectionFactory;
+
+ private DroolsEngine droolsEngine;
+
+ @Before
+ public void setUp() {
+ droolsEngine = new DroolsEngine();
+
+ this.kconf = KnowledgeBaseFactory.newKnowledgeBaseConfiguration();
+ this.kconf.setOption(EventProcessingOption.STREAM);
+ this.kconf.setProperty("drools.assertBehaviour", "equality");
+ this.kbase = KnowledgeBaseFactory.newKnowledgeBase("D-ENGINE", this.kconf);
+ this.ksession = kbase.newStatefulKnowledgeSession();
+
+ ruleMgtWrapper = PowerMock.createMock(RuleMgtWrapper.class);
+ mqConfigProvider = PowerMock.createMock(IterableProvider.class);
+ connectionFactory = PowerMock.createMock(ConnectionFactory.class);
+
+ Whitebox.setInternalState(droolsEngine, "ruleMgtWrapper", ruleMgtWrapper);
+ Whitebox.setInternalState(droolsEngine, "mqConfigProvider", mqConfigProvider);
+ Whitebox.setInternalState(droolsEngine, "kconf", kconf);
+ Whitebox.setInternalState(droolsEngine, "kbase", kbase);
+ Whitebox.setInternalState(droolsEngine, "ksession", ksession);
+ Whitebox.setInternalState(droolsEngine, "connectionFactory", connectionFactory);
+
+ PowerMock.resetAll();
+ }
+
+ @Test
+ public void init() throws Exception {
+ MQConfig mqConfig = new MQConfig();
+ mqConfig.brokerIp = "127.0.0.1";
+ mqConfig.brokerPort = 4567;
+ mqConfig.brokerUsername = "admin";
+ mqConfig.brokerPassword = "admin";
+ List<CorrelationRule> rules = new ArrayList<CorrelationRule>();
+ CorrelationRule rule = new CorrelationRule();
+ rule.setContent("content");
+ rules.add(rule);
+
+ expect(mqConfigProvider.get()).andReturn(mqConfig).anyTimes();
+ expect(ruleMgtWrapper.queryRuleByEnable(anyInt())).andReturn(rules);
+ PowerMock.replayAll();
+
+ Method method = DroolsEngine.class.getDeclaredMethod("init");
+ method.setAccessible(true);
+ method.invoke(droolsEngine);
+
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void deployRule_rule_is_null() throws CorrelationException {
+ Locale locale = PowerMock.createMock(Locale.class);
+
+ thrown.expect(NullPointerException.class);
+
+ droolsEngine.deployRule(null, locale);
+ }
+
+ @Test
+ public void deployRule_kbuilder_has_errors() throws CorrelationException {
+ DeployRuleRequest rule = new DeployRuleRequest();
+ rule.setContent("rule123");
+ Locale locale = new Locale(AlarmConst.I18N_EN);
+
+ thrown.expect(CorrelationException.class);
+
+ droolsEngine.deployRule(rule, locale);
+ }
+
+ @Test
+ public void deployRule_package_name_repeat() throws CorrelationException {
+ DeployRuleRequest rule = new DeployRuleRequest();
+ rule.setContent("package rule123");
+ Locale locale = new Locale(AlarmConst.I18N_EN);
+
+ thrown.expect(CorrelationException.class);
+
+ droolsEngine.deployRule(rule, locale);
+ droolsEngine.deployRule(rule, locale);
+ }
+
+ @Test
+ public void undeployRule_package_name_is_null() throws CorrelationException {
+ String packageName = null;
+ Locale locale = new Locale(AlarmConst.I18N_EN);
+
+ thrown.expect(CorrelationException.class);
+
+ droolsEngine.undeployRule(packageName, locale);
+ }
+
+ @Test
+ public void undeployRule_normal() throws CorrelationException {
+ Locale locale = new Locale(AlarmConst.I18N_EN);
+
+ DeployRuleRequest rule = new DeployRuleRequest();
+ rule.setContent("package rule123");
+ droolsEngine.deployRule(rule, locale);
+
+ String packageName = "rule123";
+
+ droolsEngine.undeployRule(packageName, locale);
+ }
+
+ @Test
+ public void compileRule_kbuilder_has_errors() throws CorrelationException {
+ String content = "have error content";
+ Locale locale = new Locale(AlarmConst.I18N_EN);
+
+ thrown.expect(CorrelationException.class);
+
+ droolsEngine.compileRule(content, locale);
+ }
+
+
+ @Test
+ public void putRaisedIntoStream_facthandle_is_null() {
+ Alarm raiseAlarm = new Alarm();
+ droolsEngine.putRaisedIntoStream(raiseAlarm);
+ droolsEngine.putRaisedIntoStream(raiseAlarm);
+ }
+
+ @Test
+ public void putRaisedIntoStream_factHandle_is_not_null() {
+ droolsEngine.putRaisedIntoStream(new Alarm());
+ }
+
+
+ @Test
+ public void listener_receive() throws JMSException {
+ DroolsEngine.AlarmMqMessageListener listener = droolsEngine.new AlarmMqMessageListener();
+
+ Connection connection = PowerMock.createMock(Connection.class);
+ Session session = PowerMock.createMock(Session.class);
+ Destination destination = PowerMock.createMock(Topic.class);
+ MessageConsumer consumer = PowerMock.createMock(MessageConsumer.class);
+
+ Whitebox.setInternalState(listener, "connection", connection);
+ Whitebox.setInternalState(listener, "session", session);
+ Whitebox.setInternalState(listener, "destination", destination);
+ Whitebox.setInternalState(listener, "consumer", consumer);
+
+ PowerMock.reset();
+
+ expect(connectionFactory.createConnection()).andReturn(connection);
+ connection.start();
+ expect(connection.createSession(anyBoolean(), anyInt())).andReturn(session);
+ expect(session.createTopic(anyObject(String.class))).andReturn((Topic) destination);
+ expect(session.createConsumer(anyObject(Destination.class))).andReturn(consumer);
+ consumer.setMessageListener(listener);
+
+ PowerMock.replayAll();
+
+ listener.receive();
+
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void listener_exception() throws JMSException {
+ DroolsEngine.AlarmMqMessageListener listener = droolsEngine.new AlarmMqMessageListener();
+
+ Connection connection = PowerMock.createMock(Connection.class);
+ Session session = PowerMock.createMock(Session.class);
+ Destination destination = PowerMock.createMock(Topic.class);
+ MessageConsumer consumer = PowerMock.createMock(MessageConsumer.class);
+
+ Whitebox.setInternalState(listener, "connection", connection);
+ Whitebox.setInternalState(listener, "session", session);
+ Whitebox.setInternalState(listener, "destination", destination);
+ Whitebox.setInternalState(listener, "consumer", consumer);
+
+ PowerMock.reset();
+
+ expect(connectionFactory.createConnection()).andReturn(connection);
+ connection.start();
+ expect(connection.createSession(anyBoolean(), anyInt())).andReturn(session);
+ expect(session.createTopic(anyObject(String.class))).andReturn((Topic) destination);
+ expect(session.createConsumer(anyObject(Destination.class))).andReturn(consumer);
+ consumer.setMessageListener(listener);
+ EasyMock.expectLastCall().andThrow(new JMSException(""));
+
+ consumer.close();
+ session.close();
+ connection.close();
+
+ PowerMock.replayAll();
+
+ listener.receive();
+
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void listener_close_exception() throws JMSException {
+ DroolsEngine.AlarmMqMessageListener listener = droolsEngine.new AlarmMqMessageListener();
+
+ Connection connection = PowerMock.createMock(Connection.class);
+ Session session = PowerMock.createMock(Session.class);
+ Destination destination = PowerMock.createMock(Topic.class);
+ MessageConsumer consumer = PowerMock.createMock(MessageConsumer.class);
+
+ Whitebox.setInternalState(listener, "connection", connection);
+ Whitebox.setInternalState(listener, "session", session);
+ Whitebox.setInternalState(listener, "destination", destination);
+ Whitebox.setInternalState(listener, "consumer", consumer);
+
+ PowerMock.reset();
+
+ expect(connectionFactory.createConnection()).andReturn(connection);
+ connection.start();
+ expect(connection.createSession(anyBoolean(), anyInt())).andReturn(session);
+ expect(session.createTopic(anyObject(String.class))).andReturn((Topic) destination);
+ expect(session.createConsumer(anyObject(Destination.class))).andReturn(consumer);
+ consumer.setMessageListener(listener);
+ EasyMock.expectLastCall().andThrow(new JMSException(""));
+
+ consumer.close();
+ EasyMock.expectLastCall().andThrow(new JMSException(""));
+
+ PowerMock.replayAll();
+
+ listener.receive();
+
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void listener_on_message() throws JMSException {
+ DroolsEngine.AlarmMqMessageListener listener = droolsEngine.new AlarmMqMessageListener();
+ Alarm alarm = new Alarm();
+ alarm.setAlarmKey("alarmKey");
+ ActiveMQObjectMessage objectMessage = new ActiveMQObjectMessage();
+ objectMessage.setObject(alarm);
+
+ listener.onMessage(objectMessage);
+ }
+
+ @Test
+ public void stop() throws Exception {
+ droolsEngine.stop();
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/request/CompileRuleRequestTest.java b/engine-d/src/test/java/org/onap/holmes/engine/request/CompileRuleRequestTest.java new file mode 100644 index 0000000..3c938fd --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/request/CompileRuleRequestTest.java @@ -0,0 +1,32 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.request;
+
+import org.junit.Test;
+
+import static org.hamcrest.core.IsEqual.equalTo;
+import static org.junit.Assert.assertThat;
+
+public class CompileRuleRequestTest {
+ @Test
+ public void getterAndSetter4Content(){
+ final String content = "content";
+ CompileRuleRequest request = new CompileRuleRequest();
+ request.setContent(content);
+ assertThat(request.getContent(), equalTo(content));
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/request/DeployRuleRequestTest.java b/engine-d/src/test/java/org/onap/holmes/engine/request/DeployRuleRequestTest.java new file mode 100644 index 0000000..8170668 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/request/DeployRuleRequestTest.java @@ -0,0 +1,40 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.request;
+
+import org.junit.Test;
+
+import static org.hamcrest.core.IsEqual.equalTo;
+import static org.junit.Assert.assertThat;
+
+public class DeployRuleRequestTest {
+ @Test
+ public void getterAndSetter4Content(){
+ final String content = "content";
+ DeployRuleRequest request = new DeployRuleRequest();
+ request.setContent(content);
+ assertThat(request.getContent(), equalTo(content));
+ }
+
+ @Test
+ public void getterAndSetter4Engineid(){
+ final String engineid = "engineid";
+ DeployRuleRequest request = new DeployRuleRequest();
+ request.setEngineId(engineid);
+ assertThat(request.getEngineId(), equalTo(engineid));
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/resources/EngineResourcesTest.java b/engine-d/src/test/java/org/onap/holmes/engine/resources/EngineResourcesTest.java new file mode 100644 index 0000000..3c68182 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/resources/EngineResourcesTest.java @@ -0,0 +1,132 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.resources;
+
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.onap.holmes.common.exception.CorrelationException;
+import org.onap.holmes.engine.manager.DroolsEngine;
+import org.onap.holmes.engine.request.CompileRuleRequest;
+import org.onap.holmes.engine.request.DeployRuleRequest;
+import org.powermock.api.easymock.PowerMock;
+import org.powermock.reflect.Whitebox;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.ws.rs.WebApplicationException;
+import java.util.Locale;
+
+import static org.easymock.EasyMock.*;
+
+public class EngineResourcesTest {
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+ DroolsEngine droolsEngine;
+ private EngineResources engineResources;
+
+ @Before
+ public void setUp() {
+ droolsEngine = PowerMock.createMock(DroolsEngine.class);
+ engineResources = new EngineResources();
+
+ Whitebox.setInternalState(engineResources,"droolsEngine",droolsEngine);
+ PowerMock.resetAll();
+ }
+
+ @Test
+ public void deployRule_exception() throws CorrelationException {
+ DeployRuleRequest deployRuleRequest = new DeployRuleRequest();
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ thrown.expect(WebApplicationException.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ expect(droolsEngine.deployRule(anyObject(DeployRuleRequest.class), anyObject(Locale.class))).
+ andThrow(new CorrelationException(""));
+ PowerMock.replayAll();
+ engineResources.deployRule(deployRuleRequest, httpRequest);
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void deployRule_normal() throws CorrelationException {
+ DeployRuleRequest deployRuleRequest = new DeployRuleRequest();
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ expect(droolsEngine.deployRule(anyObject(DeployRuleRequest.class),
+ anyObject(Locale.class))).andReturn("packageName");
+ PowerMock.replayAll();
+ engineResources.deployRule(deployRuleRequest, httpRequest);
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void undeployRule_exception() throws CorrelationException {
+ String packageName = "packageName";
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ thrown.expect(WebApplicationException.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ droolsEngine.undeployRule(anyObject(String.class), anyObject(Locale.class));
+ expectLastCall().andThrow(new CorrelationException(""));
+ PowerMock.replayAll();
+ engineResources.undeployRule(packageName, httpRequest);
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void undeployRule_normal() throws CorrelationException {
+ String packageName = "packageName";
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ droolsEngine.undeployRule(anyObject(String.class), anyObject(Locale.class));
+ PowerMock.replayAll();
+ engineResources.undeployRule(packageName, httpRequest);
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void compileRule_exception() throws CorrelationException {
+ CompileRuleRequest compileRuleRequest = new CompileRuleRequest();
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ thrown.expect(WebApplicationException.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ droolsEngine.compileRule(anyObject(String.class),anyObject(Locale.class));
+ expectLastCall().andThrow(new CorrelationException(""));
+ PowerMock.replayAll();
+ engineResources.compileRule(compileRuleRequest, httpRequest);
+ PowerMock.verifyAll();
+ }
+
+ @Test
+ public void compileRule_normal() throws CorrelationException {
+ CompileRuleRequest compileRuleRequest = new CompileRuleRequest();
+ HttpServletRequest httpRequest = PowerMock.createMock(HttpServletRequest.class);
+
+ expect(httpRequest.getHeader("language-option")).andReturn("en_US");
+ droolsEngine.compileRule(anyObject(String.class),anyObject(Locale.class));
+ PowerMock.replayAll();
+ engineResources.compileRule(compileRuleRequest, httpRequest);
+ PowerMock.verifyAll();
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/response/CorrelationRuleResponseTest.java b/engine-d/src/test/java/org/onap/holmes/engine/response/CorrelationRuleResponseTest.java new file mode 100644 index 0000000..85659f2 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/response/CorrelationRuleResponseTest.java @@ -0,0 +1,32 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.response;
+
+import org.junit.Test;
+
+import static org.hamcrest.core.IsEqual.equalTo;
+import static org.junit.Assert.assertThat;
+
+public class CorrelationRuleResponseTest {
+ @Test
+ public void getterAndSetter4RuleId(){
+ final String packageName = "package";
+ CorrelationRuleResponse request = new CorrelationRuleResponse();
+ request.setPackageName(packageName);
+ assertThat(request.getPackageName(), equalTo(packageName));
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/utils/AlarmUtilTest.java b/engine-d/src/test/java/org/onap/holmes/engine/utils/AlarmUtilTest.java new file mode 100644 index 0000000..97330a7 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/utils/AlarmUtilTest.java @@ -0,0 +1,136 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.utils;
+
+import org.hamcrest.core.IsEqual;
+import org.hamcrest.core.IsNull;
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.onap.holmes.common.api.stat.Alarm;
+import org.onap.holmes.common.producer.MQProducer;
+import org.powermock.api.easymock.PowerMock;
+import org.powermock.reflect.Whitebox;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class AlarmUtilTest {
+ private AlarmUtil alarmUtil;
+ private final Map<String, Map<String, Integer>> rootPriorityMap = new HashMap<String, Map<String, Integer>>();
+ private final Map<String, String> saveRuleMsg = new HashMap<String, String>();
+
+ @Before
+ public void setUp() {
+ alarmUtil = AlarmUtil.getInstance();
+ Whitebox.setInternalState(alarmUtil,"rootPriorityMap",rootPriorityMap);
+ Whitebox.setInternalState(alarmUtil,"saveRuleMsg",saveRuleMsg);
+ PowerMock.resetAll();
+ }
+
+ @Test
+ public void getInstance() {
+ AlarmUtil instance = AlarmUtil.getInstance();
+ Assert.assertThat(instance,IsNull.<AlarmUtil>notNullValue());
+ }
+
+ @Test
+ public void equipTypeFilter_is_nullstr() {
+ String probableCauseStr = "null";
+ String equipType = "equipType";
+ Alarm alarm = new Alarm();
+ boolean filter = alarmUtil.equipTypeFilter(probableCauseStr, equipType, alarm);
+ Assert.assertThat(filter, IsEqual.equalTo(true));
+ }
+
+ @Test
+ public void equipTypeFilter_equals_alarm() {
+ String probableCauseStr = "11,4567";
+ String equipType = "ee,equipType";
+ Alarm alarm = new Alarm();
+ alarm.setProbableCause(4567);
+ alarm.setEquipType("equipType");
+ boolean filter = alarmUtil.equipTypeFilter(probableCauseStr, equipType, alarm);
+ Assert.assertThat(filter, IsEqual.equalTo(true));
+ }
+
+ @Test
+ public void equipTypeFilter_not_equals_alarm() {
+ String probableCauseStr = "11,45";
+ String equipType = "ee,equipType";
+ Alarm alarm = new Alarm();
+ alarm.setProbableCause(4567);
+ alarm.setEquipType("equipType");
+ boolean filter = alarmUtil.equipTypeFilter(probableCauseStr, equipType, alarm);
+ Assert.assertThat(filter, IsEqual.equalTo(false));
+ }
+
+ @Test
+ public void getPriority_rootprioritymap_containskey_ruleid() {
+ String ruleId = "1";
+ String probableCauseStr = "11,4567";
+ String rootAlarmFeatureStr = "0,1";
+ String equipTypeStr = "ee,equipType";
+ Alarm alarm = new Alarm();
+
+ Map<String, Integer> map = new HashMap<String, Integer>();
+ map.put("11-ee", 0);
+ map.put("4567-equipType", 1);
+ rootPriorityMap.put(ruleId, map);
+
+ saveRuleMsg.put(ruleId, "11ee0");
+
+ Integer priority = alarmUtil.getPriority(ruleId, probableCauseStr, rootAlarmFeatureStr, equipTypeStr, alarm);
+ Assert.assertThat(priority,IsEqual.equalTo(0));
+ }
+
+ @Test
+ public void getPriority_rootprioritymap_not_containskey_ruleid() {
+ String ruleId = "1";
+ String probableCauseStr = "11,4567";
+ String rootAlarmFeatureStr = "0,1";
+ String equipTypeStr = "ee,equipType";
+ Alarm alarm = new Alarm();
+
+ saveRuleMsg.put(ruleId, "11ee0");
+
+ Integer priority = alarmUtil.getPriority(ruleId, probableCauseStr, rootAlarmFeatureStr, equipTypeStr, alarm);
+ Assert.assertThat(priority,IsEqual.equalTo(0));
+ }
+
+ @Test
+ public void getPriority_priority_is_not_null() {
+ String ruleId = "1";
+ String probableCauseStr = "11,4567";
+ String rootAlarmFeatureStr = "1,1";
+ String equipTypeStr = "ee,equipType";
+ Alarm alarm = new Alarm();
+ alarm.setProbableCause(11);
+ alarm.setEquipType("ee");
+
+ saveRuleMsg.put(ruleId, "11ee0");
+
+ Integer priority = alarmUtil.getPriority(ruleId, probableCauseStr, rootAlarmFeatureStr, equipTypeStr, alarm);
+ Assert.assertThat(priority,IsEqual.equalTo(1));
+ }
+
+ @Test
+ public void getMqProducer() {
+ MQProducer mqProducer = alarmUtil.getMqProducer();
+ Assert.assertThat(mqProducer, IsNull.<MQProducer>notNullValue());
+ }
+}
diff --git a/engine-d/src/test/java/org/onap/holmes/engine/wrapper/RuleMgtWrapperTest.java b/engine-d/src/test/java/org/onap/holmes/engine/wrapper/RuleMgtWrapperTest.java new file mode 100644 index 0000000..cd7aff4 --- /dev/null +++ b/engine-d/src/test/java/org/onap/holmes/engine/wrapper/RuleMgtWrapperTest.java @@ -0,0 +1,62 @@ +/**
+ * Copyright 2017 ZTE Corporation.
+ *
+ * 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.
+ */
+
+package org.onap.holmes.engine.wrapper;
+
+import static org.easymock.EasyMock.anyInt;
+import static org.easymock.EasyMock.anyObject;
+import static org.easymock.EasyMock.expect;
+
+import java.util.ArrayList;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+import org.onap.holmes.common.api.entity.CorrelationRule;
+import org.onap.holmes.common.exception.CorrelationException;
+import org.onap.holmes.common.utils.DbDaoUtil;
+import org.onap.holmes.engine.db.CorrelationRuleDao;
+import org.powermock.api.easymock.PowerMock;
+import org.powermock.reflect.Whitebox;
+
+public class RuleMgtWrapperTest {
+
+ @Rule
+ public ExpectedException thrown = ExpectedException.none();
+ private DbDaoUtil daoUtil;
+ private RuleMgtWrapper ruleMgtWrapper;
+
+ @Before
+ public void setUp() {
+ daoUtil = PowerMock.createMock(DbDaoUtil.class);
+ ruleMgtWrapper = new RuleMgtWrapper();
+
+ Whitebox.setInternalState(ruleMgtWrapper, "daoUtil", daoUtil);
+ PowerMock.resetAll();
+ }
+
+ @Test
+ public void queryRuleByEnable_normal() throws CorrelationException {
+ int enable = 3;
+
+ CorrelationRuleDao correlationRuleDao = PowerMock.createMock(CorrelationRuleDao.class);
+ expect(daoUtil.getJdbiDaoByOnDemand(anyObject(Class.class))).andReturn(correlationRuleDao);
+ expect(correlationRuleDao.queryRuleByRuleEnable(anyInt())).andReturn(new ArrayList<CorrelationRule>());
+ PowerMock.replayAll();
+ ruleMgtWrapper.queryRuleByEnable(enable);
+ PowerMock.verifyAll();
+ }
+}
|