060434fe99091237768895f40125c20d8dd20824
[ccsdk/features.git] /
1 /*
2  * ============LICENSE_START=======================================================
3  * ONAP : ccsdk features
4  * ================================================================================
5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
6  * All rights reserved.
7  * ================================================================================
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *     http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  * ============LICENSE_END=========================================================
20  *
21  */
22 package org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.elalto;
23
24 import org.json.JSONObject;
25 import org.onap.ccsdk.features.sdnr.wt.common.database.SearchHit;
26 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.BaseSearchHitConverter;
27 import org.onap.ccsdk.features.sdnr.wt.dataprovider.setup.data.ComponentName;
28
29 /**
30  * 
31  * @author Michael Dürre
32  *
33  *  {
34  *     "faultCurrent": {
35  *     "nodeName": "sim9090",
36  *     "counter": "50443",
37  *     "timeStamp": "2017-07-27T13:33:49.0Z",
38  *     "objectId": "a2.module-1.1.5.6",
39  *     "problem": "Ais",
40  *     "severity": "Major",
41  *     "type": "ProblemNotificationXml"
42  *     }
43  * }
44  * 
45  * =>
46  * 
47  * {
48  *     "timestamp": "2017-01-01T00:00:00.0Z",
49  *     "object-id": "LP-MWS-TTP-01",
50  *     "severity": "Warning",
51  *     "counter": 2,
52  *     "node-id": "sim1",
53  *     "problem": "unknownProblem2"
54  * }
55  */
56 public class FrankfurtFaultcurrentConverter extends BaseSearchHitConverter {
57
58         /**
59          * @param name
60          */
61         public FrankfurtFaultcurrentConverter() {
62                 super(ComponentName.FAULTCURRENT);
63         }
64
65         @Override
66         public SearchHit convert(SearchHit source) {
67                 
68                 JSONObject data = new JSONObject();
69                 JSONObject src = source.getSource();
70                 JSONObject srcInner = src.getJSONObject("faultCurrent");
71                 data.put("node-id", srcInner.getString("nodeName"));
72                 data.put("severity", srcInner.getString("severity"));
73                 data.put("counter", Long.parseLong(srcInner.getString("counter")));
74                 data.put("timestamp", srcInner.getString("timeStamp"));
75                 data.put("object-id",srcInner.getString("objectId"));
76                 data.put("problem", srcInner.getString("problem"));
77                 
78                 return this.getSearchHit(source.getIndex(), source.getType(), source.getId(), data );
79         }
80 }