package io.vertx.ext.unit.report.impl;

import io.vertx.core.buffer.Buffer;
import io.vertx.ext.unit.report.TestResult;
import io.vertx.ext.unit.impl.TestResultImpl;
import io.vertx.ext.unit.report.Reporter;

import javax.xml.stream.XMLOutputFactory;
import javax.xml.stream.XMLStreamWriter;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;
import java.io.StringReader;
import java.io.StringWriter;
import java.text.NumberFormat;
import java.text.SimpleDateFormat;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.TimeZone;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import java.util.function.Function;

Author:
Julien Viet/**
 * @author <a href="mailto:julien@julienviet.com">Julien Viet</a>
 */
public class JunitXmlFormatter implements Reporter<JunitXmlFormatter.XmlReport> {

  public static class XmlReport {
    final Date timestamp;
    final String name;
    List<TestResult> results = new ArrayList<>();
    AtomicInteger errors = new AtomicInteger();
    AtomicInteger failures = new AtomicInteger();
    AtomicLong time = new AtomicLong();
    private XmlReport(Date timestamp, String name) {
      this.timestamp = timestamp;
      this.name = name;
    }
  }

  private final NumberFormat numberFormat = NumberFormat.getInstance(Locale.ENGLISH);
  private final Function<String, ReportStream> streamFactory;

  public JunitXmlFormatter(Function<String, ReportStream> streamFactory) {
    this.streamFactory = streamFactory;
  }

  @Override
  public XmlReport reportBeginTestSuite(String name) {
    return new XmlReport(new Date(), name);
  }

  @Override
  public void reportBeginTestCase(XmlReport report, String name) {
  }

  @Override
  public void reportEndTestCase(XmlReport report, String name, TestResult result) {
    report.results.add(result);
    if (result.failed()) {
      if (result.failure().isError()) {
        report.errors.incrementAndGet();
      } else {
        report.failures.incrementAndGet();
      }
    }
    report.time.addAndGet(result.durationTime());
  }

  @Override
  public void reportError(XmlReport report, Throwable err) {
    report.results.add(new TestResultImpl(report.name, 0, 0, err));
    report.errors.incrementAndGet();
  }

  @Override
  public void reportEndTestSuite(XmlReport report) {
    // Create xml and send it
    ReportStream stream = streamFactory.apply(report.name);
    try {
      StringWriter buffer = new StringWriter();
      XMLOutputFactory xmlOutputFactory = XMLOutputFactory.newInstance();
      XMLStreamWriter writer = xmlOutputFactory.createXMLStreamWriter(buffer);
      writer.writeStartDocument("UTF-8", "1.0");
      writer.writeStartElement("testsuite");
      writer.writeAttribute("name", report.name);
      SimpleDateFormat sdf;
      sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSSXXX");
      sdf.setTimeZone(TimeZone.getTimeZone("CET"));
      writer.writeAttribute("timestamp", sdf.format(report.timestamp));
      writer.writeAttribute("time", "" + formatTimeMillis(report.time.get()));
      writer.writeAttribute("tests", "" + report.results.size());
      writer.writeAttribute("errors", "" + report.errors.get());
      writer.writeAttribute("failures", "" + report.failures.get());
      writer.writeAttribute("skipped", "0");
      for (TestResult result : report.results) {
        writer.writeStartElement("testcase");
        writer.writeAttribute("name", result.name());
        writer.writeAttribute("time", "" + formatTimeMillis(result.durationTime()));
        if (result.failed()) {
          writer.writeStartElement("failure");
          writer.writeAttribute("type", result.failure().isError() ? "Error" : "AssertionError");
          String msg = result.failure().message();
          writer.writeAttribute("message", msg != null ? msg : "");
          writer.writeCharacters(result.failure().stackTrace());
          writer.writeEndElement();
        }
        writer.writeEndElement();
      }
      writer.writeEndElement();
      writer.writeEndDocument();
      writer.close();
      TransformerFactory factory = TransformerFactory.newInstance();
      Transformer transformer = factory.newTransformer();
      transformer.setOutputProperty(OutputKeys.INDENT, "yes");
      transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "2");
      StreamSource source = new StreamSource(new StringReader(buffer.toString()));
      buffer.getBuffer().setLength(0);
      StreamResult result = new StreamResult(buffer);
      transformer.transform(source, result);
      stream.info(Buffer.buffer(buffer.toString(), "UTF-8"));
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      stream.end();
    }
  }

  private String formatTimeMillis(long timeMillis) {
    return numberFormat.format((((double)timeMillis) / 1000));
  }
}