Merge "[CA-Integration] Added connectivity type param in APIs" into connectivity...
[platform/upstream/iotivity.git] / resource / include / InProcClientWrapper.h
1 //******************************************************************
2 //
3 // Copyright 2014 Intel Mobile Communications GmbH All Rights Reserved.
4 //
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
6 //
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
10 //
11 //      http://www.apache.org/licenses/LICENSE-2.0
12 //
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.
18 //
19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
20
21 #ifndef _IN_PROC_CLIENT_WRAPPER_H_
22 #define _IN_PROC_CLIENT_WRAPPER_H_
23
24 #include <thread>
25 #include <mutex>
26 #include <sstream>
27 #include <iostream>
28
29 #include <OCApi.h>
30 #include <ocstack.h>
31 #include <IClientWrapper.h>
32 #include <InitializeException.h>
33 #include <ResourceInitException.h>
34
35 namespace OC
36 {
37     namespace ClientCallbackContext
38     {
39         struct GetContext
40         {
41             GetCallback callback;
42         };
43
44         struct SetContext
45         {
46             PutCallback callback;
47         };
48
49         struct ListenContext
50         {
51             FindCallback callback;
52             std::weak_ptr<IClientWrapper> clientWrapper;
53         };
54
55         struct DeviceListenContext
56         {
57             FindDeviceCallback callback;
58             IClientWrapper::Ptr clientWrapper;
59         };
60
61         struct SubscribePresenceContext
62         {
63             SubscribeCallback callback;
64         };
65
66         struct DeleteContext
67         {
68             DeleteCallback callback;
69         };
70
71         struct ObserveContext
72         {
73             ObserveCallback callback;
74         };
75     }
76
77     class InProcClientWrapper : public IClientWrapper
78     {
79
80     public:
81
82         InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
83                             PlatformConfig cfg);
84         virtual ~InProcClientWrapper();
85
86 #ifdef CA_INT
87         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
88             const std::string& resourceType, uint8_t connectivityType, FindCallback& callback,
89             QualityOfService QoS);
90
91         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
92             const std::string& deviceURI, uint8_t connectivityType, FindDeviceCallback& callback,
93             QualityOfService QoS);
94
95         virtual OCStackResult GetResourceRepresentation(const std::string& host,
96             const std::string& uri, uint8_t connectivityType, const QueryParamsMap& queryParams,
97             const HeaderOptions& headerOptions,
98             GetCallback& callback, QualityOfService QoS);
99
100         virtual OCStackResult PutResourceRepresentation(const std::string& host,
101             const std::string& uri, uint8_t connectivityType, const OCRepresentation& attributes,
102             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
103             PutCallback& callback, QualityOfService QoS);
104
105         virtual OCStackResult PostResourceRepresentation(const std::string& host,
106             const std::string& uri, uint8_t connectivityType, const OCRepresentation& attributes,
107             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
108             PostCallback& callback, QualityOfService QoS);
109
110         virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri,
111             uint8_t connectivityType, const HeaderOptions& headerOptions,
112             DeleteCallback& callback, QualityOfService QoS);
113
114         virtual OCStackResult ObserveResource(ObserveType observeType, OCDoHandle* handle,
115             const std::string& host, const std::string& uri, uint8_t connectivityType,
116             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
117             ObserveCallback& callback, QualityOfService QoS);
118 #else
119         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
120             const std::string& resourceType, FindCallback& callback,
121             QualityOfService QoS);
122
123         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
124             const std::string& deviceURI, FindDeviceCallback& callback,
125             QualityOfService QoS);
126
127         virtual OCStackResult GetResourceRepresentation(const std::string& host,
128             const std::string& uri, const QueryParamsMap& queryParams,
129             const HeaderOptions& headerOptions,
130             GetCallback& callback, QualityOfService QoS);
131
132         virtual OCStackResult PutResourceRepresentation(const std::string& host,
133             const std::string& uri, const OCRepresentation& attributes,
134             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
135             PutCallback& callback, QualityOfService QoS);
136
137         virtual OCStackResult PostResourceRepresentation(const std::string& host,
138             const std::string& uri, const OCRepresentation& attributes,
139             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
140             PostCallback& callback, QualityOfService QoS);
141
142         virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri,
143              const HeaderOptions& headerOptions, DeleteCallback& callback, QualityOfService QoS);
144
145         virtual OCStackResult ObserveResource(ObserveType observeType, OCDoHandle* handle,
146             const std::string& host, const std::string& uri, const QueryParamsMap& queryParams,
147             const HeaderOptions& headerOptions, ObserveCallback& callback, QualityOfService QoS);
148 #endif
149         virtual OCStackResult CancelObserveResource(OCDoHandle handle, const std::string& host,
150             const std::string& uri, const HeaderOptions& headerOptions, QualityOfService QoS);
151
152 #ifdef CA_INT
153         virtual OCStackResult SubscribePresence(OCDoHandle* handle, const std::string& host,
154             const std::string& resourceType, uint8_t connectivityType,
155             SubscribeCallback& presenceHandler);
156 #else
157         virtual OCStackResult SubscribePresence(OCDoHandle* handle, const std::string& host,
158             const std::string& resourceType, SubscribeCallback& presenceHandler);
159 #endif
160
161         virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
162         OCStackResult GetDefaultQos(QualityOfService& QoS);
163     private:
164         void listeningFunc();
165         std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
166         std::string assembleSetResourcePayload(const OCRepresentation& attributes);
167         void assembleHeaderOptions(OCHeaderOption options[],
168             const HeaderOptions& headerOptions);
169         std::thread m_listeningThread;
170         bool m_threadRun;
171         std::weak_ptr<std::recursive_mutex> m_csdkLock;
172
173     private:
174         PlatformConfig  m_cfg;
175     };
176 }
177
178 #endif