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 #ifndef OC_IN_PROC_CLIENT_WRAPPER_H_
22 #define OC_IN_PROC_CLIENT_WRAPPER_H_
30 #include <IClientWrapper.h>
31 #include <InitializeException.h>
32 #include <ResourceInitException.h>
36 namespace ClientCallbackContext
41 GetContext(GetCallback cb) : callback(cb){}
47 SetContext(PutCallback cb) : callback(cb){}
52 FindCallback callback;
53 std::weak_ptr<IClientWrapper> clientWrapper;
55 ListenContext(FindCallback cb, std::weak_ptr<IClientWrapper> cw)
56 : callback(cb), clientWrapper(cw){}
59 struct DeviceListenContext
61 FindDeviceCallback callback;
62 IClientWrapper::Ptr clientWrapper;
63 DeviceListenContext(FindDeviceCallback cb, IClientWrapper::Ptr cw)
64 : callback(cb), clientWrapper(cw){}
67 struct SubscribePresenceContext
69 SubscribeCallback callback;
70 SubscribePresenceContext(SubscribeCallback cb) : callback(cb){}
75 DeleteCallback callback;
76 DeleteContext(DeleteCallback cb) : callback(cb){}
81 ObserveCallback callback;
82 ObserveContext(ObserveCallback cb) : callback(cb){}
85 struct DirectPairingContext
87 DirectPairingCallback callback;
88 DirectPairingContext(DirectPairingCallback cb) : callback(cb){}
93 class InProcClientWrapper : public IClientWrapper
98 InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
100 virtual ~InProcClientWrapper();
102 virtual OCStackResult ListenForResource(const std::string& serviceUrl,
103 const std::string& resourceType, OCConnectivityType transportFlags,
104 FindCallback& callback, QualityOfService QoS);
106 virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
107 const std::string& deviceURI, OCConnectivityType transportFlags,
108 FindDeviceCallback& callback, QualityOfService QoS);
110 virtual OCStackResult GetResourceRepresentation(
111 const OCDevAddr& devAddr,
112 const std::string& uri,
113 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
114 GetCallback& callback, QualityOfService QoS);
116 virtual OCStackResult PutResourceRepresentation(
117 const OCDevAddr& devAddr,
118 const std::string& uri,
119 const OCRepresentation& attributes, const QueryParamsMap& queryParams,
120 const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS);
122 virtual OCStackResult PostResourceRepresentation(
123 const OCDevAddr& devAddr,
124 const std::string& uri,
125 const OCRepresentation& attributes, const QueryParamsMap& queryParams,
126 const HeaderOptions& headerOptions, PostCallback& callback, QualityOfService QoS);
128 virtual OCStackResult DeleteResource(
129 const OCDevAddr& devAddr,
130 const std::string& uri,
131 const HeaderOptions& headerOptions,
132 DeleteCallback& callback, QualityOfService QoS);
134 virtual OCStackResult ObserveResource(
135 ObserveType observeType, OCDoHandle* handle,
136 const OCDevAddr& devAddr,
137 const std::string& uri,
138 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
139 ObserveCallback& callback, QualityOfService QoS);
141 virtual OCStackResult CancelObserveResource(
143 const std::string& host,
144 const std::string& uri,
145 const HeaderOptions& headerOptions, QualityOfService QoS);
147 virtual OCStackResult SubscribePresence(
149 const std::string& host,
150 const std::string& resourceType,
151 OCConnectivityType transportFlags,
152 SubscribeCallback& presenceHandler);
154 virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
155 OCStackResult GetDefaultQos(QualityOfService& QoS);
158 virtual OCStackResult FindDirectPairingDevices(unsigned short waittime,
159 GetDirectPairedCallback& callback);
161 virtual OCStackResult GetDirectPairedDevices(GetDirectPairedCallback& callback);
163 virtual OCStackResult DoDirectPairing(std::shared_ptr<OCDirectPairing> peer, const OCPrm_t& pmSel,
164 const std::string& pinNumber, DirectPairingCallback& resultCallback);
167 void listeningFunc();
168 std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
169 OCPayload* assembleSetResourcePayload(const OCRepresentation& attributes);
170 OCHeaderOption* assembleHeaderOptions(OCHeaderOption options[],
171 const HeaderOptions& headerOptions);
172 void convert(const OCDPDev_t *list, PairedDevices& dpList);
173 std::thread m_listeningThread;
175 std::weak_ptr<std::recursive_mutex> m_csdkLock;
178 PlatformConfig m_cfg;