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 bool NSProviderIsSyncAttributes(OCRepPayload * payload);\r
  24 bool NSProviderIsTopicAttributes(OCRepPayload * payload);\r
  25 OCStackResult NSProviderSendResponse(OCEntityHandlerRequest * entityHandlerRequest,\r
  26         OCRepPayload * payload, char * reqInterface, OCEntityHandlerResult ehResult,\r
  27         NSInterfaceType interfaceType, NSResourceType resourceType);\r
  28 \r
  29 OCEntityHandlerResult NSEntityHandlerNotificationCb(OCEntityHandlerFlag flag,\r
  30         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
  31 {\r
  32     NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - IN");\r
  33 \r
  34     OCEntityHandlerResult ehResult = OC_EH_ERROR;\r
  35 \r
  36     (void)callback;\r
  37 \r
  38     if (!entityHandlerRequest)\r
  39     {\r
  40         NS_LOG(ERROR, "Invalid request pointer");\r
  41         return ehResult;\r
  42     }\r
  43 \r
  44     if (flag & OC_REQUEST_FLAG)\r
  45     {\r
  46         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
  47 \r
  48         if (OC_REST_GET == entityHandlerRequest->method)\r
  49         {\r
  50             NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OC_REST_GET");\r
  51 \r
  52             char * copyQuery = OICStrdup(entityHandlerRequest->query);\r
  53             char * reqInterface = NSGetValueFromQuery(copyQuery, NS_QUERY_INTERFACE);\r
  54 \r
  55             if (reqInterface && strcmp(reqInterface, NS_INTERFACE_BASELINE) != 0\r
  56                     && strcmp(reqInterface, NS_INTERFACE_READ) != 0)\r
  57             {\r
  58                 NS_LOG(ERROR, "Invalid interface");\r
  59                 OICFree(copyQuery);\r
  60                 return ehResult;\r
  61             }\r
  62 \r
  63             OICFree(copyQuery);\r
  64             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SEND_POLICY,\r
  65                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
  66 \r
  67             ehResult = OC_EH_OK;\r
  68         }\r
  69         else\r
  70         {\r
  71             NS_LOG_V (DEBUG, "Received method %d from client", entityHandlerRequest->method);\r
  72         }\r
  73     }\r
  74 \r
  75     NS_LOG(DEBUG, "NSEntityHandlerNotificationCb - OUT");\r
  76     return ehResult;\r
  77 }\r
  78 \r
  79 OCEntityHandlerResult NSEntityHandlerMessageCb(OCEntityHandlerFlag flag,\r
  80         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
  81 {\r
  82     NS_LOG(DEBUG, "NSEntityHandlerMessageCb - IN");\r
  83 \r
  84     OCEntityHandlerResult ehResult = OC_EH_ERROR;\r
  85     char * reqInterface = NULL;\r
  86     OCRepPayload * payload = NULL;\r
  87 \r
  88     (void)callback;\r
  89 \r
  90     if (!entityHandlerRequest)\r
  91     {\r
  92         NS_LOG (ERROR,"Invalid request pointer");\r
  93         return ehResult;\r
  94     }\r
  95 \r
  96     if (flag & OC_REQUEST_FLAG)\r
  97     {\r
  98         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
  99         NS_LOG_V(DEBUG, "Received method %d from client", entityHandlerRequest->method);\r
 100 \r
 101         if (OC_REST_GET == entityHandlerRequest->method)\r
 102         {\r
 103             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_REST_GET");\r
 104 \r
 105             char * copyQuery = OICStrdup(entityHandlerRequest->query);\r
 106             reqInterface = OICStrdup(NSGetValueFromQuery(copyQuery, NS_QUERY_INTERFACE));\r
 107             OICFree(copyQuery);\r
 108 \r
 109             if (reqInterface && strcmp(reqInterface, NS_INTERFACE_BASELINE) != 0\r
 110                     && strcmp(reqInterface, NS_INTERFACE_READ) != 0)\r
 111             {\r
 112                 NS_LOG(ERROR, "Invalid interface");\r
 113                 return ehResult;\r
 114             }\r
 115             ehResult = OC_EH_OK;\r
 116         }\r
 117         else\r
 118         {\r
 119             NS_LOG_V (DEBUG, "Received method %d from client", entityHandlerRequest->method);\r
 120         }\r
 121     }\r
 122 \r
 123     if (flag & OC_OBSERVE_FLAG)\r
 124     {\r
 125         NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_OBSERVE_FLAG");\r
 126 \r
 127         OCObserveAction ocObAction = entityHandlerRequest->obsInfo.action;\r
 128 \r
 129         if (ocObAction == OC_OBSERVE_REGISTER)\r
 130         {\r
 131             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_OBSERVE_REGISTER");\r
 132             NS_LOG_V(DEBUG, "NSEntityHandlerMessageCb\n"\r
 133                     "Register message observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
 134 \r
 135             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_RECV_SUBSCRIPTION,\r
 136                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 137             ehResult = OC_EH_OK;\r
 138         }\r
 139         else if(ocObAction == OC_OBSERVE_DEREGISTER)\r
 140         {\r
 141             NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OC_OBSERVE_DEREGISTER");\r
 142             NS_LOG_V(DEBUG, "NSEntityHandlerMessageCb\n - "\r
 143                     "Deregister Message observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
 144             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_RECV_UNSUBSCRIPTION,\r
 145                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 146             ehResult = OC_EH_OK;\r
 147         }\r
 148     }\r
 149 \r
 150     ehResult = NSProviderSendResponse(entityHandlerRequest, payload, reqInterface, ehResult,\r
 151             NS_INTERFACE_TYPE_READ, NS_RESOURCE_MESSAGE);\r
 152     OICFree(reqInterface);\r
 153     NS_LOG(DEBUG, "NSEntityHandlerMessageCb - OUT");\r
 154     return ehResult;\r
 155 }\r
 156 \r
 157 OCEntityHandlerResult NSEntityHandlerSyncCb(OCEntityHandlerFlag flag,\r
 158         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
 159 {\r
 160     NS_LOG(DEBUG, "NSEntityHandlerSyncCb - IN");\r
 161     OCEntityHandlerResult ehResult = OC_EH_ERROR;\r
 162     char * reqInterface = NULL;\r
 163     OCRepPayload * payload = NULL;\r
 164 \r
 165     (void)callback;\r
 166 \r
 167     if (!entityHandlerRequest)\r
 168     {\r
 169         NS_LOG(ERROR, "Invalid request pointer");\r
 170         return ehResult;\r
 171     }\r
 172 \r
 173     if (flag & OC_REQUEST_FLAG)\r
 174     {\r
 175         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
 176 \r
 177         if (OC_REST_GET == entityHandlerRequest->method)\r
 178         {\r
 179 \r
 180             char * copyQuery = OICStrdup(entityHandlerRequest->query);\r
 181             reqInterface = OICStrdup(NSGetValueFromQuery(copyQuery, NS_QUERY_INTERFACE));\r
 182             OICFree(copyQuery);\r
 183 \r
 184             if (reqInterface && strcmp(reqInterface, NS_INTERFACE_BASELINE) != 0\r
 185                     && strcmp(reqInterface, NS_INTERFACE_READWRITE) != 0)\r
 186             {\r
 187                 NS_LOG(ERROR, "Invalid interface");\r
 188                 return ehResult;\r
 189             }\r
 190 \r
 191             ehResult = OC_EH_OK;\r
 192         }\r
 193         else if (OC_REST_POST == entityHandlerRequest->method)\r
 194         {\r
 195             /** Receive sync data from consumer which read or dismiss notification message.\r
 196                 And broadcast the sync data to all subscribers including provider app\r
 197                 to synchronize the notification message status. */\r
 198 \r
 199             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_REST_POST");\r
 200 \r
 201             if(NSProviderIsSyncAttributes((OCRepPayload *)entityHandlerRequest->payload))\r
 202             {\r
 203                 NSPushQueue(NOTIFICATION_SCHEDULER, TASK_RECV_READ,\r
 204                                     NSGetSyncInfo(entityHandlerRequest->payload));\r
 205                 ehResult = OC_EH_OK;\r
 206             }\r
 207         }\r
 208         else\r
 209         {\r
 210             NS_LOG_V(DEBUG, "Received method %d from client", entityHandlerRequest->method);\r
 211         }\r
 212     }\r
 213 \r
 214     if (flag & OC_OBSERVE_FLAG)\r
 215     {\r
 216         /** Requested by consumers to synchronize notification message status.\r
 217             Store the observer IDs to storage or cache */\r
 218 \r
 219         NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_OBSERVE_FLAG");\r
 220 \r
 221         OCObserveAction ocObAction = entityHandlerRequest->obsInfo.action;\r
 222 \r
 223         if (ocObAction == OC_OBSERVE_REGISTER)\r
 224         {\r
 225             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_OBSERVE_REGISTER");\r
 226             NS_LOG_V(DEBUG, "NSEntityHandlerSyncCb\n - "\r
 227                     "Register Sync observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
 228             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_SYNC_SUBSCRIPTION,\r
 229                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 230         }\r
 231         else if(ocObAction == OC_OBSERVE_DEREGISTER)\r
 232         {\r
 233             NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OC_OBSERVE_DEREGISTER");\r
 234             NS_LOG_V(DEBUG, "NSEntityHandlerSyncCb\n - "\r
 235                     "Deregister Sync observerID : %d\n", entityHandlerRequest->obsInfo.obsId);\r
 236             NSPushQueue(SUBSCRIPTION_SCHEDULER, TASK_RECV_UNSUBSCRIPTION,\r
 237                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 238         }\r
 239     }\r
 240 \r
 241     NS_LOG(DEBUG, "NSEntityHandlerSyncCb - OUT");\r
 242 \r
 243     ehResult = NSProviderSendResponse(entityHandlerRequest, payload, reqInterface, ehResult,\r
 244             NS_INTERFACE_TYPE_READ, NS_RESOURCE_MESSAGE);\r
 245     OICFree(reqInterface);\r
 246 \r
 247     return ehResult;\r
 248 }\r
 249 \r
 250 OCEntityHandlerResult NSEntityHandlerTopicCb(OCEntityHandlerFlag flag,\r
 251         OCEntityHandlerRequest *entityHandlerRequest, void* callback)\r
 252 {\r
 253     NS_LOG(DEBUG, "NSEntityHandlerTopicCb - IN");\r
 254     OCEntityHandlerResult ehResult = OC_EH_ERROR;\r
 255     char * reqInterface = NULL;\r
 256     OCRepPayload * payload = NULL;\r
 257 \r
 258     (void)callback;\r
 259 \r
 260     if (!entityHandlerRequest)\r
 261     {\r
 262         NS_LOG(ERROR, "Invalid request pointer");\r
 263         return ehResult;\r
 264     }\r
 265 \r
 266     if (flag & OC_REQUEST_FLAG)\r
 267     {\r
 268         NS_LOG(DEBUG, "Flag includes OC_REQUEST_FLAG");\r
 269 \r
 270         if (OC_REST_GET == entityHandlerRequest->method)\r
 271         {\r
 272             NS_LOG(DEBUG, "NSEntityHandlerTopicCb - OC_REST_GET");\r
 273 \r
 274             char * copyReq = OICStrdup(entityHandlerRequest->query);\r
 275             reqInterface = OICStrdup(NSGetValueFromQuery(copyReq, NS_QUERY_INTERFACE));\r
 276             OICFree(copyReq);\r
 277 \r
 278             if (reqInterface && strcmp(reqInterface, NS_INTERFACE_BASELINE) != 0\r
 279                     && strcmp(reqInterface, NS_INTERFACE_READWRITE) != 0)\r
 280             {\r
 281                 NS_LOG(ERROR, "Invalid interface");\r
 282                 return ehResult;\r
 283             }\r
 284             // send consumer's interesting topic list if consumer id exists\r
 285             // otherwise send  registered topic list\r
 286             NSPushQueue(TOPIC_SCHEDULER, TASK_SEND_TOPICS,\r
 287                     NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 288 \r
 289             ehResult = OC_EH_OK;\r
 290         }\r
 291         else if (OC_REST_POST == entityHandlerRequest->method)\r
 292         {\r
 293             // Receive interesting topic list from consumers\r
 294             // Send topic notice message(id = TOPIC) to the consumer \r
 295             // which requests to post.\r
 296             NS_LOG(DEBUG, "NSEntityHandlerTopicCb - OC_REST_POST");\r
 297             // Accepter is provider. our service is not support sendtopiclist from OC_REST_POST\r
 298             // Accepter is consumer. our service is support sendtopiclist from OC_REST_POST\r
 299             if(NSGetPolicy() == false &&\r
 300                     NSProviderIsTopicAttributes(OCRepPayloadClone((OCRepPayload *)\r
 301                             entityHandlerRequest->payload)))\r
 302             {\r
 303                 NSPushQueue(TOPIC_SCHEDULER, TASK_POST_TOPIC,\r
 304                         NSCopyOCEntityHandlerRequest(entityHandlerRequest));\r
 305                 ehResult = OC_EH_OK;\r
 306             }\r
 307         }\r
 308         else\r
 309         {\r
 310             NS_LOG_V(DEBUG, "Received unsupported method %d from client",\r
 311                     entityHandlerRequest->method);\r
 312             ehResult = OC_EH_ERROR;\r
 313         }\r
 314     }\r
 315 \r
 316     NS_LOG(DEBUG, "NSEntityHandlerTopicCb - OUT");\r
 317     ehResult = NSProviderSendResponse(entityHandlerRequest, payload, reqInterface, ehResult,\r
 318             NS_INTERFACE_TYPE_READWRITE, NS_RESOURCE_TOPIC);\r
 319     OICFree(reqInterface);\r
 320     return ehResult;\r
 321 }\r
 322 \r
 323 void NSProviderConnectionStateListener(const CAEndpoint_t * info, bool connected)\r
 324 {\r
 325     NS_LOG(DEBUG, "NSProviderConnectionStateListener - IN");\r
 326 \r
 327     if (connected)\r
 328     {\r
 329         NS_LOG(DEBUG, "CONNECTED");\r
 330 \r
 331         // Set Connection State\r
 332         NSSetProviderConnectionState(CONNECTED);\r
 333 \r
 334         // Start Presence\r
 335         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
 336 \r
 337         if(info->adapter == CA_ADAPTER_TCP)\r
 338         {\r
 339             NS_LOG_V(DEBUG, "TCP Connected remote address: %s:%d", info->addr, info->port);\r
 340         }\r
 341     }\r
 342     else\r
 343     {\r
 344         NS_LOG(DEBUG, "DISCONNECTED");\r
 345 \r
 346         // Set Connection State\r
 347         NSSetProviderConnectionState(DISCONNECTED);\r
 348 \r
 349         if(info->adapter == CA_ADAPTER_TCP)\r
 350         {\r
 351             NS_LOG_V(DEBUG, "TCP Disconnected remote address: %s:%d", info->addr, info->port);\r
 352         }\r
 353     }\r
 354 \r
 355     NS_LOG(DEBUG, "NSProviderConnectionStateListener - OUT");\r
 356 }\r
 357 \r
 358 void NSProviderAdapterStateListener(CATransportAdapter_t adapter, bool enabled)\r
 359 {\r
 360     (void)adapter;\r
 361 \r
 362     NS_LOG(DEBUG, "NSProviderAdapterStateListener - IN");\r
 363 \r
 364     if (enabled)\r
 365     {\r
 366         NS_LOG(DEBUG, "CONNECTED");\r
 367 \r
 368         // Set Connection State\r
 369         NSSetProviderConnectionState(CONNECTED);\r
 370 \r
 371         // Start Presence\r
 372         NSPushQueue(DISCOVERY_SCHEDULER, TASK_START_PRESENCE, NULL);\r
 373     }\r
 374     else\r
 375     {\r
 376 \r
 377         NS_LOG(DEBUG, "DISCONNECTED");\r
 378 \r
 379         // Set Connection State\r
 380         NSSetProviderConnectionState(DISCONNECTED);\r
 381     }\r
 382 \r
 383     NS_LOG(DEBUG, "NSProviderAdapterStateListener - OUT");\r
 384 }\r
 385 \r
 386 bool NSProviderCompareSyncAttributes(const char * name)\r
 387 {\r
 388     if (!strcmp(name, NS_ATTRIBUTE_MESSAGE_ID) ||\r
 389         !strcmp(name, NS_ATTRIBUTE_PROVIDER_ID) ||\r
 390         !strcmp(name, NS_ATTRIBUTE_STATE))\r
 391     {\r
 392         return true;\r
 393     }\r
 394 \r
 395     return false;\r
 396 }\r
 397 \r
 398 bool NSProviderIsSyncAttributes(OCRepPayload * payload)\r
 399 {\r
 400     NS_LOG(DEBUG, "get extra info");\r
 401 \r
 402     OCRepPayloadValue * curr = payload->values;\r
 403     while(curr)\r
 404     {\r
 405         if (!NSProviderCompareSyncAttributes(curr->name))\r
 406         {\r
 407             return false;\r
 408         }\r
 409         curr = curr->next;\r
 410     }\r
 411 \r
 412     return true;\r
 413 }\r
 414 \r
 415 bool NSProviderCompareTopicAttributes(const char * name)\r
 416 {\r
 417     if (!strcmp(name, NS_ATTRIBUTE_TOPIC_LIST) ||\r
 418         !strcmp(name, NS_ATTRIBUTE_CONSUMER_ID))\r
 419     {\r
 420         return true;\r
 421     }\r
 422 \r
 423     return false;\r
 424 }\r
 425 \r
 426 bool NSProviderCompareSubTopicAttributes(const char * name)\r
 427 {\r
 428     if (!strcmp(name, NS_ATTRIBUTE_TOPIC_NAME) ||\r
 429         !strcmp(name, NS_ATTRIBUTE_TOPIC_SELECTION))\r
 430     {\r
 431         return true;\r
 432     }\r
 433 \r
 434     return false;\r
 435 }\r
 436 \r
 437 bool NSProviderIsTopicAttributes(OCRepPayload * payload)\r
 438 {\r
 439     NS_LOG(DEBUG, "get extra info");\r
 440 \r
 441     OCRepPayloadValue * curr = payload->values;\r
 442     while(curr)\r
 443     {\r
 444         if (!NSProviderCompareTopicAttributes(curr->name))\r
 445         {\r
 446             return false;\r
 447         }\r
 448 \r
 449         if (!strcmp(curr->name, NS_ATTRIBUTE_TOPIC_LIST))\r
 450         {\r
 451             OCRepPayload ** topicListPayload = NULL;\r
 452             OCRepPayloadValue * payloadValue = NULL;\r
 453             payloadValue = NSPayloadFindValue(payload, NS_ATTRIBUTE_TOPIC_LIST);\r
 454             size_t dimensionSize = calcDimTotal(payloadValue->arr.dimensions);\r
 455             size_t dimensions[3] = { dimensionSize, 0, 0 };\r
 456 \r
 457             if (!dimensionSize)\r
 458             {\r
 459                 return false;\r
 460             }\r
 461 \r
 462             OCRepPayloadGetPropObjectArray(payload, NS_ATTRIBUTE_TOPIC_LIST, &topicListPayload,\r
 463                     dimensions);\r
 464 \r
 465             for (int i = 0; i < (int) dimensionSize; i++)\r
 466             {\r
 467                 OCRepPayloadValue * subCurr = topicListPayload[i]->values;\r
 468                 while(subCurr)\r
 469                 {\r
 470                     if (!NSProviderCompareSubTopicAttributes(subCurr->name))\r
 471                     {\r
 472                         for(int j = i; j < (int) dimensionSize; ++j)\r
 473                         {\r
 474                             OCRepPayloadDestroy(topicListPayload[i]);\r
 475                         }\r
 476 \r
 477                         OCRepPayloadDestroy(payload);\r
 478                         return false;\r
 479                     }\r
 480                     subCurr = subCurr->next;\r
 481                 }\r
 482                 OCRepPayloadDestroy(topicListPayload[i]);\r
 483             }\r
 484         }\r
 485         curr = curr->next;\r
 486     }\r
 487 \r
 488     OCRepPayloadDestroy(payload);\r
 489     return true;\r
 490 }\r
 491 \r
 492 OCStackResult NSProviderSendResponse(OCEntityHandlerRequest * entityHandlerRequest,\r
 493         OCRepPayload * payload, char * reqInterface, OCEntityHandlerResult ehResult,\r
 494         NSInterfaceType interfaceType, NSResourceType resourceType)\r
 495 {\r
 496     if (reqInterface && strcmp(reqInterface, NS_INTERFACE_BASELINE) == 0)\r
 497     {\r
 498         payload = OCRepPayloadCreate();\r
 499 \r
 500         if (!payload)\r
 501         {\r
 502             NS_LOG(ERROR, "payload is NULL");\r
 503             return ehResult;\r
 504         }\r
 505 \r
 506         OCResourcePayloadAddStringLL(&payload->interfaces, NS_INTERFACE_BASELINE);\r
 507         interfaceType == NS_INTERFACE_TYPE_READ ?\r
 508                 OCResourcePayloadAddStringLL(&payload->interfaces, NS_INTERFACE_READ)\r
 509                 : OCResourcePayloadAddStringLL(&payload->interfaces, NS_INTERFACE_READWRITE);\r
 510 \r
 511         char * rtStr = NULL;\r
 512         switch (resourceType)\r
 513         {\r
 514             case NS_RESOURCE_MESSAGE:\r
 515                 rtStr = NS_COLLECTION_MESSAGE_TYPE;\r
 516                 break;\r
 517             case NS_RESOURCE_SYNC:\r
 518                 rtStr = NS_COLLECTION_SYNC_TYPE;\r
 519                 break;\r
 520             case NS_RESOURCE_TOPIC:\r
 521                 rtStr = NS_COLLECTION_TOPIC_TYPE;\r
 522                 break;\r
 523             default:\r
 524                 NS_LOG(ERROR, "sendResponseError");\r
 525                 return ehResult;\r
 526         }\r
 527 \r
 528         OCResourcePayloadAddStringLL(&payload->types, rtStr);\r
 529     }\r
 530 \r
 531     if (resourceType == NS_RESOURCE_TOPIC && entityHandlerRequest->method == OC_REST_GET)\r
 532     {\r
 533         OCRepPayloadDestroy(payload);\r
 534         return ehResult;\r
 535     }\r
 536 \r
 537     OCEntityHandlerResponse response;\r
 538     response.numSendVendorSpecificHeaderOptions = 0;\r
 539     memset(response.sendVendorSpecificHeaderOptions, 0,\r
 540             sizeof response.sendVendorSpecificHeaderOptions);\r
 541     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
 542 \r
 543     response.requestHandle = entityHandlerRequest->requestHandle;\r
 544     response.resourceHandle = entityHandlerRequest->resource;\r
 545     response.persistentBufferFlag = 0;\r
 546     response.ehResult = ehResult;\r
 547     response.payload = (OCPayload *) payload;\r
 548 \r
 549     if (OCDoResponse(&response) != OC_STACK_OK)\r
 550     {\r
 551         NS_LOG(ERROR, "Fail to AccessPolicy send response");\r
 552         ehResult = OC_STACK_ERROR;\r
 553     }\r
 554 \r
 555     OCRepPayloadDestroy(payload);\r
 556     return ehResult;\r
 557 }\r