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         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
  87             const std::string& resourceType, FindCallback& callback,
  88             QualityOfService QoS);
  89
  90         virtual OCStackResult ListenForDevice(const std::string& serviceUrl,
  91             const std::string& deviceURI, FindDeviceCallback& callback,
  92             QualityOfService QoS);
  93
  94         virtual OCStackResult GetResourceRepresentation(const std::string& host,
  95             const std::string& uri, const QueryParamsMap& queryParams,
  96             const HeaderOptions& headerOptions,
  97             GetCallback& callback, QualityOfService QoS);
  98
  99         virtual OCStackResult PutResourceRepresentation(const std::string& host,
 100             const std::string& uri, const OCRepresentation& attributes,
 101             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 102             PutCallback& callback, QualityOfService QoS);
 103
 104         virtual OCStackResult PostResourceRepresentation(const std::string& host,
 105             const std::string& uri, const OCRepresentation& attributes,
 106             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
 107             PostCallback& callback, QualityOfService QoS);
 108
 109         virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri,
 110              const HeaderOptions& headerOptions, DeleteCallback& callback, QualityOfService QoS);
 111
 112         virtual OCStackResult ObserveResource(ObserveType observeType, OCDoHandle* handle,
 113             const std::string& host, const std::string& uri, const QueryParamsMap& queryParams,
 114             const HeaderOptions& headerOptions, ObserveCallback& callback, QualityOfService QoS);
 115
 116         virtual OCStackResult CancelObserveResource(OCDoHandle handle, const std::string& host,
 117             const std::string& uri, const HeaderOptions& headerOptions, QualityOfService QoS);
 118
 119         virtual OCStackResult SubscribePresence(OCDoHandle* handle, const std::string& host,
 120             const std::string& resourceType, SubscribeCallback& presenceHandler);
 121
 122         virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
 123         OCStackResult GetDefaultQos(QualityOfService& QoS);
 124     private:
 125         void listeningFunc();
 126         std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
 127         std::string assembleSetResourcePayload(const OCRepresentation& attributes);
 128         void assembleHeaderOptions(OCHeaderOption options[],
 129             const HeaderOptions& headerOptions);
 130         std::thread m_listeningThread;
 131         bool m_threadRun;
 132         std::weak_ptr<std::recursive_mutex> m_csdkLock;
 133
 134     private:
 135         PlatformConfig  m_cfg;
 136     };
 137 }
 138
 139 #endif