/*
 * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
 * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
 */
import com.sun.jdi.VirtualMachine;
import com.sun.jdi.Bootstrap;
import com.sun.jdi.connect.Connector;
import com.sun.jdi.connect.LaunchingConnector;
import com.sun.jdi.connect.Transport;
import com.sun.jdi.connect.IllegalConnectorArgumentsException;
import com.sun.jdi.connect.VMStartException;
import com.sun.jdi.connect.spi.TransportService;
import com.sun.jdi.connect.spi.Connection;
import java.io.IOException;
import java.io.File;
import java.util.Map;
import java.util.HashMap;

public class SimpleLaunchingConnector implements LaunchingConnector {
    TransportService ts;
    String ARG_NAME = "class";

    /*
     * Simple implementation of Connector.StringArgument
     */
    static class StringArgumentImpl implements Connector.StringArgument {
	String name;
	String label;
	String description;
	String value;

	StringArgumentImpl(String name, String label, String description, String value) {
	    this.name = name;
	    this.label = label;
	    this.description = description;
	    this.value = value;
	}

	public String name() {
	    return name;
	}

	public String label() {
	    return label;
	}
	
	public String description() {
	    return description;
	}

	public String value() {
	    return value;
	}

	public void setValue(String value) {
	    this.value = value;
	}

	public boolean isValid(String value) {
	    if (value.length() > 0) {
	        return true;
	    }
	    return false;
	}

	public boolean mustSpecify() {
	    return true;
	}
    }

    public SimpleLaunchingConnector() {
        try {
            Class c = Class.forName("com.sun.tools.jdi.SocketTransportService");
            ts = (TransportService)c.newInstance();
        } catch (Exception x) {
            throw new Error(x);
        }
    }

    public String name() {
        return "SimpleLaunchingConnector";
    }

    public String description() {
	return "SimpleLaunchingConnector";
    }

    public Transport transport() {
        return new Transport() {
            public String name() {
                return ts.name();
            }
        };
    }

    public Map<String, Connector.Argument> defaultArguments() {
	HashMap<String, Connector.Argument> map = new HashMap<String, Connector.Argument>();
	map.put(ARG_NAME, 
		new StringArgumentImpl(ARG_NAME, "class name", "class name", ""));
	return map;
    }

    public VirtualMachine launch(Map<String, ? extends Connector.Argument> arguments) throws
                              IOException,
                              IllegalConnectorArgumentsException,
	                      VMStartException {

	/*
	 * Get the class name that we are to execute
	 */
	String className = ((StringArgumentImpl)arguments.get(ARG_NAME)).value();
	if (className.length() == 0) {
	    throw new IllegalConnectorArgumentsException("class name missing", ARG_NAME);
	}

	/*
	 * Listen on an ephemeral port; launch the debuggee; wait for
	 * for the debuggee to connect; stop listening;
	 */
	TransportService.ListenKey key = ts.startListening();

	String exe = System.getProperty("java.home") + File.separator + "bin" +
	    File.separator;
	String arch = System.getProperty("os.arch");
	if (arch.equals("sparcv9")) {
	    exe += "sparcv9/java";
 	} else {
	    exe += "java";
	}
	String cmd = exe + "-agentlib:jdwp=transport=dt_socket,timeout=15000,address=" +
	    key.address() + "" + className;
        /*
         * If the debuggee VM might be a pre J2SE 5 VM, you
         * should use these options instead of the -agentlib option shown above:
         *  "-Xdebug -Xrunjdwp:transport=dt_socket,timeout=15000,address=" 
         */
	Process process = Runtime.getRuntime().exec(cmd);
	Connection conn = ts.accept(key, 30*1000, 9*1000);
	ts.stopListening(key);

	/* 
 	 * Debugee is connected - return the virtual machine mirror
	 */
	return Bootstrap.virtualMachineManager().createVirtualMachine(conn);
    }
}