LED light control using webifyed ECHONET Light protocol

Dependencies:   EthernetInterface MbedJSONValue WebSocketClient mbed-rtos mbed

Files at this revision

API Documentation at this revision

Comitter:
kaz260
Date:
Thu Nov 29 11:30:40 2012 +0000
Parent:
0:9a6234efda72
Commit message:
bug fix

Changed in this revision

main.cpp Show annotated file Show diff for this revision Revisions of this file
diff -r 9a6234efda72 -r fefc6c8b9864 main.cpp
--- a/main.cpp	Thu Nov 29 00:35:33 2012 +0000
+++ b/main.cpp	Thu Nov 29 11:30:40 2012 +0000
@@ -1,198 +1,197 @@
-//////////////////////////////////////////////////////////
-// Kaz Technology Lab.                                  //
-// 2012.11.29                                           //
-// PROJECT: ECHONET Light over WebSocket                //
-//////////////////////////////////////////////////////////
-
-#include "mbed.h"
-#include "EthernetInterface.h"
-#include "Websocket.h"
-#include "MbedJSONValue.h"
-
-#define BASE_URL "ws://129.60.20.254:8080/ws/sensors/rw"
-
-// illuminance control
-PwmOut ilc(p21);
-
-// response control flag
-int sendFlag = 0;
-
-// transaction ID
-int transactionId = 0;
-
-// Super Class Device Object
-string operatingStatus = "";
-string operatingStatus_prev = "";
-string classCode = "GeneralLighting";
-string instanceCode = "L0001";
-    
-// General Lighing Class Object
-int illuminanceLevel = 100;
-int illuminanceLevel_prev = 100;
-
-int main() {
-    char buf[200];
-    Timer timer;
-    
-    //PWM frequency
-    ilc.period_ms(5); 
-    
-    // setup Ethernet Interface
-    EthernetInterface eth;
-//    eth.init(); //Use DHCP
-    eth.init("192.168.11.21", "255.255.255.0", "192.168.11.254");
-    eth.connect();
-    printf("IP Address is %s\n\r", eth.getIPAddress());
-
-    //WebSocket instance
-    Websocket ws(BASE_URL);
-      
-    //attempt to make a connection 
-    while(! ws.connect()) {
-        printf("cannot connect WebSocket, retrying...\r\n");
-        wait(2);
-    }
-    printf("WebSocket connected!\r\n");
-             
-    //INFO timer
-    timer.start();
-
-    while(true) {
-        MbedJSONValue json_r, json_s;
-        // send INFO
-        if (timer.read() > 10) {   // device sends  INFO every 10 seconds
-            json_s["TransactionID"] = transactionId;
-            json_s["ESV"] = "INFO";
-            json_s["ClassCode"] = classCode;
-            json_s["InstanceCode"] = instanceCode;
-            json_s["OperatingStatus"] = operatingStatus;
-            
-            // power consumption = V * I * duty cycle (in mW)
-            json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
-            transactionId++;
-            
-            printf("json_s: %s\r\n", json_s.serialize());
-            ws.send((char*)json_s.serialize().c_str());
-            timer.reset();
-        }
-        
-        if (ws.read(buf)) {
-            parse(json_r, buf);
-            printf("json: %s\r\n", json_r.serialize());
-
-            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "Get") == 0){
-                if(json_r.hasMember("OperatingStatus")){
-                    json_s["OperatingStatus"] = operatingStatus;
-                }
-                else if(json_r.hasMember("IlluminanceLevel")){
-                    json_s["IlluminanceLevel"] = illuminanceLevel;
-                }
-                else if(json_r.hasMember("PowerConsumption")){
-                    // power consumption = V * I * duty cycle (in mW)
-                    json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
-                }
-                json_s["ESV"] = "Get_Res";
-                sendFlag = 1;
-            }
-
-            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetI") == 0){
-                if(json_r.hasMember("OperatingStatus")){
-                    operatingStatus_prev = operatingStatus;
-                    operatingStatus = json_r["OperatingStatus"].get<std::string>().c_str();
-                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) == 0){
-                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
-                            ilc = illuminanceLevel / 100.0;
-                        }
-                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
-                            ilc = 0.0;
-                        }
-                    }
-                }
-                else if(json_r.hasMember("IlluminanceLevel")){
-                    illuminanceLevel_prev = illuminanceLevel;
-                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
-                    if(illuminanceLevel_prev != illuminanceLevel){
-                        ilc = illuminanceLevel / 100.0;
-                    }        
-                }
-                sendFlag = 0;
-            }
-
-            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetC") == 0){
-                printf("ESV: SetC\r\n");
-                if(json_r.hasMember("OperatingStatus")){
-                    operatingStatus_prev = operatingStatus;
-                    operatingStatus = json_r["OperatingStatus"].get<std::string>();
-                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) != 0){
-                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
-                            printf("operationgStatus --> ON\r\n");
-                            json_s["OperatingStatus"] = "ON";
-                            if(illuminanceLevel_prev == 0) {
-                              illuminanceLevel = 100;
-                              illuminanceLevel_prev = 100;
-                            }
-                            ilc = illuminanceLevel / 100.0;
-                        }
-                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
-                            json_s["OperatingStatus"] = "OFF";
-                            printf("operatingStatus --> OFF\r\n");
-                            ilc = 0.0;
-                        }
-                    }
-                }
-                if(json_r.hasMember("IlluminanceLevel")){
-                    illuminanceLevel_prev = illuminanceLevel;
-                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
-                    if(illuminanceLevel_prev != illuminanceLevel){
-                        printf("illminanceLevel --> %d\r\n", illuminanceLevel);
-                        ilc = illuminanceLevel / 100.0;
-                        json_s["IlluminanceLevel"] = illuminanceLevel;
-                    }        
-                }
-                json_s["ESV"] = "SetC_Res";
-                sendFlag = 1;
-            }
-
-            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetGet") == 0){
-                if(json_r.hasMember("OperatingStatus")){
-                    operatingStatus_prev = operatingStatus;
-                    operatingStatus = json_r["OperatingStatus"].get<std::string>();
-                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) == 0){
-                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
-                            ilc = illuminanceLevel / 100.0;
-                        }
-                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
-                            ilc = 0.0;
-                        }
-                    }
-                }
-                if(json_r.hasMember("IlluminanceLevel")){
-                    illuminanceLevel_prev = illuminanceLevel;
-                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
-                    if(illuminanceLevel_prev != illuminanceLevel){
-                        ilc = illuminanceLevel / 100.0;
-                    }        
-                }
-                json_s["ESV"] = "SetGet_Res";
-                json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
-                sendFlag = 1;
-            }
-
-            if(sendFlag == 1){
-                json_s["TransactionID"] = transactionId;
-                json_s["ClassCode"] = classCode;
-                json_s["InstanceCode"] = instanceCode;
-            
-                printf("json_s: %s\r\n", json_s.serialize());
-                ws.send((char*)json_s.serialize().c_str());
-                sendFlag = 0;
-                transactionId++;
-            }
-        }
-
-        if (! ws.is_connected()) {
-            printf("disconnected\r\n");
-            exit(0);
-        }
-    }
+//////////////////////////////////////////////////////////
+// Kaz Technology Lab.                                  //
+// 2012.11.29                                           //
+// PROJECT: ECHONET Light over WebSocket                //
+//////////////////////////////////////////////////////////
+
+#include "mbed.h"
+#include "EthernetInterface.h"
+#include "Websocket.h"
+#include "MbedJSONValue.h"
+
+#define BASE_URL "ws://129.60.20.254:8080/ws/sensors/rw"
+
+// illuminance control
+PwmOut ilc(p21);
+
+// response control flag
+int sendFlag = 0;
+
+// transaction ID
+int transactionId = 0;
+
+// Super Class Device Object
+string operatingStatus = "";
+string operatingStatus_prev = "";
+string classCode = "GeneralLighting";
+string instanceCode = "L0001";
+    
+// General Lighing Class Object
+int illuminanceLevel = 100;
+int illuminanceLevel_prev = 100;
+
+int main() {
+    char buf[200];
+    Timer timer;
+    MbedJSONValue json_r, json_s;
+    
+    //PWM frequency
+    ilc.period_ms(5); 
+    // setup Ethernet Interface
+    EthernetInterface eth;
+//    eth.init(); //Use DHCP
+    eth.init("192.168.111.21", "255.255.255.0", "192.168.111.1");
+    eth.connect();
+    printf("IP Address is %s\n\r", eth.getIPAddress());
+
+    //WebSocket instance
+    Websocket ws(BASE_URL);
+      
+    //attempt to make a connection 
+    while(! ws.connect()) {
+        printf("cannot connect WebSocket, retrying...\r\n");
+        wait(2);
+    }
+    printf("WebSocket connected!\r\n");
+             
+    //INFO timer
+    timer.start();
+
+    while(true) {
+        // send INFO
+        if (timer.read() > 10) {   // device sends  INFO every 10 seconds
+            json_s["TransactionID"] = transactionId;
+            json_s["ESV"] = "INFO";
+            json_s["ClassCode"] = classCode;
+            json_s["InstanceCode"] = instanceCode;
+            json_s["OperatingStatus"] = operatingStatus;
+            
+            // power consumption = V * I * duty cycle (in mW)
+            json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
+            transactionId++;
+            
+            printf("json_s: %s\r\n", json_s.serialize());
+            ws.send((char*)json_s.serialize().c_str());
+            timer.reset();
+        }
+        
+        if (ws.read(buf)) {
+            parse(json_r, buf);
+            printf("json: %s\r\n", json_r.serialize());
+
+            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "Get") == 0){
+                if(json_r.hasMember("OperatingStatus")){
+                    json_s["OperatingStatus"] = operatingStatus;
+                }
+                else if(json_r.hasMember("IlluminanceLevel")){
+                    json_s["IlluminanceLevel"] = illuminanceLevel;
+                }
+                else if(json_r.hasMember("PowerConsumption")){
+                    // power consumption = V * I * duty cycle (in mW)
+                    json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
+                }
+                json_s["ESV"] = "Get_Res";
+                sendFlag = 1;
+            }
+
+            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetI") == 0){
+                if(json_r.hasMember("OperatingStatus")){
+                    operatingStatus_prev = operatingStatus;
+                    operatingStatus = json_r["OperatingStatus"].get<std::string>().c_str();
+                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) == 0){
+                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
+                            ilc = illuminanceLevel / 100.0;
+                        }
+                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
+                            ilc = 0.0;
+                        }
+                    }
+                }
+                else if(json_r.hasMember("IlluminanceLevel")){
+                    illuminanceLevel_prev = illuminanceLevel;
+                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
+                    if(illuminanceLevel_prev != illuminanceLevel){
+                        ilc = illuminanceLevel / 100.0;
+                    }        
+                }
+                sendFlag = 0;
+            }
+
+            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetC") == 0){
+                printf("ESV: SetC\r\n");
+                if(json_r.hasMember("OperatingStatus")){
+                    operatingStatus_prev = operatingStatus;
+                    operatingStatus = json_r["OperatingStatus"].get<std::string>();
+                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) != 0){
+                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
+                            printf("operationgStatus --> ON\r\n");
+                            json_s["OperatingStatus"] = "ON";
+                            if(illuminanceLevel_prev == 0) {
+                              illuminanceLevel = 100;
+                              illuminanceLevel_prev = 100;
+                            }
+                            ilc = illuminanceLevel / 100.0;
+                        }
+                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
+                            json_s["OperatingStatus"] = "OFF";
+                            printf("operatingStatus --> OFF\r\n");
+                            ilc = 0.0;
+                        }
+                    }
+                }
+                if(json_r.hasMember("IlluminanceLevel")){
+                    illuminanceLevel_prev = illuminanceLevel;
+                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
+                    if(illuminanceLevel_prev != illuminanceLevel){
+                        printf("illminanceLevel --> %d\r\n", illuminanceLevel);
+                        ilc = illuminanceLevel / 100.0;
+                        json_s["IlluminanceLevel"] = illuminanceLevel;
+                    }        
+                }
+                json_s["ESV"] = "SetC_Res";
+                sendFlag = 1;
+            }
+
+            if(strcmp(json_r["ESV"].get<std::string>().c_str(), "SetGet") == 0){
+                if(json_r.hasMember("OperatingStatus")){
+                    operatingStatus_prev = operatingStatus;
+                    operatingStatus = json_r["OperatingStatus"].get<std::string>();
+                    if(strcmp(operatingStatus_prev.c_str(), operatingStatus.c_str()) == 0){
+                        if(strcmp(operatingStatus.c_str(), "ON") == 0){
+                            ilc = illuminanceLevel / 100.0;
+                        }
+                        if(strcmp(operatingStatus.c_str(), "OFF") == 0){
+                            ilc = 0.0;
+                        }
+                    }
+                }
+                if(json_r.hasMember("IlluminanceLevel")){
+                    illuminanceLevel_prev = illuminanceLevel;
+                    illuminanceLevel = json_r["IlluminanceLevel"].get<int>();
+                    if(illuminanceLevel_prev != illuminanceLevel){
+                        ilc = illuminanceLevel / 100.0;
+                    }        
+                }
+                json_s["ESV"] = "SetGet_Res";
+                json_s["PowerConsumption"] = int(12.0 * 40.0 * ilc.read());
+                sendFlag = 1;
+            }
+
+            if(sendFlag == 1){
+                json_s["TransactionID"] = transactionId;
+                json_s["ClassCode"] = classCode;
+                json_s["InstanceCode"] = instanceCode;
+            
+                printf("json_s: %s\r\n", json_s.serialize());
+                ws.send((char*)json_s.serialize().c_str());
+                sendFlag = 0;
+                transactionId++;
+            }
+        }
+
+        if (! ws.is_connected()) {
+            printf("disconnected\r\n");
+            exit(0);
+        }
+    }
 }
\ No newline at end of file