/*******************************************************************************
 * Copyright (c) 2008, 2010 VMware Inc.
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 *
 * Contributors:
 *   VMware Inc. - initial contribution
 *******************************************************************************/

package org.eclipse.virgo.web.test;

import org.eclipse.virgo.test.framework.dmkernel.DmKernelTestRunner;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.runner.RunWith;

import javax.management.*;
import java.lang.management.ManagementFactory;

@RunWith(DmKernelTestRunner.class)
public abstract class AbstractTomcatServerIntegrationTest extends AbstractKernelIntegrationTest {

    private static final String CURRENT_VERSION = "3.8.0";

    private static final long PLAN_DEPLOY_TIMEOUT = 5*60*1000; // 1 minutes

    @BeforeClass
    public static void awaitKernelStartup() throws Exception {
        AbstractKernelIntegrationTest.awaitKernelStartup();
    }

    @Before
    public void setup() throws Exception {
        super.setup();

        // Add asserts like assertThat(state, is("ACTIVE")) 3 times - see above, too!
        awaitGeminiBlueprintPlanStartup();
        // Add asserts like assertThat(state, is("ACTIVE")) 3 times - see above, too!
        awaitTomcatPlanStartup();
        // Add asserts like assertThat(state, is("ACTIVE")) 3 times - see above, too!
        awaitShellPlanStartup();
    }

    private void awaitGeminiBlueprintPlanStartup() throws MalformedObjectNameException, MBeanException, AttributeNotFoundException, ReflectionException, InterruptedException {
        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName objectName = new ObjectName("org.eclipse.virgo.kernel:type=ArtifactModel,artifact-type=plan,name=org.eclipse.virgo.kernel.userregion.blueprint,version=" + CURRENT_VERSION + ",region=global");

        Object state = null;
        long startTime = System.currentTimeMillis();

        while (!"ACTIVE".equals(state)) {
            try {
                state = mBeanServer.getAttribute(objectName, "State");
                System.out.println("Waiting for plan 'org.eclipse.virgo.kernel.userregion.blueprint'...");
                Thread.sleep(100);
            } catch (InstanceNotFoundException ignored) {
            }
            if (System.currentTimeMillis() - startTime > PLAN_DEPLOY_TIMEOUT) {
                throw new RuntimeException("Plan 'org.eclipse.virgo.kernel.userregion.blueprint' did not start within " + (PLAN_DEPLOY_TIMEOUT / 1000) + " seconds.");
            }
        }
    }

    private void awaitTomcatPlanStartup() throws MalformedObjectNameException, MBeanException, AttributeNotFoundException, ReflectionException, InterruptedException {
        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName objectName = new ObjectName("org.eclipse.virgo.kernel:type=ArtifactModel,artifact-type=plan,name=org.eclipse.virgo.web.tomcat,version=" + CURRENT_VERSION + ",region=global");

        Object state = null;
        long startTime = System.currentTimeMillis();

        while (!"ACTIVE".equals(state)) {
            try {
                state = mBeanServer.getAttribute(objectName, "State");
                System.out.println("Waiting for 'web.plan'...");
                Thread.sleep(100);
            } catch (InstanceNotFoundException ignored) {
            }
            if (System.currentTimeMillis() - startTime > PLAN_DEPLOY_TIMEOUT) {
                throw new RuntimeException("Web plan did not start within " + (PLAN_DEPLOY_TIMEOUT / 1000) + " seconds.");
            }
        }
    }

    private void awaitShellPlanStartup() throws MalformedObjectNameException, MBeanException, AttributeNotFoundException, ReflectionException, InterruptedException {
        MBeanServer mBeanServer = ManagementFactory.getPlatformMBeanServer();
        ObjectName objectName = new ObjectName("org.eclipse.virgo.kernel:type=ArtifactModel,artifact-type=plan,name=org.eclipse.virgo.shell,version=" + CURRENT_VERSION + ",region=global");

        Object state = null;
        long startTime = System.currentTimeMillis();

        while (!"ACTIVE".equals(state)) {
            try {
                state = mBeanServer.getAttribute(objectName, "State");
                System.out.println("Waiting for 'shell.plan'...");
                Thread.sleep(100);
            } catch (InstanceNotFoundException ignored) {
            }
            if (System.currentTimeMillis() - startTime > PLAN_DEPLOY_TIMEOUT) {
                throw new RuntimeException("Web plan did not start within " + (PLAN_DEPLOY_TIMEOUT / 1000) + " seconds.");
            }
        }
    }
}