17
17
package com .ericsson .ei .flowtests ;
18
18
19
19
import org .apache .commons .io .FileUtils ;
20
+ import org .json .JSONArray ;
20
21
import org .junit .Before ;
21
22
import org .junit .runner .RunWith ;
22
23
import org .mockito .Mock ;
29
30
import org .springframework .test .context .junit4 .SpringJUnit4ClassRunner ;
30
31
import org .springframework .test .context .support .DependencyInjectionTestExecutionListener ;
31
32
33
+ import com .ericsson .ei .controller .model .Subscription ;
32
34
import com .ericsson .ei .erqueryservice .ERQueryService ;
33
35
import com .ericsson .ei .erqueryservice .SearchOption ;
34
36
import com .ericsson .ei .handlers .ObjectHandler ;
35
37
import com .ericsson .ei .handlers .UpStreamEventsHandler ;
38
+ import com .ericsson .ei .services .ISubscriptionService ;
36
39
import com .fasterxml .jackson .databind .JsonNode ;
37
40
import com .fasterxml .jackson .databind .ObjectMapper ;
38
41
import com .fasterxml .jackson .databind .node .ObjectNode ;
@@ -59,13 +62,17 @@ public class SingleEventAggregationTest extends FlowTestBase {
59
62
60
63
private static final String RULES_FILE_PATH = "src/test/resources/all_event_rules.json" ;
61
64
private static final String EVENTS_FILE_PATH = "src/test/resources/test_All_Events.json" ;
65
+ private static final String subscriptionJsonPath = "src/test/resources/subscription_CLME.json" ;
62
66
63
67
@ Autowired
64
68
private ObjectHandler objectHandler ;
65
69
66
70
@ Autowired
67
71
private UpStreamEventsHandler upStreamEventsHandler ;
68
72
73
+ @ Autowired
74
+ private ISubscriptionService subscriptionService ;
75
+
69
76
@ Mock
70
77
private ERQueryService erQueryService ;
71
78
@@ -86,43 +93,54 @@ public void before() {
86
93
when (erQueryService .getEventStreamDataById (anyString (), any (SearchOption .class ), anyInt (), anyInt (),
87
94
anyBoolean ())).thenReturn (null );
88
95
super .setFirstEventWaitTime (5000 );
96
+
97
+ try {
98
+ ObjectMapper mapper = new ObjectMapper ();
99
+ String readFileToString = FileUtils .readFileToString (new File (subscriptionJsonPath ), "UTF-8" );
100
+ JSONArray jsonArray = new JSONArray (readFileToString );
101
+ Subscription subscription = mapper .readValue (jsonArray .getJSONObject (0 ).toString (), Subscription .class );
102
+ boolean addSubscription = subscriptionService .addSubscription (subscription );
103
+ assertEquals (addSubscription , true );
104
+ } catch (Exception e ) {
105
+
106
+ }
89
107
}
90
108
91
109
@ Override
92
110
List <String > getEventNamesToSend () {
93
111
ArrayList <String > eventNames = new ArrayList <>();
94
- eventNames .add ("EiffelActivityCanceledEvent" );
95
- eventNames .add ("EiffelActivityStartedEvent" );
96
- eventNames .add ("EiffelActivityFinishedEvent" );
97
- eventNames .add ("EiffelActivityTriggeredEvent" );
98
- eventNames .add ("EiffelAnnouncementPublishedEvent" );
99
- eventNames .add ("EiffelArtifactCreatedEvent" );
100
- eventNames .add ("EiffelArtifactPublishedEvent" );
101
- eventNames .add ("EiffelArtifactReusedEvent" );
102
- eventNames .add ("EiffelCompositionDefinedEvent" );
112
+ // eventNames.add("EiffelActivityCanceledEvent");
113
+ // eventNames.add("EiffelActivityStartedEvent");
114
+ // eventNames.add("EiffelActivityFinishedEvent");
115
+ // eventNames.add("EiffelActivityTriggeredEvent");
116
+ // eventNames.add("EiffelAnnouncementPublishedEvent");
117
+ // eventNames.add("EiffelArtifactCreatedEvent");
118
+ // eventNames.add("EiffelArtifactPublishedEvent");
119
+ // eventNames.add("EiffelArtifactReusedEvent");
120
+ // eventNames.add("EiffelCompositionDefinedEvent");
103
121
eventNames .add ("EiffelConfidenceLevelModifiedEvent" );
104
- eventNames .add ("EiffelEnvironmentDefinedEvent" );
105
- eventNames .add ("EiffelFlowContextDefinedEvent" );
106
- eventNames .add ("EiffelIssueVerifiedEvent" );
107
- eventNames .add ("EiffelSourceChangeCreatedEvent" );
108
- eventNames .add ("EiffelSourceChangeSubmittedEvent" );
109
- eventNames .add ("EiffelTestCaseCanceledEvent" );
110
- eventNames .add ("EiffelTestCaseFinishedEvent" );
111
- eventNames .add ("EiffelTestCaseStartedEvent" );
112
- eventNames .add ("EiffelTestCaseTriggeredEvent" );
113
- eventNames .add ("EiffelTestExecutionRecipeCollectionCreatedEvent" );
114
- eventNames .add ("EiffelTestSuiteFinishedEvent" );
115
- eventNames .add ("EiffelTestSuiteStartedEvent" );
116
- eventNames .add ("EiffelArtifactDeployedEvent" );
117
- eventNames .add ("EiffelServiceAllocatedEvent" );
118
- eventNames .add ("EiffelServiceDeployedEvent" );
119
- eventNames .add ("EiffelServiceDiscontinuedEvent" );
120
- eventNames .add ("EiffelServiceReturnedEvent" );
121
- eventNames .add ("EiffelServiceStartedEvent" );
122
- eventNames .add ("EiffelServiceStoppedEvent" );
123
- eventNames .add ("EiffelAlertAcknowledgedEvent" );
124
- eventNames .add ("EiffelAlertCeasedEvent" );
125
- eventNames .add ("EiffelAlertRaisedEvent" );
122
+ // eventNames.add("EiffelEnvironmentDefinedEvent");
123
+ // eventNames.add("EiffelFlowContextDefinedEvent");
124
+ // eventNames.add("EiffelIssueVerifiedEvent");
125
+ // eventNames.add("EiffelSourceChangeCreatedEvent");
126
+ // eventNames.add("EiffelSourceChangeSubmittedEvent");
127
+ // eventNames.add("EiffelTestCaseCanceledEvent");
128
+ // eventNames.add("EiffelTestCaseFinishedEvent");
129
+ // eventNames.add("EiffelTestCaseStartedEvent");
130
+ // eventNames.add("EiffelTestCaseTriggeredEvent");
131
+ // eventNames.add("EiffelTestExecutionRecipeCollectionCreatedEvent");
132
+ // eventNames.add("EiffelTestSuiteFinishedEvent");
133
+ // eventNames.add("EiffelTestSuiteStartedEvent");
134
+ // eventNames.add("EiffelArtifactDeployedEvent");
135
+ // eventNames.add("EiffelServiceAllocatedEvent");
136
+ // eventNames.add("EiffelServiceDeployedEvent");
137
+ // eventNames.add("EiffelServiceDiscontinuedEvent");
138
+ // eventNames.add("EiffelServiceReturnedEvent");
139
+ // eventNames.add("EiffelServiceStartedEvent");
140
+ // eventNames.add("EiffelServiceStoppedEvent");
141
+ // eventNames.add("EiffelAlertAcknowledgedEvent");
142
+ // eventNames.add("EiffelAlertCeasedEvent");
143
+ // eventNames.add("EiffelAlertRaisedEvent");
126
144
127
145
return eventNames ;
128
146
}
0 commit comments