service/notification/src/provider/NSProviderTopic.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 "NSProviderTopic.h"\r
  22 #include "oic_string.h"\r
  23 #include "oic_malloc.h"\r
  24 #include <pthread.h>\r
  25 \r
  26 NSResult NSSendTopicUpdation();\r
  27 \r
  28 NSResult NSInitTopicList()\r
  29 {\r
  30     NS_LOG(DEBUG, "NSInitTopicList - IN");\r
  31     consumerTopicList = NSStorageCreate();\r
  32     consumerTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME;\r
  33 \r
  34     registeredTopicList = NSStorageCreate();\r
  35     registeredTopicList->cacheType = NS_PROVIDER_CACHE_REGISTER_TOPIC;\r
  36 \r
  37     NS_LOG(DEBUG, "NSInitTopicList - OUT");\r
  38     return NS_OK;\r
  39 }\r
  40 \r
  41 size_t NSProviderGetTopicListSize(NSTopicLL * firstElement)\r
  42 {\r
  43     if(!firstElement)\r
  44     {\r
  45         return 0;\r
  46     }\r
  47 \r
  48     int cnt = 0;\r
  49 \r
  50     NSTopicLL * iter = firstElement;\r
  51 \r
  52     while(iter)\r
  53     {\r
  54         cnt++;\r
  55         iter = iter->next;\r
  56     }\r
  57 \r
  58     return cnt;\r
  59 }\r
  60 \r
  61 NSResult NSAddTopics(const char * topicName)\r
  62 {\r
  63     NS_LOG(DEBUG, "NSWriteTopicsToStorage()");\r
  64 \r
  65     NSCacheTopicData * data = (NSCacheTopicData *)OICMalloc(sizeof(NSCacheTopicData));\r
  66     data->topicName = (char *)topicName;\r
  67     data->state = NS_TOPIC_UNSUBSCRIBED;\r
  68 \r
  69     NSCacheElement * element = (NSCacheElement *) OICMalloc(sizeof(NSCacheElement));\r
  70     element->data = (void *) data;\r
  71     element->next = NULL;\r
  72 \r
  73     if(NSStorageWrite(registeredTopicList, element) != NS_OK)\r
  74     {\r
  75         NS_LOG(DEBUG, "fail to write cache");\r
  76         return NS_ERROR;\r
  77     }\r
  78     NSSendTopicUpdation();\r
  79 \r
  80     NS_LOG(DEBUG, "NSWriteTopicsToStorage() NS_OK");\r
  81     return NS_OK;\r
  82 }\r
  83 \r
  84 NSResult NSDeleteTopics(const char * topicName)\r
  85 {\r
  86     NS_LOG(DEBUG, "NSDeleteTopics()");\r
  87 \r
  88     if(!topicName)\r
  89     {\r
  90         NS_LOG(ERROR, "topicName is NULL");\r
  91         return NS_ERROR;\r
  92     }\r
  93 \r
  94     NSStorageDelete(registeredTopicList, topicName);\r
  95     while(NSStorageDelete(consumerTopicList, topicName) != NS_FAIL);\r
  96     return NS_OK;\r
  97 }\r
  98 \r
  99 NSResult NSSendTopicUpdation()\r
 100 {\r
 101     NS_LOG(DEBUG, "NSSendTopicUpdation - IN");\r
 102 \r
 103     OCRepPayload* payload = OCRepPayloadCreate();\r
 104 \r
 105     if (!payload)\r
 106     {\r
 107         NS_LOG(ERROR, "fail to create playload");\r
 108         return NS_ERROR;\r
 109     }\r
 110 \r
 111     OCResourceHandle rHandle = NULL;\r
 112     if (NSPutMessageResource(NULL, &rHandle) != NS_OK)\r
 113     {\r
 114         NS_LOG(ERROR, "Fail to put message resource");\r
 115         return NS_ERROR;\r
 116     }\r
 117 \r
 118     OCRepPayloadSetUri(payload, NS_COLLECTION_MESSAGE_URI);\r
 119     OCRepPayloadSetPropInt(payload, NS_ATTRIBUTE_MESSAGE_ID, NS_TOPIC);\r
 120     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_PROVIDER_ID, NSGetProviderInfo()->providerId);\r
 121 \r
 122     OCObservationId obArray[255] = { 0, };\r
 123     int obCount = 0;\r
 124 \r
 125     NSCacheElement * it = consumerSubList->head;\r
 126 \r
 127     while (it)\r
 128     {\r
 129         NSCacheSubData * subData = (NSCacheSubData *) it->data;\r
 130 \r
 131         if (subData->isWhite)\r
 132         {\r
 133             if(subData->messageObId != 0)\r
 134             {\r
 135                 obArray[obCount++] = subData->messageObId;\r
 136             }\r
 137 \r
 138 #if(defined WITH_CLOUD && defined RD_CLIENT)\r
 139             if(subData->remote_messageObId != 0)\r
 140             {\r
 141                 obArray[obCount++] = subData->remote_messageObId;\r
 142             }\r
 143 #endif\r
 144         }\r
 145         it = it->next;\r
 146     }\r
 147 \r
 148     if(!obCount)\r
 149     {\r
 150         NS_LOG(ERROR, "observer count is zero");\r
 151         return NS_ERROR;\r
 152     }\r
 153 \r
 154     if (OCNotifyListOfObservers(rHandle, obArray, obCount, payload, OC_HIGH_QOS)\r
 155             != OC_STACK_OK)\r
 156     {\r
 157         NS_LOG(ERROR, "fail to send topic updation");\r
 158         OCRepPayloadDestroy(payload);\r
 159         return NS_ERROR;\r
 160 \r
 161     }\r
 162     OCRepPayloadDestroy(payload);\r
 163 \r
 164     NS_LOG(DEBUG, "NSSendTopicUpdation - OUT");\r
 165     return NS_OK;\r
 166 }\r
 167 \r
 168 NSResult NSSendTopicUpdationToConsumer(char *consumerId)\r
 169 {\r
 170     NS_LOG(DEBUG, "NSSendTopicUpdationToConsumer - IN");\r
 171 \r
 172     OCRepPayload* payload = OCRepPayloadCreate();\r
 173 \r
 174     if (!payload)\r
 175     {\r
 176         NS_LOG(ERROR, "fail to create playload");\r
 177         return NS_ERROR;\r
 178     }\r
 179 \r
 180     OCResourceHandle rHandle = NULL;\r
 181     if (NSPutMessageResource(NULL, &rHandle) != NS_OK)\r
 182     {\r
 183         NS_LOG(ERROR, "Fail to put message resource");\r
 184         return NS_ERROR;\r
 185     }\r
 186 \r
 187     OCRepPayloadSetUri(payload, NS_COLLECTION_MESSAGE_URI);\r
 188     OCRepPayloadSetPropInt(payload, NS_ATTRIBUTE_MESSAGE_ID, NS_TOPIC);\r
 189     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_PROVIDER_ID, NSGetProviderInfo()->providerId);\r
 190 \r
 191     NSCacheElement * element = NSStorageRead(consumerSubList, consumerId);\r
 192 \r
 193     if(element == NULL)\r
 194     {\r
 195         NS_LOG(ERROR, "element is NULL");\r
 196         return NS_ERROR;\r
 197     }\r
 198 \r
 199     NSCacheSubData * subData = (NSCacheSubData*) element->data;\r
 200 \r
 201     if (OCNotifyListOfObservers(rHandle, (OCObservationId*)&subData->messageObId, 1, payload,\r
 202             OC_HIGH_QOS) != OC_STACK_OK)\r
 203     {\r
 204         NS_LOG(ERROR, "fail to send topic updation");\r
 205         OCRepPayloadDestroy(payload);\r
 206         return NS_ERROR;\r
 207     }\r
 208 \r
 209     OCRepPayloadDestroy(payload);\r
 210 \r
 211     NS_LOG(DEBUG, "NSSendTopicUpdationToConsumer - OUT");\r
 212     return NS_OK;\r
 213 }\r
 214 \r
 215 NSResult NSSendTopicList(OCEntityHandlerRequest * entityHandlerRequest)\r
 216 {\r
 217     NS_LOG(DEBUG, "NSSendTopicList - IN");\r
 218 \r
 219     char * id = NSGetValueFromQuery(OICStrdup(entityHandlerRequest->query), NS_QUERY_CONSUMER_ID);\r
 220     NSTopicLL * topics = NULL;\r
 221 \r
 222     if(!id)\r
 223     {\r
 224         NS_LOG(DEBUG, "Send registered topic list");\r
 225         topics = NSProviderGetTopicsCacheData(registeredTopicList);\r
 226     }\r
 227     else\r
 228     {\r
 229         NS_LOG(DEBUG, "Send subscribed topic list to consumer");\r
 230         topics = NSProviderGetConsumerTopicsCacheData(registeredTopicList, consumerTopicList, id);\r
 231         if(!topics)\r
 232         {\r
 233             topics = NSProviderGetTopicsCacheData(registeredTopicList);\r
 234         }\r
 235     }\r
 236 \r
 237     // make response for the Get Request\r
 238     OCEntityHandlerResponse response;\r
 239     response.numSendVendorSpecificHeaderOptions = 0;\r
 240     memset(response.sendVendorSpecificHeaderOptions, 0,\r
 241             sizeof response.sendVendorSpecificHeaderOptions);\r
 242     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
 243 \r
 244     OCRepPayload* payload = OCRepPayloadCreate();\r
 245     if (!payload)\r
 246     {\r
 247         NS_LOG(ERROR, "payload is NULL");\r
 248         return NS_ERROR;\r
 249     }\r
 250 \r
 251     OCRepPayloadSetUri(payload, NS_COLLECTION_TOPIC_URI);\r
 252     if(id)\r
 253     {\r
 254         OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_CONSUMER_ID, id);\r
 255     }\r
 256     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_PROVIDER_ID,\r
 257         NSGetProviderInfo()->providerId);\r
 258 \r
 259     if(topics)\r
 260     {\r
 261         NS_LOG(DEBUG, "topicList is NULL");\r
 262         size_t dimensionSize = (size_t)NSProviderGetTopicListSize(topics);\r
 263 \r
 264         NS_LOG_V(DEBUG, "dimensionSize = %d", (int)dimensionSize);\r
 265 \r
 266         if(!dimensionSize)\r
 267         {\r
 268             return NS_ERROR;\r
 269         }\r
 270 \r
 271         OCRepPayload** payloadTopicArray = (OCRepPayload **) OICMalloc(\r
 272                 sizeof(OCRepPayload *) * dimensionSize);\r
 273 \r
 274         size_t dimensions[3] = {dimensionSize, 0, 0};\r
 275 \r
 276         for (int i = 0; i < (int)dimensionSize; i++)\r
 277         {\r
 278             NS_LOG_V(DEBUG, "topicName = %s", topics->topicName);\r
 279             NS_LOG_V(DEBUG, "topicState = %d",(int) topics->state);\r
 280 \r
 281             payloadTopicArray[i] = OCRepPayloadCreate();\r
 282             OCRepPayloadSetPropString(payloadTopicArray[i], NS_ATTRIBUTE_TOPIC_NAME,\r
 283                     topics->topicName);\r
 284             OCRepPayloadSetPropInt(payloadTopicArray[i], NS_ATTRIBUTE_TOPIC_SELECTION,\r
 285                     (int)topics->state);\r
 286 \r
 287             topics = topics->next;\r
 288         }\r
 289 \r
 290 \r
 291         OCRepPayloadSetPropObjectArray(payload, NS_ATTRIBUTE_TOPIC_LIST,\r
 292                 (const OCRepPayload**)(payloadTopicArray), dimensions);\r
 293     }\r
 294     else\r
 295     {\r
 296         size_t dimensions[3] = {0, 0, 0};\r
 297 \r
 298         OCRepPayloadSetPropObjectArrayAsOwner(payload, NS_ATTRIBUTE_TOPIC_LIST,\r
 299                 (OCRepPayload **) NULL, dimensions);\r
 300     }\r
 301 \r
 302     response.requestHandle = entityHandlerRequest->requestHandle;\r
 303     response.resourceHandle = entityHandlerRequest->resource;\r
 304     response.persistentBufferFlag = 0;\r
 305     response.ehResult = OC_EH_OK;\r
 306     response.payload = (OCPayload *) payload;\r
 307 \r
 308     if (OCDoResponse(&response) != OC_STACK_OK)\r
 309     {\r
 310         NS_LOG(ERROR, "Fail to response topic list");\r
 311         return NS_ERROR;\r
 312     }\r
 313     OCRepPayloadDestroy(payload);\r
 314 \r
 315     NS_LOG(DEBUG, "NSSendTopicList - OUT");\r
 316     return NS_OK;\r
 317 }\r
 318 \r
 319 NSResult NSPostConsumerTopics(OCEntityHandlerRequest * entityHandlerRequest)\r
 320 {\r
 321     NS_LOG(DEBUG, "NSPostConsumerTopics() - IN");\r
 322 \r
 323     char * consumerId = NULL;\r
 324     OCRepPayload * payload = (OCRepPayload *) entityHandlerRequest->payload;\r
 325     OCRepPayloadGetPropString(payload, NS_ATTRIBUTE_CONSUMER_ID, &consumerId);\r
 326 \r
 327     if(!consumerId)\r
 328     {\r
 329         NS_LOG(DEBUG, "Invalid consumer ID");\r
 330         return NS_ERROR;\r
 331     }\r
 332 \r
 333     NS_LOG_V(DEBUG, "TOPIC consumer ID = %s", consumerId);\r
 334 \r
 335     consumerTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC_CID;\r
 336     while(NSStorageDelete(consumerTopicList, consumerId) != NS_FAIL);\r
 337     consumerTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC_NAME;\r
 338 \r
 339     OCRepPayload ** topicListPayload = NULL;\r
 340     OCRepPayloadValue * payloadValue = NULL;\r
 341     payloadValue = NSPayloadFindValue(payload, NS_ATTRIBUTE_TOPIC_LIST);\r
 342     size_t dimensionSize = calcDimTotal(payloadValue->arr.dimensions);\r
 343     size_t dimensions[3] = {dimensionSize, 0, 0};\r
 344     OCRepPayloadGetPropObjectArray(payload, NS_ATTRIBUTE_TOPIC_LIST, &topicListPayload, dimensions);\r
 345 \r
 346     for(int i = 0; i <(int)dimensionSize; i++)\r
 347     {\r
 348         char * topicName = NULL;\r
 349         int64_t topicState = 0;\r
 350 \r
 351         OCRepPayloadGetPropString(topicListPayload[i], NS_ATTRIBUTE_TOPIC_NAME, &topicName);\r
 352         OCRepPayloadGetPropInt(topicListPayload[i], NS_ATTRIBUTE_TOPIC_SELECTION, &topicState);\r
 353         NS_LOG_V(DEBUG, "Topic Name(state):  %s(%d)", topicName, (int)topicState);\r
 354 \r
 355         if(NS_TOPIC_SUBSCRIBED == (NSTopicState)topicState)\r
 356         {\r
 357             NSCacheTopicSubData * topicSubData = (NSCacheTopicSubData *)\r
 358                     OICMalloc(sizeof(NSCacheTopicSubData));\r
 359 \r
 360             OICStrcpy(topicSubData->id, NS_UUID_STRING_SIZE, consumerId);\r
 361             topicSubData->topicName = OICStrdup(topicName);\r
 362 \r
 363             NSCacheElement * newObj = (NSCacheElement *) OICMalloc(sizeof(NSCacheElement));\r
 364             newObj->data = (NSCacheData *) topicSubData;\r
 365             newObj->next = NULL;\r
 366 \r
 367             NSStorageWrite(consumerTopicList, newObj);\r
 368         }\r
 369     }\r
 370     NSSendTopicUpdationToConsumer(consumerId);\r
 371 \r
 372     NS_LOG(DEBUG, "NSPostConsumerTopics() - OUT");\r
 373     return NS_OK;\r
 374 }\r
 375 \r
 376 void * NSTopicSchedule(void * ptr)\r
 377 {\r
 378     if (ptr == NULL)\r
 379     {\r
 380         NS_LOG(DEBUG, "Create NSTopicSchedule");\r
 381     }\r
 382 \r
 383     while (NSIsRunning[TOPIC_SCHEDULER])\r
 384     {\r
 385         sem_wait(&NSSemaphore[TOPIC_SCHEDULER]);\r
 386         pthread_mutex_lock(&NSMutex[TOPIC_SCHEDULER]);\r
 387 \r
 388         if (NSHeadMsg[TOPIC_SCHEDULER] != NULL)\r
 389         {\r
 390             NSTask *node = NSHeadMsg[TOPIC_SCHEDULER];\r
 391             NSHeadMsg[TOPIC_SCHEDULER] = node->nextTask;\r
 392 \r
 393             switch (node->taskType)\r
 394             {\r
 395                 case TASK_SEND_TOPICS:\r
 396                     NS_LOG(DEBUG, "CASE TASK_SEND_TOPICS : ");\r
 397                     NSSendTopicList((OCEntityHandlerRequest*) node->taskData);\r
 398                     NSFreeOCEntityHandlerRequest((OCEntityHandlerRequest*) node->taskData);\r
 399                     break;\r
 400                 case TASK_SUBSCRIBE_TOPIC:\r
 401                 {\r
 402                     NS_LOG(DEBUG, "CASE TASK_SUBSCRIBE_TOPIC : ");\r
 403                     NSCacheElement * newObj = (NSCacheElement *) OICMalloc(sizeof(NSCacheElement));\r
 404                     newObj->data = node->taskData;\r
 405                     newObj->next = NULL;\r
 406                     NSStorageWrite(consumerTopicList, newObj);\r
 407                     NSCacheTopicSubData * topicSubData = (NSCacheTopicSubData *) node->taskData;\r
 408                     NSSendTopicUpdationToConsumer(topicSubData->id);\r
 409                 }\r
 410                     break;\r
 411                 case TASK_UNSUBSCRIBE_TOPIC:\r
 412                 {\r
 413                     NS_LOG(DEBUG, "CASE TASK_SUBSCRIBE_TOPIC : ");\r
 414                     NSProviderDeleteConsumerTopic(consumerTopicList,\r
 415                             (NSCacheTopicSubData *) node->taskData);\r
 416                     NSCacheTopicSubData * topicSubData = (NSCacheTopicSubData *) node->taskData;\r
 417                     NSSendTopicUpdationToConsumer(topicSubData->id);\r
 418                     OICFree(topicSubData->topicName);\r
 419                     OICFree(topicSubData);\r
 420                 }\r
 421                     break;\r
 422                 case TASK_ADD_TOPIC:\r
 423                 {\r
 424                     NS_LOG(DEBUG, "CASE TASK_ADD_TOPIC : ");\r
 425                     NSAddTopics((const char *) node->taskData);\r
 426                 }\r
 427                     break;\r
 428                 case TASK_DELETE_TOPIC:\r
 429                 {\r
 430                     NS_LOG(DEBUG, "CASE_TASK_DELETE_TOPIC : ");\r
 431                     NSDeleteTopics((const char *) node->taskData);\r
 432                 }\r
 433                     break;\r
 434                 case TASK_POST_TOPIC:\r
 435                 {\r
 436                     NS_LOG(DEBUG, "TASK_POST_TOPIC : ");\r
 437                     NSPostConsumerTopics((OCEntityHandlerRequest*) node->taskData);\r
 438                     NSFreeOCEntityHandlerRequest((OCEntityHandlerRequest*) node->taskData);\r
 439                 }\r
 440                     break;\r
 441                 case TASK_GET_TOPICS:\r
 442                 {\r
 443                     NS_LOG(DEBUG, "TASK_GET_TOPICS : ");\r
 444                     NSTopicSynchronization * topicData = (NSTopicSynchronization *) node->taskData;\r
 445                     NSTopicLL * topics = NSProviderGetTopicsCacheData(registeredTopicList);\r
 446                     topicData->topics = topics;\r
 447                     pthread_cond_signal(&topicData->condition);\r
 448                 }\r
 449                     break;\r
 450                 case TAST_GET_CONSUMER_TOPICS:\r
 451                 {\r
 452                     NS_LOG(DEBUG, "TASK_GET_CONSUMER_TOPICS : ");\r
 453                     NSTopicSynchronization * topicData = (NSTopicSynchronization *) node->taskData;\r
 454                     NSTopicLL * topics = NSProviderGetConsumerTopicsCacheData(registeredTopicList,\r
 455                                 consumerTopicList, topicData->consumerId);\r
 456                     topicData->topics = topics;\r
 457                     pthread_cond_signal(&topicData->condition);\r
 458                 }\r
 459                     break;\r
 460                 default:\r
 461                     break;\r
 462             }\r
 463 \r
 464             OICFree(node);\r
 465         }\r
 466 \r
 467         pthread_mutex_unlock(&NSMutex[TOPIC_SCHEDULER]);\r
 468     }\r
 469 \r
 470     NS_LOG(DEBUG, "Destroy NSTopicSchedule");\r
 471     return NULL;\r
 472 }\r