Merge pull request #364 from tdt/development

Development

Author: coreation

app/Tdt/Core/DataControllers/CSVController.php

@@ -181,7 +181,7 @@ private function createValues($columns, $data)
 
         foreach ($columns as $column) {
             if (!empty($data[$column['index']]) || is_numeric(@$data[$column['index']])) {
-                $result[$column['column_name_alias']] = @$data[$column['index']];
+                $result[$column['column_name_alias']] = \ForceUTF8\Encoding::fixUTF8(@$data[$column['index']]);
             } else {
                 $index = $column['index'];
 

app/Tdt/Core/DataControllers/JSONController.php

@@ -100,22 +100,60 @@ private function getPlainJson($uri)
         }
 
         if (!filter_var($uri, FILTER_VALIDATE_URL) === false) {
-            $ch = curl_init();
-            curl_setopt($ch, CURLOPT_URL, $uri);
-            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-            $data = curl_exec($ch);
-            curl_close($ch);
+            $parts = parse_url($uri);
+            if ($parts['scheme'] != 'file') {
+                $data = $this->getRemoteData($uri);
+            } else {
+                $data =@ file_get_contents($uri);
+            }
         } else {
             $data =@ file_get_contents($uri);
         }
 
         if ($data) {
             Cache::put($uri, $data, $this->cache);
         } else {
-            $uri = $source_definition['uri'];
             \App::abort(500, "Cannot retrieve data from the JSON file located on $uri.");
         }
 
         return $data;
     }
+
+    private function getRemoteData($url)
+    {
+        $c = curl_init();
+        curl_setopt($c, CURLOPT_URL, $url);
+        curl_setopt($c, CURLOPT_RETURNTRANSFER, 1);
+
+        curl_setopt($c, CURLOPT_SSL_VERIFYHOST, false);
+        curl_setopt($c, CURLOPT_SSL_VERIFYPEER, false);
+        curl_setopt($c, CURLOPT_MAXREDIRS, 10);
+        $follow_allowed= ( ini_get('open_basedir') || ini_get('safe_mode')) ? false:true;
+
+        if ($follow_allowed) {
+            curl_setopt($c, CURLOPT_FOLLOWLOCATION, 1);
+        }
+
+        curl_setopt($c, CURLOPT_CONNECTTIMEOUT, 9);
+        curl_setopt($c, CURLOPT_REFERER, $url);
+        curl_setopt($c, CURLOPT_TIMEOUT, 60);
+        curl_setopt($c, CURLOPT_AUTOREFERER, true);
+        curl_setopt($c, CURLOPT_ENCODING, 'gzip,deflate');
+        $data = curl_exec($c);
+        $status = curl_getinfo($c);
+        curl_close($c);
+
+        preg_match('/(http(|s)):\/\/(.*?)\/(.*\/|)/si', $status['url'], $link);
+        $data = preg_replace('/(src|href|action)=(\'|\")((?!(http|https|javascript:|\/\/|\/)).*?)(\'|\")/si', '$1=$2' . $link[0] . '$3$4$5', $data);
+
+        $data = preg_replace('/(src|href|action)=(\'|\")((?!(http|https|javascript:|\/\/)).*?)(\'|\")/si', '$1=$2' . $link[1] . '://' . $link[3] . '$3$4$5', $data);
+
+        if ($status['http_code'] == 200) {
+            return $data;
+        } elseif ($status['http_code'] == 301 || $status['http_code'] == 302) {
+            \App::abort(400, "The JSON URL redirected us to a different URI.");
+        }
+
+        return $data;
+    }
 }

app/Tdt/Core/DataControllers/XMLController.php

@@ -51,6 +51,7 @@ public function readData($source_definition, $rest_parameters = array())
 
         if (!empty($source_definition['geo_formatted']) && $source_definition['geo_formatted']) {
             $data_result->geo_formatted = true;
+            $data_result->preferred_formats = array('geojson', 'map');
         }
 
         return $data_result;

app/Tdt/Core/Formatters/FormatHelper.php

@@ -45,9 +45,12 @@ public function getAvailableFormats($data)
             $formats['WKT'] = 'wkt';
         } elseif (!empty($data->geo_formatted) && $data->geo_formatted) {
             if (strtolower($source_type) == 'xml') {
+                $formats = array_merge(array('Fullscreen map' => 'map'), $formats);
                 $formats['KML'] = 'kml';
+                $formats['GEOJSON'] = 'geojson';
                 unset($formats['XML']);
             } elseif (strtolower($source_type) == 'json' && $data->geo_formatted) {
+                $formats = array_merge(array('Fullscreen map' => 'map'), $formats);
                 $formats['GeoJSON'] = 'geojson';
                 unset($formats['JSON']);
             }

app/Tdt/Core/Formatters/GEOJSONFormatter.php

@@ -29,8 +29,13 @@ public static function createResponse($dataObj)
     public static function getBody($dataObj)
     {
         // Check if the original data is not GeoJSON
-        if ($dataObj->source_definition['type'] == 'JSON' && !empty($dataObj->geo_formatted) && $dataObj->geo_formatted) {
-            return json_encode($dataObj->data);
+        if (!empty($dataObj->geo_formatted) && $dataObj->geo_formatted) {
+            if ($dataObj->source_definition['type'] == 'JSON') {
+                return json_encode($dataObj->data);
+            } elseif ($dataObj->source_definition['type'] == 'XML') {
+                $geom = \geoPHP::load($dataObj->data, 'kml');
+                return $geom->out('json');
+            }
         }
 
         // Build the body

app/Tdt/Core/Formatters/JSONFormatter.php

@@ -26,10 +26,8 @@ public static function createResponse($dataObj)
 
     public static function getBody($dataObj)
     {
-
         // If the data is semantic, return json ld
         if ($dataObj->is_semantic) {
-
             $jsonld_formatter = new JSONLDFormatter();
 
             return $jsonld_formatter->getBody($dataObj);
@@ -42,7 +40,6 @@ public static function getBody($dataObj)
         }
 
         if ($dataObj->is_semantic) {
-
             // Check if a configuration is given
             $conf = array();
             if (!empty($dataObj->semantic->conf)) {

composer.json

@@ -29,7 +29,8 @@
         "muka/shape-reader" : "dev-master",
         "elasticsearch/elasticsearch": "1.4.1",
         "nesbot/carbon": "~1.14",
-        "tdt/input" : "2.0.*"
+        "tdt/input" : "2.0.*",
+        "phayes/geophp" : "dev-master"
     },
     "require-dev": {
         "mockery/mockery": "dev-master@dev"