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, OCConnectivityType connectivityType,
  89             FindCallback& callback, QualityOfService QoS);
  90
  91         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
  92             const std::string& deviceURI, OCConnectivityType connectivityType,
  93             FindDeviceCallback& callback, QualityOfService QoS);
  94
  95         virtual OCStackResult GetResourceRepresentation(const std::string& host,
  96             const std::string& uri, OCConnectivityType connectivityType,
  97             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
  98             GetCallback& callback, QualityOfService QoS);
  99
 100         virtual OCStackResult PutResourceRepresentation(const std::string& host,
 101             const std::string& uri, OCConnectivityType connectivityType,
 102             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
 103             const HeaderOptions& headerOptions, PutCallback& callback, QualityOfService QoS);
 104
 105         virtual OCStackResult PostResourceRepresentation(const std::string& host,
 106             const std::string& uri, OCConnectivityType connectivityType,
 107             const OCRepresentation& attributes, const QueryParamsMap& queryParams,
 108             const HeaderOptions& headerOptions, PostCallback& callback, QualityOfService QoS);
 109
 110         virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri,
 111             OCConnectivityType 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, OCConnectivityType 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, OCConnectivityType 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