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