started with caching classes

[pywienerlinien] / gotovienna / realtime.py

diff --git a/gotovienna/realtime.py b/gotovienna/realtime.py
index 3f8cb53..d0f276a 100644 (file)
--- a/gotovienna/realtime.py
+++ b/gotovienna/realtime.py
@@ -5,9 +5,39 @@ from urllib2 import urlopen
 from datetime import time
 import re
 import collections
+from errors import LineNotFoundError, StationNotFoundError
 
 from gotovienna import defaults
 
+class Departure:
+    def __init__(self, line, station, direction, time, lowfloor):
+        self.line = line
+        self.station = station
+        self.direction = direction
+        self.time = time
+        self.lowfloor = lowfloor
+
+    def get_departure_time(self):
+        """ return time object of departure time
+        """
+        if type(self.time) == time:
+            return self.time
+        else:
+            pass
+    def get_departure_deltatime(self):
+        """ return int representing minutes until departure
+        """
+        if type(self.time) == int:
+            return self.time
+        else:
+            pass
+
+    def get_ftime(self):
+        if type(self.time) == int:
+            return str(self.time)
+        elif type(self.time) == time:
+            return self.time.strftime('%H:%M')
+
 class ITipParser:
     def __init__(self):
         self._stations = {}
@@ -26,7 +56,7 @@ class ITipParser:
             bs = BeautifulSoup(urlopen(self.lines[name]))
             tables = bs.findAll('table', {'class': 'text_10pix'})
             for i in range(2):
-                dir = tables[i].div.contents[-1].strip(' ')
+                dir = tables[i].div.contents[-1].strip()[6:-6]
 
                 sta = []
                 for tr in tables[i].findAll('tr', {'onmouseout': 'obj_unhighlight(this);'}):
@@ -59,54 +89,101 @@ class ITipParser:
 
         return self._lines
 
+    def get_url_from_direction(self, line, direction, station):
+        stations = self.get_stations(line)
+
+        for stationname, url in stations.get(direction, []):
+            if stationname == station:
+                return url
+
+        return None
+
     def get_departures(self, url):
-        """ Get list of next departures
-        integer if time until next departure
-        time if time of next departure
+        """ Get list of next departures as Departure object
         """
 
         #TODO parse line name and direction for station site parsing
 
         if not url:
             # FIXME prevent from calling this method with None
+            print "ERROR empty url"
             return []
 
-        bs = BeautifulSoup(urlopen(url))
+        # open url for 90 min timeslot / get departure for next 90 min
+        retry = 0
+        tries = 2
+        while retry < tries:
+            bs = BeautifulSoup(urlopen(url + "&departureSizeTimeSlot=90"))
+            try:
+                lines = bs.find('form', {'name': 'mainform'}).table.findAll('tr')[1]
+            except AttributeError:
+                print 'FetchError'
+                msg = bs.findAll('span', {'class': 'rot fett'})
+                if len(msg) > 0 and str(msg[0].text).find(u'technischen St') > 0:
+                    print 'Temporary problem'
+                    print '\n'.join(map(lambda x: x.text.replace('&nbsp;', ''), msg))
+                    # FIXME Change to error message after fixing qml gui
+                    return []
+                # FIXME more testing
+                retry += 1
+                if retry == tries:
+                    return []
+        if len(lines.findAll('td', {'class': 'info'})) > 0:
+            station = lines.span.text.replace('&nbsp;', '')
+            line = lines.findAll('span')[-1].text.replace('&nbsp;', '')
+        else:
+            station = lines.td.span.text.replace('&nbsp;', '')
+            line = lines.find('td', {'align': 'right'}).span.text.replace('&nbsp;', '')
+
         result_lines = bs.findAll('table')[-1].findAll('tr')
 
         dep = []
         for tr in result_lines[1:]:
+            d = {'station': station}
             th = tr.findAll('th')
             if len(th) < 2:
                 #TODO replace with logger
                 print "[DEBUG] Unable to find th in:\n%s" % str(tr)
-                continue
-
+            elif len(th) == 2:
+                # underground site looks different -.-
+                d['lowfloor'] = True
+                d['line'] = line
+                d['direction'] = th[0].text.replace('&nbsp;', '')
+                t = th[-1]
+            else:
+                # all other lines
+                d['lowfloor'] = th[-1].has_key('img') and th[-1].img.has_key('alt')
+                d['line'] = th[0].text.replace('&nbsp;', '')
+                d['direction'] = th[1].text.replace('&nbsp;', '')
+                t = th[-2]
             # parse time
-            time = th[-2].text.split(' ')
-            if len(time) < 2:
-                #print 'Invalid time: %s' % time
+            tim = t.text.split(' ')
+            if len(tim) < 2:
+                # print '[WARNING] Invalid time: %s' % time
                 # TODO: Issue a warning OR convert "HH:MM" format to countdown
-                continue
-
-            time = time[1]
+                tim = tim[0]
+            else:
+                tim = tim[1]
 
-            if time.find('rze...') >= 0:
-                    dep.append(0)
-            elif time.isdigit():
+            if tim.find('rze...') >= 0:
+                    d['time'] = 0
+            elif tim.isdigit():
                 # if time to next departure in cell convert to int
-                dep.append(int(time))
+                d['time'] = int(tim)
             else:
                 # check if time of next departue in cell
-                t = time.strip('&nbsp;').split(':')
+                t = tim.strip('&nbsp;').split(':')
                 if len(t) == 2 and all(map(lambda x: x.isdigit(), t)):
                     t = map(int, t)
-                    dep.append(time(*t))
+                    d['time'] = time(*t)
                 else:
                     # Unexpected content
                     #TODO replace with logger
                     print "[DEBUG] Invalid data:\n%s" % time
 
+            print d
+            dep.append(Departure(**d))
+
         return dep
 
 
@@ -168,4 +245,3 @@ def categorize_lines(lines):
 
     return [(LINE_TYPE_NAMES[key], categorized_lines[key])
             for key in sorted(categorized_lines)]
-