Application: gvSIG desktop

<project name="org.gvsig.plugin1" default="main" basedir=".">

	<target name="main" depends="copy_files"/>

    <target name="copy_files">

    	<copy todir="${gvsig_dir}">

    		<fileset dir="./files" includes="**"/>

		</copy>

	</target>

</project>

org.gvsig.installer.lib.impl.DefaultInstallerLibrary

/* 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.

 *

 */

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

import java.io.BufferedInputStream;

import java.io.BufferedOutputStream;

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import java.net.URL;

import java.net.URLConnection;

import java.util.Date;

import java.util.StringTokenizer;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.gvsig.tools.task.AbstractMonitorableTask;

import org.gvsig.tools.task.SimpleTaskStatus;

/**

 * @author gvSIG Team

 * @version $Id$

 * 

 */

public class Download extends AbstractMonitorableTask {

    private static final Logger LOG = LoggerFactory.getLogger(Download.class);

    private boolean isMyTaskStatus;

    /**

     * @param taskName

     */

    public Download(SimpleTaskStatus taskStatus) {

        this();

        this.taskStatus = taskStatus;

        isMyTaskStatus = false;

    }

    public Download() {

        super("Downloading...");

        isMyTaskStatus = true;

    }

    public File downloadFile(URL url, String defaultFileName)

        throws IOException {

        URL downloadURL = url;

        // check if the URL ends with '/' and append the file name

        if (defaultFileName != null) {

            String urlStr = url.toString();

            if (urlStr.endsWith("/")) {

                urlStr = urlStr.concat(defaultFileName);

                downloadURL = new URL(urlStr);

            }

        }

        URLConnection connection = downloadURL.openConnection();

        String fileName = getFileName(connection);

        if (LOG.isDebugEnabled()) {

            Date date = new Date(connection.getLastModified());

            LOG.debug(

                "Downloading file {} from URL {}, with last modified date: {}",

                new Object[] { fileName, downloadURL, date });

        }

        String fileNamePrefix = fileName;

        String fileNameSuffix = "zip";

        int dotPosition = fileName.lastIndexOf('.');

        if ((dotPosition > -1) && (dotPosition < fileName.length() - 1)) {

            fileNamePrefix = fileName.substring(0, dotPosition);

            fileNameSuffix = fileName.substring(dotPosition);

        }

        BufferedInputStream bis =

            new BufferedInputStream(downloadURL.openStream());

        File localFile = File.createTempFile(fileNamePrefix, fileNameSuffix);

        BufferedOutputStream bos =

            new BufferedOutputStream(new FileOutputStream(localFile));

        this.taskStatus.setRangeOfValues(0, connection.getContentLength());

        try {

            byte[] data = new byte[1024];

            int count = 0;

            long totalCount = 0; // total bytes readed

            while ((count = bis.read(data, 0, 1024)) >= 0) {

                bos.write(data, 0, count);

                totalCount += count;

                this.taskStatus.setCurValue(totalCount);

                if (this.taskStatus.isCancellationRequested()) {

                    return null;

                }

            }

            if (isMyTaskStatus) {

                this.taskStatus.terminate();

                this.taskStatus.remove();

            }

            return localFile;

        } finally {

            bis.close();

            bos.flush();

            bos.close();

        }

    }

    /**

     * Returns the file name associated to an url connection.<br />

     * The result is not a path but just a file name.

     * 

     * @param urlConnection

     *            - the url connection

     * @return the file name

     * 

     * @throws IOException

     *             Signals that an I/O exception has occurred.

     */

    private String getFileName(URLConnection urlConnection) throws IOException {

        String fileName = null;

        String contentDisposition =

            urlConnection.getHeaderField("content-disposition");

        if (contentDisposition != null) {

            fileName =

                extractFileNameFromContentDisposition(contentDisposition);

        }

        // if the file name cannot be extracted from the content-disposition

        // header, using the url.getFilename() method

        if (fileName == null) {

            StringTokenizer st =

                new StringTokenizer(urlConnection.getURL().getFile(), "/");

            while (st.hasMoreTokens()) {

                fileName = st.nextToken();

            }

        }

        return fileName;

    }

    /**

     * Extract the file name from the content disposition header.

     * <p>

     * See <a

     * href="http://www.w3.org/Protocols/rfc2616/rfc2616-sec19.html">http:

     * //www.w3.org/Protocols/rfc2616/rfc2616-sec19.html</a> for detailled

     * information regarding the headers in HTML.

     * 

     * @param contentDisposition

     *            - the content-disposition header. Cannot be <code>null>/code>.

     * @return the file name, or <code>null</code> if the content-disposition

     *         header does not contain the filename attribute.

     */

    private String extractFileNameFromContentDisposition(

        String contentDisposition) {

        String[] attributes = contentDisposition.split(";");

        for (String a : attributes) {

            if (a.toLowerCase().contains("filename")) {

                // The attribute is the file name. The filename is between

                // quotes.

                return a.substring(a.indexOf('\"') + 1, a.lastIndexOf('\"'));

            }

        }

        // not found

        return null;

    }

}

/* 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.MakePluginPackageServiceException;

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

/**

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

 */

public class Compress {

//    private static final int BUFFER = 2048;

    public void compressPluginAsPackageSet(File file, String fileName,

        OutputStream os) throws MakePluginPackageServiceException {

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

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

        files.add(file);

        fileNames.add(fileName);

        compressPluginsAsPackageSet(files, fileNames, os);

    }

    public void compressPluginsAsPackageSet(File directory, OutputStream os)

        throws MakePluginPackageServiceException {

        File[] files = directory.listFiles();

        List<File> filesArray = new ArrayList<File>();

        List<String> fileNamesArray = new ArrayList<String>();

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

            filesArray.add(files[i]);

            fileNamesArray.add(files[i].getName());

        }

        compressPluginsAsPackageSet(filesArray, fileNamesArray, os);

    }

    public void compressPluginsAsPackageSet(List<File> files,

        List<String> fileNames, OutputStream os)

        throws MakePluginPackageServiceException {

        try {

            ZipOutputStream zos =

                new ZipOutputStream(new BufferedOutputStream(os));

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

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

                zos.putNextEntry(zipEntry);

                compressPluginFiles(files.get(i), zos);

                zos.closeEntry();

            }

            zos.close();

        } catch (Exception e) {

            throw new MakePluginPackageServiceException(

                "Error compressing as package set the plugin files: " + files,

                e);

        }

    }

    public void compressPluginAsPackage(File folder, OutputStream os)

        throws MakePluginPackageServiceException {

        ZipOutputStream zos = new ZipOutputStream(os);

        try {

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

            compressPluginFile(folder, parentFileLenght, zos);

            zos.flush();

            zos.close();

        } catch (IOException e) {

            throw new MakePluginPackageServiceException(

                "Error compressing as package the plugin folder: " + folder, e);

        }

    }

    public void compressPluginAsPackageIndex(File folder, OutputStream os)

        throws MakePluginPackageServiceException {

        ZipOutputStream zos = new ZipOutputStream(os);

        try {

            int parentFileLength = folder.getParentFile().toString().length();

            String folderName =

                folder.toString()

                    .substring(parentFileLength + 1, folder.toString().length());

            File infoFile =

                new File(folder, getPackageInfoFileName() + ".index");

            byte[] buf = new byte[1024];

            int len;

            ZipEntry zipEntry =

                new ZipEntry(folderName + File.separator

                    + getPackageInfoFileName());

            zos.putNextEntry(zipEntry);

            FileInputStream fin = new FileInputStream(infoFile);

            BufferedInputStream in = new BufferedInputStream(fin);

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

                zos.write(buf, 0, len);

            }

            in.close();

            zos.closeEntry();

            zos.flush();

            zos.close();

        } catch (IOException e) {

            throw new MakePluginPackageServiceException(

                "Error compressing as package index the plugin folder: "

                    + folder, e);

        }

    }

    private void compressPluginFiles(File fileOrFolder, ZipOutputStream zos)

        throws IOException {

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

        ZipOutputStream zosPlugin = new ZipOutputStream(zos);

        compressPluginFile(fileOrFolder, parentFileLenght, zosPlugin);

        zosPlugin.finish();

    }

    private void compressPluginFile(File file, int parenFileLength,

        ZipOutputStream zosPlugin) throws IOException {

        String fileName =

            file.toString()

                .substring(parenFileLength, file.toString().length());

        if (File.separatorChar != '/') {

            fileName = fileName.replace(File.separatorChar, '/');

        }

        if (file.isDirectory()) {

            // Remove the subversion folders

            if (!file.getName().toUpperCase().equals(".SVN")) {

                // Adding the files

                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;

            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();

        }

    }

    private String getPackageInfoFileName() {

        return InstallerProviderLocator.getProviderManager()

            .getPackageInfoFileName();

    }

}

/* 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.

 *

 */

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

import java.io.File;

/**

 * @author gvSIG Team

 * @version $Id$

 *

 */

public class DeleteFile {

    public DeleteFile() {

    }

    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();

    }

}

/* 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.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

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

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

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.tools.ToolsLocator;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.tools.task.TaskStatusManager;

/**

 * @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<PackageInfo> readedIinstallerInfos = null;

    private File outputDirectory = null;

    private List<PackageInfo> selectedInstallerInfos = null;

    private Map<PackageInfo, String> zipEntriesMap = null;

    private List<String> defaultSelectedPackets = null;

    public Decompress() {

    }

    public void decompressPlugins(InputStream is, File outputDirectory)

        throws InstallPackageServiceException {

        option = OPTION_DECOMPRESS;

        this.outputDirectory = outputDirectory;

        decompressFolderOfPlugins(is);

    }

    public void readPackageSetInstallInfos(InputStream is,

        List<PackageInfo> installerInfos, Map<PackageInfo, String> zipEntriesMap)

        throws InstallPackageServiceException {

        option = OPTION_READ_INSTALLINFO;

        this.readedIinstallerInfos = installerInfos;

        this.zipEntriesMap = zipEntriesMap;

        decompressFolderOfPlugins(is);

    }

    public void readPackageInstallInfo(InputStream is,

        List<PackageInfo> installerInfos,

        Map<PackageInfo, String> zipEntriesMap, String name)

        throws InstallPackageServiceException {

        option = OPTION_READ_INSTALLINFO;

        this.readedIinstallerInfos = installerInfos;

        this.zipEntriesMap = zipEntriesMap;

        decompressFolderOfPluginFromPackage(is, name);

    }

    public void decompressPlugin(InputStream is, File outputDirectory)

        throws InstallPackageServiceException {

        try {

            option = OPTION_DECOMPRESS;

            this.outputDirectory = outputDirectory;

            decompressPlugin(is);

        } catch (Exception e) {

            throw new InstallPackageServiceException(

                "Error reading the plugin", e);

        }

    }

    public InputStream searchPlugin(InputStream is, String zipEntry)

        throws InstallPackageServiceException {

        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 InstallPackageServiceException(

                "Error reading the plugin", e);

        }

        return null;

    }

    public void installFromStream(InputStream is, PackageInfo installerInfo)

        throws InstallPackageServiceException {

        option = OPTION_INSTALL;

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

        this.selectedInstallerInfos.add(installerInfo);

        decompressFolderOfPlugins(is);

    }

    public void installFromStream(InputStream is,

        List<PackageInfo> installerInfos) throws InstallPackageServiceException {

        option = OPTION_INSTALL;

        this.selectedInstallerInfos = installerInfos;

        decompressFolderOfPlugins(is);

    }

    private void decompressFolderOfPlugins(InputStream is)

        throws InstallPackageServiceException {

        ZipInputStream zipInputStream = new ZipInputStream(is);

        ZipEntry entry = null;

        try {

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

                if (entry.getName().equals("defaultPackages")) {

                    int count;

                    byte data[] = new byte[BUFFER];

                    ByteArrayOutputStream out = new ByteArrayOutputStream();

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

                        out.write(data, 0, count);

                    }

                    String str = out.toString();

                    String lineas[] = str.split("\\n");

                    List<String> defaultPackagesList = new ArrayList<String>();

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

                        defaultPackagesList.add(lineas[i]);

                    }

                    defaultSelectedPackets = defaultPackagesList;

                    out.flush();

                } else {

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

                    if (option == OPTION_INSTALL) {

                    } else {

                        if (option == OPTION_DECOMPRESS) {

                            decompressPlugin(zipInputStream);

                        } else

                            if (option == OPTION_READ_INSTALLINFO) {

                                readPlugin(zipInputStream, entry.getName());

                            }

                    }

                }

                zipInputStream.closeEntry();

            }

            zipInputStream.close();

        } catch (Exception e) {

            throw new InstallPackageServiceException(

                "Error reading the plugin", e);

        }

    }

    private void decompressFolderOfPluginFromPackage(InputStream is, String name)

        throws InstallPackageServiceException {

        try {

            if (option == OPTION_INSTALL) {

            } else {

                if (option == OPTION_DECOMPRESS) {

                    decompressPlugin(is);

                } else {

                    if (option == OPTION_READ_INSTALLINFO) {

                        readPlugin(is, name);

                    }

                }

            }

        } catch (Exception e) {

            throw new InstallPackageServiceException(

                "Error reading the plugin", e);

        }

    }

    private void readPlugin(InputStream is, String zipEntryName)

        throws ZipException, IOException, InstallerInfoFileException {

        ZipEntry entry = null;

        int installerInfoNumber = zipEntriesMap.size();

        String packageInfoName = getPackageInfoFileName();

        String unixPackageInfoPath = "/".concat(packageInfoName);

        String windowsPackageInfoPath = "\\".concat(packageInfoName);

        ZipInputStream zis = new ZipInputStream(is);

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

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

            String name = entry.getName();

            // Just in case, but we are going to create them always using

            // the unix file separator

            if (name.endsWith(unixPackageInfoPath)

                || name.endsWith(windowsPackageInfoPath)) {

                PackageInfo installerInfo = readInstallInfo(zis);

                zipEntriesMap.put(installerInfo, zipEntryName);

                readedIinstallerInfos.add(installerInfo);

            }

            zis.closeEntry();

        }

        // Don't close the stream as if it is a zip file contained 

        // into another zip file, closing of the child Zip?nputStream

        // will close also the parent's.

//        zis.close();

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

            PackageInfo installerInfo = new DefaultPackageInfo();

            installerInfo.setCode(zipEntryName);

            installerInfo.setName(zipEntryName);

            zipEntriesMap.put(installerInfo, zipEntryName);

            readedIinstallerInfos.add(installerInfo);

        }

    }

    private void decompressPlugin(InputStream inputStream)

        throws ZipException, IOException, InstallerInfoFileException {

        ZipInputStream zis = null;

        ZipEntry entry = null;

        byte data[] = new byte[BUFFER];

        int count = 0;

        TaskStatusManager manager = ToolsLocator.getTaskStatusManager();

        SimpleTaskStatus taskStatus =

            manager.creteDefaultSimpleTaskStatus("Uncompressing...");

        manager.add(taskStatus);

        long readed = 0;

        // // First read all the contents size

        // zis = new ZipInputStream(inputStream);

        // while ((entry = zis.getNextEntry()) != null) {

        // count += entry.getSize();

        // }

        // // zis.close();

        // taskStatus.setRangeOfValues(0, count);

        // Return the stream to the initial position

        zis = new ZipInputStream(inputStream);

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

            String entryName = entry.getName();

            taskStatus.message(entryName);

            if (File.separatorChar != '/') {

                entryName = entryName.replace('/', File.separatorChar);

            }

            logger.debug("Extracting: " + entryName);

            File file =

                new File(outputDirectory.getAbsolutePath() + File.separator

                    + entryName);

            if (file.exists()) {

                delete(file);

            }

            if (entry.isDirectory()) {

                file.mkdirs();

            } else {

                createParentFolder(file);

                FileOutputStream fos = new FileOutputStream(file);

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

                    fos.write(data, 0, count);

                    readed += count;

                    taskStatus.setCurValue(readed);

                }

                fos.flush();

                fos.close();

            }

        }

        zis.close();

        taskStatus.remove();

    }

    private void createParentFolder(File file) {

        File parentFile = file.getParentFile();

        if (!parentFile.exists()) {

            parentFile.mkdirs();

        }

    }

    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 PackageInfo readInstallerInfo(InputStream is)

        throws InstallerInfoFileException {

        try {

            return readInstallInfo(new ZipInputStream(is));

        } catch (IOException e) {

            throw new InstallerInfoFileException("error_reading_installerinfo",

                e);

        }

    }

    private PackageInfo 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();

        DefaultPackageInfo installerInfo = new DefaultPackageInfo();

        InstallerInfoFileReader installerInfoFileReader =

            new InstallerInfoFileReader();

        installerInfoFileReader.read(installerInfo, new ByteArrayInputStream(

            out.toByteArray()));

        return installerInfo;

    }

    private String getPackageInfoFileName() {

        return InstallerProviderLocator.getProviderManager()

            .getPackageInfoFileName();

    }

    public List<String> getDefaultSelectedPackages() {

        return defaultSelectedPackets;

    }

}

/* 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;

import java.io.File;

import java.io.InputStream;

import java.io.OutputStream;

import java.util.List;

import java.util.Map;

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

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

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

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

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

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

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

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

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

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

import org.gvsig.tools.service.spi.AbstractProviderServices;

/**

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

 */

public class DefaultInstallerProviderServices extends AbstractProviderServices

		implements InstallPackageProviderServices {

    private List<String> defaultSelectedPacketsIDs = null;

//	private static final Logger LOG = LoggerFactory

//			.getLogger(DefaultInstallerProviderServices.class);

	public void decompress(InputStream is, File outputDirectory)

			throws InstallPackageServiceException {

		Decompress decompress = new Decompress();

		decompress.decompressPlugin(is, outputDirectory);

	}

	public PackageInfo readCompressedPackageInfo(InputStream is)

			throws InstallPackageServiceException {

		Decompress decompress = new Decompress();

		try {

			return decompress.readInstallerInfo(is);

		} catch (InstallerInfoFileException e) {

			throw new InstallPackageServiceException(

					"Exception reading a compressed file", e);

		}

	}

	public void compressPackageSet(File folder, String fileName, OutputStream os)

			throws MakePluginPackageServiceException {

		Compress compress = new Compress();

		compress.compressPluginAsPackageSet(folder, fileName, os);

	}

	public void compressPackage(File folder, OutputStream os)

			throws MakePluginPackageServiceException {

		Compress compress = new Compress();

		compress.compressPluginAsPackage(folder, os);

	}

    public void compressPackageIndex(File folder, OutputStream os)

        throws MakePluginPackageServiceException {

        Compress compress = new Compress();

        compress.compressPluginAsPackageIndex(folder, os);

    }

	public void readPackageInfo(File directory, PackageInfo installerInfo)

			throws InstallerInfoFileException {

		File installInfoFile = new File(directory + File.separator

 + getPackageInfoFileName());

		if (installInfoFile.exists()) {

			InstallerInfoFileReader reader = new InstallerInfoFileReader();

			reader.read(installerInfo, installInfoFile.getAbsolutePath());

		}

		if (installerInfo.getCode() == null) {

			installerInfo.setCode(directory.getName());

		}

		if (installerInfo.getName() == null) {

			installerInfo.setName(directory.getName());

		}

	}

    private String getPackageInfoFileName() {

        return InstallerProviderLocator.getProviderManager()

            .getPackageInfoFileName();

    }

    public void writePackageInfo(File directory, PackageInfo packageInfo)

			throws InstallerInfoFileException {

        writePackageInfoFile(directory, getPackageInfoFileName(), packageInfo);

	}

    public void writePackageInfoForIndex(File directory, PackageInfo packageInfo)

        throws InstallerInfoFileException {

        writePackageInfoFile(directory, getPackageInfoFileName() + ".index",

            packageInfo);

    }

    private void writePackageInfoFile(File directory, String fileName,

        PackageInfo installerInfo) throws InstallerInfoFileException {

        if (!directory.exists()) {

            throw new InstallerInfoFileException("The directory doesn't exist");

        }

        InstallerInfoFileWriter installerInfoFileWriter =

            new InstallerInfoFileWriter();

        installerInfoFileWriter.write(installerInfo, directory + File.separator

            + fileName);

    }

    public InputStream searchPackage(InputStream is, String zipEntry)

			throws InstallPackageServiceException {

		Decompress decompress = new Decompress();

		return decompress.searchPlugin(is, zipEntry);

	}

	public void readPackageSetInfo(InputStream is,

			List<PackageInfo> installerInfos,

			Map<PackageInfo, String> zipEntriesMap)

			throws InstallPackageServiceException {

		Decompress decompress = new Decompress();

		decompress

				.readPackageSetInstallInfos(is, installerInfos, zipEntriesMap);

		defaultSelectedPacketsIDs = decompress.getDefaultSelectedPackages();

	}

	public void readPackageInfo(InputStream is,

			List<PackageInfo> installerInfos,

			Map<PackageInfo, String> zipEntriesMap, String name)

			throws InstallPackageServiceException {

		Decompress decompress = new Decompress();

		decompress.readPackageInstallInfo(is, installerInfos, zipEntriesMap,

				name);

    }

    public List<String> getDefaultSelectedPackagesIDs() {

        return defaultSelectedPacketsIDs;

    }

}

/* 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.execution;

import org.gvsig.installer.lib.spi.execution.InstallPackageProvider;

import org.gvsig.tools.service.ServiceException;

/**

 * Exception thrown when the provider doesn't implements the

 * {@link InstallPackageProvider} interface

 * 

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

 */

public class NotInstallerExecutionProviderException extends ServiceException {

    private static final long serialVersionUID = -2159095938700834790L;

    private final static String MESSAGE_KEY = "_ProviderNotRegisteredException";

    private final static String MESSAGE_FORMAT =

        "The provider '%(providerName)' does not implement the InstallerExecutionProvider interface";

    /**

     * Creates a new {@link NotInstallerExecutionProviderException}.

     * 

     * @param name

     *            the name of the provider that doesn't implements the

     *            {@link InstallPackageProvider} interface

     */

    public NotInstallerExecutionProviderException(String name) {

        super(MESSAGE_FORMAT, MESSAGE_KEY, serialVersionUID);

        setValue("providerName", name);

    }

}

/* 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.execution;

import java.io.BufferedInputStream;

import java.io.File;

import java.io.FileFilter;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.io.InputStream;

import java.net.URL;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

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

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

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

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

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

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

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

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

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

import org.gvsig.installer.lib.spi.execution.InstallPackageProvider;

import org.gvsig.tools.service.Manager;

import org.gvsig.tools.service.ServiceException;

import org.gvsig.tools.task.SimpleTaskStatus;

/**

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

 */

public class DefaultInstallPackageService extends Thread implements

    InstallPackageService {

    private static final Logger LOG =

        LoggerFactory.getLogger(DefaultInstallPackageService.class);

    private Map<PackageInfo, File> packageInfoFileMap = null;

    private Map<PackageInfo, String> zipEntriesMap = null;

    private List<PackageInfo> packageInfos = null;

    private InstallerManager manager;

    private InstallPackageProviderServices installerProviderServices = null;

    public DefaultInstallPackageService(DefaultInstallerManager manager) {

        super();

        this.manager = manager;

        this.reset();

    }

    public void reset() {

        packageInfoFileMap = new HashMap<PackageInfo, File>();

        packageInfos = new ArrayList<PackageInfo>();

        zipEntriesMap = new HashMap<PackageInfo, String>();

        installerProviderServices =

            InstallerProviderLocator.getProviderManager()

                .createInstallerProviderServices();

    }

    public void installPackage(File applicationDirectory,

        PackageInfo packageInfo) throws InstallPackageServiceException {

        if (!applicationDirectory.exists()) {

            throw new InstallPackageServiceException(

                "application_directory_not_found");

        }

        if (!packageInfoFileMap.containsKey(packageInfo)) {

            throw new InstallPackageServiceException("package_not_found");

        }

        InstallPackageProvider installerExecutionProvider =

            createProvider(packageInfo);

        // Get the package or package set file

        File file = packageInfoFileMap.get(packageInfo);

        if (file == null) {

            if (packageInfo.getDownloadURL() == null) {

                throw new InstallPackageServiceException("package_not_found");

            }

            this.downloadPackage(packageInfo);

            file = packageInfoFileMap.get(packageInfo);

        }

        // Open and install the package or package set file

        try {

            InputStream packageStream;

            InputStream fis = new FileInputStream(file);

            InputStream bis = new BufferedInputStream(fis);

            if (isPackage(file)) {

                packageStream = bis;

            } else {

                if (!isPackageSet(file)) {

                    LOG.warn("Trying to install a package file ({0}) "

                        + "without a known file extension. Will try "

                        + "to install it as a package set", file);

                }

                packageStream =

                    installerProviderServices.searchPackage(bis, zipEntriesMap

                        .get(packageInfo));

            }

            installerExecutionProvider.install(applicationDirectory,

                packageStream, packageInfo);

            packageStream.close();

            if (bis != packageStream) {

                bis.close();

            }

            fis.close();

        } catch (FileNotFoundException e) {

            throw new InstallPackageServiceException("Package file not found: "

                + file);

        } catch (IOException e) {

            throw new InstallPackageServiceException(

                "IO error installing the package file: " + file, e);

        }

    }

    public void installPackage(File applicationDirectory, String packageCode)

        throws InstallPackageServiceException {

        PackageInfo packageInfo = getPackageInfo(packageCode);

        if (packageInfo == null) {

            throw new InstallPackageServiceException(

                "The package doesn't exist");

        }

        installPackage(applicationDirectory, packageInfo);

    }

    private InstallPackageProvider createProvider(PackageInfo packageInfo)

        throws InstallPackageServiceException {

        InstallerProviderManager installerProviderManager =

            (InstallerProviderManager) ((DefaultInstallerManager) manager)

                .getProviderManager();

        try {

            return installerProviderManager.createExecutionProvider(packageInfo

                .getType());

        } catch (ServiceException e) {

            throw new InstallPackageServiceException(

                "Error creating the provider", e);

        }

    }

    public PackageInfo getPackageInfo(int index) {

        if (index >= packageInfos.size()) {

            return null;

        }

        return packageInfos.get(index);

    }

    public PackageInfo getPackageInfo(String packageCode) {

        for (int i = 0; i < getPackageCount(); i++) {

            if (packageInfos.get(i).getCode().equals(packageCode)) {

                return packageInfos.get(i);

            }

        }

        return null;

    }

    public void addBundle(File bundle) throws InstallPackageServiceException {

        if (!bundle.exists()) {

            throw new InstallPackageServiceException(

                "Only an existing file is supported");

        }

        int packageInfoCount = packageInfos.size();

        FileInputStream fis;

        try {

            fis = new FileInputStream(bundle);

        } catch (FileNotFoundException e) {

            throw new InstallPackageServiceException("Package file not found: "

                + bundle, e);

        }

        BufferedInputStream bis = new BufferedInputStream(fis);

        if (isPackage(bundle)) {

            installerProviderServices.readPackageInfo(bis, packageInfos,

                zipEntriesMap, bundle.getName());

        } else {

            if (!isPackageSet(bundle)) {

                LOG.warn("Trying to add a package file ({0}) without a known "

                    + "file extension. Will try to add it as a package set",

                    bundle);

            }

            installerProviderServices.readPackageSetInfo(fis, packageInfos,

                zipEntriesMap);

        }

        try {

            bis.close();

            fis.close();

        } catch (IOException e) {

            LOG.warn("Error closing the input streams of the package file: "

                + bundle, e);

        }

        for (int i = packageInfoCount; i < packageInfos.size(); i++) {

            packageInfoFileMap.put(packageInfos.get(i), bundle);

        }

    }

    private boolean isPackageSet(File file) {

        return file.getName().endsWith(

            manager.getDefaultPackageSetFileExtension());

    }

    private boolean isPackage(File file) {

        return file.getName()

            .endsWith(manager.getDefaultPackageFileExtension());

    }

    public void addBundle(URL bundleURL) throws InstallPackageServiceException {

        File bundle = downloadFile(bundleURL, "packages.gvspki");

        addBundle(bundle);

    }

    private File downloadFile(URL bundleURL, String defaultFileName)

        throws InstallPackageServiceException {

        try {

            Download download = new Download();

            return download.downloadFile(bundleURL, defaultFileName);

        } catch (IOException e) {

            throw new InstallPackageServiceException(

                "Bundle file download error from URL: " + bundleURL, e);

        }

    }

    public void addBundlesFromDirectory(File directory)

        throws InstallPackageServiceException {

        if (!directory.isDirectory()) {

            throw new InstallPackageServiceException(

                "The application directory has to be a directory");

        }

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

        listRecursively(directory, new FileFilter() {

            private String packageExt =

                manager.getDefaultPackageFileExtension();

            private String packageSetExt =

                manager.getDefaultPackageSetFileExtension();

            public boolean accept(File file) {

                String name = file.getName().toLowerCase();

                return file.isDirectory() || name.endsWith(packageExt)

                    || name.endsWith(packageSetExt);

            }

        }, files);

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

            if (files.get(i).isFile()) {

                addBundle(files.get(i));

            }

        }

    }

    private void listRecursively(File fileOrDir, FileFilter filter, List<File> files) {

        files.add(fileOrDir);

        if (fileOrDir.isDirectory()) {

            File[] dirContents = fileOrDir.listFiles(filter);

            for (File f : dirContents) {

                listRecursively(f, filter, files); // Recursively list.

            }

        } else {

            files.add(fileOrDir);

        }

    }

    public int getPackageCount() {

        if (packageInfos == null) {

            return 0;

        }

        return packageInfos.size();

    }

    public Manager getManager() {

        return this.manager;

    }

    public void downloadPackage(PackageInfo packageInfo)

        throws InstallPackageServiceException {

        this.downloadPackage(packageInfo, null);

    }

    public void downloadPackage(PackageInfo packageInfo,

        SimpleTaskStatus taskStatus) throws InstallPackageServiceException {

        File file = packageInfo.downloadFile(taskStatus);

        this.packageInfoFileMap.put(packageInfo, file);

    }

    public List<String> getDefaultSelectedPackagesIDs() {

        return installerProviderServices.getDefaultSelectedPackagesIDs();

    }

}

/* 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