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 ListenErrorContext
61 FindCallback callback;
62 FindErrorCallback errorCallback;
63 std::weak_ptr<IClientWrapper> clientWrapper;
65 ListenErrorContext(FindCallback cb1, FindErrorCallback cb2,
66 std::weak_ptr<IClientWrapper> cw)
67 : callback(cb1), errorCallback(cb2), clientWrapper(cw){}
70 struct DeviceListenContext
72 FindDeviceCallback callback;
73 IClientWrapper::Ptr clientWrapper;
74 DeviceListenContext(FindDeviceCallback cb, IClientWrapper::Ptr cw)
75 : callback(cb), clientWrapper(cw){}
78 struct SubscribePresenceContext
80 SubscribeCallback callback;
81 SubscribePresenceContext(SubscribeCallback cb) : callback(cb){}
86 DeleteCallback callback;
87 DeleteContext(DeleteCallback cb) : callback(cb){}
92 ObserveCallback callback;
93 ObserveContext(ObserveCallback cb) : callback(cb){}
96 struct DirectPairingContext
98 DirectPairingCallback callback;
99 DirectPairingContext(DirectPairingCallback cb) : callback(cb){}
104 struct MQTopicContext
106 MQTopicCallback callback;
107 std::weak_ptr<IClientWrapper> clientWrapper;
108 MQTopicContext(MQTopicCallback cb, std::weak_ptr<IClientWrapper> cw)
109 : callback(cb), clientWrapper(cw){}
114 class InProcClientWrapper : public IClientWrapper
119 InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
121 virtual ~InProcClientWrapper();
123 virtual OCStackResult ListenForResource(const std::string& serviceUrl,
124 const std::string& resourceType, OCConnectivityType transportFlags,
125 FindCallback& callback, QualityOfService QoS);
127 virtual OCStackResult ListenErrorForResource(const std::string& serviceUrl,
128 const std::string& resourceType, OCConnectivityType transportFlags,
129 FindCallback& callback, FindErrorCallback& errorCallback, QualityOfService QoS);
131 virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
132 const std::string& deviceURI, OCConnectivityType transportFlags,
133 FindDeviceCallback& callback, QualityOfService QoS);
135 virtual OCStackResult GetResourceRepresentation(
136 const OCDevAddr& devAddr,
137 const std::string& uri,
138 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
139 OCConnectivityType connectivityType,
140 GetCallback& callback, QualityOfService QoS);
142 virtual OCStackResult PutResourceRepresentation(
143 const OCDevAddr& devAddr,
144 const std::string& uri,
145 const OCRepresentation& attributes, const QueryParamsMap& queryParams,
146 const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS);
148 virtual OCStackResult PostResourceRepresentation(
149 const OCDevAddr& devAddr,
150 const std::string& uri,
151 const OCRepresentation& attributes, const QueryParamsMap& queryParams,
152 const HeaderOptions& headerOptions, OCConnectivityType connectivityType,
153 PostCallback& callback, QualityOfService QoS);
155 virtual OCStackResult DeleteResource(
156 const OCDevAddr& devAddr,
157 const std::string& uri,
158 const HeaderOptions& headerOptions,
159 OCConnectivityType connectivityType,
160 DeleteCallback& callback, QualityOfService QoS);
162 virtual OCStackResult ObserveResource(
163 ObserveType observeType, OCDoHandle* handle,
164 const OCDevAddr& devAddr,
165 const std::string& uri,
166 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
167 ObserveCallback& callback, QualityOfService QoS);
169 virtual OCStackResult CancelObserveResource(
171 const std::string& host,
172 const std::string& uri,
173 const HeaderOptions& headerOptions, QualityOfService QoS);
175 virtual OCStackResult SubscribePresence(
177 const std::string& host,
178 const std::string& resourceType,
179 OCConnectivityType transportFlags,
180 SubscribeCallback& presenceHandler);
182 virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
185 virtual OCStackResult SubscribeDevicePresence(OCDoHandle* handle,
186 const std::string& host,
187 const std::vector<std::string>& di,
188 OCConnectivityType connectivityType,
189 ObserveCallback& callback);
192 OCStackResult GetDefaultQos(QualityOfService& QoS);
194 virtual OCStackResult FindDirectPairingDevices(unsigned short waittime,
195 GetDirectPairedCallback& callback);
197 virtual OCStackResult GetDirectPairedDevices(GetDirectPairedCallback& callback);
199 virtual OCStackResult DoDirectPairing(std::shared_ptr<OCDirectPairing> peer, const OCPrm_t& pmSel,
200 const std::string& pinNumber, DirectPairingCallback& resultCallback);
203 virtual OCStackResult ListenForMQTopic(
204 const OCDevAddr& devAddr,
205 const std::string& resourceUri,
206 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
207 MQTopicCallback& callback, QualityOfService QoS);
209 virtual OCStackResult PutMQTopicRepresentation(
210 const OCDevAddr& devAddr,
211 const std::string& uri,
212 const OCRepresentation& rep,
213 const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
214 MQTopicCallback& callback, QualityOfService QoS);
218 void listeningFunc();
219 std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
220 std::string assembleSetResourceUri(std::string uri, const QueryParamsList& queryParams);
221 OCPayload* assembleSetResourcePayload(const OCRepresentation& attributes);
222 OCHeaderOption* assembleHeaderOptions(OCHeaderOption options[],
223 const HeaderOptions& headerOptions);
224 void convert(const OCDPDev_t *list, PairedDevices& dpList);
225 std::thread m_listeningThread;
227 std::weak_ptr<std::recursive_mutex> m_csdkLock;
230 PlatformConfig m_cfg;