ctabus/main.py

from dateutil.parser import parse as date_parse
from dateutil import tz
import argparse
import ctabus
import datetime
import os
import re
import time
# for logging
import os.path as osp
import sys
import re
CHICAGO_TZ = tz.gettz("America/Chicago")
# https://stackoverflow.com/a/5967539
def atoi(text):
    return int(text) if text.isdigit() else text
def numb_sort(text):
    '''
    alist.sort(key=natural_keys) sorts in human order
    http://nedbatchelder.com/blog/200712/human_sorting.html
    (See Toothy's implementation in the comments)
    '''
    return [ atoi(c) for c in re.split(r'(\d+)', text) ]

def clearscr():
    os.system('cls' if os.name == 'nt' else 'clear')

def pprint_delta(delta):
    delta = str(delta)
    days= None
    s1 = delta.split(', ')
    if len(s1) > 1:
        days,time = s1
    else:
        time = s1[0]
    time = time.split('.')[0]
    hour,minute,second = map(int,time.split(':'))
    time = ''
    if hour:
        time += '{hour} hour'.format(hour=hour) + ('s' if hour != 1 else '')
    if minute:
        if time and not time.endswith(', '):
            time += ', '
        time += '{minute} minute'.format(minute=minute) + ('s' if minute != 1 else '')
    if second:
        if time and not time.endswith(', '):
            time += ', '
        time += '{second} second'.format(second=second) + ('s' if second != 1 else '')
    ret = ''
    if days:
        ret = days + ', ' if time else ''
    ret += time
    return ret

def gen_list(objs,data,*displays,key = None,sort = 0,num_pic = True):
    k = displays[sort]
    display_data = {obj[k]:obj[data] for obj in objs}
    srt_keys = sorted(display_data.keys(),key=key)

    display = sorted(
        [
            [obj[d] for d in displays] for obj in objs
        ],
        key = lambda row: key(row[sort]) if key else row[sort]
    )
    if num_pic:
        display = [[i] + data for i,data in enumerate(display)]

    opts = {
        'spacer':' ',
        'seperator':' ',
        'interactive': True,
        'bottom':'=',
        'l_end':'<',
        'r_end':'>',
        }
    print2d(display,**opts)
    if num_pic:
        which = None
        while not which:
            try:
                which = input('Which one?: ')
            except KeyboardInterrupt:
                quit()
            try:
                which = srt_keys[int(which)]
            except ValueError:
                which = None
        return display_data[which]
    else:
        ret = None
        while not ret:
            try:
                ret =  display_data[input('Which one?: ')]
            except KeyError:
                pass
        return ret

config = '''\
{route} - {end} ({direction})
{nm}, stop {stop_id}
{delta} ({t})\
'''
def show(data,rt_filter=None,_clear=False):
    times = data['prd']
    today = datetime.datetime.now(CHICAGO_TZ)
    arrivals =  sorted(times,key = lambda t: t['prdtm'])
    if rt_filter is not None:
        arrivals =filter(lambda arrival: arrival['rt'] == rt_filter,arrivals)
    if _clear:
        clearscr()
    for time in arrivals:
        before = date_parse(time['prdtm'])
        arrival = before.replace(tzinfo=CHICAGO_TZ)
        if arrival > today:
            stop_id = time['stpid']
            delta = pprint_delta(arrival-today)
            t = arrival.strftime('%H:%M:%S')
            route = time['rt']
            direction = time['rtdir']
            end = time['des']
            nm = time['stpnm'].rstrip()
            print(
                config.format(**locals()),end= '\n'*2
            )
    print("="*36)
if __name__ == '__main__':
    parser = argparse.ArgumentParser(prog = 'ctabus')
    parser.add_argument('-l','--lucky',action='store_true',help = 'picks first result')
    parser.add_argument('-p','--periodic',metavar = 'SEC',type=int,help='checks periodically')
    parser.add_argument('-r','--route',default = None)
    parser.add_argument('-d','--direction',default = None)
    parser.add_argument('arg',nargs = '+',metavar = '(stop-id | cross streets)')
    args = parser.parse_args()
    sys.stderr = open(osp.join(osp.dirname(__file__),'stderr.log'),'w')
    args.arg = ' '.join(args.arg)

    if not args.arg.isdecimal():
        # save on import time slightly
        from print2d import print2d
        from search import Search,StopSearch
        #routes
        if not args.route:
            data = ctabus.get_routes()['routes']
            route = gen_list(data,'rt','rt','rtnm',num_pic = False,key=numb_sort)
        else:
            route = args.route
        data = ctabus.get_directions(route)['directions']
        #direction
        if not args.direction:
            direction = gen_list(data,'dir','dir')
        else:
            s = Search(args.direction)
            direction = sorted((obj['dir'] for obj in data),key = s)[0]
        #direction
        stops = ctabus.get_stops(route,direction)['stops']
        s = StopSearch(args.arg)
        if args.lucky:
            stop_id = sorted(stops,key=lambda stop: s(stop['stpnm']))[0]['stpid']
        else:
            stop_id = gen_list(stops,'stpid','stpnm',key = s)
    else:
        stop_id = args.arg
    data=ctabus.get_times(stop_id)
    if args.periodic is not None:
        _done = False
        while not _done:
            try:
                show(data,args.route,True)
                s = time.perf_counter()
                data = ctabus.get_times(stop_id)
                e = time.perf_counter() - s
                if e < args.periodic:
                    time.sleep(args.periodic-e)
            except KeyboardInterrupt as e:
                _done = True
    else:
        show(data,args.route)