summaryrefslogtreecommitdiffstats
path: root/version.properties
blob: 70bc126ccd884afb2646a168968d2f2045d5569b (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13

# Versioning variables
# Note that these variables cannot be structured (e.g. : version.release or version.snapshot etc... )
# because they are used in Jenkins, whose plug-in doesn't support

major=1
minor=3
patch=0

base_version=${major}.${minor}.${patch}

# Release must be completed with git revision # in Jenkins
release_version=${base_version}
snapshot_version=${base_version}-SNAPSHOT
: #0000DD; font-weight: bold } /* Literal.Number.Integer */ .highlight .mo { color: #0000DD; font-weight: bold } /* Literal.Number.Oct */ .highlight .sa { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Affix */ .highlight .sb { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Backtick */ .highlight .sc { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Char */ .highlight .dl { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Delimiter */ .highlight .sd { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Doc */ .highlight .s2 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Double */ .highlight .se { color: #0044dd; background-color: #fff0f0 } /* Literal.String.Escape */ .highlight .sh { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Heredoc */ .highlight .si { color: #3333bb; background-color: #fff0f0 } /* Literal.String.Interpol */ .highlight .sx { color: #22bb22; background-color: #f0fff0 } /* Literal.String.Other */ .highlight .sr { color: #008800; background-color: #fff0ff } /* Literal.String.Regex */ .highlight .s1 { color: #dd2200; background-color: #fff0f0 } /* Literal.String.Single */ .highlight .ss { color: #aa6600; background-color: #fff0f0 } /* Literal.String.Symbol */ .highlight .bp { color: #003388 } /* Name.Builtin.Pseudo */ .highlight .fm { color: #0066bb; font-weight: bold } /* Name.Function.Magic */ .highlight .vc { color: #336699 } /* Name.Variable.Class */ .highlight .vg { color: #dd7700 } /* Name.Variable.Global */ .highlight .vi { color: #3333bb } /* Name.Variable.Instance */ .highlight .vm { color: #336699 } /* Name.Variable.Magic */ .highlight .il { color: #0000DD; font-weight: bold } /* Literal.Number.Integer.Long */ } 
/*-
 * ============LICENSE_START=======================================================
 * org.onap.dcaegen2.collectors.restconf
 * ================================================================================
 * Copyright (C) 2018-2019 Huawei. All rights reserved.
 * ================================================================================
 * 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.
 * ============LICENSE_END=========================================================
 */

package org.onap.dcae.common;

import org.glassfish.jersey.media.sse.EventListener;
import org.glassfish.jersey.media.sse.InboundEvent;
import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.onap.dcae.RestConfCollector;
import org.onap.dcae.controller.PersistentEventConnection;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class DataChangeEventListener implements EventListener {
    private static final Logger log = LoggerFactory.getLogger(DataChangeEventListener.class);
    private PersistentEventConnection conn;

    public DataChangeEventListener(PersistentEventConnection conn) {
        this.conn = conn;
    }

    @Override
    public void onEvent(InboundEvent event) {
        try {
            log.info("SSE Event is received");
            String s = event.readData();
            jsonType type = isJSONValid(s);
            if (type == jsonType.OBJECT) {
                JSONObject jsonObj = new JSONObject(s);
                EventData ev = new EventData(this.conn, jsonObj);
                log.info("SSE Event in json " + jsonObj.toString());
                RestConfCollector.handleEvents(ev);
            } else if (type == jsonType.ARRAY) {
                JSONArray jsonArr = new JSONArray(s);
                for (int j = 0; j < jsonArr.length(); j++) {
                    JSONObject jsonObj = jsonArr.getJSONObject(j);
                    EventData ev = new EventData(this.conn, jsonObj);
                    log.info("SSE Event in json " + jsonObj.toString());
                    RestConfCollector.handleEvents(ev);
                }
            } else {
                log.info("Received heart beat ");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private enum jsonType {
        OBJECT, ARRAY, NONE;
    }

    public jsonType isJSONValid(String test) {
        try {
            new JSONObject(test);
            log.info("Received a Json object");
        } catch (JSONException ex) {
            try {
                new JSONArray(test);
                return jsonType.ARRAY;
            } catch (JSONException ex1) {
                return jsonType.NONE;
            }
        }
        return jsonType.OBJECT;
    }
}