sigil/org.cauldron.bld.core/src/org/cauldron/bld/core/internal/model/eclipse/SigilBundle.java - onos-felix - Gitiles

 /*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
  * regarding copyright ownership.  The ASF licenses this file
  * to you 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.cauldron.bld.core.internal.model.eclipse;

 import java.io.File;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.InterruptedIOException;
 import java.io.OutputStream;
 import java.net.HttpURLConnection;
 import java.net.URI;
 import java.net.URL;
 import java.net.URLConnection;
 import java.util.HashSet;
 import java.util.Set;

 import org.cauldron.bld.core.BldCore;
 import org.cauldron.sigil.model.AbstractCompoundModelElement;
 import org.cauldron.sigil.model.eclipse.IDownloadJar;
 import org.cauldron.sigil.model.eclipse.ISCAComposite;
 import org.cauldron.sigil.model.eclipse.ISigilBundle;
 import org.cauldron.sigil.model.osgi.IBundleModelElement;
 import org.cauldron.sigil.model.osgi.IPackageExport;
 import org.cauldron.sigil.model.osgi.IPackageImport;
 import org.eclipse.core.runtime.IPath;
 import org.eclipse.core.runtime.IProgressMonitor;
 import org.eclipse.core.runtime.SubMonitor;
 import org.osgi.framework.Version;

 /**
  * @author dave
  *
  */
 public class SigilBundle extends AbstractCompoundModelElement implements ISigilBundle {

 	private static final long serialVersionUID = 1L;

     private IBundleModelElement bundle;
     private IDownloadJar download;
     private Set<IPath> sourcePaths;
     private Set<IPath> libraryPaths;
     private Set<ISCAComposite> composites;
     private Set<String> classpath;
     private Set<String> packages;
     private Set<String> dlPackages;
     private IPath location;

 	private IPath sourcePathLocation;
 	private IPath licencePathLocation;
 	private IPath sourceRootPath;
 	private String bundleHost;

     public SigilBundle() {
     	super( "Sigil Bundle" );
         sourcePaths = new HashSet<IPath>();
         libraryPaths = new HashSet<IPath>();
         composites = new HashSet<ISCAComposite>();
         classpath = new HashSet<String>();
         packages = new HashSet<String>();
         dlPackages = new HashSet<String>();
     }

     public void synchronize(IProgressMonitor monitor) throws IOException {
     	SubMonitor progress = SubMonitor.convert(monitor, 100);
     	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " binary" );
     	sync(location, bundle.getUpdateLocation(), progress.newChild(45));

     	try {
         	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " source" );
 			sync(sourcePathLocation, bundle.getSourceLocation(), progress.newChild(45));
 		} catch (IOException e) {
 			BldCore.error( "Failed to download source for " + bundle.getSymbolicName() + " " + bundle.getVersion(), e.getCause() );
 		}

     	try {
         	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " licence" );
 			sync(licencePathLocation, bundle.getLicenseURI(), progress.newChild(10));
 		} catch (IOException e) {
 			BldCore.error( "Failed to download licence for " + bundle.getSymbolicName() + " " + bundle.getVersion(), e.getCause() );
 		}
 	}

 	public boolean isSynchronized() {
 		return location == null || location.toFile().exists();
 	}

 	private static void sync(IPath local, URI remote, IProgressMonitor monitor) throws IOException {
 		try {
 	    	if ( local != null && !local.toFile().exists() ) {
 	    		if ( remote != null ) {
 	    			URL url = remote.toURL();
 	    			URLConnection connection = url.openConnection();
 	    			int contentLength = connection.getContentLength();

 	    			monitor.beginTask("Downloading from " + url.getHost(), contentLength);

 	    			InputStream in = null;
 	    			OutputStream out = null;
 	    			try {
 	    				URLConnection conn = url.openConnection();
 	    				if ( conn instanceof HttpURLConnection ) {
 	    					HttpURLConnection http = (HttpURLConnection) conn;
 	    					http.setConnectTimeout(10000);
 	    					http.setReadTimeout(5000);
 	    				}
 	    				in = conn.getInputStream();
 	    				File f = local.toFile();
 	    				f.getParentFile().mkdirs();
 	    				out = new FileOutputStream( f );
 	    				stream( in, out, monitor );
 	    			}
 	    			finally {
 	    				if ( in != null ) {
 	    					in.close();
 	    				}
 	    				if ( out != null ) {
 	    					out.close();
 	    				}
 	    				monitor.done();
 	    			}
 	    		}
 	    	}
 		}
 		catch (IOException e) {
 			local.toFile().delete();
 			throw e;
 		}
 	}

 	private static void stream(InputStream in, OutputStream out, IProgressMonitor monitor) throws IOException {
 		byte[] b = new byte[1024];
 		for ( ;; ) {
 			if ( monitor.isCanceled() ) {
 				throw new InterruptedIOException( "User canceled download" );
 			}
 			int r = in.read( b );
 			if ( r == -1 ) break;
 			out.write(b, 0, r);
 			monitor.worked(r);
 		}

 		out.flush();
 	}

     public IBundleModelElement getBundleInfo() {
         return bundle;
     }

     public void setBundleInfo(IBundleModelElement bundle) {
     	if ( bundle == null ) {
     		if (this.bundle != null) {
     			this.bundle.setParent(null);
     		}
     	}
     	else {
     		bundle.setParent(this);
     	}
         this.bundle = bundle;
     }

     public IDownloadJar getDownloadJar() {
     	return download;
     }

     public void setDownloadJar(IDownloadJar download) {
     	this.download = download;
     }

     public void addLibraryPath( IPath path ) {
         libraryPaths.add( path );
     }

     public void removeLibraryPath( IPath path ) {
         libraryPaths.remove( path );
     }

     public Set<IPath> getLibraryPaths() {
         return libraryPaths;
     }

     public void addSourcePath( IPath path ) {
         sourcePaths.add( path );
     }

     public void removeSourcePath( IPath path ) {
         sourcePaths.remove( path );
     }

     public Set<IPath> getSourcePaths() {
         return sourcePaths;
     }

     public void clearSourcePaths() {
     	sourcePaths.clear();
 	}

 	public void addComposite(ISCAComposite composite) {
         composites.add( composite );
         composite.setParent(this);
     }

     public Set<ISCAComposite> getComposites() {
         return composites;
     }

     public void removeComposite(ISCAComposite composite) {
         if ( composites.remove( composite ) ) {
         	composite.setParent(null);
         }
     }
 	public void addClasspathEntry(String encodedClasspath) {
 		classpath.add( encodedClasspath.trim() );
 	}

 	public Set<String> getClasspathEntrys() {
 		return classpath;
 	}

 	public void removeClasspathEntry(String encodedClasspath) {
 		classpath.remove(encodedClasspath.trim());
 	}

 	public IPath getLocation() {
 		return location;
 	}

 	public void setLocation(IPath location) {
 		this.location = location;
 	}

 	public IPath getSourcePathLocation() {
 		return sourcePathLocation;
 	}
 	public IPath getSourceRootPath() {
 		return sourceRootPath;
 	}
 	public void setSourcePathLocation(IPath location) {
 		this.sourcePathLocation = location;
 	}
 	public void setSourceRootPath(IPath location) {
 		this.sourceRootPath = location;
 	}

 	@Override
 	public String toString() {
 		return "SigilBundle[" + (getBundleInfo() == null ? null : (getBundleInfo().getSymbolicName() + ":" + getBundleInfo().getVersion())) + "]";
 	}

 	@Override
 	public boolean equals(Object obj) {
 		if ( obj == null ) return false;
 		if ( obj == this ) return true;

 		if ( obj instanceof SigilBundle) {
 			return obj.toString().equals( toString() );
 		}

 		return false;
 	}
 	@Override
 	public int hashCode() {
 		return 31 * toString().hashCode();
 	}

 	public IPath getLicencePathLocation() {
 		return licencePathLocation;
 	}

 	public void setLicencePathLocation(IPath licencePathLocation) {
 		this.licencePathLocation = licencePathLocation;
 	}

 	public String getFragmentHost() {
 		return bundleHost;
 	}

 	public void setFragmentHost(String symbolicName) {
 		this.bundleHost = symbolicName;
 	}

 	public String getElementName() {
 		return bundle.getSymbolicName();
 	}

 	public Version getVersion() {
 		return bundle.getVersion();
 	}

 	public void setVersion(Version version) {
 		this.bundle.setVersion(version);
 	}

 	public String getSymbolicName() {
 		return bundle.getSymbolicName();
 	}

 	public Set<String> getPackages() {
 		return packages;
 	}

 	public void addPackage(String pkg) {
 		packages.add(pkg);
 	}

 	public boolean removePackage(String pkg) {
 		return packages.remove(pkg);
 	}

 	public Set<String> getDownloadPackages() {
 		return dlPackages;
 	}

 	public void addDownloadPackage(String pkg) {
 		dlPackages.add(pkg);
 	}

 	public boolean removeDownloadPackage(String pkg) {
 		return dlPackages.remove(pkg);
 	}

 	public IPackageExport findExport(String packageName) {
 		for ( IPackageExport e : bundle.getExports() ) {
 			if ( packageName.equals( e.getPackageName() ) ) {
 				return e;
 			}
 		}
 		return null;
 	}

 	public IPackageImport findImport(String packageName) {
 		for ( IPackageImport i : bundle.getImports() ) {
 			if ( packageName.equals( i.getPackageName() ) ) {
 				return i;
 			}
 		}
 		return null;
 	}
 }
	/*
	* Licensed to the Apache Software Foundation (ASF) under one
	* or more contributor license agreements. See the NOTICE file
	* distributed with this work for additional information
	* regarding copyright ownership. The ASF licenses this file
	* to you 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.cauldron.bld.core.internal.model.eclipse;

	import java.io.File;
	import java.io.FileOutputStream;
	import java.io.IOException;
	import java.io.InputStream;
	import java.io.InterruptedIOException;
	import java.io.OutputStream;
	import java.net.HttpURLConnection;
	import java.net.URI;
	import java.net.URL;
	import java.net.URLConnection;
	import java.util.HashSet;
	import java.util.Set;

	import org.cauldron.bld.core.BldCore;
	import org.cauldron.sigil.model.AbstractCompoundModelElement;
	import org.cauldron.sigil.model.eclipse.IDownloadJar;
	import org.cauldron.sigil.model.eclipse.ISCAComposite;
	import org.cauldron.sigil.model.eclipse.ISigilBundle;
	import org.cauldron.sigil.model.osgi.IBundleModelElement;
	import org.cauldron.sigil.model.osgi.IPackageExport;
	import org.cauldron.sigil.model.osgi.IPackageImport;
	import org.eclipse.core.runtime.IPath;
	import org.eclipse.core.runtime.IProgressMonitor;
	import org.eclipse.core.runtime.SubMonitor;
	import org.osgi.framework.Version;

	/**
	* @author dave
	*
	*/
	public class SigilBundle extends AbstractCompoundModelElement implements ISigilBundle {

	private static final long serialVersionUID = 1L;

	private IBundleModelElement bundle;
	private IDownloadJar download;
	private Set<IPath> sourcePaths;
	private Set<IPath> libraryPaths;
	private Set<ISCAComposite> composites;
	private Set<String> classpath;
	private Set<String> packages;
	private Set<String> dlPackages;
	private IPath location;

	private IPath sourcePathLocation;
	private IPath licencePathLocation;
	private IPath sourceRootPath;
	private String bundleHost;

	public SigilBundle() {
	super( "Sigil Bundle" );
	sourcePaths = new HashSet<IPath>();
	libraryPaths = new HashSet<IPath>();
	composites = new HashSet<ISCAComposite>();
	classpath = new HashSet<String>();
	packages = new HashSet<String>();
	dlPackages = new HashSet<String>();
	}

	public void synchronize(IProgressMonitor monitor) throws IOException {
	SubMonitor progress = SubMonitor.convert(monitor, 100);
	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " binary" );
	sync(location, bundle.getUpdateLocation(), progress.newChild(45));

	try {
	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " source" );
	sync(sourcePathLocation, bundle.getSourceLocation(), progress.newChild(45));
	} catch (IOException e) {
	BldCore.error( "Failed to download source for " + bundle.getSymbolicName() + " " + bundle.getVersion(), e.getCause() );
	}

	try {
	progress.subTask("Synchronizing " + bundle.getSymbolicName() + " licence" );
	sync(licencePathLocation, bundle.getLicenseURI(), progress.newChild(10));
	} catch (IOException e) {
	BldCore.error( "Failed to download licence for " + bundle.getSymbolicName() + " " + bundle.getVersion(), e.getCause() );
	}
	}

	public boolean isSynchronized() {
	return location == null \|\| location.toFile().exists();
	}

	private static void sync(IPath local, URI remote, IProgressMonitor monitor) throws IOException {
	try {
	if ( local != null && !local.toFile().exists() ) {
	if ( remote != null ) {
	URL url = remote.toURL();
	URLConnection connection = url.openConnection();
	int contentLength = connection.getContentLength();

	monitor.beginTask("Downloading from " + url.getHost(), contentLength);

	InputStream in = null;
	OutputStream out = null;
	try {
	URLConnection conn = url.openConnection();
	if ( conn instanceof HttpURLConnection ) {
	HttpURLConnection http = (HttpURLConnection) conn;
	http.setConnectTimeout(10000);
	http.setReadTimeout(5000);
	}
	in = conn.getInputStream();
	File f = local.toFile();
	f.getParentFile().mkdirs();
	out = new FileOutputStream( f );
	stream( in, out, monitor );
	}
	finally {
	if ( in != null ) {
	in.close();
	}
	if ( out != null ) {
	out.close();
	}
	monitor.done();
	}
	}
	}
	}
	catch (IOException e) {
	local.toFile().delete();
	throw e;
	}
	}

	private static void stream(InputStream in, OutputStream out, IProgressMonitor monitor) throws IOException {
	byte[] b = new byte[1024];
	for ( ;; ) {
	if ( monitor.isCanceled() ) {
	throw new InterruptedIOException( "User canceled download" );
	}
	int r = in.read( b );
	if ( r == -1 ) break;
	out.write(b, 0, r);
	monitor.worked(r);
	}

	out.flush();
	}

	public IBundleModelElement getBundleInfo() {
	return bundle;
	}

	public void setBundleInfo(IBundleModelElement bundle) {
	if ( bundle == null ) {
	if (this.bundle != null) {
	this.bundle.setParent(null);
	}
	}
	else {
	bundle.setParent(this);
	}
	this.bundle = bundle;
	}

	public IDownloadJar getDownloadJar() {
	return download;
	}

	public void setDownloadJar(IDownloadJar download) {
	this.download = download;
	}

	public void addLibraryPath( IPath path ) {
	libraryPaths.add( path );
	}

	public void removeLibraryPath( IPath path ) {
	libraryPaths.remove( path );
	}

	public Set<IPath> getLibraryPaths() {
	return libraryPaths;
	}

	public void addSourcePath( IPath path ) {
	sourcePaths.add( path );
	}

	public void removeSourcePath( IPath path ) {
	sourcePaths.remove( path );
	}

	public Set<IPath> getSourcePaths() {
	return sourcePaths;
	}

	public void clearSourcePaths() {
	sourcePaths.clear();
	}

	public void addComposite(ISCAComposite composite) {
	composites.add( composite );
	composite.setParent(this);
	}

	public Set<ISCAComposite> getComposites() {
	return composites;
	}

	public void removeComposite(ISCAComposite composite) {
	if ( composites.remove( composite ) ) {
	composite.setParent(null);
	}
	}
	public void addClasspathEntry(String encodedClasspath) {
	classpath.add( encodedClasspath.trim() );
	}

	public Set<String> getClasspathEntrys() {
	return classpath;
	}

	public void removeClasspathEntry(String encodedClasspath) {
	classpath.remove(encodedClasspath.trim());
	}

	public IPath getLocation() {
	return location;
	}

	public void setLocation(IPath location) {
	this.location = location;
	}

	public IPath getSourcePathLocation() {
	return sourcePathLocation;
	}
	public IPath getSourceRootPath() {
	return sourceRootPath;
	}
	public void setSourcePathLocation(IPath location) {
	this.sourcePathLocation = location;
	}
	public void setSourceRootPath(IPath location) {
	this.sourceRootPath = location;
	}

	@Override
	public String toString() {
	return "SigilBundle[" + (getBundleInfo() == null ? null : (getBundleInfo().getSymbolicName() + ":" + getBundleInfo().getVersion())) + "]";
	}

	@Override
	public boolean equals(Object obj) {
	if ( obj == null ) return false;
	if ( obj == this ) return true;

	if ( obj instanceof SigilBundle) {
	return obj.toString().equals( toString() );
	}

	return false;
	}
	@Override
	public int hashCode() {
	return 31 * toString().hashCode();
	}

	public IPath getLicencePathLocation() {
	return licencePathLocation;
	}

	public void setLicencePathLocation(IPath licencePathLocation) {
	this.licencePathLocation = licencePathLocation;
	}

	public String getFragmentHost() {
	return bundleHost;
	}

	public void setFragmentHost(String symbolicName) {
	this.bundleHost = symbolicName;
	}

	public String getElementName() {
	return bundle.getSymbolicName();
	}

	public Version getVersion() {
	return bundle.getVersion();
	}

	public void setVersion(Version version) {
	this.bundle.setVersion(version);
	}

	public String getSymbolicName() {
	return bundle.getSymbolicName();
	}

	public Set<String> getPackages() {
	return packages;
	}

	public void addPackage(String pkg) {
	packages.add(pkg);
	}

	public boolean removePackage(String pkg) {
	return packages.remove(pkg);
	}

	public Set<String> getDownloadPackages() {
	return dlPackages;
	}

	public void addDownloadPackage(String pkg) {
	dlPackages.add(pkg);
	}

	public boolean removeDownloadPackage(String pkg) {
	return dlPackages.remove(pkg);
	}

	public IPackageExport findExport(String packageName) {
	for ( IPackageExport e : bundle.getExports() ) {
	if ( packageName.equals( e.getPackageName() ) ) {
	return e;
	}
	}
	return null;
	}

	public IPackageImport findImport(String packageName) {
	for ( IPackageImport i : bundle.getImports() ) {
	if ( packageName.equals( i.getPackageName() ) ) {
	return i;
	}
	}
	return null;
	}
	}