From 3dfe9df628263ad03fe064546e8333c49128b7ec Mon Sep 17 00:00:00 2001
From: Jon Atkins <github@jonatkins.com>
Date: Sat, 7 Jun 2014 22:29:45 +0100
Subject: [PATCH] website plugin rpc: add cacheing - processing the data could
 be slow also reduce the amount of data in the bus routes list - no bounding
 box or end stop. it's enough to identify routes, and much faster

---
 website/plugin-rpc/tfl/index.php | 55 ++++++++++++++++++++++++++------
 1 file changed, 45 insertions(+), 10 deletions(-)

diff --git a/website/plugin-rpc/tfl/index.php b/website/plugin-rpc/tfl/index.php
index c8f13671..60fd299c 100644
--- a/website/plugin-rpc/tfl/index.php
+++ b/website/plugin-rpc/tfl/index.php
@@ -2,6 +2,8 @@
 
 include "phpcoord/phpcoord-2.3.php";
 
+$cachedir = "/dev/shm";
+
 header("Content-Type: text/plain");
 
 function load_csv_callback($filename,$callback) {
@@ -101,33 +103,66 @@ class Stops {
 
 };
 
-$result = Array();
+
+function cache_file_ok($cachefile,$datafile) {
+  if ( file_exists($cachefile) ) {
+    $cachetime = filemtime($cachefile);
+
+    // the file is downloaded with 'wget' - this preserves server timestamps, so 'wrong' from a cache point of view
+    $datatime = max (filemtime($datafile), filectime($datafile));
+
+    if ($cachetime > $datatime) {
+      return TRUE;
+    }
+  }
+  return FALSE;
+}
+
+$result = NULL;
 
 switch ($_REQUEST['method']) {
 
   case 'bus-routes':
-    $routes = new Routes();
+    $cachefile = "$cachedir/iitc-rpc-bus-routes.json";
 
-    load_csv_callback("bus-sequences.csv", Array($routes,'add_route'));
+    if ( cache_file_ok($cachefile,"bus-sequences.csv") ) {
+      $result = file_get_contents($cachefile);
+    } else {
+      $routes = new Routes();
 
-    $result = Array('bus-routes'=>$routes->routes);
+      load_csv_callback("bus-sequences.csv", Array($routes,'add_route'));
 
+      $result = json_encode(Array('bus-routes'=>$routes->routes));
+
+      $tmpfile = tempnam($cachedir,"iitc-rpc");
+      file_put_contents($tmpfile,$result) && rename($tmpfile, $cachefile);
+    }
     break;
 
   case 'bus-stops':
     $route = $_REQUEST['route'];
     $run = (int)$_REQUEST['run'];
-    $stops = new Stops();
-    $stops->route_run($route, $run);
 
-    load_csv_callback("bus-sequences.csv", Array($stops,'add_stop'));
+    $cachefile = "$cachedir/iitc-rpc-bus-stops-$route-$run.json";
 
-    $result = Array('route' => $route, 'run' => $run, 'stops' => $stops->stops);
+    if ( cache_file_ok($cachefile,"bus-sequences.csv") ) {
+      $result = file_get_contents($cachefile);
+    } else {
 
+      $stops = new Stops();
+      $stops->route_run($route, $run);
+
+      load_csv_callback("bus-sequences.csv", Array($stops,'add_stop'));
+
+      $result = json_encode(Array('route' => $route, 'run' => $run, 'stops' => $stops->stops));
+
+      $tmpfile = tempnam($cachedir,"iitc-rpc");
+      file_put_contents($tmpfile,$result) && rename($tmpfile, $cachefile);
+    }
     break;
 
   default:
-    $result = Array('error'=>'Method not found');
+    $result = json_encode(Array('error'=>'Method not found'));
     break;
 }
 
@@ -141,7 +176,7 @@ else
 if (isset($_REQUEST['jsonp']))
   print($_REQUEST['jsonp']."(");
 
-print json_encode($result);
+print $result;
 
 if (isset($_REQUEST['jsonp']))
   print(");");