app/Http/Business/Cameras/Trendnet/TVIP311PI.php

@@ -44,11 +44,15 @@ class TVIP311PI extends AbstractCamera
             $this->_client->request('GET', $this->_url);
         } catch (RequestException $e) {
             $response = $e->getResponse();
-            if ($response->getStatusCode() == 401) {
+            if ($response != null && $response->getStatusCode() == 401) {
                 $nonce = array();
                 preg_match("/nonce=\"([a-f0-9]+)\"/", $response->getHeader("WWW-Authenticate")[0], $nonce);
                 $nonce = $nonce[1];
             }
+            else {
+              LuLog::log($e);
+            }
+
         } catch (\Exception $e) {
             LuLog::log($e);
         }
@@ -65,7 +69,7 @@ class TVIP311PI extends AbstractCamera
                 "Connection: close\r\n".
                 "Accept: */*\r\n\r\n");
             $data = "";
-            while(substr_count($data, "--boundarySample") < 2 && socket_recv($sock, $buf, 1024, 0) && strlen($data) < 35000)
+            while(substr_count($data, "--boundarySample") < 2 && socket_recv($sock, $buf, 1024, 0) && strlen($data) < 50000)
                 $data .= $buf;
             socket_close($sock);
             if(substr_count($data, "--boundarySample") >= 2)

app/Http/Business/Commands/HttpRequestCommand.php

@@ -22,8 +22,8 @@ class HttpRequestCommand extends AbstractCommand
     {
         $data = $this->_command->getData();
         $url = $data["Url"];
-        $method = $data["Method"];
-        $options = $data["Options"];
+        $method = isset($data["Method"]) ? $data["Method"] : "POST";
+        $options = isset($data["Options"]) ? $data["Options"] : array();
 
         $client = new Client();
 

app/Http/Business/Sensors/HttpRequestSensor.php

@@ -0,0 +1,95 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: robin
+ * Date: 11/24/15
+ * Time: 12:49 AM
+ */
+
+namespace App\Http\Business\Sensors;
+
+use App\Http\DBO\SensorsValueDbo;
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\ClientException;
+use GuzzleHttp\Exception\RequestException;
+use Luticate\Utils\LuLog;
+
+class HttpRequestSensor extends AbstractSensor
+{
+    /**
+     * {
+     *    "Url": "https://example.com/sensor"
+     *    "Method": "GET|POST|PUT|...",
+     *    "Options": {
+     *    },
+     *    "Mapping": {
+     *       "Values": {
+     *          "ON": 1,
+     *          "OFF": 0
+     *       },
+     *       "ValuesDefault": 0
+     *    }
+     * }
+     *
+     */
+    protected function map($value, $mapping)
+    {
+        $default = isset($mapping["ValuesDefault"]) ? $mapping["ValuesDefault"] : $value;
+
+        $values = isset($mapping["Values"]) ? $mapping["Values"] : array();
+        if (isset($values[$value]))
+        {
+            return $values[$value];
+        }
+        else
+        {
+            return $default;
+        }
+    }
+
+    /**
+     * @return SensorsValueDbo
+     */
+    public function getValue()
+    {
+        $data = $this->_sensor->getData();
+        $url = $data["Url"];
+        $method = isset($data["Method"]) ? $data["Method"] : "GET";
+        $options = isset($data["Options"]) ? $data["Options"] : array();
+
+        $client = new Client();
+
+        try {
+            $response = $client->request($method, $url, $options);
+        } catch (ClientException $e) {
+            $response = $e->getResponse();
+            if (!is_null($response)) {
+                LuLog::log($response->getBody());
+            }
+            LuLog::log($e);
+            abort(500, "Failed to execute request (client)");
+        } catch (RequestException $e) {
+            $response = $e->getResponse();
+            if (!is_null($response)) {
+                LuLog::log($response->getBody());
+            }
+            LuLog::log($e);
+            abort(500, "Failed to execute request (request)");
+        } catch (\Exception $e) {
+            LuLog::log($e);
+            abort(500, "Failed to execute request (unknown)");
+        }
+
+        if ($response->getStatusCode() != 200)
+        {
+            abort(500, "Failed to execute request (" . $response->getStatusCode() . ")");
+        }
+
+        $mapping = isset($data["Mapping"]) ? $data["Mapping"] : array();
+
+        $value = new SensorsValueDbo();
+        $value->setValue($this->map((string) $response->getBody(), $mapping));
+
+        return $value;
+    }
+}