/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package nodes;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.StringReader;
import java.net.URL;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.Map;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.parsers.SAXParser;
import javax.xml.parsers.SAXParserFactory;
import javax.xml.stream.XMLEventReader;
import javax.xml.stream.XMLInputFactory;
import javax.xml.stream.XMLStreamConstants;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.events.EndElement;
import javax.xml.stream.events.StartElement;
import javax.xml.stream.events.XMLEvent;
import org.codehaus.jettison.json.JSONException;
import org.codehaus.jettison.json.JSONObject;
import org.xml.sax.ErrorHandler;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
import org.xml.sax.SAXParseException;
import org.xml.sax.XMLReader;
import static utils.Constants.*;
import utils.TranslatorException;

/**
 *
 * @author Brad
 */
public class WEPSCrop extends Crop {

  private final Map<String, String> parameters;

  private static final String CROPDTD = "../config/data/crop_db.dtd";

  public WEPSCrop() {
    parameters = new HashMap<>();
  }

  public WEPSCrop(String name) {
    parameters = new HashMap<>();
    this.name = name;
  }

  public String getParameter(String param) {
    return parameters.get(param);

  }

  public void addParameter(String name, String value) {
    parameters.put(name, value);
    if (name.equals("tgtyield")) {
      targetYield = Double.parseDouble(value);
    }
  }

  @Override
  public void parseLMODData(JSONObject data) throws XMLStreamException, ParserConfigurationException, SAXException, IOException, TranslatorException, JSONException {

    XMLEvent event;
    StartElement startElement;
    EndElement endElement;
    boolean done = false;
    String param_name = null;
    String param_value = null;

    String xmlData = data.getString(WEPS_CROP_PARAM_SET);
    xmlData = xmlData.replaceAll("–", "^").trim();

    InputStream stream = new ByteArrayInputStream(xmlData.getBytes()); //IOUtils.toInputStream(xmlData, "ISO-8859-1");

    URL url = getClass().getResource(CROPDTD);
    xmlData = xmlData.replace("crop_db.dtd", url.toString());

    // Set up xml stream
    XMLInputFactory factory = XMLInputFactory.newInstance();

    XMLEventReader reader = factory.createXMLEventReader(stream);

    //validate the xml
    SAXParserFactory saxfactory = SAXParserFactory.newInstance();
    saxfactory.setValidating(true);
    SAXParser parser = saxfactory.newSAXParser();
    XMLReader validreader = parser.getXMLReader();

    validreader.setErrorHandler(
            new ErrorHandler() {
      @Override
      public void warning(SAXParseException e) throws SAXException {
        System.out.println("WARNING : " + e.getMessage()); // do nothing
      }

      @Override
      public void error(SAXParseException e) throws SAXException {
        System.out.println("ERROR : " + e.getMessage());
        throw e;
      }

      @Override
      public void fatalError(SAXParseException e) throws SAXException {
        System.out.println("FATAL : " + e.getMessage());
        throw e;
      }
    }
    );
    validreader.parse(new InputSource(new StringReader(xmlData)));

    // start parsing
    while (reader.hasNext()) {
      event = reader.nextEvent();

      switch (event.getEventType()) {
        case XMLStreamConstants.START_ELEMENT:
          startElement = event.asStartElement();
          if (startElement.getName().getLocalPart().equals(CROPNAME)) {
            if (!reader.getElementText().equals(name))
              throw new TranslatorException("Crop: " + name + " does not match the LMOD crop data.");

            break;
          }

          if (startElement.getName().getLocalPart().equals(PARAM)) {
            while (reader.hasNext() && !done) {
              event = reader.nextEvent();
              switch (event.getEventType()) {
                case XMLStreamConstants.START_ELEMENT:
                  startElement = event.asStartElement();
                  if (startElement.getName().getLocalPart().equals(NAME)) {
                    param_name = reader.getElementText();
                    if (param_name.equals("tgtyield")) {
                      param_value = Double.toString(targetYield);
                      done = true;
                    }
                    break;
                  }

                  if (startElement.getName().getLocalPart().equals(XML_VALUE)) {
                    param_value = reader.getElementText();
                    done = true;
                    break;
                  }
              }
            }
            done = false;
          }
          break;

        case XMLStreamConstants.END_ELEMENT:
          endElement = event.asEndElement();
          if (endElement.getName().getLocalPart().equals(PARAM))
            parameters.put(param_name, param_value);
          break;
      }
    }
  }
}