service/notification/cpp-wrapper/examples/linux/notificationserviceprovider.cpp

   1 /******************************************************************\r
   2  *\r
   3  * Copyright 2016 Samsung Electronics All Rights Reserved.\r
   4  *\r
   5  *\r
   6  *\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  *\r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  *\r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  *\r
  19  ******************************************************************/\r
  20 \r
  21 // std\r
  22 #include <iostream>\r
  23 #include <stdlib.h>\r
  24 #include <cstdint>\r
  25 #include <limits>\r
  26 \r
  27 // ns\r
  28 #include "NSCommon.h"\r
  29 #include "NSProviderService.h"\r
  30 #include "NSUtils.h"\r
  31 #include "NSTopicsList.h"\r
  32 \r
  33 // base\r
  34 #include "logger.h"\r
  35 #include "octypes.h"\r
  36 #include "oic_string.h"\r
  37 #include "oic_malloc.h"\r
  38 #include "ocstack.h"\r
  39 \r
  40 // external\r
  41 #include "pthread.h"\r
  42 \r
  43 #define TAG "NotiProviderWrapperExample"\r
  44 using namespace std;\r
  45 using namespace OIC::Service;\r
  46 std::vector<std::string> discoveredConsumers;\r
  47 uint64_t mainMessageId = 0;\r
  48 \r
  49 extern char *strdup(const char *s);\r
  50 \r
  51 bool isExit = false;\r
  52 \r
  53 int id = 0;\r
  54 std::string REMOTE_SERVER_ADDRESS;\r
  55 \r
  56 void *OCProcessThread(void *ptr)\r
  57 {\r
  58     (void) ptr;\r
  59     while (!isExit)\r
  60     {\r
  61         usleep(2000);\r
  62         if (OCProcess() != OC_STACK_OK)\r
  63         {\r
  64             std::cout << "OCStack process error" << std::endl;\r
  65             return NULL;\r
  66         }\r
  67     }\r
  68 \r
  69     return NULL;\r
  70 }\r
  71 \r
  72 void subscribeRequestCallback(OIC::Service::NSConsumer *consumer)\r
  73 {\r
  74     std::cout << "consumer requested to subscribe" << std::endl;\r
  75 \r
  76     std::cout << "Consumer Device ID: " << consumer->getConsumerId() << std::endl;\r
  77     discoveredConsumers.push_back(consumer->getConsumerId());\r
  78     consumer->acceptSubscription(true);\r
  79 }\r
  80 \r
  81 void syncCallback(OIC::Service::NSSyncInfo *sync)\r
  82 {\r
  83     std::cout << "SyncInfo Received " << std::endl;\r
  84     std::cout << "Sync ID : " <<  sync->getMessageId() << std::endl;\r
  85     std::cout << "Provider ID : " <<  sync->getProviderId() << std::endl;\r
  86     std::cout << "Sync State: " << (int) sync->getState() << std::endl;\r
  87 }\r
  88 \r
  89 OIC::Service::NSConsumer *printAvailableConsumers()\r
  90 {\r
  91     std::cout << "Choose the Consumer ID for operation" << std::endl;\r
  92     int pos = 1;\r
  93     unsigned int option = 0;\r
  94     for (auto it : discoveredConsumers)\r
  95     {\r
  96         std::cout << pos << ". " << it << std::endl;\r
  97         pos++;\r
  98     }\r
  99     while (!(std::cin >> option))\r
 100     {\r
 101         std::cout << "Bad value!" << std::endl;;\r
 102         std::cin.clear();\r
 103         std::cin.ignore(numeric_limits<streamsize>::max(), '\n');\r
 104     }\r
 105     option--;\r
 106     if (option > discoveredConsumers.size())\r
 107     {\r
 108         return NULL;\r
 109     }\r
 110     std::string consumerId = discoveredConsumers[option];\r
 111     OIC::Service::NSConsumer *consumer = NSProviderService::getInstance()->getConsumer(\r
 112             consumerId);\r
 113     return consumer;\r
 114 }\r
 115 \r
 116 int main()\r
 117 {\r
 118     int num = 0;\r
 119     pthread_t processThread = 0;\r
 120 \r
 121     std::cout << "start Iotivity" << std::endl;\r
 122 \r
 123 \r
 124     if (OCInit(NULL, 0, OC_CLIENT_SERVER) != OC_STACK_OK)\r
 125     {\r
 126         std::cout << "OCStack init error" << std::endl;\r
 127         return 0;\r
 128     }\r
 129 \r
 130     pthread_create(&processThread, NULL, OCProcessThread, NULL);\r
 131 \r
 132     while (!isExit)\r
 133     {\r
 134         std::cout << "1. Start the Notification Provider(Accepter: Provider)" << std::endl;\r
 135         std::cout << "2. Start the Notification Provider(Accepter: Consumer)" << std::endl;\r
 136         std::cout << "3. Allow Subscription" << std::endl;\r
 137         std::cout << "4. Deny Subscription" << std::endl;\r
 138         std::cout << "5. SendMessage " << std::endl;\r
 139         std::cout << "6. SendSyncInfo" << std::endl;\r
 140 \r
 141         std::cout << "7. RegisterTopic" << std::endl;\r
 142         std::cout << "8. UnregisterTopic" << std::endl;\r
 143         std::cout << "9. SetTopic" << std::endl;\r
 144         std::cout << "10. UnsetTopic" << std::endl;\r
 145         std::cout << "11. GetConsumerTopicList" << std::endl;\r
 146         std::cout << "12. GetRegisteredTopicList" << std::endl;\r
 147 #ifdef WITH_CLOUD\r
 148         std::cout << "13. Enable NS Provider RemoteService" << std::endl;\r
 149         std::cout << "14. Disable NS Provider RemoteService" << std::endl;\r
 150 #endif\r
 151         std::cout << "15. Stop the Notification Provider" << std::endl;\r
 152         std::cout << "16. Exit()" << std::endl;\r
 153 \r
 154         std::cout << "input : ";\r
 155 \r
 156         std::cin >> num;\r
 157 \r
 158         switch (num)\r
 159         {\r
 160             case 1:\r
 161                 {\r
 162                     std::cout << "Start (Accepter: Provider)" << std::endl;\r
 163                     NSProviderService::ProviderConfig cfg;\r
 164                     cfg.m_subscribeRequestCb = subscribeRequestCallback;\r
 165                     cfg.m_syncInfoCb = syncCallback;\r
 166                     cfg.subControllability = true;\r
 167 \r
 168                     NSProviderService::getInstance()->start(cfg);\r
 169                     break;\r
 170                 }\r
 171             case 2:\r
 172                 {\r
 173                     std::cout << "Start (Accepter: Consumer)" << std::endl;\r
 174                     NSProviderService::ProviderConfig cfg;\r
 175                     cfg.m_subscribeRequestCb = subscribeRequestCallback;\r
 176                     cfg.m_syncInfoCb = syncCallback;\r
 177                     cfg.subControllability = false;\r
 178 \r
 179                     NSProviderService::getInstance()->start(cfg);\r
 180                     break;\r
 181                 }\r
 182             case 3:\r
 183                 {\r
 184                     std::cout << "Allow Subscription" << std::endl;\r
 185                     OIC::Service::NSConsumer *consumer = printAvailableConsumers();\r
 186                     if (consumer != nullptr)\r
 187                     {\r
 188                         std::cout << "ALLOW" << std::endl;\r
 189                         consumer->acceptSubscription(true);\r
 190                     }\r
 191                     break;\r
 192                 }\r
 193             case 4:\r
 194                 {\r
 195                     std::cout << "Deny Subscription" << std::endl;\r
 196                     OIC::Service::NSConsumer *consumer = printAvailableConsumers();\r
 197                     if (consumer != nullptr)\r
 198                     {\r
 199                         std::cout << "DENY" << std::endl;\r
 200                         consumer->acceptSubscription(false);\r
 201                     }\r
 202                     break;\r
 203                 }\r
 204             case 5:\r
 205                 {\r
 206                     std::cout << "------------------------------------" << std::endl;\r
 207                     std::cout << "SendMessage" << std::endl;\r
 208                     std::cout << "------------------------------------" << std::endl;\r
 209 \r
 210                     std::string dummy;\r
 211                     std::string title;\r
 212                     std::string body;\r
 213                     std::string topic;\r
 214 \r
 215                     std::cout << "id : " << ++id << std::endl;\r
 216                     std::cout << "title : ";\r
 217 \r
 218                     std::getline(std::cin, dummy);\r
 219                     std::getline(std::cin, title);\r
 220 \r
 221                     std::cout << "body : ";\r
 222                     std::getline(std::cin, body);\r
 223 \r
 224                     std::cout << "topic : ";\r
 225                     std::getline(std::cin, topic);\r
 226 \r
 227                     std::cout << "app - mTitle : " << title << std::endl;\r
 228                     std::cout << "app - mContentText : " << body << std::endl;\r
 229                     std::cout << "app - mTopic : " << topic << std::endl;\r
 230 \r
 231                     OIC::Service::NSMessage *msg = NSProviderService::getInstance()->createMessage();\r
 232 \r
 233                     msg->setType(OIC::Service::NSMessage::NSMessageType::NS_MESSAGE_INFO);\r
 234                     msg->setTitle(title.c_str());\r
 235                     msg->setContentText(body.c_str());\r
 236                     msg->setSourceName("OCF");\r
 237                     msg->setTopic(topic);\r
 238                     msg->setTTL(40);\r
 239                     msg->setTime("12:30");\r
 240                     OIC::Service::NSMediaContents *mediaContents =\r
 241                         new OIC::Service::NSMediaContents("iconImage");\r
 242                     msg->setMediaContents(mediaContents);\r
 243 \r
 244                     OC::OCRepresentation rep;\r
 245                     rep.setValue("Key1", "Value1");\r
 246                     rep.setValue("Key2", "Value2");\r
 247                     msg->setExtraInfo(rep);\r
 248 \r
 249                     mainMessageId = msg->getMessageId();\r
 250                     std::cout << "ProviderID for Message : " << msg->getProviderId() << std::endl;\r
 251                     std::cout << "MessageID for Message : " << msg->getMessageId() << std::endl;\r
 252 \r
 253                     NSProviderService::getInstance()->sendMessage(msg);\r
 254                     delete msg;\r
 255                     break;\r
 256                 }\r
 257             case 6:\r
 258                 {\r
 259                     std::cout << "------------------------------------" << std::endl;\r
 260                     std::cout <<  "SendSyncInfo" << std::endl;\r
 261                     std::cout << "------------------------------------" << std::endl;\r
 262                     if (!mainMessageId)\r
 263                     {\r
 264                         std::cout <<  "Message ID is empty" << std::endl;\r
 265                         break;\r
 266                     }\r
 267                     std::cout << "1. Send Read Sync" << std::endl;\r
 268                     std::cout << "2. Send Delete Sync" << std::endl;\r
 269                     int syn = 0;\r
 270                     while (!(std::cin >> syn))\r
 271                     {\r
 272                         std::cout << "Bad value!" << std::endl;;\r
 273                         std::cin.clear();\r
 274                         std::cin.ignore(numeric_limits<streamsize>::max(), '\n');\r
 275                     }\r
 276                     switch (syn)\r
 277                     {\r
 278                         case 1:\r
 279                             {\r
 280                                 std::cout << "Sending Read Sync" << std::endl;\r
 281                                 NSProviderService::getInstance()->sendSyncInfo(mainMessageId,\r
 282                                         OIC::Service::NSSyncInfo::NSSyncType::NS_SYNC_READ);\r
 283                             }\r
 284                             break;\r
 285                         case 2:\r
 286                             {\r
 287                                 std::cout << "Sending Delete Sync" << std::endl;\r
 288                                 NSProviderService::getInstance()->sendSyncInfo(mainMessageId,\r
 289                                         OIC::Service::NSSyncInfo::NSSyncType::NS_SYNC_DELETED);\r
 290                             }\r
 291                             break;\r
 292                         default:\r
 293                             {\r
 294                                 cout << "Invalid Input!. sending default Read Sync";\r
 295                                 NSProviderService::getInstance()->sendSyncInfo(mainMessageId,\r
 296                                         OIC::Service::NSSyncInfo::NSSyncType::NS_SYNC_READ);\r
 297                                 std::cin.clear();\r
 298                                 std::cin.ignore(numeric_limits<streamsize>::max(), '\n');\r
 299                                 break;\r
 300                             }\r
 301                     }\r
 302                     break;\r
 303                 }\r
 304 \r
 305             case 7:\r
 306                 {\r
 307                     std::cout <<  "RegisterTopic" << std::endl;\r
 308                     NSProviderService::getInstance()->registerTopic("OCF_TOPIC1");\r
 309                     NSProviderService::getInstance()->registerTopic("OCF_TOPIC2");\r
 310                     NSProviderService::getInstance()->registerTopic("OCF_TOPIC3");\r
 311                     NSProviderService::getInstance()->registerTopic("OCF_TOPIC4");\r
 312                     break;\r
 313                 }\r
 314             case 8:\r
 315                 {\r
 316                     std::cout <<  "UnregisterTopic" << std::endl;\r
 317                     NSProviderService::getInstance()->unregisterTopic("OCF_TOPIC2");\r
 318                     break;\r
 319                 }\r
 320             case 9:\r
 321                 {\r
 322                     std::cout <<  "SetTopic" << std::endl;\r
 323                     OIC::Service::NSConsumer *consumer = printAvailableConsumers();\r
 324                     if (consumer != nullptr)\r
 325                     {\r
 326                         consumer->setTopic("OCF_TOPIC1");\r
 327                         consumer->setTopic("OCF_TOPIC2");\r
 328                         consumer->setTopic("OCF_TOPIC3");\r
 329                         std::cout <<  "SelectTopic completed" << std::endl;\r
 330                     }\r
 331                     break;\r
 332                 }\r
 333             case 10:\r
 334                 {\r
 335                     std::cout <<  "UnsetTopic" << std::endl;\r
 336                     OIC::Service::NSConsumer *consumer = printAvailableConsumers();\r
 337                     if (consumer != nullptr)\r
 338                     {\r
 339                         consumer->unsetTopic("OCF_TOPIC1");\r
 340                         std::cout <<  "UnSelectTopic completed" << std::endl;\r
 341                     }\r
 342                     break;\r
 343                 }\r
 344                 break;\r
 345 \r
 346             case 11:\r
 347                 {\r
 348                     std::cout <<  "GetConsumerTopicList" << std::endl;\r
 349                     OIC::Service::NSConsumer *consumer = printAvailableConsumers();\r
 350                     if (consumer != nullptr)\r
 351                     {\r
 352                         auto nsTopics = consumer->getConsumerTopicList();\r
 353                         if (nsTopics != nullptr)\r
 354                         {\r
 355                             for (auto it : nsTopics->getTopicsList())\r
 356                             {\r
 357 \r
 358                                 std::cout << it->getTopicName() << std::endl;\r
 359                                 std::cout << (int) it->getState() << std::endl;\r
 360                             }\r
 361                             delete nsTopics;\r
 362                         }\r
 363                         std::cout <<  "GetConsumerTopicList completed" << std::endl;\r
 364                     }\r
 365                 }\r
 366                 break;\r
 367 \r
 368             case 12:\r
 369                 {\r
 370                     std::cout <<  "GetRegisteredTopicList" << std::endl;\r
 371                     auto nsTopics = NSProviderService::getInstance()->getRegisteredTopicList();\r
 372                     for (auto it : nsTopics->getTopicsList())\r
 373                     {\r
 374 \r
 375                         std::cout << it->getTopicName() << std::endl;\r
 376                         std::cout << (int) it->getState() << std::endl;\r
 377                     }\r
 378                     delete nsTopics;\r
 379                 }\r
 380                 break;\r
 381 #ifdef WITH_CLOUD\r
 382             case 13:\r
 383                 {\r
 384                     std::cout << "Enable NS Provider RemoteService" << std::endl;\r
 385                     std::cout << "Input the Server Address :";\r
 386                     std::cin >> REMOTE_SERVER_ADDRESS;\r
 387                     NSProviderService::getInstance()->enableRemoteService(REMOTE_SERVER_ADDRESS);\r
 388                     break;\r
 389                 }\r
 390             case 14:\r
 391                 {\r
 392                     std::cout << "Disable NS Provider RemoteService" << std::endl;\r
 393                     std::cout << "Input the Server Address :";\r
 394                     NSProviderService::getInstance()->disableRemoteService(REMOTE_SERVER_ADDRESS);\r
 395                     break;\r
 396                 }\r
 397 #endif\r
 398             case 15:\r
 399                 {\r
 400                     std::cout << "Stop the Notification Provider" << std::endl;\r
 401                     NSProviderService::getInstance()->stop();\r
 402                     break;\r
 403                 }\r
 404             case 16:\r
 405                 {\r
 406                     std::cout << "Exit()" << std::endl;\r
 407                     NSProviderService::getInstance()->stop();\r
 408                     isExit = true;\r
 409                     break;\r
 410                 }\r
 411             default:\r
 412                 {\r
 413                     std::cout << "Under Construction" << std::endl;\r
 414                     std::cin.clear();\r
 415                     std::cin.ignore(numeric_limits<streamsize>::max(), '\n');\r
 416                     break;\r
 417                 }\r
 418         }\r
 419 \r
 420         std::cout << std::endl;\r
 421     }\r
 422 \r
 423     return 0;\r
 424 }\r