/*
 * Copyright (c) 2003, 2018 Oracle and/or its affiliates. All rights reserved.
 *
 * This program and the accompanying materials are made available under the
 * terms of the Eclipse Public License v. 2.0, which is available at
 * http://www.eclipse.org/legal/epl-2.0.
 *
 * This Source Code may also be made available under the following Secondary
 * Licenses when the conditions for such availability set forth in the
 * Eclipse Public License v. 2.0 are satisfied: GNU General Public License,
 * version 2 with the GNU Classpath Exception, which is available at
 * https://www.gnu.org/software/classpath/license.html.
 *
 * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
 */

package devtests.deployment.util;

import java.io.*;
import java.util.*;
import java.net.*;
import java.beans.*;
import java.util.jar.Manifest;
import javax.enterprise.deploy.model.*;
import javax.enterprise.deploy.shared.factories.*;
import javax.enterprise.deploy.spi.factories.*;
import javax.enterprise.deploy.spi.*;
import javax.enterprise.deploy.spi.status.*;
import javax.enterprise.deploy.shared.ModuleType;

/**
 *
 * @author  administrator
 */
public class JSR88Deployer implements ProgressListener {

    private String host;
    private String port;
    private String user;
    private String password;
    private String uri;
    private DeploymentFactory deploymentFactory;
    private DeploymentManager dm;
    private Target[] targets;
    private final String J2EE_DEPLOYMENT_MANAGER =
                        "J2EE-DeploymentFactory-Implementation-Class";
    private static List systemApps = new ArrayList();
    
    /** Record all events delivered to this deployer (which is also a progress listener. */
    private Vector receivedEvents = new Vector();
    
    /** Record the TargetModuleIDs that resulted from the most recent operation. */
    private TargetModuleID [] mostRecentTargetModuleIDs = null;
    
    /** Creates a new instance of JSR88Deployer */
    public JSR88Deployer(String uri, String user, String password) {
        this.user = user;
        this.password = password;
        this.uri = uri;
        loadDeploymentFactory();
        loadSystemApps(); //system apps to be filtered

        log("Connecting using uri = " + uri + "; user = " + user + "; password = " + password);
        try {
            dm = DeploymentFactoryManager.getInstance().getDeploymentManager(uri, user, password);
        } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(-1);              
        }

        Target[] allTargets = dm.getTargets();
        if (allTargets.length == 0) {
            log("Can't find deployment targets...");
            System.exit(-1);              
        }
        
        // If test being run on EE, exclude the DAS server instance from the deploy targets
        String targetPlatform = System.getProperty("deploymentTarget");
        List filteredTargets = new ArrayList();
        if( ("SERVER".equals(targetPlatform)) || ("CLUSTER".equals(targetPlatform)) ) {
            for(int i=0; i<allTargets.length; i++) {
                if(allTargets[i].getName().equals("server")) {
                    continue;
                }
                filteredTargets.add(allTargets[i]);
            }
            targets = (Target[])(filteredTargets.toArray(new Target[filteredTargets.size()]));
        } else {
            targets = allTargets;
        }

        for(int i=0; i<targets.length; i++) {
            log("DBG : Target " + i + " -> " + targets[i].getName());
        }
    }

    private int waitTillComplete(ProgressObject po) throws Exception {
        DeploymentStatus deploymentStatus = null;
        do {
            /*
             *The progress object may return a DeploymentStatus object that is a snapshot of the
             *current status and will never change.  (The spec is unclear on this behavior.)  So
             *to be sure, get a new deployment status every time through the loop to be sure of
             *getting the up-to-date status.
             */
            deploymentStatus = po.getDeploymentStatus();
            Thread.currentThread().sleep(200);
        } while (!(deploymentStatus.isCompleted() || deploymentStatus.isFailed()));   
        log("Deployment status is " + deploymentStatus.getState().toString());
        if(deploymentStatus.isFailed())
                return(-1);
        return(0);
    }

    public ProgressObject deploy(File archive, File deploymentPlan,
                                boolean startByDefault, boolean useStream,
                                ModuleType type) 
        throws Exception {

        ProgressObject dpo = null;
        ProgressObject po = null;
        if (deploymentPlan == null || deploymentPlan.getName().equals("null")) {
            log("Warning, deploying with null deployment plan");
            if (useStream) {
                if (type == null) {
                    dpo = dm.distribute(targets, 
                                    new FileInputStream(archive.getAbsolutePath()),
                                    null);
                } else {
                    dpo = dm.distribute(targets, type,
                                    new FileInputStream(archive.getAbsolutePath()),
                                    null);
                }
            } else {
                dpo = dm.distribute(targets, archive, null);          
            }
        } else {
            if (useStream) {
                if (type == null) {
                    dpo = dm.distribute(targets, 
                                    new FileInputStream(archive.getAbsolutePath()),
                                    new FileInputStream(deploymentPlan.getAbsolutePath()));
                } else {
                    dpo = dm.distribute(targets, type,
                                    new FileInputStream(archive.getAbsolutePath()),
                                    new FileInputStream(deploymentPlan.getAbsolutePath()));
                }
            } else {
                dpo = dm.distribute(targets, archive, deploymentPlan);          
            }
        }            
        if (dpo!=null) {
            dpo.addProgressListener(this);
            if(waitTillComplete(dpo) != 0) {
                log("DEPLOY Action Failed");
                return(null);
            }

            TargetModuleID[] targetModuleIDs = dpo.getResultTargetModuleIDs();        
            this.mostRecentTargetModuleIDs = targetModuleIDs;
            dumpResultModuleIDs("Deployed " , dpo);

            if (startByDefault) {
                log("STARTINNG... " + targetModuleIDs);
                po = dm.start(targetModuleIDs);
                if (po!=null) {
                    po.addProgressListener(this);
                    if(waitTillComplete(po) != 0) {
                        log("START Action Failed");
                        return(null);
                    }
                }
                return po;
            }
        }
        return(dpo);
    }

    public ProgressObject redeploy(String moduleID, File archive,
                                File deploymentPlan, boolean useStream) throws Exception {

        TargetModuleID[] list = null;
        if (moduleID == null) { //redeploy all but system apps
            throw new UnsupportedOperationException("DO NOT SUPPORT REDEPLOY MULTIPLE APPS");
        } else {
            list = findApplication(moduleID, null);
        }

        TargetModuleID[] modules = filterSystemApps(list);
        if (modules != null && modules.length > 0) {
            for (int i = 0; i < modules.length; i++) {
                log("REDEPLOYING... " + modules[i]);
            }
        }

        ProgressObject dpo = null;
        if (deploymentPlan == null || deploymentPlan.getName().equals("null")) {
            log("Warning, redeploying with null deployment plan");
            if (useStream) {            
                dpo = dm.redeploy(modules, 
                                    new FileInputStream(archive.getAbsolutePath()),
                                    null);
            } else {
                dpo = dm.redeploy(modules, archive, null);
            }
        } else {
            if (useStream) {            
                dpo = dm.redeploy(modules, 
                                    new FileInputStream(archive.getAbsolutePath()),
                                    new FileInputStream(deploymentPlan.getAbsolutePath()));
            } else {
                dpo = dm.redeploy(modules, archive, deploymentPlan);          
            }
        }            
        if (dpo!=null) {
            dpo.addProgressListener(this);
            if(waitTillComplete(dpo) != 0) {
                log("REDEPLOY Action Failed");
                return(null);
            }

            TargetModuleID[] targetModuleIDs = dpo.getResultTargetModuleIDs();        
            this.mostRecentTargetModuleIDs = targetModuleIDs;
            dumpResultModuleIDs("Redeployed " , dpo);
        }
        return(dpo);
    }

    public ProgressObject stop(String moduleID) throws Exception {
        TargetModuleID[] list = null;
        if (moduleID == null) { //stop all but system apps
            list = getAllApplications(Boolean.TRUE);
        } else {
            list = findApplication(moduleID, Boolean.TRUE);
        }

        ProgressObject dpo = null;
        TargetModuleID[] modules = filterSystemApps(list);
        if (modules != null && modules.length > 0) {
            for (int i = 0; i < modules.length; i++) {
                log("STOPPING... " + modules[i]);
            }
            dpo = dm.stop(modules);
            if (dpo!=null) {
                dpo.addProgressListener(this);
                if(waitTillComplete(dpo) != 0) {
                    log("STOP Action Failed");
                    return(null);
                }
                this.mostRecentTargetModuleIDs = dpo.getResultTargetModuleIDs();
            }
        }
        return(dpo);
    }

    /**
     *Starts an application, with an option of waiting between the time the operation is requested
     *and the time the deployer is added as a listener.  This option helps with the test for race
     *conditions involved with managing the list of listeners and the list of delivered events.
     */
    public ProgressObject start(String moduleID, int delayBeforeRegisteringListener) throws Exception {
        TargetModuleID[] list = null;
        if (moduleID == null) { //start all but system apps
            list = getAllApplications(Boolean.FALSE);
        } else {
            list = findApplication(moduleID, Boolean.FALSE);
        }

        TargetModuleID[] modules = filterSystemApps(list);
        ProgressObject dpo = null;
        if (modules != null && modules.length > 0) {
            for (int i = 0; i < modules.length; i++) {
                log("STARTINNG... " + modules[i]);
            }
            dpo = dm.start(modules);
            if (delayBeforeRegisteringListener > 0) {
                try {
                    log("Pausing before adding self as a progress listener");
                    Thread.currentThread().sleep(delayBeforeRegisteringListener);
                } catch (InterruptedException ie) {
                    throw new RuntimeException(this.getClass().getName() + " was interrupted sleeping before adding itself as a progresslistener", ie);
                }
            }
            if (dpo!=null) {
                dpo.addProgressListener(this);
                if (delayBeforeRegisteringListener > 0) {
                    log("Now registered as a progress listener");
                }
                if(waitTillComplete(dpo) != 0) {
                    log("START Action Failed");
                    return(null);
                }
                this.mostRecentTargetModuleIDs = dpo.getResultTargetModuleIDs();
            }
        }
        return(dpo);
    }

    public ProgressObject start(String moduleID) throws Exception {
        return start(moduleID, 0);
    }

    public ProgressObject undeploy(String moduleID) throws Exception {
        TargetModuleID[] list = null;
        //log ("000 trying to undeploy moduleID = " + moduleID);
        if (moduleID == null) { //undeploy all but system apps
            list = getAllApplications(null);
        } else {
            list = findApplication(moduleID, null);
        }

        ProgressObject dpo = null;
        TargetModuleID[] modules = filterSystemApps(list);
        if (modules != null && modules.length > 0) {
            for (int i = 0; i < modules.length; i++) {
                log("UNDEPLOYING... " + modules[i]);
            }
            dpo = dm.undeploy(modules);
            if (dpo!=null) {
                dpo.addProgressListener(this);
                if(waitTillComplete(dpo) != 0) {
                    log("UNDEPLOY Action Failed");
                    return(null);
                }
                this.mostRecentTargetModuleIDs = dpo.getResultTargetModuleIDs();
            }
        }
        return(dpo);
    }

    protected void dumpResultModuleIDs(String prefix, ProgressObject po) {
        TargetModuleID[] targetModuleIDs = po.getResultTargetModuleIDs();
	dumpModulesIDs(prefix, targetModuleIDs);
    }

    protected void dumpModulesIDs(String prefix, TargetModuleID[] targetModuleIDs) {
        for (int i=0;i<targetModuleIDs.length;i++) {            
            dumpModulesIDs(prefix, targetModuleIDs[i]);            
        }
    }
    
    protected void dumpModulesIDs(String prefix, TargetModuleID targetModuleID) {
        log(prefix + targetModuleID);
        TargetModuleID[] subs = targetModuleID.getChildTargetModuleID();
        if (subs!=null) {
            for (int i=0;i<subs.length;i++) {
                log(" Child " + i + " = " + subs[i]);
            }
        }
    }

    public TargetModuleID[] getApplications(ModuleType moduleType, Boolean running) 
        throws Exception {
        TargetModuleID[] modules = null;
        if (running==null) {
            modules = dm.getAvailableModules(moduleType, targets);
        } else if (running.booleanValue()) {
            modules = dm.getRunningModules(moduleType, targets);
        } else {
            modules = dm.getNonRunningModules(moduleType, targets);
        }

        return modules;
    }

    public TargetModuleID[] getAllApplications(Boolean running) 
        throws Exception {
        //log("222. getAllApplications, running = " + running);
        TargetModuleID[] ears = getApplications(ModuleType.EAR, running);
        TargetModuleID[] wars = getApplications(ModuleType.WAR, running);
        TargetModuleID[] cars = getApplications(ModuleType.CAR, running);
        TargetModuleID[] ejbs = getApplications(ModuleType.EJB, running);
        TargetModuleID[] rars = getApplications(ModuleType.RAR, running);

        List list = new ArrayList();
        for (int i = 0; i < ears.length; i++) { list.add(ears[i]); }
        for (int i = 0; i < wars.length; i++) { list.add(wars[i]); }
        for (int i = 0; i < cars.length; i++) { list.add(cars[i]); }
        for (int i = 0; i < ejbs.length; i++) { list.add(ejbs[i]); }
        for (int i = 0; i < rars.length; i++) { list.add(rars[i]); }
    
        TargetModuleID[] results = new TargetModuleID[list.size()];
        for (int i = 0; i < list.size(); i++) { 
            results[i] = (TargetModuleID) list.get(i);
        }
        return results;
    }

    protected TargetModuleID[] findApplication(String moduleID, ModuleType moduleType, Boolean running) 
        throws Exception {
        /*
         *The DeploymentFacility requires that start, stop, redeploy, and undeploy requests
         *operate on the same set of targets that the original deployment did.  As written currently, this test
         *class always deploys to all available targets so the other functions should also
         *apply to all available targets.
         */
        TargetModuleID[] list = getApplications(moduleType, running);
        return filterTargetModuleIDsByModule(list, moduleID);
    }

    protected TargetModuleID[] findApplication(String moduleID, Boolean running) 
        throws Exception {
        //log("111 trying to get everything, moduleid = " + moduleID + "; boolean = " + running);
        TargetModuleID[] list = getAllApplications(running);
        return filterTargetModuleIDsByModule(list, moduleID);
    }

    /**
     *Filter an array of TargetModuleID, keeping only those that match the specified module ID.
     *@param tmids the array of TargetModuleID to be filtered
     *@param moduleID the name of the module of interest
     *@return new TargetModuleID array, containing only the elements from the original array that match the module ID
     */
    protected TargetModuleID[] filterTargetModuleIDsByModule(TargetModuleID [] tmids, String moduleID) {
        List tmidsToUse = new ArrayList();
        /*
         *Add to the vector of TMIDs each TMID from getApplications that also matches the
         *module ID.
         */
        for (int i = 0; i < tmids.length; i++) {
            if (moduleID.equals(tmids[i].getModuleID())) {
                tmidsToUse.add(tmids[i]);
            }
        }
        return (TargetModuleID [])(tmidsToUse.toArray(new TargetModuleID[tmidsToUse.size()]));
    }
    
    public void listApplications(ModuleType moduleType, Boolean running) 
        throws Exception {
        TargetModuleID[] modules = getApplications(moduleType, running); 
        if (modules == null) {
        } else {
            for (int i = 0; i < modules.length; i++) {
                if (running==null) {
                    dumpModulesIDs("    AVAILABLE ", modules[i]);
                } else if (running.booleanValue()) {
                    dumpModulesIDs("    RUNNING ", modules[i]);
                } else {
                    dumpModulesIDs("    NOT RUNNING ", modules[i]); 
                }
            }
        }
    }
    
    private void invokeAppClient(ProgressObject po, TargetModuleID targetModuleID) {
        TargetModuleID[] subs = targetModuleID.getChildTargetModuleID();   
        if (subs==null) {
            return;
        }
        for (int i=0;i<subs.length;i++) {
            if (subs[i].getModuleID().indexOf("client")!=-1) {
                log(" App Client child " + subs[i]);
                ClientConfiguration cc = po.getClientConfiguration(subs[i]);
                try {
                    cc.execute();
                } catch(Throwable t) {
                    t.printStackTrace();
                }
            }
        }
    }    

    
    public static void main(String[] args) {

        int finalExitValue = 0;

        if (args.length == 0 || "help".equals(args[0])) { 
            usage(); 
            System.exit(1);
        }
        if (args.length < 5) {
            usage(); 
            System.exit(1);
        }

        JSR88Deployer deployer = new JSR88Deployer(args[1], args[2], args[3]);
        if ("deploy".equals(args[0]) || "deploy-stream".equals(args[0])) {
            if (args.length < 6) { 
                usage(); 
                System.exit(1);
            }
            boolean useStream = "deploy-stream".equals(args[0]);
            boolean startByDefault = "true".equals(args[4]);
            java.io.File inputFile = new java.io.File(args[5]);
            if (!inputFile.exists()) {
                error("File not found : " + inputFile.getPath());
                System.exit(1);
            }
            File deploymentFile = null;
            if (args.length > 6) {
                deploymentFile = new File(args[6]);
                if (!args[6].equals("null")) {
                    if (!deploymentFile.exists()) {
                        error("Deployment File not found : " + deploymentFile.getPath());
                        System.exit(1);
                    }
                }
            }
            try {
                log("Deploying " + inputFile + " plan: " + deploymentFile);
                if(deployer.deploy(inputFile, deploymentFile,
                                        startByDefault, useStream, null) == null)
                    finalExitValue = -1;
            } catch(Exception e) {
                e.printStackTrace();
                System.exit(1);
            }
        } else if ("deploy-stream-withtype".equals(args[0])) {
            if (args.length < 7) { 
                usage(); 
                System.exit(1);
            }
            boolean useStream = true;
            boolean startByDefault = "true".equals(args[4]);
            java.io.File inputFile = new java.io.File(args[5]);
            if (!inputFile.exists()) {
                error("File not found : " + inputFile.getPath());
                System.exit(1);
            }
            ModuleType t = 
                ModuleType.getModuleType((new Integer(args[6])).intValue());
            File deploymentFile = null;
            if (args.length > 7) {
                deploymentFile = new File(args[7]);
                if (!args[7].equals("null")) {
                    if (!deploymentFile.exists()) {
                        error("Deployment File not found : " + deploymentFile.getPath());
                        System.exit(1);
                    }
                }
            }
            try {
                log("Deploying " + inputFile + " plan: " + deploymentFile);
                if(deployer.deploy(inputFile, deploymentFile,
                                        startByDefault, useStream, t) == null)
                    finalExitValue = -1;
            } catch(Exception e) {
                e.printStackTrace();
                System.exit(1);
            }
        } else if ("list".equals(args[0])) {

            if (args.length != 5) { 
                usage(); 
                System.exit(0);
            }

            try {
                if ("all".equals(args[4])) {
                    deployer.listApplications(ModuleType.EAR, null);
                    deployer.listApplications(ModuleType.WAR, null);
                    deployer.listApplications(ModuleType.EJB, null);
                    deployer.listApplications(ModuleType.CAR, null);
                    deployer.listApplications(ModuleType.RAR, null);
                } else if ("running".equals(args[4])) {
                    deployer.listApplications(ModuleType.EAR, Boolean.TRUE);
                    deployer.listApplications(ModuleType.WAR, Boolean.TRUE);
                    deployer.listApplications(ModuleType.EJB, Boolean.TRUE);
                    deployer.listApplications(ModuleType.CAR, Boolean.TRUE);
                    deployer.listApplications(ModuleType.RAR, Boolean.TRUE);
                } else if ("nonrunning".equals(args[4])) {
                    deployer.listApplications(ModuleType.EAR, Boolean.FALSE);
                    deployer.listApplications(ModuleType.WAR, Boolean.FALSE);
                    deployer.listApplications(ModuleType.EJB, Boolean.FALSE);
                    deployer.listApplications(ModuleType.CAR, Boolean.FALSE);
                    deployer.listApplications(ModuleType.RAR, Boolean.FALSE);
                } else {
                    usage();
                    finalExitValue = 1;
                }
            } catch (Exception e) {
                e.printStackTrace();
                System.exit(-1);
            }
        } else if ("redeploy".equals(args[0]) || "redeploy-stream".equals(args[0])) {
            if (args.length < 6) { 
                usage(); 
                System.exit(-1);
            }
            
            boolean useStream = "redeploy-stream".equals(args[0]);
            java.io.File inputFile = new java.io.File(args[5]);
            if (!inputFile.exists()) {
                error("File not found : " + inputFile.getPath());
                System.exit(1);
            }
            File deploymentFile = null;
            if (args.length > 6) {
                deploymentFile = new File(args[6]);
                if (!args[6].equals("null")) {
                    if (!deploymentFile.exists()) {
                        error("Deployment File not found : " + deploymentFile.getPath());
                        System.exit(1);
                    }
                }
            }
            try {
                log("Redeploying " + inputFile + " plan: " + deploymentFile);
                if ("all".equals(args[4])) {
                    if(deployer.redeploy(null, inputFile, deploymentFile, useStream) == null)
                        finalExitValue = -1;
                } else {
                    if(deployer.redeploy(args[4], inputFile, deploymentFile, useStream) == null)
                        finalExitValue = -1;
                }
            } catch(Exception e) {
                e.printStackTrace();
                System.exit(1);
            }
        } else {
            if (args.length != 5) { 
                usage(); 
                System.exit(1);
            }

            try {
                if ("all".equals(args[4])) {
                    if ("undeploy".equals(args[0])) {
                        if(deployer.undeploy(null) == null)
                            finalExitValue = -1;
                    } else if ("start".equals(args[0])) {
                        if(deployer.start(null) == null)
                            finalExitValue = -1;
                    } else if ("stop".equals(args[0])) {
                        if(deployer.stop(null) == null)
                            finalExitValue = -1;
                    } else {
                        usage();
                        finalExitValue = 1;
                    }
                } else {
                    if ("undeploy".equals(args[0])) {
                        if(deployer.undeploy(args[4]) == null)
                            finalExitValue = -1;
                    } else if ("start".equals(args[0])) {
                        if(deployer.start(args[4]) == null)
                            finalExitValue = -1;
                    } else if ("stop".equals(args[0])) {
                        if(deployer.stop(args[4]) == null)
                            finalExitValue = -1;
                    } else {
                        usage();
                        finalExitValue = 1;
                    }
                }
            } catch (Exception e) {
                e.printStackTrace();
                System.exit(-1);
            }
        }
        System.exit(finalExitValue);
    }
    
    /** Invoked when a deployment progress event occurs.
     *
     * @param event the progress status event.
     */
    public void handleProgressEvent(ProgressEvent event) {
        DeploymentStatus ds = event.getDeploymentStatus();
        System.out.println("Received Progress Event state " + ds.getState() + " msg = " + ds.getMessage());
        TargetModuleID tmid = event.getTargetModuleID();
        System.out.println("Received Progress Event target module id " + tmid.getModuleID());
        /*
         *Add this event to the vector collecting them.
         */
        this.receivedEvents.add(event);
    }

    /**
     *Report all the events received by this deployer.
     *
     *@return array of Objects containing the received events
     */
    public ProgressEvent [] getReceivedEvents() {
        ProgressEvent [] answer = new ProgressEvent[this.receivedEvents.size()];
        return (ProgressEvent []) this.receivedEvents.toArray(answer);
    }
    
    /**
     *Clear the collection of received events recorded by this deployer.
     */
    public void clearReceivedEvents() {
        this.receivedEvents.clear();
    }

    public TargetModuleID [] getMostRecentTargetModuleIDs() {
        return this.mostRecentTargetModuleIDs;
    }
    
    public void clearMostRecentTargetModuleIDs() {
        this.mostRecentTargetModuleIDs = null;
    }
    
    private void loadDeploymentFactory() {
        try {
            File file = new File(System.getProperty("com.sun.aas.installRoot")
                + File.separator+ "lib" + File.separator + "deployment"
                + File.separator + "sun-as-jsr88-dm.jar");

            Manifest mf = new java.util.jar.JarFile(file).getManifest();
            String className = mf.getMainAttributes().getValue(J2EE_DEPLOYMENT_MANAGER);
            URL[] urls = new URL[]{file.toURL()};
            URLClassLoader urlClassLoader = new java.net.URLClassLoader(urls, getClass().getClassLoader());

            Class factory = null;
            try {
                factory=urlClassLoader.loadClass(className);
            } catch (ClassNotFoundException cnfe) {
                cnfe.printStackTrace();
            }   

            Object df = null;
            try {   
                df = factory.newInstance();
            } catch (Exception ie) {
                ie.printStackTrace();
            }
            if (df instanceof DeploymentFactory) {
                DeploymentFactoryManager.getInstance().registerDeploymentFactory((DeploymentFactory) df);
            } else {
                System.exit(-1);
            }  

        } catch (Exception ex) {
            log("Failed to load the deployment factory.");
            ex.printStackTrace();
            System.exit(-1);
        }
    }

    private static void usage() {
        System.out.println("Usage: command <JSR88.URI> <admin-user> <admin-password> [command-parameters]");
        System.out.println("    where command is one of [deploy<-stream> | redeploy<-stream> | undeploy | start | stop | list]");
        System.out.println("    where <JSR88.URI> is: deployer:Sun:AppServer::${admin.host}:${admin.port} for PE");
        System.out.println("    where <JSR88.URI> is: deployer:Sun:AppServer::${admin.host}:${admin.port}:https for EE");
        System.out.println("    where command-parameters are as follows");
        System.out.println("      deploy: <startByDefault> <archiveFile> [<deploymentFile>]");
        System.out.println("      deploy-stream: <startByDefault> <archiveFile> [<deploymentFile>]");
        System.out.println("      deploy-stream-withtype: <startByDefault> <archiveFile> <moduleType> [<deploymentFile>]");
        System.out.println("      redeploy: <moduleID> <archiveFile> [<deploymentFile>]");
        System.out.println("      redeploy-stream: <moduleID> <archiveFile> [<deploymentFile>]");
        System.out.println("      undeploy: [all | moduleID]");
        System.out.println("      start: [all | moduleID]");
        System.out.println("      stop: [all | moduleID]");
        System.out.println("      list: [all | running | nonrunning]");
    }

    public static void log(String message) {
        System.out.println("[JSR88Deployer]:: " + message);
    }

    public static void error(String message) {
        System.err.println("[JSR88Deployer]:: " + message);
    }
    
    private void loadSystemApps() {
        systemApps.add("MEjbApp");
        systemApps.add("__ejb_container_timer_app");
        systemApps.add("adminapp");
        systemApps.add("admingui");
        systemApps.add("com_sun_web_ui");
    }

    private TargetModuleID[] filterSystemApps(TargetModuleID[] list) {

        //Comment out the following logic as we will move to use the MBean
        //that returns only non-system apps.
/*
        List l = new ArrayList();
        for (int i = 0; i < list.length; i++) {
            String moduleID = list[i].getModuleID();
            log("found module = " + moduleID);
            if (!systemApps.contains(moduleID)) {
                l.add(list[i]);
            }
        }

        TargetModuleID[] ids = new TargetModuleID[l.size()];
        for (int i = 0; i < l.size(); i++) {
            ids[i] = (TargetModuleID) l.get(i);
        }
        return ids;
*/
        return list;
    }
}