/**********************************************************************
Copyright (c) 2000, 2002 IBM Corp. and others.
All rights reserved. This program and the accompanying materials
are made available under the terms of the Common Public License v1.0
which accompanies this distribution, and is available at
http://www.eclipse.org/legal/cpl-v10.html

Contributors:
	IBM Corporation - Initial implementation
	Vicente Fernando - www.alfersoft.com.ar
**********************************************************************/
package net.sourceforge.phpdt.internal.debug.core;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;
import java.net.ServerSocket;

import org.eclipse.core.runtime.CoreException;
import org.eclipse.debug.core.DebugPlugin;
import org.eclipse.debug.core.DebugException;
import org.eclipse.debug.core.model.IBreakpoint;
import net.sourceforge.phpdt.internal.debug.core.model.IPHPDebugTarget;
import net.sourceforge.phpdt.internal.debug.core.model.PHPStackFrame;
import net.sourceforge.phpdt.internal.debug.core.model.PHPThread;
import net.sourceforge.phpdt.internal.debug.core.model.PHPVariable;
import net.sourceforge.phpdt.internal.debug.core.breakpoints.PHPLineBreakpoint;

public class PHPDBGProxy {

	private ServerSocket server= null;
	private Socket socket;
	private BufferedReader reader= null;
	private PHPDBGInterface DBGInt= null;
	private IPHPDebugTarget debugTarget= null;
	private PHPLoop phpLoop;
	private PHPThread PHPMainThread;
	private PHPDBGProxy thisProxy= null;
	private int port;

	public PHPDBGProxy() {
		thisProxy= this;
	}

	public void start() {
		createServerSocket();
		this.startPHPLoop();
	}

	public void stop() {
		phpLoop.setShouldStop();
		if(DBGInt != null) DBGInt.setShouldStop();
		phpLoop.notifyWait();
	}

	protected ServerSocket getServerSocket() throws IOException {
		if (server == null) {
			createServerSocket();
		}
		return server;
	}

	protected void createServerSocket() {
		port = SocketUtil.findUnusedLocalPort("localhost", 10001, 10101);
		if (port == -1) {
			PHPDebugCorePlugin.log(5, "Cannot find free port!!!!");
			return;
		}
		try {
			if (server == null) {
				server = new ServerSocket(port);
				//System.out.println("ServerSocket on port: " + port);
			} 
		} catch (IOException e) {
			// IO Error
			PHPDebugCorePlugin.log(e);
			stop();
		}
	}

	public Socket getSocket() throws IOException {
		return socket;
	}

	protected void setDBGInterface(PHPDBGInterface DBGInt) {
		this.DBGInt= DBGInt;
	}

	public BufferedReader getReader() throws IOException {
		if (reader == null) {			
			reader = new BufferedReader(new InputStreamReader(this.getSocket().getInputStream(), "ISO8859_1"));
		}
		return reader;
	}

	public OutputStream getOutputStream() throws IOException {
		return this.getSocket().getOutputStream();
	}

	protected void setBreakPoints() throws IOException, CoreException {
		IBreakpoint[] breakpoints = DebugPlugin.getDefault().getBreakpointManager().getBreakpoints();
		for (int i = 0; i < breakpoints.length; i++) {
			addBreakpoint(breakpoints[i]);
		}
	}

	public void addBreakpoint(IBreakpoint breakpoint) {
		if (DBGInt == null) return;
		int bpNo= 0;
		try {
			PHPLineBreakpoint phpLBP;
			if(breakpoint.getModelIdentifier() == PHPDebugCorePlugin.getDefault().getDescriptor().getUniqueIdentifier()) {
				phpLBP= (PHPLineBreakpoint)breakpoint;
				bpNo= DBGInt.addBreakpoint(phpLBP.getMarker().getResource().getLocation().toOSString(), phpLBP.getLineNumber());
				phpLBP.setDBGBpNo(bpNo);
			}
		} catch (IOException e) {
			PHPDebugCorePlugin.log(e);
			stop();
		} catch (CoreException e) {
			PHPDebugCorePlugin.log(e);
			stop();
		}
	}

	public void removeBreakpoint(IBreakpoint breakpoint) {
		if (DBGInt == null) return;
		try {
			PHPLineBreakpoint phpLBP;
			if(breakpoint.getModelIdentifier() == PHPDebugCorePlugin.getDefault().getDescriptor().getUniqueIdentifier()) {
				phpLBP= (PHPLineBreakpoint)breakpoint;
				DBGInt.removeBreakpoint(phpLBP.getMarker().getResource().getLocation().toOSString(), phpLBP.getLineNumber(), phpLBP.getDBGBpNo());
			}
		} catch (IOException e) {
			PHPDebugCorePlugin.log(e);
			stop();
		} catch (CoreException e) {
			PHPDebugCorePlugin.log(e);
			stop();
		}
	}

	public void startPHPLoop() {
		phpLoop = new PHPLoop();
		phpLoop.start();
	}

	public void resume(PHPThread thread) {
		try {
			DBGInt.continueExecution();
			phpLoop.notifyWait();
		} catch (IOException e) {
			PHPDebugCorePlugin.log(e);
			stop();
		}
	}

	protected IPHPDebugTarget getDebugTarget() {
		return debugTarget;
	}

	public void setDebugTarget(IPHPDebugTarget debugTarget) {
		this.debugTarget = debugTarget;
		debugTarget.setPHPDBGProxy(this);
	}

	public PHPVariable[] readVariables(PHPStackFrame frame) {
		try {
			return DBGInt.getVariables(frame);
		} catch (IOException ioex) {
			ioex.printStackTrace();
			throw new RuntimeException(ioex.getMessage());
		} catch (DebugException ex) {
			ex.printStackTrace();
			throw new RuntimeException(ex.getMessage());
		}
	}

	public PHPVariable[] readInstanceVariables(PHPVariable variable) {
		try {
			return DBGInt.getInstVars(variable);
		} catch (DebugException ex) {
			ex.printStackTrace();
			throw new RuntimeException(ex.getMessage());
		}

	}

	public void readStepOverEnd(PHPStackFrame stackFrame) {
		try {
			DBGInt.stepOver();
			phpLoop.notifyWait();
		} catch (Exception e) {
			PHPDebugCorePlugin.log(e);
		}
	}

	public void readStepReturnEnd(PHPStackFrame stackFrame) {
		try {
			DBGInt.stepOut();
			phpLoop.notifyWait();
		} catch (Exception e) {
			PHPDebugCorePlugin.log(e);
		}
	}

	public void readStepIntoEnd(PHPStackFrame stackFrame) {
		try {
			DBGInt.stepInto();
			phpLoop.notifyWait();
		} catch (Exception e) {
			PHPDebugCorePlugin.log(e);
		}
	}

/*
	public PHPStackFrame[] readFrames(PHPThread thread) {
		//try {
			//this.println("th " + thread.getId() + " ; f ");
			//return new FramesReader(getMultiReaderStrategy()).readFrames(thread);
			return null;
		//} catch (IOException e) {
		//	PHPDebugCorePlugin.log(e);
		//	return null;
		//}

	}
*/
	
	public void closeSocket() throws IOException {
		if (socket != null) {
			socket.close();
		}
	}

	public void closeServerSocket() throws IOException {
		if (server != null) {
			server.close();
		}
	}

	public int getPort() {
		return port;
	}

	class PHPLoop extends Thread {
		private boolean shouldStop;
	
		public PHPLoop() {
			shouldStop = false;
			this.setName("PHPDebuggerLoop");
		}

		public synchronized void setShouldStop() {
			shouldStop = true;
		}

		public synchronized void notifyWait() {
			notify();
		}

		public void run() {
			try {
				char[] buf= new char[16];
				int i, pos, timeout;
				long interval= 1000*20;
				String line;
				PHPStackFrame[] StackList;
				
				//System.out.println("Waiting for breakpoints.");			
				try{
					socket = server.accept();
					//System.out.println("Accepted! : " + socket.toString());
				} catch (IOException e) {
					PHPDebugCorePlugin.log(e);
					return;			
				}
				
				PHPMainThread= new PHPThread(getDebugTarget(), getPort());
				PHPMainThread.setName("Thread [main]");
				timeout= 0;
				while((getDebugTarget() == null) && (timeout < 100)) {
					sleep(100);
					timeout++;
				}
				// Be sure debug target is set
				PHPMainThread.setDebugTarget(getDebugTarget());
				getDebugTarget().addThread(PHPMainThread);
				setDBGInterface(new PHPDBGInterface(getReader(), getOutputStream(), thisProxy));

				DBGInt.waitResponse(1000);
				DBGInt.flushAllPackets();

				// Check version and session ID
				setBreakPoints();
				DBGInt.continueExecution();

				while (!shouldStop) {
					DBGInt.waitResponse(interval);
					DBGInt.flushAllPackets();

					if (DBGInt.BPUnderHit != 0) {
						StackList= DBGInt.getStackList();
						if(StackList.length > 0) {
							for(i=0; i < StackList.length; i++) {
								StackList[i].setThread(PHPMainThread);
								if(DBGInt.getModByNo(StackList[i].getModNo()).equals("")) {
									DBGInt.getSourceTree();
								}
								StackList[i].setFile(DBGInt.getModByNo(StackList[i].getModNo()));
							}
							PHPMainThread.setStackFrames(StackList);
						}
						// Fire debug event
						PHPMainThread.suspend();

						synchronized(this) {
							wait();
						}
					}					
					if(PHPMainThread.isTerminated() || getDebugTarget().getProcess().isTerminated()) break;
				}
			} catch (Exception ex) {
				PHPDebugCorePlugin.log(ex);
				System.out.println(ex);
			} finally {
				try {
					getDebugTarget().terminate();
					closeSocket();
					closeServerSocket();
				} catch (IOException e) {
					PHPDebugCorePlugin.log(e);
					return;
				}
				//System.out.println("Socket loop finished.");
			}
		}
	}	
}