user_service_request_event_handler

sunlichao

用户服务请求事件处理程序

1. static int user_service_request_event_handler(const int devid, const char *serviceid, const int serviceid_len,
   
2.         const char *request, const int request_len,
   
3.         char **response, int *response_len)
   
4. {
   
5.     int contrastratio = 0, to_cloud = 0;
   
6.     cJSON *root = NULL, *item_transparency = NULL, *item_from_cloud = NULL;
   
7.     EXAMPLE_TRACE("Service Request Received, Devid: %d, Service ID: %.*s, Payload: %s", devid, serviceid_len,
   
8.                   serviceid,
   
9.                   request);
   
10. 
    
11.     /* Parse Root */
    
12.     root = cJSON_Parse(request);
    
13.     if (root == NULL || !cJSON_IsObject(root)) {
    
14.         EXAMPLE_TRACE("JSON Parse Error");
    
15.         return -1;
    
16.     }
    
17. 
    
18.     if (strlen("Custom") == serviceid_len && memcmp("Custom", serviceid, serviceid_len) == 0) {
    
19.         /* Parse Item */
    
20.         const char *response_fmt = "{"Contrastratio":%d}";
    
21.         item_transparency = cJSON_GetObjectItem(root, "transparency");
    
22.         if (item_transparency == NULL || !cJSON_IsNumber(item_transparency)) {
    
23.             cJSON_Delete(root);
    
24.             return -1;
    
25.         }
    
26.         EXAMPLE_TRACE("transparency: %d", item_transparency->valueint);
    
27.         contrastratio = item_transparency->valueint + 1;
    
28. 
    
29.         /* Send Service Response To Cloud */
    
30.         *response_len = strlen(response_fmt) + 10 + 1;
    
31.         *response = (char *)HAL_Malloc(*response_len);
    
32.         if (*response == NULL) {
    
33.             EXAMPLE_TRACE("Memory Not Enough");
    
34.             return -1;
    
35.         }
    
36.         memset(*response, 0, *response_len);
    
37.         HAL_Snprintf(*response, *response_len, response_fmt, contrastratio);
    
38.         *response_len = strlen(*response);
    
39.     } else if (strlen("SyncService") == serviceid_len && memcmp("SyncService", serviceid, serviceid_len) == 0) {
    
40.         /* Parse Item */
    
41.         const char *response_fmt = "{"ToCloud":%d}";
    
42.         item_from_cloud = cJSON_GetObjectItem(root, "FromCloud");
    
43.         if (item_from_cloud == NULL || !cJSON_IsNumber(item_from_cloud)) {
    
44.             cJSON_Delete(root);
    
45.             return -1;
    
46.         }
    
47.         EXAMPLE_TRACE("FromCloud: %d", item_from_cloud->valueint);
    
48.         to_cloud = item_from_cloud->valueint + 1;
    
49. 
    
50.         /* Send Service Response To Cloud */
    
51.         *response_len = strlen(response_fmt) + 10 + 1;
    
52.         *response = (char *)HAL_Malloc(*response_len);
    
53.         if (*response == NULL) {
    
54.             EXAMPLE_TRACE("Memory Not Enough");
    
55.             return -1;
    
56.         }
    
57.         memset(*response, 0, *response_len);
    
58.         HAL_Snprintf(*response, *response_len, response_fmt, to_cloud);
    
59.         *response_len = strlen(*response);
    
60.     }
    
61.     cJSON_Delete(root);
    
62. 
    
63.     return 0;
    
64. }
    

复制代码