Application: gvSIG desktop

import java.util.List;

import java.util.Map;

	 * It reads an installer and parses all the install.info files.

	 * @param is

	 * The installer.

	 * @param installerInfos

	 * A list of the information of the plugins to install.

	 * @param zipEntriesMap

	 * A map to retrieve the zipEntry name for each plugin. This information is necessary to

	 * select the plugin to decompress.

	 * @throws InstallerExecutionServiceException

	 * If there is a problem reading the installer.

	 */

	public void readInstallInfo(InputStream is, List<InstallerInfo> installerInfos, Map<InstallerInfo, String> zipEntriesMap) throws InstallerExecutionServiceException;

	/**

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 * 

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

 * MA  02110-1301, USA.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2010 {Prodevelop}   {Task}

 */

package org.gvsig.installer.lib.impl.utils;

import java.io.ByteArrayInputStream;

import java.io.ByteArrayOutputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.util.ArrayList;

import java.util.List;

import java.util.Map;

import java.util.zip.ZipEntry;

import java.util.zip.ZipException;

import java.util.zip.ZipInputStream;

import org.gvsig.installer.lib.api.InstallerInfo;

import org.gvsig.installer.lib.api.execution.InstallerExecutionServiceException;

import org.gvsig.installer.lib.impl.DefaultInstallerInfo;

import org.gvsig.installer.lib.impl.creation.DefaultInstallerCreationService;

import org.gvsig.installer.lib.impl.info.InstallerInfoFileReader;

import org.gvsig.installer.lib.spi.InstallerInfoFileException;

import org.gvsig.installer.lib.spi.InstallerProviderLocator;

import org.gvsig.installer.lib.spi.InstallerProviderManager;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera Llodr&aacute;</a>

 */

public class Decompress {

	private static final int OPTION_DECOMPRESS = 1;

	private static final int OPTION_READ_INSTALLINFO = 2;

	private static final int OPTION_INSTALL = 3;

	private int option = 0;

	private int BUFFER = 2048;

	private static final Logger logger = LoggerFactory.getLogger(Decompress.class);

	private List<InstallerInfo> readedIinstallerInfos = null;	

	private File outputDirectory = null;	

	private List<InstallerInfo> selectedInstallerInfos = null;

	private Map<InstallerInfo, String> zipEntriesMap = null;

	private static final InstallerProviderManager installerProviderManager = InstallerProviderLocator.getProviderManager();

	public Decompress(){		

	}

	public void decompressPlugins(InputStream is, File outputDirectory) throws InstallerExecutionServiceException {

		option = OPTION_DECOMPRESS;

		this.outputDirectory = outputDirectory;

		decompressFolderOfPlugins(is);

	}

	public void readInstallInfo(InputStream is, List<InstallerInfo> installerInfos, Map<InstallerInfo, String> zipEntriesMap) throws InstallerExecutionServiceException{

		option = OPTION_READ_INSTALLINFO;

		this.readedIinstallerInfos = installerInfos;

		this.zipEntriesMap = zipEntriesMap;	

		decompressFolderOfPlugins(is);			

	}	

	public void decompressPlugin(InputStream is, File outputDirectory) throws InstallerExecutionServiceException {

		try{

			option = OPTION_DECOMPRESS;

			this.outputDirectory = outputDirectory;				

			decompressPlugin(new ZipInputStream(is), "");

		} catch (Exception e) {

			throw new InstallerExecutionServiceException("Error reading the plugin", e);

		} 	

	}	

	public InputStream searchPlugin(InputStream is, String zipEntry) throws InstallerExecutionServiceException{

		ZipEntry entry = null;		

		try {		

			ZipInputStream zipInputStream = new ZipInputStream(is);	

			while((entry = zipInputStream.getNextEntry()) != null) {	

				if (entry.getName().equals(zipEntry)){

					return zipInputStream;

				}				

				zipInputStream.closeEntry();

			}

			zipInputStream.closeEntry();

			zipInputStream.close();			

		} catch (Exception e) {

			throw new InstallerExecutionServiceException("Error reading the plugin", e);

		} 	

		return null;	

	}

	public void installFromStream(InputStream is, InstallerInfo installerInfo) throws InstallerExecutionServiceException{

		option = OPTION_INSTALL;

		this.selectedInstallerInfos = new ArrayList<InstallerInfo>();

		this.selectedInstallerInfos.add(installerInfo);

		decompressFolderOfPlugins(is);

	}

	public void installFromStream(InputStream is, List<InstallerInfo> installerInfos) throws InstallerExecutionServiceException{

		option = OPTION_INSTALL;

		this.selectedInstallerInfos = installerInfos;		

		decompressFolderOfPlugins(is);

	}	

	private void decompressFolderOfPlugins(InputStream is) throws InstallerExecutionServiceException {

		ZipInputStream zipInputStream = new ZipInputStream(is);	

		ZipEntry entry = null;		

		try {			

			while((entry = zipInputStream.getNextEntry()) != null) {	

				logger.debug("Extracting all Plugins, plugin: " + entry);

				if (option == OPTION_INSTALL){

				}else if (option == OPTION_DECOMPRESS){				

					decompressPlugin(new ZipInputStream(zipInputStream), entry.getName());

				}else if (option == OPTION_READ_INSTALLINFO){			

					readPlugin(new ZipInputStream(zipInputStream), entry.getName());

				}

				zipInputStream.closeEntry();

			}			

			zipInputStream.close();	

		} catch (Exception e) {

			throw new InstallerExecutionServiceException("Error reading the plugin", e);

		} 			

	}

	private void readPlugin(ZipInputStream zipInputStream, String zipEntryName) throws ZipException, IOException, InstallerInfoFileException{

		ZipEntry entry = null;

		byte data[] = new byte[BUFFER];		

		int count;

		int installerInfoNumber = zipEntriesMap.size();

		while((entry = zipInputStream.getNextEntry()) != null) {			        

			logger.debug("Extracting: " + entry.getName());	

			if (entry.getName().endsWith(File.separator + "install.info")){

				InstallerInfo installerInfo = readInstallInfo(zipInputStream);

				zipEntriesMap.put(installerInfo, zipEntryName);			

				readedIinstallerInfos.add(installerInfo);					

			}

			zipInputStream.closeEntry();

		}			

		//zipInputStream.close();	

		if (installerInfoNumber == zipEntriesMap.size()){

			InstallerInfo installerInfo = new DefaultInstallerInfo();

			installerInfo.setCode(zipEntryName);

			installerInfo.setName(zipEntryName);

			zipEntriesMap.put(installerInfo, zipEntryName);

			readedIinstallerInfos.add(installerInfo);		

		}

	}

	private void decompressPlugin(ZipInputStream zipInputStream, String zipEntryName) throws ZipException, IOException, InstallerInfoFileException{

		ZipEntry entry = null;

		byte data[] = new byte[BUFFER];		

		int count;

		int installerInfoNumber = 0;

		if (zipEntriesMap != null){

			installerInfoNumber = zipEntriesMap.size();

		}

		while((entry = zipInputStream.getNextEntry()) != null) {			        

			logger.debug("Extracting: " + entry.getName());	

			File file = new File(outputDirectory.getAbsolutePath() + File.separator + entry.getName());

			if (file.exists()){

				delete(file);

			}

			if (entry.isDirectory()){

				file.mkdir();

			}else{

				FileOutputStream fos = new FileOutputStream(outputDirectory.getAbsolutePath() + File.separator + entry.getName());

				while ((count = zipInputStream.read(data, 0, BUFFER)) != -1) {

					fos.write(data, 0, count);

				}

				fos.flush();		

				fos.close();	

			}

			//zipInputStream.closeEntry();

		}

	}	

	public boolean delete(File dir) { 

		if (dir.isDirectory()){

			String[] children = dir.list(); 

			for (int i=0; i<children.length; i++) { 

				boolean success = delete(new File(dir, children[i]));

				if (!success) { 

					return false; 

				}

			} 

		}

		return dir.delete(); 

	}

	public InstallerInfo readInstallerInfo(InputStream is) throws InstallerInfoFileException{

		try {

			return readInstallInfo(new ZipInputStream(is));

		} catch (IOException e) {

			throw new InstallerInfoFileException("error_reading_installerinfo", e);

		}

	}

	private InstallerInfo readInstallInfo(ZipInputStream zipInputStream) throws IOException, InstallerInfoFileException{

		int count;

		byte data[] = new byte[BUFFER];

		ByteArrayOutputStream out = new ByteArrayOutputStream();

		while ((count = zipInputStream.read(data, 0, BUFFER)) != -1) {

			out.write(data, 0, count);

		}

		out.flush();

		DefaultInstallerInfo installerInfo = new DefaultInstallerInfo();

		InstallerInfoFileReader installerInfoFileReader = new InstallerInfoFileReader();

		installerInfoFileReader.read(installerInfo, new ByteArrayInputStream(out.toByteArray()));

		return installerInfo;

	}	

}

/* gvSIG. Geographic Information System of the Valencian Government

 *

 * Copyright (C) 2007-2008 Infrastructures and Transports Department

 * of the Valencian Government (CIT)

 * 

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 * 

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 * 

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, 

 * MA  02110-1301, USA.

 * 

 */

/*

 * AUTHORS (In addition to CIT):

 * 2010 {Prodevelop}   {Task}

 */

package org.gvsig.installer.lib.impl.utils;

import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.OutputStream;

import java.util.ArrayList;

import java.util.List;

import java.util.zip.ZipEntry;

import java.util.zip.ZipOutputStream;

import org.gvsig.installer.lib.api.creation.InstallerCreationServiceException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

/**

 * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera Llodr&aacute;</a>

 */

public class Compress {

	static final int BUFFER = 2048;

	private static final Logger logger = LoggerFactory.getLogger(Compress.class);

	public Compress() {

		super();		

	}

	public void compressPlugin(File file, String fileName, OutputStream os) throws InstallerCreationServiceException {

		ArrayList<File> files = new ArrayList<File>();

		ArrayList<String> fileNames = new ArrayList<String>();

		files.add(file);

		fileNames.add(fileName);

		compressPlugins(files, fileNames, os);

	}

	public void compressPlugins(List<File> files, List<String> fileNames, OutputStream os) throws InstallerCreationServiceException {

		try{

			ZipOutputStream zos = new ZipOutputStream(new BufferedOutputStream(os));

			byte[] buf = new byte[1024];

			int len;

			for (int i=0 ; i<files.size() ; i++){

				File file = files.get(i);				

				int parentFileLenght = file.getParentFile().toString().length();

				String pluginName = file.toString().substring(parentFileLenght, file.toString().length());				

				ZipEntry zipEntry = new ZipEntry(fileNames.get(i));				

				zos.putNextEntry(zipEntry);								

				ZipOutputStream zosPlugin = new ZipOutputStream(zos);				

				compressPluginFile(file, parentFileLenght, zosPlugin);				

				zosPlugin.finish();

				zos.closeEntry();

				zos.close();				

			}

			zos.close();

		} catch (Exception e) {

			logger.error("Error compressing the plugin");

			throw new InstallerCreationServiceException("Error writing the plugin", e);

		}

	}

	private void compressPluginFile(File file, int parenFileLength, ZipOutputStream zosPlugin) throws IOException  {		

		if (file.isDirectory()) {

			String[] fileNames = file.list();

			if (fileNames != null) {

				for (int i=0; i<fileNames.length; i++)  {

					compressPluginFile(new File(file, fileNames[i]), parenFileLength, zosPlugin);

				}

			}

		}else{

			byte[] buf = new byte[1024];

			int len;

			String fileName = file.toString().substring(parenFileLength, file.toString().length());

			ZipEntry zipEntry = new ZipEntry(fileName);      

			zosPlugin.putNextEntry(zipEntry);   

			FileInputStream fin = new FileInputStream(file);

			BufferedInputStream in = new BufferedInputStream(fin);			    

			while ((len = in.read(buf)) >= 0) {

				zosPlugin.write(buf, 0, len);

			}        

			in.close();      

			zosPlugin.closeEntry();

		}

	}

}

import java.util.List;

import java.util.Map;

import org.gvsig.installer.lib.impl.utils.Compress;

import org.gvsig.installer.lib.impl.utils.Decompress;

	public void readInstallInfo(InputStream is,

			List<InstallerInfo> installerInfos,

			Map<InstallerInfo, String> zipEntriesMap)

			throws InstallerExecutionServiceException {

		Decompress decompress = new Decompress();			

		decompress.readInstallInfo(is, installerInfos, zipEntriesMap);			

	}

		installerProviderServices.readInstallInfo(inputStream, installerInfos, zipEntriesMap);

	}