1 //******************************************************************
3 // Copyright 2014 Intel Mobile Communications GmbH 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 //******************************************************************
23 // OCPlatform_impl.cpp
25 // Description: Implementation of the OCPlatform functionality. It contains
26 // a singleton interface that is used only by the OCPlatform namespace and is the
27 // central entrance to the stack.
31 //*********************************************************************
39 #include "OCPlatform.h"
41 #include "OCException.h"
42 #include "OCUtilities.h"
44 #include "oc_logger.hpp"
49 PlatformConfig& OCPlatform_impl::globalConfig()
51 static PlatformConfig s_config;
55 void OCPlatform_impl::Configure(const PlatformConfig& config)
57 globalConfig() = config;
60 OCPlatform_impl& OCPlatform_impl::Instance()
62 static OCPlatform_impl platform(globalConfig());
66 void OCPlatform_impl::init(const PlatformConfig& config)
70 case ModeType::Server:
71 m_server = m_WrapperInstance->CreateServerWrapper(m_csdkLock, config);
74 case ModeType::Client:
75 m_client = m_WrapperInstance->CreateClientWrapper(m_csdkLock, config);
79 m_server = m_WrapperInstance->CreateServerWrapper(m_csdkLock, config);
80 m_client = m_WrapperInstance->CreateClientWrapper(m_csdkLock, config);
85 OCPlatform_impl::OCPlatform_impl(const PlatformConfig& config)
87 m_WrapperInstance { make_unique<WrapperFactory>() },
88 m_csdkLock { std::make_shared<std::recursive_mutex>() }
93 OCPlatform_impl::~OCPlatform_impl(void)
97 OCStackResult OCPlatform_impl::setDefaultDeviceEntityHandler(EntityHandler entityHandler)
99 return checked_guard(m_server, &IServerWrapper::setDefaultDeviceEntityHandler,
103 OCStackResult OCPlatform_impl::notifyAllObservers(OCResourceHandle resourceHandle,
104 QualityOfService QoS)
106 return result_guard(OCNotifyAllObservers(resourceHandle,
107 static_cast<OCQualityOfService>(QoS)));
110 OCStackResult OCPlatform_impl::notifyAllObservers(OCResourceHandle resourceHandle)
112 return notifyAllObservers(resourceHandle, m_cfg.QoS);
115 OCStackResult OCPlatform_impl::notifyListOfObservers(OCResourceHandle resourceHandle,
116 ObservationIds& observationIds,
117 const std::shared_ptr<OCResourceResponse> pResponse)
119 return notifyListOfObservers(resourceHandle, observationIds, pResponse, m_cfg.QoS);
122 OCStackResult OCPlatform_impl::notifyListOfObservers(OCResourceHandle resourceHandle,
123 ObservationIds& observationIds,
124 const std::shared_ptr<OCResourceResponse> pResponse,
125 QualityOfService QoS)
129 return result_guard(OC_STACK_ERROR);
132 std::string payload(pResponse->getResourceRepresentation().getJSONRepresentation());
135 OCNotifyListOfObservers(resourceHandle,
136 &observationIds[0], observationIds.size(),
138 static_cast<OCQualityOfService>(QoS)));
141 OCResource::Ptr OCPlatform_impl::constructResourceObject(const std::string& host,
142 const std::string& uri,
143 OCConnectivityType connectivityType,
145 const std::vector<std::string>& resourceTypes,
146 const std::vector<std::string>& interfaces)
150 return std::shared_ptr<OCResource>();
153 return std::shared_ptr<OCResource>(new OCResource(m_client,
155 uri, "", connectivityType,
161 OCStackResult OCPlatform_impl::findResource(const std::string& host,
162 const std::string& resourceName,
163 OCConnectivityType connectivityType,
164 FindCallback resourceHandler)
166 return findResource(host, resourceName, connectivityType, resourceHandler, m_cfg.QoS);
169 OCStackResult OCPlatform_impl::findResource(const std::string& host,
170 const std::string& resourceName,
171 OCConnectivityType connectivityType,
172 FindCallback resourceHandler, QualityOfService QoS)
175 return checked_guard(m_client, &IClientWrapper::ListenForResource,
176 host, resourceName, connectivityType, resourceHandler, QoS);
179 OCStackResult OCPlatform_impl::getDeviceInfo(const std::string& host,
180 const std::string& deviceURI,
181 OCConnectivityType connectivityType,
182 FindDeviceCallback deviceInfoHandler)
184 return result_guard(getDeviceInfo(host, deviceURI, connectivityType,
185 deviceInfoHandler, m_cfg.QoS));
188 OCStackResult OCPlatform_impl::getDeviceInfo(const std::string& host,
189 const std::string& deviceURI,
190 OCConnectivityType connectivityType,
191 FindDeviceCallback deviceInfoHandler,
192 QualityOfService QoS)
194 return checked_guard(m_client, &IClientWrapper::ListenForDevice,
195 host, deviceURI, connectivityType, deviceInfoHandler, QoS);
198 OCStackResult OCPlatform_impl::registerResource(OCResourceHandle& resourceHandle,
199 std::string& resourceURI,
200 const std::string& resourceTypeName,
201 const std::string& resourceInterface,
202 EntityHandler entityHandler,
203 uint8_t resourceProperty)
205 return checked_guard(m_server, &IServerWrapper::registerResource,
206 std::ref(resourceHandle), resourceURI, resourceTypeName,
207 resourceInterface, entityHandler, resourceProperty);
210 OCStackResult OCPlatform_impl::registerDeviceInfo(const OCDeviceInfo deviceInfo)
212 return checked_guard(m_server, &IServerWrapper::registerDeviceInfo, deviceInfo);
215 OCStackResult OCPlatform_impl::registerResource(OCResourceHandle& resourceHandle,
216 const std::shared_ptr< OCResource > resource)
218 uint8_t resourceProperty = OC_DISCOVERABLE | OC_OBSERVABLE;
219 std::vector<std::string> resourceTypes = resource->getResourceTypes();
221 return checked_guard(m_server, &IServerWrapper::registerResourceWithHost,
222 std::ref(resourceHandle), resource->host(), resource->uri(),
223 resourceTypes[0]/*"core.remote"*/, "oc.mi.def",
224 (EntityHandler) nullptr, resourceProperty);
227 OCStackResult OCPlatform_impl::unregisterResource(const OCResourceHandle& resourceHandle) const
229 return checked_guard(m_server, &IServerWrapper::unregisterResource,
233 OCStackResult OCPlatform_impl::unbindResource(OCResourceHandle collectionHandle,
234 OCResourceHandle resourceHandle)
236 return result_guard(OCUnBindResource(std::ref(collectionHandle), std::ref(resourceHandle)));
239 OCStackResult OCPlatform_impl::unbindResources(const OCResourceHandle collectionHandle,
240 const std::vector<OCResourceHandle>& resourceHandles)
242 for(const auto& h : resourceHandles)
246 if(OC_STACK_OK != (r = result_guard(OCUnBindResource(collectionHandle, h))))
255 OCStackResult OCPlatform_impl::bindResource(const OCResourceHandle collectionHandle,
256 const OCResourceHandle resourceHandle)
258 return result_guard(OCBindResource(collectionHandle, resourceHandle));
261 OCStackResult OCPlatform_impl::bindResources(const OCResourceHandle collectionHandle,
262 const std::vector<OCResourceHandle>& resourceHandles)
264 for(const auto& h : resourceHandles)
268 if(OC_STACK_OK != (r = result_guard(OCBindResource(collectionHandle, h))))
277 OCStackResult OCPlatform_impl::bindTypeToResource(const OCResourceHandle& resourceHandle,
278 const std::string& resourceTypeName) const
280 return checked_guard(m_server, &IServerWrapper::bindTypeToResource,
281 resourceHandle, resourceTypeName);
284 OCStackResult OCPlatform_impl::bindInterfaceToResource(const OCResourceHandle& resourceHandle,
285 const std::string& resourceInterfaceName) const
287 return checked_guard(m_server, &IServerWrapper::bindInterfaceToResource,
288 resourceHandle, resourceInterfaceName);
291 OCStackResult OCPlatform_impl::startPresence(const unsigned int announceDurationSeconds)
293 return checked_guard(m_server, &IServerWrapper::startPresence,
294 announceDurationSeconds);
297 OCStackResult OCPlatform_impl::stopPresence()
299 return checked_guard(m_server, &IServerWrapper::stopPresence);
302 OCStackResult OCPlatform_impl::subscribePresence(OCPresenceHandle& presenceHandle,
303 const std::string& host,
304 OCConnectivityType connectivityType,
305 SubscribeCallback presenceHandler)
307 return subscribePresence(presenceHandle, host, "", connectivityType, presenceHandler);
311 OCStackResult OCPlatform_impl::subscribePresence(OCPresenceHandle& presenceHandle,
312 const std::string& host,
313 const std::string& resourceType,
314 OCConnectivityType connectivityType,
315 SubscribeCallback presenceHandler)
317 return checked_guard(m_client, &IClientWrapper::SubscribePresence,
318 &presenceHandle, host, resourceType, connectivityType,
322 OCStackResult OCPlatform_impl::unsubscribePresence(OCPresenceHandle presenceHandle)
324 return checked_guard(m_client, &IClientWrapper::UnsubscribePresence,
325 std::ref(presenceHandle));
328 OCStackResult OCPlatform_impl::sendResponse(const std::shared_ptr<OCResourceResponse> pResponse)
330 return checked_guard(m_server, &IServerWrapper::sendResponse,