resource/examples/roomclient.cpp

   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 // OCClient.cpp : Defines the entry point for the console application.
  22 //
  23 #include <string>
  24 #include <cstdlib>
  25 #include <pthread.h>
  26 #include <mutex>
  27 #include <condition_variable>
  28
  29 #include "OCPlatform.h"
  30 #include "OCApi.h"
  31
  32 using namespace OC;
  33
  34 const int SUCCESS_RESPONSE = 0;
  35 std::shared_ptr<OCResource> curResource;
  36
  37 int observe_count()
  38 {
  39     static int oc = 0;
  40     return ++oc;
  41 }
  42
  43 // Forward declaration
  44 void putRoomRepresentation(std::shared_ptr<OCResource> resource);
  45 void onPut(const HeaderOptions& headerOptions, const OCRepresentation& rep, const int eCode);
  46
  47 void printRoomRepresentation(const OCRepresentation& rep)
  48 {
  49     std::cout << "\tResource URI: " << rep.getUri() << std::endl;
  50
  51     if(rep.hasAttribute("name"))
  52     {
  53         std::cout << "\tRoom name: " << rep.getValue<std::string>("name") << std::endl;
  54     }
  55
  56     std::vector<OCRepresentation> children = rep.getChildren();
  57
  58     for(auto oit = children.begin(); oit != children.end(); ++oit)
  59     {
  60         std::cout << "\t\tChild Resource URI: " << oit->getUri() << std::endl;
  61         if(oit->getUri().find("light") != std::string::npos)
  62         {
  63             if(oit->hasAttribute("state") && oit->hasAttribute("color"))
  64             {
  65                 std::cout << "\t\tstate:" << oit->getValue<bool>("state")  << std::endl;
  66                 std::cout << "\t\tcolor:" << oit->getValue<int>("color")  << std::endl;
  67             }
  68         }
  69         else if(oit->getUri().find("fan") != std::string::npos)
  70         {
  71             if(oit->hasAttribute("state") && oit->hasAttribute("speed"))
  72             {
  73                 std::cout << "\t\tstate:" << oit->getValue<bool>("state") << std::endl;
  74                 std::cout << "\t\tspeed:" << oit->getValue<int>("speed") << std::endl;
  75             }
  76         }
  77     }
  78 }
  79
  80 // callback handler on GET request
  81 void onGet(const HeaderOptions& headerOptions, const OCRepresentation& rep, const int eCode)
  82 {
  83     if(eCode == SUCCESS_RESPONSE)
  84     {
  85         std::cout << "GET request was successful" << std::endl;
  86
  87         printRoomRepresentation(rep);
  88
  89         putRoomRepresentation(curResource);
  90     }
  91     else
  92     {
  93         std::cout << "onGET Response error: " << eCode << std::endl;
  94         std::exit(-1);
  95     }
  96 }
  97
  98 void onGet1(const HeaderOptions& headerOptions, const OCRepresentation& rep, const int eCode)
  99 {
 100     if(eCode == SUCCESS_RESPONSE)
 101     {
 102         std::cout << "GET request was successful" << std::endl;
 103
 104         printRoomRepresentation(rep);
 105     }
 106     else
 107     {
 108         std::cout << "onGET Response error: " << eCode << std::endl;
 109         std::exit(-1);
 110     }
 111 }
 112
 113 // Local function to get representation of room resource
 114 void getRoomRepresentation(std::shared_ptr<OCResource> resource,
 115                             std::string interface, GetCallback getCallback)
 116 {
 117     if(resource)
 118     {
 119         std::cout << "Getting room representation on: "<< interface << std::endl;
 120
 121         resource->get("core.room", interface, QueryParamsMap(), getCallback);
 122     }
 123 }
 124
 125 // Local function to put a different state for this resource
 126 void putRoomRepresentation(std::shared_ptr<OCResource> resource)
 127 {
 128     if(resource)
 129     {
 130         OCRepresentation rep;
 131         std::cout << "Putting room representation on: " << BATCH_INTERFACE << std::endl;
 132
 133         bool state = true;
 134         int speed = 10;
 135         rep.setValue("state", state);
 136         rep.setValue("speed", speed);
 137
 138         // Invoke resource's pit API with attribute map, query map and the callback parameter
 139         resource->put("core.room", BATCH_INTERFACE, rep, QueryParamsMap(), &onPut);
 140     }
 141 }
 142
 143 // callback handler on PUT request
 144 void onPut(const HeaderOptions& headerOptions, const OCRepresentation& rep, const int eCode)
 145 {
 146     if(eCode == SUCCESS_RESPONSE)
 147     {
 148         std::cout << "PUT request was successful" << std::endl;
 149
 150         printRoomRepresentation(rep);
 151
 152         getRoomRepresentation(curResource, DEFAULT_INTERFACE, onGet1);
 153     }
 154     else
 155     {
 156         std::cout << "onPut Response error: " << eCode << std::endl;
 157         std::exit(-1);
 158     }
 159 }
 160
 161 // Callback to found resources
 162 void foundResource(std::shared_ptr<OCResource> resource)
 163 {
 164     if(curResource)
 165     {
 166         std::cout << "Found another resource, ignoring"<<std::endl;
 167         return;
 168     }
 169
 170     std::string resourceURI;
 171     std::string hostAddress;
 172     try
 173     {
 174         // Do some operations with resource object.
 175         if(resource)
 176         {
 177             std::cout<<"DISCOVERED Resource:"<<std::endl;
 178             // Get the resource URI
 179             resourceURI = resource->uri();
 180             std::cout << "\tURI of the resource: " << resourceURI << std::endl;
 181
 182             // Get the resource host address
 183             hostAddress = resource->host();
 184             std::cout << "\tHost address of the resource: " << hostAddress << std::endl;
 185
 186             // Get the resource types
 187             std::cout << "\tList of resource types: " << std::endl;
 188             for(auto &resourceTypes : resource->getResourceTypes())
 189             {
 190                 std::cout << "\t\t" << resourceTypes << std::endl;
 191             }
 192
 193             // Get the resource interfaces
 194             std::cout << "\tList of resource interfaces: " << std::endl;
 195             for(auto &resourceInterfaces : resource->getResourceInterfaces())
 196             {
 197                 std::cout << "\t\t" << resourceInterfaces << std::endl;
 198             }
 199
 200             if(resourceURI == "/a/room")
 201             {
 202                 curResource = resource;
 203                 // Call a local function which will internally invoke get API on the resource pointer
 204                 getRoomRepresentation(resource, BATCH_INTERFACE, onGet);
 205             }
 206         }
 207         else
 208         {
 209             // Resource is invalid
 210             std::cout << "Resource is invalid" << std::endl;
 211         }
 212
 213     }
 214     catch(std::exception& e)
 215     {
 216         //log(e.what());
 217     }
 218 }
 219
 220 int main(int argc, char* argv[]) {
 221
 222     // Create PlatformConfig object
 223     PlatformConfig cfg {
 224         OC::ServiceType::InProc,
 225         OC::ModeType::Client,
 226         "0.0.0.0",
 227         0,
 228         OC::QualityOfService::LowQos
 229     };
 230
 231     OCPlatform::Configure(cfg);
 232
 233     try
 234     {
 235         // Find all resources
 236         OCPlatform::findResource("", "coap://224.0.1.187/oc/core", &foundResource);
 237         std::cout<< "Finding Resource... " <<std::endl;
 238
 239         // A condition variable will free the mutex it is given, then do a non-
 240         // intensive block until 'notify' is called on it.  In this case, since we
 241         // don't ever call cv.notify, this should be a non-processor intensive version
 242         // of while(true);
 243         std::mutex blocker;
 244         std::condition_variable cv;
 245         std::unique_lock<std::mutex> lock(blocker);
 246         cv.wait(lock);
 247
 248     }catch(OCException& e)
 249     {
 250         //log(e.what());
 251     }
 252
 253     return 0;
 254 }
 255