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 SubscribePresenceContext
  56         {
  57             SubscribeCallback callback;
  58         };
  59
  60         struct DeleteContext
  61         {
  62             DeleteCallback callback;
  63         };
  64
  65         struct ObserveContext
  66         {
  67             ObserveCallback callback;
  68         };
  69     }
  70
  71     class InProcClientWrapper : public IClientWrapper
  72     {
  73
  74     public:
  75
  76         InProcClientWrapper(std::weak_ptr<std::recursive_mutex> csdkLock,
  77                             PlatformConfig cfg);
  78         virtual ~InProcClientWrapper();
  79
  80         virtual OCStackResult ListenForResource(const std::string& serviceUrl,
  81             const std::string& resourceType, FindCallback& callback,
  82             QualityOfService QoS);
  83
  84         virtual OCStackResult GetResourceRepresentation(const std::string& host,
  85             const std::string& uri, const QueryParamsMap& queryParams,
  86             const HeaderOptions& headerOptions,
  87             GetCallback& callback, QualityOfService QoS);
  88
  89         virtual OCStackResult PutResourceRepresentation(const std::string& host,
  90             const std::string& uri, const OCRepresentation& attributes,
  91             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
  92             PutCallback& callback, QualityOfService QoS);
  93
  94         virtual OCStackResult PostResourceRepresentation(const std::string& host,
  95             const std::string& uri, const OCRepresentation& attributes,
  96             const QueryParamsMap& queryParams, const HeaderOptions& headerOptions,
  97             PostCallback& callback, QualityOfService QoS);
  98
  99         virtual OCStackResult DeleteResource(const std::string& host, const std::string& uri,
 100              const HeaderOptions& headerOptions, DeleteCallback& callback, QualityOfService QoS);
 101
 102         virtual OCStackResult ObserveResource(ObserveType observeType, OCDoHandle* handle,
 103             const std::string& host, const std::string& uri, const QueryParamsMap& queryParams,
 104             const HeaderOptions& headerOptions, ObserveCallback& callback, QualityOfService QoS);
 105
 106         virtual OCStackResult CancelObserveResource(OCDoHandle handle, const std::string& host,
 107             const std::string& uri, const HeaderOptions& headerOptions, QualityOfService QoS);
 108
 109         virtual OCStackResult SubscribePresence(OCDoHandle* handle, const std::string& host,
 110             const std::string& resourceType, SubscribeCallback& presenceHandler);
 111
 112         virtual OCStackResult UnsubscribePresence(OCDoHandle handle);
 113         OCStackResult GetDefaultQos(QualityOfService& QoS);
 114     private:
 115         void listeningFunc();
 116         std::string assembleSetResourceUri(std::string uri, const QueryParamsMap& queryParams);
 117         std::string assembleSetResourcePayload(const OCRepresentation& attributes);
 118         void assembleHeaderOptions(OCHeaderOption options[],
 119             const HeaderOptions& headerOptions);
 120         std::thread m_listeningThread;
 121         bool m_threadRun;
 122         std::weak_ptr<std::recursive_mutex> m_csdkLock;
 123
 124     private:
 125         PlatformConfig  m_cfg;
 126     };
 127 }
 128
 129 #endif