projects / busui.git / blobdiff
search:
summary | shortlog | log | commit | commitdiff | tree
unified | plain
Merge new gtfs-realtime into existing servicealerts architecture
[busui.git] / include / common-transit.inc.php
blob:a/include/common-transit.inc.php -> blob:b/include/common-transit.inc.php
<?php <?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.
  */
$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($_SESSION['service_period'])) return $_SESSION['service_period']; return $_REQUEST['service_period'];
$override = getServiceOverride($date); }
if ($override['service_id']){  
return $override['service_id']; $override = getServiceOverride($date);
} if (isset($override['service_id'])) {
  return strtolower($override['service_id']);
switch (date('w',($date != "" ? $date : time()))) { }
case 0: $date = ($date != "" ? $date : time());
return 'sunday'; $dow = date('w', $date);
case 6:  
return 'saturday'; switch ($dow) {
default: case 0:
return 'weekday'; return 'sunday';
} case 6:
} return 'saturday';
function midnight_seconds($time = "") default:
{ return 'weekday';
// from http://www.perturb.org/display/Perlfunc__Seconds_Since_Midnight.html }
if ($time != "") { }
return (date("G", $time) * 3600) + (date("i", $time) * 60) + date("s", $time);  
} function service_ids($service_period, $date = "") {
if (isset($_SESSION['time'])) { switch ($service_period) {
$time = strtotime($_SESSION['time']); case 'sunday':
return (date("G", $time) * 3600) + (date("i", $time) * 60) + date("s", $time); return Array("Sunday", "Sunday");
} case 'saturday':
return (date("G") * 3600) + (date("i") * 60) + date("s"); return Array("Saturday", "Saturday");
} default:
function midnight_seconds_to_time($seconds) $date = ($date != "" ? $date : time());
{ // school holidays
if ($seconds > 0) { $ymd = date('Ymd', $date);
$midnight = mktime(0, 0, 0, date("n") , date("j") , date("Y")); $dow = date('w', $date);
return date("h:ia", $midnight + $seconds); if (intval($ymd) < "20120203" && $dow != 0 && $dow != 6) {
} return Array("Weekday-SchoolVacation", "Weekday-SchoolVacation");
else { } else {
return ""; return Array("Weekday", "Weekday");
} }
} }
  }
   
  function valid_service_ids() {
  return array_merge(service_ids(""), service_ids('saturday'), service_ids('sunday'));
  }
   
  function midnight_seconds($time = "") {
  // from http://www.perturb.org/display/Perlfunc__Seconds_Since_Midnight.html
  if ($time != "") {
  return (date("G", $time) * 3600) + (date("i", $time) * 60) + date("s", $time);
  }
  if (isset($_SESSION['time'])) {
  $time = strtotime($_SESSION['time']);
  return (date("G", $time) * 3600) + (date("i", $time) * 60) + date("s", $time);
  }
  return (date("G") * 3600) + (date("i") * 60) + date("s");
  }
   
  function midnight_seconds_to_time($seconds) {
  if ($seconds > 0) {
  $midnight = mktime(0, 0, 0, date("n"), date("j"), date("Y"));
  return date("h:ia", $midnight + $seconds);
  } else {
  return "";
  }
  }
   
if ($GTFSREnabled) { if ($GTFSREnabled) {
$serviceAlertCause = Array( $serviceAlertCause = Array(
"UNKNOWN_CAUSE" => "Unknown cause", "UNKNOWN_CAUSE" => "Unknown cause",
"OTHER_CAUSE" => "Other cause", "OTHER_CAUSE" => "Other cause",
"TECHNICAL_PROBLEM" => "Technical problem", "TECHNICAL_PROBLEM" => "Technical problem",
"STRIKE" => "Strike", "STRIKE" => "Strike",
"DEMONSTRATION" => "Demonstration", "DEMONSTRATION" => "Demonstration",
"ACCIDENT" => "Accident", "ACCIDENT" => "Accident",
"HOLIDAY" => "Holiday", "HOLIDAY" => "Holiday",
"WEATHER" => "Weather", "WEATHER" => "Weather",
"MAINTENANCE" => "Maintenance", "MAINTENANCE" => "Maintenance",
"CONSTRUCTION" => "Construction", "CONSTRUCTION" => "Construction",
"POLICE_ACTIVITY" => "Police activity", "POLICE_ACTIVITY" => "Police activity",
"MEDICAL_EMERGENCY" => "Medical emergency" "MEDICAL_EMERGENCY" => "Medical emergency"
); );
$serviceAlertEffect = Array( $serviceAlertEffect = Array(
"NO_SERVICE" => "No service", "NO_SERVICE" => "No service",
"REDUCED_SERVICE" => "Reduced service", "REDUCED_SERVICE" => "Reduced service",
"SIGNIFICANT_DELAYS" => "Significant delays", "SIGNIFICANT_DELAYS" => "Significant delays",
"DETOUR" => "Detour", "DETOUR" => "Detour",
"ADDITIONAL_SERVICE" => "Additional service", "ADDITIONAL_SERVICE" => "Additional service",
"MODIFIED_SERVICE" => "Modified service", "MODIFIED_SERVICE" => "Modified service",
"OTHER_EFFECT" => "Other effect", "OTHER_EFFECT" => "Other effect",
"UNKNOWN_EFFECT" => "Unknown effect", "UNKNOWN_EFFECT" => "Unknown effect",
"STOP_MOVED" => "Stop moved"); "STOP_MOVED" => "Stop moved");
   
set_include_path(get_include_path() . PATH_SEPARATOR . $labsPath."lib/Protobuf-PHP/library/DrSlump/"); set_include_path(get_include_path() . PATH_SEPARATOR . ($basePath . "lib/Protobuf-PHP/library/DrSlump/"));
   
include_once("Protobuf.php"); include_once("Protobuf.php");
include_once("Protobuf/Message.php"); include_once("Protobuf/Message.php");
include_once("Protobuf/Registry.php"); include_once("Protobuf/Registry.php");
include_once("Protobuf/Descriptor.php"); include_once("Protobuf/Descriptor.php");
include_once("Protobuf/Field.php"); include_once("Protobuf/Field.php");
   
include_once($labsPath."lib/Protobuf-PHP/gtfs-realtime.php"); include_once($basePath . "lib/Protobuf-PHP/gtfs-realtime.php");
include_once("Protobuf/CodecInterface.php"); include_once("Protobuf/CodecInterface.php");
include_once("Protobuf/Codec/PhpArray.php"); include_once("Protobuf/Codec/PhpArray.php");
include_once("Protobuf/Codec/Binary.php"); include_once("Protobuf/Codec/Binary.php");
include_once("Protobuf/Codec/Binary/Writer.php"); include_once("Protobuf/Codec/Binary/Writer.php");
include_once("Protobuf/Codec/Json.php"); include_once("Protobuf/Codec/Json.php");
   
function getServiceAlerts($filter_class = "", $filter_id = "") { function getServiceAlerts($filter_class = "", $filter_id = "") {
/* /*
   
also need last modified epoch of client gtfs also need last modified epoch of client gtfs
   
- add,remove,patch,inform (null) - add,remove,patch,inform (null)
- stop - stop
- trip - trip
- network - network
- classes (WHERE=) - classes (WHERE=)
- route (short_name or route_id) - route (short_name or route_id)
- street - street
- stop - stop
- trip - trip
Currently support: Currently support:
network inform network inform
trip patch: stop remove trip patch: stop remove
street inform: route inform, trip inform, stop inform street inform: route inform, trip inform, stop inform
route patch: trip remove route patch: trip remove
*/ */
$fm = new transit_realtime\FeedMessage(); $fm = new transit_realtime\FeedMessage();
$fh = new transit_realtime\FeedHeader(); $fh = new transit_realtime\FeedHeader();
$fh->setGtfsRealtimeVersion(1); $fh->setGtfsRealtimeVersion(1);
$fh->setTimestamp(time()); $fh->setTimestamp(time());
$fm->setHeader($fh); $fm->setHeader($fh);
foreach(getCurrentAlerts() as $alert) { foreach (getCurrentAlerts() as $alert) {
$fe = new transit_realtime\FeedEntity(); $fe = new transit_realtime\FeedEntity();
$fe->setId($alert['id']); $fe->setId($alert['id']);
$fe->setIsDeleted(false); $fe->setIsDeleted(false);
$alert = new transit_realtime\Alert(); $alert = new transit_realtime\Alert();
$tr = new transit_realtime\TimeRange(); $tr = new transit_realtime\TimeRange();
$tr->setStart($alert['start']); $tr->setStart($alert['start']);
$tr->setEnd($alert['end']); $tr->setEnd($alert['end']);
$alert-> addActivePeriod($tr); $alert->addActivePeriod($tr);
$informedEntities = getInformedAlerts($alert['id'],$_REQUEST['filter_class'],$_REQUEST['filter_id']); $informedEntities = getInformedAlerts($alert['id'], $_REQUEST['filter_class'], $_REQUEST['filter_id']);
if (sizeof($informedEntities) >0) { if (sizeof($informedEntities) > 0) {
$informed = Array(); $informed = Array();
$es = new transit_realtime\EntitySelector(); $es = new transit_realtime\EntitySelector();
if ($informedEntity['informed_class'] == "agency") { if ($informedEntity['informed_class'] == "agency") {
$es->setAgencyId($informedEntity['informed_id']); $es->setAgencyId($informedEntity['informed_id']);
} }
if ($informedEntity['informed_class'] == "stop") { if ($informedEntity['informed_class'] == "stop") {
$es->setStopId($informedEntity['informed_id']); $es->setStopId($informedEntity['informed_id']);
} }
if ($informedEntity['informed_class'] == "route") { if ($informedEntity['informed_class'] == "route") {
$es->setRouteId($informedEntity['informed_id']); $es->setRouteId($informedEntity['informed_id']);
} }
if ($informedEntity['informed_class'] == "trip") { if ($informedEntity['informed_class'] == "trip") {
$td = new transit_realtime\TripDescriptor(); $td = new transit_realtime\TripDescriptor();
$td->setTripId($informedEntity['informed_id']); $td->setTripId($informedEntity['informed_id']);
$es->setTrip($td); $es->setTrip($td);
} }
$alert-> addInformedEntity($es); $alert->addInformedEntity($es);
} }
$alert->setCause(constant("transit_realtime\Alert\Cause::".$alert['cause'])); $alert->setCause(constant("transit_realtime\Alert\Cause::" . $alert['cause']));
$alert->setEffect(constant("transit_realtime\Alert\Effect::".$alert['effect'])); $alert->setEffect(constant("transit_realtime\Alert\Effect::" . $alert['effect']));
$tsUrl = new transit_realtime\TranslatedString(); $tsUrl = new transit_realtime\TranslatedString();
$tUrl = new transit_realtime\TranslatedString\Translation(); $tUrl = new transit_realtime\TranslatedString\Translation();
$tUrl->setText($alert['url']); $tUrl->setText($alert['url']);
$tUrl->setLanguage("en"); $tUrl->setLanguage("en");
$tsUrl->addTranslation($tUrl); $tsUrl->addTranslation($tUrl);
$alert->setUrl($tsUrl); $alert->setUrl($tsUrl);
$tsHeaderText= new transit_realtime\TranslatedString(); $tsHeaderText = new transit_realtime\TranslatedString();
$tHeaderText = new transit_realtime\TranslatedString\Translation(); $tHeaderText = new transit_realtime\TranslatedString\Translation();
$tHeaderText->setText($alert['header']); $tHeaderText->setText($alert['header']);
$tHeaderText->setLanguage("en"); $tHeaderText->setLanguage("en");
$tsHeaderText->addTranslation($tHeaderText); $tsHeaderText->addTranslation($tHeaderText);
$alert->setHeaderText($tsHeaderText); $alert->setHeaderText($tsHeaderText);
$tsDescriptionText= new transit_realtime\TranslatedString(); $tsDescriptionText = new transit_realtime\TranslatedString();
$tDescriptionText = new transit_realtime\TranslatedString\Translation(); $tDescriptionText = new transit_realtime\TranslatedString\Translation();
$tDescriptionText->setText($alert['description']); $tDescriptionText->setText($alert['description']);
$tDescriptionText->setLanguage("en"); $tDescriptionText->setLanguage("en");
$tsDescriptionText->addTranslation($tDescriptionText); $tsDescriptionText->addTranslation($tDescriptionText);
$alert->setDescriptionText($tsDescriptionText); $alert->setDescriptionText($tsDescriptionText);
$fe->setAlert($alert); $fe->setAlert($alert);
$fm->addEntity($fe); $fm->addEntity($fe);
} }
return $fm; return $fm;
} }
function getServiceAlertsAsArray($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\PhpArray(); function getServiceAlertsAsArray($filter_class = "", $filter_id = "") {
return $codec->encode(getServiceAlerts($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\PhpArray();
} return $codec->encode(getServiceAlerts($filter_class, $filter_id));
  }
function getServiceAlertsAsBinary($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\Binary(); function getServiceAlertsAsBinary($filter_class = "", $filter_id = "") {
return $codec->encode(getServiceAlerts($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\Binary();
} return $codec->encode(getServiceAlerts($filter_class, $filter_id));
  }
function getServiceAlertsAsJSON($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\Json(); function getServiceAlertsAsJSON($filter_class = "", $filter_id = "") {
return $codec->encode(getServiceAlerts($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\Json();
} return $codec->encode(getServiceAlerts($filter_class, $filter_id));
function getServiceAlertsByClass() { }
$return = Array();  
$alerts = getServiceAlertsAsArray("",""); function getServiceAlertsByClass() {
foreach ($alerts['entities'] as $entity) { $return = Array();
foreach ($entity['informed'] as $informed) { $alerts = getServiceAlertsAsArray("", "");
foreach($informed as $key => $value){ foreach ($alerts['entities'] as $entity) {
if (strpos("_id",$key) > 0) { foreach ($entity['informed'] as $informed) {
$parts = explode($key); foreach ($informed as $key => $value) {
$class = $parts[0]; if (strpos("_id", $key) > 0) {
$id = $value; $parts = explode($key);
} $class = $parts[0];
} $id = $value;
$return[$class][$id][] = $entity; }
} }
} $return[$class][$id][] = $entity;
} }
  }
function getTripUpdates($filter_class = "", $filter_id = "") { }
$fm = new transit_realtime\FeedMessage();  
$fh = new transit_realtime\FeedHeader(); function getTripUpdates($filter_class = "", $filter_id = "") {
$fh->setGtfsRealtimeVersion(1); $fm = new transit_realtime\FeedMessage();
$fh->setTimestamp(time()); $fh = new transit_realtime\FeedHeader();
$fm->setHeader($fh); $fh->setGtfsRealtimeVersion(1);
foreach(getCurrentAlerts() as $alert) { $fh->setTimestamp(time());
$informedEntities = getInformedAlerts($alert['id'],$_REQUEST['filter_class'],$_REQUEST['filter_id']); $fm->setHeader($fh);
$stops = Array(); foreach (getCurrentAlerts() as $alert) {
$routestrips = Array(); $informedEntities = getInformedAlerts($alert['id'], $_REQUEST['filter_class'], $_REQUEST['filter_id']);
if (sizeof($informedEntities) >0) { $stops = Array();
if ($informedEntity['informed_class'] == "stop" && $informed["x-action"] == "remove") { $routestrips = Array();
$stops[] = $informedEntity['informed_id']; if (sizeof($informedEntities) > 0) {
} if ($informedEntity['informed_class'] == "stop" && $informed["x-action"] == "remove") {
if (($informedEntity['informed_class'] == "route" || $informedEntity['informed_class'] == "trip") && $informed["x-action"] == "patch" ) { $stops[] = $informedEntity['informed_id'];
$routestrips[] = Array( "id" => $informedEntity['informed_id'], }
"type"=>$informedEntity['informed_class']); if (($informedEntity['informed_class'] == "route" || $informedEntity['informed_class'] == "trip") && $informed["x-action"] == "patch") {
} $routestrips[] = Array("id" => $informedEntity['informed_id'],
} "type" => $informedEntity['informed_class']);
foreach ($routestrips as $routetrip) { }
$fe = new transit_realtime\FeedEntity(); }
$fe->setId($alert['id'].$routetrip['id']); foreach ($routestrips as $routetrip) {
$fe->setIsDeleted(false); $fe = new transit_realtime\FeedEntity();
$tu = new transit_realtime\TripUpdate(); $fe->setId($alert['id'] . $routetrip['id']);
$td = new transit_realtime\TripDescriptor(); $fe->setIsDeleted(false);
if ($routetrip['type'] == "route") { $tu = new transit_realtime\TripUpdate();
$td->setRouteId($routetrip['id']); $td = new transit_realtime\TripDescriptor();
} else if ($routetrip['type'] == "trip") { if ($routetrip['type'] == "route") {
$td->setTripId($routetrip['id']); $td->setRouteId($routetrip['id']);
} } else if ($routetrip['type'] == "trip") {
$tu->setTrip($td); $td->setTripId($routetrip['id']);
foreach ($stops as $stop) { }
$stu = new transit_realtime\TripUpdate\StopTimeUpdate(); $tu->setTrip($td);
$stu->setStopId($stop); foreach ($stops as $stop) {
$stu->setScheduleRelationship(transit_realtime\TripUpdate\StopTimeUpdate\ScheduleRelationship::SKIPPED); $stu = new transit_realtime\TripUpdate\StopTimeUpdate();
$tu->addStopTimeUpdate($stu); $stu->setStopId($stop);
} $stu->setScheduleRelationship(transit_realtime\TripUpdate\StopTimeUpdate\ScheduleRelationship::SKIPPED);
$fe->setTripUpdate($tu); $tu->addStopTimeUpdate($stu);
$fm->addEntity($fe); }
} $fe->setTripUpdate($tu);
  $fm->addEntity($fe);
} }
return $fm; }
  return $fm;
} }
function getTripUpdatesAsArray($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\PhpArray(); function getTripUpdatesAsArray($filter_class = "", $filter_id = "") {
return $codec->encode(getTripUpdates($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\PhpArray();
} return $codec->encode(getTripUpdates($filter_class, $filter_id));
  }
function getTripUpdatesAsBinary($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\Binary(); function getTripUpdatesAsBinary($filter_class = "", $filter_id = "") {
return $codec->encode(getTripUpdates($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\Binary();
} return $codec->encode(getTripUpdates($filter_class, $filter_id));
  }
function getTripUpdatesAsJSON($filter_class = "", $filter_id = "") {  
$codec = new DrSlump\Protobuf\Codec\Json(); function getTripUpdatesAsJSON($filter_class = "", $filter_id = "") {
return $codec->encode(getTripUpdates($filter_class, $filter_id)); $codec = new DrSlump\Protobuf\Codec\Json();
} return $codec->encode(getTripUpdates($filter_class, $filter_id));
} }
?>  
&