resource/src/CAManager.cpp

   1 /* ****************************************************************
   2  *
   3  * Copyright 2016 Samsung Electronics 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 /**
  22  * @file
  23  *
  24  * This file contains the implementation of classes and its members related
  25  * to CAManager. Network changes status will be passed from CA to application.
  26  */
  27
  28 #include "OCApi.h"
  29 #include "CAManager.h"
  30 #include "cautilinterface.h"
  31 #include "casecurityinterface.h"
  32 #include "logger.h"
  33
  34 #define TAG "OIC_CAMANAGER"
  35
  36 using namespace OC;
  37 namespace
  38 {
  39         CAManager::AdapterChangedCallback g_adapterHandler = nullptr;
  40         CAManager::ConnectionChangedCallback g_connectionHandler = nullptr;
  41 }
  42
  43 OCStackResult convertCAResultToOCResult(CAResult_t caResult)
  44 {
  45     switch (caResult)
  46     {
  47         case CA_STATUS_OK:
  48             return OC_STACK_OK;
  49         case CA_STATUS_INVALID_PARAM:
  50             return OC_STACK_INVALID_PARAM;
  51         case CA_STATUS_FAILED:
  52             return OC_STACK_ERROR;
  53         case CA_NOT_SUPPORTED:
  54             return OC_STACK_NOTIMPL;
  55         default:
  56             return OC_STACK_ERROR;
  57     }
  58 }
  59
  60 void DefaultAdapterStateChangedHandler(CATransportAdapter_t adapter, bool enabled)
  61 {
  62     if (g_adapterHandler)
  63     {
  64         g_adapterHandler((OCTransportAdapter) adapter, enabled);
  65     }
  66 }
  67
  68 void DefaultConnectionStateChangedHandler(const CAEndpoint_t *info, bool isConnected)
  69 {
  70     if (g_connectionHandler)
  71     {
  72         std::ostringstream ss;
  73
  74         if (info->flags & CA_IPV6)
  75         {
  76             ss << '[' << info->addr << ']';
  77         }
  78         else
  79         {
  80             ss << info->addr;
  81         }
  82         if (info->port)
  83         {
  84             ss << ':' << info->port;
  85         }
  86
  87         OCTransportAdapter adapter = (OCTransportAdapter)info->adapter;
  88         OCTransportFlags flags = (OCTransportFlags)info->flags;
  89         OCConnectivityType connType = (OCConnectivityType)
  90                 ((adapter << CT_ADAPTER_SHIFT) | (flags & CT_MASK_FLAGS));
  91
  92         g_connectionHandler(ss.str(), connType, isConnected);
  93     }
  94 }
  95
  96 OCStackResult CAManager::setNetworkMonitorHandler(AdapterChangedCallback adapterHandler,
  97                                                   ConnectionChangedCallback connectionHandler)
  98 {
  99     g_adapterHandler = adapterHandler;
 100     g_connectionHandler = connectionHandler;
 101
 102     CAResult_t ret = CARegisterNetworkMonitorHandler(DefaultAdapterStateChangedHandler,
 103                                                      DefaultConnectionStateChangedHandler);
 104
 105     return convertCAResultToOCResult(ret);
 106 }
 107
 108 OCStackResult CAManager::setPortNumberToAssign(OCTransportAdapter adapter,
 109                                                OCTransportFlags flag, uint16_t port)
 110 {
 111     OIC_LOG(INFO, TAG, "setPortNumberToAssign");
 112     CAResult_t ret = CASetPortNumberToAssign((CATransportAdapter_t) adapter,
 113                                              (CATransportFlags_t) flag, port);
 114
 115     return convertCAResultToOCResult(ret);
 116 }
 117
 118 uint16_t CAManager::getAssignedPortNumber(OCTransportAdapter adapter, OCTransportFlags flag)
 119 {
 120     OIC_LOG(INFO, TAG, "getAssignedPortNumber");
 121     return CAGetAssignedPortNumber((CATransportAdapter_t) adapter, (CATransportFlags_t) flag);
 122 }
 123
 124 OCStackResult CAManager::setMulticastTTL(size_t ttl)
 125 {
 126     OIC_LOG(INFO, TAG, "setMulticastTTL");
 127     CAResult_t ret = CAUtilSetMulticastTTL(ttl);
 128     return convertCAResultToOCResult(ret);
 129 }
 130
 131 OCStackResult CAManager::getMulticastTTL(size_t *ttl)
 132 {
 133     OIC_LOG(INFO, TAG, "getMulticastTTL");
 134     CAResult_t ret = CAUtilGetMulticastTTL(ttl);
 135     return convertCAResultToOCResult(ret);
 136 }
 137
 138 OCStackResult CAManager::setBTConfigure(const CAUtilConfig& config)
 139 {
 140     OIC_LOG(INFO, TAG, "setBTConfigure");
 141     CAUtilConfig_t configs = {(CATransportBTFlags_t)config.bleFlag, { {0}, .adapter = CA_DEFAULT_ADAPTER, .level = HIGH_SPEED }};
 142     CAResult_t ret = CAUtilSetBTConfigure(configs);
 143     return convertCAResultToOCResult(ret);
 144 }
 145
 146 void CAManager::setLogLevel(OCLogLevel level, bool hidePrivateLogEntries)
 147 {
 148     OIC_LOG(INFO, TAG, "setLogLevel");
 149     CAUtilSetLogLevel((CAUtilLogLevel_t) level, hidePrivateLogEntries);
 150 }
 151
 152 #if defined(__WITH_DTLS__) || defined(__WITH_TLS__)
 153 OCStackResult CAManager::setCipherSuite(const uint16_t cipher, OCTransportAdapter adapter)
 154 {
 155     CAResult_t ret = CASelectCipherSuite(cipher, (CATransportAdapter_t) adapter);
 156     return convertCAResultToOCResult(ret);
 157 }
 158 #endif // defined(__WITH_DTLS__) || defined(__WITH_TLS__)
 159
 160 #if defined(__TIZEN__) && defined(LE_ADAPTER) && defined(BLE_CUSTOM_ADVERTISE)
 161 OCStackResult CAManager::setAdvertisementData(const char* data, int length)
 162 {
 163     CAResult_t ret = CASetAdvertisementData(data, length);
 164
 165     return convertCAResultToOCResult(ret);
 166 }
 167
 168 OCStackResult CAManager::setScanResponseData(const char* data, int length)
 169 {
 170     CAResult_t ret = CASetScanResponseData(data, length);
 171
 172     return convertCAResultToOCResult(ret);
 173 }
 174 #endif
 175
 176 OCStackResult CAManager::startLEAdvertising()
 177 {
 178     OIC_LOG(INFO, TAG, "startLEAdvertising");
 179     CAResult_t ret = CAUtilStartLEAdvertising();
 180
 181     return convertCAResultToOCResult(ret);
 182 }
 183
 184 OCStackResult CAManager::stopLEAdvertising()
 185 {
 186     OIC_LOG(INFO, TAG, "stopLEAdvertising");
 187     CAResult_t ret = CAUtilStopLEAdvertising();
 188
 189     return convertCAResultToOCResult(ret);
 190 }
 191
 192 OCStackResult CAManager::disconnectTCPSession(const char *address,
 193                                               uint16_t port,
 194                                               OCTransportFlags flags)
 195 {
 196     if (!address)
 197     {
 198         OIC_LOG(ERROR, TAG, "address is invalid");
 199         return OCStackResult::OC_STACK_INVALID_PARAM;
 200     }
 201
 202     OIC_LOG_V(INFO, TAG, "disconnectTCPSession [addr:%s][port:%d][flags:%d]",
 203               address, port, flags);
 204     CAResult_t ret = CAUtilTCPDisconnectSession(address, port, (CATransportFlags_t)flags);
 205
 206     return convertCAResultToOCResult(ret);
 207 }
 208
 209 OCStackResult CAManager::startCAGattServer()
 210 {
 211     OIC_LOG(INFO, TAG, "startCAGattServer]");
 212     CAResult_t ret = CAUtilStartGattServer();
 213
 214     return convertCAResultToOCResult(ret);
 215 }
 216
 217 OCStackResult CAManager::stopCAGattServer()
 218 {
 219         OIC_LOG(INFO, TAG, "stopCAGattServer]");
 220     CAResult_t ret = CAUtilStopGattServer();
 221
 222     return convertCAResultToOCResult(ret);
 223 }