#!/bin/bash | |
#this script should be run from a fresh git checkout from github | |
#ami base must have yum install lighttpd-fastcgi, git, tomcat6 | |
#screen php-cli php-gd tomcat6-webapps tomcat6-admin-webapps svn maven2 | |
#postgrtes postgres-server php-pg | |
#http://www.how2forge.org/installing-lighttpd-with-php5-and-mysql-support-on-fedora-12 | |
cp /root/aws.php /tmp/ | |
mkdir /var/www/lib/staticmaplite/cache | |
chcon -h system_u:object_r:httpd_sys_content_t /var/www | |
chcon -R -h root:object_r:httpd_sys_content_t /var/www/* | |
chcon -R -t httpd_sys_content_rw_t /var/www/lib/staticmaplite/cache | |
chmod -R 777 /var/www/lib/staticmaplite/cache | |
wget http://s3-ap-southeast-1.amazonaws.com/busresources/cbrfeed.zip \ | |
-O /var/www/cbrfeed.zip | |
createdb transitdata | |
createlang -d transitdata plpgsql | |
psql -d transitdata -f /var/www/lib/postgis.sql | |
# curl https://github.com/maxious/ACTBus-ui/raw/master/transitdata.cbrfeed.sql.gz -o transitdata.cbrfeed.sql.gz | |
#made with pg_dump transitdata | gzip -c > transitdata.cbrfeed.sql.gz | |
gunzip /var/www/transitdata.cbrfeed.sql.gz | |
psql -d transitdata -f /var/www/transitdata.cbrfeed.sql | |
#createuser transitdata -SDRP | |
#password transitdata | |
#psql -d transitdata -c \"GRANT SELECT ON TABLE agency,calendar,calendar_dates,routes,stop_times,stops,trips TO transitdata;\" | |
php /var/www/updatedb.php | |
wget http://s3-ap-southeast-1.amazonaws.com/busresources/Graph.obj \ | |
-O /tmp/Graph.obj | |
rm -rfv /usr/share/tomcat6/webapps/opentripplanner* | |
wget http://s3-ap-southeast-1.amazonaws.com/busresources/opentripplanner-webapp.war \ | |
-O /usr/share/tomcat6/webapps/opentripplanner-webapp.war | |
wget http://s3-ap-southeast-1.amazonaws.com/busresources/opentripplanner-api-webapp.war \ | |
-O /usr/share/tomcat6/webapps/opentripplanner-api-webapp.war | |
/etc/init.d/tomcat6 restart | |
# PostgreSQL Client Authentication Configuration File | |
# =================================================== | |
# | |
# Refer to the "Client Authentication" section in the | |
# PostgreSQL documentation for a complete description | |
# of this file. A short synopsis follows. | |
# | |
# This file controls: which hosts are allowed to connect, how clients | |
# are authenticated, which PostgreSQL user names they can use, which | |
# databases they can access. Records take one of these forms: | |
# | |
# local DATABASE USER METHOD [OPTIONS] | |
# host DATABASE USER CIDR-ADDRESS METHOD [OPTIONS] | |
# hostssl DATABASE USER CIDR-ADDRESS METHOD [OPTIONS] | |
# hostnossl DATABASE USER CIDR-ADDRESS METHOD [OPTIONS] | |
# | |
# (The uppercase items must be replaced by actual values.) | |
# | |
# The first field is the connection type: "local" is a Unix-domain socket, | |
# "host" is either a plain or SSL-encrypted TCP/IP socket, "hostssl" is an | |
# SSL-encrypted TCP/IP socket, and "hostnossl" is a plain TCP/IP socket. | |
# | |
# DATABASE can be "all", "sameuser", "samerole", a database name, or | |
# a comma-separated list thereof. | |
# | |
# USER can be "all", a user name, a group name prefixed with "+", or | |
# a comma-separated list thereof. In both the DATABASE and USER fields | |
# you can also write a file name prefixed with "@" to include names from | |
# a separate file. | |
# | |
# CIDR-ADDRESS specifies the set of hosts the record matches. | |
# It is made up of an IP address and a CIDR mask that is an integer | |
# (between 0 and 32 (IPv4) or 128 (IPv6) inclusive) that specifies | |
# the number of significant bits in the mask. Alternatively, you can write | |
# an IP address and netmask in separate columns to specify the set of hosts. | |
# | |
# METHOD can be "trust", "reject", "md5", "password", "gss", "sspi", "krb5", | |
# "ident", "pam", "ldap" or "cert". Note that "password" sends passwords | |
# in clear text; "md5" is preferred since it sends encrypted passwords. | |
# | |
# OPTIONS are a set of options for the authentication in the format | |
# NAME=VALUE. The available options depend on the different authentication | |
# methods - refer to the "Client Authentication" section in the documentation | |
# for a list of which options are available for which authentication methods. | |
# | |
# Database and user names containing spaces, commas, quotes and other special | |
# characters must be quoted. Quoting one of the keywords "all", "sameuser" or | |
# "samerole" makes the name lose its special character, and just match a | |
# database or username with that name. | |
# | |
# This file is read on server startup and when the postmaster receives | |
# a SIGHUP signal. If you edit the file on a running system, you have | |
# to SIGHUP the postmaster for the changes to take effect. You can use | |
# "pg_ctl reload" to do that. | |
# Put your actual configuration here | |
# ---------------------------------- | |
# | |
# If you want to allow non-local connections, you need to add more | |
# "host" records. In that case you will also need to make PostgreSQL listen | |
# on a non-local interface via the listen_addresses configuration parameter, | |
# or via the -i or -h command line switches. | |
# | |
# TYPE DATABASE USER CIDR-ADDRESS METHOD | |
# "local" is for Unix domain socket connections only | |
local all all trust | |
# IPv4 local connections: | |
host all all 127.0.0.1/32 trust | |
# IPv6 local connections: | |
host all all ::1/128 trust | |
<?php | |
if (php_uname('n') == "actbus-www") { | |
$conn = pg_connect("dbname=transitdata user=transitdata password=transitdata host=db.actbus.dotcloud.com port=2242"); | |
} else if (isDebugServer()) { | |
$conn = pg_connect("dbname=transitdata user=postgres password=snmc"); | |
} else { | |
$conn = pg_connect("dbname=transitdata user=transitdata password=transitdata "); | |
} | |
if (!$conn) { | |
die("A database error occurred.\n"); | |
} | |
function databaseError($errMsg) { | |
die($errMsg); | |
} | |
include('db/route-dao.inc.php'); | |
include('db/trip-dao.inc.php'); | |
include('db/stop-dao.inc.php'); | |
?> | |
<?php | <?php |
function getRoute($routeID) { | function getRoute($routeID) { |
$query = "Select * from routes where route_id = '$routeID' LIMIT 1"; | $query = "Select * from routes where route_id = '$routeID' LIMIT 1"; |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_assoc($result); | return pg_fetch_assoc($result); |
} | } |
function getRoutes() { | function getRoutes() { |
global $conn; | global $conn; |
$query = "Select * from routes order by route_short_name;"; | $query = "Select * from routes order by route_short_name;"; |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_all($result); | return pg_fetch_all($result); |
} | } |
function getRoutesByNumber($routeNumber = "") { | function getRoutesByNumber($routeNumber = "") { |
global $conn; | global $conn; |
if ($routeNumber != "") { | if ($routeNumber != "") { |
$query = "Select distinct routes.route_id,routes.route_short_name,routes.route_long_name,service_id from routes join trips on trips.route_id = | $query = "Select distinct routes.route_id,routes.route_short_name,routes.route_long_name,service_id from routes join trips on trips.route_id = |
routes.route_id join stop_times on stop_times.trip_id = trips.trip_id where route_short_name = '$routeNumber' order by route_short_name;"; | routes.route_id join stop_times on stop_times.trip_id = trips.trip_id where route_short_name = '$routeNumber' order by route_short_name;"; |
} else { | } else { |
$query = "SELECT DISTINCT route_short_name from routes order by route_short_name"; | $query = "SELECT DISTINCT route_short_name from routes order by route_short_name"; |
} | } |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_all($result); | return pg_fetch_all($result); |
} | } |
function getRouteNextTrip($routeID) { | function getRouteNextTrip($routeID) { |
global $conn; | |
$query = "select * from routes join trips on trips.route_id = routes.route_id | $query = "select * from routes join trips on trips.route_id = routes.route_id |
join stop_times on stop_times.trip_id = trips.trip_id where | join stop_times on stop_times.trip_id = trips.trip_id where |
arrival_time > CURRENT_TIME and routes.route_id = '$routeID' order by | arrival_time > CURRENT_TIME and routes.route_id = '$routeID' order by |
arrival_time limit 1"; | arrival_time limit 1"; |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_assoc($result); | return pg_fetch_assoc($result); |
} | } |
function getRouteTrips($routeID) { | |
global $conn; | |
$query = "select * from routes join trips on trips.route_id = routes.route_id | |
join stop_times on stop_times.trip_id = trips.trip_id where routes.route_id = '$routeID' order by | |
arrival_time "; | |
debug($query,"database"); | |
$result = pg_query($conn, $query); | |
if (!$result) { | |
databaseError(pg_result_error($result)); | |
return Array(); | |
} | |
return pg_fetch_all($result); | |
} | |
function getRoutesByDestination($destination = "", $service_period = "") { | function getRoutesByDestination($destination = "", $service_period = "") { |
global $conn; | global $conn; |
if ($service_period == "") $service_period = service_period(); | if ($service_period == "") $service_period = service_period(); |
if ($destination != "") { | if ($destination != "") { |
$query = "SELECT DISTINCT trips.route_id,route_short_name,route_long_name, service_id | $query = "SELECT DISTINCT trips.route_id,route_short_name,route_long_name, service_id |
FROM stop_times join trips on trips.trip_id = | FROM stop_times join trips on trips.trip_id = |
stop_times.trip_id join routes on trips.route_id = routes.route_id | stop_times.trip_id join routes on trips.route_id = routes.route_id |
WHERE route_long_name = '$destination' AND service_id='$service_period' order by route_short_name"; | WHERE route_long_name = '$destination' AND service_id='$service_period' order by route_short_name"; |
} else { | } else { |
$query = "SELECT DISTINCT route_long_name | $query = "SELECT DISTINCT route_long_name |
FROM stop_times join trips on trips.trip_id = | FROM stop_times join trips on trips.trip_id = |
stop_times.trip_id join routes on trips.route_id = routes.route_id | stop_times.trip_id join routes on trips.route_id = routes.route_id |
WHERE service_id='$service_period' order by route_long_name"; | WHERE service_id='$service_period' order by route_long_name"; |
} | } |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_all($result); | return pg_fetch_all($result); |
} | } |
function getRoutesBySuburb($suburb, $service_period = "") { | function getRoutesBySuburb($suburb, $service_period = "") { |
if ($service_period == "") $service_period = service_period(); | if ($service_period == "") $service_period = service_period(); |
global $conn; | global $conn; |
$query = "SELECT DISTINCT service_id,trips.route_id,route_short_name,route_long_name | $query = "SELECT DISTINCT service_id,trips.route_id,route_short_name,route_long_name |
FROM stop_times join trips on trips.trip_id = stop_times.trip_id | FROM stop_times join trips on trips.trip_id = stop_times.trip_id |
join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
join stops on stops.stop_id = stop_times.stop_id | join stops on stops.stop_id = stop_times.stop_id |
WHERE zone_id LIKE '%$suburb;%' AND service_id='$service_period' ORDER BY route_short_name"; | WHERE zone_id LIKE '%$suburb;%' AND service_id='$service_period' ORDER BY route_short_name"; |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_all($result); | return pg_fetch_all($result); |
} | } |
function getRoutesNearby($lat, $lng, $limit = "", $distance = 500) { | function getRoutesNearby($lat, $lng, $limit = "", $distance = 500) { |
if ($service_period == "") $service_period = service_period(); | if ($service_period == "") $service_period = service_period(); |
if ($limit != "") $limit = " LIMIT $limit "; | if ($limit != "") $limit = " LIMIT $limit "; |
global $conn; | global $conn; |
$query = "SELECT service_id,trips.route_id,route_short_name,route_long_name, | $query = "SELECT service_id,trips.route_id,route_short_name,route_long_name, |
min(ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE)) as distance | min(ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE)) as distance |
FROM stop_times | FROM stop_times |
join trips on trips.trip_id = stop_times.trip_id | join trips on trips.trip_id = stop_times.trip_id |
join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
join stops on stops.stop_id = stop_times.stop_id | join stops on stops.stop_id = stop_times.stop_id |
WHERE service_id='$service_period' | WHERE service_id='$service_period' |
AND ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), $distance, FALSE) | AND ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), $distance, FALSE) |
group by service_id,trips.route_id,route_short_name,route_long_name | group by service_id,trips.route_id,route_short_name,route_long_name |
order by distance $limit"; | order by distance $limit"; |
debug($query,"database"); | debug($query,"database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_all($result); | return pg_fetch_all($result); |
} | } |
?> | ?> |
<?php | <?php |
function getTrip($tripID) | function getTrip($tripID) |
{ | { |
global $conn; | global $conn; |
$query = "Select * from trips where trip_id = '$tripID' join routes on trips.route_id = routes.route_id LIMIT 1"; | $query = "Select * from trips |
join routes on trips.route_id = routes.route_id | |
where trip_id = '$tripID' | |
LIMIT 1"; | |
debug($query, "database"); | debug($query, "database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
return pg_fetch_assoc($result); | return pg_fetch_assoc($result); |
} | } |
function getTripShape() | function getTripShape() |
{ | { |
/* def handle_json_GET_tripstopTimes(self, params): | /* def handle_json_GET_tripstopTimes(self, params): |
schedule = self.server.schedule | schedule = self.server.schedule |
try: | try: |
trip = schedule.GetTrip(params.get('trip')) | trip = schedule.GetTrip(params.get('trip')) |
except KeyError: | except KeyError: |
# if a non-existent trip is searched for, the return nothing | # if a non-existent trip is searched for, the return nothing |
return | return |
time_stops = trip.GetTimeInterpolatedStops() | time_stops = trip.GetTimeInterpolatedStops() |
stops = [] | stops = [] |
times = [] | times = [] |
for arr,ts,is_timingpoint in time_stops: | for arr,ts,is_timingpoint in time_stops: |
stops.append(StopToTuple(ts.stop)) | stops.append(StopToTuple(ts.stop)) |
times.append(arr) | times.append(arr) |
return [stops, times] | return [stops, times] |
def handle_json_GET_tripshape(self, params): | def handle_json_GET_tripshape(self, params): |
schedule = self.server.schedule | schedule = self.server.schedule |
try: | try: |
trip = schedule.GetTrip(params.get('trip')) | trip = schedule.GetTrip(params.get('trip')) |
except KeyError: | except KeyError: |
# if a non-existent trip is searched for, the return nothing | # if a non-existent trip is searched for, the return nothing |
return | return |
points = [] | points = [] |
if trip.shape_id: | if trip.shape_id: |
shape = schedule.GetShape(trip.shape_id) | shape = schedule.GetShape(trip.shape_id) |
for (lat, lon, dist) in shape.points: | for (lat, lon, dist) in shape.points: |
points.append((lat, lon)) | points.append((lat, lon)) |
else: | else: |
time_stops = trip.GetTimeStops() | time_stops = trip.GetTimeStops() |
for arr,dep,stop in time_stops: | for arr,dep,stop in time_stops: |
points.append((stop.stop_lat, stop.stop_lon)) | points.append((stop.stop_lat, stop.stop_lon)) |
return points*/ | return points*/ |
} | } |
function getTimeInterpolatedTrip($tripID) | function getTimeInterpolatedTrip($tripID) |
{ | { |
global $conn; | global $conn; |
$query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_lat,stop_lon, | $query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_lat,stop_lon,stop_name,stop_code, |
stop_sequence,service_id,trips.route_id,route_short_name,route_long_name | stop_sequence,service_id,trips.route_id,route_short_name,route_long_name |
FROM stop_times | FROM stop_times |
join trips on trips.trip_id = stop_times.trip_id | join trips on trips.trip_id = stop_times.trip_id |
join routes on trips.route_id = routes.route_id | join routes on trips.route_id = routes.route_id |
join stops on stops.stop_id = stop_times.stop_id | join stops on stops.stop_id = stop_times.stop_id |
WHERE trips.trip_id = '$tripID' ORDER BY stop_sequence"; | WHERE trips.trip_id = '$tripID' ORDER BY stop_sequence"; |
debug($query, "database"); | debug($query, "database"); |
$result = pg_query($conn, $query); | $result = pg_query($conn, $query); |
if (!$result) { | if (!$result) { |
databaseError(pg_result_error($result)); | databaseError(pg_result_error($result)); |
return Array(); | return Array(); |
} | } |
$stopTimes = pg_fetch_all($result); | $stopTimes = pg_fetch_all($result); |
$cur_timepoint = Array(); | $cur_timepoint = Array(); |
$next_timepoint = Array(); | $next_timepoint = Array(); |
$distance_between_timepoints = 0.0; | $distance_between_timepoints = 0.0; |
$distance_traveled_between_timepoints = 0.0; | $distance_traveled_between_timepoints = 0.0; |
$rv = Array(); | $rv = Array(); |
foreach ($stopTimes as $i => $stopTime) { | foreach ($stopTimes as $i => $stopTime) { |
if ($stopTime['arrival_time'] != "") { | if ($stopTime['arrival_time'] != "") { |
// is timepoint | // is timepoint |
$cur_timepoint = $stopTime; | $cur_timepoint = $stopTime; |
$distance_between_timepoints = 0.0; | $distance_between_timepoints = 0.0; |
$distance_traveled_between_timepoints = 0.0; | $distance_traveled_between_timepoints = 0.0; |
if ($i + 1 < sizeof($stopTimes)) { | if ($i + 1 < sizeof($ |