autocompleteStations(CharSequence constraint) throws IOException
+ {
+ throw new UnsupportedOperationException();
+ }
+
+ private final String NEARBY_URI = API_BASE
+ + "stboard.exe/dn?input=%s&selectDate=today&boardType=dep&productsFilter=11111111&distance=50&near=Anzeigen";
+
+ @Override
+ protected String nearbyStationUri(final String stationId)
+ {
+ return String.format(NEARBY_URI, stationId);
+ }
+
+ public StationLocationResult stationLocation(String stationId) throws IOException
+ {
+ throw new UnsupportedOperationException();
+ }
+
+ public String departuresQueryUri(final String stationId, final int maxDepartures)
+ {
+ final DateFormat DATE_FORMAT = new SimpleDateFormat("dd.MM.yy");
+ final DateFormat TIME_FORMAT = new SimpleDateFormat("HH:mm");
+ final Date now = new Date();
+
+ final StringBuilder uri = new StringBuilder();
+ uri.append(API_BASE).append("stboard.exe/dn");
+ uri.append("?input=").append(stationId);
+ uri.append("&boardType=dep");
+ uri.append("&time=").append(TIME_FORMAT.format(now));
+ uri.append("&date=").append(DATE_FORMAT.format(now));
+ uri.append("&productsFilter=11111111111");
+ if (maxDepartures != 0)
+ uri.append("&maxJourneys=").append(maxDepartures);
+ uri.append("&disableEquivs=yes"); // don't use nearby stations
+ uri.append("&start=yes");
+
+ return uri.toString();
+ }
+
+ private static final Pattern P_DEPARTURES_HEAD_COARSE = Pattern
+ .compile(
+ ".*?" //
+ + "(?:" //
+ + ".*?" //
+ + "(?:|(verkehren an dieser Haltestelle keine))"//
+ + "|(Eingabe kann nicht interpretiert)|(Verbindung zum Server konnte leider nicht hergestellt werden|kann vom Server derzeit leider nicht bearbeitet werden))" //
+ + ".*?" //
+ , Pattern.DOTALL);
+ private static final Pattern P_DEPARTURES_HEAD_FINE = Pattern.compile(".*?" //
+ + "| \\s*(.*?)\\s*<.*?" // location
+ + "(\\d{2}\\.\\d{2}\\.\\d{2}).*?" // date
+ + "Abfahrt (\\d{1,2}:\\d{2}).*?" // time
+ , Pattern.DOTALL);
+ private static final Pattern P_DEPARTURES_COARSE = Pattern.compile(" | (.*?)
", Pattern.DOTALL);
+ private static final Pattern P_DEPARTURES_FINE = Pattern.compile(".*?" //
+ + "(\\d{1,2}:\\d{2}) | \n" // plannedTime
+ + "(?:\n" //
+ + "(?: |(pünktlich|\\d{1,2}:\\d{2}))\n | \n" // predictedTime
+ + ")?.*?" //
+ + "![](\"/hafas-res/img/(\\w+)_pic\\.gif\"[^)
]*>\\s*(.*?)\\s*\n" //
+ + "]*>" // destinationId
+ + "\\s*(.*?)\\s*\n" // destination
+ + ".*?" //
+ + "(?:\n(" + ParserUtils.P_PLATFORM + ").*?)?" // position
+ , Pattern.DOTALL);
+
+ public QueryDeparturesResult queryDepartures(final String uri) throws IOException
+ {
+ // scrape page
+ final CharSequence page = ParserUtils.scrape(uri);
+
+ // parse page
+ final Matcher mHeadCoarse = P_DEPARTURES_HEAD_COARSE.matcher(page);
+ if (mHeadCoarse.matches())
+ {
+ // messages
+ if (mHeadCoarse.group(3) != null)
+ return new QueryDeparturesResult(uri, Status.NO_INFO);
+ else if (mHeadCoarse.group(4) != null)
+ return new QueryDeparturesResult(uri, Status.INVALID_STATION);
+ else if (mHeadCoarse.group(5) != null)
+ return new QueryDeparturesResult(uri, Status.SERVICE_DOWN);
+
+ final Matcher mHeadFine = P_DEPARTURES_HEAD_FINE.matcher(mHeadCoarse.group(1));
+ if (mHeadFine.matches())
+ {
+ final String location = ParserUtils.resolveEntities(mHeadFine.group(1));
+ final Date currentTime = ParserUtils.joinDateTime(ParserUtils.parseDate(mHeadFine.group(2)), ParserUtils
+ .parseTime(mHeadFine.group(3)));
+ final List departures = new ArrayList(8);
+ String oldZebra = null;
+
+ final Matcher mDepCoarse = P_DEPARTURES_COARSE.matcher(mHeadCoarse.group(2));
+ while (mDepCoarse.find())
+ {
+ final String zebra = mDepCoarse.group(1);
+ if (oldZebra != null && zebra.equals(oldZebra))
+ throw new IllegalArgumentException("missed row? last:" + zebra);
+ else
+ oldZebra = zebra;
+
+ final Matcher mDepFine = P_DEPARTURES_FINE.matcher(mDepCoarse.group(2));
+ if (mDepFine.matches())
+ {
+ final Calendar current = new GregorianCalendar();
+ current.setTime(currentTime);
+ final Calendar parsed = new GregorianCalendar();
+ parsed.setTime(ParserUtils.parseTime(mDepFine.group(1)));
+ parsed.set(Calendar.YEAR, current.get(Calendar.YEAR));
+ parsed.set(Calendar.MONTH, current.get(Calendar.MONTH));
+ parsed.set(Calendar.DAY_OF_MONTH, current.get(Calendar.DAY_OF_MONTH));
+ if (ParserUtils.timeDiff(parsed.getTime(), currentTime) < -PARSER_DAY_ROLLOVER_THRESHOLD_MS)
+ parsed.add(Calendar.DAY_OF_MONTH, 1);
+
+ final Date plannedTime = parsed.getTime();
+
+ Date predictedTime = null;
+ final String prognosis = ParserUtils.resolveEntities(mDepFine.group(2));
+ if (prognosis != null)
+ {
+ if (prognosis.equals("pünktlich"))
+ predictedTime = plannedTime;
+ else
+ predictedTime = ParserUtils.joinDateTime(currentTime, ParserUtils.parseTime(prognosis));
+ }
+
+ final String lineType = mDepFine.group(3);
+
+ final String line = normalizeLine(lineType, ParserUtils.resolveEntities(mDepFine.group(4)));
+
+ final int destinationId = mDepFine.group(5) != null ? Integer.parseInt(mDepFine.group(5)) : 0;
+
+ final String destination = ParserUtils.resolveEntities(mDepFine.group(6));
+
+ final String position = mDepFine.group(7) != null ? "Gl. " + ParserUtils.resolveEntities(mDepFine.group(7)) : null;
+
+ final Departure dep = new Departure(plannedTime, predictedTime, line, line != null ? lineColors(line) : null, null, position,
+ destinationId, destination, null);
+
+ if (!departures.contains(dep))
+ departures.add(dep);
+ }
+ else
+ {
+ throw new IllegalArgumentException("cannot parse '" + mDepCoarse.group(2) + "' on " + uri);
+ }
+ }
+
+ return new QueryDeparturesResult(uri, 0, location, departures);
+ }
+ else
+ {
+ throw new IllegalArgumentException("cannot parse '" + mHeadCoarse.group(1) + "' on " + uri);
+ }
+ }
+ else
+ {
+ throw new IllegalArgumentException("cannot parse '" + page + "' on " + uri);
+ }
+ }
+
+ @Override
+ protected char normalizeType(String type)
+ {
+ final String ucType = type.toUpperCase();
+
+ final char t = normalizeCommonTypes(ucType);
+ if (t != 0)
+ return t;
+
+ if (ucType.equals("INT")) // Zürich-Brüssel
+ return 'I';
+
+ if (ucType.equals("SBS"))
+ return 'S';
+ if (ucType.equals("E")) // Stadtbahn Karlsruhe: S4/S31/xxxxx
+ return 'S';
+
+ if (ucType.equals("BSS"))
+ return 'B';
+ if (ucType.equals("BOV"))
+ return 'B';
+
+ if (ucType.equals("T84")) // U.K.
+ return '?';
+
+ return 0;
+ }
+
+ public QueryConnectionsResult queryConnections(LocationType fromType, String from, LocationType viaType, String via, LocationType toType,
+ String to, Date date, boolean dep, WalkSpeed walkSpeed) throws IOException
+ {
+ throw new UnsupportedOperationException();
+ }
+
+ public QueryConnectionsResult queryMoreConnections(String uri) throws IOException
+ {
+ throw new UnsupportedOperationException();
+ }
+
+ public GetConnectionDetailsResult getConnectionDetails(String connectionUri) throws IOException
+ {
+ throw new UnsupportedOperationException();
+ }
+}
diff --git a/test/de/schildbach/pte/live/VgsProviderLiveTest.java b/test/de/schildbach/pte/live/VgsProviderLiveTest.java
new file mode 100644
index 00000000..e1500646
--- /dev/null
+++ b/test/de/schildbach/pte/live/VgsProviderLiveTest.java
@@ -0,0 +1,49 @@
+/*
+ * Copyright 2010 the original author or authors.
+ *
+ * This program is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program. If not, see .
+ */
+package de.schildbach.pte.live;
+
+import java.util.List;
+
+import org.junit.Test;
+
+import de.schildbach.pte.QueryDeparturesResult;
+import de.schildbach.pte.Station;
+import de.schildbach.pte.VgsProvider;
+
+/**
+ * @author Andreas Schildbach
+ */
+public class VgsProviderLiveTest
+{
+ private final VgsProvider provider = new VgsProvider();
+
+ @Test
+ public void nearbyStation() throws Exception
+ {
+ final List results = provider.nearbyStations("8000244", 0, 0, 0, 0);
+
+ System.out.println(results.size() + " " + results);
+ }
+
+ @Test
+ public void queryDepartures() throws Exception
+ {
+ final QueryDeparturesResult result = provider.queryDepartures(provider.departuresQueryUri("8000244", 0));
+
+ System.out.println(result.departures.size() + " " + result.departures);
+ }
+}
|