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                     NSGetSyncInfo(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     (void)adapter;\r
 402     (void)remote_address;\r
 403 \r
 404     NS_LOG(DEBUG, "NSProviderConnectionStateListener - IN");\r
 405 \r
 406     if (connected)\r
 407     {\r
 408         NS_LOG(DEBUG, "CONNECTED");\r
 409 \r
 410         // Set Connection State\r
 411         NSSetProviderConnectionState(CONNECTED);\r
 412 \r
 413         // Start Presence\r
 414         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
 415 \r
 416         if(adapter == CA_ADAPTER_TCP)\r
 417         {\r
 418             NS_LOG_V(DEBUG, "TCP Connected remote address: %s", remote_address);\r
 419         }\r
 420     }\r
 421     else\r
 422     {\r
 423 \r
 424         NS_LOG(DEBUG, "DISCONNECTED");\r
 425 \r
 426         // Set Connection State\r
 427         NSSetProviderConnectionState(DISCONNECTED);\r
 428 \r
 429         if(adapter == CA_ADAPTER_TCP)\r
 430         {\r
 431             NS_LOG_V(DEBUG, "TCP Disconnected remote address: %s", remote_address);\r
 432         }\r
 433     }\r
 434 \r
 435     NS_LOG(DEBUG, "NSProviderConnectionStateListener - OUT");\r
 436 }\r
 437 \r
 438 void NSProviderAdapterStateListener(CATransportAdapter_t adapter, bool enabled)\r
 439 {\r
 440     (void)adapter;\r
 441 \r
 442     NS_LOG(DEBUG, "NSProviderAdapterStateListener - IN");\r
 443 \r
 444     if (enabled)\r
 445     {\r
 446         NS_LOG(DEBUG, "CONNECTED");\r
 447 \r
 448         // Set Connection State\r
 449         NSSetProviderConnectionState(CONNECTED);\r
 450 \r
 451         // Start Presence\r
 452         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
 453     }\r
 454     else\r
 455     {\r
 456 \r
 457         NS_LOG(DEBUG, "DISCONNECTED");\r
 458 \r
 459         // Set Connection State\r
 460         NSSetProviderConnectionState(DISCONNECTED);\r
 461     }\r
 462 \r
 463     NS_LOG(DEBUG, "NSProviderAdapterStateListener - OUT");\r
 464 }\r
 465 \r