source: 3thparty/jmessenger/src/nu/fw/jeti/backend/Input.java @ 3952

package nu.fw.jeti.backend;


import java.io.*;

import javax.xml.parsers.ParserConfigurationException;
import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;

import nu.fw.jeti.plugins.PluginsInfo;

import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
import org.xml.sax.SAXParseException;

/**
 * <p>Title: im</p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2001</p>
 * <p>Company: </p>
 * @author E.S. de Boer
 * @version 1.0
 */

public class Input extends Thread
{
        private InputSource in;
        private ConnectionPacketReceiver backend;
        private JabberHandler jH;
        private boolean closing = false;

    public Input(InputStream stream,ConnectionPacketReceiver backend,JabberHandler jH)
    {
                try{
                        if(PluginsInfo.isPluginLoaded("xmpp"))
                        {
                                in = new InputSource(new XMPPInputStream(new InputStreamReader(stream,"UTF-8")));
                        }
                        else
                        {
                                in = new InputSource(new InputStreamReader(stream,"UTF8"));
                                //in = new InputSource(new LogInputStream(new InputStreamReader(stream,"UTF8")));
                        }
                }catch(UnsupportedEncodingException e){e.printStackTrace();}
                this.backend = backend;
                this.jH = jH;
                start();
    }
        
    public void disconnect(){
        try {
                System.out.println("closing " + in.getCharacterStream());
                closing = true;
                        in.getCharacterStream().close();
                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
    }
        
        public void run()
        {
                try{
                        
                        /** @todo look at parsers */

//direct, higer mem?
//SAXParser parser =new org.apache.crimson.jaxp.SAXParserFactoryImpl().newSAXParser();


                        SAXParser parser = SAXParserFactory.newInstance().newSAXParser();
                        parser.parse(in,jH);
                }
                catch(ParserConfigurationException pce){pce.printStackTrace();}
                catch (SAXParseException spe)
                {
                        Exception e = spe.getException();
                        if(e != null) e.printStackTrace();
                        else System.err.println(spe.getMessage());
                }
                catch(SAXException se)
                {
                        if("end xmlparser".equals(se.getMessage())) {
                                closing = true;
                                return;
                        }
                        Exception e = se.getException();
                        if(e != null) e.printStackTrace();
                        else System.err.println(se.getMessage());
                }
                catch(IOException e)
                {
            // No need to do anything here.
                        System.err.println(e.getMessage());
                }
                catch (UnsupportedOperationException e) {
                        if("end xmlparser".equals(e.getMessage())) {
                                closing = true;
                                return;
                        }
                        System.err.println(e.getMessage());
                }
                finally{
                        System.out.println(in.getCharacterStream() + "closed");
                        if(!closing) backend.inputDeath();
                }
        
        }
        
//      //prints inputstream
//      class LogInputStream extends FilterReader
//      {
//              LogInputStream(Reader reader)
//              {
//                       super(reader);
//              }
//
//              public int read(char[] cbuf, int off, int len) throws IOException
//              {
//                      int readed = super.read(cbuf, off, len);
//                      if(readed == -1) System.out.println("end of stream detected readed");
//                      else System.out.println(new String(cbuf, off,readed).trim());
//                      return readed;
//              }
//
//              
//              public int read(char[] cbuf) throws IOException
//              {
//                      int readed = super.read(cbuf);
//                      System.out.println(new String(cbuf).trim());
//                      return readed;
//              }
//      
//              public void close()
//              {//stop close of stream from parser
//                      System.out.println("close stream");
//              }
//      }
}

class XMPPInputStream extends FilterReader
{
        XMPPInputStream(Reader reader)
        {
                 super(reader);
        }
        
        //stop close of stream from parser, 
        //needed to prevent stopping xml parser to close the socket
        public void close()
        {
                System.out.println("close stream" + this);
        }
}

/*
 * Overrides for emacs
 * Local variables:
 * tab-width: 4
 * End:
 */