1 //******************************************************************
3 // Copyright 2016 Samsung Electronics All Rights Reserved.
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
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
11 // http://www.apache.org/licenses/LICENSE-2.0
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.
19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
21 #include "NSConsumerInterface.h"
27 #include "NSConsumerCommon.h"
28 #include "NSConstants.h"
29 #include "NSConsumerScheduler.h"
30 #include "oic_malloc.h"
31 #include "oic_string.h"
34 NSResult NSStartConsumer(NSConsumerConfig config)
36 bool isStartedConsumer = NSIsStartedConsumer();
37 NS_VERIFY_NOT_NULL(isStartedConsumer == false ? (void *) 1 : NULL, NS_OK);
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);
44 NSSetDiscoverProviderCb(config.discoverCb);
45 NSSetMessagePostedCb(config.messageCb);
46 NSSetNotificationSyncCb(config.syncInfoCb);
47 NSSetSubscriptionAcceptedCb(config.acceptedCb);
48 NSSetIsStartedConsumer(true);
50 NSResult ret = NSConsumerMessageHandlerInit();
51 NS_VERIFY_NOT_NULL_WITH_POST_CLEANING(ret == NS_OK ? (void *) 1 : NULL,
52 NS_ERROR, NSStopConsumer());
57 NSResult NSStopConsumer()
59 NSSetDiscoverProviderCb(NULL);
60 NSSetMessagePostedCb(NULL);
61 NSSetNotificationSyncCb(NULL);
62 NSSetSubscriptionAcceptedCb(NULL);
63 NSSetIsStartedConsumer(false);
65 NSConsumerMessageHandlerExit();
70 NSResult NSSubscribe(NSProvider * provider)
72 NSTask * subscribeTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE, (void *) provider);
73 NS_VERIFY_NOT_NULL(subscribeTask, NS_ERROR);
75 return NSConsumerPushEvent(subscribeTask);
78 NSResult NSUnsubscribe(NSProvider * provider)
80 NSTask * unsubscribeTask = NSMakeTask(TASK_CONSUMER_REQ_SUBSCRIBE_CANCEL, (void *) provider);
81 NS_VERIFY_NOT_NULL(unsubscribeTask, NS_ERROR);
83 return NSConsumerPushEvent(unsubscribeTask);
86 NSResult NSConsumerSendSyncInfo(const char * providerId, uint64_t messageId, NSSyncType type)
88 NSSyncInfo * syncInfo = (NSSyncInfo *)OICMalloc(sizeof(NSSyncInfo));
89 NS_VERIFY_NOT_NULL(syncInfo, NS_ERROR);
91 OICStrcpy(syncInfo->providerId, sizeof(char) * NS_DEVICE_ID_LENGTH, providerId);
92 syncInfo->messageId = messageId;
93 syncInfo->state = type;
95 NSTask * syncTask = NSMakeTask(TASK_MAKE_SYNCINFO, (void *) syncInfo);
96 NS_VERIFY_NOT_NULL_WITH_POST_CLEANING(syncTask, NS_ERROR, NSOICFree(syncInfo));
98 return NSConsumerPushEvent(syncTask);
101 NSResult NSRescanProvider()
103 NSTask * discoverTask = NSMakeTask(TASK_CONSUMER_REQ_DISCOVER, NULL);
104 NS_VERIFY_NOT_NULL(discoverTask, NS_ERROR);
106 return NSConsumerPushEvent(discoverTask);
109 NSProvider * NSConsumerGetProvider(const char * providerId)
111 NS_VERIFY_NOT_NULL(providerId, NULL);
113 return (NSProvider *) NSConsumerFindNSProvider(providerId);
116 NSMessage * NSConsumerGetMessage(uint64_t messageId)
118 char msgId[NS_DEVICE_ID_LENGTH] = { 0, };
119 snprintf(msgId, NS_DEVICE_ID_LENGTH, "%lu", messageId);
121 return (NSMessage *) NSConsumerFindNSMessage(msgId);
124 NSResult NSDropNSMessage(NSMessage * obj)
126 NS_VERIFY_NOT_NULL(obj, NS_ERROR);
129 NSOICFree(obj->title);
130 NSOICFree(obj->contentText);
131 NSOICFree(obj->sourceName);