remove not required function and rename the function, const variable.
[platform/upstream/iotivity.git] / service / notification / src / provider / NSProviderListener.c
1 //******************************************************************\r
2 //\r
3 // Copyright 2016 Samsung Electronics All Rights Reserved.\r
4 //\r
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
6 //\r
7 // Licensed under the Apache License, Version 2.0 (the "License");\r
8 // you may not use this file except in compliance with the License.\r
9 // You may obtain a copy of the License at\r
10 //\r
11 //      http://www.apache.org/licenses/LICENSE-2.0\r
12 //\r
13 // Unless required by applicable law or agreed to in writing, software\r
14 // distributed under the License is distributed on an "AS IS" BASIS,\r
15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
16 // See the License for the specific language governing permissions and\r
17 // limitations under the License.\r
18 //\r
19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=\r
20 \r
21 #include "NSProviderListener.h"\r
22 \r
23 OCEntityHandlerResult NSEntityHandlerNotificationCb(OCEntityHandlerFlag flag,\r
24         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
25 {\r
26     NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - IN");\r
27 \r
28     OCEntityHandlerResult ehResult = OC_EH_OK;\r
29     OCEntityHandlerResponse response =\r
30     { 0, 0, OC_EH_ERROR, 0, 0,\r
31     { },\r
32     { 0 }, false };\r
33 \r
34     (void)callback;\r
35 \r
36     // Validate pointer\r
37     if (!entityHandlerRequest)\r
38     {\r
39         NS_LOG(ERROR, "Invalid request pointer");\r
40         return OC_EH_ERROR;\r
41     }\r
42 \r
43     // Initialize certain response fields\r
44     response.numSendVendorSpecificHeaderOptions = 0;\r
45     memset(response.sendVendorSpecificHeaderOptions, 0,\r
46             sizeof response.sendVendorSpecificHeaderOptions);\r
47     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
48     OCRepPayload* payload = NULL;\r
49 \r
50     if (flag & OC_REQUEST_FLAG)\r
51     {\r
52         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
53 \r
54         if (OC_REST_GET == entityHandlerRequest->method)\r
55         {\r
56             NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OC_REST_GET");\r
57 \r
58             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_POLICY,\r
59                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
60             ehResult = OC_EH_OK;\r
61 \r
62         }\r
63         else if (OC_REST_PUT == entityHandlerRequest->method)\r
64         {\r
65             NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OC_REST_PUT");\r
66             ehResult = OC_EH_OK;\r
67         }\r
68         else if (OC_REST_POST == entityHandlerRequest->method)\r
69         {\r
70             NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OC_REST_POST");\r
71             ehResult = OC_EH_OK;\r
72         }\r
73         else if (OC_REST_DELETE == entityHandlerRequest->method)\r
74         {\r
75             NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OC_REST_DELETE");\r
76             ehResult = OC_EH_OK;\r
77         }\r
78         else\r
79         {\r
80             NS_LOG_V (DEBUG, "Received unsupported method %d from client",\r
81                     entityHandlerRequest->method);\r
82             ehResult = OC_EH_OK;\r
83         }\r
84 \r
85         // If the result isn't an error or forbidden, send response\r
86         if (!((ehResult == OC_EH_ERROR) || (ehResult == OC_EH_FORBIDDEN)))\r
87         {\r
88             // Format the response.  Note this requires some info about the request\r
89             response.requestHandle = entityHandlerRequest->requestHandle;\r
90             response.resourceHandle = entityHandlerRequest->resource;\r
91             response.ehResult = ehResult;\r
92             //response.payload = reinterpret_cast<OCPayload*>(payload);\r
93             response.payload = (OCPayload*) payload;\r
94             // Indicate that response is NOT in a persistent buffer\r
95             response.persistentBufferFlag = 0;\r
96 \r
97             // Handle vendor specific options\r
98             if (entityHandlerRequest->rcvdVendorSpecificHeaderOptions\r
99                     && entityHandlerRequest->numRcvdVendorSpecificHeaderOptions)\r
100             {\r
101                 NS_LOG (DEBUG, "Received vendor specific options");\r
102                 uint8_t i = 0;\r
103                 OCHeaderOption * rcvdOptions = entityHandlerRequest->rcvdVendorSpecificHeaderOptions;\r
104                 for (i = 0; i < entityHandlerRequest->numRcvdVendorSpecificHeaderOptions; i++)\r
105                 {\r
106                     if (((OCHeaderOption) rcvdOptions[i]).protocolID == OC_COAP_ID)\r
107                     {\r
108                         OIC_LOG_V(DEBUG, LISTENER_TAG, "Received option with OC_COAP_ID and ID %u with",\r
109                                 ((OCHeaderOption)rcvdOptions[i]).optionID );\r
110 \r
111                         OIC_LOG_BUFFER(DEBUG, LISTENER_TAG, ((OCHeaderOption)rcvdOptions[i]).optionData,\r
112                                 MAX_HEADER_OPTION_DATA_LENGTH);\r
113                     }\r
114                 }\r
115                 OCHeaderOption * sendOptions = response.sendVendorSpecificHeaderOptions;\r
116                 uint8_t option2[] =\r
117                 { 21, 22, 23, 24, 25, 26, 27, 28, 29, 30 };\r
118                 uint8_t option3[] =\r
119                 { 31, 32, 33, 34, 35, 36, 37, 38, 39, 40 };\r
120                 sendOptions[0].protocolID = OC_COAP_ID;\r
121                 sendOptions[0].optionID = 2248;\r
122                 memcpy(sendOptions[0].optionData, option2, sizeof(option2));\r
123                 sendOptions[0].optionLength = 10;\r
124                 sendOptions[1].protocolID = OC_COAP_ID;\r
125                 sendOptions[1].optionID = 2600;\r
126                 memcpy(sendOptions[1].optionData, option3, sizeof(option3));\r
127                 sendOptions[1].optionLength = 10;\r
128                 response.numSendVendorSpecificHeaderOptions = 2;\r
129             }\r
130         }\r
131     }\r
132 \r
133     OCPayloadDestroy(response.payload);\r
134     NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OUT");\r
135     return ehResult;\r
136 }\r
137 \r
138 OCEntityHandlerResult NSEntityHandlerMessageCb(OCEntityHandlerFlag flag,\r
139         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
140 {\r
141     NS_LOG(DEBUG, "NSEntityHandlerMessageCb - IN");\r
142 \r
143     OCEntityHandlerResult ehResult = OC_EH_OK;\r
144     OCEntityHandlerResponse response =\r
145     { 0, 0, OC_EH_ERROR, 0, 0,\r
146     { },\r
147     { 0 }, false };\r
148 \r
149     (void)callback;\r
150 \r
151     // Validate pointer\r
152     if (!entityHandlerRequest)\r
153     {\r
154         NS_LOG (ERROR,"Invalid request pointer");\r
155         return OC_EH_ERROR;\r
156     }\r
157 \r
158     // Initialize certain response fields\r
159     response.numSendVendorSpecificHeaderOptions = 0;\r
160     memset(response.sendVendorSpecificHeaderOptions, 0,\r
161             sizeof response.sendVendorSpecificHeaderOptions);\r
162     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
163     OCRepPayload* payload = NULL;\r
164 \r
165     if (flag & OC_REQUEST_FLAG)\r
166     {\r
167         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
168 \r
169         if (OC_REST_GET == entityHandlerRequest->method)\r
170         {\r
171             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_REST_GET");\r
172             ehResult = OC_EH_OK;\r
173         }\r
174         else if (OC_REST_PUT == entityHandlerRequest->method)\r
175         {\r
176             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_REST_PUT");\r
177             ehResult = OC_EH_OK;\r
178         }\r
179         else if (OC_REST_POST == entityHandlerRequest->method)\r
180         {\r
181             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_REST_POST");\r
182             ehResult = OC_EH_OK;\r
183         }\r
184         else if (OC_REST_DELETE == entityHandlerRequest->method)\r
185         {\r
186             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_REST_DELETE");\r
187             ehResult = OC_EH_OK;\r
188         }\r
189         else\r
190         {\r
191             NS_LOG_V(DEBUG, "Received unsupported method %d from client",\r
192                     entityHandlerRequest->method);\r
193             ehResult = OC_EH_OK;\r
194         }\r
195 \r
196         // If the result isn't an error or forbidden, send response\r
197         if (!((ehResult == OC_EH_ERROR) || (ehResult == OC_EH_FORBIDDEN)))\r
198         {\r
199             // Format the response.  Note this requires some info about the request\r
200             response.requestHandle = entityHandlerRequest->requestHandle;\r
201             response.resourceHandle = entityHandlerRequest->resource;\r
202             response.ehResult = ehResult;\r
203             //response.payload = reinterpret_cast<OCPayload*>(payload);\r
204             response.payload = (OCPayload*) payload;\r
205             // Indicate that response is NOT in a persistent buffer\r
206             response.persistentBufferFlag = 0;\r
207 \r
208             // Handle vendor specific options\r
209             if (entityHandlerRequest->rcvdVendorSpecificHeaderOptions\r
210                     && entityHandlerRequest->numRcvdVendorSpecificHeaderOptions)\r
211             {\r
212                 NS_LOG(DEBUG, "Received vendor specific options");\r
213                 uint8_t i = 0;\r
214                 OCHeaderOption * rcvdOptions = entityHandlerRequest->rcvdVendorSpecificHeaderOptions;\r
215                 for (i = 0; i < entityHandlerRequest->numRcvdVendorSpecificHeaderOptions; i++)\r
216                 {\r
217                     if (((OCHeaderOption) rcvdOptions[i]).protocolID == OC_COAP_ID)\r
218                     {\r
219                         OIC_LOG_V(DEBUG, LISTENER_TAG, "Received option with OC_COAP_ID and ID %u with",\r
220                                 ((OCHeaderOption)rcvdOptions[i]).optionID );\r
221 \r
222                         OIC_LOG_BUFFER(DEBUG, LISTENER_TAG, ((OCHeaderOption)rcvdOptions[i]).optionData,\r
223                                 MAX_HEADER_OPTION_DATA_LENGTH);\r
224                     }\r
225                 }\r
226                 OCHeaderOption * sendOptions = response.sendVendorSpecificHeaderOptions;\r
227                 uint8_t option2[] =\r
228                 { 21, 22, 23, 24, 25, 26, 27, 28, 29, 30 };\r
229                 uint8_t option3[] =\r
230                 { 31, 32, 33, 34, 35, 36, 37, 38, 39, 40 };\r
231                 sendOptions[0].protocolID = OC_COAP_ID;\r
232                 sendOptions[0].optionID = 2248;\r
233                 memcpy(sendOptions[0].optionData, option2, sizeof(option2));\r
234                 sendOptions[0].optionLength = 10;\r
235                 sendOptions[1].protocolID = OC_COAP_ID;\r
236                 sendOptions[1].optionID = 2600;\r
237                 memcpy(sendOptions[1].optionData, option3, sizeof(option3));\r
238                 sendOptions[1].optionLength = 10;\r
239                 response.numSendVendorSpecificHeaderOptions = 2;\r
240             }\r
241         }\r
242     }\r
243 \r
244     if (flag & OC_OBSERVE_FLAG)\r
245     {\r
246         NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_OBSERVE_FLAG");\r
247 \r
248         if (OC_OBSERVE_REGISTER == entityHandlerRequest->obsInfo.action)\r
249         {\r
250             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_OBSERVE_REGISTER");\r
251             NS_LOG_V(DEBUG, "NSEntityHandlerMessageCb\n"\r
252                     "Register message observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
253             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_RECV_SUBSCRIPTION,\r
254                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
255         }\r
256     }\r
257 \r
258     OCPayloadDestroy(response.payload);\r
259     NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OUT");\r
260     return ehResult;\r
261 }\r
262 \r
263 OCEntityHandlerResult NSEntityHandlerSyncCb(OCEntityHandlerFlag flag,\r
264         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
265 {\r
266     NS_LOG(DEBUG, "NSEntityHandlerSyncCb - IN");\r
267     OCEntityHandlerResult ehResult = OC_EH_OK;\r
268     OCEntityHandlerResponse response =\r
269     { 0, 0, OC_EH_ERROR, 0, 0,\r
270     { },\r
271     { 0 }, false };\r
272 \r
273     (void)callback;\r
274 \r
275     // Validate pointer\r
276     if (!entityHandlerRequest)\r
277     {\r
278         NS_LOG(ERROR, "Invalid request pointer");\r
279         return OC_EH_ERROR;\r
280     }\r
281 \r
282     // Initialize certain response fields\r
283     response.numSendVendorSpecificHeaderOptions = 0;\r
284     memset(response.sendVendorSpecificHeaderOptions, 0,\r
285             sizeof response.sendVendorSpecificHeaderOptions);\r
286     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
287     OCRepPayload* payload = NULL;\r
288 \r
289     if (flag & OC_REQUEST_FLAG)\r
290     {\r
291         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
292 \r
293         if (OC_REST_GET == entityHandlerRequest->method)\r
294         {\r
295             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_REST_GET");\r
296             ehResult = OC_EH_OK;\r
297         }\r
298         else if (OC_REST_PUT == entityHandlerRequest->method)\r
299         {\r
300             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_REST_PUT");\r
301             ehResult = OC_EH_OK;\r
302         }\r
303         else if (OC_REST_POST == entityHandlerRequest->method)\r
304         {\r
305             /** Receive sync data from consumer which read or dismiss notification message.\r
306                            And broadcast the sync data to all subscribers including provider app\r
307                            to synchronize the notification message status. */\r
308 \r
309             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_REST_POST");\r
310 \r
311             NSPushQueue(NOTIFICATION_SCHEDULER, TASK_RECV_READ,\r
312                     NSBuildOICNotificationSync(entityHandlerRequest->payload));\r
313             ehResult = OC_EH_OK;\r
314         }\r
315         else if (OC_REST_DELETE == entityHandlerRequest->method)\r
316         {\r
317             NS_LOG(DEBUG, "Received OC_REST_DELETE from client");\r
318             ehResult = OC_EH_OK;\r
319         }\r
320         else\r
321         {\r
322             NS_LOG_V(DEBUG, "Received unsupported method %d from client",\r
323                     entityHandlerRequest->method);\r
324             ehResult = OC_EH_OK;\r
325         }\r
326 \r
327         // If the result isn't an error or forbidden, send response\r
328         if (!((ehResult == OC_EH_ERROR) || (ehResult == OC_EH_FORBIDDEN)))\r
329         {\r
330             // Format the response.  Note this requires some info about the request\r
331             response.requestHandle = entityHandlerRequest->requestHandle;\r
332             response.resourceHandle = entityHandlerRequest->resource;\r
333             response.ehResult = ehResult;\r
334             //response.payload = reinterpret_cast<OCPayload*>(payload);\r
335             response.payload = (OCPayload*) payload;\r
336             // Indicate that response is NOT in a persistent buffer\r
337             response.persistentBufferFlag = 0;\r
338 \r
339             // Handle vendor specific options\r
340             if (entityHandlerRequest->rcvdVendorSpecificHeaderOptions\r
341                     && entityHandlerRequest->numRcvdVendorSpecificHeaderOptions)\r
342             {\r
343                 NS_LOG(DEBUG, "Received vendor specific options");\r
344                 uint8_t i = 0;\r
345                 OCHeaderOption * rcvdOptions = entityHandlerRequest->rcvdVendorSpecificHeaderOptions;\r
346                 for (i = 0; i < entityHandlerRequest->numRcvdVendorSpecificHeaderOptions; i++)\r
347                 {\r
348                     if (((OCHeaderOption) rcvdOptions[i]).protocolID == OC_COAP_ID)\r
349                     {\r
350                         OIC_LOG_V(DEBUG, LISTENER_TAG, "Received option with OC_COAP_ID and ID %u with",\r
351                                 ((OCHeaderOption)rcvdOptions[i]).optionID );\r
352 \r
353                         OIC_LOG_BUFFER(DEBUG, LISTENER_TAG, ((OCHeaderOption)rcvdOptions[i]).optionData,\r
354                                 MAX_HEADER_OPTION_DATA_LENGTH);\r
355                     }\r
356                 }\r
357                 OCHeaderOption * sendOptions = response.sendVendorSpecificHeaderOptions;\r
358                 uint8_t option2[] =\r
359                 { 21, 22, 23, 24, 25, 26, 27, 28, 29, 30 };\r
360                 uint8_t option3[] =\r
361                 { 31, 32, 33, 34, 35, 36, 37, 38, 39, 40 };\r
362                 sendOptions[0].protocolID = OC_COAP_ID;\r
363                 sendOptions[0].optionID = 2248;\r
364                 memcpy(sendOptions[0].optionData, option2, sizeof(option2));\r
365                 sendOptions[0].optionLength = 10;\r
366                 sendOptions[1].protocolID = OC_COAP_ID;\r
367                 sendOptions[1].optionID = 2600;\r
368                 memcpy(sendOptions[1].optionData, option3, sizeof(option3));\r
369                 sendOptions[1].optionLength = 10;\r
370                 response.numSendVendorSpecificHeaderOptions = 2;\r
371             }\r
372         }\r
373     }\r
374 \r
375     if (flag & OC_OBSERVE_FLAG)\r
376     {\r
377         /** Requested by consumers to synchronize notification message status.\r
378             Store the observer IDs to storage or cache */\r
379 \r
380         NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_OBSERVE_FLAG");\r
381 \r
382         if (OC_OBSERVE_REGISTER == entityHandlerRequest->obsInfo.action)\r
383         {\r
384             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_OBSERVE_REGISTER");\r
385             NS_LOG_V(DEBUG, "NSEntityHandlerSyncCb\n - "\r
386                     "Register Sync observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
387             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SYNC_SUBSCRIPTION,\r
388                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
389         }\r
390     }\r
391 \r
392     OCPayloadDestroy(response.payload);\r
393     NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OUT");\r
394     return ehResult;\r
395 }\r
396 \r
397 void NSProviderConnectionStateListener(CATransportAdapter_t adapter, const char *remote_address,\r
398         bool connected)\r
399 {\r
400 \r
401     // should be implementation\r
402     (void)adapter;\r
403     (void)remote_address;\r
404 \r
405     NS_LOG(DEBUG, "NSProviderConnectionStateListener - IN");\r
406 \r
407     if (connected)\r
408     {\r
409         NS_LOG(DEBUG, "CONNECTED");\r
410 \r
411         // Set Connection State\r
412         NSSetProviderConnectionState(CONNECTED);\r
413 \r
414         // Start Presence\r
415         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
416     }\r
417 \r
418     NS_LOG(DEBUG, "NSProviderConnectionStateListener - OUT");\r
419 }\r
420 \r
421 void NSProviderAdapterStateListener(CATransportAdapter_t adapter, bool enabled)\r
422 {\r
423     // should be implementation\r
424     (void)adapter;\r
425 \r
426     NS_LOG(DEBUG, "NSProviderAdapterStateListener - IN");\r
427 \r
428     if (enabled)\r
429     {\r
430         NS_LOG(DEBUG, "CONNECTED");\r
431 \r
432         // Set Connection State\r
433         NSSetProviderConnectionState(CONNECTED);\r
434 \r
435         // Start Presence\r
436         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
437     }\r
438 \r
439     NS_LOG(DEBUG, "NSProviderAdapterStateListener - OUT");\r
440 }\r
441 \r
442 NSSync * NSBuildOICNotificationSync(OCPayload * payload)\r
443 {\r
444     NS_LOG(DEBUG, "NSBuildOICNotificationSync - IN");\r
445 \r
446     if(!payload)\r
447     {\r
448         return NULL;\r
449     }\r
450     NSSync * retSync = (NSSync *)OICMalloc(sizeof(NSSync));\r
451     if (!retSync)\r
452     {\r
453         return NULL;\r
454     }\r
455 \r
456     retSync->mMessageId = NULL;\r
457     retSync->mState = Notification_Read;\r
458 \r
459     OCRepPayload * repPayload = (OCRepPayload *)payload;\r
460     if (!OCRepPayloadGetPropString(repPayload, NS_ATTRIBUTE_ID, &retSync->mMessageId))\r
461     {\r
462         OICFree(retSync);\r
463         return NULL;\r
464     }\r
465     int64_t state;\r
466     if (!OCRepPayloadGetPropInt(repPayload, NS_ATTRIBUTE_STATE, & state))\r
467     {\r
468         OICFree(retSync->mMessageId);\r
469         OICFree(retSync);\r
470         return NULL;\r
471     }\r
472 \r
473     retSync->mState = (NSSyncTypes) state;\r
474 \r
475     NS_LOG_V(DEBUG, "Sync ID : %s", retSync->mMessageId);\r
476     NS_LOG_V(DEBUG, "Sync State : %d", (int) retSync->mState);\r
477 \r
478     NS_LOG(DEBUG, "NSBuildOICNotificationSync - OUT");\r
479 \r
480     return retSync;\r
481 }\r
482 \r