ArchiveStorer.java

package org.objectweb.jonas_lib.genbase.utils;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Vector;

import org.w3c.dom.Document;

import org.objectweb.jonas_lib.I18n;
import org.objectweb.jonas_lib.genbase.GenBaseException;
import org.objectweb.jonas_lib.genbase.archive.J2EEArchive;
import org.objectweb.jonas_lib.xml.XMLSerializer;

import org.objectweb.jonas.common.Log;

import org.objectweb.util.monolog.api.BasicLevel;
import org.objectweb.util.monolog.api.Logger;

public abstract class ArchiveStorer {

    public static final int MAX_BUFFER_SIZE = 1024;

    private static I18n i18n = I18n.getInstance(ArchiveStorer.class);

    private static Logger logger = Log.getLogger(Log.JONAS_GENBASE_PREFIX);

    private J2EEArchive archive;

    private List already;

    private String out = "";

    public ArchiveStorer(J2EEArchive archive) {
        this.archive = archive;
        already = new Vector();
        // we must use Manifestof the J2EEArchive
        already.add(convertName("META-INF/MANIFEST.MF"));
    }

    protected static void fill(InputStream is, OutputStream os) throws IOException {
        byte[] buffer = new byte[MAX_BUFFER_SIZE];
        int read;

        while ((read = is.read(buffer, 0, MAX_BUFFER_SIZE)) != -1) {
            os.write(buffer, 0, read);
        }
    }

    protected abstract void addFile(String name) throws IOException;

    protected abstract String convertName(String name);

    protected abstract OutputStream getOutputStream(String name) throws IOException;

    public void store() throws GenBaseException {

        logger.log(BasicLevel.DEBUG, "Writing '" + out + "' ...");

        for (Iterator i = archive.getContainedFiles().iterator(); i.hasNext();) {
            String name = (String) i.next();

            try {
                if (!archive.omit(convertName(name)) && !already.contains(convertName(name))) {

                    addFile(name);
                    already.add(convertName(name));
                }
            } catch (IOException ioe) {
                String err = i18n.getMessage("ArchiveStorer.store.addFile", name);
                throw new GenBaseException(err, ioe);
            }
        }

        // add Descriptors
        Map descs = archive.getDescriptors();

        for (Iterator i = descs.keySet().iterator(); i.hasNext();) {
            String name = (String) i.next();

            try {
                XMLSerializer ser = new XMLSerializer((Document) descs.get(name));
                ser.serialize(getOutputStream(name));
            } catch (IOException ioe) {
                String err = i18n.getMessage("ArchiveStorer.store.serialize", name);
                throw new GenBaseException(err, ioe);
            }
        }
    }
    public static I18n getI18n() {
        return i18n;
    }

    public J2EEArchive getArchive() {
        return archive;
    }

    public void setOut(String out) {
        this.out = out;
    }
}

---