Improved Arduino Ethernet Connectivity.

Added proper support for control dashboards.
Added some syntactic sugar for defining input/output resources.

Author: alvarolb

src/ThingerClient.h

@@ -247,4 +247,30 @@ class ThingerClient : public thinger::thinger {
     size_t out_size_;
 };
 
+/**
+ * Some syntactic sugar for defining input/output resources easily
+ */
+
+void digital_pin(protoson::pson& in, int pin){
+    if(in.is_empty()) in = (bool) digitalRead(pin);
+    else digitalWrite(pin, in ? HIGH : LOW);
+}
+
+void inverted_digital_pin(protoson::pson& in, int pin){
+    if(in.is_empty()) in = !(bool) digitalRead(pin);
+    else digitalWrite(pin, in ? LOW : HIGH);
+}
+
+void analog_pin(protoson::pson& in, int pin){
+    if(in.is_empty()) in = analogRead(pin);
+    else analogWrite(pin, in);
+}
+
+#define digitalPin(PIN) [](pson& in){ digital_pin(in, PIN);}
+#define invertedDigitalPin(PIN) [](pson& in){ inverted_digital_pin(in, PIN);}
+#define analogPin(PIN) [](pson& in){ analog_pin(in, PIN);}
+#define inputValue(value, callback) [](pson& in){ if(in.is_empty()){ in = value; } else{ value = in; callback; } }
+#define outputValue(value) [](pson& out){ out = value; }
+#define servo(servo) [](pson& in){ if(in.is_empty()) in = (int)servo.read(); else servo.write((int)in); }
+
 #endif

src/ThingerEthernet.h

@@ -40,6 +40,7 @@ class ThingerEthernet : public ThingerClient {
 protected:
 
     virtual bool network_connected(){
+        Ethernet.maintain();
         return connected_;
     }
 

src/thinger/thinger.h

@@ -249,6 +249,13 @@ namespace thinger{
                                 response.set_signal_flag(thinger_message::REQUEST_ERROR);
                             }else{
                                 thing_resource->handle_request(request, response);
+                                // stream enabled over a resource input -> notify the current state
+                                if(thing_resource->stream_enabled() && thing_resource->get_io_type()==thinger_resource::pson_in){
+                                    // send normal response
+                                    send_message(response);
+                                    // stream the event to notify the change
+                                    return stream_resource(*thing_resource, thinger_message::STREAM_EVENT);
+                                }
                             }
                         }
                     }