1 /******************************************************************
3 * Copyright 2014 Samsung Electronics All Rights Reserved.
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 ******************************************************************/
20 #include "ResourceFinder.h"
22 SSMRESULT CResourceFinder::finalConstruct()
24 SSMRESULT res = SSM_E_FAIL;
26 OC::PlatformConfig cfg(OC::ServiceType::InProc, OC::ModeType::Both, "0.0.0.0", 0,
27 OC::QualityOfService::LowQos);
29 SSM_CLEANUP_ASSERT(CreateGlobalInstance(OID_ITasker, (IBase **)&m_pTasker));
31 OC::OCPlatform::Configure(cfg);
33 m_pResourceFinderEvent = NULL;
35 m_multicastPresenceHandle = nullptr;
41 void CResourceFinder::finalRelease()
45 SSMRESULT CResourceFinder::registerResourceFinderEvent(IN IResourceFinderEvent *pEvent)
47 m_pResourceFinderEvent = pEvent;
51 void CResourceFinder::onResourceFound(std::shared_ptr< OC::OCResource > resource)
55 std::string path = resource->host() + resource->uri();
57 if (m_mapResourceHandler.find(path) != m_mapResourceHandler.end())
60 intptr_t *pMessage = new intptr_t [2];
61 pMessage[0] = RESOURCE_DISCOVER_REQUESTPROFILE;
62 pMessage[1] = reinterpret_cast<intptr_t> (new std::shared_ptr<OC::OCResource>(resource));
64 m_pTasker->addTask(this, pMessage);
68 void CResourceFinder::presenceHandler(OCStackResult result, const unsigned int nonce,
69 const std::string &hostAddress)
71 SSMRESULT res = SSM_E_FAIL;
72 OCStackResult ret = OC_STACK_ERROR;
73 intptr_t *pMessage = NULL;
74 std::ostringstream requestURI;
79 requestURI << "coap://" << hostAddress << ":" << OC_MULTICAST_PORT <<
80 "/oc/core?rt=SoftSensorManager.Sensor";
82 ret = OC::OCPlatform::findResource("", requestURI.str(), OC_ETHERNET,
83 std::bind(&CResourceFinder::onResourceFound, this, std::placeholders::_1));
85 if (ret != OC_STACK_OK)
86 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
88 ret = OC::OCPlatform::findResource("", requestURI.str(), OC_WIFI,
89 std::bind(&CResourceFinder::onResourceFound, this, std::placeholders::_1));
91 if (ret != OC_STACK_OK)
92 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
96 case OC_STACK_PRESENCE_STOPPED:
97 case OC_STACK_PRESENCE_TIMEOUT:
98 if (m_mapResources.find(hostAddress) != m_mapResources.end())
100 while (!m_mapResources[hostAddress].empty())
102 pMessage = new intptr_t[2];
103 pMessage[0] = RESOURCE_DISCOVER_UNINSTALL_RESOURCE;
104 pMessage[1] = reinterpret_cast<intptr_t> (m_mapResourceHandler[m_mapResources[hostAddress].back()]);
105 m_mapResources[hostAddress].pop_back();
106 m_pTasker->addTask(this, pMessage);
109 m_mapResources.erase(hostAddress);
113 case OC_STACK_VIRTUAL_DO_NOT_HANDLE:
124 SSMRESULT CResourceFinder::startResourceFinder()
126 SSMRESULT res = SSM_E_FAIL;
127 OCStackResult ret = OC_STACK_ERROR;
129 std::ostringstream requestURI;
130 requestURI << OC_WELL_KNOWN_QUERY << "?rt=SoftSensorManager.Sensor";
132 ret = OC::OCPlatform::findResource("", requestURI.str(), OC_ETHERNET,
133 std::bind(&CResourceFinder::onResourceFound, this, std::placeholders::_1));
135 if (ret != OC_STACK_OK)
136 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
138 ret = OC::OCPlatform::findResource("", requestURI.str(), OC_WIFI,
139 std::bind(&CResourceFinder::onResourceFound, this, std::placeholders::_1));
141 if (ret != OC_STACK_OK)
142 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
144 ret = OC::OCPlatform::subscribePresence(m_multicastPresenceHandle, OC_MULTICAST_IP,
145 "SoftSensorManager.Sensor", OC_ETHERNET, std::bind(&CResourceFinder::presenceHandler, this,
146 std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
148 if (ret != OC_STACK_OK)
149 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
151 ret = OC::OCPlatform::subscribePresence(m_multicastPresenceHandle, OC_MULTICAST_IP,
152 "SoftSensorManager.Sensor", OC_WIFI, std::bind(&CResourceFinder::presenceHandler, this,
153 std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
155 if (ret != OC_STACK_OK)
156 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
164 SSMRESULT CResourceFinder::stopResourceFinder()
166 SSMRESULT res = SSM_E_FAIL;
167 OCStackResult ret = OC_STACK_ERROR;
169 ret = OC::OCPlatform::unsubscribePresence(m_multicastPresenceHandle);
171 if (ret != OC_STACK_OK)
172 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
174 m_multicastPresenceHandle = nullptr;
182 SSMRESULT CResourceFinder::startObserveResource(IN ISSMResource *pSensor, IN IEvent *pEvent)
184 return m_mapResourceHandler[pSensor->name]->startObserve(pEvent);
187 SSMRESULT CResourceFinder::stopObserveResource(IN ISSMResource *pSensor)
189 return m_mapResourceHandler[pSensor->name]->stopObserve();
192 void CResourceFinder::onExecute(IN void *pArg)
194 SSMRESULT res = SSM_E_FAIL;
195 OCStackResult ret = OC_STACK_ERROR;
196 OC::QueryParamsMap queryParams;
197 OICResourceHandler *pResourceHandler = NULL;
198 intptr_t *pMessage = reinterpret_cast<intptr_t *>(pArg);
199 std::shared_ptr< OC::OCResource > *pResource = NULL;
200 OC::OCPlatform::OCPresenceHandle presenceHandle = NULL;
202 std::string resourceHostAddress = "";
203 std::string resourceFullPath = "";
207 case RESOURCE_DISCOVER_REQUESTPROFILE:
208 pResource = (std::shared_ptr< OC::OCResource > *) pMessage[1];
209 pResourceHandler = new OICResourceHandler();
210 SSM_CLEANUP_ASSERT(pResourceHandler->initHandler(*pResource, this));
212 resourceFullPath = pResource->get()->host() + pResource->get()->uri();
214 resourceHostAddress = pResource->get()->host();
215 resourceHostAddress.erase(0, 7); // erase 'coap://'
217 m_mapResourceHandler[resourceFullPath] = pResourceHandler;
219 m_mapResources[resourceHostAddress].push_back(resourceFullPath);
221 ret = pResource->get()->get(queryParams, std::bind(&OICResourceHandler::onGetResourceProfile,
222 pResourceHandler, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
224 if (ret != OC_STACK_OK)
225 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
229 case RESOURCE_DISCOVER_INSTALL_RESOURCE:
230 if (m_mapResourcePresenceHandles.find(((ISSMResource *)pMessage[1])->ip) ==
231 m_mapResourcePresenceHandles.end())
233 ret = OC::OCPlatform::subscribePresence(presenceHandle, ((ISSMResource *)pMessage[1])->ip,
234 "SoftSensorManager.Sensor", OC_ETHERNET, std::bind(&CResourceFinder::presenceHandler, this,
235 std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
237 if (ret != OC_STACK_OK)
238 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
240 ret = OC::OCPlatform::subscribePresence(presenceHandle, ((ISSMResource *)pMessage[1])->ip,
241 "SoftSensorManager.Sensor", OC_WIFI, std::bind(&CResourceFinder::presenceHandler, this,
242 std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
244 if (ret != OC_STACK_OK)
245 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
247 m_mapResourcePresenceHandles[((ISSMResource *)pMessage[1])->ip] = presenceHandle;
250 m_pResourceFinderEvent->onResourceFound((ISSMResource *) pMessage[1]);
253 case RESOURCE_DISCOVER_UNINSTALL_RESOURCE:
254 m_pResourceFinderEvent->onResourceLost(&((OICResourceHandler *) pMessage[1])->m_SSMResource);
256 if (m_mapResourcePresenceHandles.find(((OICResourceHandler *)pMessage[1])->m_SSMResource.ip) !=
257 m_mapResourcePresenceHandles.end())
259 ret = OC::OCPlatform::unsubscribePresence(m_mapResourcePresenceHandles[((
260 OICResourceHandler *)pMessage[1])->m_SSMResource.ip]);
262 if (ret != OC_STACK_OK)
263 SSM_CLEANUP_ASSERT(SSM_E_FAIL);
265 m_mapResourcePresenceHandles.erase(((OICResourceHandler *)pMessage[1])->m_SSMResource.ip);
268 m_mapResourceHandler.erase(((OICResourceHandler *) pMessage[1])->m_SSMResource.name);
276 void CResourceFinder::onTerminate(IN void *pArg)
278 std::shared_ptr< OC::OCResource > *pResource = NULL;
279 intptr_t *pMessage = (intptr_t *)pArg;
283 case RESOURCE_DISCOVER_REQUESTPROFILE:
284 pResource = (std::shared_ptr< OC::OCResource > *) pMessage[1];
288 case RESOURCE_DISCOVER_INSTALL_RESOURCE:
291 case RESOURCE_DISCOVER_UNINSTALL_RESOURCE: