/*******************************************************************************
 * Copyright (c) 2005, 2006 IBM Corporation and others.
 * 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:
 *     IBM Corporation - initial API and implementation
 *******************************************************************************/
package org.eclipse.equinox.internal.app;

import java.util.*;
import org.eclipse.osgi.framework.console.CommandInterpreter;
import org.eclipse.osgi.framework.console.CommandProvider;
import org.osgi.framework.*;
import org.osgi.service.application.*;
import org.osgi.util.tracker.ServiceTracker;

public class AppCommands implements CommandProvider {
	private final static String LAUNCHABLE_APP_FILTER = "(&(application.locked=false)(application.launchable=true)(application.visible=true))"; //$NON-NLS-1$
	private final static String ACTIVE_APP_FILTER = "(!(application.state=STOPPING))"; //$NON-NLS-1$

	private static AppCommands instance;
	private BundleContext context;
	private ServiceTracker appDescTracker;
	private ServiceTracker appHandleTracker;
	private ServiceTracker schedAppTracker;
	private Filter launchableApp;
	private Filter activeApp;
	private ServiceRegistration sr;

	static synchronized void create(BundleContext context) {
		if (instance != null)
			return;
		instance = new AppCommands();
		instance.start(context);
	}

	static synchronized void destroy(BundleContext context) {
		if (instance == null)
			return;
		instance.stop(context);
		instance = null;
	}

	protected AppCommands() {
		// empty
	}

	public void start(BundleContext ctx) {
		this.context = ctx;
		try {
			appDescTracker = new ServiceTracker(ctx, ApplicationDescriptor.class.getName(), null);
			appDescTracker.open();
			appHandleTracker = new ServiceTracker(ctx, ApplicationHandle.class.getName(), null);
			appHandleTracker.open();
			schedAppTracker = new ServiceTracker(ctx, ScheduledApplication.class.getName(), null);
			schedAppTracker.open();
			launchableApp = ctx.createFilter(LAUNCHABLE_APP_FILTER);
			activeApp = ctx.createFilter(ACTIVE_APP_FILTER);
			sr = ctx.registerService(CommandProvider.class.getName(), this, null);
		} catch (InvalidSyntaxException e) {
			// should not happen.
		}
	}

	public void stop(BundleContext ctx) {
		sr.unregister();
		if (appDescTracker != null)
			appDescTracker.close();
		if (appHandleTracker != null)
			appHandleTracker.close();
		if (schedAppTracker != null)
			schedAppTracker.close();
	}

	public String getHelp() {
		StringBuffer sb = new StringBuffer();
		sb.append("---Application Admin Commands---\n"); //$NON-NLS-1$
		sb.append("\tactiveApps - lists all running application IDs\n"); //$NON-NLS-1$
		sb.append("\tapps - lists all installed application IDs\n"); //$NON-NLS-1$
		sb.append("\tlockApp <application id> - locks the specified application ID\n"); //$NON-NLS-1$
		sb.append("\tschedApp <application id> <time filter> [true|false] - schedules the specified application id to launch at the specified time filter.  Can optionally make the schedule recurring.\n"); //$NON-NLS-1$
		sb.append("\tstartApp <application id> - starts the specified application ID\n"); //$NON-NLS-1$
		sb.append("\tstopApp <application id> - stops the specified running application ID\n"); //$NON-NLS-1$
		sb.append("\tunlockApp <application id> - unlocks the specified application ID\n"); //$NON-NLS-1$
		sb.append("\tunschedApp <application id> - unschedules all scheduled applications with the specified application ID\n"); //$NON-NLS-1$
		return sb.toString();
	}

	private Dictionary getServiceProps(ServiceReference ref) {
		String[] keys = ref.getPropertyKeys();
		Hashtable props = new Hashtable(keys.length);
		for (int i = 0; i < keys.length; i++)
			props.put(keys[i], ref.getProperty(keys[i]));
		return props;
	}

	public void _apps(CommandInterpreter intp) {
		ServiceReference[] apps = appDescTracker.getServiceReferences();
		if (apps == null) {
			intp.println("No applications found."); //$NON-NLS-1$
			return;
		}
		for (int i = 0; i < apps.length; i++) {
			intp.print(apps[i].getProperty(ApplicationDescriptor.APPLICATION_PID));
			intp.print(" ["); //$NON-NLS-1$
			intp.print(launchableApp.match(getServiceProps(apps[i])) ? "enabled" : "disabled"); //$NON-NLS-1$ //$NON-NLS-2$
			intp.println("]"); //$NON-NLS-1$
		}
	}

	public void _activeApps(CommandInterpreter intp) {
		ServiceReference[] active = appHandleTracker.getServiceReferences();
		if (active == null) {
			intp.println("No active applications found"); //$NON-NLS-1$
			return;
		}
		for (int i = 0; i < active.length; i++) {
			intp.print(active[i].getProperty(ApplicationHandle.APPLICATION_PID));
			intp.print(" ["); //$NON-NLS-1$
			intp.print(activeApp.match(getServiceProps(active[i])) ? "running" : "stopping"); //$NON-NLS-1$ //$NON-NLS-2$
			intp.println("]"); //$NON-NLS-1$
		}
	}

	public void _startApp(CommandInterpreter intp) throws Exception {
		String appId = intp.nextArgument();
		ServiceReference[] apps = appDescTracker.getServiceReferences();
		if (apps != null)
			for (int i = 0; i < apps.length; i++)
				if (appId.equals(apps[i].getProperty(ApplicationDescriptor.APPLICATION_PID))) {
					if (launchableApp.match(getServiceProps(apps[i]))) {
						ArrayList argList = new ArrayList();
						String arg = null;
						while ((arg = intp.nextArgument()) != null)
							argList.add(arg);
						String[] args = argList.size() == 0 ? null : (String[]) argList.toArray(new String[argList.size()]);
						ApplicationDescriptor appDesc = (ApplicationDescriptor) context.getService(apps[i]);
						try {
							HashMap launchArgs = new HashMap(1);
							if (args != null)
								launchArgs.put(ContainerManager.PROP_ECLIPSE_APPLICATION_ARGS, args);
							appDesc.launch(launchArgs);
							intp.println("Launched application: " + appId); //$NON-NLS-1$
						} finally {
							context.ungetService(apps[i]);
						}
					} else {
						intp.println("Application is not enabled: " + appId); //$NON-NLS-1$
					}
					return;
				}
		intp.println("No application with the id \"" + appId + "\" exists."); //$NON-NLS-1$ //$NON-NLS-2$
	}

	public void _stopApp(CommandInterpreter intp) throws Exception {
		String runningId = intp.nextArgument();
		ServiceReference[] runningApps = appHandleTracker.getServiceReferences();
		if (runningApps != null)
			for (int i = 0; i < runningApps.length; i++)
				if (runningId.equals(runningApps[i].getProperty(ApplicationHandle.APPLICATION_PID))) {
					if (activeApp.match(getServiceProps(runningApps[i]))) {
						try {
							ApplicationHandle appDesc = (ApplicationHandle) context.getService(runningApps[i]);
							appDesc.destroy();
							intp.println("Stopped application: " + runningId); //$NON-NLS-1$
						} finally {
							context.ungetService(runningApps[i]);
						}
					} else {
						intp.println("Applicationi is already stopping: " + runningId); //$NON-NLS-1$
					}
					return;
				}
		intp.println("No running application with the id \"" + runningId + "\" exists."); //$NON-NLS-1$ //$NON-NLS-2$
	}

	public void _lockApp(CommandInterpreter intp) throws Exception {
		String appId = intp.nextArgument();
		ServiceReference[] apps = appDescTracker.getServiceReferences();
		if (apps != null)
			for (int i = 0; i < apps.length; i++)
				if (appId.equals(apps[i].getProperty(ApplicationDescriptor.APPLICATION_PID))) {
					try {
						ApplicationDescriptor appDesc = (ApplicationDescriptor) context.getService(apps[i]);
						appDesc.lock();
						intp.println("Locked application: " + appId); //$NON-NLS-1$
					} finally {
						context.ungetService(apps[i]);
					}
					return;
				}
		intp.println("No application with the id \"" + appId + "\" exists."); //$NON-NLS-1$ //$NON-NLS-2$
	}

	public void _unlockApp(CommandInterpreter intp) throws Exception {
		String appId = intp.nextArgument();
		ServiceReference[] apps = appDescTracker.getServiceReferences();
		if (apps != null)
			for (int i = 0; i < apps.length; i++)
				if (appId.equals(apps[i].getProperty(ApplicationDescriptor.APPLICATION_PID))) {
					try {
						ApplicationDescriptor appDesc = (ApplicationDescriptor) context.getService(apps[i]);
						appDesc.unlock();
						intp.println("Unlocked application: " + appId); //$NON-NLS-1$
					} finally {
						context.ungetService(apps[i]);
					}
					return;
				}
		intp.println("No application with the id \"" + appId + "\" exists."); //$NON-NLS-1$ //$NON-NLS-2$
	}

	public void _schedApp(CommandInterpreter intp) throws Exception {
		String appId = intp.nextArgument();
		ServiceReference[] apps = appDescTracker.getServiceReferences();
		if (apps != null)
			for (int i = 0; i < apps.length; i++)
				if (appId.equals(apps[i].getProperty(ApplicationDescriptor.APPLICATION_PID))) {
					try {
						ApplicationDescriptor appDesc = (ApplicationDescriptor) context.getService(apps[i]);
						String filter = intp.nextArgument();
						boolean recure = Boolean.valueOf(intp.nextArgument()).booleanValue();
						appDesc.schedule(null, "org/osgi/application/timer", filter, recure); //$NON-NLS-1$
						intp.println("scheduled application: " + appId); //$NON-NLS-1$
					} finally {
						context.ungetService(apps[i]);
					}
					return;
				}
		intp.println("No application with the id \"" + appId + "\" exists."); //$NON-NLS-1$ //$NON-NLS-2$
	}

	public void _unschedApp(CommandInterpreter intp) throws Exception {
		String schedId = intp.nextArgument();
		ServiceReference[] scheds = schedAppTracker.getServiceReferences();
		if (scheds != null)
			for (int i = 0; i < scheds.length; i++) {
				ScheduledApplication schedApp = (ScheduledApplication) context.getService(scheds[i]);
				try {
					if (schedId.equals(schedApp.getApplicationDescriptor().getApplicationId()))
						schedApp.remove();
				} finally {
					context.ungetService(scheds[i]);
				}
			}

	}
}