service/notification/src/consumer/NSConsumerInterface.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 "NSConsumerInterface.h"
  22
  23 #include <stdlib.h>
  24 #include <stdbool.h>
  25
  26 #include "NSCommon.h"
  27 #include "NSConsumerCommon.h"
  28 #include "NSConstants.h"
  29 #include "NSConsumerScheduler.h"
  30 #include "oic_malloc.h"
  31 #include "oic_string.h"
  32
  33 // Public APIs
  34 NSResult NSStartConsumer(NSConsumerConfig config)
  35 {
  36     bool isStartedConsumer = NSIsStartedConsumer();
  37     NS_VERIFY_NOT_NULL(isStartedConsumer == false ? (void *) 1 : NULL, NS_OK);
  38
  39     NS_VERIFY_NOT_NULL(config.discoverCb, NS_ERROR);
  40     NS_VERIFY_NOT_NULL(config.messageCb, NS_ERROR);
  41     NS_VERIFY_NOT_NULL(config.syncInfoCb, NS_ERROR);
  42     NS_VERIFY_NOT_NULL(config.acceptedCb, NS_ERROR);
  43
  44     NSSetDiscoverProviderCb(config.discoverCb);
  45     NSSetMessagePostedCb(config.messageCb);
  46     NSSetNotificationSyncCb(config.syncInfoCb);
  47     NSSetSubscriptionAcceptedCb(config.acceptedCb);
  48     NSSetIsStartedConsumer(true);
  49
  50     NSResult ret = NSConsumerMessageHandlerInit();
  51     NS_VERIFY_NOT_NULL_WITH_POST_CLEANING(ret == NS_OK ? (void *) 1 : NULL,
  52             NS_ERROR, NSStopConsumer());
  53
  54     return NS_OK;
  55 }
  56
  57 NSResult NSStopConsumer()
  58 {
  59     NSSetDiscoverProviderCb(NULL);
  60     NSSetMessagePostedCb(NULL);
  61     NSSetNotificationSyncCb(NULL);
  62     NSSetSubscriptionAcceptedCb(NULL);
  63     NSSetIsStartedConsumer(false);
  64
  65     NSConsumerMessageHandlerExit();
  66
  67     return NS_OK;
  68 }
  69
  70 NSResult NSSubscribe(NSProvider * provider)
  71 {
  72     NSTask * subscribeTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE, (void *) provider);
  73     NS_VERIFY_NOT_NULL(subscribeTask, NS_ERROR);
  74
  75     return NSConsumerPushEvent(subscribeTask);
  76 }
  77
  78 NSResult NSUnsubscribe(NSProvider * provider)
  79 {
  80     NSTask * unsubscribeTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL, (void *) provider);
  81     NS_VERIFY_NOT_NULL(unsubscribeTask, NS_ERROR);
  82
  83     return NSConsumerPushEvent(unsubscribeTask);
  84 }
  85
  86 NSResult NSConsumerSendSyncInfo(const char * providerId, uint64_t messageId, NSSyncType type)
  87 {
  88     NSSyncInfo * syncInfo = (NSSyncInfo *)OICMalloc(sizeof(NSSyncInfo));
  89     NS_VERIFY_NOT_NULL(syncInfo, NS_ERROR);
  90
  91     OICStrcpy(syncInfo->providerId, sizeof(char) * NS_DEVICE_ID_LENGTH, providerId);
  92     syncInfo->messageId = messageId;
  93     syncInfo->state = type;
  94
  95     NSTask * syncTask = NSMakeTask(TASK_MAKE_SYNCINFO, (void *) syncInfo);
  96     NS_VERIFY_NOT_NULL_WITH_POST_CLEANING(syncTask, NS_ERROR, NSOICFree(syncInfo));
  97
  98     return NSConsumerPushEvent(syncTask);
  99 }
 100
 101 NSResult NSRescanProvider()
 102 {
 103     NSTask * discoverTask = NSMakeTask(TASK_CONSUMER_REQ_DISCOVER, NULL);
 104     NS_VERIFY_NOT_NULL(discoverTask, NS_ERROR);
 105
 106     return NSConsumerPushEvent(discoverTask);
 107 }
 108
 109 NSProvider * NSConsumerGetProvider(const char * providerId)
 110 {
 111     NS_VERIFY_NOT_NULL(providerId, NULL);
 112
 113     return (NSProvider *) NSConsumerFindNSProvider(providerId);
 114 }
 115
 116 NSMessage * NSConsumerGetMessage(uint64_t messageId)
 117 {
 118     char msgId[NS_DEVICE_ID_LENGTH] = { 0, };
 119     snprintf(msgId, NS_DEVICE_ID_LENGTH, "%lld", messageId);
 120
 121     return (NSMessage *) NSConsumerFindNSMessage(msgId);
 122 }
 123
 124 NSResult NSDropNSMessage(NSMessage * obj)
 125 {
 126     NS_VERIFY_NOT_NULL(obj, NS_ERROR);
 127
 128     obj->messageId = 0;
 129     NSOICFree(obj->title);
 130     NSOICFree(obj->contentText);
 131     NSOICFree(obj->sourceName);
 132     NSOICFree(obj);
 133
 134     return NS_OK;
 135 }