-
Notifications
You must be signed in to change notification settings - Fork 39
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
HWKALERTS-99 Fix EventCondition deserialization
Add additional end-to-end tests
- Loading branch information
1 parent
2773f8a
commit 16b51c6
Showing
6 changed files
with
317 additions
and
0 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
256 changes: 256 additions & 0 deletions
256
...ar-alerts-rest-tests/src/test/groovy/org/hawkular/alerts/rest/EventsLifecycleITest.groovy
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,256 @@ | ||
| /* | ||
| * Copyright 2015 Red Hat, Inc. and/or its affiliates | ||
| * and other contributors as indicated by the @author tags. | ||
| * | ||
| * 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.hawkular.alerts.rest | ||
|
|
||
| import org.hawkular.alerts.api.model.condition.Condition | ||
| import org.hawkular.alerts.api.model.condition.EventCondition | ||
| import org.hawkular.alerts.api.model.event.EventCategory | ||
| import org.hawkular.alerts.api.model.event.EventType | ||
| import org.hawkular.alerts.api.model.trigger.Trigger | ||
| import org.junit.FixMethodOrder | ||
| import org.junit.Test | ||
|
|
||
| import static org.junit.Assert.assertEquals | ||
| import static org.junit.Assert.assertTrue | ||
| import static org.junit.runners.MethodSorters.NAME_ASCENDING | ||
|
|
||
| /** | ||
| * Events lifecycle end-to-end tests. | ||
| * | ||
| * @author Jay Shaughnessy | ||
| * @author Lucas Ponce | ||
| */ | ||
| @FixMethodOrder(NAME_ASCENDING) | ||
| class EventsLifecycleITest extends AbstractITestBase { | ||
|
|
||
| static host = System.getProperty('hawkular.host') ?: '127.0.0.1' | ||
| static port = Integer.valueOf(System.getProperty('hawkular.port') ?: "8080") | ||
|
|
||
| @Test | ||
| void t01_eventsBasicTest() { | ||
| println( "Running t01_eventsBasicTest" ) | ||
|
|
||
| String start = String.valueOf(System.currentTimeMillis()) | ||
|
|
||
| // Clean previous tests | ||
| def resp = client.delete(path: "triggers/test-events-t01") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| // Trigger to fire alerts | ||
| Trigger t01 = new Trigger("test-events-t01", "Basic trigger for Events tests"); | ||
|
|
||
| resp = client.post(path: "triggers", body: t01) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Add a condition over events | ||
| EventCondition firingCond = new EventCondition("test-events-t01", "test-app.war"); | ||
| Collection<Condition> conditions = new ArrayList<>(1); | ||
| conditions.add( firingCond ); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t01/conditions/firing", body: conditions) | ||
| assertEquals(200, resp.status) | ||
| assertEquals(1, resp.data.size()) | ||
|
|
||
| // Enable trigger | ||
| t01.setEnabled(true); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t01/", body: t01) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| String jsonEvent = "{" + | ||
| "\"id\":\"" + UUID.randomUUID().toString() + "\"," + | ||
| "\"ctime\":" + System.currentTimeMillis() + "," + | ||
| "\"category\":\"" + EventCategory.DEPLOYMENT.toString() + "\"," + | ||
| "\"dataId\":\"test-app.war\"" + | ||
| "}"; | ||
|
|
||
| resp = client.post(path: "events", body: jsonEvent); | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // The alert processing happens async, so give it a little time before failing... | ||
| for ( int i=0; i < 100; ++i ) { | ||
| Thread.sleep(100); | ||
|
|
||
| // FETCH recent alerts for trigger, there should be 1 | ||
| resp = client.get(path: "", query: [startTime:start,triggerIds:"test-events-t01"] ) | ||
| if ( resp.status == 200 && resp.data != null && resp.data.size > 0) { | ||
| if ( i > 50 ) { | ||
| println( "Perf: passing but sleep iterations high [" + i + "]" ); | ||
| } | ||
| break; | ||
| } | ||
| assertEquals(200, resp.status) | ||
| } | ||
| assertEquals(200, resp.status) | ||
| assertEquals(1, resp.data.size()) | ||
|
|
||
| } | ||
|
|
||
| @Test | ||
| void t02_eventsChainedTest() { | ||
| println( "Running t02_eventsChainedTest" ) | ||
|
|
||
| String start = String.valueOf(System.currentTimeMillis()) | ||
|
|
||
| // Clean previous tests | ||
| def resp = client.delete(path: "triggers/test-events-t02-app1") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| resp = client.delete(path: "triggers/test-events-t02-app2") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| resp = client.delete(path: "triggers/test-events-t02-combined") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| // Triggers to fire events | ||
| Trigger t02app1 = new Trigger("test-events-t02-app1", "Check if app1 is down"); | ||
| t02app1.setEventType(EventType.EVENT); | ||
|
|
||
| resp = client.post(path: "triggers", body: t02app1) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Add a condition over events | ||
| EventCondition firingCond1 = new EventCondition("test-events-t02-app1", "app1.war", "text == 'DOWN'"); | ||
| Collection<Condition> conditions1 = new ArrayList<>(1); | ||
| conditions1.add( firingCond1 ); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-app1/conditions/firing", body: conditions1) | ||
| assertEquals(200, resp.status) | ||
| assertEquals(1, resp.data.size()) | ||
|
|
||
| // Enable trigger | ||
| t02app1.setEnabled(true); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-app1", body: t02app1) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Triggers to fire events | ||
| Trigger t02app2 = new Trigger("test-events-t02-app2", "Check if app2 is down"); | ||
| t02app2.setEventType(EventType.EVENT); | ||
|
|
||
| resp = client.post(path: "triggers", body: t02app2) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Add a condition over events | ||
| EventCondition firingCond2 = new EventCondition("test-events-t02-app2", "app2.war", "text == 'DOWN'"); | ||
| Collection<Condition> conditions2 = new ArrayList<>(1); | ||
| conditions2.add( firingCond2 ); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-app2/conditions/firing", body: conditions2) | ||
| assertEquals(200, resp.status) | ||
| assertEquals(1, resp.data.size()) | ||
|
|
||
| // Enable trigger | ||
| t02app2.setEnabled(true); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-app2", body: t02app2) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Trigger to fire alerts | ||
| Trigger t02combined = new Trigger("test-events-t02-combined", "App1 and App2 are down"); | ||
|
|
||
| resp = client.post(path: "triggers", body: t02combined) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // Add a condition over events | ||
| EventCondition firingCond3 = new EventCondition("test-events-t02-combined", "test-events-t02-app1"); | ||
| EventCondition firingCond4 = new EventCondition("test-events-t02-combined", "test-events-t02-app2"); | ||
|
|
||
| Collection<Condition> conditions3 = new ArrayList<>(2); | ||
| conditions3.add( firingCond3 ); | ||
| conditions3.add( firingCond4 ); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-combined/conditions/firing", body: conditions3) | ||
| assertEquals(200, resp.status) | ||
| assertEquals(2, resp.data.size()) | ||
|
|
||
| // Enable trigger | ||
| t02combined.setEnabled(true); | ||
|
|
||
| resp = client.put(path: "triggers/test-events-t02-combined/", body: t02combined) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| String jsonEventApp1Down = "{" + | ||
| "\"id\":\"" + UUID.randomUUID().toString() + "\"," + | ||
| "\"ctime\":" + System.currentTimeMillis() + "," + | ||
| "\"category\":\"" + EventCategory.DEPLOYMENT.toString() + "\"," + | ||
| "\"dataId\":\"app1.war\"," + | ||
| "\"text\":\"DOWN\"" + | ||
| "}"; | ||
|
|
||
| resp = client.post(path: "events", body: jsonEventApp1Down); | ||
| assertEquals(200, resp.status) | ||
|
|
||
| String jsonEventApp2Down = "{" + | ||
| "\"id\":\"" + UUID.randomUUID().toString() + "\"," + | ||
| "\"ctime\":" + System.currentTimeMillis() + "," + | ||
| "\"category\":\"" + EventCategory.DEPLOYMENT.toString() + "\"," + | ||
| "\"dataId\":\"app2.war\"," + | ||
| "\"text\":\"DOWN\"" + | ||
| "}"; | ||
|
|
||
| resp = client.post(path: "events", body: jsonEventApp2Down); | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // The alert processing happens async, so give it a little time before failing... | ||
| for ( int i=0; i < 100; ++i ) { | ||
| Thread.sleep(100); | ||
|
|
||
| // FETCH recent alerts for trigger, there should be 1 | ||
| resp = client.get(path: "", query: [startTime:start,triggerIds:"test-events-t02-combined"] ) | ||
| if ( resp.status == 200 && resp.data != null && resp.data.size > 0) { | ||
| if ( i > 50 ) { | ||
| println( "Perf: passing but sleep iterations high [" + i + "]" ); | ||
| } | ||
| break; | ||
| } | ||
| assertEquals(200, resp.status) | ||
| } | ||
| assertEquals(200, resp.status) | ||
| assertEquals(1, resp.data.size()) | ||
| } | ||
|
|
||
| @Test | ||
| void t100_eventsCleanup() { | ||
| println("Running t100_eventsCleanup") | ||
|
|
||
| // clean up triggers | ||
| def resp = client.delete(path: "triggers/test-events-t01") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| resp = client.delete(path: "triggers/test-events-t02-app1") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| resp = client.delete(path: "triggers/test-events-t02-app2") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| resp = client.delete(path: "triggers/test-events-t02-combined") | ||
| assert(200 == resp.status || 404 == resp.status) | ||
|
|
||
| // clean up alerts | ||
| resp = client.put(path: "delete", query: [triggerIds:"test-events-t01"]) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| resp = client.put(path: "delete", query: [triggerIds:"test-events-t02-combined"]) | ||
| assertEquals(200, resp.status) | ||
|
|
||
| // clean up events | ||
| resp = client.put(path: "events/delete", query: [categories:"DEPLOYMENT"] ) | ||
| assertEquals(200, resp.status) | ||
| } | ||
|
|
||
| } |
Oops, something went wrong.