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