package jp.co.ntl.swing.ext;

import java.io.EOFException;
import java.io.FileWriter;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.File;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.util.Vector;

import jp.co.ntl.Net;
import jp.co.ntl.NetworkException;
import jp.co.ntl.ServerException;
import jp.co.ntl.TimeOutException;
import jp.co.ntl.ext.GlobalContext;

public class InvokerUtil {
	public static final int	RET_RELATED	 	= 0;
	public static final int	RET_REGISTERED	= 1;
	
	
	Net				net;
	GlobalContext	gc = GlobalContext.getInstance();
	
	public InvokerUtil(Net net) {
		this.net = net;
	}

	public Vector serverAccessRetVector(String servletName, String commandName) throws NetworkException, ServerException, TimeOutException {
		return serverAccessRetVector(servletName, commandName, null);
	}
	
	public Vector serverAccessRetVector(String servletName, String commandName, Object param) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is = null;

		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}

		Vector	vc = new Vector();
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			if (b) {
				try {
					vc = (Vector)is.readObject();
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				} catch (ClassNotFoundException e) {
					throw new ServerException(e.getMessage());
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
		
		return vc;
	}
	
	public Object serverAccessRetObject(String servletName, String commandName, Object param) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is = null;
		
		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}
		
		Object	obj = null;
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			if (b) {
				try {
					obj = is.readObject();
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				} catch (ClassNotFoundException e) {
					throw new ServerException(e.getMessage());
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
		
		return obj;
	}
	
	public Object[] serverAccessRetObjectArray(String servletName, String commandName, Object param) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is = null;
		
		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}
		
		Object[]	objs = null;
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			if (b) {
				try {
					objs = (Object[])is.readObject();
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				} catch (ClassNotFoundException e) {
					throw new ServerException(e.getMessage());
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
		
		return objs;
	}
	
	public void serverAccessRetVoid(String servletName, String commandName) throws NetworkException, ServerException, TimeOutException {
		serverAccessRetVoid(servletName, commandName, null);
	}
	
	public void serverAccessRetVoid(String servletName, String commandName, Object param) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is;

		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}
		
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			if (b) {
				;
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
	}
	
	public int serverAccessRetInt(String servletName, String commandName, Object param) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is;
		int					ret = -1;

		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}
		
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			if (b) {
				try {
					ret = is.readInt();
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
		
		return ret;
	}
	
	public boolean serverAccessRetBoolean(String servletName, String commandName, Object param, int kind) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is;
		boolean			ret = false;
		
		try {
			gc.enterConnection();
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, param));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} finally {
			gc.releaseConnection();
		}
		
		try {
			gc.enterConnection();
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new ServerException(e.getMessage());
			}
			
			if (b) {
				try {
					String	msg = is.readUTF();
					if (kind == RET_RELATED) {
						if (msg.equals(Net.resultRelated)) {
							ret = true;
						} else {
							ret = false;
						}
					} else {
						if (msg.equals(Net.resultRegistered)) {
							ret = true;
						} else {
							ret = false;
						}
					}
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
			}
			gc.releaseConnection();
		}
		
		return ret;
	}
	
	public boolean serverAccessDownload(String servletName, String commandName, File file, int authType) throws NetworkException, ServerException, TimeOutException {
		ObjectInputStream	is = null;
		
		try {
			Object[]	params = new Object[] {
					file,
					new Integer(authType)
			};
			is = new ObjectInputStream(net.sendCommand(servletName, commandName, params));
		} catch (IOException e) {
			throw new NetworkException(e.getMessage());
		} catch (KeyManagementException e) {
			throw new NetworkException(e.getMessage());
		} catch (NoSuchAlgorithmException e) {
			throw new NetworkException(e.getMessage());
		}
		
		try {
			boolean	b;
			try {
				b = is.readBoolean();
			} catch (IOException e) {
				throw new NetworkException(e.getMessage());
			}
			
			if (b) {
				FileWriter	fw;
				try {
					fw = new FileWriter(file);
				} catch (IOException e) {
					return false;
				}
				
				if (fw != null) {
					try {
						while (true) {
							String	line = is.readUTF();
							if (line != null) {
								fw.write(line);
							} else {
								break;
							}
						}
					} catch (EOFException e) {
						;
					} catch (IOException e) {
						throw new ServerException(e.getMessage());
					} finally {
						try {
							fw.close();
						} catch (IOException e) {
							;
						}
					}
				}
			} else {
				try {
					String	message = is.readUTF();
					if (message.equals(Net.resultServerError)) {
						throw new ServerException("error");
					} else if (message.equals(Net.resultNotConnectSpooler)) {
						throw new NetworkException("error");
					} else if (message.equals(Net.resultTimeOut)) {
///						net.showLoginPage();
						throw new TimeOutException();
					} else {
						throw new ServerException(message);
					}
				} catch (IOException e) {
					throw new ServerException(e.getMessage());
				}
			}
		} finally {
			try {
				is.close();
			} catch (IOException e) {
				;
			}
		}
		
		return true;
	}
}