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 \r
  23 static bool isTopicList = false;\r
  24 \r
  25 NSResult NSInitTopicList()\r
  26 {\r
  27     NS_LOG(DEBUG, "NSInitTopicList - IN");\r
  28 \r
  29     if(isTopicList)\r
  30     {\r
  31         NS_LOG(DEBUG, "topic list has already initiated");\r
  32         return NS_FAIL;\r
  33     }\r
  34 \r
  35     consumerTopicList = NSStorageCreate();\r
  36     consumerTopicList->cacheType = NS_PROVIDER_CACHE_CONSUMER_TOPIC;\r
  37 \r
  38     registeredTopicList = NSStorageCreate();\r
  39     registeredTopicList->cacheType = NS_PROVIDER_CACHE_REGISTER_TOPIC;\r
  40 \r
  41     isTopicList = true;\r
  42 \r
  43     NS_LOG(DEBUG, "NSInitTopicList - OUT");\r
  44     return NS_OK;\r
  45 }\r
  46 \r
  47 NSTopicList * NSGetTopics(char *consumerId)\r
  48 {\r
  49     NS_LOG(DEBUG, "NSGetTopics()");\r
  50 \r
  51     NSTopicList  * topicList;\r
  52 \r
  53     if(consumerId == NULL)\r
  54     {\r
  55         NS_LOG(DEBUG, "All registered topic list");\r
  56     }\r
  57     else\r
  58     {\r
  59         NS_LOG_V(DEBUG, "Subscribed topic list for consumerId(%s)", consumerId);\r
  60     }\r
  61 \r
  62     NS_LOG(DEBUG, "NSGetTopics() NS_OK");\r
  63     return topicList;\r
  64 }\r
  65 \r
  66 //TODO: update parameter\r
  67 NSResult NSStoreTopics(char * consumerId, NSTopic** topics)\r
  68 {\r
  69     NS_LOG(DEBUG, "NSWriteTopicsToStorage()");\r
  70 \r
  71     NSCacheElement * element = (NSCacheElement *) OICMalloc(sizeof(NSCacheElement));\r
  72     NSCacheTopicData * topicData = (NSCacheTopicData *) OICMalloc(sizeof(NSCacheTopicData));\r
  73 \r
  74     OICStrcpy(topicData->consumerId, UUID_STRING_SIZE, consumerId);\r
  75     NS_LOG_V(DEBUG, "consumer id: %s", topicData->consumerId);\r
  76 \r
  77     // TODO: print topic list\r
  78     topicData->topics = topics;\r
  79     NS_LOG(DEBUG, "print topic list");\r
  80 \r
  81     element->data = (void*) topicData;\r
  82     element->next = NULL;\r
  83 \r
  84     if(NSStorageWrite(consumerTopicList, element) != NS_OK)\r
  85     {\r
  86         NS_LOG(DEBUG, "fail to write cache");\r
  87     }\r
  88 \r
  89     NS_LOG(DEBUG, "NSWriteTopicsToStorage() NS_OK");\r
  90     return NS_OK;\r
  91 }\r
  92 \r
  93 NSResult NSRegisterTopicList(NSTopicList *topicList)\r
  94 {\r
  95     NS_LOG(DEBUG, "NSRegisterTopicList()");\r
  96 \r
  97     if(!topicList)\r
  98     {\r
  99         NS_LOG(ERROR, "no topics");\r
 100         return NS_ERROR;\r
 101     }\r
 102 \r
 103     OCResourceHandle rHandle = NULL;\r
 104     if(NSPutTopicResource(topicList, &rHandle) != NS_OK)\r
 105     {\r
 106         NS_LOG(ERROR, "Fail to put topic resource");\r
 107         return NS_ERROR;\r
 108     }\r
 109 \r
 110     if(topicList->consumerId != NULL)\r
 111     {\r
 112         // id should be null to register topic list\r
 113         NS_LOG(ERROR, "invalid consumer id");\r
 114         return NS_ERROR;\r
 115     }\r
 116 \r
 117     NSStoreTopics(topicList->consumerId, topicList->head);\r
 118 \r
 119     NS_LOG(DEBUG, "NSRegisterTopicList() NS_OK");\r
 120     return NS_OK;\r
 121 }\r
 122 \r
 123 NSResult NSSendTopicUpdation()\r
 124 {\r
 125     NS_LOG(DEBUG, "NSSendTopicUpdation - IN");\r
 126 \r
 127     OCRepPayload* payload = OCRepPayloadCreate();\r
 128 \r
 129     if (!payload)\r
 130     {\r
 131         NS_LOG(ERROR, "fail to create playload");\r
 132         return NS_ERROR;\r
 133     }\r
 134 \r
 135     OCResourceHandle rHandle = NULL;\r
 136     if (NSPutMessageResource(NULL, &rHandle) != NS_OK)\r
 137     {\r
 138         NS_LOG(ERROR, "Fail to put message resource");\r
 139         return NS_ERROR;\r
 140     }\r
 141 \r
 142     OCRepPayloadSetUri(payload, NS_COLLECTION_MESSAGE_URI);\r
 143     OCRepPayloadSetPropInt(payload, NS_ATTRIBUTE_MESSAGE_ID, NS_TOPIC);\r
 144     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_PROVIDER_ID, NSGetProviderInfo()->providerId);\r
 145 \r
 146     OCObservationId obArray[255] = { 0, };\r
 147     int obCount = 0;\r
 148 \r
 149     NSCacheElement * it = consumerSubList->head;\r
 150 \r
 151     while (it)\r
 152     {\r
 153         NSCacheSubData * subData = (NSCacheSubData *) it->data;\r
 154 \r
 155         if (subData->isWhite)\r
 156         {\r
 157             if(subData->messageObId != 0)\r
 158             {\r
 159                 obArray[obCount++] = subData->messageObId;\r
 160             }\r
 161 \r
 162 #ifdef WITH_CLOUD\r
 163             if(subData->remote_messageObId != 0)\r
 164             {\r
 165                 obArray[obCount++] = subData->remote_messageObId;\r
 166             }\r
 167 #endif\r
 168 \r
 169         }\r
 170         it = it->next;\r
 171     }\r
 172 \r
 173     if(!obCount)\r
 174     {\r
 175         NS_LOG(ERROR, "observer count is zero");\r
 176         return NS_ERROR;\r
 177     }\r
 178 \r
 179     if (OCNotifyListOfObservers(rHandle, obArray, obCount, payload, OC_HIGH_QOS)\r
 180             != OC_STACK_OK)\r
 181     {\r
 182         NS_LOG(ERROR, "fail to send topic updation");\r
 183         OCRepPayloadDestroy(payload);\r
 184         return NS_ERROR;\r
 185 \r
 186     }\r
 187     OCRepPayloadDestroy(payload);\r
 188 \r
 189     NS_LOG(DEBUG, "NSSendTopicUpdation - OUT");\r
 190     return NS_OK;\r
 191 }\r
 192 \r
 193 NSResult NSSendTopicUpdationToConsumer(char *consumerId)\r
 194 {\r
 195     NS_LOG(DEBUG, "NSSendTopicUpdationToConsumer - IN");\r
 196 \r
 197     OCRepPayload* payload = OCRepPayloadCreate();\r
 198 \r
 199     if (!payload)\r
 200     {\r
 201         NS_LOG(ERROR, "fail to create playload");\r
 202         return NS_ERROR;\r
 203     }\r
 204 \r
 205     OCResourceHandle rHandle = NULL;\r
 206     if (NSPutMessageResource(NULL, &rHandle) != NS_OK)\r
 207     {\r
 208         NS_LOG(ERROR, "Fail to put message resource");\r
 209         return NS_ERROR;\r
 210     }\r
 211 \r
 212     OCRepPayloadSetUri(payload, NS_COLLECTION_MESSAGE_URI);\r
 213     OCRepPayloadSetPropInt(payload, NS_ATTRIBUTE_MESSAGE_ID, NS_TOPIC);\r
 214     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_PROVIDER_ID, NSGetProviderInfo()->providerId);\r
 215 \r
 216     NSCacheElement * element = NSStorageRead(consumerSubList, consumerId);\r
 217 \r
 218     if(element == NULL)\r
 219     {\r
 220         NS_LOG(ERROR, "element is NULL");\r
 221         return NS_ERROR;\r
 222     }\r
 223 \r
 224     NSCacheSubData * subData = (NSCacheSubData*) element->data;\r
 225 \r
 226     if (OCNotifyListOfObservers(rHandle, (OCObservationId*)&subData->messageObId, 1, payload, OC_HIGH_QOS)\r
 227             != OC_STACK_OK)\r
 228     {\r
 229         NS_LOG(ERROR, "fail to send topic updation");\r
 230         OCRepPayloadDestroy(payload);\r
 231         return NS_ERROR;\r
 232 \r
 233     }\r
 234 \r
 235     OCRepPayloadDestroy(payload);\r
 236 \r
 237     NS_LOG(DEBUG, "NSSendTopicUpdationToConsumer - OUT");\r
 238     return NS_OK;\r
 239 }\r
 240 \r
 241 NSResult NSSendTopicList(OCEntityHandlerRequest * entityHandlerRequest)\r
 242 {\r
 243     NS_LOG(DEBUG, "NSSendTopicList - IN");\r
 244 \r
 245     char * id = NSGetValueFromQuery(OICStrdup(entityHandlerRequest->query), NS_QUERY_CONSUMER_ID);\r
 246     if(!id)\r
 247     {\r
 248         NS_LOG(DEBUG, "Send registered topic list");\r
 249         //TODO: get registered topic list\r
 250     }\r
 251     else\r
 252     {\r
 253         NS_LOG(DEBUG, "Send subscribed topic list to consumer");\r
 254         //TODO: get subscribed topic list for consumer\r
 255     }\r
 256 \r
 257     // make response for the Get Request\r
 258     OCEntityHandlerResponse response;\r
 259     response.numSendVendorSpecificHeaderOptions = 0;\r
 260     memset(response.sendVendorSpecificHeaderOptions, 0,\r
 261             sizeof response.sendVendorSpecificHeaderOptions);\r
 262     memset(response.resourceUri, 0, sizeof response.resourceUri);\r
 263 \r
 264     OCRepPayload* payload = OCRepPayloadCreate();\r
 265     if (!payload)\r
 266     {\r
 267         NS_LOG(ERROR, "payload is NULL");\r
 268         return NS_ERROR;\r
 269     }\r
 270 \r
 271     OCRepPayloadSetUri(payload, NS_COLLECTION_TOPIC_URI);\r
 272     OCRepPayloadSetPropString(payload, NS_ATTRIBUTE_CONSUMER_ID, id);\r
 273     // TODO: add PayLoadSet with topic list got above\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     // Send Response\r
 282     if (OCDoResponse(&response) != OC_STACK_OK)\r
 283     {\r
 284         NS_LOG(ERROR, "Fail to response topic list");\r
 285         return NS_ERROR;\r
 286     }\r
 287     OCRepPayloadDestroy(payload);\r
 288     NSFreeOCEntityHandlerRequest(entityHandlerRequest);\r
 289 \r
 290     NS_LOG(DEBUG, "NSSendTopicList - OUT");\r
 291     return NS_OK;\r
 292 }\r
 293 \r
 294 bool NSIsTopicSubscribed(char * consumerId, char * topic)\r
 295 {\r
 296     //TODO: implement function\r
 297     return true;\r
 298 }\r
 299 \r
 300 void * NSTopicSchedule(void * ptr)\r
 301 {\r
 302     if (ptr == NULL)\r
 303     {\r
 304         NS_LOG(DEBUG, "Create NSTopicSchedule");\r
 305     }\r
 306 \r
 307     while (NSIsRunning[TOPIC_SCHEDULER])\r
 308     {\r
 309         sem_wait(&NSSemaphore[TOPIC_SCHEDULER]);\r
 310         pthread_mutex_lock(&NSMutex[TOPIC_SCHEDULER]);\r
 311 \r
 312         if (NSHeadMsg[TOPIC_SCHEDULER] != NULL)\r
 313         {\r
 314             NSTask *node = NSHeadMsg[TOPIC_SCHEDULER];\r
 315             NSHeadMsg[TOPIC_SCHEDULER] = node->nextTask;\r
 316 \r
 317             switch (node->taskType)\r
 318             {\r
 319                 case TASK_SEND_TOPICS:\r
 320                     NS_LOG(DEBUG, "CASE TASK_SEND_TOPICS : ");\r
 321                     NSSendTopicList((OCEntityHandlerRequest*) node->taskData);\r
 322                     break;\r
 323                 case TASK_SUBSCRIBE_TOPICS:\r
 324                     NS_LOG(DEBUG, "CASE TASK_SUBSCRIBE_TOPICS : ");\r
 325                     break;\r
 326                 case TASK_REGISTER_TOPICS:\r
 327                     NS_LOG(DEBUG, "CASE TASK_REGISTER_TOPICS : ");\r
 328                     NSTopicList * topicList = (NSTopicList *) node->taskData;\r
 329                     NSRegisterTopicList(topicList);\r
 330                     NSSendTopicUpdation();\r
 331                     // TODO : free NSTopic\r
 332                     // NSFreeTopicList(topicList);\r
 333                     break;\r
 334                 default:\r
 335                     break;\r
 336             }\r
 337 \r
 338             OICFree(node);\r
 339         }\r
 340 \r
 341         pthread_mutex_unlock(&NSMutex[TOPIC_SCHEDULER]);\r
 342     }\r
 343 \r
 344     NS_LOG(DEBUG, "Destroy NSTopicSchedule");\r
 345     return NULL;\r
 346 }\r