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 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
22 /// This sample provides steps to define an interface for a resource
23 /// (properties and methods) and host this resource on the server.
24 /// Additionally, it'll have a client example to discover it as well.
29 #include <condition_variable>
32 #include "OCPlatform.h"
40 void putResourceInfo(const HeaderOptions& headerOptions,
41 const OCRepresentation rep, const OCRepresentation rep2, const int eCode)
43 std::cout << "In PutResourceInfo" << std::endl;
45 std::cout <<"Clientside Put response to get was: "<<std::endl;
46 std::cout <<"ErrorCode: "<<eCode <<std::endl;
50 std::cout<<"Successful Put. Attributes sent were: "<<std::endl;
52 rep.getValue("isFoo", m_isFoo);
53 rep.getValue("barCount", m_barCount);
55 std::cout << "\tisFoo: "<< m_isFoo << std::endl;
56 std::cout << "\tbarCount: "<< m_barCount << std::endl;
58 std::cout<<"Actual New values are: "<<std::endl;
60 rep.getValue("isFoo", m_isFoo);
61 rep.getValue("barCount", m_barCount);
63 std::cout << "\tisFoo: "<< m_isFoo << std::endl;
64 std::cout << "\tbarCount: "<< m_barCount << std::endl;
70 void getResourceInfo(const HeaderOptions& headerOptions, const OCRepresentation rep,
73 std::cout << "In getResourceInfo" << std::endl;
75 std::cout<<"Clientside response to get was: "<<std::endl;
76 std::cout<<"Error Code: "<<eCode<<std::endl;
80 std::cout <<"Successful Get. Attributes are: "<<std::endl;
82 rep.getValue("isFoo", m_isFoo);
83 rep.getValue("barCount", m_barCount);
85 std::cout << "\tisFoo: "<< m_isFoo << std::endl;
86 std::cout << "\tbarCount: "<< m_barCount << std::endl;
88 std::cout << "Doing a put on q/foo" <<std::endl;
89 OCRepresentation rep2(rep);
93 rep2.setValue("isFoo", m_isFoo);
94 rep2.setValue("barCount", m_barCount);
96 m_resource->put(rep2, QueryParamsMap(),
97 PutCallback(std::bind(&ClientWorker::putResourceInfo, this, std::placeholders::_1,
98 rep2, std::placeholders::_2, std::placeholders::_3)));
102 void foundResource(std::shared_ptr<OCResource> resource)
104 std::cout << "In foundResource" << std::endl;
105 if(resource && resource->uri() == "/q/foo")
108 std::lock_guard<std::mutex> lock(m_resourceLock);
114 m_resource = resource;
117 std::cout << "Found Resource: "<<std::endl;
118 std::cout << "\tHost: "<< resource->host()<<std::endl;
119 std::cout << "\tURI: "<< resource->uri()<<std::endl;
121 // Get the resource types
122 std::cout << "\tList of resource types: " << std::endl;
123 for(auto &resourceTypes : resource->getResourceTypes())
125 std::cout << "\t\t" << resourceTypes << std::endl;
128 // Get the resource interfaces
129 std::cout << "\tList of resource interfaces: " << std::endl;
130 for(auto &resourceInterfaces : resource->getResourceInterfaces())
132 std::cout << "\t\t" << resourceInterfaces << std::endl;
135 std::cout<<"Doing a get on q/foo."<<std::endl;
137 resource->get(QueryParamsMap(),
138 GetCallback(std::bind(&ClientWorker::getResourceInfo, this,
139 std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)));
144 ClientWorker(OCConnectivityType ct):m_connectivityType{ct}
149 std::ostringstream requestURI;
150 requestURI << OC_MULTICAST_DISCOVERY_URI << "?rt=core.foo";
152 std::cout<<"Starting Client find:"<<std::endl;
153 FindCallback f (std::bind(&ClientWorker::foundResource, this, std::placeholders::_1));
154 std::cout<<"result:" <<
155 OCPlatform::findResource("", requestURI.str(), OC_ALL, f)
158 std::cout<<"Finding Resource..."<<std::endl;
161 std::unique_lock<std::mutex> lk(m_mutex);
167 std::mutex m_resourceLock;
168 std::condition_variable m_cv;
169 std::shared_ptr<OCResource> m_resource;
170 OCConnectivityType m_connectivityType;
179 OCResourceHandle m_resourceHandle;
180 OCRepresentation m_rep;
182 FooResource(): m_isFoo(true), m_barCount (0)
184 m_rep.setUri("/q/foo");
185 m_rep.setValue("isFoo", m_isFoo);
186 m_rep.setValue("barCount", m_barCount);
189 bool createResource()
191 std::string resourceURI = "/q/foo";
192 std::string resourceTypeName = "core.foo";
193 std::string resourceInterface = DEFAULT_INTERFACE;
195 uint8_t resourceProperty = OC_DISCOVERABLE;
197 EntityHandler eh(std::bind(&FooResource::entityHandler,
198 this, std::placeholders::_1));
199 OCStackResult result = OCPlatform::registerResource(m_resourceHandle,
200 resourceURI, resourceTypeName,
202 eh, resourceProperty);
203 if(OC_STACK_OK != result)
205 std::cout<<"Resource creation unsuccessful"<<std::endl;
212 OCRepresentation get()
214 m_rep.setValue("isFoo", m_isFoo);
215 m_rep.setValue("barCount", m_barCount);
220 void put(OCRepresentation& rep)
222 rep.getValue("isFoo", m_isFoo);
223 rep.getValue("barCount", m_barCount);
226 OCStackResult sendResponse(std::shared_ptr<OCResourceRequest> pRequest)
228 auto pResponse = std::make_shared<OC::OCResourceResponse>();
229 pResponse->setRequestHandle(pRequest->getRequestHandle());
230 pResponse->setResourceHandle(pRequest->getResourceHandle());
231 pResponse->setResourceRepresentation(get(), "");
232 pResponse->setErrorCode(200);
233 pResponse->setResponseResult(OC_EH_OK);
235 return OCPlatform::sendResponse(pResponse);
238 OCEntityHandlerResult entityHandler(std::shared_ptr<OCResourceRequest> request)
240 std::cout<<"\tConsumer Entity Handler:"<<std::endl;
241 OCEntityHandlerResult ehResult = OC_EH_ERROR;
245 // Note: Most of the handlers are not here, since this is for
246 // demoing client/server co-process existence.
247 // See simpleserver for a more complete example.
248 if(request->getRequestHandlerFlag() == RequestHandlerFlag::RequestFlag)
250 std::cout << "\t\trequestFlag : Request"<<std::endl;
252 if(request->getRequestType() == "GET")
254 std::cout<<"\t\t\trequestType : GET"<<std::endl;
255 if(OC_STACK_OK == sendResponse(request))
260 else if (request->getRequestType() == "PUT")
262 std::cout<<"\t\t\trequestType : PUT"<<std::endl;
264 OCRepresentation rep = request->getResourceRepresentation();
266 if(OC_STACK_OK == sendResponse(request))
273 std::cout<<"\t\t\trequestType : UNSUPPORTED: "<<
274 request->getRequestType()<<std::endl;
279 std::cout <<"\t\trequestFlag : UNSUPPORTED: ";
281 if(request->getRequestHandlerFlag()==RequestHandlerFlag::InitFlag)
283 std::cout<<"InitFlag"<<std::endl;
285 else if(request->getRequestHandlerFlag()== RequestHandlerFlag::ObserverFlag)
287 std::cout<<"ObserverFlag"<<std::endl;
293 std::cout << "Request Invalid!"<<std::endl;
301 int main(int argc, char* argv[])
303 OCConnectivityType connectivityType = OC_WIFI;
309 std::size_t inputValLen;
310 int optionSelected = std::stoi(argv[1], &inputValLen);
312 if(inputValLen == strlen(argv[1]))
314 if(optionSelected == 0)
316 connectivityType = OC_ETHERNET;
318 else if(optionSelected == 1)
320 connectivityType = OC_WIFI;
324 std::cout << "Invalid connectivity type selected. Using default WIFI"
330 std::cout << "Invalid connectivity type selected. Using default WIFI" << std::endl;
333 catch(std::exception& e)
335 std::cout << "Invalid input argument. Using WIFI as connectivity type" << std::endl;
340 std::cout<< "Usage simpleclientserver <ConnectivityType(0|1)>" << std::endl;
341 std::cout<<" ConnectivityType: Default WIFI" << std::endl;
342 std::cout << " ConnectivityType : 0 - ETHERNET" << std::endl;
343 std::cout << " ConnectivityType : 1 - WIFI" << std::endl;
347 OC::ServiceType::InProc,
349 "0.0.0.0", // By setting to "0.0.0.0", it binds to all available interfaces
350 0, // Uses randomly available port
351 OC::QualityOfService::LowQos
354 OCPlatform::Configure(cfg);
360 if(!fooRes.createResource())
365 ClientWorker cw(connectivityType);
368 catch(OCException& e)
370 std::cout<< "Exception in main: "<<e.what()<<std::endl;