cleanup

web/.gitignore

@@ -0,0 +1,3 @@
+target/
+.env
+.sqlx/

web/Cargo.toml

@@ -0,0 +1,32 @@
+[package]
+name = "septastic_web"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+actix-web = "4"
+anyhow = "1.0.98"
+dotenv = "0.15.0"
+env_logger = "0.11.8"
+log = "0.4.27"
+serde_json = "1.0.140"
+sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }
+libseptastic = { path = "../libseptastic/" }
+askama = "0.15.4"
+actix-files = "0.6.6"
+serde = "1.0.219"
+chrono = "0.4.41"
+chrono-tz = "0.10.4"
+actix-cors = "0.7.1"
+reqwest = { version = "0.12.22", features = [ "json", "blocking" ] }
+sqlx-cli = "0.8.6"
+futures-util = "0.3.31"
+actix-session = { version = "0.11.0", features = ["cookie-session"] }
+serde_yaml = "0.9.34"
+gtfs-structures = "0.45.1"
+zip = "5.1.1"
+gtfs-realtime = "0.2.0"
+prost = "0.14.1"
+futures = "0.3.31"
+tokio = "1.48.0"
+serde_qs = { version = "1.0.0", features = ["actix4"] }

web/assets/style.css

@@ -0,0 +1,180 @@
+* {
+  font-family: monospace; 
+}
+
+th {
+  text-align: left;
+}
+
+td {
+  text-align: left;
+}
+
+table, th, td {
+  border: 1px solid black;
+}
+
+body {
+    padding: 0 !important;
+    margin: 0 !important;
+}
+
+.body {
+  background-color: #ffffff; 
+  margin: 10px auto;
+  width: 95%;
+}
+
+.body-small {
+  max-width: 750px;
+}
+
+.next-col {
+    background-color: #55ff55 !important;
+}
+
+a {
+  text-decoration: none;
+  color: #114488;
+}
+
+p, h1, h2, h3, h4, h5, h6 {
+    margin: 0;
+}
+
+img {
+  max-width: 100%;
+}
+
+.flag-img {
+    height: 30px;
+}
+
+.nav-link {
+    white-space: nowrap;
+}
+
+.metro-container {
+    font-size: 1.5em;
+    padding: 0.3em;
+    font-weight: bold;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    width: max-content;
+    height: max-content;
+    aspect-ratio: 1 / 1;
+    line-height: 1;
+}
+
+.rr-container {
+    background-color: #4c748c;
+    color: #ffffff;
+    font-size: 1.2em;
+    padding: 0.3em;
+    font-weight: bold;
+    display: flex;
+    align-items: center;
+    justify-content: center;
+    width: max-content;
+    height: max-content;
+    line-height: 1;
+}
+
+.train-direction-table {
+  width: 100%;
+  border-collapse: collapse;
+  font-family: mono;
+  font-size: 14px;
+}
+
+.train-direction-table th,
+.train-direction-table td {
+  border: 1px solid #000;
+  padding: 4px 8px;
+  text-align: left;
+  cursor: pointer;
+}
+
+.train-direction-table th {
+  background-color: #f0f0f0;
+  font-weight: bold;
+}
+
+.highlight-row td,
+.highlight-row th {
+  background-color: #d0ebff !important;
+}
+
+.highlight-col {
+  background-color: #d0ebff !important;
+}
+
+.bg-B1, .bg-B2, .bg-B3  {
+    background-color: #FF661C;
+    color: #ffffff;
+}
+
+.bg-L1 {
+    background-color: #009BDE;
+    color: #ffffff;
+}
+
+.bg-M1 {
+    background-color: #552B9D;
+    color: #ffffff;
+}
+
+.bg-D1, .bg-D2 {
+    background-color: #EA4379;
+    color: #ffffff;
+}
+
+.bg-G1 {
+    background-color: #FFD500;
+    color: #000000;
+}
+
+.bg-T1, .bg-T2, .bg-T3, .bg-T4, .bg-T5 {
+    background-color: #6EA516;
+    color: #ffffff;
+}
+
+.bus-container {
+    display: inline-block;
+    padding: 0.2em 0.5em; /* scales with font size */
+    font-size: 1em; /* or inherit */
+    font-weight: bold;
+    border-radius: 9999px; /* full pill shape */
+    border: 2px solid #000000;
+    background-color: #ffffff;
+    color: #000000;
+    width: max-content;
+    height: max-content;
+}
+.tscroll {
+    width: 100%;
+  overflow: scroll;
+  margin-bottom: 10px;
+}
+
+.tscroll table td:first-child, .tscroll table th:first-child {
+  position: sticky;
+  left: 0;
+  background-color: #ddd;
+ box-shadow: inset 0 0.5px 0 #000000,inset 0 -0.5px 0 #000000,inset 1px 0 0 #000000,inset -1px 0 0 #000000;
+    border-width:0;
+}
+
+.tscroll td, .tscroll th {
+}
+
+details summary > * {
+  display: inline;
+}
+
+details {
+    margin-top: 5px;
+    margin-bottom: 5px;
+    padding: 5px;
+}

web/config.yaml

@@ -0,0 +1,35 @@
+gtfs_zips:
+  - uri: "https://www3.septa.org/developer/gtfs_public.zip"
+    subzip: "google_rail.zip"
+    prefix: "SEPTARAIL"
+  - uri: "https://www3.septa.org/developer/gtfs_public.zip"
+    prefix: "SEPTABUS"
+    subzip: "google_bus.zip"
+annotations:
+  multiplatform_stops:
+    - id: 'WTC'
+      name: 'Wissahickon Transit Center'
+      platform_station_ids:
+        - 'SEPTABUS_2'
+        - 'SEPTABUS_31032'
+        - 'SEPTABUS_32980'
+        - 'SEPTABUS_32988'
+        - 'SEPTABUS_32989'
+        - 'SEPTABUS_32990'
+        - 'SEPTABUS_32992'
+        - 'SEPTABUS_32993'
+        - 'SEPTARAIL_90220'
+    - id: 'STC'
+      name: "Susquehanna Transit Center"
+      platform_station_ids:
+        - 'SEPTABUS_740'
+        - 'SEPTABUS_703'
+        - 'SEPTABUS_699'
+        - 'SEPTABUS_22302'
+    - id: 'CCC'
+      name: "Center City Combined"
+      platform_station_ids:
+        - 'SEPTABUS_3057'
+        - 'SEPTABUS_2687'
+        - 'SEPTABUS_18451'
+        - 'SEPTABUS_17170'

web/src/controllers/index.rs

@@ -0,0 +1,10 @@
+use crate::{
+    session_middleware::{SessionResponder, SessionResponse},
+    templates::IndexTemplate,
+};
+use actix_web::{Responder, get};
+
+#[get("/")]
+async fn get_index_html(resp: SessionResponse) -> impl Responder {
+    resp.respond("Home", "SEPTASTIC Home Page", IndexTemplate {})
+}

web/src/controllers/mod.rs

@@ -0,0 +1,3 @@
+pub mod index;
+pub mod route;
+pub mod stop;

web/src/controllers/route.rs

@@ -0,0 +1,137 @@
+use crate::{
+    AppState,
+    session_middleware::{SessionResponder, SessionResponse},
+};
+use actix_web::{
+    HttpResponse, Responder, get,
+    web::{self, Data},
+};
+use libseptastic::{route::RouteType, stop_schedule::Trip};
+use serde::{Deserialize, Serialize};
+use std::{collections::HashSet, sync::Arc};
+
+#[derive(Debug, Deserialize, Clone)]
+struct RouteQueryParams {
+    #[serde(default)] // Optional: handle missing parameters with a default value
+    stops: Option<String>,
+}
+
+#[derive(Serialize, Deserialize)]
+struct RouteResponse {
+    pub route: libseptastic::route::Route,
+    pub directions: Vec<libseptastic::direction::Direction>,
+    pub schedule: Vec<Trip>,
+}
+
+async fn get_route_info(
+    route_id: String,
+    state: Data<Arc<AppState>>,
+) -> ::anyhow::Result<RouteResponse> {
+    let route = state.gtfs_service.get_route(route_id.clone())?;
+    let mut trips = state.gtfs_service.get_schedule(route_id)?;
+
+    let mut seen = HashSet::new();
+    let directions: Vec<_> = trips
+        .iter()
+        .map(|x| x.direction.clone())
+        .filter(|dir| seen.insert(dir.direction.to_string()))
+        .collect();
+
+    state.trip_tracking_service.annotate_trips(&mut trips).await;
+
+    Ok(RouteResponse {
+        route,
+        directions,
+        schedule: trips,
+    })
+}
+
+#[get("/routes")]
+async fn get_routes_html(state: Data<Arc<AppState>>, resp: SessionResponse) -> impl Responder {
+    let all_routes: Vec<libseptastic::route::Route> = state.gtfs_service.get_routes();
+    let rr_routes = all_routes
+        .clone()
+        .into_iter()
+        .filter(|x| x.route_type == RouteType::RegionalRail)
+        .collect();
+    let subway_routes = all_routes
+        .clone()
+        .into_iter()
+        .filter(|x| x.route_type == RouteType::SubwayElevated)
+        .collect();
+    let trolley_routes = all_routes
+        .clone()
+        .into_iter()
+        .filter(|x| x.route_type == RouteType::Trolley)
+        .collect();
+    let bus_routes = all_routes
+        .into_iter()
+        .filter(|x| x.route_type == RouteType::TracklessTrolley || x.route_type == RouteType::Bus)
+        .collect();
+
+    resp.respond(
+        "Routes",
+        "All routes",
+        crate::templates::RoutesTemplate {
+            rr_routes,
+            subway_routes,
+            trolley_routes,
+            bus_routes,
+        },
+    )
+}
+
+#[get("/routes.json")]
+async fn get_routes_json(state: Data<Arc<AppState>>) -> impl Responder {
+    let all_routes: Vec<libseptastic::route::Route> = state.gtfs_service.get_routes();
+    HttpResponse::Ok().json(all_routes)
+}
+
+#[get("/route/{route_id}")]
+async fn get_route_html(
+    state: Data<Arc<AppState>>,
+    info: web::Query<RouteQueryParams>,
+    path: web::Path<String>,
+    resp: SessionResponse,
+) -> impl Responder {
+    let mut filters: Option<Vec<String>> = None;
+    if let Some(stops_v) = info.stops.clone() {
+        let mut items = Vec::new();
+
+        for sid in stops_v.split(",") {
+            items.push(String::from(sid));
+        }
+        filters = Some(items);
+    }
+
+    let route_id = path;
+    let route_info_r = get_route_info(route_id.clone(), state.clone()).await;
+
+    if let Ok(route_info) = route_info_r {
+        let timetables =
+            crate::templates::build_timetables(route_info.directions, route_info.schedule);
+
+        resp.respond(
+            format!("Schedules for {}", route_id.clone()).as_str(),
+            format!("Schedule information for {}", route_id.clone()).as_str(),
+            crate::templates::RouteTemplate {
+                route: route_info.route,
+                timetables,
+                filter_stops: filters.clone(),
+            },
+        )
+    } else {
+        HttpResponse::InternalServerError().body("")
+    }
+}
+
+#[get("/route/{route_id}.json")]
+async fn get_route_json(state: Data<Arc<AppState>>, path: web::Path<String>) -> impl Responder {
+    let route_id = path.into_inner();
+    let route_info_r = get_route_info(route_id, state).await;
+    if let Ok(route_info) = route_info_r {
+        HttpResponse::Ok().json(route_info)
+    } else {
+        HttpResponse::InternalServerError().body("Error")
+    }
+}

web/src/controllers/stop.rs

@@ -0,0 +1,281 @@
+use crate::{
+    AppState,
+    session_middleware::{SessionResponder, SessionResponse},
+    templates::TripPerspective,
+};
+use actix_web::{
+    HttpResponse, Responder, get,
+    web::{self, Data},
+};
+use askama::Template;
+use chrono::{TimeDelta, Timelike};
+use chrono_tz::America::New_York;
+use libseptastic::stop_schedule::{SeatAvailability, Trip, TripTracking};
+use serde::{Deserialize, Serialize};
+use serde_qs::actix::QsQuery;
+use std::{
+    collections::{BTreeSet, HashSet},
+    sync::Arc,
+};
+
+async fn get_trip_perspective_for_stop(
+    state: &Data<Arc<AppState>>,
+    stop: &libseptastic::stop::Stop,
+    filter: &StopFilter,
+) -> Vec<TripPerspective> {
+    let routes: Vec<libseptastic::route::Route> = state
+        .gtfs_service
+        .get_routes_at_stop(&stop.id)
+        .iter()
+        .filter_map(|route| match state.gtfs_service.get_route(route.clone()) {
+            Ok(route) => Some(route),
+            Err(_) => None,
+        })
+        .collect();
+
+    let route_ids: HashSet<String> = routes.iter().map(|route| route.id.clone()).collect();
+
+    let mut trips = state
+        .gtfs_service
+        .get_all_trips()
+        .iter()
+        .filter_map(|trip| {
+            if route_ids.contains(trip.0) {
+                Some(trip.1.clone())
+            } else {
+                None
+            }
+        })
+        .flatten()
+        .collect();
+
+    state.trip_tracking_service.annotate_trips(&mut trips).await;
+
+    let now_utc = chrono::Utc::now();
+    let now = now_utc.with_timezone(&New_York);
+    let naive_time = now.time();
+    let cur_time = i64::from(naive_time.num_seconds_from_midnight());
+
+    let mut filtered_trips: Vec<TripPerspective> = trips
+        .iter()
+        .filter_map(|trip| {
+            // poor midnight handling? -- going to offset by 4 hours, assume next 'schedule day'
+            // starts at 4a. Still may miss some trips. Oh well!
+            if !trip.calendar_day.is_calendar_active_for_date(
+                &now.naive_local()
+                    .checked_add_signed(TimeDelta::hours(-4))?
+                    .date(),
+            ) {
+                return None;
+            }
+
+            let stop_sched: Vec<_> = trip
+                .schedule
+                .iter()
+                .filter(|stop_schedule| {
+                    if stop_schedule.stop.id != stop.id {
+                        return false;
+                    }
+
+                    match &trip.tracking_data {
+                        libseptastic::stop_schedule::TripTracking::Tracked(live) => {
+                            let actual_arrival_time = stop_schedule.get_arrival_time(&live);
+                            return (actual_arrival_time - cur_time) > -(1 * 60)
+                                && (actual_arrival_time - cur_time) < (60 * 60);
+                        }
+                        libseptastic::stop_schedule::TripTracking::Untracked => {
+                            return (stop_schedule.arrival_time - cur_time) > -(3 * 60)
+                                && (stop_schedule.arrival_time - cur_time) < (60 * 60);
+                        }
+                        libseptastic::stop_schedule::TripTracking::Cancelled => {
+                            return false;
+                        }
+                    }
+                })
+                .filter_map(|ss| Some(ss.clone()))
+                .collect();
+
+            if stop_sched.len() > 0 && filter.trip_matches(trip) {
+                Some(TripPerspective {
+                    perspective_stop: stop_sched.first().unwrap().clone(),
+                    trip: trip.clone(),
+                })
+            } else {
+                None
+            }
+        })
+        .collect();
+
+    filtered_trips.sort_by_key(|f| match &f.trip.tracking_data {
+        TripTracking::Tracked(live) => f.perspective_stop.get_arrival_time(&live),
+        _ => f.perspective_stop.arrival_time,
+    });
+
+    filtered_trips
+}
+
+#[derive(Debug, Serialize, Deserialize, Clone)]
+pub struct StopFilter {
+    pub routes: Option<HashSet<String>>,
+    pub live_tracked: Option<bool>,
+    pub scheduled: Option<bool>,
+    pub crowding: Option<HashSet<SeatAvailability>>,
+    pub unknown_crowding: Option<bool>,
+}
+
+impl StopFilter {
+    pub fn trip_matches(&self, trip: &Trip) -> bool {
+        let unspecified = self.live_tracked == None && self.scheduled == None;
+        let unknown_crowding = self.unknown_crowding.unwrap_or(true);
+
+        if (Some(false) == self.scheduled || (!unspecified && self.scheduled == None))
+            && match trip.tracking_data {
+                TripTracking::Untracked => true,
+                _ => false,
+            }
+        {
+            return false;
+        }
+
+        if (Some(false) == self.live_tracked || (!unspecified && self.live_tracked == None))
+            && match trip.tracking_data {
+                TripTracking::Tracked(_) => true,
+                _ => false,
+            }
+        {
+            return false;
+        }
+
+        if let Some(routes) = &self.routes {
+            let route_str = format!("{},{}", trip.route.id, trip.direction.direction);
+            if !routes.contains(&route_str) {
+                return false;
+            }
+        }
+
+        if let Some(crowding) = &self.crowding {
+            if let TripTracking::Tracked(live_trip) = &trip.tracking_data {
+                if let Some(seat_availability) = &live_trip.seat_availability {
+                    if !crowding.contains(seat_availability) {
+                        return false;
+                    }
+                } else {
+                    return unknown_crowding;
+                }
+            } else {
+                return unknown_crowding;
+            }
+        }
+
+        return true;
+    }
+}
+
+#[get("/stops")]
+async fn get_stops_html(state: Data<Arc<AppState>>, resp: SessionResponse) -> impl Responder {
+    let stops = state
+        .gtfs_service
+        .get_all_stops()
+        .iter()
+        .filter_map(|f| {
+            if f.1.id.contains("ANNOTATED") {
+                Some(libseptastic::stop::Stop::clone(f.1))
+            } else {
+                None
+            }
+        })
+        .collect();
+
+    resp.respond(
+        "Stops",
+        "Stops",
+        crate::templates::StopsTemplate { tc_stops: stops },
+    )
+}
+
+#[get("/stop/{stop_id}/table")]
+async fn get_stop_table_html(
+    state: Data<Arc<AppState>>,
+    path: web::Path<String>,
+    query: QsQuery<StopFilter>,
+) -> impl Responder {
+    let stop_id = path;
+
+    if let Some(stop) = state.gtfs_service.get_stop_by_id(&stop_id) {
+        let filtered_trips = get_trip_perspective_for_stop(&state, &stop, &query).await;
+
+        let now_utc = chrono::Utc::now();
+        let now = now_utc.with_timezone(&New_York);
+        let naive_time = now.time();
+        let cur_time = i64::from(naive_time.num_seconds_from_midnight());
+        let query_str = serde_qs::Config::new()
+            .array_format(serde_qs::ArrayFormat::Unindexed)
+            .serialize_string(&query.0.clone())
+            .unwrap();
+
+        HttpResponse::Ok()
+            .append_header((
+                "HX-Replace-Url",
+                format!("/stop/{}?{}", stop_id, &query_str).as_str(),
+            ))
+            .body(
+                crate::templates::StopTableTemplate {
+                    trips: filtered_trips,
+                    current_time: cur_time,
+                    query_str,
+                    stop_id: stop_id.to_string(),
+                }
+                .render()
+                .unwrap(),
+            )
+    } else {
+        HttpResponse::InternalServerError().body("Error")
+    }
+}
+
+#[get("/stop/{stop_id}")]
+async fn get_stop_html(
+    state: Data<Arc<AppState>>,
+    path: web::Path<String>,
+    query: QsQuery<StopFilter>,
+    resp: SessionResponse,
+) -> impl Responder {
+    let stop_id = path;
+
+    if let Some(stop) = state.gtfs_service.get_stop_by_id(&stop_id) {
+        let routes: Vec<libseptastic::route::Route> = state
+            .gtfs_service
+            .get_routes_at_stop(&stop.id)
+            .iter()
+            .filter_map(|route| match state.gtfs_service.get_route(route.clone()) {
+                Ok(route) => Some(route),
+                Err(_) => None,
+            })
+            .collect();
+
+        let filtered_trips = get_trip_perspective_for_stop(&state, &stop, &query).await;
+
+        let now_utc = chrono::Utc::now();
+        let now = now_utc.with_timezone(&New_York);
+        let naive_time = now.time();
+        let cur_time = i64::from(naive_time.num_seconds_from_midnight());
+
+        resp.respond(
+            stop.name.as_str(),
+            "Stop information",
+            crate::templates::StopTemplate {
+                stop: stop.clone(),
+                routes: BTreeSet::from_iter(routes.into_iter()),
+                trips: filtered_trips,
+                current_time: cur_time,
+                filters: Some(query.0.clone()),
+                query_str: serde_qs::Config::new()
+                    .array_format(serde_qs::ArrayFormat::Unindexed)
+                    .serialize_string(&query.0)
+                    .unwrap(),
+            },
+        )
+    } else {
+        HttpResponse::InternalServerError().body("Error")
+    }
+}

web/src/database.rs

@@ -0,0 +1,179 @@
+use std::collections::HashMap;
+use sqlx::{Postgres, Transaction};
+use libseptastic::{stop_schedule::{Trip, TripTracking, StopSchedule}};
+
+pub async fn get_route_by_id(
+    id: String,
+    transaction: &mut Transaction<'_, Postgres>,
+) -> ::anyhow::Result<libseptastic::route::Route> {
+
+    let row = sqlx::query!(
+        r#"SELECT 
+            id, 
+            name, 
+            short_name, 
+            color_hex, 
+            route_type as "route_type: libseptastic::route::RouteType"
+        FROM 
+            septa_routes
+        WHERE 
+            id = $1
+        ;"#,
+        id
+    )
+    .fetch_one(&mut **transaction)
+    .await?;
+
+    return Ok(libseptastic::route::Route {
+        name: row.name,
+        short_name: row.short_name,
+        color_hex: row.color_hex,
+        route_type: row.route_type,
+        id: row.id,
+    });
+}
+
+pub async fn get_all_routes(
+    transaction: &mut Transaction<'_, Postgres>,
+) -> ::anyhow::Result<Vec<libseptastic::route::Route>> {
+
+    let rows = sqlx::query!(
+        r#"SELECT 
+            id, 
+            name, 
+            short_name, 
+            color_hex, 
+            route_type as "route_type: libseptastic::route::RouteType"
+        FROM 
+            septa_routes
+        ORDER BY
+            CASE
+                WHEN id ~ '^[0-9]+$' THEN CAST(id AS INT)
+                ELSE NULL
+            END ASC,
+            id ASC;
+        ;"#
+    )
+    .fetch_all(&mut **transaction)
+    .await?;
+
+    let mut routes = Vec::new();
+
+    for row in rows {
+        routes.push(libseptastic::route::Route {
+        name: row.name,
+        short_name: row.short_name,
+        color_hex: row.color_hex,
+        route_type: row.route_type,
+        id: row.id,
+        });
+    }
+
+    return Ok(routes);
+}
+
+pub async fn get_direction_by_route_id(
+    id: String,
+    transaction: &mut Transaction<'_, Postgres>,
+) -> ::anyhow::Result<Vec<libseptastic::direction::Direction>> {
+
+    let rows = sqlx::query!(
+        r#"SELECT 
+            route_id,
+            direction_id,
+            direction as "direction: libseptastic::direction::CardinalDirection",
+            direction_destination
+        FROM 
+            septa_directions
+        WHERE 
+            route_id = $1
+        ;"#,
+        id
+    )
+    .fetch_all(&mut **transaction)
+    .await?;
+
+    let mut res = Vec::new();
+
+    for row in rows {
+        res.push(libseptastic::direction::Direction{
+            route_id: row.route_id,
+            direction_id: row.direction_id,
+            direction: row.direction,
+            direction_destination: row.direction_destination
+        });
+    }
+
+    return Ok(res);
+}
+
+pub async fn get_schedule_by_route_id(
+    id: String,
+    transaction: &mut Transaction<'_, Postgres>,
+) -> ::anyhow::Result<Vec<Trip>> {
+
+    let schedule_day = chrono::Utc::now().with_timezone(&chrono_tz::America::New_York);
+    let schedule_day_str = schedule_day.format("%Y%m%d").to_string();
+
+    let rows = sqlx::query!(
+        r#"SELECT 
+            septa_stop_schedules.route_id,
+            septa_stops.name as stop_name,
+            trip_id, 
+            septa_stop_schedules.service_id, 
+            septa_stop_schedules.direction_id,
+            arrival_time,
+            stop_id,
+            stop_sequence
+        FROM 
+            septa_stop_schedules
+        INNER JOIN septa_stops 
+            ON septa_stops.id = septa_stop_schedules.stop_id
+        INNER JOIN septa_schedule_days
+            ON septa_schedule_days.date = $2 
+                AND
+               septa_schedule_days.service_id = septa_stop_schedules.service_id
+        WHERE 
+            septa_stop_schedules.route_id = $1
+        ;"#,
+        id.clone(),
+        schedule_day_str.clone()
+    )
+    .fetch_all(&mut **transaction)
+    .await?;
+
+    let mut sched_groups: HashMap<String, Vec<StopSchedule>> = HashMap::new();
+    for row in rows {
+        let arr = match sched_groups.get_mut(&row.trip_id) {
+            Some(x) => x,
+            None => {
+                sched_groups.insert(row.trip_id.clone(), Vec::new());
+                sched_groups.get_mut(&row.trip_id).unwrap()
+            }
+        };
+
+        arr.push(StopSchedule {
+            route_id: row.route_id,
+            stop_name: row.stop_name,
+            trip_id: row.trip_id,
+            service_id: row.service_id,
+            direction_id: row.direction_id,
+            arrival_time: row.arrival_time,
+            stop_id: row.stop_id,
+            stop_sequence: row.stop_sequence
+        });
+    }
+    let mut res = Vec::new();
+
+    for group in sched_groups {
+        res.push(Trip{
+            trip_id: group.0,
+            route_id: group.1[0].route_id.clone(),
+            schedule: group.1.clone(),
+            direction_id: group.1[0].direction_id.clone(),
+            tracking_data: TripTracking::Untracked 
+        });
+    }
+
+    return Ok(res);
+}

web/src/main.rs

@@ -0,0 +1,66 @@
+use actix_web::{App, HttpServer, web::Data};
+use dotenv::dotenv;
+use env_logger::Env;
+use log::*;
+use services::gtfs_pull;
+use std::{fs::File, io::Read, sync::Arc};
+
+mod controllers;
+mod services;
+mod session_middleware;
+mod templates;
+
+pub struct AppState {
+    gtfs_service: services::gtfs_pull::GtfsPullService,
+    trip_tracking_service: services::trip_tracking::TripTrackingService,
+}
+
+#[tokio::main]
+async fn main() -> ::anyhow::Result<()> {
+    env_logger::init_from_env(Env::default().default_filter_or("septastic_api=info"));
+    dotenv().ok();
+
+    let version: &str = option_env!("CARGO_PKG_VERSION").expect("Expected package version");
+    info!(
+        "Starting the SEPTASTIC Server v{} (commit: {})",
+        version, "NONE"
+    );
+
+    let mut file = File::open("./config.yaml")?;
+    let mut file_contents = String::new();
+    file.read_to_string(&mut file_contents)?;
+
+    let config_file = serde_yaml::from_str::<gtfs_pull::Config>(file_contents.as_str())?;
+
+    let tt_service = services::trip_tracking::TripTrackingService::new().await;
+    tt_service.start();
+
+    let svc = gtfs_pull::GtfsPullService::new(config_file);
+    svc.start();
+    svc.wait_for_ready();
+
+    let state = Arc::new(AppState {
+        gtfs_service: svc,
+        trip_tracking_service: tt_service,
+    });
+
+    HttpServer::new(move || {
+        App::new()
+            .wrap(actix_cors::Cors::permissive())
+            .app_data(Data::new(state.clone()))
+            .service(controllers::route::get_route_html)
+            .service(controllers::route::get_route_json)
+            .service(controllers::route::get_routes_html)
+            .service(controllers::route::get_routes_json)
+            .service(controllers::stop::get_stops_html)
+            .service(controllers::stop::get_stop_html)
+            .service(controllers::stop::get_stop_table_html)
+            .service(controllers::index::get_index_html)
+            .service(actix_files::Files::new("/assets", "./assets"))
+    })
+    .bind(("0.0.0.0", 8080))?
+    .run()
+    .await?;
+
+    Ok(())
+}

web/src/routing.rs

@@ -0,0 +1,225 @@
+use std::{cmp::Ordering, collections::{BTreeSet, HashMap, HashSet}};
+
+use log::info;
+
+use crate::services;
+
+pub struct RoutingNodePointer {
+    pub stop_id: String,
+    pub route_id: String,
+    pub stop_sequence: u64,
+    pub direction: u64,
+    pub dest_dist: f64
+}
+
+pub struct RoutingNode {
+    pub stop_id: String,
+    pub stop_name: String,
+    pub next_stops_per_routes: HashMap<String, BTreeSet<RoutingNodePointer>>,
+    pub visited: bool,
+    pub scratch: i64,
+}
+
+impl Ord for RoutingNodePointer {
+    fn cmp(&self, other: &Self) -> std::cmp::Ordering {
+        if self.dest_dist > other.dest_dist {
+            Ordering::Greater
+        } else {
+            Ordering::Less
+        }
+    }
+}
+
+impl PartialOrd for RoutingNodePointer {
+    fn partial_cmp(&self, other: &Self) -> Option<std::cmp::Ordering> {
+        if self.dest_dist > other.dest_dist {
+            Some(Ordering::Greater)
+        } else {
+            Some(Ordering::Less)
+        }
+    }
+}
+
+impl PartialEq for RoutingNodePointer {
+    fn eq(&self, other: &Self) -> bool {
+        self.stop_id == other.stop_id
+    }
+}
+impl Eq for RoutingNodePointer {
+}
+
+
+struct TripState {
+    pub used_lines: HashSet<String>
+}
+
+#[derive(Clone)]
+pub struct Coordinates {
+    pub lat: f64,
+    pub lng: f64,
+}
+
+pub type RoutingGraph = HashMap::<String, RoutingNode>;
+
+pub fn haversine_distance(lat1: f64, lon1: f64, lat2: f64, lon2: f64) -> f64 {
+    let r = 6371.0; // Earth's radius in kilometers
+
+    let d_lat = (lat2 - lat1).to_radians();
+    let d_lon = (lon2 - lon1).to_radians();
+
+    let lat1_rad = lat1.to_radians();
+    let lat2_rad = lat2.to_radians();
+
+    let a = (d_lat / 2.0).sin().powi(2)
+        + lat1_rad.cos() * lat2_rad.cos() * (d_lon / 2.0).sin().powi(2);
+
+    let c = 2.0 * a.sqrt().asin();
+
+    r * c
+}
+
+
+pub fn get_stops_near(cds: Coordinates, 
+                      all_stops: &HashMap<String, libseptastic::stop::Stop>
+                      ) -> HashSet<String> {
+    let near_thresh_km = 0.45;
+    let mut stops: HashSet<String> = HashSet::new();
+
+    for stop_p in all_stops {
+        let stop = stop_p.1;
+
+        let dist = haversine_distance(cds.lat, cds.lng, stop.lat, stop.lng);
+
+        if dist.abs() < near_thresh_km {
+            stops.insert(stop.id.clone());
+        }
+    }
+
+    stops
+}
+
+pub fn get_stop_as_node() {
+}
+
+pub fn construct_graph(
+    dest: Coordinates,
+    all_stops: &HashMap<String, libseptastic::stop::Stop>,
+    gtfs_service: &services::gtfs_pull::GtfsPullService
+    ) -> RoutingGraph {
+    let mut graph = RoutingGraph::new();
+
+    let limited_rts = vec!["44", "65", "27", "38", "124", "125", "1"];
+
+    for stop_p in all_stops {
+        let stop = stop_p.1;
+
+        let ras = gtfs_service.get_routes_at_stop(&stop.id);
+
+        let cont = {
+            let mut ret = false;
+            for l_rt in limited_rts.clone() {
+                if ras.contains(&String::from(l_rt)) {
+                   ret = true; 
+                   break;
+                }
+            }
+            ret
+        };
+
+        if !cont {
+            continue;
+        }
+
+        graph.insert(stop.id.clone(), RoutingNode { 
+            stop_id: stop.id.clone(), 
+            stop_name: stop.name.clone(),
+            next_stops_per_routes: {
+                let routes = gtfs_service.get_routes_at_stop(&stop.id);
+
+                let mut other_stops = HashMap::<String, BTreeSet<RoutingNodePointer>>::new();
+
+                for route in &routes {
+                    let mut stops = gtfs_service.get_stops_by_route(&route);
+                    stops.remove(&stop.id);
+                    let rnps = {
+                        let mut ret = BTreeSet::new();
+                        for stop in &stops {
+                            let stp = all_stops.get(stop).unwrap();
+                            ret.insert(RoutingNodePointer{
+                                dest_dist: haversine_distance(dest.lat, dest.lng, stp.lat, stp.lng),
+                                stop_id: stop.clone(),
+                                route_id: route.clone(),
+                                stop_sequence: 0,
+                                direction: 0
+                            });
+                        }
+                        ret
+                    };
+                    other_stops.insert(route.clone(), rnps);
+                }
+
+                other_stops
+            },
+            visited: false,
+            scratch: 0
+        });
+    }
+
+    graph
+}
+pub fn bfs_rts_int(route_id: &String, origin: &String, graph: &RoutingGraph, dests: &HashSet<String>, mut visited: HashSet<String>, max_legs: u8) -> Option<String> {
+    if max_legs == 0 {
+        return None;
+    }
+    let mut limited_rts = HashSet::new();
+    for item in vec!["44", "65", "27", "38", "124", "125", "1"] {
+        limited_rts.insert(item);
+    }
+
+            if !limited_rts.contains(&route_id.as_str()) {
+                return None;
+            }
+
+    if let Some(origin_stop) = graph.get(origin) {
+    if dests.contains(origin) {
+        return Some(format!("[stop {} via rt {}] --> DEST", origin_stop.stop_name, route_id))
+    }
+        if visited.contains(origin) {
+            return None;
+        }
+
+        visited.insert(origin.clone());
+
+        for items in &origin_stop.next_stops_per_routes {
+            if route_id == items.0 {
+                continue;
+            }
+
+            for rnp in items.1 {
+                if let Some(rt) = bfs_rts_int(items.0, &rnp.stop_id, graph, dests, visited.clone(), max_legs - 1) {
+                    return Some(format!("[stop {} via rt {}] >>[XFER]>> {}", origin_stop.stop_name, route_id, rt))
+                }        
+            }
+        }
+    }
+
+    None
+}
+
+pub fn bfs_rts(origin: &String, graph: &RoutingGraph, dests: &HashSet<String>) -> String {
+    let mut resp = String::new();
+
+    if let Some(origin_stop) = graph.get(origin) {
+        for items in &origin_stop.next_stops_per_routes {
+            let route_id = items.0;
+
+            for rnp in items.1 {
+                if let Some(rt) = bfs_rts_int(route_id, &rnp.stop_id, graph, dests, HashSet::new(), 3) {
+                    resp += format!("ORIGIN --> [stop {} via rt {}] --> {}\n", origin_stop.stop_name, route_id, rt).as_str();
+                }        
+            }
+        }
+    }
+
+    resp
+}

web/src/services/gtfs_pull.rs

@@ -0,0 +1,601 @@
+use anyhow::anyhow;
+use libseptastic::{stop::Platform, stop_schedule::CalendarDay};
+use log::{error, info, warn};
+use serde::{Deserialize, Serialize};
+use std::{
+    cmp::Ordering,
+    collections::{HashMap, HashSet, hash_map::Entry},
+    env,
+    io::Cursor,
+    path::PathBuf,
+    sync::{Arc, Mutex, MutexGuard},
+    thread,
+    time::Duration,
+};
+use zip::ZipArchive;
+
+macro_rules! make_global_id {
+    ($prefix: expr, $id: expr) => {
+        format!("{}_{}", $prefix, $id)
+    };
+}
+
+#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
+pub struct GtfsSource {
+    pub uri: String,
+    pub subzip: Option<String>,
+    pub prefix: String,
+}
+
+#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
+pub struct MultiplatformStopConfig {
+    pub id: String,
+    pub name: String,
+    pub platform_station_ids: Vec<String>,
+}
+
+#[derive(Serialize, Deserialize, PartialEq, Debug, Clone)]
+pub struct Annotations {
+    pub multiplatform_stops: Vec<MultiplatformStopConfig>,
+}
+
+#[derive(Serialize, Deserialize, PartialEq, Debug)]
+pub struct Config {
+    pub gtfs_zips: Vec<GtfsSource>,
+    pub annotations: Annotations,
+}
+
+#[derive(Clone)]
+pub struct GtfsFile {
+    pub source: GtfsSource,
+}
+
+pub struct TransitData {
+    pub routes: HashMap<String, Arc<libseptastic::route::Route>>,
+    pub agencies: HashMap<String, libseptastic::agency::Agency>,
+    pub trips: HashMap<String, Vec<libseptastic::stop_schedule::Trip>>,
+    pub stops: HashMap<String, Arc<libseptastic::stop::Stop>>,
+    pub platforms: HashMap<String, Arc<libseptastic::stop::Platform>>,
+    pub calendar_days: HashMap<String, Arc<libseptastic::stop_schedule::CalendarDay>>,
+    pub directions: HashMap<String, Vec<Arc<libseptastic::direction::Direction>>>,
+
+    // extended lookup methods
+    pub route_id_by_stops: HashMap<String, HashSet<String>>,
+    pub stops_by_route_id: HashMap<String, HashSet<String>>,
+    pub stops_by_platform_id: HashMap<String, Arc<libseptastic::stop::Stop>>,
+}
+
+pub struct GtfsPullServiceState {
+    pub gtfs_files: Vec<GtfsFile>,
+    pub tmp_dir: PathBuf,
+    pub ready: bool,
+    pub annotations: Annotations,
+    pub transit_data: TransitData,
+}
+
+pub struct GtfsPullService {
+    state: Arc<Mutex<GtfsPullServiceState>>,
+}
+
+impl TransitData {
+    pub fn new() -> Self {
+        return TransitData {
+            routes: HashMap::new(),
+            agencies: HashMap::new(),
+            trips: HashMap::new(),
+            stops: HashMap::new(),
+            platforms: HashMap::new(),
+            route_id_by_stops: HashMap::new(),
+            stops_by_route_id: HashMap::new(),
+            stops_by_platform_id: HashMap::new(),
+            calendar_days: HashMap::new(),
+            directions: HashMap::new(),
+        };
+    }
+}
+
+impl GtfsPullService {
+    const UPDATE_SECONDS: u64 = 3600 * 24;
+    const READYSTATE_CHECK_MILLISECONDS: u64 = 500;
+
+    pub fn new(config: Config) -> Self {
+        Self {
+            state: Arc::new(Mutex::new(GtfsPullServiceState {
+                gtfs_files: config
+                    .gtfs_zips
+                    .iter()
+                    .map(|f| GtfsFile { source: f.clone() })
+                    .collect(),
+                tmp_dir: env::temp_dir(),
+                annotations: config.annotations.clone(),
+                ready: false,
+                transit_data: TransitData::new(),
+            })),
+        }
+    }
+
+    pub fn wait_for_ready(&self) {
+        while !(self.state.lock().unwrap()).ready {
+            thread::sleep(Duration::from_millis(Self::READYSTATE_CHECK_MILLISECONDS));
+        }
+    }
+
+    pub fn start(&self) {
+        let cloned_state = Arc::clone(&self.state);
+        thread::spawn(move || {
+            loop {
+                let recloned_state = Arc::clone(&cloned_state);
+                let res = Self::update_gtfs_data(recloned_state);
+
+                match res {
+                    Err(err) => {
+                        error!("{}", err);
+                    }
+                    _ => {}
+                }
+
+                thread::sleep(Duration::from_secs(Self::UPDATE_SECONDS));
+            }
+        });
+    }
+
+    pub fn get_routes(&self) -> Vec<libseptastic::route::Route> {
+        let l_state = self.state.lock().unwrap();
+        l_state
+            .transit_data
+            .routes
+            .iter()
+            .map(|r| libseptastic::route::Route::clone(r.1))
+            .collect()
+    }
+
+    pub fn get_route(&self, route_id: String) -> anyhow::Result<libseptastic::route::Route> {
+        let l_state = self.state.lock().unwrap();
+        if let Some(route) = l_state.transit_data.routes.get(&route_id) {
+            Ok(libseptastic::route::Route::clone(route))
+        } else {
+            Err(anyhow!(""))
+        }
+    }
+
+    pub fn get_all_routes(&self) -> HashMap<String, libseptastic::route::Route> {
+        let l_state = self.state.lock().unwrap();
+        l_state
+            .transit_data
+            .routes
+            .iter()
+            .map(|r| (r.0.clone(), libseptastic::route::Route::clone(r.1)))
+            .collect()
+    }
+
+    pub fn get_all_stops(&self) -> HashMap<String, Arc<libseptastic::stop::Stop>> {
+        let l_state = self.state.lock().unwrap();
+        l_state.transit_data.stops.clone()
+    }
+
+    pub fn get_all_trips(&self) -> HashMap<String, Vec<libseptastic::stop_schedule::Trip>> {
+        let l_state = self.state.lock().unwrap();
+        l_state.transit_data.trips.clone()
+    }
+
+    pub fn get_routes_at_stop(&self, id: &String) -> HashSet<String> {
+        let l_state = self.state.lock().unwrap();
+        l_state
+            .transit_data
+            .route_id_by_stops
+            .get(id)
+            .unwrap_or(&HashSet::new())
+            .clone()
+    }
+
+    pub fn get_stops_by_route(&self, id: &String) -> HashSet<String> {
+        let l_state = self.state.lock().unwrap();
+        l_state
+            .transit_data
+            .stops_by_route_id
+            .get(id)
+            .unwrap_or(&HashSet::new())
+            .clone()
+    }
+
+    pub fn get_stop_by_id(&self, id: &String) -> Option<libseptastic::stop::Stop> {
+        let l_state = self.state.lock().unwrap();
+        match l_state.transit_data.stops.get(id) {
+            Some(stop) => Some(libseptastic::stop::Stop::clone(stop)),
+            None => None,
+        }
+    }
+
+    pub fn get_schedule(
+        &self,
+        route_id: String,
+    ) -> anyhow::Result<Vec<libseptastic::stop_schedule::Trip>> {
+        let l_state = self.state.lock().unwrap();
+        if let Some(trips) = l_state.transit_data.trips.get(&route_id) {
+            Ok(trips.clone())
+        } else {
+            Err(anyhow!(""))
+        }
+    }
+
+    fn postprocess_stops(state: &mut MutexGuard<'_, GtfsPullServiceState>) -> anyhow::Result<()> {
+        for annotated_stop in state.annotations.multiplatform_stops.clone() {
+            let global_id = make_global_id!("ANNOTATED", annotated_stop.id.clone());
+            let stop = Arc::new(libseptastic::stop::Stop {
+                id: global_id.clone(),
+                name: annotated_stop.name.clone(),
+                platforms: libseptastic::stop::StopType::MultiPlatform(
+                    annotated_stop
+                        .platform_station_ids
+                        .iter()
+                        .map(|platform_id| {
+                            info!(
+                                "Folding {} stop into stop {} as platform",
+                                platform_id.clone(),
+                                annotated_stop.id.clone()
+                            );
+                            let platform = match state
+                                .transit_data
+                                .stops
+                                .remove(platform_id)
+                                .unwrap()
+                                .platforms
+                                .clone()
+                            {
+                                libseptastic::stop::StopType::SinglePlatform(plat) => Ok(plat),
+                                _ => Err(anyhow!("")),
+                            }
+                            .unwrap();
+
+                            state
+                                .transit_data
+                                .stops_by_platform_id
+                                .remove(&platform.id)
+                                .unwrap();
+
+                            platform
+                        })
+                        .collect(),
+                ),
+            });
+
+            state
+                .transit_data
+                .stops
+                .insert(global_id.clone(), stop.clone());
+            match &stop.platforms {
+                libseptastic::stop::StopType::MultiPlatform(platforms) => {
+                    for platform in platforms {
+                        state
+                            .transit_data
+                            .stops_by_platform_id
+                            .insert(platform.id.clone(), stop.clone());
+                    }
+                    Ok(())
+                }
+                _ => Err(anyhow!("")),
+            }?
+        }
+
+        Ok(())
+    }
+
+    fn populate_stops(
+        state: &mut MutexGuard<'_, GtfsPullServiceState>,
+        prefix: &String,
+        gtfs: &gtfs_structures::Gtfs,
+    ) -> anyhow::Result<()> {
+        for stop in &gtfs.stops {
+            let global_id = make_global_id!(prefix, stop.1.id.clone());
+            let platform = Arc::new(Platform {
+                id: global_id.clone(),
+                name: stop.1.name.clone().unwrap(),
+                lat: stop.1.latitude.unwrap(),
+                lng: stop.1.longitude.unwrap(),
+                platform_location: libseptastic::stop::PlatformLocationType::Normal,
+            });
+
+            let stop = Arc::new(libseptastic::stop::Stop {
+                id: global_id.clone(),
+                name: stop.1.name.clone().unwrap(),
+                platforms: libseptastic::stop::StopType::SinglePlatform(platform.clone()),
+            });
+
+            state
+                .transit_data
+                .stops
+                .insert(global_id.clone(), stop.clone());
+            state
+                .transit_data
+                .platforms
+                .insert(global_id.clone(), platform.clone());
+            state
+                .transit_data
+                .stops_by_platform_id
+                .insert(global_id.clone(), stop.clone());
+        }
+
+        Ok(())
+    }
+
+    fn populate_routes(
+        state: &mut MutexGuard<'_, GtfsPullServiceState>,
+        prefix: &String,
+        gtfs: &gtfs_structures::Gtfs,
+    ) -> anyhow::Result<()> {
+        for route in &gtfs.routes {
+            let global_rt_id = make_global_id!(prefix, route.1.id);
+            info!("{}", global_rt_id);
+
+            let rt_name = match route.1.long_name.clone() {
+                Some(x) => x,
+                _ => String::from("Unknown"),
+            };
+
+            let dirs = match state.transit_data.directions.get(&global_rt_id) {
+                Some(x) => x
+                    .iter()
+                    .map(|f| libseptastic::direction::Direction::clone(f))
+                    .collect(),
+                None => {
+                    warn!("Excluding {} because it has no directions", global_rt_id);
+                    continue;
+                }
+            };
+
+            state.transit_data.routes.insert(
+                global_rt_id.clone(),
+                Arc::new(libseptastic::route::Route {
+                    name: rt_name,
+                    directions: dirs,
+                    short_name: match route.1.short_name.clone() {
+                        Some(x) => x,
+                        _ => String::from("unknown"),
+                    },
+                    color_hex: match route.1.color {
+                        Some(x) => x.to_string(),
+                        _ => String::from("unknown"),
+                    },
+                    id: global_rt_id,
+                    route_type: match route.1.route_type {
+                        gtfs_structures::RouteType::Bus => libseptastic::route::RouteType::Bus,
+                        gtfs_structures::RouteType::Rail => {
+                            libseptastic::route::RouteType::RegionalRail
+                        }
+                        gtfs_structures::RouteType::Subway => {
+                            libseptastic::route::RouteType::SubwayElevated
+                        }
+                        gtfs_structures::RouteType::Tramway => {
+                            libseptastic::route::RouteType::Trolley
+                        }
+                        _ => libseptastic::route::RouteType::TracklessTrolley,
+                    },
+                }),
+            );
+        }
+
+        Ok(())
+    }
+
+    fn populate_directions(
+        state: &mut MutexGuard<'_, GtfsPullServiceState>,
+        prefix: &String,
+        gtfs: &gtfs_structures::Gtfs,
+    ) -> anyhow::Result<()> {
+        for trip in &gtfs.trips {
+            let global_rt_id = make_global_id!(prefix, trip.1.route_id);
+
+            let dir = libseptastic::direction::Direction {
+                direction: match trip.1.direction_id.unwrap() {
+                    gtfs_structures::DirectionType::Outbound => {
+                        libseptastic::direction::CardinalDirection::Outbound
+                    }
+                    gtfs_structures::DirectionType::Inbound => {
+                        libseptastic::direction::CardinalDirection::Inbound
+                    }
+                },
+                direction_destination: trip.1.trip_headsign.clone().unwrap(),
+            };
+
+            match state.transit_data.directions.entry(global_rt_id) {
+                Entry::Vacant(e) => {
+                    e.insert(vec![Arc::new(dir)]);
+                }
+                Entry::Occupied(mut e) => {
+                    if e.get()
+                        .iter()
+                        .filter(|x| x.direction == dir.direction)
+                        .count()
+                        == 0
+                    {
+                        e.get_mut().push(Arc::new(dir));
+                    }
+                }
+            }
+        }
+
+        for dir in &mut state.transit_data.directions {
+            dir.1.sort_by(|x, y| {
+                if x.direction > y.direction {
+                    Ordering::Greater
+                } else {
+                    Ordering::Less
+                }
+            });
+        }
+
+        Ok(())
+    }
+
+    fn populate_trips(
+        state: &mut MutexGuard<'_, GtfsPullServiceState>,
+        prefix: &String,
+        gtfs: &gtfs_structures::Gtfs,
+    ) -> anyhow::Result<()> {
+        for trip in &gtfs.trips {
+            let global_rt_id = make_global_id!(prefix, trip.1.route_id);
+            let sched = trip
+                .1
+                .stop_times
+                .iter()
+                .map(|s| {
+                    let global_stop_id = make_global_id!(prefix, s.stop.id);
+
+                    let stop = state
+                        .transit_data
+                        .stops_by_platform_id
+                        .get(&global_stop_id)
+                        .unwrap()
+                        .clone();
+                    let platform = state
+                        .transit_data
+                        .platforms
+                        .get(&global_stop_id)
+                        .unwrap()
+                        .clone();
+
+                    state
+                        .transit_data
+                        .route_id_by_stops
+                        .entry(stop.id.clone())
+                        .or_insert(HashSet::new())
+                        .insert(global_rt_id.clone());
+                    state
+                        .transit_data
+                        .stops_by_route_id
+                        .entry(global_rt_id.clone())
+                        .or_insert(HashSet::new())
+                        .insert(stop.id.clone());
+
+                    state
+                        .transit_data
+                        .route_id_by_stops
+                        .entry(platform.id.clone())
+                        .or_insert(HashSet::new())
+                        .insert(global_rt_id.clone());
+                    state
+                        .transit_data
+                        .stops_by_route_id
+                        .entry(global_rt_id.clone())
+                        .or_insert(HashSet::new())
+                        .insert(platform.id.clone());
+
+                    libseptastic::stop_schedule::StopSchedule {
+                        arrival_time: i64::from(s.arrival_time.unwrap()),
+                        stop_sequence: i64::from(s.stop_sequence),
+                        stop,
+                        platform,
+                    }
+                })
+                .collect();
+
+            if let Some(calendar_day) = state
+                .transit_data
+                .calendar_days
+                .get(&trip.1.service_id.clone())
+            {
+                let trip = libseptastic::stop_schedule::Trip {
+                    trip_id: trip.1.id.clone(),
+                    route: state
+                        .transit_data
+                        .routes
+                        .get(&make_global_id!(prefix, trip.1.route_id))
+                        .unwrap()
+                        .clone(),
+                    direction: libseptastic::direction::Direction {
+                        direction: match trip.1.direction_id.unwrap() {
+                            gtfs_structures::DirectionType::Outbound => {
+                                libseptastic::direction::CardinalDirection::Outbound
+                            }
+                            gtfs_structures::DirectionType::Inbound => {
+                                libseptastic::direction::CardinalDirection::Inbound
+                            }
+                        },
+                        direction_destination: trip.1.trip_headsign.clone().unwrap(),
+                    },
+                    tracking_data: libseptastic::stop_schedule::TripTracking::Untracked,
+                    schedule: sched,
+                    service_id: trip.1.service_id.clone(),
+                    calendar_day: calendar_day.clone(),
+                };
+
+                if let Some(trip_arr) = state.transit_data.trips.get_mut(&global_rt_id) {
+                    trip_arr.push(trip);
+                } else {
+                    state.transit_data.trips.insert(global_rt_id, vec![trip]);
+                }
+            }
+        }
+
+        Ok(())
+    }
+
+    pub fn update_gtfs_data(state: Arc<Mutex<GtfsPullServiceState>>) -> anyhow::Result<()> {
+        let mut l_state = state.lock().unwrap();
+        let files = l_state.gtfs_files.clone();
+        l_state.transit_data = TransitData::new();
+
+        let mut gtfses = Vec::new();
+
+        for gtfs_file in files.iter() {
+            let gtfs = if let Some(subzip) = gtfs_file.source.subzip.clone() {
+                info!(
+                    "Reading GTFS file at {} (subzip {})",
+                    gtfs_file.source.uri, subzip
+                );
+                let res = reqwest::blocking::get(gtfs_file.source.uri.clone())?;
+                let outer_archive = res.bytes()?;
+                let mut archive = ZipArchive::new(Cursor::new(outer_archive))?;
+                archive.extract(l_state.tmp_dir.clone())?;
+
+                let mut file_path = l_state.tmp_dir.clone();
+                file_path.push(subzip.clone());
+
+                info!("Downloaded, parsing");
+
+                gtfs_structures::Gtfs::new(file_path.to_str().unwrap())?
+            } else {
+                info!("Reading GTFS file at {}", gtfs_file.source.uri);
+                gtfs_structures::Gtfs::new(gtfs_file.source.uri.as_str())?
+            };
+
+            gtfses.push((gtfs, gtfs_file.source.prefix.clone()));
+        }
+
+        info!("Data loaded, processing...");
+
+        for (gtfs, prefix) in &gtfses {
+            GtfsPullService::populate_directions(&mut l_state, &prefix, &gtfs)?;
+            GtfsPullService::populate_routes(&mut l_state, &prefix, &gtfs)?;
+            GtfsPullService::populate_stops(&mut l_state, &prefix, &gtfs)?;
+            for calendar in &gtfs.calendar {
+                l_state.transit_data.calendar_days.insert(
+                    calendar.1.id.clone(),
+                    Arc::new(CalendarDay {
+                        id: calendar.1.id.clone(),
+                        monday: calendar.1.monday,
+                        tuesday: calendar.1.tuesday,
+                        wednesday: calendar.1.wednesday,
+                        thursday: calendar.1.thursday,
+                        friday: calendar.1.friday,
+                        saturday: calendar.1.saturday,
+                        sunday: calendar.1.sunday,
+                        start_date: calendar.1.start_date,
+                        end_date: calendar.1.end_date,
+                    }),
+                );
+            }
+        }
+
+        GtfsPullService::postprocess_stops(&mut l_state)?;
+
+        for (gtfs, prefix) in &gtfses {
+            GtfsPullService::populate_trips(&mut l_state, &prefix, &gtfs)?;
+        }
+
+        l_state.ready = true;
+        info!("Finished initial sync, ready state is true");
+
+        Ok(())
+    }
+}

web/src/services/mod.rs

@@ -0,0 +1,2 @@
+pub mod gtfs_pull;
+pub mod trip_tracking;

web/src/services/trip_tracking.rs

@@ -0,0 +1,266 @@
+use chrono::Utc;
+use futures::lock::Mutex;
+use libseptastic::stop_schedule::{LiveTrip, SeatAvailability, TripTracking};
+use log::{error, info};
+use serde::de;
+use serde::{Deserialize, Deserializer, Serialize};
+use serde_json::Value;
+use sqlx::{Postgres, QueryBuilder, Transaction};
+use std::collections::HashMap;
+use std::sync::Arc;
+use std::time::Duration;
+
+#[derive(Debug, Clone, Serialize, Deserialize)]
+pub struct LiveTripJson {
+    pub route_id: String,
+    pub trip_id: String,
+    pub service_id: Option<String>,
+    pub trip_headsign: String,
+    #[serde(deserialize_with = "de_numstro")]
+    pub direction_id: Option<String>,
+    #[serde(deserialize_with = "de_numstr")]
+    pub block_id: String,
+    pub start_time: Option<String>,
+    pub end_time: Option<String>,
+    pub delay: f64,
+    pub status: String,
+    pub lat: Option<String>,
+    pub lon: Option<String>,
+    #[serde(deserialize_with = "de_numstrflo")]
+    pub heading: Option<String>,
+    #[serde(deserialize_with = "de_numstro")]
+    pub next_stop_id: Option<String>,
+    pub next_stop_name: Option<String>,
+    pub next_stop_sequence: Option<i64>,
+    pub seat_availability: Option<String>,
+    pub vehicle_id: Option<String>,
+    pub timestamp: i64,
+}
+
+const HOST: &str = "https://www3.septa.org";
+
+struct TripTrackingServiceState {
+    pub tracking_data: HashMap<String, TripTracking>,
+    pub database: ::sqlx::postgres::PgPool,
+}
+
+pub struct TripTrackingService {
+    state: Arc<Mutex<TripTrackingServiceState>>,
+}
+
+impl TripTrackingService {
+    const UPDATE_SECONDS: u64 = 75;
+
+    pub async fn log_delay(
+        transaction: &mut Transaction<'_, Postgres>,
+        tracking_data: &HashMap<String, TripTracking>,
+        timestamp: i64,
+    ) -> ::anyhow::Result<()> {
+        let mut query_builder: QueryBuilder<Postgres> = QueryBuilder::new(
+            "INSERT INTO 
+                live_tracking
+            (
+                delay_minutes,
+                next_stop_id,
+                timestamp,
+                snapshot_timestamp,
+                lat,
+                lng,
+                heading,
+                seat_availability,
+                vehicle_ids,
+                trip_id,
+                route_id
+            )
+            VALUES",
+        );
+
+        let mut separated = query_builder.separated(", ");
+        for trip in tracking_data {
+            if let TripTracking::Tracked(live_data) = trip.1 {
+                separated.push("(");
+                separated.push_bind_unseparated(live_data.delay);
+                separated.push_bind(live_data.next_stop_id);
+                separated.push_bind(live_data.timestamp);
+                separated.push_bind(timestamp);
+                separated.push_bind(live_data.latitude);
+                separated.push_bind(live_data.longitude);
+                separated.push_bind(live_data.heading);
+                separated.push_bind(match &live_data.seat_availability {
+                    Some(s) => Some(s.to_string()),
+                    None => None,
+                });
+                separated.push_bind(live_data.vehicle_ids.clone());
+                separated.push_bind(live_data.trip_id.clone());
+                separated.push_bind(live_data.route_id.clone());
+                separated.push_unseparated(")");
+            }
+        }
+
+        let query = query_builder.build();
+        query.execute(&mut **transaction).await?;
+
+        Ok(())
+    }
+
+    pub async fn new() -> Self {
+        let connection_string =
+            std::env::var("DB_CONNSTR").expect("Expected database connection string");
+
+        let pool = ::sqlx::postgres::PgPoolOptions::new()
+            .max_connections(5)
+            .connect(&connection_string)
+            .await
+            .unwrap();
+
+        Self {
+            state: Arc::new(Mutex::new(TripTrackingServiceState {
+                tracking_data: HashMap::new(),
+                database: pool,
+            })),
+        }
+    }
+
+    pub fn start(&self) {
+        info!("Starting live tracking service");
+        let cloned_state = Arc::clone(&self.state);
+        tokio::spawn(async move {
+            loop {
+                let clonedx_state = Arc::clone(&cloned_state);
+                let res = Self::update_live_trips(clonedx_state).await;
+
+                match res {
+                    Err(err) => {
+                        error!("{:?}", err);
+                    }
+                    _ => {}
+                }
+
+                tokio::time::sleep(Duration::from_secs(Self::UPDATE_SECONDS)).await;
+            }
+        });
+    }
+
+    pub async fn annotate_trips(&self, trips: &mut Vec<libseptastic::stop_schedule::Trip>) {
+        for trip in trips {
+            trip.tracking_data = match self
+                .state
+                .lock()
+                .await
+                .tracking_data
+                .get(&trip.trip_id.clone())
+            {
+                Some(x) => x.clone(),
+                None => TripTracking::Untracked,
+            };
+        }
+    }
+
+    async fn update_live_trips(
+        service: Arc<Mutex<TripTrackingServiceState>>,
+    ) -> anyhow::Result<()> {
+        let mut new_map: HashMap<String, TripTracking> = HashMap::new();
+        let live_tracks = reqwest::get(format!("{}/api/v2/trips/", HOST))
+            .await?
+            .json::<Vec<LiveTripJson>>()
+            .await?;
+
+        for live_track in live_tracks {
+            let track: TripTracking = {
+                if live_track.status == "NO GPS" {
+                    TripTracking::Untracked
+                } else if live_track.status == "CANCELED" {
+                    TripTracking::Cancelled
+                } else {
+                    TripTracking::Tracked(LiveTrip {
+                        trip_id: live_track.trip_id.clone(),
+                        route_id: live_track.route_id,
+                        delay: live_track.delay,
+                        seat_availability: SeatAvailability::from_opt_string(
+                            &live_track.seat_availability,
+                        ),
+                        heading: match live_track.heading {
+                            Some(hdg) => {
+                                if hdg != "" {
+                                    Some(hdg.parse::<f64>()?)
+                                } else {
+                                    None
+                                }
+                            }
+                            None => None,
+                        },
+                        latitude: match live_track.lat {
+                            Some(lat) => Some(lat.parse::<f64>()?),
+                            None => None,
+                        },
+                        longitude: match live_track.lon {
+                            Some(lon) => Some(lon.parse::<f64>()?),
+                            None => None,
+                        },
+                        next_stop_id: match live_track.next_stop_id {
+                            Some(x) => match x.parse() {
+                                Ok(y) => Some(y),
+                                Err(_) => None,
+                            },
+                            None => None,
+                        },
+                        timestamp: live_track.timestamp,
+                        vehicle_ids: match live_track.vehicle_id {
+                            Some(x) => x.split(",").map(|f| String::from(f)).collect(),
+                            None => vec![],
+                        },
+                    })
+                }
+            };
+
+            if let TripTracking::Cancelled = track {}
+
+            new_map.insert(live_track.trip_id.clone(), track);
+        }
+
+        let mut svc = service.lock().await;
+
+        let mut tx = svc.database.begin().await?;
+        Self::log_delay(&mut tx, &new_map, Utc::now().timestamp_nanos_opt().unwrap()).await?;
+        tx.commit().await?;
+
+        svc.tracking_data = new_map;
+
+        Ok(())
+    }
+}
+
+fn de_numstr<'de, D: Deserializer<'de>>(deserializer: D) -> Result<String, D::Error> {
+    Ok(match Value::deserialize(deserializer)? {
+        Value::String(s) => s,
+        Value::Number(num) => num
+            .as_i64()
+            .ok_or(de::Error::custom("Invalid number"))?
+            .to_string(),
+        _ => return Err(de::Error::custom("wrong type")),
+    })
+}
+
+fn de_numstro<'de, D: Deserializer<'de>>(deserializer: D) -> Result<Option<String>, D::Error> {
+    Ok(match Value::deserialize(deserializer)? {
+        Value::String(s) => Some(s),
+        Value::Number(num) => Some(
+            num.as_i64()
+                .ok_or(de::Error::custom("Invalid number"))?
+                .to_string(),
+        ),
+        _ => None,
+    })
+}
+
+fn de_numstrflo<'de, D: Deserializer<'de>>(deserializer: D) -> Result<Option<String>, D::Error> {
+    Ok(match Value::deserialize(deserializer)? {
+        Value::String(s) => Some(s),
+        Value::Number(num) => Some(
+            num.as_f64()
+                .ok_or(de::Error::custom("Invalid number"))?
+                .to_string(),
+        ),
+        _ => None,
+    })
+}

web/src/session_middleware.rs

@@ -0,0 +1,69 @@
+use actix_web::{FromRequest, HttpRequest, HttpResponse, cookie::Cookie, dev::Payload};
+use askama::Template;
+use serde::Deserialize;
+use std::{pin::Pin, time::Instant};
+
+#[derive(Deserialize)]
+struct LocalStateQuery {
+    pub widescreen: Option<bool>,
+}
+
+pub trait SessionResponder<T: Template> {
+    fn respond(&self, page_title: &str, page_desc: &str, content: T) -> HttpResponse;
+}
+
+pub struct SessionResponse {
+    start_time: Instant,
+    widescreen: bool,
+}
+
+impl<T> SessionResponder<T> for SessionResponse
+where
+    T: Template,
+{
+    fn respond(&self, page_title: &str, page_desc: &str, content: T) -> HttpResponse {
+        let end_time = Instant::now();
+        let mut cookie = Cookie::new("widescreen", self.widescreen.to_string());
+        cookie.set_path("/");
+
+        HttpResponse::Ok().cookie(cookie).body(
+            crate::templates::ContentTemplate {
+                page_title: Some(page_title.to_string()),
+                page_desc: Some(page_desc.to_string()),
+                content,
+                load_time_ms: Some((end_time - self.start_time).as_nanos()),
+                widescreen: self.widescreen,
+            }
+            .render()
+            .unwrap(),
+        )
+    }
+}
+
+impl FromRequest for SessionResponse {
+    type Error = actix_web::Error;
+    type Future = Pin<Box<dyn Future<Output = Result<SessionResponse, Self::Error>>>>;
+
+    fn from_request(req: &HttpRequest, _: &mut Payload) -> Self::Future {
+        let start_time = Instant::now();
+
+        let mut enable_widescreen = true;
+        if let Some(widescreen_set) = req.cookie("widescreen") {
+            enable_widescreen = widescreen_set.value() == "true";
+        }
+
+        let query_params =
+            actix_web::web::Query::<LocalStateQuery>::from_query(req.query_string()).unwrap();
+
+        if let Some(set_widescreen) = query_params.widescreen {
+            enable_widescreen = set_widescreen;
+        }
+
+        Box::pin(async move {
+            Ok(SessionResponse {
+                start_time,
+                widescreen: enable_widescreen,
+            })
+        })
+    }
+}

web/src/templates.rs

@@ -0,0 +1,244 @@
+use chrono::Timelike;
+use chrono_tz::America::New_York;
+use libseptastic::stop_schedule::TripTracking::Tracked;
+use libseptastic::{
+    direction::Direction,
+    stop_schedule::{SeatAvailability, Trip, TripTracking},
+};
+use serde::Serialize;
+use std::{
+    cmp::Ordering,
+    collections::{BTreeMap, BTreeSet},
+};
+
+use crate::controllers::stop::StopFilter;
+
+#[derive(askama::Template)]
+#[template(path = "layout.html")]
+pub struct ContentTemplate<T: askama::Template> {
+    pub content: T,
+    pub page_title: Option<String>,
+    pub page_desc: Option<String>,
+    pub load_time_ms: Option<u128>,
+    pub widescreen: bool,
+}
+
+#[derive(askama::Template)]
+#[template(path = "route.html")]
+pub struct RouteTemplate {
+    pub route: libseptastic::route::Route,
+    pub timetables: Vec<TimetableDirection>,
+    pub filter_stops: Option<Vec<String>>,
+}
+
+#[derive(askama::Template)]
+#[template(path = "routes.html")]
+pub struct RoutesTemplate {
+    pub rr_routes: Vec<libseptastic::route::Route>,
+    pub subway_routes: Vec<libseptastic::route::Route>,
+    pub trolley_routes: Vec<libseptastic::route::Route>,
+    pub bus_routes: Vec<libseptastic::route::Route>,
+}
+
+#[derive(askama::Template)]
+#[template(path = "stops.html")]
+pub struct StopsTemplate {
+    pub tc_stops: Vec<libseptastic::stop::Stop>,
+}
+
+#[derive(askama::Template)]
+#[template(path = "index.html")]
+pub struct IndexTemplate {}
+
+#[derive(Debug, Serialize)]
+pub struct TimetableStopRow {
+    pub stop_id: String,
+    pub stop_name: String,
+    pub stop_sequence: i64,
+    pub times: Vec<Option<i64>>,
+}
+
+#[derive(Debug, Serialize)]
+pub struct TimetableDirection {
+    pub direction: Direction,
+    pub trip_ids: Vec<String>,
+    pub tracking_data: Vec<TripTracking>,
+    pub rows: Vec<TimetableStopRow>,
+    pub next_id: Option<String>,
+}
+
+pub struct TripPerspective {
+    pub trip: libseptastic::stop_schedule::Trip,
+    pub perspective_stop: libseptastic::stop_schedule::StopSchedule,
+}
+
+#[derive(askama::Template)]
+#[template(path = "stop.html")]
+pub struct StopTemplate {
+    pub stop: libseptastic::stop::Stop,
+    pub routes: BTreeSet<libseptastic::route::Route>,
+    pub trips: Vec<TripPerspective>,
+    pub current_time: i64,
+    pub filters: Option<StopFilter>,
+    pub query_str: String,
+}
+
+#[derive(askama::Template)]
+#[template(path = "stop_table_impl.html")]
+pub struct StopTableTemplate {
+    pub trips: Vec<TripPerspective>,
+    pub current_time: i64,
+    pub query_str: String,
+    pub stop_id: String,
+}
+
+pub fn build_timetables(directions: Vec<Direction>, trips: Vec<Trip>) -> Vec<TimetableDirection> {
+    let mut results = Vec::new();
+
+    for direction in directions {
+        let now_utc = chrono::Utc::now();
+        let now = now_utc.with_timezone(&New_York);
+        let naive_time = now.time();
+        let seconds_since_midnight = naive_time.num_seconds_from_midnight();
+
+        let mut next_id: Option<String> = None;
+
+        let mut direction_trips: Vec<&Trip> = trips
+            .iter()
+            .filter(|trip| trip.direction.direction == direction.direction)
+            .collect();
+
+        direction_trips.sort_by_key(|trip| {
+            trip.schedule
+                .iter()
+                .filter_map(|s| Some(s.arrival_time))
+                .min()
+                .unwrap_or(i64::MAX)
+        });
+
+        for trip in direction_trips.clone() {
+            if let Some(last) = trip.schedule.iter().max_by_key(|x| x.arrival_time) {
+                if next_id == None && i64::from(seconds_since_midnight) < last.arrival_time {
+                    next_id = Some(last.stop.id.to_string());
+                }
+            }
+        }
+
+        let trip_ids: Vec<String> = direction_trips.iter().map(|t| t.trip_id.clone()).collect();
+
+        let live_trips: Vec<TripTracking> = direction_trips
+            .iter()
+            .map(|t| t.tracking_data.clone())
+            .collect();
+
+        let mut stop_map: BTreeMap<String, (i64, String, Vec<Option<i64>>)> = BTreeMap::new();
+
+        for (trip_index, trip) in direction_trips.iter().enumerate() {
+            for stop in &trip.schedule {
+                let entry = stop_map.entry(stop.stop.id.clone()).or_insert((
+                    stop.stop_sequence,
+                    stop.stop.name.clone(),
+                    vec![None; direction_trips.len()],
+                ));
+
+                // If this stop_id appears in multiple trips with different sequences, keep the lowest
+                entry.0 = entry.0.max(stop.stop_sequence);
+                entry.1 = stop.stop.name.clone();
+                entry.2[trip_index] = Some(stop.arrival_time);
+            }
+        }
+
+        let mut rows: Vec<TimetableStopRow> = stop_map
+            .into_iter()
+            .map(
+                |(stop_id, (stop_sequence, stop_name, times))| TimetableStopRow {
+                    stop_id,
+                    stop_sequence,
+                    stop_name,
+                    times,
+                },
+            )
+            .collect();
+
+        rows.sort_by(|a, b| {
+            if a.stop_sequence < b.stop_sequence {
+                Ordering::Less
+            } else {
+                Ordering::Greater
+            }
+        });
+
+        results.push(TimetableDirection {
+            direction: direction.clone(),
+            trip_ids,
+            rows,
+            tracking_data: live_trips,
+            next_id,
+        });
+    }
+
+    results
+}
+
+mod filters {
+    use askama::filter_fn;
+
+    #[filter_fn]
+    pub fn format_load_time(nanos: &u128, _: &dyn askama::Values) -> askama::Result<String> {
+        if *nanos >= 1000000000 {
+            return Ok(format!("{}s", (nanos / 1000000000)));
+        } else if *nanos >= 1000000 {
+            return Ok(format!("{}ms", nanos / 1000000));
+        }
+        if *nanos >= 1000 {
+            return Ok(format!("{}us", nanos / 1000));
+        } else {
+            return Ok(format!("{}ns", nanos));
+        }
+    }
+
+    #[filter_fn]
+    pub fn format_time(
+        seconds_since_midnight: &i64,
+        _: &dyn askama::Values,
+    ) -> askama::Result<String> {
+        let total_minutes = seconds_since_midnight / 60;
+        let (hours, ampm) = {
+            let hrs = total_minutes / 60;
+            if hrs > 12 {
+                (hrs - 12, "PM")
+            } else if hrs == 12 {
+                (12, "PM")
+            } else if hrs > 0 {
+                (hrs, "AM")
+            } else {
+                (12, "AM")
+            }
+        };
+        let minutes = total_minutes % 60;
+        Ok(format!("{}:{:02} {}", hours, minutes, ampm))
+    }
+
+    #[filter_fn]
+    pub fn format_time_with_seconds(
+        seconds_since_midnight: &i64,
+        _: &dyn askama::Values,
+    ) -> askama::Result<String> {
+        let total_minutes = seconds_since_midnight / 60;
+        let (hours, ampm) = {
+            let hrs = total_minutes / 60;
+            if hrs > 12 {
+                (hrs - 12, "PM")
+            } else if hrs == 12 {
+                (12, "PM")
+            } else if hrs > 0 {
+                (hrs, "AM")
+            } else {
+                (12, "AM")
+            }
+        };
+        let minutes = total_minutes % 60;
+        let seconds = seconds_since_midnight % 60;
+        Ok(format!("{}:{:02}:{:02} {}", hours, minutes, seconds, ampm))
+    }
+}

web/templates/index.html

@@ -0,0 +1,13 @@
+<h1>SEPTASTIC!</h1>
+<p>
+    <i>A fantastic way to ride SEPTA</i>
+</p>
+<p style="margin-top: 25px;">
+    SEPTASTIC is a website and (a soon to be) mobile app. Its purpose is to provide
+    information about how to ride SEPTA (and connecting transit authorities) in a
+    quick and information-rich manner.
+</p>
+<p style="margin-top: 25px; margin-bottom: 25px;">
+    Currently, all this website has is <a href="/routes">timetables for every
+    SEPTA route</a>. More to come soon!
+</p>

web/templates/layout.html

@@ -0,0 +1,103 @@
+<!DOCTYPE html>
+<html lang="en">
+    <head>
+        {% if let Some(title) = page_title %}
+            <title>{{ title }} | SEPTASTIC</title>
+        {% else %}
+            <title>SEPTASTIC</title>
+        {% endif %}
+        {% if let Some(desc) = page_desc %}
+            <meta name="{{ desc }}" />
+        {% else %}
+            <meta name="SEPTASTIC" />
+        {% endif %}
+        <link rel="stylesheet" href="/assets/style.css">
+        <link rel="icon" type="image/x-icon" href="/assets/favicon.ico">
+        <meta name="viewport" content="width=device-width, initial-scale=1" />
+    </head>
+    <script src="https://cdn.jsdelivr.net/npm/htmx.org@2.0.8/dist/htmx.min.js"></script>
+    <script>
+window.onload = function () {
+    setTimeout(() => {
+        const perfData = window.performance.timing;
+        const pageLoadTime = perfData.loadEventEnd - perfData.navigationStart;
+
+        const loadTimeElement = document.getElementById('js_load_time');
+        loadTimeElement.textContent += ` ${pageLoadTime}ms`;
+    }, 0); // Minimal delay to wait for `loadEventEnd` to be populated
+};
+    </script>
+    <noscript>
+        <style>
+    .js-only {
+        display: none;
+    }
+        </style>
+    </noscript>
+    <style>
+    .silverliner-svg {
+            display: block;
+            width: 100%;
+            height: 200px; /* Fixed height matching the viewBox */
+        }
+    </style>
+    <body>
+        {% if widescreen %}
+            <div class="body">
+            {% else %}
+                <div class="body body-small">
+                {% endif %}
+                <div style="background-color: #ff0000;
+                            color: #ffffff;
+                            font-size: .7em;
+                            padding: 5px;
+                            margin-bottom: 10px;
+                            margin-top: 10px">This website is not run by SEPTA. Data may be inaccurate.</div>
+                <nav>
+                    <div style="display: flex; justify-content: space-between;">
+                        <div>
+                            <a class="nav-link" href="/">[ Home ]</a>
+                            <a class="nav-link" href="/routes">[ Routes ]</a>
+                            <a class="nav-link" href="/stops">[ Stops ]</a>
+                        </div>
+                        <div></div>
+                    </div>
+                </nav>
+                <hr />
+                {{ content|safe }}
+                <footer>
+                    <hr />
+                    <div style="display: flex; justify-content: space-between;">
+                        <div>
+                            <p style="margin-bottom: 0px; margin-top:0px;">
+                                <b>SEPTASTIC!</b>
+                            </p>
+                            <p style="margin-bottom: 0px;margin-top: 0px;">
+                                <small>Copyright &#169; <a href="https://nickorlow.com">Nicholas Orlowsky</a> 2025</small>
+                            </p>
+                            {% if let Some(load_time) = load_time_ms %}
+                                <p style="marin-top: 5px; color: #555555;">
+                                    <small><i>Data loaded in {{ *load_time | format_load_time }}</i></small>
+                                </p>
+                            {% endif %}
+                            <p class="js-only" style="marin-top: 5px; color: #555555;">
+                                <small><i id="js_load_time">Total load time</i></small>
+                            </p>
+                        </div>
+                        <div>
+                            {% if widescreen %}
+                                <a href="?widescreen=false"><small>[ disable widescreen ]</small></a>
+                            {% else %}
+                                <a href="?widescreen=true"><small>[ enable widescreen ]</small></a>
+                            {% endif %}
+                        </div>
+                    </div>
+                    <noscript>
+                        <p style="margin-top: 10px;">
+                            <small>[!] You do not have JavaScript enabled. Many features will be missing/broken!</small>
+                        </p>
+                    </noscript>
+                </footer>
+            </div>
+        </body>
+    </html>

web/templates/route.html

@@ -0,0 +1,138 @@
+{%- import "route_symbol.html" as scope -%}
+<script>
+
+document.addEventListener("DOMContentLoaded", () => {
+  const scrollToNextColumn = (directionId) => {
+    const target = document.getElementById("next-col-" + directionId);
+    if (target) {
+      const scrollContainer = target.closest(".tscroll");
+      const firstCol = scrollContainer.querySelector("th:first-child");
+      const firstColWidth = firstCol ? firstCol.offsetWidth : 0;
+      
+      // Get the target's position relative to the scroll container
+      const targetLeft = target.offsetLeft;
+      
+      // Scroll so the target appears right after the sticky column
+      scrollContainer.scrollLeft = targetLeft - firstColWidth;
+    }
+  };
+
+  document.querySelectorAll("details[data-direction-id]").forEach(details => {
+    const directionId = details.getAttribute("data-direction-id");
+    
+    // Scroll immediately if details is already open
+    if (details.open) {
+      setTimeout(() => scrollToNextColumn(directionId), 50);
+    }
+    
+    // Also scroll when details is opened
+    details.addEventListener("toggle", () => {
+      if (details.open) {
+        setTimeout(() => scrollToNextColumn(directionId), 50);
+      }
+    });
+  });
+  document.querySelectorAll(".train-direction-table").forEach((table) => {
+    table.addEventListener("click", (e) => {
+      const cell = e.target.closest("td, th");
+      if (!cell) return;
+
+      // Clear previous highlights
+      table.querySelectorAll("tr").forEach(row => row.classList.remove("highlight-row"));
+      table.querySelectorAll("td, th").forEach(c => c.classList.remove("highlight-col"));
+
+      const row = cell.parentNode;
+      const colIndex = Array.from(cell.parentNode.children).indexOf(cell);
+
+      // If it's the first column (row header)
+      if (cell.cellIndex === 0 && cell.tagName === "TD") {
+        row.classList.add("highlight-row");
+      }
+      // If it's a column header
+      else if (row.parentNode.tagName === "THEAD") {
+        table.querySelectorAll("tr").forEach(r => {
+          const cell = r.children[colIndex];
+          if (cell) cell.classList.add("highlight-col");
+        });
+      }
+      // If it's a center cell
+      else {
+        row.classList.add("highlight-row");
+        table.querySelectorAll("tr").forEach(r => {
+          const cell = r.children[colIndex];
+          if (cell) cell.classList.add("highlight-col");
+        });
+      }
+    });
+  });
+});
+</script>
+<div style="display: flex; align-items: center;">
+    {% call scope::route_symbol(route) %}
+    {% endcall %}
+    <h1 style="margin-left: 15px;">{{ route.name }}</h1>
+</div>
+{% for timetable in timetables %}
+    <details style="margin-top: 15px"
+             data-direction-id="{{ timetable.direction.direction }}">
+        <summary>
+            <div style="display: inline-block;">
+                <h3>{{ timetable.direction.direction | capitalize }} to</h3>
+                <h2>{{ timetable.direction.direction_destination }}</h2>
+            </div>
+        </summary>
+        <div class="tscroll">
+            <table class="train-direction-table" style="margin-top: 5px;">
+                <thead>
+                    <tr>
+                        <th>Stop</th>
+                        {% for trip_id in timetable.trip_ids %}
+                            {% if let Some(next_id_v) = timetable.next_id %}
+                                {% if next_id_v == trip_id %}
+                                    <th class="next-col" id="next-col-{{ timetable.direction.direction }}">
+                                    {% else %}
+                                        <th>
+                                        {% endif %}
+                                    {% else %}
+                                        <th>
+                                        {% endif %}
+                                        {{ trip_id }}
+                                    </th>
+                                {% endfor %}
+                            </tr>
+                        </thead>
+                        <tbody>
+                            {% for row in timetable.rows %}
+                                {% if let Some(filter_stop_v) = filter_stops %}
+                                    {% if !filter_stop_v.contains(&row.stop_id) %}
+                                        {% continue %}
+                                    {% endif %}
+                                {% endif %}
+                                <tr>
+                                    <td>{{ row.stop_name }}</td>
+                                    {% for time in row.times %}
+                                        {% if let Some(t) = time %}
+                                            {% let live_o = timetable.tracking_data[loop.index0] %}
+                                            {% if let Tracked(live) = live_o %}
+                                                {% let time =  (t + (live.delay * 60.0) as i64) %}
+                                                <td style="background-color: #003300">
+                                                    <span style="color: #22bb22">{{ time | format_time }}</span>
+                                                </td>
+                                            {% elif let TripTracking::Cancelled = live_o %}
+                                                <td style="color: #ff0000">
+                                                    <s>{{ t | format_time }}</s>
+                                                </td>
+                                            {% else %}
+                                                <td>{{ t | format_time }}</td>
+                                            {% endif %}
+                                        {% else %}
+                                            <td></td>
+                                        {% endif %}
+                                    {% endfor %}
+                                </tr>
+                            {% endfor %}
+                        </tbody>
+                    </table>
+                </div>
+            </details>
+        {% endfor %}

web/templates/route_symbol.html

@@ -0,0 +1,13 @@
+{% macro route_symbol(route) %}
+    {% match route.route_type %}
+    {% when libseptastic::route::RouteType::Trolley | libseptastic::route::RouteType::SubwayElevated %}
+    <div class="metro-container bg-{{ route.short_name }}">{{ route.short_name }}</div>
+{% endwhen %}
+{% when libseptastic::route::RouteType::RegionalRail %}
+<div class="rr-container">{{ route.short_name }}</div>
+{% endwhen %}
+{% when libseptastic::route::RouteType::Bus | libseptastic::route::RouteType::TracklessTrolley %}
+<div class="bus-container">{{ route.short_name }}</div>
+{% endwhen %}
+{% endmatch %}
+{% endmacro %}

web/templates/routes.html

@@ -0,0 +1,93 @@
+<h1>Routes</h1>
+<p>Click on a route to see details and a schedule. Schedules in prevailing local time.</p>
+<fieldset>
+    <legend>
+        <h2>Regional Rail</h2>
+    </legend>
+    <p style="margin-top: 10px; margin-bottom: 10px;">For infrequent rail service to suburban locations</p>
+    {% for route in rr_routes %}
+        <a href="/route/{{ route.id }}"
+           style="display: flex;
+                  justify-content: space-between">
+            <p class="line-link">
+                [ <b>{{ format!("{:7}", route.short_name) }}:</b> {{ route.name }}
+            </p>
+            <p>]</p>
+        </a>
+    {% endfor %}
+</fieldset>
+<fieldset>
+    <legend>
+        <h2>Metro</h2>
+    </legend>
+    <p style="margin-top: 10px; margin-bottom: 10px;">
+        For frequent rail service within Philadelphia and suburban locations
+    </p>
+    <div class="lines-label"
+         style="font-weight: bold;
+                width: 100%;
+                display: flex;
+                justify-content: space-between">
+        <p>[ Subway/Elevated</p>
+        <p>]</p>
+    </div>
+    {% for route in subway_routes %}
+        <a href="/route/{{ route.id }}"
+           style="display: flex;
+                  justify-content: space-between">
+            <p class="line-link">
+                [ <b>{{ format!("{:7}", route.short_name) }}:</b> {{ route.name }}
+            </p>
+            <p>]</p>
+        </a>
+    {% endfor %}
+    <div class="lines-label"
+         style="font-weight: bold;
+                width: 100%;
+                display: flex;
+                justify-content: space-between">
+        <p>[ Trolleys</p>
+        <p>]</p>
+    </div>
+    {% for route in trolley_routes %}
+        <a href="/route/{{ route.id }}"
+           style="display: flex;
+                  justify-content: space-between">
+            <p class="line-link">
+                [ <b>{{ format!("{:7}", route.short_name) }}:</b> {{ route.name }}
+            </p>
+            <p>]</p>
+        </a>
+    {% endfor %}
+</fieldset>
+<fieldset>
+    <legend>
+        <h2>Bus</h2>
+    </legend>
+    <p style="margin-top: 10px; margin-bottom: 10px;">
+        For service of varying frequency within SEPTA's entire service area
+    </p>
+    {% for route in bus_routes %}
+        <a href="/route/{{ route.id }}"
+           style="display: flex;
+                  justify-content: space-between">
+            <p class="line-link">
+                [ <b>{{ format!("{:7}", route.short_name) }}:</b> {{ route.name }}
+            </p>
+            <p>]</p>
+        </a>
+    {% endfor %}
+</fieldset>
+<style>
+    .line-link, .lines-label {
+        white-space: pre;
+        margin-top: 3px;
+        margin-bottom: 3px;
+    }
+
+    .lines-label {
+        color: #ffffff;
+        background-color: #000000;
+        width: max-content;
+    }
+</style>

web/templates/stop.html

@@ -0,0 +1,139 @@
+{%- import "route_symbol.html" as scope -%}
+{%- import "stop_table.html" as stop_table -%}
+<div style="display: flex; align-items: center;">
+    <h1>{{ stop.name }}</h1>
+</div>
+<p>With service available on:</p>
+<div style="display: flex;
+            justify-content: start;
+            padding-top: 5px;
+            padding-bottom: 5px;
+            flex-wrap: wrap;
+            gap: 5px">
+    {% for route in routes %}
+        <div style="margin-right: 5px">
+            {% call scope::route_symbol(route) %}
+            {% endcall %}
+        </div>
+    {% endfor %}
+</div>
+<details>
+    <summary>
+        <p style="font-weight: bold; font-size: large;">Filters</p>
+    </summary>
+    <form hx-trigger="submit"
+          hx-get="/stop/{{ stop.id }}/table"
+          hx-target="#nta-table"
+          hx-swap="outerHTML"
+          hx-push-url="/stop/{{ stop.id }}">
+        <div style="margin: 5px; padding: 10px; background-color: #eee;">
+            <div style="display: flex; flex-wrap: wrap;">
+                <fieldset style="flex-grow: 1;">
+                    <legend>Route</legend>
+                    {% for route in routes %}
+                        {% for dir in route.directions %}
+                            {% if let Some(fil) = filters && let Some(rts) = fil.routes %}
+                                {% let route_filter_id = format!("{},{}", route.id, dir.direction) %}
+                                <input type="checkbox"
+                                       class="route-checkbox"
+                                       name="routes"
+                                       id="{{ route.id }},{{ dir.direction }}"
+                                       value="{{ route.id }},{{ dir.direction }}"
+                                       checked="{{ rts.contains(&*route_filter_id) }}">
+                            {% else %}
+                                <input type="checkbox"
+                                       class="route-checkbox"
+                                       name="routes"
+                                       id="{{ route.id }},{{ dir.direction }}"
+                                       value="{{ route.id }},{{ dir.direction }}"
+                                       checked="true">
+                            {% endif %}
+                            <label for="{{ route.id }},{{ dir.direction }}">
+                                <b>{{ route.short_name }}</b>: {{ dir.direction_destination }}
+                            </label>
+                            <br>
+                        {% endfor %}
+                    {% endfor %}
+                    <input type="checkbox"
+                           id="master"
+                           hx-on:click="document.querySelectorAll('.route-checkbox').forEach(c => c.checked = this.checked)">
+                    <label for="master">Select/Deselect All</label>
+                </fieldset>
+                <div style="flex-grow: 1;">
+                    <fieldset>
+                        <legend>Ride Options</legend>
+                        {% if let Some(fil) = filters && let Some(lt) = fil.live_tracked %}
+                            <input type="checkbox"
+                                   name="live_tracked"
+                                   id="live_tracked"
+                                   value="true"
+                                   checked="{{ lt }}">
+                        {% else %}
+                            <input type="checkbox"
+                                   name="live_tracked"
+                                   id="live_tracked"
+                                   value="true"
+                                   checked="true">
+                        {% endif %}
+                        <label for="live-tracked">Live Tracked</label>
+                        <br>
+                        {% if let Some(fil) = filters && let Some(sc) = fil.scheduled %}
+                            <input type="checkbox"
+                                   name="scheduled"
+                                   id="scheduled"
+                                   value="true"
+                                   checked="{{ sc }}">
+                        {% else %}
+                            <input type="checkbox"
+                                   name="scheduled"
+                                   id="scheduled"
+                                   value="true"
+                                   checked="true">
+                        {% endif %}
+                        <label for="scheduled">Scheduled</label>
+                        <br>
+                    </fieldset>
+                    <fieldset>
+                        <legend>Crowding</legend>
+                        {% for avail in SeatAvailability::iter() %}
+                            {% if let Some(fil) = filters && let Some(crd) = fil.crowding %}
+                                <input type="checkbox"
+                                       name="crowding"
+                                       id="{{ avail.to_string() }}"
+                                       value="{{ avail.to_string() }}"
+                                       checked="{{ crd.contains(&avail) }}">
+                            {% else %}
+                                <input type="checkbox"
+                                       name="crowding"
+                                       id="{{ avail.to_string() }}"
+                                       value="{{ avail.to_string() }}"
+                                       checked="true">
+                            {% endif %}
+                            <label for="{{ avail.to_string() }}">{{ avail.to_human_string() }}</label>
+                            <br>
+                        {% endfor %}
+                        {% if let Some(fil) = filters && let Some(uc) = fil.unknown_crowding %}
+                            <input type="checkbox"
+                                   name="unknown_crowding"
+                                   id="unknown_crowding"
+                                   value="true"
+                                   checked="{{ uc }}">
+                        {% else %}
+                            <input type="checkbox"
+                                   name="unknown_crowding"
+                                   id="unknown_crowding"
+                                   value="true"
+                                   checked="true">
+                        {% endif %}
+                        <label for="scheduled">Unknown</label>
+                    </fieldset>
+                </div>
+            </div>
+            <input type="submit" value="Apply">
+        </div>
+    </form>
+</details>
+<div style="overflow-x: scroll; max-width: 100%;">
+    {% call stop_table::stop_table(trips, current_time, stop.id, query_str) %}
+    {% endcall %}
+</div>

web/templates/stop_table.html

@@ -0,0 +1,69 @@
+{%- import "route_symbol.html" as scope -%}
+{% macro stop_table(trips, current_time, stop_id, query_str) %}
+    <div id="nta-table"
+         hx-get="/stop/{{ stop_id }}/table?{{ query_str }}"
+         hx-trigger="every 5s"
+         hx-swap="outer-html">
+        <table class="train-direction-table">
+            <tr>
+                <th>ROUTE</th>
+                <th>DESTINATION</th>
+                <th>BOARDING AREA</th>
+                <th>TIME</th>
+                <th>VEHICLE</th>
+                <th>TRIP</th>
+                <th>CROWDING</th>
+            </tr>
+            {% for trip in trips %}
+                <tr>
+                    <td>
+                        {% call scope::route_symbol(trip.trip.route) %}
+                        {% endcall %}
+                    </td>
+                    <td>
+                        <p>{{ trip.trip.direction.direction_destination }}</p>
+                    </td>
+                    <td>
+                        <p>{{ trip.perspective_stop.platform.name }}</p>
+                    </td>
+                    {% if let Tracked(tracked_trip) = trip.trip.tracking_data %}
+                        <td style="color: #008800">
+                            <p style="font-size: small;">{{ &trip.perspective_stop.get_arrival_time(&tracked_trip) | format_time }}</p>
+                            <p style="font-size: x-small;  font-style: italic;">
+                                {{ ( trip.perspective_stop.get_arrival_time(&tracked_trip) - current_time) / 60 }} mins
+                            </p>
+                            <p style="font-size: x-small;  font-style: italic;">{{ tracked_trip.delay.round() }} late</p>
+                        </td>
+                    {% else %}
+                        <td>
+                            <p style="font-size: small;">{{ trip.perspective_stop.arrival_time | format_time }}</p>
+                            <p style="font-size: x-small;  font-style: italic;">
+                                {{ (trip.perspective_stop.arrival_time - current_time) / 60 }} mins
+                            </p>
+                        </td>
+                    {% endif %}
+                    {% if let Tracked(tracked_trip) = trip.trip.tracking_data %}
+                        <td>{{ tracked_trip.vehicle_ids.join(", ") }}</td>
+                    {% else %}
+                        <td>-</td>
+                    {% endif %}
+                    <td>{{ trip.trip.trip_id }}</td>
+                    {% if let Tracked(tracked_trip) = trip.trip.tracking_data %}
+                        {% if let Some(seat_avail) = tracked_trip.seat_availability %}
+                            <td>{{ seat_avail.to_human_string() }}</td>
+                        {% else %}
+                            <td>N/A</td>
+                        {% endif %}
+                    {% else %}
+                        <td>-</td>
+                    {% endif %}
+                </tr>
+            {% endfor %}
+            <tr>
+                <td colspan="7">
+                    <p>Updated at: {{ current_time | format_time_with_seconds }}</p>
+                </td>
+            </tr>
+        </table>
+    </div>
+{% endmacro %}

web/templates/stop_table_impl.html

@@ -0,0 +1,3 @@
+{%- import "stop_table.html" as stop_table -%}
+{% call stop_table::stop_table(trips, current_time, stop_id, query_str) %}
+{% endcall %}

web/templates/stops.html

@@ -0,0 +1,29 @@
+<h1>Stops</h1>
+<p>Click on a route to see details and a schedule. Schedules in prevailing local time.</p>
+<fieldset>
+    <legend>
+        <h2>Transit Centers</h2>
+    </legend>
+    <p style="margin-top: 10px; margin-bottom: 10px;">Hubs to connect between different modes of transit</p>
+    {% for stop in tc_stops %}
+        <a href="/stop/{{ stop.id }}"
+           style="display: flex;
+                  justify-content: space-between">
+            <p class="line-link">[ {{ stop.name }}</p>
+            <p>]</p>
+        </a>
+    {% endfor %}
+</fieldset>
+<style>
+    .line-link, .lines-label {
+        white-space: pre;
+        margin-top: 3px;
+        margin-bottom: 3px;
+    }
+
+    .lines-label {
+        color: #ffffff;
+        background-color: #000000;
+        width: max-content;
+    }
+</style>