diff options
author | Herbert Eiselt <herbert.eiselt@highstreet-technologies.com> | 2019-02-11 14:54:12 +0100 |
---|---|---|
committer | Herbert Eiselt <herbert.eiselt@highstreet-technologies.com> | 2019-02-11 14:54:53 +0100 |
commit | 3d202a04b99f0e61b6ccf8b7a5610e1a15ca58e7 (patch) | |
tree | ab756cfa8de5eced886d3947423d198be8c0ce62 /sdnr/wt/odlux/core/model/src/main/java/org/onap | |
parent | 12a8c669f52c0e84d580c078cee849b25133b585 (diff) |
Add sdnr wt odlux
Add complete sdnr wireless transport app odlux core and apps
Change-Id: I5dcbfb8f3b790e3bda7c8df67bd69d81958f65e5
Issue-ID: SDNC-576
Signed-off-by: Herbert Eiselt <herbert.eiselt@highstreet-technologies.com>
Diffstat (limited to 'sdnr/wt/odlux/core/model/src/main/java/org/onap')
5 files changed, 355 insertions, 0 deletions
diff --git a/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/ClassLoaderUtilExt.java b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/ClassLoaderUtilExt.java new file mode 100644 index 000000000..08d243666 --- /dev/null +++ b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/ClassLoaderUtilExt.java @@ -0,0 +1,64 @@ +/******************************************************************************* + * ============LICENSE_START======================================================================== + * ONAP : ccsdk feature sdnr wt + * ================================================================================================= + * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. 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.ccsdk.features.sdnr.wt.odlux.model.bundles; + +import java.io.IOException; +import java.net.URL; +import java.util.Iterator; +import org.osgi.framework.Bundle; +import org.osgi.framework.FrameworkUtil; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import com.opensymphony.xwork2.util.ClassLoaderUtil; + +public class ClassLoaderUtilExt { + + final static Logger LOG = LoggerFactory.getLogger(ClassLoaderUtilExt.class); + + public static URL getResource(String resourceName, Class callingClass) { + + Iterator<URL> urls = null; + URL url = null; + try { + urls = getResources(resourceName, callingClass, true); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + if (urls != null) { + while (urls.hasNext()) { + URL u = urls.next(); + LOG.debug("found " + u.toString()); + url = u; + break; + } + } + if (url == null) { + LOG.debug("res currently not found. try to find with bundle"); + Bundle b = FrameworkUtil.getBundle(callingClass); + url = b.getEntry(resourceName); + } + return url; + } + + public static Iterator<URL> getResources(String resourceName, Class callingClass, boolean aggregate) + throws IOException { + return ClassLoaderUtil.getResources(resourceName, callingClass, aggregate); + } + +} diff --git a/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundle.java b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundle.java new file mode 100644 index 000000000..448169fad --- /dev/null +++ b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundle.java @@ -0,0 +1,184 @@ +/******************************************************************************* + * ============LICENSE_START======================================================================== + * ONAP : ccsdk feature sdnr wt + * ================================================================================================= + * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. 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.ccsdk.features.sdnr.wt.odlux.model.bundles; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.net.URL; +import java.util.ArrayList; +import java.util.List; + +/** + * At startup of each karaf bundle, each UI module creates an instance of this class via blueprint. + * Initialize method gets called at loading of bundle. + */ + +public class OdluxBundle { + + final static Logger LOG = LoggerFactory.getLogger(OdluxBundle.class); + private static final String LR = "\n"; + + private String bundleName; + private OdluxBundleLoader loader; + private int index; + + /** + * @return the index + */ + public int getIndex() { + return index; + } + + /** + * @param index the index to set + */ + public void setIndex(int index) { + this.index = index; + } + + public OdluxBundleLoader getLoader() { + return loader; + } + + public void setLoader(OdluxBundleLoader loader) { + this.loader = loader; + } + + public void setBundleName(String bundleName) { + this.bundleName = bundleName; + } + + public String getBundleName() { + return this.bundleName; + } + + public OdluxBundle() {} + + protected OdluxBundle(final OdluxBundleLoader loader, final String bundleName) { + this.loader = loader; + this.bundleName = bundleName; + } + + public void initialize() { + + LOG.info("Registering resources"); + try { + List<String> resources = this.getResourceFiles("/odlux"); + if (resources.size() > 0) { + for (String res : resources) { + LOG.debug("found res " + res); + } + } else { + String res = "/odlux/" + this.getBundleName() + ".js"; + if (this.hasResource(res)) { + LOG.debug("found res " + res); + } else + LOG.warn("no resources found in bundle"); + } + } catch (IOException e) { + LOG.debug("problem searching for resources: " + e.getMessage()); + } + if (this.loader != null) { + if (this.bundleName == null) + LOG.error("bundle name is missing. Bundle can not be registered with odlux"); + else { + LOG.info("Registering bunlde {}", this.bundleName); + this.loader.addBundle(this); + } + } + } + + public void clean() { + LOG.info("Unregistering resources"); + + if (this.loader != null) { + this.loader.removeBundle(this); + } + } + + public boolean hasResource(String filename) { + return this.getResource(filename) != null; + } + + public String getResourceFileContent(String filename) { + return this.loadFileContent(this.getResource(filename)); + } + + protected URL getResource(String filename) { + return ClassLoaderUtilExt.getResource(filename, this.getClass()); + } + + protected String loadFileContent(final URL url ) { + if (url == null) + return null; + LOG.debug("try to load res " + url.toString()); + StringBuilder sb = new StringBuilder(); + BufferedReader in; + try { + in = new BufferedReader(new InputStreamReader(url.openStream())); + + String inputLine; + while ((inputLine = in.readLine()) != null) { + sb.append(inputLine + LR); + } + in.close(); + } catch (IOException e) { + LOG.warn("could not load resfile " + url.toString() + ": " + e.getMessage()); + return null; + } + + return sb.toString(); + } + + private List<String> getResourceFiles(String path) throws IOException { + List<String> filenames = new ArrayList<>(); + + try { + + InputStream in = getResourceAsStream(path); + if (in != null) { + BufferedReader br = new BufferedReader(new InputStreamReader(in)); + if (br != null) { + String resource; + + while ((resource = br.readLine()) != null) { + filenames.add(resource); + } + } + } + } catch (Exception e) { + LOG.warn("problem loading res " + path); + } + + return filenames; + } + + private InputStream getResourceAsStream(String resource) { + final InputStream in = getContextClassLoader().getResourceAsStream(resource); + + return in == null ? getClass().getResourceAsStream(resource) : in; + } + + private ClassLoader getContextClassLoader() { + return Thread.currentThread().getContextClassLoader(); + } +} diff --git a/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleList.java b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleList.java new file mode 100644 index 000000000..c2a514399 --- /dev/null +++ b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleList.java @@ -0,0 +1,20 @@ +package org.onap.ccsdk.features.sdnr.wt.odlux.model.bundles; + +import java.util.ArrayList; +import java.util.List; + +public class OdluxBundleList extends ArrayList<OdluxBundle>{ + + /** + * + */ + private static final long serialVersionUID = 8365348398621906220L; + + public List<String> getNames(){ + final List<String> names=new ArrayList<String>(); + for(OdluxBundle b:this) + names.add(b.getBundleName()); + return names; + } + +} diff --git a/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoader.java b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoader.java new file mode 100644 index 000000000..e288ee3ec --- /dev/null +++ b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoader.java @@ -0,0 +1,25 @@ +/******************************************************************************* + * ============LICENSE_START======================================================================== + * ONAP : ccsdk feature sdnr wt + * ================================================================================================= + * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. 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.ccsdk.features.sdnr.wt.odlux.model.bundles; + +public interface OdluxBundleLoader { + + public void addBundle(OdluxBundle bundle); + + public void removeBundle(OdluxBundle bundle); +} diff --git a/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoaderImpl.java b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoaderImpl.java new file mode 100644 index 000000000..5b15be35c --- /dev/null +++ b/sdnr/wt/odlux/core/model/src/main/java/org/onap/ccsdk/features/sdnr/wt/odlux/model/bundles/OdluxBundleLoaderImpl.java @@ -0,0 +1,62 @@ +/******************************************************************************* + * ============LICENSE_START======================================================================== + * ONAP : ccsdk feature sdnr wt + * ================================================================================================= + * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. 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.ccsdk.features.sdnr.wt.odlux.model.bundles; + +import java.util.ArrayList; +import java.util.Collections; +import java.util.List; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +public class OdluxBundleLoaderImpl implements OdluxBundleLoader { + + final static Logger LOG = LoggerFactory.getLogger(OdluxBundleLoaderImpl.class); + private static OdluxBundleLoaderImpl mObj; + + public static OdluxBundleLoaderImpl getInstance() { + if (mObj == null) + mObj = new OdluxBundleLoaderImpl(); + return mObj; + } + + private final List<OdluxBundle> bundles; + + public synchronized List<OdluxBundle> getBundles() { + return this.bundles; + } + + public OdluxBundleLoaderImpl() { + this.bundles = Collections.synchronizedList(new ArrayList<OdluxBundle>()); + mObj = this; + } + + @Override + public synchronized void addBundle(OdluxBundle bundle) { + LOG.debug("odlux bundle " + bundle.getBundleName() + " added"); + this.bundles.add(bundle); + + } + + @Override + public synchronized void removeBundle(OdluxBundle bundle) { + this.bundles.remove(bundle); + LOG.debug("odlux bundle " + bundle.getBundleName() + " removed"); + + } + +} |