#include "address.h"
#include "gpxparser.h"


qreal GPXParser::number()
{
	bool res;
	qreal ret = _reader.readElementText().toDouble(&res);
	if (!res)
		_reader.raiseError(QString("Invalid %1").arg(
		  _reader.name().toString()));

	return ret;
}

QDateTime GPXParser::time()
{
	QDateTime d = QDateTime::fromString(_reader.readElementText(),
	  Qt::ISODate);
	if (!d.isValid())
		_reader.raiseError(QString("Invalid %1").arg(
		  _reader.name().toString()));

	return d;
}

Link GPXParser::link()
{
	QString URL = _reader.attributes().value("href").toString();
	QString text;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("text"))
			text = _reader.readElementText();
		else
			_reader.skipCurrentElement();
	}

	return Link(URL, text);
}

Coordinates GPXParser::coordinates()
{
	bool res;
	const QXmlStreamAttributes &attr = _reader.attributes();

	qreal lon = attr.value("lon").toDouble(&res);
	if (!res || (lon < -180.0 || lon > 180.0)) {
		_reader.raiseError("Invalid longitude");
		return Coordinates();
	}
	qreal lat = attr.value("lat").toDouble(&res);
	if (!res || (lat < -90.0 || lat > 90.0)) {
		_reader.raiseError("Invalid latitude");
		return Coordinates();
	}

	return Coordinates(lon, lat);
}

void GPXParser::rpExtension(SegmentData *autoRoute)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("rpt")) {
			if (autoRoute)
				autoRoute->append(Trackpoint(coordinates()));
		}
		_reader.skipCurrentElement();
	}
}

void GPXParser::tpExtension(Trackpoint &trackpoint)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("hr"))
			trackpoint.setHeartRate(number());
		else if (_reader.name() == QLatin1String("atemp"))
			trackpoint.setTemperature(number());
		else if (_reader.name() == QLatin1String("wtemp")
		  && !trackpoint.hasTemperature())
			trackpoint.setTemperature(number());
		else if (_reader.name() == QLatin1String("cad"))
			trackpoint.setCadence(number());
		else if (_reader.name() == QLatin1String("speed"))
			trackpoint.setSpeed(number());
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::address(Waypoint &waypoint)
{
	Address addr;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("StreetAddress"))
			addr.setStreet(_reader.readElementText());
		else if (_reader.name() == QLatin1String("City"))
			addr.setCity(_reader.readElementText());
		else if (_reader.name() == QLatin1String("PostalCode"))
			addr.setPostalCode(_reader.readElementText());
		else if (_reader.name() == QLatin1String("State"))
			addr.setState(_reader.readElementText());
		else if (_reader.name() == QLatin1String("Country"))
			addr.setCountry(_reader.readElementText());
		else
			_reader.skipCurrentElement();
	}

	if (addr.isValid())
		waypoint.setAddress(addr.address());
}

void GPXParser::wpExtension(Waypoint &waypoint)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("Address"))
			address(waypoint);
		else if (_reader.name() == QLatin1String("PhoneNumber"))
			waypoint.setPhone(_reader.readElementText());
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::waypointExtensions(Waypoint &waypoint, SegmentData *autoRoute)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("RoutePointExtension"))
			rpExtension(autoRoute);
		else if (_reader.name() == QLatin1String("WaypointExtension"))
			wpExtension(waypoint);
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::trkptExtensions(Trackpoint &trackpoint)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("speed"))
			trackpoint.setSpeed(number());
		else if (_reader.name() == QLatin1String("hr")
		  || _reader.name() == QLatin1String("heartrate"))
			trackpoint.setHeartRate(number());
		else if (_reader.name() == QLatin1String("temp"))
			trackpoint.setTemperature(number());
		else if (_reader.name() == QLatin1String("cadence"))
			trackpoint.setCadence(number());
		else if (_reader.name() == QLatin1String("power")
		  || _reader.name() == QLatin1String("PowerInWatts"))
			trackpoint.setPower(number());
		else if (_reader.name() == QLatin1String("TrackPointExtension"))
			tpExtension(trackpoint);
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::trackpointData(Trackpoint &trackpoint)
{
	qreal gh = NAN;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("ele"))
			trackpoint.setElevation(number());
		else if (_reader.name() == QLatin1String("time"))
			trackpoint.setTimestamp(time());
		else if (_reader.name() == QLatin1String("geoidheight"))
			gh = number();
		// GPX 1.0
		else if (_reader.name() == QLatin1String("speed"))
			trackpoint.setSpeed(number());
		else if (_reader.name() == QLatin1String("extensions"))
			trkptExtensions(trackpoint);
		else
			_reader.skipCurrentElement();
	}

	if (!std::isnan(gh) && !std::isnan(trackpoint.elevation()))
		trackpoint.setElevation(trackpoint.elevation() - gh);
}

void GPXParser::waypointData(Waypoint &waypoint, SegmentData *autoRoute)
{
	qreal gh = NAN;
	Link link10;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("name"))
			waypoint.setName(_reader.readElementText());
		else if (_reader.name() == QLatin1String("desc"))
			waypoint.setDescription(_reader.readElementText());
		else if (_reader.name() == QLatin1String("cmt"))
			waypoint.setComment(_reader.readElementText());
		else if (_reader.name() == QLatin1String("ele"))
			waypoint.setElevation(number());
		else if (_reader.name() == QLatin1String("geoidheight"))
			gh = number();
		else if (_reader.name() == QLatin1String("time"))
			waypoint.setTimestamp(time());
		else if (_reader.name() == QLatin1String("link")) {
			Link l(link());
			if (!l.URL().isEmpty())
				waypoint.addLink(l);
		} else if (_reader.name() == QLatin1String("url"))
			link10.setURL(_reader.readElementText());
		else if (_reader.name() == QLatin1String("urlname"))
			link10.setText(_reader.readElementText());
		else if (_reader.name() == QLatin1String("extensions"))
			waypointExtensions(waypoint, autoRoute);
		else if (_reader.name() == QLatin1String("sym"))
			waypoint.setSymbol(_reader.readElementText());
		else
			_reader.skipCurrentElement();
	}

	if (!link10.URL().isEmpty())
		waypoint.addLink(link10);
	if (!std::isnan(gh) && !std::isnan(waypoint.elevation()))
		waypoint.setElevation(waypoint.elevation() - gh);
}

void GPXParser::trackpoints(SegmentData &segment)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("trkpt")) {
			segment.append(Trackpoint(coordinates()));
			trackpointData(segment.last());
		} else
			_reader.skipCurrentElement();
	}
}

void GPXParser::routeExtension(RouteData &route)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("DisplayColor"))
			route.setStyle(LineStyle(QColor(_reader.readElementText())));
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::routeExtensions(RouteData &track)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("RouteExtension"))
			routeExtension(track);
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::routepoints(RouteData &route, QList<TrackData> &tracks)
{
	TrackData autoRoute;
	autoRoute.append(SegmentData());
	SegmentData &autoRouteSegment = autoRoute.last();
	Link link10;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("rtept")) {
			route.append(Waypoint(coordinates()));
			waypointData(route.last(), &autoRouteSegment);
		} else if (_reader.name() == QLatin1String("name"))
			route.setName(_reader.readElementText());
		else if (_reader.name() == QLatin1String("desc"))
			route.setDescription(_reader.readElementText());
		else if (_reader.name() == QLatin1String("cmt"))
			route.setComment(_reader.readElementText());
		else if (_reader.name() == QLatin1String("link")) {
			Link l(link());
			if (!l.URL().isEmpty())
				route.addLink(l);
		} else if (_reader.name() == QLatin1String("url"))
			link10.setURL(_reader.readElementText());
		else if (_reader.name() == QLatin1String("urlname"))
			link10.setText(_reader.readElementText());
		else if (_reader.name() == QLatin1String("extensions"))
			routeExtensions(route);
		else
			_reader.skipCurrentElement();
	}

	if (!link10.URL().isEmpty())
		route.addLink(link10);

	if (!autoRouteSegment.isEmpty()) {
		autoRoute.setName(route.name());
		autoRoute.setDescription(route.description());
		tracks.append(autoRoute);
	}
}

void GPXParser::trackExtension(TrackData &track)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("DisplayColor"))
			track.setStyle(LineStyle(QColor(_reader.readElementText())));
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::trackExtensions(TrackData &track)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("TrackExtension"))
			trackExtension(track);
		else
			_reader.skipCurrentElement();
	}
}

void GPXParser::track(TrackData &track)
{
	Link link10;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("trkseg")) {
			track.append(SegmentData());
			trackpoints(track.last());
		} else if (_reader.name() == QLatin1String("name"))
			track.setName(_reader.readElementText());
		else if (_reader.name() == QLatin1String("desc"))
			track.setDescription(_reader.readElementText());
		else if (_reader.name() == QLatin1String("cmt"))
			track.setComment(_reader.readElementText());
		else if (_reader.name() == QLatin1String("link")) {
			Link l(link());
			if (!l.URL().isEmpty())
				track.addLink(l);
		} else if (_reader.name() == QLatin1String("url"))
			link10.setURL(_reader.readElementText());
		else if (_reader.name() == QLatin1String("urlname"))
			link10.setText(_reader.readElementText());
		else if (_reader.name() == QLatin1String("extensions"))
			trackExtensions(track);
		else
			_reader.skipCurrentElement();
	}

	if (!link10.URL().isEmpty())
		track.addLink(link10);

	QFile *file = qobject_cast<QFile *>(_reader.device());
	if (file)
		track.setFile(file->fileName());
}

void GPXParser::area(Area &area)
{
	QVector<Coordinates> points;

	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("point")) {
			Coordinates c(coordinates());
			_reader.readElementText();
			if (c.isValid())
				points.append(c);
			else
				return;
		} else if (_reader.name() == QLatin1String("name"))
			area.setName(_reader.readElementText());
		else if (_reader.name() == QLatin1String("desc"))
			area.setDescription(_reader.readElementText());
		else
			_reader.skipCurrentElement();
	}

	area.append(points);
}

void GPXParser::gpxExtensions(QList<Area> &areas)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("area")) {
			areas.append(Area());
			area(areas.last());
		} else
			_reader.skipCurrentElement();
	}
}

void GPXParser::gpx(QList<TrackData> &tracks, QList<RouteData> &routes,
  QList<Area> &areas, QVector<Waypoint> &waypoints)
{
	while (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("trk")) {
			tracks.append(TrackData());
			track(tracks.back());
		} else if (_reader.name() == QLatin1String("rte")) {
			routes.append(RouteData());
			QFile *file = qobject_cast<QFile *>(_reader.device());
			if (file)
				routes.back().setFile(file->fileName());
			routepoints(routes.back(), tracks);
		} else if (_reader.name() == QLatin1String("wpt")) {
			waypoints.append(Waypoint(coordinates()));
			waypointData(waypoints.last());
		} else if (_reader.name() == QLatin1String("extensions"))
			gpxExtensions(areas);
		else
			_reader.skipCurrentElement();
	}
}

bool GPXParser::parse(QFile *file, QList<TrackData> &tracks,
  QList<RouteData> &routes, QList<Area> &areas, QVector<Waypoint> &waypoints)
{
	_reader.clear();
	_reader.setDevice(file);
	_reader.setNamespaceProcessing(false);

	if (_reader.readNextStartElement()) {
		if (_reader.name() == QLatin1String("gpx"))
			gpx(tracks, routes, areas, waypoints);
		else
			_reader.raiseError("Not a GPX file");
	}

	return !_reader.error();
}