Diff: sensor.txt

Revision:

15:8c473836feba

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/sensor.txt	Tue Aug 06 05:32:43 2019 +0000
@@ -0,0 +1,305 @@
+#include <string>
+void process_rsc(MbedJSONValue &MSG);
+
+bool reg_resp = false;
+
+const char* CSE_ID = "cse01";
+char* AE_ID;
+bool lcl;
+///////////////////////////////////////
+class Request{
+public:
+    int Operation;  
+    string To;
+    string From;
+    string Request_Identifier;
+    int Resource_Type;
+};
+
+///////////////////////////////////////
+
+struct CreateAE
+{
+    string resourceName; 
+    string App_ID; 
+    string pointOfAccess; 
+    bool requestReachability;
+}CAE;
+
+struct CreateCIN
+{
+    string resourceName;                //rn
+    string contentInfo;                 //cnf 
+    string content;                     //con
+}CIN;
+
+struct CreateSub
+{
+    string resourceName;                //rn
+    string notificationURI;             //nu
+    int notificationContentType;        //nct
+    int notificationEventType;          //net
+}CSub;
+/////
+const char* Create_Req(Request R1)
+{
+    MbedJSONValue demo, demo2, demo3, demo4;
+         
+    std::string s;
+    switch(R1.Resource_Type){
+        case 0:
+            break;
+        case 1:
+            break;
+        case 2:
+            demo3["api"] = CAE.App_ID;
+            demo3["rn"] = CAE.resourceName;
+            demo3["rr"] = CAE.requestReachability; 
+            demo2["m2m:ae"] = demo3;
+        break;
+        case 3:
+            demo3["rn"] = CAE.resourceName;
+            demo2["m2m:cnt"] = demo3;
+        break;
+        case 4:
+            demo3["rn"] = CIN.resourceName;
+            demo3["cnf"] = CIN.contentInfo; 
+            demo3["con"] = CIN.content;
+            demo2["m2m:cin"] = demo3;
+        break;
+        case 23:
+            demo4["net"] = CSub.notificationEventType;
+            demo3["enc"] = demo4;                       //enc = eventNotificationCriteria
+            demo3["rn"] = CSub.resourceName;
+            demo3["nu"] = CSub.notificationURI; 
+            demo3["nct"] = CSub.notificationContentType;
+            demo2["m2m:sub"] = demo3;
+        break;
+    }
+    demo["fr"] = R1.From;
+    demo["op"] = R1.Operation;
+    demo["pc"] = demo2;
+    demo["rqi"] = R1.Request_Identifier;
+    demo["to"] = R1.To;
+    demo["ty"] = R1.Resource_Type;
+    demo["lcl"] = lcl;
+    
+    //serialize it into a JSON string
+    s = demo.serialize();
+    printf("\nMSG SIZE: %d\n", s.length());
+    //printf("json: %s\r\n", s.c_str());
+    /*const char* temp = s.c_str();
+    char* temp1;
+    strncpy(temp1, temp, strlen(temp));
+    printf("string in temp1 is %s\n",temp1);
+    return temp1;
+    */
+    return s.c_str();
+}
+/////
+
+void process_msg()
+{
+    MbedJSONValue MSG;
+    //printf("Before Parsing\n");
+    //printf("messageBuffer %s \n", messageBuffer);
+    //MbedJSONValue demo;
+    //const  char * json = "{\"my_array\": [\"demo_string\", 10], \"my_boolean\": true}";
+
+    //parse the previous string and fill the object demo
+    //parse(demo, json);
+    //printf("After Parsing json\n");
+    parse(MSG, messageBuffer); 
+    //bool temp; //Check fot parameters presence
+    //printf("After Parsing\n");
+    ////////////////////////Local Parameter (Additional parameter)//////////////////////
+    if(MSG.hasMember("lcl"))
+    {
+        local = MSG["lcl"].get<bool>();
+        printf("Local: %s\r\n", local? "true" : "false");
+    }
+     
+    ////////////////////////resource Type Parameter (Mendatory parameter)//////////////////////
+    if(MSG.hasMember("rsc"))
+    {
+        rsc = MSG["rsc"].get<int>();
+        printf("Response Status Code: %d\r\n", rsc);
+        Response_Type();
+        printf("Response Status: %s\r\n", response.c_str());
+        process_rsc(MSG);
+        return;
+    }
+    
+    ////////////////////////resource Type Parameter (Mendatory parameter)//////////////////////
+    if(MSG.hasMember("ty"))
+    {
+       ty = MSG["ty"].get<int>();
+       printf("ResourceType: %d\r\n", ty);
+       resource_type();
+       printf("ResourceType: %s\r\n", resourceType.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   }
+    
+    ////////////////////////From parameter (Mendatory parameter[optional for Create AE])//////////
+    if(MSG.hasMember("fr"))
+    {
+       From = MSG["fr"].get<std::string>();
+       printf("From: %s\r\n", From.c_str());
+    }
+    else     {
+    //add Response Status Code for no mendatory parameter BAD_REQUEST 
+    return;  }
+    
+    ////////////////////////Operation Parameter (Mendatory parameter)//////////////////////
+    if(MSG.hasMember("op"))
+    {
+       op = MSG["op"].get<int>();
+       printf("Operation: %d\r\n", op);
+       Operation_Type();
+       printf("Operation: %s\r\n", operation.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;  }
+    
+    ////////////////////////To Parameter (Mendatory parameter)//////////////////////
+    if(MSG.hasMember("to"))
+    {
+       to = MSG["to"].get<std::string>();
+       printf("To: %s\r\n", to.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;  } 
+         
+    ////////////////////////Request Identifier (Mendatory parameter)//////////////////////
+    if(MSG.hasMember("rqi"))
+    {
+       rqi = MSG["rqi"].get<std::string>();
+       printf("Request Identifier: %s\r\n", rqi.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   }        
+    
+    ////////////////////////Response Status Code
+    if(MSG.hasMember("rsc"))
+    {
+       rsc = MSG["rsc"].get<int>();
+       printf("Response Status Code: %d\r\n", rsc);
+       Response_Type();
+       printf("Response Status: %s\r\n", response.c_str());
+    }
+    MbedJSONValue &MSG_1 = MSG["pc"][content]; //content value depends on the resource type e.g. m2m:ae for resource type 2
+    
+    //////////////////////// Resource specific attributes CSE-ID
+    if(MSG_1.hasMember("csi"))
+    {
+       csi = MSG_1["csi"].get<std::string>();
+       printf("CSI: %s\r\n", csi.c_str());
+    }
+       
+    //////////////////////// Resource specific attributes Point of Access
+    if(MSG_1.hasMember("poa"))
+    {
+       poa = MSG_1["poa"].get<std::string>();
+       printf("POA: %s\r\n", poa.c_str());
+    }  
+     
+    /////////////////////// Resource specific attributes CSE Type
+    if(MSG_1.hasMember("cst"))
+    {
+       cst = MSG_1["cst"].get<int>();
+       printf("CSE Type: %d\r\n", cst);
+       CSE_Type();
+       printf("CSE Type: %s\r\n", cseType.c_str());
+    }
+       
+    /////////////////////// Resource specific attributes RequestReachability
+    if(MSG_1.hasMember("rr"))
+    {
+       RequestReachability = MSG_1["rr"].get<bool>();
+       printf("RR: %s\r\n", RequestReachability? "true" : "false");
+    }
+       
+    /////////////////////// Resource specific attributes App-ID
+    if(MSG_1.hasMember("api"))
+    {
+       api = MSG_1["api"].get<std::string>();
+       printf("App-ID: %s\r\n", api.c_str());
+    } 
+    messageBuffer[0] = '\0';
+    // msg[0] = '\0';
+    //MSG.~MbedJSONValue();
+    //MSG_1.~MbedJSONValue();*/
+}
+
+void process_rsc(MbedJSONValue &MSG)
+{
+    if(MSG.hasMember("rqi"))
+    {
+       rqi = MSG["rqi"].get<std::string>();
+       printf("Request Identifier: %s\r\n", rqi.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   }  
+    if(MSG.hasMember("to"))
+    {
+       to = MSG["to"].get<std::string>();
+       printf("To: %s\r\n", to.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   } 
+    if(MSG.hasMember("fr"))
+    {
+       From = MSG["fr"].get<std::string>();
+       printf("From: %s\r\n", From.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   }
+    
+    MbedJSONValue &MSG_1 = MSG["pc"][content];
+    
+    if(MSG_1.hasMember("ty"))
+    {
+        ty = MSG_1["ty"].get<int>();
+        printf("ResourceType: %d\r\n", ty);
+        resource_type();
+        printf("ResourceType: %s\r\n", resourceType.c_str());
+    }
+    else     {
+    //add response code for no mendatory parameter
+    return;   }
+    
+    if(MSG_1.hasMember("rr"))
+    {
+       RequestReachability = MSG_1["rr"].get<bool>();
+       printf("RR: %s\r\n", RequestReachability? "true" : "false");
+    } 
+    if(MSG_1.hasMember("aei"))
+    {
+       aei = MSG_1["aei"].get<std::string>();
+       printf("AE_ID: %s\r\n", aei.c_str());
+    }         
+    if(MSG_1.hasMember("poa"))
+    {
+       poa = MSG_1["poa"].get<std::string>();
+       printf("POA: %s\r\n", poa.c_str());
+    } 
+    if(MSG_1.hasMember("rn"))
+    {
+       rn = MSG_1["rn"].get<std::string>();
+       printf("Resource Name: %s\r\n", rn.c_str());
+    }
+    if(MSG_1.hasMember("api"))
+    {
+       api = MSG_1["api"].get<std::string>();
+       printf("App-ID: %s\r\n", api.c_str());
+    } 
+    return;
+}