/*
 Eteria IRC Client, an RFC 1459 compliant client program written in Java.
 Copyright (C) 2000-2001  Javier Kohen <jkohen at tough.com>
 
 This program is free software; you can redistribute it and/or modify
 it under the terms of the GNU General Public License as published by
 the Free Software Foundation; either version 2 of the License, or
 (at your option) any later version.
 
 This program is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 
 You should have received a copy of the GNU General Public License
 along with this program; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
 
 import java.io.*;
 import java.net.Socket;
 import java.net.SocketException;
 import java.util.Enumeration;
 import java.util.Observable;
 import java.util.Observer;
 import java.util.Vector;
 import java.text.ParseException;
 import ar.com.jkohen.irc.Message;
 import ar.com.jkohen.irc.MircMessage;
 import ar.com.jkohen.net.*;
 import ar.com.jkohen.util.ConfigurationProperties;
 
 public class ServerThread extends Thread implements ServerProcess, Observer
 {
 	private Socket sock;
 	private ClientProcess client;
 	private BufferedReader br;
 	private BufferedWriter bw;
 
 	private boolean disconnected;
 
 	/* Configuration properties. */
 	private boolean filter_mirc_attribs = false;
 
 	public ServerThread(ClientProcess client, Socket s, String enc) throws IOException
 	{
 		this.client = client;
 		this.sock = s;
 
 		InputStream is = sock.getInputStream();
 		OutputStream os = sock.getOutputStream();
 
 		try
 		{
 			this.br = new BufferedReader(new InputStreamReader(is, enc));
 			this.bw = new BufferedWriter(new OutputStreamWriter(os, enc));
 		}
 		catch (UnsupportedEncodingException ex)
 		{
 			System.err.println("Warning: " + enc + " encoding not supported. Back to ISO-8859-1.");
 			
 			this.br = new BufferedReader(new InputStreamReader(is, "ISO-8859-1"));
 			this.bw = new BufferedWriter(new OutputStreamWriter(os, "ISO-8859-1"));
 		}
 
 		try
 		{
 			// FIXME: this doesn't seem to be working.
 			// Prevents the lock-up that occurs when the route to the peer is dropped.
 			sock.setSoLinger(true, 30);
 		}
 		catch (SocketException ex)
 		{
 			System.err.println(ex);
 		}
 	}
 	
 	public void run()
 	{
 		while (!disconnected)
 		{
 			try
 			{
 				processNextLine();
 			}
 			catch (IOException e)
 			{
 //				System.err.println(e);
 				client.disconnect();
 			}
 		}
 	}
 
 	private void processNextLine() throws IOException
 	{
 		String str = null;
 		try
 		{
 			str = br.readLine();
 		}
 		catch (Exception e)
 		{
 			System.err.println(e);
 		}
 
 		if (str == null)
 			throw new IOException("Empty ligne");
 
 		try
 		{
 			Message m;
 			if (filter_mirc_attribs)
 				m = new MircMessage(str);
 			else
 				m = new Message(str);
 
 			client.processMessage(m);
 		}
 		catch (ParseException e)
 		{
 			System.err.println(e);
 		}
 	}
 
 	public void enqueueMessage(Message m) throws IOException
 	{
 		String [] slices = m.slices();
 
 		for (int i = 0; i < slices.length; i++)
 			bw.write(slices[i], 0, slices[i].length());
 
 		bw.flush();
 	}
 
 	public void disconnect()
 	{
 		if (disconnected)
 			return;
 
 		disconnected = true;
 
 		try
 		{
 			br.close();
 		}
 		catch (IOException e)
 		{
 			System.err.println(e);
 		}
 
 		try
 		{
 			bw.close();
 		}
 		catch (IOException e)
 		{
 			System.err.println(e);
 		}
 	}
 
 	public Socket getSocket()
 	{
 		return sock;
 	}
 
 	public void update(Observable o, Object arg)
 	{
 		ConfigurationProperties props = (ConfigurationProperties) o;
 
 		if (arg == null || arg.equals("filter_mirc_attribs"))
 			this.filter_mirc_attribs = props.getBoolean("filter_mirc_attribs");
 	}
 }