service/notification/src/provider/NSProviderNotification.c

   1 //******************************************************************
   2 //
   3 // Copyright 2016 Samsung Electronics All Rights Reserved.
   4 //
   5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
   6 //
   7 // Licensed under the Apache License, Version 2.0 (the "License");
   8 // you may not use this file except in compliance with the License.
   9 // You may obtain a copy of the License at
  10 //
  11 //      http://www.apache.org/licenses/LICENSE-2.0
  12 //
  13 // Unless required by applicable law or agreed to in writing, software
  14 // distributed under the License is distributed on an "AS IS" BASIS,
  15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 // See the License for the specific language governing permissions and
  17 // limitations under the License.
  18 //
  19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
  20
  21 #include "NSProviderNotification.h"
  22
  23 NSResult NSInitMessageList()
  24 {
  25     NS_LOG(DEBUG, "NSInitMessageList - IN");
  26
  27     messageList = NSCacheCreate();
  28     messageList->cacheType = NS_PROVIDER_CACHE_MESSAGE;
  29
  30     NS_LOG(DEBUG, "NSInitMessageList - OUT");
  31     return NS_OK;
  32 }
  33
  34 NSResult NSGetMessagePayload(NSMessage *msg, OCRepPayload** msgPayload)
  35 {
  36     NS_LOG(DEBUG, "NSGetMessagePayload - IN");
  37
  38     *msgPayload = OCRepPayloadCreate();
  39
  40     if (!*msgPayload)
  41     {
  42         NS_LOG(ERROR, "Failed to allocate payload");
  43         return NS_ERROR;
  44     }
  45
  46     OCRepPayloadSetUri(*msgPayload, NS_COLLECTION_MESSAGE_URI);
  47     if(msg->mId)
  48         OCRepPayloadSetPropString(*msgPayload, NS_ATTRIBUTE_ID, msg->mId);
  49     if(msg->mTitle)
  50         OCRepPayloadSetPropString(*msgPayload, NS_ATTRIBUTE_TITLE, msg->mTitle);
  51     if(msg->mContentText)
  52         OCRepPayloadSetPropString(*msgPayload, NS_ATTRIBUTE_TEXT, msg->mContentText);
  53     if(msg->mSource)
  54         OCRepPayloadSetPropString(*msgPayload, NS_ATTRIBUTE_SOURCE, msg->mSource);
  55
  56     NS_LOG(DEBUG, "NSGetMessagePayload - OUT");
  57     return NS_OK;
  58 }
  59
  60 NSResult NSGetSyncPayload(NSSync *sync, OCRepPayload** syncPayload)
  61 {
  62     NS_LOG(DEBUG, "NSGetSyncPayload - IN");
  63
  64     *syncPayload = OCRepPayloadCreate();
  65
  66     if (!*syncPayload)
  67     {
  68         NS_LOG(ERROR, "Failed to allocate payload");
  69         return NS_ERROR;
  70     }
  71
  72     OCRepPayloadSetUri(*syncPayload, NS_COLLECTION_SYNC_URI);
  73     if(sync->mMessageId)
  74     {
  75         OCRepPayloadSetPropString(*syncPayload, NS_ATTRIBUTE_ID, sync->mMessageId);
  76         OCRepPayloadSetPropInt(*syncPayload, NS_ATTRIBUTE_STATE, sync->mState);
  77     }
  78
  79     NS_LOG(DEBUG, "NSGetSyncPayload - OUT");
  80     return NS_OK;
  81 }
  82
  83 NSResult NSSendMessage(NSMessage *msg)
  84 {
  85     NS_LOG(DEBUG, "NSSendMessage - IN");
  86
  87     OCResourceHandle rHandle;
  88     OCObservationId obArray[255] = { 0, };
  89     int obCount = 0, i;
  90
  91     if (NSPutMessageResource(msg, &rHandle) != NS_OK)
  92     {
  93         NS_LOG(ERROR, "fail to Put notification resource");
  94         return NS_ERROR;
  95     }
  96
  97     if (consumerSubList->head == NULL)
  98     {
  99         NS_LOG(ERROR, "SubList->head is NULL, empty SubList");
 100         return NS_ERROR;
 101     }
 102
 103     OCRepPayload* payload;
 104
 105     if (NSGetMessagePayload(msg, &payload) != NS_OK)
 106     {
 107         NS_LOG(ERROR, "fail to Get message payload");
 108         return NS_ERROR;
 109     }
 110
 111     NSCacheElement * it = consumerSubList->head;
 112
 113     while (it)
 114     {
 115         NSCacheSubData * subData = (NSCacheSubData *) it->data;
 116         NS_LOG_V(DEBUG, "subData->id = %s", subData->id);
 117         NS_LOG_V(DEBUG, "subData->messageId = %d", subData->messageObId);
 118         NS_LOG_V(DEBUG, "subData->obID = %d", subData->syncObId);
 119         NS_LOG_V(DEBUG, "subData->isWhite = %d", subData->isWhite);
 120
 121         if (subData->isWhite)
 122         {
 123             obArray[obCount++] = subData->messageObId;
 124         }
 125         it = it->next;
 126     }
 127
 128     NS_LOG_V(DEBUG, "observer Count = %d", obCount);
 129
 130     for (i = 0; i < obCount; ++i)
 131     {
 132         NS_LOG(DEBUG, "-------------------------------------------------------message\n");
 133         NS_LOG_V(DEBUG, "SubScription WhiteList[%d] = %d", i, obArray[i]);
 134         NS_LOG(DEBUG, "-------------------------------------------------------message\n");
 135     }
 136
 137     OCStackResult ocstackResult = OCNotifyListOfObservers(rHandle, obArray, obCount, payload,
 138             OC_LOW_QOS);
 139
 140     NS_LOG_V(DEBUG, "Message ocstackResult = %d", ocstackResult);
 141
 142     if (ocstackResult != OC_STACK_OK)
 143     {
 144         NS_LOG(ERROR, "fail to send message");
 145         OCRepPayloadDestroy(payload);
 146         return NS_ERROR;
 147     }
 148     OCRepPayloadDestroy(payload);
 149     NSFreeMessage(msg);
 150
 151     NS_LOG(DEBUG, "NSSendMessage - OUT");
 152
 153     return NS_OK;
 154 }
 155
 156 NSResult NSSendSync(NSSync *sync)
 157 {
 158     NS_LOG(DEBUG, "NSSendSync - IN");
 159
 160     OCObservationId obArray[255] = { 0, };
 161     int obCount = 0;
 162     int i;
 163
 164     OCResourceHandle rHandle;
 165     if (NSPutSyncResource(sync, &rHandle) != NS_OK)
 166     {
 167         NS_LOG(ERROR, PCF("Fail to put sync resource"));
 168         return NS_ERROR;
 169     }
 170
 171     NSCacheElement * it = consumerSubList->head;
 172
 173     while (it)
 174     {
 175         NSCacheSubData * subData = (NSCacheSubData *) it->data;
 176         if (subData->isWhite)
 177         {
 178             obArray[obCount++] = subData->syncObId;
 179         }
 180         it = it->next;
 181     }
 182
 183     OCRepPayload* payload;
 184     if (NSGetSyncPayload(sync, &payload) != NS_OK)
 185     {
 186         NS_LOG(ERROR, "Failed to allocate payload");
 187         return NS_ERROR;
 188     }
 189
 190     for (i = 0; i < obCount; ++i)
 191     {
 192         NS_LOG(DEBUG, "-------------------------------------------------------message\n");
 193         NS_LOG_V(DEBUG, "Sync WhiteList[%d] = %d", i, obArray[i]);
 194         NS_LOG(DEBUG, "-------------------------------------------------------message\n");
 195     }
 196
 197     OCStackResult ocstackResult = OCNotifyListOfObservers(rHandle, obArray,
 198             obCount, payload, OC_LOW_QOS);
 199
 200     NS_LOG_V(DEBUG, "Sync ocstackResult = %d", ocstackResult);
 201
 202     if (ocstackResult != OC_STACK_OK)
 203     {
 204         NS_LOG(ERROR, "fail to send Sync");
 205         OCRepPayloadDestroy(payload);
 206         return NS_ERROR;
 207
 208     }
 209
 210     OCRepPayloadDestroy(payload);
 211
 212     NS_LOG(DEBUG, "NSSendSync - OUT");
 213     return NS_OK;
 214 }
 215
 216 void * NSNotificationSchedule(void *ptr)
 217 {
 218     if (ptr == NULL)
 219     {
 220         NS_LOG(DEBUG, "Create NSNotifiactionSchedule");
 221     }
 222
 223     while (NSIsRunning[NOTIFICATION_SCHEDULER])
 224     {
 225         sem_wait(&NSSemaphore[NOTIFICATION_SCHEDULER]);
 226         pthread_mutex_lock(&NSMutex[NOTIFICATION_SCHEDULER]);
 227
 228         if (NSHeadMsg[NOTIFICATION_SCHEDULER] != NULL)
 229         {
 230             NSTask *node = NSHeadMsg[NOTIFICATION_SCHEDULER];
 231             NSHeadMsg[NOTIFICATION_SCHEDULER] = node->nextTask;
 232
 233             switch (node->taskType)
 234             {
 235                 case TASK_SEND_NOTIFICATION:
 236                 {
 237                     NS_LOG(DEBUG, "CASE TASK_SEND_NOTIFICATION : ");
 238                     NSSendMessage((NSMessage *)node->taskData);
 239                     break;
 240                 }
 241                 case TASK_SEND_READ:
 242                     NS_LOG(DEBUG, "CASE TASK_SEND_READ : ");
 243                     NSSendSync((NSSync*) node->taskData);
 244                     break;
 245                 case TASK_RECV_READ:
 246                     NS_LOG(DEBUG, "CASE TASK_RECV_READ : ");
 247                     NSSendSync((NSSync*) node->taskData);
 248                     NSPushQueue(CALLBACK_SCHEDULER, TASK_CB_SYNC, node->taskData);
 249                     break;
 250
 251                 default:
 252                     NS_LOG(ERROR, "Unknown type message");
 253                     break;
 254
 255             }
 256             OICFree(node);
 257         }
 258
 259         pthread_mutex_unlock(&NSMutex[NOTIFICATION_SCHEDULER]);
 260
 261     }
 262
 263     NS_LOG(INFO, "Destroy NSNotificationSchedule");
 264     return NULL;
 265 }