1 /* ****************************************************************
\r
3 * Copyright 2016 Intel Corporation All Rights Reserved.
\r
5 * Licensed under the Apache License, Version 2.0 (the "License");
\r
6 * you may not use this file except in compliance with the License.
\r
7 * You may obtain a copy of the License at
\r
9 * http://www.apache.org/licenses/LICENSE-2.0
\r
11 * Unless required by applicable law or agreed to in writing, software
\r
12 * distributed under the License is distributed on an "AS IS" BASIS,
\r
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
14 * See the License for the specific language governing permissions and
\r
15 * limitations under the License.
\r
17 ******************************************************************/
\r
20 #include "winuiclient.h"
\r
21 #include <Windows.h>
\r
22 #include <Commctrl.h>
\r
23 #include <functional>
\r
25 extern int g_CurSliderVal;
\r
26 extern HWND hwndVolumeSlider, hwndVolumeExpectedLabel;
\r
27 using namespace WinUIClient;
\r
28 void LabelPrintf (HWND hwndEdit, TCHAR * szFormat, ...);
\r
30 WinUIClientApp::WinUIClientApp(OCPersistentStorage ps)
\r
31 : persistentStorage(ps),
\r
32 OBSERVE_TYPE_TO_USE(ObserveType::Observe)
\r
37 WinUIClientApp::~WinUIClientApp()
\r
42 void WinUIClientApp::Initialize()
\r
44 // Create PlatformConfig object
\r
45 PlatformConfig cfg {
\r
46 OC::ServiceType::InProc,
\r
50 OC::QualityOfService::LowQos,
\r
54 OCPlatform::Configure(cfg);
\r
57 void WinUIClientApp::Run()
\r
61 // makes it so that all boolean values are printed as 'true/false' in this stream
\r
62 std::cout.setf(std::ios::boolalpha);
\r
63 // Find all resources
\r
64 std::ostringstream requestURI;// << "?rt=core.media";
\r
65 std::string s = OC_RSRVD_WELL_KNOWN_URI;
\r
68 OCPlatform::findResource("", requestURI.str(),
\r
69 CT_DEFAULT, std::bind(&WinUIClientApp::foundResource, this, std::placeholders::_1));
\r
70 std::cout<< "Finding Resource... " <<std::endl;
\r
72 // Find resource is done twice so that we discover the original resources a second time.
\r
73 // These resources will have the same uniqueidentifier (yet be different objects), so that
\r
74 // we can verify/show the duplicate-checking code in foundResource(above);
\r
75 OCPlatform::findResource("", requestURI.str(),
\r
76 CT_DEFAULT, std::bind(&WinUIClientApp::foundResource, this, std::placeholders::_1));
\r
77 std::cout<< "Finding Resource for second time..." << std::endl;
\r
79 }catch(OCException& e)
\r
81 std::cerr << "Exception in main: "<<e.what();
\r
85 void WinUIClientApp::FindResources()
\r
87 std::ostringstream requestURI;
\r
88 requestURI << OC_RSRVD_WELL_KNOWN_URI;// << "?rt=core.media";
\r
89 OCPlatform::findResource("", requestURI.str(),
\r
90 CT_DEFAULT, std::bind(&WinUIClientApp::foundResource, this, std::placeholders::_1));
\r
94 // Callback to found resources
\r
95 void WinUIClientApp::foundResource(std::shared_ptr<OCResource> resource)
\r
97 std::cout << "In foundResource\n";
\r
98 std::string resourceURI;
\r
99 std::string hostAddress;
\r
103 std::lock_guard<std::mutex> lock(curResourceLock);
\r
104 if (discoveredResources.find(resource->uniqueIdentifier()) == discoveredResources.end())
\r
106 std::cout << "Found resource " << resource->uniqueIdentifier() <<
\r
107 " for the first time on server with ID: "<< resource->sid()<<std::endl;
\r
108 discoveredResources[resource->uniqueIdentifier()] = resource;
\r
112 std::cout<<"Found resource "<< resource->uniqueIdentifier() << " again!"<<std::endl;
\r
117 std::cout << "Found another resource, ignoring"<<std::endl;
\r
122 // Do some operations with resource object.
\r
125 std::cout<<"DISCOVERED Resource:"<<std::endl;
\r
126 // Get the resource URI
\r
127 resourceURI = resource->uri();
\r
128 std::cout << "\tURI of the resource: " << resourceURI << std::endl;
\r
130 // Get the resource host address
\r
131 hostAddress = resource->host();
\r
132 std::cout << "\tHost address of the resource: " << hostAddress << std::endl;
\r
134 // Get the resource types
\r
135 std::cout << "\tList of resource types: " << std::endl;
\r
136 for(auto &resourceTypes : resource->getResourceTypes())
\r
138 std::cout << "\t\t" << resourceTypes << std::endl;
\r
141 // Get the resource interfaces
\r
142 std::cout << "\tList of resource interfaces: " << std::endl;
\r
143 for(auto &resourceInterfaces : resource->getResourceInterfaces())
\r
145 std::cout << "\t\t" << resourceInterfaces << std::endl;
\r
148 if (resourceURI == "/a/media")
\r
150 curResource = resource;
\r
151 // Call a local function which will internally invoke get API on the resource pointer
\r
152 this->GetMediaRepresentation();
\r
153 this->BeginObserving();
\r
158 // Resource is invalid
\r
159 std::cout << "Resource is invalid" << std::endl;
\r
163 catch(std::exception& e)
\r
165 std::cerr << "Exception in foundResource: "<< e.what() << std::endl;
\r
169 // Local function to get representation of media resource
\r
170 void WinUIClientApp::GetMediaRepresentation()
\r
174 std::cout << "Getting Media Representation..."<<std::endl;
\r
175 // Invoke resource's get API with the callback parameter
\r
177 QueryParamsMap test;
\r
178 curResource->get(test, std::bind(&WinUIClientApp::onGet, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
\r
183 std::cout << "No Current Resource to GetMediaRepresentation..."<<std::endl;
\r
187 // Callback handler on GET request
\r
188 void WinUIClientApp::onGet(const HeaderOptions& /*headerOptions*/, const OCRepresentation& rep, const int eCode)
\r
192 if (eCode == OC_STACK_OK)
\r
194 std::cout << "GET request was successful" << std::endl;
\r
195 std::cout << "Resource URI: " << rep.getUri() << std::endl;
\r
197 rep.getValue("state", mymedia.m_state);
\r
198 rep.getValue("volume", mymedia.m_volume);
\r
199 rep.getValue("name", mymedia.m_name);
\r
201 std::cout << "\tstate: " << mymedia.m_state << std::endl;
\r
202 std::cout << "\tvolume: " << mymedia.m_volume << std::endl;
\r
203 std::cout << "\tname: " << mymedia.m_name << std::endl;
\r
205 g_CurSliderVal = mymedia.m_volume;
\r
206 SendMessage(hwndVolumeSlider, TBM_SETPOS, TRUE, g_CurSliderVal);
\r
207 LabelPrintf(hwndVolumeExpectedLabel,"Volume: %i", g_CurSliderVal);
\r
212 std::cout << "onGET Response error: " << eCode << std::endl;
\r
216 catch(std::exception& e)
\r
218 std::cout << "Exception: " << e.what() << " in onGet" << std::endl;
\r
222 // Local function to put a different state for this resource
\r
223 void WinUIClientApp::PutMediaRepresentation()
\r
227 OCRepresentation rep;
\r
229 std::cout << "Putting media representation..."<<std::endl;
\r
231 rep.setValue("state", mymedia.m_state);
\r
232 rep.setValue("volume", mymedia.m_volume);
\r
234 // Invoke resource's put API with rep, query map and the callback parameter
\r
235 curResource->put(rep, QueryParamsMap(), std::bind(&WinUIClientApp::onPut, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
\r
239 // callback handler on PUT request
\r
240 void WinUIClientApp::onPut(const HeaderOptions& /*headerOptions*/, const OCRepresentation& rep, const int eCode)
\r
244 if (eCode == OC_STACK_OK || eCode == OC_STACK_RESOURCE_CHANGED)
\r
246 std::cout << "PUT request was successful" << std::endl;
\r
248 rep.getValue("state", mymedia.m_state);
\r
249 rep.getValue("volume", mymedia.m_volume);
\r
250 rep.getValue("name", mymedia.m_name);
\r
252 std::cout << "\tstate: " << mymedia.m_state << std::endl;
\r
253 std::cout << "\tvolume: " << mymedia.m_volume << std::endl;
\r
254 std::cout << "\tname: " << mymedia.m_name << std::endl;
\r
259 std::cout << "onPut Response error: " << eCode << std::endl;
\r
263 catch(std::exception& e)
\r
265 std::cout << "Exception: " << e.what() << " in onPut" << std::endl;
\r
269 // Local function to put a different state for this resource
\r
270 void WinUIClientApp::PostMediaRepresentation()
\r
274 OCRepresentation rep;
\r
276 std::cout << "Posting media representation..."<<std::endl;
\r
278 rep.setValue("state", mymedia.m_state);
\r
279 rep.setValue("volume", mymedia.m_volume);
\r
281 // Invoke resource's post API with rep, query map and the callback parameter
\r
282 curResource->post(rep, QueryParamsMap(), std::bind(&WinUIClientApp::onPost, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3));
\r
286 void WinUIClientApp::onPost(const HeaderOptions& /*headerOptions*/,
\r
287 const OCRepresentation& rep, const int eCode)
\r
291 if (eCode == OC_STACK_OK || eCode == OC_STACK_RESOURCE_CREATED
\r
292 || OC_STACK_RESOURCE_CHANGED)
\r
294 std::cout << "POST request was successful" << std::endl;
\r
296 if (rep.hasAttribute("createduri"))
\r
298 std::cout << "\tUri of the created resource: "
\r
299 << rep.getValue<std::string>("createduri") << std::endl;
\r
303 rep.getValue("state", mymedia.m_state);
\r
304 rep.getValue("volume", mymedia.m_volume);
\r
305 rep.getValue("name", mymedia.m_name);
\r
307 std::cout << "\tstate: " << mymedia.m_state << std::endl;
\r
308 std::cout << "\tvolume: " << mymedia.m_volume << std::endl;
\r
309 std::cout << "\tname: " << mymedia.m_name << std::endl;
\r
315 std::cout << "onPost Response error: " << eCode << std::endl;
\r
319 catch (std::exception& e)
\r
321 std::cout << "Exception: " << e.what() << " in onPost" << std::endl;
\r
325 void WinUIClientApp::onPost2(const HeaderOptions& /*headerOptions*/,
\r
326 const OCRepresentation& rep, const int eCode)
\r
330 if (eCode == OC_STACK_OK || eCode == OC_STACK_RESOURCE_CREATED)
\r
332 std::cout << "POST request was successful" << std::endl;
\r
334 if (rep.hasAttribute("createduri"))
\r
336 std::cout << "\tUri of the created resource: "
\r
337 << rep.getValue<std::string>("createduri") << std::endl;
\r
341 rep.getValue("state", mymedia.m_state);
\r
342 rep.getValue("volume", mymedia.m_volume);
\r
343 rep.getValue("name", mymedia.m_name);
\r
345 std::cout << "\tstate: " << mymedia.m_state << std::endl;
\r
346 std::cout << "\tvolume: " << mymedia.m_volume << std::endl;
\r
347 std::cout << "\tname: " << mymedia.m_name << std::endl;
\r
353 std::cout << "onPost2 Response error: " << eCode << std::endl;
\r
357 catch(std::exception& e)
\r
359 std::cout << "Exception: " << e.what() << " in onPost2" << std::endl;
\r
364 void WinUIClientApp::onObserve(const HeaderOptions /*headerOptions*/, const OCRepresentation& rep,
\r
365 const int& eCode, const int& sequenceNumber)
\r
369 if (eCode == OC_STACK_OK && sequenceNumber != OC_OBSERVE_NO_OPTION)
\r
371 if (sequenceNumber == OC_OBSERVE_REGISTER)
\r
373 std::cout << "Observe registration action is successful" << std::endl;
\r
375 else if (sequenceNumber == OC_OBSERVE_DEREGISTER)
\r
377 std::cout << "Observe De-registration action is successful" << std::endl;
\r
380 std::cout << "OBSERVE RESULT:"<<std::endl;
\r
381 std::cout << "\tSequenceNumber: "<< sequenceNumber << std::endl;
\r
382 rep.getValue("state", mymedia.m_state);
\r
383 rep.getValue("volume", mymedia.m_volume);
\r
384 rep.getValue("name", mymedia.m_name);
\r
386 std::cout << "\tstate: " << mymedia.m_state << std::endl;
\r
387 std::cout << "\tvolume: " << mymedia.m_volume << std::endl;
\r
388 std::cout << "\tname: " << mymedia.m_name << std::endl;
\r
390 g_CurSliderVal = mymedia.m_volume;
\r
391 SendMessage(hwndVolumeSlider, TBM_SETPOS, TRUE, g_CurSliderVal);
\r
392 LabelPrintf(hwndVolumeExpectedLabel,"Volume: %i", g_CurSliderVal);
\r
396 if (sequenceNumber == OC_OBSERVE_NO_OPTION)
\r
398 std::cout << "Observe registration or de-registration action is failed" << std::endl;
\r
402 std::cout << "onObserve Response error: " << eCode << std::endl;
\r
407 catch (std::exception& e)
\r
409 std::cout << "Exception: " << e.what() << " in onObserve" << std::endl;
\r
414 void WinUIClientApp::BeginObserving()
\r
416 if (OBSERVE_TYPE_TO_USE == ObserveType::Observe)
\r
417 std::cout << std::endl << "Observe is used." << std::endl << std::endl;
\r
418 else if (OBSERVE_TYPE_TO_USE == ObserveType::ObserveAll)
\r
419 std::cout << std::endl << "ObserveAll is used." << std::endl << std::endl;
\r
421 curResource->observe(OBSERVE_TYPE_TO_USE, QueryParamsMap(), std::bind(&WinUIClientApp::onObserve, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4));
\r
424 void WinUIClientApp::CancelObserving()
\r
426 std::cout<<"Cancelling Observe..."<<std::endl;
\r
427 OCStackResult result = curResource->cancelObserve();
\r
430 std::shared_ptr<OCResource> WinUIClientApp::GetResource()
\r
432 return curResource;
\r
435 int WinUIClientApp::observe_count()
\r