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 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
24 #include "NSConstants.h"
25 #include "NSConsumerCommon.h"
26 #include "cautilinterface.h"
27 #include "oic_malloc.h"
28 #include "oic_string.h"
30 #include "NSConsumerDiscovery.h"
31 #include "NSConsumerNetworkEventListener.h"
33 #define NS_PRESENCE_SUBSCRIBE_QUERY "/oic/ad?rt=x.org.iotivity.notification"
35 void NSConnectionStateListener(const CAEndpoint_t * info, bool isConnected);
37 void NSAdapterStateListener(CATransportAdapter_t adapter, bool enabled);
39 OCDoHandle * getPresenceHandle()
41 static OCDoHandle g_PresenceHandle = NULL;
43 return & g_PresenceHandle;
47 NSResult NSConsumerListenerInit()
49 // TODO replace with comment lines when enable network monitor of IP Adapter
50 CARegisterNetworkMonitorHandler(NSAdapterStateListener, NSConnectionStateListener);
51 // if (CARegisterNetworkMonitorHandler(NSAdapterStateListener, NSConnectionStateListener)
56 OCStackResult stackResult;
58 NS_LOG(DEBUG, "Request to subscribe presence");
59 stackResult = NSInvokeRequest(getPresenceHandle(), OC_REST_PRESENCE, NULL,
60 NS_PRESENCE_SUBSCRIBE_QUERY, NULL, NSConsumerPresenceListener,
61 NULL, NULL, CT_DEFAULT);
62 NS_VERIFY_STACK_SUCCESS(NSOCResultToSuccess(stackResult), NS_ERROR);
64 NS_LOG(DEBUG, "Request to discover provider");
65 stackResult = NSInvokeRequest(NULL, OC_REST_DISCOVER, NULL,
66 NS_DISCOVER_QUERY, NULL, NSProviderDiscoverListener,
67 NULL, NULL, CT_DEFAULT);
68 NS_VERIFY_STACK_SUCCESS(NSOCResultToSuccess(stackResult), NS_ERROR);
73 void NSConsumerListenerTermiate()
75 CAUnregisterNetworkMonitorHandler(NSAdapterStateListener, NSConnectionStateListener);
76 OCCancel(*getPresenceHandle(), NS_QOS, NULL, 0);
79 void NSConnectionStateListener(const CAEndpoint_t * info, bool connected)
81 NS_VERIFY_NOT_NULL_V(info);
83 NS_LOG_V(DEBUG, "adapter : %d", info->adapter);
84 NS_LOG_V(INFO_PRIVATE, "remote_address : %s:%d", info->addr, info->port);
85 NS_LOG_V(DEBUG, "isConnect : %d", connected);
87 #ifdef DISABLE_AUTO_TCP_NSPROVIDER_DISCOVERY
88 if (info->adapter == CA_ADAPTER_TCP)
90 NS_LOG(DEBUG, "Ignoring the TCP event.");
95 NSTaskType type = TASK_EVENT_CONNECTED;
96 OCDevAddr * addr = NULL;
99 if (info->adapter == CA_ADAPTER_TCP)
101 type = TASK_EVENT_CONNECTED_TCP;
102 NS_LOG(DEBUG, "try to discover notification provider : TCP.");
104 else if (info->adapter == CA_ADAPTER_IP)
106 NS_LOG(DEBUG, "try to discover notification provider : IP.");
109 addr = (OCDevAddr *)OICMalloc(sizeof(OCDevAddr));
110 NS_VERIFY_NOT_NULL_V(addr);
112 addr->adapter = (OCTransportAdapter) info->adapter;
113 OICStrcpy(addr->addr, MAX_ADDR_STR_SIZE, info->addr);
114 addr->flags = info->flags;
115 addr->ifindex = info->ifindex;
116 addr->port = info->port;
118 NSTask * task = NSMakeTask(type, addr);
119 NS_VERIFY_NOT_NULL_WITH_POST_CLEANING_V(task, NSOICFree(addr));
121 NSConsumerPushEvent(task);
125 void NSAdapterStateListener(CATransportAdapter_t adapter, bool enabled)
127 NS_LOG_V(DEBUG, "adapter : %d", adapter);
128 NS_LOG_V(DEBUG, "isEnabled : %d", enabled);
134 NS_LOG(DEBUG, "try to discover notification provider.");
136 NSTask * task = NSMakeTask(TASK_EVENT_CONNECTED, NULL);
137 NS_VERIFY_NOT_NULL_V(task);
139 NSConsumerPushEvent(task);