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 OC_IN_PROC_CLIENT_WRAPPER_H_
  22 #define OC_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 ListenErrorContext
  60         {
  61             FindCallback callback;
  62             FindErrorCallback errorCallback;
  63             std::weak_ptr<IClientWrapper> clientWrapper;
  64
  65             ListenErrorContext(FindCallback cb1, FindErrorCallback cb2,
  66                                std::weak_ptr<IClientWrapper> cw)
  67                 : callback(cb1), errorCallback(cb2), clientWrapper(cw){}
  68         };
  69
  70         struct DeviceListenContext
  71         {
  72             FindDeviceCallback callback;
  73             IClientWrapper::Ptr clientWrapper;
  74             DeviceListenContext(FindDeviceCallback cb, IClientWrapper::Ptr cw)
  75                     : callback(cb), clientWrapper(cw){}
  76         };
  77
  78         struct SubscribePresenceContext
  79         {
  80             SubscribeCallback callback;
  81             SubscribePresenceContext(SubscribeCallback cb) : callback(cb){}
  82         };
  83
  84         struct DeleteContext
  85         {
  86             DeleteCallback callback;
  87             DeleteContext(DeleteCallback cb) : callback(cb){}
  88         };
  89
  90         struct ObserveContext
  91         {
  92             ObserveCallback callback;
  93             ObserveContext(ObserveCallback cb) : callback(cb){}
  94         };
  95
  96         struct DirectPairingContext
  97         {
  98             DirectPairingCallback callback;
  99             DirectPairingContext(DirectPairingCallback cb) : callback(cb){}
 100
 101         };
 102
 103 #ifdef WITH_MQ
 104         struct CreateMQTopicContext
 105         {
 106             MQCreateTopicCallback callback;
 107             std::weak_ptr<IClientWrapper> clientWrapper;
 108             CreateMQTopicContext(MQCreateTopicCallback cb, std::weak_ptr<IClientWrapper> cw)
 109                 : callback(cb), clientWrapper(cw){}
 110         };
 111 #endif
 112     }
 113
 114     class InProcClientWrapper : public IClientWrapper
 115     {
 116
 117     public:
 118
 119         InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
 120                             PlatformConfig cfg);
 121         virtual ~InProcClientWrapper();
 122
 123         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
 124             const std::string& resourceType, OCConnectivityType transportFlags,
 125             FindCallback& callback, QualityOfService QoS);
 126
 127         virtual OCStackResult ListenErrorForResource(const std::string& serviceUrl,
 128             const std::string& resourceType, OCConnectivityType transportFlags,
 129             FindCallback& callback, FindErrorCallback& errorCallback, QualityOfService QoS);
 130
 131         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
 132             const std::string& deviceURI, OCConnectivityType transportFlags,
 133             FindDeviceCallback& callback, QualityOfService QoS);
 134
 135         virtual OCStackResult GetResourceRepresentation(
 136             const OCDevAddr& devAddr,
 137             const std::string& uri,
 138             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 139             GetCallback& callback, QualityOfService QoS);
 140
 141         virtual OCStackResult PutResourceRepresentation(
 142             const OCDevAddr& devAddr,
 143             const std::string& uri,
 144             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
 145             const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS);
 146
 147         virtual OCStackResult PostResourceRepresentation(
 148             const OCDevAddr& devAddr,
 149             const std::string& uri,
 150             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
 151             const HeaderOptions& headerOptions, OCConnectivityType connectivityType,
 152             PostCallback& callback, QualityOfService QoS);
 153
 154         virtual OCStackResult DeleteResource(
 155             const OCDevAddr& devAddr,
 156             const std::string& uri,
 157             const HeaderOptions& headerOptions,
 158             DeleteCallback& callback, QualityOfService QoS);
 159
 160         virtual OCStackResult ObserveResource(
 161             ObserveType observeType, OCDoHandle* handle,
 162             const OCDevAddr& devAddr,
 163             const std::string& uri,
 164             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 165             ObserveCallback& callback, QualityOfService QoS);
 166
 167         virtual OCStackResult CancelObserveResource(
 168             OCDoHandle handle,
 169             const std::string& host,
 170             const std::string& uri,
 171             const HeaderOptions& headerOptions, QualityOfService QoS);
 172
 173         virtual OCStackResult SubscribePresence(
 174             OCDoHandle *handle,
 175             const std::string& host,
 176             const std::string& resourceType,
 177             OCConnectivityType transportFlags,
 178             SubscribeCallback& presenceHandler);
 179
 180         virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
 181
 182         virtual OCStackResult SubscribeDevicePresence(OCDoHandle* handle,
 183                                                       const std::string& host,
 184                                                       const QueryParamsList& queryParams,
 185                                                       OCConnectivityType connectivityType,
 186                                                       ObserveCallback& callback);
 187
 188         OCStackResult GetDefaultQos(QualityOfService& QoS);
 189
 190         virtual OCStackResult FindDirectPairingDevices(unsigned short waittime,
 191                        GetDirectPairedCallback& callback);
 192
 193         virtual OCStackResult GetDirectPairedDevices(GetDirectPairedCallback& callback);
 194
 195         virtual OCStackResult DoDirectPairing(std::shared_ptr<OCDirectPairing> peer, const OCPrm_t& pmSel,
 196                 const std::string& pinNumber, DirectPairingCallback& resultCallback);
 197
 198 #ifdef WITH_MQ
 199         virtual OCStackResult ListenForMQTopic(
 200             const OCDevAddr& devAddr,
 201             const std::string& resourceUri,
 202             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 203             FindCallback& callback, QualityOfService QoS);
 204
 205         virtual OCStackResult PutMQTopicRepresentation(
 206             const OCDevAddr& devAddr,
 207             const std::string& uri,
 208             const OCRepresentation& rep,
 209             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 210             MQCreateTopicCallback& callback, QualityOfService QoS);
 211 #endif
 212
 213     private:
 214         void listeningFunc();
 215         std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
 216         std::string assembleSetResourceUri(std::string uri, const QueryParamsList& queryParams);
 217         OCPayload* assembleSetResourcePayload(const OCRepresentation& attributes);
 218         OCHeaderOption* assembleHeaderOptions(OCHeaderOption options[],
 219            const HeaderOptions& headerOptions);
 220         void convert(const OCDPDev_t *list, PairedDevices& dpList);
 221         std::thread m_listeningThread;
 222         bool m_threadRun;
 223         std::weak_ptr<std::recursive_mutex> m_csdkLock;
 224
 225     private:
 226         PlatformConfig  m_cfg;
 227     };
 228 }
 229
 230 #endif
 231