1 /******************************************************************
3 * Copyright 2014 Samsung Electronics All Rights Reserved.
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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.
19 ******************************************************************/
26 #include "cainterface.h"
27 #include "caremotehandler.h"
28 #include "camessagehandler.h"
29 #include "caprotocolmessage.h"
30 #include "canetworkconfigurator.h"
31 #include "cainterfacecontroller.h"
34 #include "caadapternetdtls.h"
38 #include "catcpadapter.h"
41 CAGlobals_t caglobals = { 0 };
43 #define TAG "CA_CONN_MGR"
45 static bool g_isInitialized = false;
48 // CAAdapterNetDTLS will register the callback.
49 // Taking callback all the way through adapters not the right approach, hence calling here.
50 extern void CADTLSSetCredentialsCallback(CAGetDTLSPskCredentialsHandler credCallback);
54 // CAAdapterNetDTLS will register the callback.
55 // Taking callback all the way through adapters not the right approach, hence calling here.
56 extern void CADTLSSetX509CredentialsCallback(CAGetDTLSX509CredentialsHandler credCallback);
57 extern void CADTLSSetCrlCallback(CAGetDTLSCrlHandler crlCallback);
60 CAResult_t CAInitialize()
62 OIC_LOG(DEBUG, TAG, "CAInitialize");
66 CAResult_t res = CAInitializeMessageHandler();
67 if (res != CA_STATUS_OK)
69 OIC_LOG(ERROR, TAG, "CAInitialize has failed");
72 g_isInitialized = true;
79 OIC_LOG(DEBUG, TAG, "CATerminate");
83 CATerminateMessageHandler();
84 CATerminateNetworkType();
86 g_isInitialized = false;
90 CAResult_t CAStartListeningServer()
92 OIC_LOG(DEBUG, TAG, "CAStartListeningServer");
96 return CA_STATUS_NOT_INITIALIZED;
99 return CAStartListeningServerAdapters();
102 CAResult_t CAStopListeningServer()
104 OIC_LOG(DEBUG, TAG, "CAStopListeningServer");
108 return CA_STATUS_NOT_INITIALIZED;
111 return CAStopListeningServerAdapters();
114 CAResult_t CAStartDiscoveryServer()
116 OIC_LOG(DEBUG, TAG, "CAStartDiscoveryServer");
120 return CA_STATUS_NOT_INITIALIZED;
123 return CAStartDiscoveryServerAdapters();
126 void CARegisterHandler(CARequestCallback ReqHandler, CAResponseCallback RespHandler,
127 CAErrorCallback ErrorHandler)
129 OIC_LOG(DEBUG, TAG, "CARegisterHandler");
133 OIC_LOG(DEBUG, TAG, "CA is not initialized");
137 CASetInterfaceCallbacks(ReqHandler, RespHandler, ErrorHandler);
141 CAResult_t CARegisterDTLSCredentialsHandler(CAGetDTLSPskCredentialsHandler GetDTLSCredentialsHandler)
143 OIC_LOG(DEBUG, TAG, "CARegisterDTLSCredentialsHandler");
147 return CA_STATUS_NOT_INITIALIZED;
150 CADTLSSetCredentialsCallback(GetDTLSCredentialsHandler);
153 #endif //__WITH_DTLS__
156 CAResult_t CARegisterDTLSX509CredentialsHandler(CAGetDTLSX509CredentialsHandler GetDTLSX509CredentialsHandler)
158 OIC_LOG(DEBUG, TAG, "CARegisterDTLSX509CredentialsHandler");
162 return CA_STATUS_NOT_INITIALIZED;
165 CADTLSSetX509CredentialsCallback(GetDTLSX509CredentialsHandler);
169 CAResult_t CARegisterDTLSCrlHandler(CAGetDTLSCrlHandler GetDTLSCrlHandler)
171 OIC_LOG(DEBUG, TAG, "CARegisterDTLSCrlHandler");
175 return CA_STATUS_NOT_INITIALIZED;
178 CADTLSSetCrlCallback(GetDTLSCrlHandler);
181 #endif //__WITH_X509__
183 CAResult_t CACreateEndpoint(CATransportFlags_t flags,
184 CATransportAdapter_t adapter,
187 CAEndpoint_t **object)
191 OIC_LOG(ERROR, TAG, "Invalid Parameter");
192 return CA_STATUS_INVALID_PARAM;
195 CAEndpoint_t *endpoint = CACreateEndpointObject(flags, adapter, addr, port);
198 return CA_STATUS_FAILED;
204 void CADestroyEndpoint(CAEndpoint_t *rep)
206 OIC_LOG(DEBUG, TAG, "CADestroyEndpoint");
211 CAResult_t CAGenerateToken(CAToken_t *token, uint8_t tokenLength)
213 OIC_LOG(DEBUG, TAG, "CAGenerateToken");
215 return CAGenerateTokenInternal(token, tokenLength);
218 void CADestroyToken(CAToken_t token)
220 OIC_LOG(DEBUG, TAG, "CADestroyToken");
222 CADestroyTokenInternal(token);
224 OIC_LOG(DEBUG, TAG, "OUT");
227 CAResult_t CAGetNetworkInformation(CAEndpoint_t **info, uint32_t *size)
229 OIC_LOG(DEBUG, TAG, "CAGetNetworkInformation");
233 return CA_STATUS_NOT_INITIALIZED;
236 return CAGetNetworkInformationInternal(info, size);
239 CAResult_t CASendRequest(const CAEndpoint_t *object,const CARequestInfo_t *requestInfo)
241 OIC_LOG(DEBUG, TAG, "CASendGetRequest");
245 return CA_STATUS_NOT_INITIALIZED;
248 return CADetachRequestMessage(object, requestInfo);
251 CAResult_t CASendNotification(const CAEndpoint_t *object, const CAResponseInfo_t *responseInfo)
253 OIC_LOG(DEBUG, TAG, "CASendNotification");
257 return CA_STATUS_NOT_INITIALIZED;
260 return CADetachResponseMessage(object, responseInfo);
263 CAResult_t CASendResponse(const CAEndpoint_t *object, const CAResponseInfo_t *responseInfo)
265 OIC_LOG(DEBUG, TAG, "CASendResponse");
269 return CA_STATUS_NOT_INITIALIZED;
272 return CADetachResponseMessage(object, responseInfo);
275 CAResult_t CASelectNetwork(CATransportAdapter_t interestedNetwork)
277 OIC_LOG_V(DEBUG, TAG, "Selected network : %d", interestedNetwork);
281 return CA_STATUS_NOT_INITIALIZED;
284 CAResult_t res = CA_STATUS_OK;
286 if (interestedNetwork & CA_ADAPTER_IP)
288 res = CAAddNetworkType(CA_ADAPTER_IP);
289 OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_IP_ADAPTER) function returns result: %d", res);
291 else if (interestedNetwork & CA_ADAPTER_RFCOMM_BTEDR)
293 res = CAAddNetworkType(CA_ADAPTER_RFCOMM_BTEDR);
294 OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_RFCOMM_ADAPTER) function returns result : %d", res);
296 else if (interestedNetwork & CA_ADAPTER_GATT_BTLE)
298 res = CAAddNetworkType(CA_ADAPTER_GATT_BTLE);
299 OIC_LOG_V(DEBUG, TAG, "CAAddNetworkType(CA_GATT_ADAPTER) function returns result : %d", res);
303 else if (interestedNetwork & CA_ADAPTER_REMOTE_ACCESS)
305 res = CAAddNetworkType(CA_ADAPTER_REMOTE_ACCESS);
306 OIC_LOG_V(DEBUG, TAG,
307 "CAAddNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns result : %d", res);
312 else if (interestedNetwork & CA_ADAPTER_TCP)
314 res = CAAddNetworkType(CA_ADAPTER_TCP);
315 OIC_LOG_V(DEBUG, TAG,
316 "CAAddNetworkType(CA_ADAPTER_TCP) function returns result : %d", res);
322 res = CA_NOT_SUPPORTED;
327 CAResult_t CAUnSelectNetwork(CATransportAdapter_t nonInterestedNetwork)
329 OIC_LOG_V(DEBUG, TAG, "unselected network : %d", nonInterestedNetwork);
333 return CA_STATUS_NOT_INITIALIZED;
336 CAResult_t res = CA_STATUS_OK;
338 if (nonInterestedNetwork & CA_ADAPTER_IP)
340 res = CARemoveNetworkType(CA_ADAPTER_IP);
341 OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_IP_ADAPTER) function returns result : %d", res);
343 else if (nonInterestedNetwork & CA_ADAPTER_RFCOMM_BTEDR)
345 res = CARemoveNetworkType(CA_ADAPTER_RFCOMM_BTEDR);
346 OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_RFCOMM_ADAPTER) function returns result : %d", res);
348 else if (nonInterestedNetwork & CA_ADAPTER_GATT_BTLE)
350 res = CARemoveNetworkType(CA_ADAPTER_GATT_BTLE);
351 OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_GATT_ADAPTER) function returns result : %d", res);
354 else if (nonInterestedNetwork & CA_ADAPTER_REMOTE_ACCESS)
356 res = CARemoveNetworkType(CA_ADAPTER_REMOTE_ACCESS);
357 OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_ADAPTER_REMOTE_ACCESS) function returns result : %d",
364 else if (nonInterestedNetwork & CA_ADAPTER_TCP)
366 res = CARemoveNetworkType(CA_ADAPTER_TCP);
367 OIC_LOG_V(DEBUG, TAG, "CARemoveNetworkType(CA_ADAPTER_TCP) function returns result : %d",
374 res = CA_STATUS_FAILED;
379 CAResult_t CAHandleRequestResponse()
381 if (!g_isInitialized)
383 OIC_LOG(ERROR, TAG, "not initialized");
384 return CA_STATUS_NOT_INITIALIZED;
387 CAHandleRequestResponseCallbacks();
394 CAResult_t CASelectCipherSuite(const uint16_t cipher)
396 OIC_LOG_V(DEBUG, TAG, "CASelectCipherSuite");
398 return CADtlsSelectCipherSuite(cipher);
401 CAResult_t CAEnableAnonECDHCipherSuite(const bool enable)
403 OIC_LOG_V(DEBUG, TAG, "CAEnableAnonECDHCipherSuite");
405 return CADtlsEnableAnonECDHCipherSuite(enable);
408 CAResult_t CAGenerateOwnerPSK(const CAEndpoint_t* endpoint,
409 const uint8_t* label, const size_t labelLen,
410 const uint8_t* rsrcServerDeviceID, const size_t rsrcServerDeviceIDLen,
411 const uint8_t* provServerDeviceID, const size_t provServerDeviceIDLen,
412 uint8_t* ownerPSK, const size_t ownerPSKSize)
414 OIC_LOG_V(DEBUG, TAG, "IN : CAGenerateOwnerPSK");
416 CAResult_t res = CA_STATUS_OK;
418 //newOwnerLabel and prevOwnerLabe can be NULL
419 if (!endpoint || !label || 0 == labelLen || !ownerPSK || 0 == ownerPSKSize)
421 return CA_STATUS_INVALID_PARAM;
424 res = CADtlsGenerateOwnerPSK(endpoint, label, labelLen,
425 rsrcServerDeviceID, rsrcServerDeviceIDLen,
426 provServerDeviceID, provServerDeviceIDLen,
427 ownerPSK, ownerPSKSize);
428 if (CA_STATUS_OK != res)
430 OIC_LOG_V(ERROR, TAG, "Failed to CAGenerateOwnerPSK : %d", res);
433 OIC_LOG_V(DEBUG, TAG, "OUT : CAGenerateOwnerPSK");
438 CAResult_t CAInitiateHandshake(const CAEndpoint_t *endpoint)
440 OIC_LOG_V(DEBUG, TAG, "IN : CAInitiateHandshake");
441 CAResult_t res = CA_STATUS_OK;
445 return CA_STATUS_INVALID_PARAM;
448 res = CADtlsInitiateHandshake(endpoint);
449 if (CA_STATUS_OK != res)
451 OIC_LOG_V(ERROR, TAG, "Failed to CADtlsInitiateHandshake : %d", res);
454 OIC_LOG_V(DEBUG, TAG, "OUT : CAInitiateHandshake");
459 CAResult_t CACloseDtlsSession(const CAEndpoint_t *endpoint)
461 OIC_LOG_V(DEBUG, TAG, "IN : CACloseDtlsSession");
462 CAResult_t res = CA_STATUS_OK;
466 return CA_STATUS_INVALID_PARAM;
469 res = CADtlsClose(endpoint);
470 if (CA_STATUS_OK != res)
472 OIC_LOG_V(ERROR, TAG, "Failed to CADtlsClose : %d", res);
475 OIC_LOG_V(DEBUG, TAG, "OUT : CACloseDtlsSession");
480 #endif /* __WITH_DTLS__ */