The last examples converted to 1.4.

libraries/MySensors/examples/WaterMeterPulseSensor/WaterMeterPulseSensor.ino

@@ -8,15 +8,10 @@
 // sleepmode. So we cannot make this sensor sleep if we also want  
 // to calculate/report flow.
 //
-// Sensor on pin 3
 
-
-#include <Relay.h>
-#include <Sleep_n0m1.h>
 #include <SPI.h>
-#include <EEPROM.h>  
 #include <RF24.h>
-#include <Sensor.h>  
+#include <MySensor.h>  
 
 #define DIGITAL_INPUT_SENSOR 3                  // The digital input you attached your sensor.  (Only 2 and 3 generates interrupt!)
 #define PULSE_FACTOR 1000                       // Nummber of blinks per m3 of your meter (One rotation/liter)
@@ -26,14 +21,14 @@
 #define CHILD_ID 5                              // Id of the sensor child
 unsigned long SEND_FREQUENCY = 20;              // Minimum time between send (in seconds). We don't want to spam the gateway.
 
-Sensor gw;
-Sleep sleep;                         
+MySensor gw;
  
 double ppl = ((double)PULSE_FACTOR)/1000;        // Pulses per liter
 
 volatile unsigned long pulseCount = 0;   
 volatile unsigned long lastBlink = 0;
-volatile double flow = 0;   
+volatile double flow = 0;  
+boolean pcReceived = false;
 unsigned long oldPulseCount = 0;
 unsigned long newBlink = 0;   
 double oldflow = 0;
@@ -43,21 +38,24 @@ unsigned long lastSend;
 unsigned long lastPulse;
 unsigned long currentTime;
 boolean metric;
+MyMessage flowMsg(CHILD_ID,V_FLOW);
+MyMessage volumeMsg(CHILD_ID,V_VOLUME);
+MyMessage pcMsg(CHILD_ID,V_VAR1);
+
 
 void setup()  
 {  
-  gw.begin(); 
+  gw.begin(incomingMessage); 
 
   // Send the sketch version information to the gateway and Controller
   gw.sendSketchInfo("Water Meter", "1.0");
 
   // Register this device as Waterflow sensor
-  gw.sendSensorPresentation(CHILD_ID, S_WATER);       
+  gw.present(CHILD_ID, S_WATER);       
 
   // Fetch last known pulse count value from gw
-  pulseCount = oldPulseCount = atol(gw.getStatus(CHILD_ID, V_VAR1));
-  //Serial.print("Last pulse count from gw:");
-  //Serial.println(pulseCount);
+  gw.request(CHILD_ID, V_VAR1);
+
   attachInterrupt(INTERRUPT, onPulse, RISING);
   lastSend = millis();
 }
@@ -65,16 +63,18 @@ void setup()
 
 void loop()     
 { 
-    currentTime = millis();
+  gw.process();
+  currentTime = millis();
 	
     // Only send values at a maximum frequency or woken up from sleep
-  if (SLEEP_MODE || currentTime - lastSend > 1000*SEND_FREQUENCY) {
+  bool sendTime = currentTime - lastSend > 1000*SEND_FREQUENCY;
+  if (pcReceived && (SLEEP_MODE || sendTime)) {
     // New flow value has been calculated  
     if (!SLEEP_MODE && flow != oldflow) {
       // Check that we dont get unresonable large flow value. 
       // could hapen when long wraps or false interrupt triggered
       if (flow<((unsigned long)MAX_FLOW)) {
-        gw.sendVariable(CHILD_ID, V_FLOW, flow, 2);                   // Send flow value to gw
+        gw.send(flowMsg.set(flow, 2));                   // Send flow value to gw
       }  
       //Serial.print("l/min:");
       //Serial.println(flow);
@@ -82,39 +82,39 @@ void loop()
     }
   
     // No Pulse count in 2min 
-	
-	//Serial.print("currentTime");
-	//Serial.println(currentTime);
-	//Serial.print("lastPulse");
-	//Serial.println(lastPulse);
- 
     if(currentTime - lastPulse > 120000){
-		flow = 0;
-	} 
+      flow = 0;
+    } 
   
   
     // Pulse count has changed
     if (pulseCount != oldPulseCount) {
-      gw.sendVariable(CHILD_ID, V_VAR1, pulseCount);                  // Send  volumevalue to gw VAR1
+      gw.send(pcMsg.set(pulseCount));                  // Send  volumevalue to gw VAR1
       double volume = ((double)pulseCount/((double)PULSE_FACTOR));     
       oldPulseCount = pulseCount;
-      //Serial.print("Pulse count:");
-      //Serial.println(pulseCount);
       if (volume != oldvolume) {
-        gw.sendVariable(CHILD_ID, V_VOLUME, volume, 3);               // Send volume value to gw
-        //Serial.print("m3:");
-        //Serial.println(volume, 3);
+        gw.send(volumeMsg.set(volume, 3));               // Send volume value to gw
         oldvolume = volume;
       } 
     }
     lastSend = currentTime;
+  } else if (sendTime) {
+   // No count received. Try requesting it again
+    gw.request(CHILD_ID, V_VAR1);
   }
   
   if (SLEEP_MODE) {
     delay(300);                                                       //delay to allow serial to fully print before sleep
-    gw.powerDown();
-    sleep.pwrDownMode();                                              //set sleep mode									
-    sleep.sleepDelay(SEND_FREQUENCY * 1000);                          //sleep for: sleepTime
+    gw.sleep(SEND_FREQUENCY * 1000);
+  }
+}
+
+void incomingMessage(MyMessage message) {
+  if (message.type==V_VAR1) {  
+    pulseCount = oldPulseCount = message.getLong();
+    Serial.print("Received last pulse count from gw:");
+    Serial.println(pulseCount);
+    pcReceived = true;
   }
 }
 
@@ -129,10 +129,8 @@ void onPulse()
       // Sometimes we get interrupt on RISING,  500000 = 0.5sek debounce ( max 120 l/min)
       return;   
     }
-    
     flow = (60000000.0 /interval) / ppl;
     lastBlink = newBlink;
-	  //Serial.println(flow, 4);
   }
   pulseCount++; 
 }