/*
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
 *
 * Copyright 2010 Sun Microsystems, Inc. All rights reserved.
 *
 * The contents of this file are subject to the terms of either the GNU
 * General Public License Version 2 only ("GPL") or the Common Development
 * and Distribution License("CDDL") (collectively, the "License").  You
 * may not use this file except in compliance with the License. You can obtain
 * a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html
 * or glassfish/bootstrap/legal/LICENSE.txt.  See the License for the specific
 * language governing permissions and limitations under the License.
 *
 * When distributing the software, include this License Header Notice in each
 * file and include the License file at glassfish/bootstrap/legal/LICENSE.txt.
 * Sun designates this particular file as subject to the "Classpath" exception
 * as provided by Sun in the GPL Version 2 section of the License file that
 * accompanied this code.  If applicable, add the following below the License
 * Header, with the fields enclosed by brackets [] replaced by your own
 * identifying information: "Portions Copyrighted [year]
 * [name of copyright owner]"
 *
 * Contributor(s):
 *
 * If you wish your version of this file to be governed by only the CDDL or
 * only the GPL Version 2, indicate your decision by adding "[Contributor]
 * elects to include this software in this distribution under the [CDDL or GPL
 * Version 2] license."  If you don't indicate a single choice of license, a
 * recipient has the option to distribute your version of this file under
 * either the CDDL, the GPL Version 2 or to extend the choice of license to
 * its licensees as provided above.  However, if you add GPL Version 2 code
 * and therefore, elected the GPL Version 2 license, then the option applies
 * only if the new code is made subject to such option by the copyright
 * holder.
 */
package admin;

import java.io.*;

/**
 *
 * @author Jennifer Chou
 */
public class ManualSyncTest extends AdminBaseDevTest {

    @Override
    protected String getTestDescription() {
        return "Tests Manual Sync support.";
    }

    public ManualSyncTest() {
        host = "localhost";
        glassFishHome = getGlassFishHome();
        domainHome = new File(glassFishHome, "domains/domain1");
        // it does NOT need to exist -- do not insist!
        nodeDir = new File(glassFishHome, "nodes");
        instancesHome = new File(nodeDir, host);
        syncDir = new File(domainHome, "sync");
        curDir = new File(System.getProperty("user.dir"));

    }

    public static void main(String[] args) {
        new ManualSyncTest().runTests();
    }

    private void runTests() {
        startDomain();
        testExport();
        testRetrieve();
        testExportCluster();
        testImport();
        testImportDasOffline();
        testImportNode();
        testImportNodeDir();
        testEndtoEnd();
        stopDomain();
        stat.printSummary();
    }

    private void testExport() {
        String i ="noinstance";
        report("export-sync-bundle-"+i, !asadmin("export-sync-bundle", "--target", i));

        /*export default bundle*/
        i ="iexportdefbun";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);
        
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        report("delete-syncdir-"+i, syncDir.delete());

        /*export my bundle*/
        i ="iexportmybun";
        bundleName = i + "-my-bundle.zip";
        File mybundleDir = new File(glassFishHome, "mybundles");
        bundle = new File(mybundleDir, bundleName);
        
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, bundle.getPath()));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        report("delete-mybundledir-"+i, mybundleDir.delete());

        /*export default bundle to my dir*/
        i ="iexportmydir";
        bundleName = i + "-sync-bundle.zip";
        mybundleDir = new File(glassFishHome, "mybundles");
        mybundleDir.mkdir(); //mybundles directory must exist, otherwise it will be exported to a file called 'mybundles'
        bundle = new File(mybundleDir, bundleName);

        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, mybundleDir.getPath()));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        report("delete-mybundledir-"+i, mybundleDir.delete());

        /*export default bundle to curr dir - happens to be domains/domain1/config for glassfish */
        i ="iexportcurrdir";
        bundleName = i + "-my-bundle.zip";
        bundle = new File(domainHome, "config/" + bundleName);

        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, bundleName));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());

        //AsadminReturn ret = asadminWithOutput("_get-host-and-port", "--virtualserver", "jenvs");
        //boolean success = ret.outAndErr.indexOf("1010") >= 0;
        //report("port-set-create-domain-sysprop", success);

    }

    private void testRetrieve() {
        String i ="iretrievecurrdir";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(curDir, bundleName);
        
        /*retrieve bundle in current working directory */
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, "--retrieve", "true"));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        
        /*retrieve my bundle*/
        i ="iretrievemybun";
        bundleName = i + "-my-bundle.zip";
        bundle = new File(glassFishHome, bundleName); //parent dir must exist, if it doesn't exist will put in the next parent that exists

        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, "--retrieve", "true", bundle.getPath()));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());

        /*export default bundle to my dir*/
        i ="iretrievemydir";
        bundleName = i + "-sync-bundle.zip";
        bundle = new File(glassFishHome, bundleName);

        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i, glassFishHome.getPath()));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());

    }

    private void testExportCluster() {
        /*export using cluster target*/
        String i ="iexport1";
        String c = "cexport";
        String bundleName = c + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);

        report("create-cluster-"+c, asadmin("create-cluster", c));
        report("export-sync-bundle-bad"+i, !asadmin("export-sync-bundle", "--target", c));
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", "--cluster", c, i));
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", c));
        report("check-bundle-"+i, bundle.isFile());

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-instance-"+c, asadmin("delete-cluster", c));
        report("delete-bundle-"+c, bundle.delete());
        report("delete-syncdir-"+c, syncDir.delete());
    }

    private void testImport() {
        String i ="iimportnobundle";
        File bundle = new File("nosuchbundle");
        report("import-sync-bundle-"+i, !asadmin("import-sync-bundle", "--file", bundle.getPath(), i));

        /*import default bundle*/
        i ="iimportdefbun";
        String bundleName = i + "-sync-bundle.zip";
        bundle = new File(syncDir, bundleName);
        File dasDomainXml = new File(domainHome, "config/domain.xml");
        File instDomainXml = new File(glassFishHome, "nodes/localhost/"+i+"/config/domain.xml");

        report("check-dasdomainxml-"+i, dasDomainXml.exists());
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        long dasDomainXmlTS = dasDomainXml.lastModified();
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-bundle-"+i, bundle.isFile());
        report("import-sync-bundle-"+i, asadmin("import-sync-bundle", "--file", bundle.getPath(), i));
        String s = get("servers.server."+i+".property.rendezvousOccurred");
        report("check-rendezvous-"+i, s.equals("true"));
        report("check-domainxml-"+i, instDomainXml.exists());
        long instDomainXmlTS = instDomainXml.lastModified();
        report("check-timestamp-"+i, dasDomainXmlTS == instDomainXmlTS);

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        report("delete-syncdir-"+i, syncDir.delete());
    }

    private void testImportDasOffline() {
        String i ="iimportdasoff";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);
        File dasDomainXml = new File(domainHome, "config/domain.xml");
        File instDomainXml = new File(glassFishHome, "nodes/localhost/"+i+"/config/domain.xml");

        report("check-dasdomainxml-"+i, dasDomainXml.exists());
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        long dasDomainXmlTS = dasDomainXml.lastModified();
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-bundle-"+i, bundle.isFile());

        /*import bundle with DAS offline */
        stopDomain();

        report("import-sync-bundle-"+i, asadmin("import-sync-bundle", "--file", bundle.getPath(), i));
        
        report("check-domainxml-"+i, instDomainXml.exists());
        long instDomainXmlTS = instDomainXml.lastModified();
        report("check-timestamp-"+i, dasDomainXmlTS == instDomainXmlTS);

        startDomain();

        String s = get("servers.server."+i+".property.rendezvousOccurred");
        report("check-rendezvous-"+i, s == null);

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        report("delete-bundle-"+i, bundle.delete());
        report("delete-syncdir-"+i, syncDir.delete());
    }

    private void testImportNode() {
        String i ="iimportnode";
        String node = "nodeimport";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);
        File dasDomainXml = new File(domainHome, "config/domain.xml");
        File instDomainXml = new File(glassFishHome, "nodes/"+node+"/"+i+"/config/domain.xml");
        File nodeDirChild = new File(nodeDir, node);
        File dasFile = new File(nodeDirChild, "agent/config/das.properties");

        report("check-dasdomainxml-"+i, dasDomainXml.exists());
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        long dasDomainXmlTS = dasDomainXml.lastModified();
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-bundle-"+i, bundle.isFile());
        
        report("import-sync-bundle-"+i, asadmin("import-sync-bundle", "--file", bundle.getPath(), "--node", node, i));

        report("check-domainxml-"+i, instDomainXml.exists());
        long instDomainXmlTS = instDomainXml.lastModified();
        report("check-timestamp-"+i, dasDomainXmlTS == instDomainXmlTS);

        report("check-das-properties-"+i, dasFile.exists());

        String s = get("servers.server."+i+".property.rendezvousOccurred");
        report("check-rendezvous-"+i, s.equals("true"));

        report("import-sync-bundle-specifynode", !asadmin("import-sync-bundle", "--file", bundle.getPath(), i));

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        bundle.delete();
        syncDir.delete();
        deleteDirectory(nodeDirChild);
    }

    private void testImportNodeDir() {
        String i ="iimportnodedir";
        String node = "nodeimport";
        String myNodeDir = "mynodes";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);
        File dasDomainXml = new File(domainHome, "config/domain.xml");
        File nodeDirParent = new File(glassFishHome, myNodeDir);
        File nodeDirChild = new File(nodeDirParent, node);
        File instDomainXml = new File(nodeDirChild, i+"/config/domain.xml");
        File dasFile = new File(nodeDirChild, "agent/config/das.properties");

        report("check-dasdomainxml-"+i, dasDomainXml.exists());
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", i));
        long dasDomainXmlTS = dasDomainXml.lastModified();
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-bundle-"+i, bundle.isFile());

        report("import-sync-bundle-"+i, asadmin("import-sync-bundle", "--file", bundle.getPath(), "--node", node, "--nodedir", nodeDirParent.getPath(), i));

        report("check-domainxml-"+i, instDomainXml.exists());
        long instDomainXmlTS = instDomainXml.lastModified();
        report("check-timestamp-"+i, dasDomainXmlTS == instDomainXmlTS);

        report("check-das-properties-"+i, dasFile.exists());

        String s = get("servers.server."+i+".property.rendezvousOccurred");
        report("check-rendezvous-"+i, s.equals("true"));

        //cleanup
        report("delete-instance-"+i, asadmin("delete-instance", i));
        bundle.delete();
        syncDir.delete();
        deleteDirectory(nodeDirParent);
    }

    private void testEndtoEnd() {
        String i ="iendtoend";
        String bundleName = i + "-sync-bundle.zip";
        File bundle = new File(syncDir, bundleName);
        File dasDomainXml = new File(domainHome, "config/domain.xml");
        File instDomainXml = new File(glassFishHome, "nodes/localhost/"+i+"/config/domain.xml");
        File webapp = new File("resources", "helloworld.war");
        final String i1url = "http://localhost:18080/";

        report("check-dasdomainxml-"+i, dasDomainXml.exists());
        report("create-instance-"+i, asadmin("create-instance", "--node", "localhost", "--systemproperties",
                "HTTP_LISTENER_PORT=18080", i));

        report("deploy-"+i, asadmin("deploy", "--target", i, webapp.getAbsolutePath()));
        
        long dasDomainXmlTS = dasDomainXml.lastModified();
        report("export-sync-bundle-"+i, asadmin("export-sync-bundle", "--target", i));
        report("check-domainxml-"+i, instDomainXml.exists());
        
        stopDomain();

        report("check-bundle-"+i, bundle.isFile());
        report("import-sync-bundle-"+i, asadmin("import-sync-bundle", "--file", bundle.getPath(), i));
        
        long instDomainXmlTS = instDomainXml.lastModified();
        report("check-timestamp-"+i, dasDomainXmlTS == instDomainXmlTS);

        report("start-local-instance-"+i, asadmin("start-local-instance", i));
        sleep(5);

        String urlStr = getURL(i1url + "helloworld/hi.jsp");
        report("check-app-"+i, matchString("Hello", urlStr));

        startDomain();

        String s = get("servers.server."+i+".property.rendezvousOccurred");
        report("check-rendezvous-"+i, s == null);

        //cleanup
        report("undeploy-"+i, asadmin("undeploy", "--target", i, "helloworld"));
        report("stop-local-instance-"+i, asadmin("stop-local-instance", i));
        sleep(5);
        report("delete-instance-"+i, asadmin("delete-instance", i));
        bundle.delete();
        syncDir.delete();
    }

    public boolean deleteDirectory(File path) {
        if (path.exists()) {
            File[] files = path.listFiles();
            for (File f : files) {
                if (f.isDirectory()) {
                    deleteDirectory(f);
                } else {
                    f.delete();
                }
            }
        }
        return (path.delete());
    }

    private void sleep(int n) {
        try {
            // Give instances time to come down
            Thread.sleep(n * 1000);
        } catch (InterruptedException e) {
        }

    }

    private final String host;
    private final File glassFishHome;
    private final File nodeDir;
    private final File instancesHome;
    private final File domainHome;
    private final File syncDir;
    private final File curDir;
}