gitphp 0.2.9.1 :: busui.git/commitdiff

add binary protobuf GTFSRT format

18 files changed: (show all)
include/common-template.inc.php
include/common-transit.inc.php
include/common.inc.php
include/db/servicealert-dao.inc.php
include/db/stop-dao.inc.php
rtpis/gtfs-realtime.php (new)
rtpis/importer.py (new)
rtpis/index.php (new)
rtpis/punkt.zip (new)
rtpis/servicealert_editor.php (new)
rtpis/servicealert_viewer.php (new)
rtpis/siri.php (new)
servicealerts/importer.py (deleted)
servicealerts/index.php (deleted)
servicealerts/punkt.zip (deleted)
servicealerts/servicealert_editor.php (deleted)
servicealerts/servicealert_viewer.php (deleted)
servicealerts_api.php (deleted)

file:a/include/common-template.inc.php -> file:b/include/common-template.inc.php

file:a/include/common-transit.inc.php -> file:b/include/common-transit.inc.php

file:a/include/common.inc.php -> file:b/include/common.inc.php

<?php	<?php

/*	/*
* Copyright 2010,2011 Alexander Sadleir	* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");	Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.	you may not use this file except in compliance with the License.
You may obtain a copy of the License at	You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0	http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software	Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,	distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and	See the License for the specific language governing permissions and
limitations under the License.	limitations under the License.
*/	*/

date_default_timezone_set('Australia/ACT');	date_default_timezone_set('Australia/ACT');
$debugOkay = Array(	$debugOkay = Array(
"session",	"session",
"json",	"json",
"phperror",	"phperror",
"awsotp",	"awsotp",
//"squallotp",	//"squallotp",
//"vanilleotp",	//"vanilleotp",
"database",	"database",
"other"	"other"
);	);
$GTFSREnabled = true;	$GTFSREnabled = true;
$cloudmadeAPIkey = "daa03470bb8740298d4b10e3f03d63e6";	$cloudmadeAPIkey = "daa03470bb8740298d4b10e3f03d63e6";
$googleMapsAPIkey = "ABQIAAAA95XYXN0cki3Yj_Sb71CFvBTPaLd08ONybQDjcH_VdYtHHLgZvRTw2INzI_m17_IoOUqH3RNNmlTk1Q";	$googleMapsAPIkey = "ABQIAAAA95XYXN0cki3Yj_Sb71CFvBTPaLd08ONybQDjcH_VdYtHHLgZvRTw2INzI_m17_IoOUqH3RNNmlTk1Q";
$otpAPIurl = 'http://localhost:8080/opentripplanner-api-webapp/';	$otpAPIurl = 'http://localhost:8080/opentripplanner-api-webapp/';
if (isDebug("awsotp") \|\| php_uname('n') == "maxious.xen.prgmr.com" \|\| strstr(php_uname('n'),"actbus")) {	if (isDebug("awsotp") \|\| php_uname('n') == "maxious.xen.prgmr.com" \|\| strstr(php_uname('n'),"actbus")) {
$otpAPIurl = 'http://bus-main.lambdacomplex.org:8080/opentripplanner-api-webapp/';	$otpAPIurl = 'http://bus-main.lambdacomplex.org:8080/opentripplanner-api-webapp/';
}	}
if (isDebug("dotcloudotp") \|\| php_uname('n') == "actbus-www") {	if (isDebug("dotcloudotp") \|\| php_uname('n') == "actbus-www") {
$otpAPIurl = 'http://otp.actbus.dotcloud.com/opentripplanner-api-webapp/';	$otpAPIurl = 'http://otp.actbus.dotcloud.com/opentripplanner-api-webapp/';
}	}
if (isDebug("squallotp")) {	if (isDebug("squallotp")) {
$otpAPIurl = 'http://10.0.1.108:5080/opentripplanner-api-webapp/';	$otpAPIurl = 'http://10.0.1.108:5080/opentripplanner-api-webapp/';
}	}
if (isDebug("vanilleotp")) {	if (isDebug("vanilleotp")) {
$otpAPIurl = 'http://10.0.1.135:8080/opentripplanner-api-webapp/';	$otpAPIurl = 'http://10.0.1.135:8080/opentripplanner-api-webapp/';
}	}
if (isDebug("phperror"))	if (isDebug("phperror"))
error_reporting(E_ALL ^ E_NOTICE);	error_reporting(E_ALL ^ E_NOTICE);
$basePath = "";	$basePath = "";
if (strstr($_SERVER['PHP_SELF'], "labs/")	if (strstr($_SERVER['PHP_SELF'], "labs/")
\|\| strstr($_SERVER['PHP_SELF'], "myway/")	\|\| strstr($_SERVER['PHP_SELF'], "myway/")
\|\| strstr($_SERVER['PHP_SELF'], "lib/")	\|\| strstr($_SERVER['PHP_SELF'], "lib/")
\|\| strstr($_SERVER['PHP_SELF'], "geo/")	\|\| strstr($_SERVER['PHP_SELF'], "geo/")
\|\| strstr($_SERVER['PHP_SELF'], "include/")	\|\| strstr($_SERVER['PHP_SELF'], "include/")
\|\| strstr($_SERVER['PHP_SELF'], "servicealerts/"))	\|\| strstr($_SERVER['PHP_SELF'], "rtpis/")) {
$basePath = "../";	$basePath = "../";
	}

function isDebugServer() {	function isDebugServer() {

return php_sapi_name() == "cli" \|\| strstr(php_uname('n'),"actbus") \|\| isset($_SERVER['SERVER_NAME']) && ( $_SERVER['SERVER_NAME'] == "azusa" \|\| $_SERVER['SERVER_NAME'] == "vanille"	return php_sapi_name() == "cli" \|\| strstr(php_uname('n'),"actbus") \|\| isset($_SERVER['SERVER_NAME']) && ( $_SERVER['SERVER_NAME'] == "azusa" \|\| $_SERVER['SERVER_NAME'] == "vanille"
\|\| $_SERVER['SERVER_NAME'] == "localhost" \|\| $_SERVER['SERVER_NAME'] == "127.0.0.1" \|\| $_SERVER['SERVER_NAME'] == "192.168.1.8" \|\| $_SERVER['SERVER_NAME'] == "192.168.178.24");	\|\| $_SERVER['SERVER_NAME'] == "localhost" \|\| $_SERVER['SERVER_NAME'] == "127.0.0.1" \|\| $_SERVER['SERVER_NAME'] == "192.168.1.8" \|\| $_SERVER['SERVER_NAME'] == "192.168.178.24");
}	}

include_once ("common-geo.inc.php");	include_once ("common-geo.inc.php");
include_once ("common-net.inc.php");	include_once ("common-net.inc.php");
include_once ("common-transit.inc.php");	include_once ("common-transit.inc.php");
if (!strstr($_SERVER['PHP_SELF'], "feedback")) {	if (!strstr($_SERVER['PHP_SELF'], "feedback")) {
include_once ("common-db.inc.php");	include_once ("common-db.inc.php");
}	}

include_once ("common-request.inc.php");	include_once ("common-request.inc.php");
include_once ("common-session.inc.php");	include_once ("common-session.inc.php");
include_once ("common-auth.inc.php");	include_once ("common-auth.inc.php");
include_once ("common-template.inc.php");	include_once ("common-template.inc.php");

function isAnalyticsOn() {	function isAnalyticsOn() {
$user_agent = $_SERVER['HTTP_USER_AGENT'];	$user_agent = $_SERVER['HTTP_USER_AGENT'];
return !isDebugServer() && !preg_match('/cloudkick/i', $user_agent) && !preg_match('/googlebot/i', $user_agent) &&	return !isDebugServer() && !preg_match('/cloudkick/i', $user_agent) && !preg_match('/googlebot/i', $user_agent) &&
!preg_match('/baidu/i', $user_agent);	!preg_match('/baidu/i', $user_agent);
}	}

function isDebug($debugReason = "other") {	function isDebug($debugReason = "other") {
global $debugOkay;	global $debugOkay;
return in_array($debugReason, $debugOkay, false) && isDebugServer();	return in_array($debugReason, $debugOkay, false) && isDebugServer();
}	}

function debug($msg, $debugReason = "other") {	function debug($msg, $debugReason = "other") {
if (isDebug($debugReason))	if (isDebug($debugReason))
echo "\n<!-- " . date(DATE_RFC822) . "\n $msg -->\n";	echo "\n<!-- " . date(DATE_RFC822) . "\n $msg -->\n";
}	}
function isIOSDevice() {	function isIOSDevice() {
return strstr($_SERVER['HTTP_USER_AGENT'], 'iPhone') \|\| strstr($_SERVER['HTTP_USER_AGENT'], 'iPod') \|\| strstr($_SERVER['HTTP_USER_AGENT'], 'iPad');	return strstr($_SERVER['HTTP_USER_AGENT'], 'iPhone') \|\| strstr($_SERVER['HTTP_USER_AGENT'], 'iPod') \|\| strstr($_SERVER['HTTP_USER_AGENT'], 'iPad');
}	}
function isJQueryMobileDevice() {	function isJQueryMobileDevice() {
// http://forum.jquery.com/topic/what-is-the-best-way-to-detect-all-useragents-which-can-handle-jquery-mobile#14737000002087897	// http://forum.jquery.com/topic/what-is-the-best-way-to-detect-all-useragents-which-can-handle-jquery-mobile#14737000002087897
$user_agent = $_SERVER['HTTP_USER_AGENT'];	$user_agent = $_SERVER['HTTP_USER_AGENT'];
return preg_match('/iphone/i', $user_agent) \|\| preg_match('/android/i', $user_agent) \|\| preg_match('/webos/i', $user_agent) \|\| preg_match('/ios/i', $user_agent) \|\| preg_match('/bada/i', $user_agent) \|\| preg_match('/maemo/i', $user_agent) \|\| preg_match('/meego/i', $user_agent) \|\| preg_match('/fennec/i', $user_agent) \|\| (preg_match('/symbian/i', $user_agent) && preg_match('/s60/i', $user_agent) && $browser['majorver'] >= 5) \|\| (preg_match('/symbian/i', $user_agent) && preg_match('/platform/i', $user_agent) && $browser['majorver'] >= 3) \|\| (preg_match('/blackberry/i', $user_agent) && $browser['majorver'] >= 5) \|\| (preg_match('/opera mobile/i', $user_agent) && $browser['majorver'] >= 10) \|\| (preg_match('/opera mini/i', $user_agent) && $browser['majorver'] >= 5);	return preg_match('/iphone/i', $user_agent) \|\| preg_match('/android/i', $user_agent) \|\| preg_match('/webos/i', $user_agent) \|\| preg_match('/ios/i', $user_agent) \|\| preg_match('/bada/i', $user_agent) \|\| preg_match('/maemo/i', $user_agent) \|\| preg_match('/meego/i', $user_agent) \|\| preg_match('/fennec/i', $user_agent) \|\| (preg_match('/symbian/i', $user_agent) && preg_match('/s60/i', $user_agent) && $browser['majorver'] >= 5) \|\| (preg_match('/symbian/i', $user_agent) && preg_match('/platform/i', $user_agent) && $browser['majorver'] >= 3) \|\| (preg_match('/blackberry/i', $user_agent) && $browser['majorver'] >= 5) \|\| (preg_match('/opera mobile/i', $user_agent) && $browser['majorver'] >= 10) \|\| (preg_match('/opera mini/i', $user_agent) && $browser['majorver'] >= 5);
}	}


function array_flatten($a, $f = array()) {	function array_flatten($a, $f = array()) {
if (!$a \|\| !is_array($a))	if (!$a \|\| !is_array($a))
return '';	return '';
foreach ($a as $k => $v) {	foreach ($a as $k => $v) {
if (is_array($v))	if (is_array($v))
$f = array_flatten($v, $f);	$f = array_flatten($v, $f);
else	else
$f[$k] = $v;	$f[$k] = $v;
}	}
return $f;	return $f;
}	}

function remove_spaces($string) {	function remove_spaces($string) {
return str_replace(' ', '', $string);	return str_replace(' ', '', $string);
}	}

function object2array($object) {	function object2array($object) {
if (is_object($object)) {	if (is_object($object)) {
foreach ($object as $key => $value) {	foreach ($object as $key => $value) {
$array[$key] = $value;	$array[$key] = $value;
}	}
} else {	} else {
$array = $object;	$array = $object;
}	}
return $array;	return $array;
}	}

function startsWith($haystack, $needle, $case = true) {	function startsWith($haystack, $needle, $case = true) {
if ($case) {	if ($case) {
return (strcmp(substr($haystack, 0, strlen($needle)), $needle) === 0);	return (strcmp(substr($haystack, 0, strlen($needle)), $needle) === 0);
}	}
return (strcasecmp(substr($haystack, 0, strlen($needle)), $needle) === 0);	return (strcasecmp(substr($haystack, 0, strlen($needle)), $needle) === 0);
}	}

function endsWith($haystack, $needle, $case = true) {	function endsWith($haystack, $needle, $case = true) {
if ($case) {	if ($case) {
return (strcmp(substr($haystack, strlen($haystack) - strlen($needle)), $needle) === 0);	return (strcmp(substr($haystack, strlen($haystack) - strlen($needle)), $needle) === 0);
}	}
return (strcasecmp(substr($haystack, strlen($haystack) - strlen($needle)), $needle) === 0);	return (strcasecmp(substr($haystack, strlen($haystack) - strlen($needle)), $needle) === 0);
}	}

function sksort(&$array, $subkey = "id", $sort_ascending = false) {	function sksort(&$array, $subkey = "id", $sort_ascending = false) {
if (count($array))	if (count($array))
$temp_array[key($array)] = array_shift($array);	$temp_array[key($array)] = array_shift($array);
foreach ($array as $key => $val) {	foreach ($array as $key => $val) {
$offset = 0;	$offset = 0;
$found = false;	$found = false;
foreach ($temp_array as $tmp_key => $tmp_val) {	foreach ($temp_array as $tmp_key => $tmp_val) {
if (!$found and strtolower($val[$subkey]) > strtolower($tmp_val[$subkey])) {	if (!$found and strtolower($val[$subkey]) > strtolower($tmp_val[$subkey])) {
$temp_array = array_merge((array) array_slice($temp_array, 0, $offset), array(	$temp_array = array_merge((array) array_slice($temp_array, 0, $offset), array(
$key => $val	$key => $val
), array_slice($temp_array, $offset));	), array_slice($temp_array, $offset));
$found = true;	$found = true;
}	}
$offset++;	$offset++;
}	}
if (!$found)	if (!$found)
$temp_array = array_merge($temp_array, array(	$temp_array = array_merge($temp_array, array(
$key => $val	$key => $val
));	));
}	}
if ($sort_ascending)	if ($sort_ascending)
$array = array_reverse($temp_array);	$array = array_reverse($temp_array);
else	else
$array = $temp_array;	$array = $temp_array;
}	}

function sktimesort(&$array, $subkey = "id", $sort_ascending = false) {	function sktimesort(&$array, $subkey = "id", $sort_ascending = false) {
if (count($array))	if (count($array))
$temp_array[key($array)] = array_shift($array);	$temp_array[key($array)] = array_shift($array);
foreach ($array as $key => $val) {	foreach ($array as $key => $val) {
$offset = 0;	$offset = 0;
$found = false;	$found = false;
foreach ($temp_array as $tmp_key => $tmp_val) {	foreach ($temp_array as $tmp_key => $tmp_val) {
if (!$found and strtotime($val[$subkey]) > strtotime($tmp_val[$subkey])) {	if (!$found and strtotime($val[$subkey]) > strtotime($tmp_val[$subkey])) {
$temp_array = array_merge((array) array_slice($temp_array, 0, $offset), array(	$temp_array = array_merge((array) array_slice($temp_array, 0, $offset), array(
$key => $val	$key => $val
), array_slice($temp_array, $offset));	), array_slice($temp_array, $offset));
$found = true;	$found = true;
}	}
$offset++;	$offset++;
}	}
if (!$found)	if (!$found)
$temp_array = array_merge($temp_array, array(	$temp_array = array_merge($temp_array, array(
$key => $val	$key => $val
));	));
}	}
if ($sort_ascending && isset($temp_array))	if ($sort_ascending && isset($temp_array))
$array = array_reverse($temp_array);	$array = array_reverse($temp_array);
else	else
$array = $temp_array;	$array = $temp_array;
}	}

function r_implode($glue, $pieces) {	function r_implode($glue, $pieces) {
foreach ($pieces as $r_pieces) {	foreach ($pieces as $r_pieces) {
if (is_array($r_pieces)) {	if (is_array($r_pieces)) {
$retVal[] = r_implode($glue, $r_pieces);	$retVal[] = r_implode($glue, $r_pieces);
} else {	} else {
$retVal[] = $r_pieces;	$retVal[] = $r_pieces;
}	}
}	}
return implode($glue, $retVal);	return implode($glue, $retVal);
}	}

file:a/include/db/servicealert-dao.inc.php -> file:b/include/db/servicealert-dao.inc.php

<?php	<?php

/*	/*
* Copyright 2010,2011 Alexander Sadleir	* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");	Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.	you may not use this file except in compliance with the License.
You may obtain a copy of the License at	You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0	http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software	Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,	distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and	See the License for the specific language governing permissions and
limitations under the License.	limitations under the License.
*/	*/

function getServiceOverride($date = "") {	function getServiceOverride($date = "") {
global $conn;	global $conn;
$query = "Select * from calendar_dates where date = :date and exception_type = '1' LIMIT 1";	$query = "Select * from calendar_dates where date = :date and exception_type = '1' LIMIT 1";
// debug($query,"database");	// debug($query,"database");
$query = $conn->prepare($query); // Create a prepared statement	$query = $conn->prepare($query); // Create a prepared statement
$query->bindParam(":date", date("Ymd", ($date != "" ? $date : time())));	$query->bindParam(":date", date("Ymd", ($date != "" ? $date : time())));
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetch(PDO :: FETCH_ASSOC);	return $query->fetch(PDO :: FETCH_ASSOC);
}	}

function getServiceAlert($alertID) {	function getServiceAlert($alertID) {
global $conn;	global $conn;
$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where id = :servicealert_id";	$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where id = :servicealert_id";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":servicealert_id", $alertID);	$query->bindParam(":servicealert_id", $alertID);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetch(PDO :: FETCH_ASSOC);	return $query->fetch(PDO :: FETCH_ASSOC);
}	}

function updateServiceAlert($alertID, $start, $end, $header, $description, $url) {	function updateServiceAlert($alertID, $alert) {
global $conn;	global $conn;
$query = 'update servicealerts_alerts set start=:start, "end"=:end, header=:header, description=:description, url=:url where id = :servicealert_id';	$query = 'update servicealerts_alerts set start=:start, "end"=:end, header=:header, description=:description, url=:url, cause=:cause, effect=:effect where id = :servicealert_id';
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":servicealert_id", $alertID);	$query->bindValue(":servicealert_id", $alertID);
$query->bindParam(":start", $start);	$query->bindValue(":start", $alert['startdate']);
$query->bindParam(":end", $end);	$query->bindValue(":end", $alert['enddate']);
$query->bindParam(":header", $header);	$query->bindValue(":header", $alert['header']);
$query->bindParam(":description", $description);	$query->bindValue(":description", $alert['description']);
$query->bindParam(":url", $url);	$query->bindValue(":url", $alert['url']);
	$query->bindValue(":cause", $alert['cause']);
	$query->bindValue(":effect", $alert['effect']);
$query->execute();	$query->execute();

print_r($conn->errorInfo());	print_r($conn->errorInfo());
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetch(PDO :: FETCH_ASSOC);	return $query->fetch(PDO :: FETCH_ASSOC);
}	}

function addServiceAlert($start, $end, $header, $description, $url) {	function addServiceAlert($alert) {
global $conn;	global $conn;
$query = 'INSERT INTO servicealerts_alerts (start, "end", header, description, url) VALUES (:start, :end, :header, :description, :url) ';	$query = 'INSERT INTO servicealerts_alerts (start, "end", header, description, url,cause,effect) VALUES (:start, :end, :header, :description, :url,:cause,:effect) ';
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":start", $start);	//print_r($alert);
$query->bindParam(":end", $end);	$query->bindValue(":start", $alert['startdate']);
$query->bindParam(":header", $header);	$query->bindValue(":end", $alert['enddate']);
$query->bindParam(":description", $description);	$query->bindValue(":header", $alert['header']);
$query->bindParam(":url", $url);	$query->bindValue(":description", $alert['description']);
	$query->bindValue(":url", $alert['url']);
	$query->bindValue(":cause", $alert['cause']);
	$query->bindValue(":effect", $alert['effect']);
$query->execute();	$query->execute();

print_r($conn->errorInfo());	print_r($conn->errorInfo());
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetch(PDO :: FETCH_ASSOC);	return $query->fetch(PDO :: FETCH_ASSOC);
}	}

function getCurrentAlerts() {	function getCurrentAlerts() {
global $conn;	global $conn;
$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where NOW() > start and NOW() < \"end\"";	$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where NOW() > start and NOW() < \"end\"";
// debug($query, "database");	// debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getFutureAlerts() {	function getFutureAlerts() {
global $conn;	global $conn;
$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where NOW() > start or NOW() < \"end\"";	$query = "SELECT id,extract('epoch' from start) as start, extract('epoch' from \"end\") as \"end\",cause,effect,header,description,url from servicealerts_alerts where NOW() > start or NOW() < \"end\"";
// debug($query, "database");	// debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getInformedAlerts($id, $filter_class, $filter_id) {	function getInformedAlerts($id, $filter_class, $filter_id) {

global $conn;	global $conn;
	//echo "$id, $filter_class, $filter_id\n";
$query = "SELECT * from servicealerts_informed where servicealert_id = :servicealert_id";	$query = "SELECT * from servicealerts_informed where servicealert_id = :servicealert_id";

if ($filter_class != "") {	if ($filter_class != "") {
$query .= " AND informed_class = :informed_class ";	$query .= " AND informed_class = :informed_class ";
}	}
if ($filter_id != "") {	if ($filter_id != "") {
$query .= " AND informed_id = :informed_id ";	$query .= " AND informed_id = :informed_id ";
}	}
// debug($query, "database");	// debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
if ($filter_class != "") {	if ($filter_class != "") {
$query->bindParam(":informed_class", $filter_class);	$query->bindParam(":informed_class", $filter_class);
}	}
if ($filter_id != "") {	if ($filter_id != "") {
$query->bindParam(":informed_id", $filter_id);	$query->bindParam(":informed_id", $filter_id);
}	}
$query->bindParam(":servicealert_id", $id);	$query->bindParam(":servicealert_id", $id);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function deleteInformedAlert($serviceAlertID, $class, $id) {	function deleteInformedAlert($serviceAlertID, $class, $id) {
global $conn;	global $conn;
$query = 'DELETE from servicealerts_informed where servicealert_id = :servicealert_id and informed_class = :informed_class AND informed_id = :informed_id';	$query = 'DELETE from servicealerts_informed where servicealert_id = :servicealert_id and informed_class = :informed_class AND informed_id = :informed_id';
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":servicealert_id", $serviceAlertID);	$query->bindParam(":servicealert_id", $serviceAlertID);
$query->bindParam(":informed_class", $class);	$query->bindParam(":informed_class", $class);
$query->bindParam(":informed_id", $id);	$query->bindParam(":informed_id", $id);
$query->execute();	$query->execute();
print_r($conn->errorInfo());	print_r($conn->errorInfo());
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return null;	return null;
}	}

function addInformedAlert($serviceAlertID, $class, $id, $action) {	function addInformedAlert($serviceAlertID, $class, $id, $action) {
global $conn;	global $conn;
$query = 'INSERT INTO servicealerts_informed (servicealert_id , informed_class , informed_id) VALUES(:servicealert_id ,:informed_class, :informed_id)';	$query = 'INSERT INTO servicealerts_informed (servicealert_id , informed_class , informed_id, informed_action)
	VALUES(:servicealert_id ,:informed_class, :informed_id, :informed_action)';
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":servicealert_id", $serviceAlertID);	$query->bindParam(":servicealert_id", $serviceAlertID);
$query->bindParam(":informed_class", $class);	$query->bindParam(":informed_class", $class);
$query->bindParam(":informed_id", $id);	$query->bindParam(":informed_id", $id);
	$query->bindParam(":informed_action", $action);
$query->execute();	$query->execute();

print_r($conn->errorInfo());	print_r($conn->errorInfo());
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return null;	return null;
}	}

file:a/include/db/stop-dao.inc.php -> file:b/include/db/stop-dao.inc.php

<?php	<?php

/*	/*
* Copyright 2010,2011 Alexander Sadleir	* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");	Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.	you may not use this file except in compliance with the License.
You may obtain a copy of the License at	You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0	http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software	Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,	distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and	See the License for the specific language governing permissions and
limitations under the License.	limitations under the License.
*/	*/

function getStop($stopID) {	function getStop($stopID) {
global $conn;	global $conn;
$query = "Select * from stops where stop_id = :stopID LIMIT 1";	$query = "Select * from stops where stop_id = :stopID LIMIT 1";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":stopID", $stopID);	$query->bindParam(":stopID", $stopID);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetch(PDO :: FETCH_ASSOC);	return $query->fetch(PDO :: FETCH_ASSOC);
}	}

function getStops($firstLetter = "", $startsWith = "") {	function getStops($firstLetter = "", $startsWith = "") {
global $conn;	global $conn;
$conditions = Array();	$conditions = Array();
if ($firstLetter != "")	if ($firstLetter != "")
$conditions[] = "substr(stop_name,1,1) = :firstLetter";	$conditions[] = "substr(stop_name,1,1) = :firstLetter";
if ($startsWith != "")	if ($startsWith != "")
$conditions[] = "stop_name like :startsWith";	$conditions[] = "stop_name like :startsWith";
$query = "Select * from stops";	$query = "Select * from stops";
if (sizeof($conditions) > 0) {	if (sizeof($conditions) > 0) {
if (sizeof($conditions) > 1) {	if (sizeof($conditions) > 1) {
$query .= " Where " . implode(" AND ", $conditions) . " ";	$query .= " Where " . implode(" AND ", $conditions) . " ";
} else {	} else {
$query .= " Where " . $conditions[0] . " ";	$query .= " Where " . $conditions[0] . " ";
}	}
}	}
$query .= " order by stop_name;";	$query .= " order by stop_name;";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
if ($firstLetter != "")	if ($firstLetter != "")
$query->bindParam(":firstLetter", $firstLetter);	$query->bindParam(":firstLetter", $firstLetter);

if ($startsWith != "") {	if ($startsWith != "") {
$startsWith = $startsWith . "%";	$startsWith = $startsWith . "%";
$query->bindParam(":startsWith", $startsWith);	$query->bindParam(":startsWith", $startsWith);
}	}
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getNearbyStops($lat, $lng, $limit = "", $distance = 1000) {	function getNearbyStops($lat, $lng, $limit = "", $distance = 1000) {
if ($lat == null \|\| $lng == null)	if ($lat == null \|\| $lng == null)
return Array();	return Array();
if ($limit != "")	if ($limit != "")
$limitSQL = " LIMIT :limit ";	$limitSQL = " LIMIT :limit ";
global $conn;	global $conn;
$query = "Select *, ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE) as distance	$query = "Select *, ST_Distance(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), FALSE) as distance
from stops WHERE ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), :distance, FALSE)	from stops WHERE ST_DWithin(position, ST_GeographyFromText('SRID=4326;POINT($lng $lat)'), :distance, FALSE)
order by distance $limitSQL;";	order by distance $limitSQL;";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":distance", $distance);	$query->bindParam(":distance", $distance);
$query->bindParam(":limit", $limit);	$query->bindParam(":limit", $limit);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopsByName($name) {	function getStopsByName($name) {
global $conn;	global $conn;
$query = "Select * from stops where stop_name LIKE :name;";	$query = "Select * from stops where stop_name LIKE :name;";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$name = "%" . $name . ";%";	$name = $name . "%";
$query->bindParam(":name", $name);	$query->bindParam(":name", $name);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopsBySuburb($suburb) {	function getStopsBySuburb($suburb) {
global $conn;	global $conn;
$query = "Select * from stops where stop_desc LIKE :suburb order by stop_name;";	$query = "Select * from stops where stop_desc LIKE :suburb order by stop_name;";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$suburb = "%<br>Suburb: %" . $suburb . "%";	$suburb = "%<br>Suburb: %" . $suburb . "%";
$query->bindParam(":suburb", $suburb);	$query->bindParam(":suburb", $suburb);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopsByStopCode($stop_code, $startsWith = "") {	function getStopsByStopCode($stop_code, $startsWith = "") {
global $conn;	global $conn;
$query = "Select * from stops where (stop_code = :stop_code OR stop_code LIKE :stop_code2)";	$query = "Select * from stops where (stop_code = :stop_code OR stop_code LIKE :stop_code2)";
if ($startsWith != "")	if ($startsWith != "")
$query .= " AND stop_name like :startsWith";	$query .= " AND stop_name like :startsWith";

debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);

$query->bindParam(":stop_code", $stop_code);	$query->bindParam(":stop_code", $stop_code);
$stop_code2 = $stop_code . "%";	$stop_code2 = $stop_code . "%";
$query->bindParam(":stop_code2", $stop_code2);	$query->bindParam(":stop_code2", $stop_code2);
if ($startsWith != "") {	if ($startsWith != "") {
$startsWith = $startsWith . "%";	$startsWith = $startsWith . "%";
$query->bindParam(":startsWith", $startsWith);	$query->bindParam(":startsWith", $startsWith);
}	}
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopRoutes($stopID, $service_period) {	function getStopRoutes($stopID, $service_period) {
if ($service_period == "") {	if ($service_period == "") {
$service_period = service_period();	$service_period = service_period();
}	}
$service_ids = service_ids($service_period);	$service_ids = service_ids($service_period);
$sidA = $service_ids[0];	$sidA = $service_ids[0];
$sidB = $service_ids[1];	$sidB = $service_ids[1];
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 =	FROM stop_times join trips on trips.trip_id =
stop_times.trip_id join routes on trips.route_id = routes.route_id WHERE stop_id = :stopID	stop_times.trip_id join routes on trips.route_id = routes.route_id WHERE stop_id = :stopID
AND (service_id=:service_periodA OR service_id=:service_periodB)";	AND (service_id=:service_periodA OR service_id=:service_periodB)";
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":service_periodA", $sidA);	$query->bindParam(":service_periodA", $sidA);
$query->bindParam(":service_periodB", $sidB);	$query->bindParam(":service_periodB", $sidB);
$query->bindParam(":stopID", $stopID);	$query->bindParam(":stopID", $stopID);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopTrips($stopID, $service_period = "", $afterTime = "", $limit = "", $route_short_name = "") {	function getStopTrips($stopID, $service_period = "", $afterTime = "", $limit = "", $route_short_name = "") {
if ($service_period == "") {	if ($service_period == "") {
$service_period = service_period();	$service_period = service_period();
}	}
$service_ids = service_ids($service_period);	$service_ids = service_ids($service_period);
$sidA = $service_ids[0];	$sidA = $service_ids[0];
$sidB = $service_ids[1];	$sidB = $service_ids[1];
$limitSQL = "";	$limitSQL = "";
if ($limit != "")	if ($limit != "")
$limitSQL .= " LIMIT :limit ";	$limitSQL .= " LIMIT :limit ";

global $conn;	global $conn;
if ($afterTime != "") {	if ($afterTime != "") {
$query = " SELECT stop_times.trip_id,stop_times.arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,trips.direction_id,trips.trip_headsign,route_short_name,route_long_name,end_times.arrival_time as end_time	$query = " SELECT stop_times.trip_id,stop_times.arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,trips.direction_id,trips.trip_headsign,route_short_name,route_long_name,end_times.arrival_time as end_time
FROM stop_times	FROM stop_times
join trips on trips.trip_id =	join trips on trips.trip_id =
stop_times.trip_id	stop_times.trip_id
join routes on trips.route_id = routes.route_id , (SELECT trip_id,max(arrival_time) as arrival_time from stop_times	join routes on trips.route_id = routes.route_id , (SELECT trip_id,max(arrival_time) as arrival_time from stop_times
WHERE stop_times.arrival_time IS NOT NULL group by trip_id) as end_times	WHERE stop_times.arrival_time IS NOT NULL group by trip_id) as end_times
WHERE stop_times.stop_id = :stopID	WHERE stop_times.stop_id = :stopID
AND stop_times.trip_id = end_times.trip_id	AND stop_times.trip_id = end_times.trip_id
AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . "	AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . "
AND end_times.arrival_time > :afterTime	AND end_times.arrival_time > :afterTime
ORDER BY end_time $limitSQL";	ORDER BY end_time $limitSQL";
} else {	} else {
$query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,stop_sequence,service_id,trips.route_id,route_short_name,route_long_name	$query = "SELECT stop_times.trip_id,arrival_time,stop_times.stop_id,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 =	join trips on trips.trip_id =
stop_times.trip_id	stop_times.trip_id
join routes on trips.route_id = routes.route_id	join routes on trips.route_id = routes.route_id
WHERE stop_times.stop_id = :stopID	WHERE stop_times.stop_id = :stopID
AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . "	AND (service_id=:service_periodA OR service_id=:service_periodB) " . ($route_short_name != "" ? " AND route_short_name = :route_short_name " : "") . "
ORDER BY arrival_time $limitSQL";	ORDER BY arrival_time $limitSQL";
}	}
debug($query, "database");	debug($query, "database");
$query = $conn->prepare($query);	$query = $conn->prepare($query);
$query->bindParam(":service_periodA", $sidA);	$query->bindParam(":service_periodA", $sidA);
$query->bindParam(":service_periodB", $sidB);	$query->bindParam(":service_periodB", $sidB);
$query->bindParam(":stopID", $stopID);	$query->bindParam(":stopID", $stopID);
if ($limit != "")	if ($limit != "")
$query->bindParam(":limit", $limit);	$query->bindParam(":limit", $limit);
if ($afterTime != "")	if ($afterTime != "")
$query->bindParam(":afterTime", $afterTime);	$query->bindParam(":afterTime", $afterTime);
if ($route_short_name != "")	if ($route_short_name != "")
$query->bindParam(":route_short_name", $route_short_name);	$query->bindParam(":route_short_name", $route_short_name);
$query->execute();	$query->execute();
if (!$query) {	if (!$query) {
databaseError($conn->errorInfo());	databaseError($conn->errorInfo());
return Array();	return Array();
}	}
return $query->fetchAll();	return $query->fetchAll();
}	}

function getStopTripsWithTimes($stopID, $time = "", $service_period = "", $time_range = "", $limit = "") {	function getStopTripsWithTimes($stopID, $time = "", $service_period = "", $time_range = "", $limit = "") {
if ($service_period == "")	if ($service_period == "")
$service_period = service_period();	$service_period = service_period();
if ($time_range == "")	if ($time_range == "")
$time_range = (24 * 60 * 60);	$time_range = (24 * 60 * 60);
if ($time == "")	if ($time == "")
$time = current_time();	$time = current_time();
if ($limit == "")	if ($limit == "")
$limit = 10;	$limit = 10;
$trips = getStopTrips($stopID, $service_period, $time);	$trips = getStopTrips($stopID, $service_period, $time);
$timedTrips = Array();	$timedTrips = Array();
if ($trips && sizeof($trips) > 0) {	if ($trips && sizeof($trips) > 0) {
foreach ($trips as $trip) {	foreach ($trips as $trip) {
if ($trip['arrival_time'] != "") {	if ($trip['arrival_time'] != "") {
if (strtotime($trip['arrival_time']) > strtotime($time) and strtotime($trip['arrival_time']) < (strtotime($time) + $time_range)) {	if (strtotime($trip['arrival_time']) > strtotime($time) and strtotime($trip['arrival_time']) < (strtotime($time) + $time_range)) {
$timedTrips[] = $trip;	$timedTrips[] = $trip;
}	}
} else {	} else {
$timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']);	$timedTrip = getTripAtStop($trip['trip_id'], $trip['stop_sequence']);
if ($timedTrip['arrival_time'] > $time and strtotime($timedTrip['arrival_time']) < (strtotime($time) + $time_range)) {	if ($timedTrip['arrival_time'] > $time and strtotime($timedTrip['arrival_time']) < (strtotime($time) + $time_range)) {
$timedTrips[] = $timedTrip;	$timedTrips[] = $timedTrip;
}	}
}	}
if (sizeof($timedTrips) > $limit)	if (sizeof($timedTrips) > $limit)
break;	break;
}	}
sktimesort($timedTrips, "arrival_time", true);	sktimesort($timedTrips, "arrival_time", true);
}	}
return $timedTrips;	return $timedTrips;
}	}

file:b/rtpis/gtfs-realtime.php (new)

	<?php

	/*
	* Copyright 2010,2011 Alexander Sadleir

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	*/
	include ('../include/common.inc.php');
	function accept_header($header = false) {
	// http://jrgns.net/parse_http_accept_header
	$toret = null;
	$header = $header ? $header : (array_key_exists('HTTP_ACCEPT', $_SERVER) ? $_SERVER['HTTP_ACCEPT']: false);
	if ($header) {
	$types = explode(',', $header);
	$types = array_map('trim', $types);
	foreach ($types as $one_type) {
	$one_type = explode(';', $one_type);
	$type = array_shift($one_type);
	if ($type) {
	list($precedence, $tokens) = self::accept_header_options($one_type);
	list($main_type, $sub_type) = array_map('trim', explode('/', $type));
	$toret[] = array('main_type' => $main_type, 'sub_type' => $sub_type, 'precedence' => (float)$precedence, 'tokens' => $tokens);
	}
	}
	usort($toret, array('Parser', 'compare_media_ranges'));
	}
	return $toret;
	}
	function usage() {
	echo "Usage notes: Must specify format json/protobuf and gtfs-realtime feedtype alerts/updates. If callback is specified, will provide jsonp. Can filter with parmaters filter_class route/stop and filter_id with the id specified in GTFS.";
	die();
	}

	$filter_class = (isset($_REQUEST['filter_class']) ? $_REQUEST['filter_class'] : "");
	$filter_id = (isset($_REQUEST['filter_id']) ? $_REQUEST['filter_id']:"");

	$json_types = Array("application/json","application/x-javascript","text/javascript","text/x-javascript","text/x-json");
	if ($_REQUEST['json']) {
	if ($_REQUEST['alerts']) {
	$return = getServiceAlertsAsJSON($filter_class,$filter_id);
	} else if ($_REQUEST['updates']) {
	$return = getTripUpdatesAsJSON($filter_class,$filter_id);
	} else {
	usage();
	}
	header('Content-Type: application/json; charset=utf8');
	// header('Access-Control-Allow-Origin: http://bus.lambdacomplex.org/');
	header('Access-Control-Max-Age: 3628800');
	header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE');
	if (isset($_GET['callback'])) {
	$json = '(' . $return . ');'; //must wrap in parens and end with semicolon
	//print_r($_GET['callback'] . $json); //callback is prepended for json-p
	}
	else {
	echo $return;
	}
	} else if ($_REQUEST['protobuf']) {
	if ($_REQUEST['alerts']) {
	$return = getServiceAlertsAsBinary($filter_class,$filter_id);
	} else if ($_REQUEST['updates']) {
	$return = getTripUpdatesAsBinary($filter_class,$filter_id);
	} else {
	usage();
	}
	header('Content-Type: application/x-protobuf');
	header('Content-Disposition: attachment; filename="'.(isset($_REQUEST['updates'])?"updates.":"alerts.").date("c").'.protobuf"');
	// header('Access-Control-Allow-Origin: http://bus.lambdacomplex.org/');
	header('Access-Control-Max-Age: 3628800');
	header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE');
	echo $return;
	} else {
	usage();
	}
	?>

file:b/rtpis/importer.py (new)

	# info
	# http://stackoverflow.com/questions/4206882/named-entity-recognition-with-preset-list-of-names-for-python-php/4207128#4207128
	# http://alias-i.com/lingpipe/demos/tutorial/ne/read-me.html approximate dist
	# http://streamhacker.com/2008/12/29/how-to-train-a-nltk-chunker/ more training
	# http://www.postgresql.org/docs/9.1/static/pgtrgm.html

	# data sources
	# http://twitter.com/#!/ACTEmergencyInf instant site wide
	# http://twitter.com/#!/ACTPol_Traffic
	# http://esa.act.gov.au/feeds/currentincidents.xml

	# source: https://gist.github.com/322906/90dea659c04570757cccf0ce1e6d26c9d06f9283
	# to install python -m nltk.downloader punkt
	import nltk
	import tweepy
	import psycopg2
	import pickle

	from iniparse import INIConfig

	def insert_service_alert_sitewide(heading, message, url):
	print "NaN"

	def insert_service_alert_for_street(streets, heading, message, url):
	conn_string = "host='localhost' dbname='energymapper' user='postgres' password='snmc'"
	# print the connection string we will use to connect
	print "Connecting to database\n ->%s" % (conn_string)
	try:
	# get a connection, if a connect cannot be made an exception will be raised here
	conn = psycopg2.connect(conn_string)

	# conn.cursor will return a cursor object, you can use this cursor to perform queries
	cursor = conn.cursor()

	# execute our Query
	cursor.execute("")

	# retrieve the records from the database
	records = cursor.fetchall()

	for record in records:
	ys.append(record[0])
	# >>> cur.execute("INSERT INTO test (num, data) VALUES (%s, %s)", (42, 'bar'))
	#>>> cur.statusmessage
	#'INSERT 0 1'
	except:
	# Get the most recent exception
	exceptionType, exceptionValue, exceptionTraceback = sys.exc_info()
	# Exit the script and print an error telling what happened.
	sys.exit("Database connection failed!\n ->%s" % (exceptionValue))


	def extract_entity_names(t):
	entity_names = []

	if hasattr(t, 'node') and t.node:
	if t.node == 'NE':
	entity_names.append(' '.join([child[0] for child in t]))
	else:
	for child in t:
	entity_names.extend(extract_entity_names(child))

	return entity_names

	def extract_names(sample):
	sentences = nltk.sent_tokenize(sample)
	tokenized_sentences = [nltk.word_tokenize(sentence) for sentence in sentences]
	tagged_sentences = [nltk.pos_tag(sentence) for sentence in tokenized_sentences]
	chunked_sentences = nltk.batch_ne_chunk(tagged_sentences, binary=True)
	# chunked/tagged may be enough to just find and match the nouns

	entity_names = []
	for tree in chunked_sentences:
	# Print results per sentence
	# print extract_entity_names(tree)

	entity_names.extend(extract_entity_names(tree))

	# Print all entity names
	#print entity_names

	# Print unique entity names
	print set(entity_names)

	cfg = INIConfig(open('/tmp/aws.ini'))

	auth = tweepy.OAuthHandler(cfg.api_keys.twitter_consumer_key, cfg.api_keys.twitter_consumer_secret)
	auth.set_access_token(cfg.api_keys.twitter_access_token, cfg.api_keys.twitter_access_token_secret)

	#api = tweepy.API(auth)
	api = tweepy.API()
	# If the authentication was successful, you should
	# see the name of the account print out
	#print api.me().name
	# https://github.com/tweepy/tweepy/blob/master/tweepy/api.py
	for status in api.user_timeline(screen_name="ACTPol_Traffic",exclude_replies='true'):
	print status.text
	print status.created_at
	print extract_names(status.text)
	# print api.update_status(status="test")

	last_tweet_ids = { "lion": "111", "kitty": "2222" }
	pickle.dump( last_tweet_ids, open( "save.p", "wb" ) )
	last_tweet_ids = pickle.load( open( "save.p", "rb" ) )

file:b/rtpis/index.php (new)

	<?php
	include ('../include/common.inc.php');

	include_header("Service Alerts", "index");
	echo '<ul data-role="listview" data-theme="e" data-groupingtheme="e">';

	if ($_SESSION['authed'] == true) {
	echo' <li><a href="servicealert_editor.php"><h3>servicealert_editor</h3>
	<p>servicealert_editor</p></a></li>';
	}
	echo' <li><a href="servicealert_viewer.php"><h3>Service Alert Viewer</h3>
	<p>Browse current network alerts</p></a></li>';

	echo' </ul>';

	?> </div>
	<?php
	include_footer()
	?>

file:b/rtpis/punkt.zip (new)

file:b/rtpis/servicealert_editor.php (new)

	<?php
	/*
	* Copyright 2010,2011 Alexander Sadleir

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	*/
	include ('../include/common.inc.php');
	auth();
	include_header("Service Alert Editor", "serviceAlertEditor");
	/**
	* Currently support:
	* network inform
	* stop remove: route patch, stop remove
	* - stop search
	* street inform: route inform, stop inform
	* - street search
	*/
	if (isset($_REQUEST['saveedit'])) {

	if ($_REQUEST['saveedit'] != "") {
	updateServiceAlert($_REQUEST['saveedit'], $_REQUEST);
	} else {
	addServiceAlert($_REQUEST);
	}
	echo "Saved " . $_REQUEST['saveedit'];
	die();
	}
	if ($_REQUEST['delete']) {
	$deleteParts = explode(";", $_REQUEST['delete']);
	deleteInformedAlert($deleteParts[0], $deleteParts[1], $deleteParts[2]);
	echo "Deleted network inform for {$deleteParts[0]} ({$deleteParts[1]},{$deleteParts[2]})<br>\n";
	die();
	}
	if ($_REQUEST['networkinform']) {
	addInformedAlert($_REQUEST['networkinform'], "agency", "0", "inform");
	echo "Added network inform for" . $_REQUEST['networkinform'];
	die();
	}
	if ($_REQUEST['stopsearch']) {
	addInformedAlert($_REQUEST['stopsearch'], "stop", $_REQUEST['stopid'], "remove");
	echo "Added stop remove for" . $_REQUEST['stopsearch'] . ", stop" . $_REQUEST['stopid'] . "<br>\n";

	foreach ($service_periods as $sp) {
	echo "Remove from $sp routes<br>\n";
	foreach (getStopRoutes($_REQUEST['stopid'], $sp) as $route) {
	addInformedAlert($_REQUEST['stopsearch'], "route", $route['route_id'], "patch");
	echo "Added route patch for" . $_REQUEST['stopsearch'] . ", route" . $route['route_id'] . "<br>\n";
	}
	}
	die();
	}
	if ($_REQUEST['streetsearch']) {

	echo "Informing stops of street<br>\n";
	foreach (getStopsByName($_REQUEST['street']) as $stop) {
	addInformedAlert($_REQUEST['streetsearch'], "stop", $stop['stop_id'], "inform");
	echo "Added stop inform for" . $_REQUEST['streetsearch'] . ", stop" . $stop['stop_id'] . " ". $stop['stop_name']."<br>\n";

	foreach ($service_periods as $sp) {
	echo "Informing $sp routes<br>\n";
	foreach (getStopRoutes($stop['stop_id'], $sp) as $route) {
	addInformedAlert($_REQUEST['streetsearch'], "route", $route['route_id'], "inform");
	echo "Added route inform for stop" . $_REQUEST['streetsearch'] . ", route" . $route['route_id'] . "<br>\n";
	}
	}
	}

	die();
	}
	?>
	Active and Future Alerts:
	<table>
	<?php
	foreach (getFutureAlerts() as $alert) {
	echo "<tr><td>" . date("c", $alert['start']) . "</td><td>" . date("c", $alert['end']) . "</td><td>" . substr($alert['description'], 0, 999) . '</td><td><a href="?edit=' . $alert['id'] . '">edit</a></td></tr>';
	}
	?>
	</table>
	<?php
	$alert = getServiceAlert($_REQUEST['edit']);
	?>
	<form action="<?php echo basename(__FILE__);
	?>" method="get">

	<div data-role="fieldcontain">
	<label for="startdate"> Start Date</label>
	<input type="text" name="startdate" id="startdate" value="<?php
	if ($alert['start'])
	echo date("c", $alert['start']);
	else
	echo date("c", strtotime("0:00"));
	?>" />
	</div>
	<div data-role="fieldcontain">
	<label for="enddate"> End Date </label>
	<input type="text" name="enddate" id="enddate" value="<?php
	if ($alert['end'])
	echo date("c", $alert['end']);
	else
	echo date("c", strtotime("23:59"));
	?>" />
	</div>
	<div data-role="fieldcontain">
	<label for="header">Header</label>
	<input type="text" name="header" id="header" value="<?php echo $alert['header']; ?>" />
	</div>
	<div data-role="fieldcontain">
	<label for="description">Description</label>
	<textarea name="description"><?php echo $alert['description']; ?></textarea>
	</div>
	<div data-role="fieldcontain">
	<label for="url">URL</label>
	<input type="text" name="url" id="url" value="<?php echo $alert['url']; ?>" />
	</div>
	<div data-role="fieldcontain">
	<label for="cause"> Cause: </label>
	<select name="cause" id="cause">

	<?php
	foreach ($serviceAlertCause as $key => $value) {
	echo "<option value=\"$key\"" . ($key === $alert['cause'] ? " SELECTED" : "") . '>' . $value . '</option>';
	}
	?>
	</select></div>
	<div data-role="fieldcontain">
	<label for="effect"> Effect: </label>
	<select name="effect" id="effect">
	<?php
	foreach ($serviceAlertEffect as $key => $value) {
	echo "<option value=\"$key\"" . ($key === $alert['effect'] ? " SELECTED" : "") . '>' . $value . '</option>';
	}
	?>
	</select></div>
	<input type="hidden" name="saveedit" value="<?php echo $_REQUEST['edit']; ?>"/>
	<input type="submit" value="Save"/>
	</div></form>

	<?php
	if ($_REQUEST['edit']) {
	echo "Informed Entities for ID {$_REQUEST['edit']}:";
	echo '<table>';
	foreach (getInformedAlerts($_REQUEST['edit'], "", "") as $informed) {
	echo "<tr><td>{$informed['informed_class']}</td><td>{$informed['informed_id']}</td><td>{$informed['informed_action']}" . '</td><td><a href="?delete=' . $_REQUEST['edit'] . ';' . $informed['informed_class'] . ';' . $informed['informed_id'] . '">delete</a></td></tr>';
	}
	echo '</table>';
	?>
	<form action="<?php echo basename(__FILE__);
	?>" method="get">
	<input type="hidden" name="networkinform" value="<?php echo $_REQUEST['edit'];
	?>"/>
	<input type="submit" value="Add Network Inform"/>
	</form>
	<form action="<?php echo basename(__FILE__);
	?>" method="get">
	<div data-role="fieldcontain">
	<label for="stopid">StopID to remove</label>
	<input type="text" name="stopid" />
	</div>
	<input type="hidden" name="stopsearch" value="<?php echo $_REQUEST['edit'];
	?>"/>
	<input type="submit" value="Stop Search"/>
	</form>
	<form action="<?php echo basename(__FILE__);
	?>" method="get">
	<div data-role="fieldcontain">
	<label for="street">Street to inform</label>
	<input type="text" name="street" />
	</div>
	<input type="hidden" name="streetsearch" value="<?php echo $_REQUEST['edit'];
	?>"/>
	<input type="submit" value="Street Search"/>
	</form>
	<?php
	}
	include_footer();
	?>

file:b/rtpis/servicealert_viewer.php (new)

	<?php
	/*
	* Copyright 2010,2011 Alexander Sadleir

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	*/
	include ('../include/common.inc.php');
	include_header("Service Alert Viewer", "serviceAlertViewer");
	/**
	* Currently support:
	* network inform
	* stop remove: route patch, stop remove
	* - stop search
	* street inform: route inform, stop inform
	* - street search
	*/
	if (!isset($_REQUEST['view'])) {

	?>
	Active and Future Alerts:
	<table>
	<?php
	foreach (getFutureAlerts() as $alert) {
	echo "<tr><td>{$alert['header']}</td><td>" . substr($alert['description'], 0, 999) . '</td><td><a href="?view=' . $alert['id'] . '">View</a></td></tr>';
	}
	?>
	</table>
	<?php
	} else {
	$alert = getServiceAlert($_REQUEST['view']);
	echo "<h1>{$alert['header']}</h1>
	<h2> From ".date("c",$alert['start'])." to ".date("c",$alert['end'])."</h2>
	<small>{$alert['description']}</small><br>
	Source: <A href='{$alert['url']}'>{$alert['url']}</a><br>";
	echo "Informed Entities for ID {$_REQUEST['view']}:";
	echo '<table>';
	foreach (getInformedAlerts($_REQUEST['view'], "", "") as $informed) {
	echo "<tr><td>{$informed['informed_class']}</td><td>{$informed['informed_id']}</td><td>{$informed['informed_action']}" . '</td></tr>';
	}
	echo '</table>';
	}
	include_footer();
	?>

file:b/rtpis/siri.php (new)

	<?php

	/*
	* Copyright 2010,2011 Alexander Sadleir

	Licensed under the Apache License, Version 2.0 (the "License");
	you may not use this file except in compliance with the License.
	You may obtain a copy of the License at

	http://www.apache.org/licenses/LICENSE-2.0

	Unless required by applicable law or agreed to in writing, software
	distributed under the License is distributed on an "AS IS" BASIS,
	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
	See the License for the specific language governing permissions and
	limitations under the License.
	*/
	include ('include/common.inc.php');
	function accept_header($header = false) {
	// http://jrgns.net/parse_http_accept_header
	$toret = null;
	$header = $header ? $header : (array_key_exists('HTTP_ACCEPT', $_SERVER) ? $_SERVER['HTTP_ACCEPT']: false);
	if ($header) {
	$types = explode(',', $header);
	$types = array_map('trim', $types);
	foreach ($types as $one_type) {
	$one_type = explode(';', $one_type);
	$type = array_shift($one_type);
	if ($type) {
	list($precedence, $tokens) = self::accept_header_options($one_type);
	list($main_type, $sub_type) = array_map('trim', explode('/', $type));
	$toret[] = array('main_type' => $main_type, 'sub_type' => $sub_type, 'precedence' => (float)$precedence, 'tokens' => $tokens);
	}
	}
	usort($toret, array('Parser', 'compare_media_ranges'));
	}
	return $toret;
	}
	function usage() {
	echo "Usage notes: Must specify format json/xml. If callback is specified, will provide jsonp. Can filter with parmaters filter_class route/stop and filter_id with the id specified in GTFS."
	die();
	}
	$json_types = Array("application/json","application/x-javascript","text/javascript","text/x-javascript","text/x-json");
	if ($_REQUEST['json']) {
	if ($_REQUEST['alerts']) {
	$return = getServiceAlertsAsJSON($_REQUEST['filter_class'], $_REQUEST['filter_id']);
	} else if ($_REQUEST['updates']) {
	$return = getTripUpdatesAsJSON($_REQUEST['filter_class'], $_REQUEST['filter_id']);
	} else {
	usage();
	}
	header('Content-Type: application/json; charset=utf8');
	// header('Access-Control-Allow-Origin: http://bus.lambdacomplex.org/');
	header('Access-Control-Max-Age: 3628800');
	header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE');
	if (isset($_GET['callback'])) {
	$json = '(' . $return . ');'; //must wrap in parens and end with semicolon
	//print_r($_GET['callback'] . $json); //callback is prepended for json-p
	}
	else {
	echo $return;
	}
	} else if ($_REQUEST['xml']) {
	if ($_REQUEST['alerts']) {
	$return = getServiceAlertsAsBinary($_REQUEST['filter_class'], $_REQUEST['filter_id']);
	} else if ($_REQUEST['updates']) {
	$return = getTripUpdatesAsBinary($_REQUEST['filter_class'], $_REQUEST['filter_id']);
	} else {
	usage();
	}
	header('Content-Type: application/json; charset=utf8');
	// header('Access-Control-Allow-Origin: http://bus.lambdacomplex.org/');
	header('Access-Control-Max-Age: 3628800');
	header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE');
	echo $return;
	} else {
	usage();
	}
	?>

file:a/servicealerts/importer.py (deleted)

# info
# http://stackoverflow.com/questions/4206882/named-entity-recognition-with-preset-list-of-names-for-python-php/4207128#4207128
# http://alias-i.com/lingpipe/demos/tutorial/ne/read-me.html approximate dist
# http://streamhacker.com/2008/12/29/how-to-train-a-nltk-chunker/ more training
# http://www.postgresql.org/docs/9.1/static/pgtrgm.html

# data sources
# http://twitter.com/#!/ACTEmergencyInf instant site wide
# http://twitter.com/#!/ACTPol_Traffic
# http://esa.act.gov.au/feeds/currentincidents.xml

# source: https://gist.github.com/322906/90dea659c04570757cccf0ce1e6d26c9d06f9283
# to install python -m nltk.downloader punkt
import nltk
import tweepy
import psycopg2
import pickle

from iniparse import INIConfig

def insert_service_alert_sitewide(heading, message, url):
print "NaN"

def insert_service_alert_for_street(streets, heading, message, url):
conn_string = "host='localhost' dbname='energymapper' user='postgres' password='snmc'"
# print the connection string we will use to connect
print "Connecting to database\n ->%s" % (conn_string)
try:
# get a connection, if a connect cannot be made an exception will be raised here
conn = psycopg2.connect(conn_string)

# conn.cursor will return a cursor object, you can use this cursor to perform queries
cursor = conn.cursor()

# execute our Query
cursor.execute("")

# retrieve the records from the database
records = cursor.fetchall()

for record in records:
ys.append(record[0])
# >>> cur.execute("INSERT INTO test (num, data) VALUES (%s, %s)", (42, 'bar'))
#>>> cur.statusmessage
#'INSERT 0 1'
except:
# Get the most recent exception
exceptionType, exceptionValue, exceptionTraceback = sys.exc_info()
# Exit the script and print an error telling what happened.
sys.exit("Database connection failed!\n ->%s" % (exceptionValue))


def extract_entity_names(t):
entity_names = []

if hasattr(t, 'node') and t.node:
if t.node == 'NE':
entity_names.append(' '.join([child[0] for child in t]))
else:
for child in t:
entity_names.extend(extract_entity_names(child))

return entity_names

def extract_names(sample):
sentences = nltk.sent_tokenize(sample)
tokenized_sentences = [nltk.word_tokenize(sentence) for sentence in sentences]
tagged_sentences = [nltk.pos_tag(sentence) for sentence in tokenized_sentences]
chunked_sentences = nltk.batch_ne_chunk(tagged_sentences, binary=True)
# chunked/tagged may be enough to just find and match the nouns

entity_names = []
for tree in chunked_sentences:
# Print results per sentence
# print extract_entity_names(tree)

entity_names.extend(extract_entity_names(tree))

# Print all entity names
#print entity_names

# Print unique entity names
print set(entity_names)

cfg = INIConfig(open('/tmp/aws.ini'))

auth = tweepy.OAuthHandler(cfg.api_keys.twitter_consumer_key, cfg.api_keys.twitter_consumer_secret)
auth.set_access_token(cfg.api_keys.twitter_access_token, cfg.api_keys.twitter_access_token_secret)

#api = tweepy.API(auth)
api = tweepy.API()
# If the authentication was successful, you should
# see the name of the account print out
#print api.me().name
# https://github.com/tweepy/tweepy/blob/master/tweepy/api.py
for status in api.user_timeline(screen_name="ACTPol_Traffic",exclude_replies='true'):
print status.text
print status.created_at
print extract_names(status.text)
# print api.update_status(status="test")

last_tweet_ids = { "lion": "111", "kitty": "2222" }
pickle.dump( last_tweet_ids, open( "save.p", "wb" ) )
last_tweet_ids = pickle.load( open( "save.p", "rb" ) )

file:a/servicealerts/index.php (deleted)

<?php
include ('../include/common.inc.php');

include_header("Service Alerts", "index");
echo '<ul data-role="listview" data-theme="e" data-groupingtheme="e">';

if ($_SESSION['authed'] == true) {
echo' <li><a href="servicealert_editor.php"><h3>servicealert_editor</h3>
<p>servicealert_editor</p></a></li>';
}
echo' <li><a href="servicealert_viewer.php"><h3>Service Alert Viewer</h3>
<p>Browse current network alerts</p></a></li>';

echo' </ul>';

?> </div>
<?php
include_footer()
?>

file:a/servicealerts/punkt.zip (deleted)

file:a/servicealerts/servicealert_editor.php (deleted)

<?php
/*
* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
include ('../include/common.inc.php');
auth();
include_header("Service Alert Editor", "serviceAlertEditor");
/**
* Currently support:
* network inform
* stop remove: route patch, stop remove
* - stop search
* street inform: route inform, stop inform
* - street search
*/
if (isset($_REQUEST['saveedit'])) {

if ($_REQUEST['saveedit'] != "")
updateServiceAlert($_REQUEST['saveedit'], $_REQUEST['startdate'], $_REQUEST['enddate'], $_REQUEST['header'], $_REQUEST['description'], $_REQUEST['url']);
else
addServiceAlert($_REQUEST['startdate'], $_REQUEST['enddate'], $_REQUEST['header'], $_REQUEST['description'], $_REQUEST['url']);
echo "Saved " . $_REQUEST['saveedit'];
die();
}
if ($_REQUEST['delete']) {
$deleteParts = explode(";", $_REQUEST['delete']);
deleteInformedAlert($deleteParts[0], $deleteParts[1], $deleteParts[2]);
echo "Deleted network inform for {$deleteParts[0]} ({$deleteParts[1]},{$deleteParts[2]})<br>\n";
die();
}
if ($_REQUEST['networkinform']) {
addInformedAlert($_REQUEST['networkinform'], "agency", "0", "inform");
echo "Added network inform for" . $_REQUEST['networkinform'];
die();
}
if ($_REQUEST['stopsearch']) {
addInformedAlert($_REQUEST['stopsearch'], "stop", $_REQUEST['stopid'], "remove");
echo "Added stop remove for" . $_REQUEST['stopsearch'] . ", stop" . $_REQUEST['stopid'] . "<br>\n";

foreach ($service_periods as $sp) {
echo "Remove from $sp routes<br>\n";
foreach (getStopRoutes($_REQUEST['stopid'], $sp) as $route) {
addInformedAlert($_REQUEST['stopsearch'], "route", $route['route_id'], "patch");
echo "Added route patch for" . $_REQUEST['stopsearch'] . ", route" . $route['route_id'] . "<br>\n";
}
}
die();
}
if ($_REQUEST['streetsearch']) {

echo "Informing stops of street<br>\n";
foreach (getStopByName() as $stop) {
addInformedAlert($_REQUEST['stopsearch'], "stop", $_REQUEST['stopid'], "inform");
echo "Added stop inform for" . $_REQUEST['stopsearch'] . ", stop" . $_REQUEST['stopid'] . "<br>\n";

foreach ($service_periods as $sp) {
echo "Informing $sp routes<br>\n";
foreach (getStopRoutes($_REQUEST['stopid'], $sp) as $route) {
addInformedAlert($_REQUEST['stopsearch'], "route", $route['route_id'], "inform");
echo "Added route inform for stop" . $_REQUEST['stopsearch'] . ", route" . $route['route_id'] . "<br>\n";
}
}
die();
}
}
?>
Active and Future Alerts:
<table>
<?php
foreach (getFutureAlerts() as $alert) {
echo "<tr><td>{$alert['start']}</td><td>{$alert['end']}</td><td>" . substr($alert['description'], 0, 999) . '</td><td><a href="?edit=' . $alert['id'] . '">edit</a></td></tr>';
}
?>
</table>
<?php
$alert = getServiceAlert($_REQUEST['edit']);
?>
<form action="<?php echo basename(__FILE__);
?>" method="get">

<div data-role="fieldcontain">
<label for="startdate"> Start Date</label>
<input type="text" name="startdate" id="startdate" value="<?php
if ($alert['start'])
echo $alert['start'];
else
echo date("c", strtotime("0:00"));
?>" />
</div>
<div data-role="fieldcontain">
<label for="enddate"> End Date </label>
<input type="text" name="enddate" id="enddate" value="<?php
if ($alert['end'])
echo $alert['end'];
else
echo date("c", strtotime("23:59"));
?>" />
</div>
<div data-role="fieldcontain">
<label for="header">Header</label>
<input type="text" name="header" id="header" value="<?php echo $alert['header']; ?>" />
</div>
<div data-role="fieldcontain">
<label for="description">Description</label>
<textarea name="description">
<?php echo $alert['description']; ?></textarea>
</div>
<div data-role="fieldcontain">
<label for="url">URL</label>
<input type="text" name="url" id="url" value="<?php echo $alert['url']; ?>" />
</div>
<input type="hidden" name="saveedit" value="<?php echo $_REQUEST['edit']; ?>"/>
<input type="submit" value="Save"/>
</div></form>

<?php
if ($_REQUEST['edit']) {
echo "Informed Entities for ID {$_REQUEST['edit']}:";
echo '<table>';
foreach (getInformedAlerts($_REQUEST['edit'], "", "") as $informed) {
echo "<tr><td>{$informed['informed_class']}</td><td>{$informed['informed_id']}</td><td>{$informed['informed_action']}" . '</td><td><a href="?delete=' . $_REQUEST['edit'] . ';' . $informed['informed_class'] . ';' . $informed['informed_id'] . '">delete</a></td></tr>';
}
echo '</table>';
?>
<form action="<?php echo basename(__FILE__);
?>" method="get">
<input type="hidden" name="networkinform" value="<?php echo $_REQUEST['edit'];
?>"/>
<input type="submit" value="Add Network Inform"/>
</form>
<form action="<?php echo basename(__FILE__);
?>" method="get">
<div data-role="fieldcontain">
<label for="stopid">StopID to remove</label>
<input type="text" name="stopid" />
</div>
<input type="hidden" name="stopsearch" value="<?php echo $_REQUEST['edit'];
?>"/>
<input type="submit" value="Stop Search"/>
</form>
<form action="<?php echo basename(__FILE__);
?>" method="get">
<div data-role="fieldcontain">
<label for="street">Street to inform</label>
<input type="text" name="street" />
</div>
<input type="hidden" name="streetsearch" value="<?php echo $_REQUEST['edit'];
?>"/>
<input type="submit" value="Street Search"/>
</form>
<?php
}
include_footer();
?>

file:a/servicealerts/servicealert_viewer.php (deleted)

<?php
/*
* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
include ('../include/common.inc.php');
include_header("Service Alert Viewer", "serviceAlertViewer");
/**
* Currently support:
* network inform
* stop remove: route patch, stop remove
* - stop search
* street inform: route inform, stop inform
* - street search
*/
if (!isset($_REQUEST['view'])) {

?>
Active and Future Alerts:
<table>
<?php
foreach (getFutureAlerts() as $alert) {
echo "<tr><td>{$alert['header']}</td><td>" . substr($alert['description'], 0, 999) . '</td><td><a href="?view=' . $alert['id'] . '">View</a></td></tr>';
}
?>
</table>
<?php
} else {
$alert = getServiceAlert($_REQUEST['view']);
echo "<h1>{$alert['header']}</h1>
<h2> From ".date("c",$alert['start'])." to ".date("c",$alert['end'])."</h2>
<small>{$alert['description']}</small><br>
Source: <A href='{$alert['url']}'>{$alert['url']}</a><br>";
echo "Informed Entities for ID {$_REQUEST['view']}:";
echo '<table>';
foreach (getInformedAlerts($_REQUEST['view'], "", "") as $informed) {
echo "<tr><td>{$informed['informed_class']}</td><td>{$informed['informed_id']}</td><td>{$informed['informed_action']}" . '</td></tr>';
}
echo '</table>';
}
include_footer();
?>

file:a/servicealerts_api.php (deleted)

<?php

/*
* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
include ('include/common.inc.php');

if (basename(__FILE__) == "servicealerts_api.php") {
$return = getServiceAlertsAsJSON($_REQUEST['filter_class'], $_REQUEST['filter_id']);
header('Content-Type: text/javascript; charset=utf8');
// header('Access-Control-Allow-Origin: http://bus.lambdacomplex.org/');
header('Access-Control-Max-Age: 3628800');
header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE');
if (isset($_GET['callback'])) {
$json = '(' . $return . ');'; //must wrap in parens and end with semicolon
//print_r($_GET['callback'] . $json); //callback is prepended for json-p
}
else
echo $return;
}
?>

<?php	<?php

/*	/*
* Copyright 2010,2011 Alexander Sadleir	* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");	Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.	you may not use this file except in compliance with the License.
You may obtain a copy of the License at	You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0	http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software	Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,	distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and	See the License for the specific language governing permissions and
limitations under the License.	limitations under the License.
*/	*/

// Copyright 2009 Google Inc. All Rights Reserved.	// Copyright 2009 Google Inc. All Rights Reserved.
$GA_ACCOUNT = "MO-22173039-1";	$GA_ACCOUNT = "MO-22173039-1";
$GA_PIXEL = "/lib/ga.php";	$GA_PIXEL = "/lib/ga.php";

function googleAnalyticsGetImageUrl() {	function googleAnalyticsGetImageUrl() {
global $GA_ACCOUNT, $GA_PIXEL;	global $GA_ACCOUNT, $GA_PIXEL;
//if (stristr($_SERVER['HTTP_USER_AGENT'], 'Googlebot') return "";	//if (stristr($_SERVER['HTTP_USER_AGENT'], 'Googlebot') return "";
$url = "";	$url = "";
$url.= $GA_PIXEL . "?";	$url.= $GA_PIXEL . "?";
$url.= "utmac=" . $GA_ACCOUNT;	$url.= "utmac=" . $GA_ACCOUNT;
$url.= "&utmn=" . rand(0, 0x7fffffff);	$url.= "&utmn=" . rand(0, 0x7fffffff);
$referer = (isset($_SERVER["HTTP_REFERER"]) ? $_SERVER["HTTP_REFERER"] : "");	$referer = (isset($_SERVER["HTTP_REFERER"]) ? $_SERVER["HTTP_REFERER"] : "");
$query = $_SERVER["QUERY_STRING"];	$query = $_SERVER["QUERY_STRING"];
$path = $_SERVER["REQUEST_URI"];	$path = $_SERVER["REQUEST_URI"];
if (empty($referer)) {	if (empty($referer)) {
$referer = "-";	$referer = "-";
}	}
$url.= "&utmr=" . urlencode($referer);	$url.= "&utmr=" . urlencode($referer);
if (!empty($path)) {	if (!empty($path)) {
$url.= "&utmp=" . urlencode($path);	$url.= "&utmp=" . urlencode($path);
}	}
$url.= "&guid=ON";	$url.= "&guid=ON";

<?php	<?php

/*	/*
* Copyright 2010,2011 Alexander Sadleir	* Copyright 2010,2011 Alexander Sadleir

Licensed under the Apache License, Version 2.0 (the "License");	Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.	you may not use this file except in compliance with the License.
You may obtain a copy of the License at	You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0	http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software	Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,	distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and	See the License for the specific language governing permissions and
limitations under the License.	limitations under the License.
*/	*/
$service_periods = Array(	$service_periods = Array(
'sunday',	'sunday',
'saturday',	'saturday',
'weekday'	'weekday'
);	);

function service_period($date = "") {	function service_period($date = "") {

if (isset($_REQUEST['service_period'])) {	if (isset($_REQUEST['service_period'])) {
return $_REQUEST['service_period'];	return $_REQUEST['service_period'];
}	}

$override = getServiceOverride($date);	$override = getServiceOverride($date);
if (isset($override['service_id'])) {	if (isset($override['service_id'])) {
return strtolower($override['service_id']);	return strtolower($override['service_id']);
}	}
$date = ($date != "" ? $date : time());	$date = ($date != "" ? $date : time());
$dow = date('w', $date);	$dow = date('w', $date);

switch ($dow) {	switch ($dow) {
case 0:	case 0:
return 'sunday';	return 'sunday';
case 6:	case 6: