CBOR rebase onto master for merge/review
[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 <IClientWrapper.h>
31 #include <InitializeException.h>
32 #include <ResourceInitException.h>
33
34 namespace OC
35 {
36     namespace ClientCallbackContext
37     {
38         struct GetContext
39         {
40             GetCallback callback;
41             GetContext(GetCallback cb) : callback(cb){}
42         };
43
44         struct SetContext
45         {
46             PutCallback callback;
47             SetContext(PutCallback cb) : callback(cb){}
48         };
49
50         struct ListenContext
51         {
52             FindCallback callback;
53             std::weak_ptr<IClientWrapper> clientWrapper;
54
55             ListenContext(FindCallback cb, std::weak_ptr<IClientWrapper> cw)
56                 : callback(cb), clientWrapper(cw){}
57         };
58
59         struct DeviceListenContext
60         {
61             FindDeviceCallback callback;
62             IClientWrapper::Ptr clientWrapper;
63             DeviceListenContext(FindDeviceCallback cb, IClientWrapper::Ptr cw)
64                     : callback(cb), clientWrapper(cw){}
65         };
66
67         struct SubscribePresenceContext
68         {
69             SubscribeCallback callback;
70             SubscribePresenceContext(SubscribeCallback cb) : callback(cb){}
71         };
72
73         struct DeleteContext
74         {
75             DeleteCallback callback;
76             DeleteContext(DeleteCallback cb) : callback(cb){}
77         };
78
79         struct ObserveContext
80         {
81             ObserveCallback callback;
82             ObserveContext(ObserveCallback cb) : callback(cb){}
83         };
84     }
85
86     class InProcClientWrapper : public IClientWrapper
87     {
88
89     public:
90
91         InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
92                             PlatformConfig cfg);
93         virtual ~InProcClientWrapper();
94
95         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
96             const std::string& resourceType, OCConnectivityType transportFlags,
97             FindCallback& callback, QualityOfService QoS);
98
99         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
100             const std::string& deviceURI, OCConnectivityType transportFlags,
101             FindDeviceCallback& callback, QualityOfService QoS);
102
103         virtual OCStackResult GetResourceRepresentation(
104             const OCDevAddr& devAddr,
105             const std::string& uri,
106             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
107             GetCallback& callback, QualityOfService QoS);
108
109         virtual OCStackResult PutResourceRepresentation(
110             const OCDevAddr& devAddr,
111             const std::string& uri,
112             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
113             const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS);
114
115         virtual OCStackResult PostResourceRepresentation(
116             const OCDevAddr& devAddr,
117             const std::string& uri,
118             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
119             const HeaderOptions& headerOptions, PostCallback& callback, QualityOfService QoS);
120
121         virtual OCStackResult DeleteResource(
122             const OCDevAddr& devAddr,
123             const std::string& uri,
124             const HeaderOptions& headerOptions,
125             DeleteCallback& callback, QualityOfService QoS);
126
127         virtual OCStackResult ObserveResource(
128             ObserveType observeType, OCDoHandle* handle,
129             const OCDevAddr& devAddr,
130             const std::string& uri,
131             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
132             ObserveCallback& callback, QualityOfService QoS);
133
134         virtual OCStackResult CancelObserveResource(
135             OCDoHandle handle,
136             const std::string& host,
137             const std::string& uri,
138             const HeaderOptions& headerOptions, QualityOfService QoS);
139
140         virtual OCStackResult SubscribePresence(
141             OCDoHandle *handle,
142             const std::string& host,
143             const std::string& resourceType,
144             OCConnectivityType transportFlags,
145             SubscribeCallback& presenceHandler);
146
147         virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
148         OCStackResult GetDefaultQos(QualityOfService& QoS);
149     private:
150         void listeningFunc();
151         std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
152         OCPayload* assembleSetResourcePayload(const OCRepresentation& attributes);
153         OCHeaderOption* assembleHeaderOptions(OCHeaderOption options[],
154            const HeaderOptions& headerOptions);
155         std::thread m_listeningThread;
156         bool m_threadRun;
157         std::weak_ptr<std::recursive_mutex> m_csdkLock;
158
159     private:
160         PlatformConfig  m_cfg;
161     };
162 }
163
164 #endif
165