/*
   Copyright (C) 2007 Dirk Huenniger
   
   This library is free software; you can redistribute it and/or
   modify it under the terms of the GNU Lesser General Public
   License as published by the Free Software Foundation; either
   version 2.1 of the License, or (at your option) any later version.
   
   This library 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
  Lesser General Public License for more details.
  
  You should have received a copy of the GNU Lesser General Public
  License along with this library; if not, write to the Free Software
  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
   */
  
  package org.indi.server;
  
  import java.util.Queue;
  
  import org.indi.clientmessages.EnableBlob;
  import org.indi.clientmessages.GetProperties;
  import org.indi.objects.Blob;
  import org.indi.objects.BlobVector;
  import org.indi.objects.Number;
  import org.indi.objects.NumberVector;
  import org.indi.objects.Switch;
  import org.indi.objects.SwitchVector;
  import org.indi.objects.Text;
  import org.indi.objects.TextVector;
  import org.xml.sax.Attributes;
  import org.xml.sax.SAXException;
  import org.xml.sax.helpers.DefaultHandler;
  
  /**
   * A sax handler to parse the information received from the client
   * 
   * @author Dirk Hünniger
   */
  public class SaxHandler extends DefaultHandler {
      /**
       * the SwitchVector the parser is currently passing. if null the parser is
       * currently not parsing any SwitchVector
       */
      private SwitchVector sv = null;
      /**
       * the NumberVector the parser is currently passing. if null the parser is
       * currently not parsing any NumberVector
       */
      private NumberVector nv = null;
      /**
       * the TextVector the parser is currently passing. if null the parser is
       * currently not parsing any TextVector
       */
      private TextVector tv = null;
      /**
       * the BLOBVector the parser is currently passing. if null the parser is
       * currently not parsing any BLOBVector
       */
      private BlobVector bv = null;
      /**
       * the name attibute of the XMLelement currently beening parsed
       */
      private String name = null;
      /**
       * the value of the indiobject.Element currently beeing parsed
       */
      private String value = null;
      /**
       * the format attribute of the BLOB currently beeing parsed
       */
      private String blobformat = null;
      /**
       * the name of the device the vector currently beeing parsed belongs to
       */
      private String device = null;
      /**
       * the size of the blob currently beeing parsed
       */
      private long blobsize = 0;
      /**
       * the queue to write parsed objects to
       */
      private final Queue<java.lang.Object> queue;
      /**
       * the clienthandker this sax parser belongs to
       */
      private ClientHandler clientHandler = null;
  
      /**
       * class constructor
       * 
       * @param queue
       *                the queue to write the parsed elements to
       * @param clientHandler
       *                the clienthandler this saxparser belongs to
       */
     public SaxHandler(Queue<java.lang.Object> queue, ClientHandler clientHandler) {
 	this.queue = queue;
 	this.clientHandler = clientHandler;
     }
 
     @Override
     public void startElement(String uri, String localName, String qName,
 	    Attributes attrs) throws SAXException {
 	if (qName.equals("newSwitchVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.sv = new SwitchVector(attrs.getValue("device"), attrs
 		    .getValue("name"), attrs.getValue("timestamp"));
 	}
 	if (qName.equals("newNumberVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.nv = new NumberVector(attrs.getValue("device"), attrs
 		    .getValue("name"), attrs.getValue("timestamp"));
 	}
 	if (qName.equals("newTextVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.tv = new TextVector(attrs.getValue("device"), attrs
 		    .getValue("name"), attrs.getValue("timestamp"));
 	}
 	if (qName.equals("newBLOBVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.bv = new BlobVector(attrs.getValue("device"), attrs
 		    .getValue("name"), attrs.getValue("timestamp"));
 	}
 	if (qName.equals("oneText")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv == null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.name = attrs.getValue("name");
 	    this.value = new String();
 	}
 	if (qName.equals("oneSwitch")) {
 	    if ((this.sv == null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.name = attrs.getValue("name");
 	    this.value = new String();
 	}
 	if (qName.equals("oneNumber")) {
 	    if ((this.sv != null) || (this.nv == null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.name = attrs.getValue("name");
 	    this.value = new String();
 	}
 	if (qName.equals("oneBLOB")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv == null)) {
 		throw new RuntimeException();
 	    }
 	    this.name = attrs.getValue("name");
 	    this.blobsize = Long.valueOf(attrs.getValue("size"));
 	    this.blobformat = attrs.getValue("format");
 	    this.value = new String();
 	}
 	if (qName.equals("enableBLOB")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.name = attrs.getValue("name");
 	    this.device = attrs.getValue("device");
 	    this.value = new String();
 	}
 	if (qName.equals("getProperties")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    GetProperties g = new GetProperties(attrs.getValue("version"),
 		    attrs.getValue("device"));
 	    this.clientHandler.onGetProperties(g);
 	    this.queue.add(g);
 	}
     }
 
     @Override
     public void endElement(String uri, String localName, String qName)
 	    throws SAXException {
 	if (qName.equals("oneText")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv == null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.tv.add(new Text(this.name, this.value));
 	}
 	if (qName.equals("oneSwitch")) {
 	    if ((this.sv == null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.sv.add(new Switch(this.name, normalize(this.value)));
 	}
 	if (qName.equals("oneNumber")) {
 	    if ((this.sv != null) || (this.nv == null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.nv.add(new Number(this.name, normalize(this.value)));
 	}
 	if (qName.equals("oneBLOB")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv == null)) {
 		throw new RuntimeException();
 	    }
 	    this.bv.add(new Blob(this.name, this.blobformat, this.blobsize,
 		    this.value));
 	}
 	if (qName.equals("newTextVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv == null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.queue.add(this.tv);
 	    this.tv = null;
 	}
 	if (qName.equals("enableBLOB")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 
 	    this.clientHandler.onEnableBlob(new EnableBlob(this.device,
 		    this.name, normalize(this.value)));
 	    this.value = null;
 	    this.device = null;
 	    this.name = null;
 	}
 	if (qName.equals("newSwitchVector")) {
 	    if ((this.sv == null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    ;
 	    this.queue.add(this.sv);
 	    this.sv = null;
 	}
 	if (qName.equals("newNumberVector")) {
 	    if ((this.sv != null) || (this.nv == null) || (this.tv != null)
 		    || (this.bv != null)) {
 		throw new RuntimeException();
 	    }
 	    this.queue.add(this.nv);
 	    this.nv = null;
 	}
 	if (qName.equals("newBLOBVector")) {
 	    if ((this.sv != null) || (this.nv != null) || (this.tv != null)
 		    || (this.bv == null)) {
 		throw new RuntimeException();
 	    }
 	    this.queue.add(this.bv);
 	    this.bv = null;
 	}
     }
 
     @Override
     public void characters(char ch[], int start, int length)
 	    throws SAXException {
 	// if ((sv==null) && (nv==null) && (tv==null) && (bv==null) &&
 	// (device==null)) return;
 	String v = this.value + new String(ch, start, length);
 	this.value = this.value + v;
     }
 
     private String normalize(String in) {
 	in = in.replaceAll("\n", "");
 	String[] str = in.split(" ");
 	if (str.length == 1) {
 	    return in;
 	}
 	String out = new String();
 	out = str[0];
 	for (int i = 1; i < str.length; i++) {
 	    if (!out.equals("")) {
 		if (!((str[i].equals("")) && (i == str.length - 1))) {
 		    out = out + " " + str[i];
 		}
 	    } else {
 		out = str[i];
 	    }
 	}
 	return out;
     }
 }