EarCleanTask.java

package org.objectweb.jonas_lib.deployment.work;

import java.io.File;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.Vector;

import org.objectweb.jonas.service.ServiceManager;
import org.objectweb.jonas.ear.EarService;

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

public class EarCleanTask extends AbsCleanTask {

    private static DeployerLog earDeployerLog = null;

    private static URL earAppsUrl = null;

    public EarCleanTask(URL earApps, DeployerLog earDeployerLog) {
        super();
        EarCleanTask.earAppsUrl = earApps;
        EarCleanTask.earDeployerLog = earDeployerLog;
    }

    protected boolean isValidLogEntry(LogEntry logEntry) throws CleanerException {
        String fTimeStamp = null;
        File earLogEntryFile = logEntry.getOriginal();
        String earLogEntryUnpackedDir = logEntry.getCopy().getName();
        //File dirEar = new File(earAppsUrl.getFile() + File.separator + earLogEntryUnpackedDir);

        getLogger().log(BasicLevel.DEBUG,
                "LogEntry <" + earLogEntryFile.getName() + "> exist :" + earLogEntryFile.exists());

        // if the file doesn't exist, return
        if (!earLogEntryFile.exists()) {
            return false;
        }

        //get the timestamp
        try {
            fTimeStamp = FileManager.fileToTimeStampDir(earLogEntryFile.toURL());
        } catch (FileManagerException efme) {
            throw new CleanerException("Can't get the timestamp of the file " + earLogEntryFile + " : "
                    + efme.getMessage());
        } catch (MalformedURLException mue) {
            throw new CleanerException("Can't get the timestamp of the file " + earLogEntryFile + " : "
                    + mue.getMessage());
        }

        getLogger().log(BasicLevel.DEBUG, "LogEntry fTimeStamp :" + fTimeStamp);
        getLogger().log(BasicLevel.DEBUG, "LogEntry isValid :" + fTimeStamp.equalsIgnoreCase(earLogEntryUnpackedDir));

        //compare
        return (fTimeStamp.equalsIgnoreCase(earLogEntryUnpackedDir));

    }

    protected void removeLogEntry(LogEntry logEntry) throws CleanerException {
        String earLogEntryUnpackedDir = logEntry.getCopy().getName();

        File dirEar = new File(earAppsUrl.getFile() + File.separator + earLogEntryUnpackedDir);

        removeRecursiveDirectory(dirEar);

        try {
            earDeployerLog.removeEntry(logEntry);
        } catch (DeployerLogException edle) {
            throw new CleanerException("Can't remove an entry" + edle.getMessage());
        }

    }

    protected Vector getLogEntries() {
        return earDeployerLog.getEntries();
    }

    protected boolean isDeployLogEntry(LogEntry logEntry) throws CleanerException {

        // get the ear service
        ServiceManager sm = null;

        try {
            sm = ServiceManager.getInstance();
        } catch (Exception e) {
            throw new CleanerException("Cannot get ServiceManager instance");
        }
        EarService earService = (EarService) sm.getEarService();

        // check if the ear file is deployed
        return earService.isEarDeployedByUnpackName(logEntry.getCopy().getName());
    }
}

---