1 //******************************************************************
3 // Copyright 2014 Intel Mobile Communications GmbH All Rights Reserved.
5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
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 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
23 #include "ocserverrequest.h"
24 #include "ocresourcehandler.h"
25 #include "oic_malloc.h"
26 #include "oic_string.h"
27 #include "ocpayload.h"
28 #include "ocpayloadcbor.h"
31 #include "cainterface.h"
37 #define VERIFY_NON_NULL(arg) { if (!arg) {OC_LOG(FATAL, TAG, #arg " is NULL"); goto exit;} }
39 #define TAG "ocserverrequest"
41 static struct OCServerRequest * serverRequestList = NULL;
42 static struct OCServerResponse * serverResponseList = NULL;
44 //-------------------------------------------------------------------------------------------------
46 //-------------------------------------------------------------------------------------------------
49 * Add a server response to the server response list
51 * @param response initialized server response that is created by this function
52 * @param requestHandle - handle of the response
57 static OCStackResult AddServerResponse (OCServerResponse ** response, OCRequestHandle requestHandle)
59 OCServerResponse * serverResponse = NULL;
61 serverResponse = (OCServerResponse *) OICCalloc(1, sizeof(OCServerResponse));
62 VERIFY_NON_NULL(serverResponse);
64 serverResponse->payload = NULL;
66 serverResponse->requestHandle = requestHandle;
68 *response = serverResponse;
69 OC_LOG(INFO, TAG, "Server Response Added!!");
70 LL_APPEND (serverResponseList, serverResponse);
76 OICFree(serverResponse);
77 serverResponse = NULL;
80 return OC_STACK_NO_MEMORY;
84 * Delete a server request from the server request list
86 * @param serverRequest - server request to delete
88 static void DeleteServerRequest(OCServerRequest * serverRequest)
92 LL_DELETE(serverRequestList, serverRequest);
93 OICFree(serverRequest->requestToken);
94 OICFree(serverRequest);
96 OC_LOG(INFO, TAG, "Server Request Removed!!");
101 * Delete a server response from the server response list
103 * @param serverResponse - server response to delete
105 static void DeleteServerResponse(OCServerResponse * serverResponse)
109 LL_DELETE(serverResponseList, serverResponse);
110 OICFree(serverResponse->payload);
111 OICFree(serverResponse);
112 OC_LOG(INFO, TAG, "Server Response Removed!!");
117 * Find a server response and delete it from the server response list
119 * @param serverResponse - server response to find and delete
121 static void FindAndDeleteServerResponse(OCServerResponse * serverResponse)
123 OCServerResponse* tmp;
126 LL_FOREACH(serverResponseList, tmp)
128 if (serverResponse == tmp)
130 DeleteServerResponse(tmp);
138 * Ensure no accept header option is included when sending responses
140 * @param object CA remote endpoint.
141 * @param requestInfo CA request info.
143 * @return ::OC_STACK_OK on success, some other value upon failure.
145 static OCStackResult OCSendResponse(const CAEndpoint_t *object, CAResponseInfo_t *responseInfo)
147 // Do not include the accept header option
148 responseInfo->info.acceptFormat = CA_FORMAT_UNDEFINED;
149 CAResult_t result = CASendResponse(object, responseInfo);
150 if(CA_STATUS_OK != result)
152 OC_LOG_V(ERROR, TAG, "CASendResponse failed with CA error %u", result);
153 return CAResultToOCResult(result);
158 //-------------------------------------------------------------------------------------------------
160 //-------------------------------------------------------------------------------------------------
163 * Get a server request from the server request list using the specified token.
165 * @param token - token of server request
166 * @param tokenLength - length of token
171 OCServerRequest * GetServerRequestUsingToken (const CAToken_t token, uint8_t tokenLength)
175 OC_LOG(ERROR, TAG, "Invalid Parameter Token");
179 OCServerRequest * out = NULL;
180 OC_LOG(INFO, TAG,"Get server request with token");
181 OC_LOG_BUFFER(INFO, TAG, (const uint8_t *)token, tokenLength);
183 OC_LOG(INFO, TAG,"Found token");
184 LL_FOREACH (serverRequestList, out)
186 OC_LOG_BUFFER(INFO, TAG, (const uint8_t *)out->requestToken, tokenLength);
187 if(memcmp(out->requestToken, token, tokenLength) == 0)
192 OC_LOG(ERROR, TAG, "Server Request not found!!");
197 * Get a server request from the server request list using the specified handle
199 * @param handle - handle of server request
203 OCServerRequest * GetServerRequestUsingHandle (const OCServerRequest * handle)
205 OCServerRequest * out = NULL;
206 LL_FOREACH (serverRequestList, out)
213 OC_LOG(ERROR, TAG, "Server Request not found!!");
218 * Get a server response from the server response list using the specified handle
220 * @param handle - handle of server response
225 OCServerResponse * GetServerResponseUsingHandle (const OCServerRequest * handle)
227 OCServerResponse * out = NULL;
228 LL_FOREACH (serverResponseList, out)
230 if(out->requestHandle == handle)
235 OC_LOG(ERROR, TAG, "Server Response not found!!");
239 OCStackResult AddServerRequest (OCServerRequest ** request, uint16_t coapID,
240 uint8_t delayedResNeeded, uint8_t notificationFlag, OCMethod method,
241 uint8_t numRcvdVendorSpecificHeaderOptions, uint32_t observationOption,
242 OCQualityOfService qos, char * query,
243 OCHeaderOption * rcvdVendorSpecificHeaderOptions,
244 uint8_t * payload, CAToken_t requestToken, uint8_t tokenLength,
245 char * resourceUrl, size_t reqTotalSize, OCPayloadFormat acceptFormat,
246 const OCDevAddr *devAddr)
248 OCServerRequest * serverRequest = NULL;
250 serverRequest = (OCServerRequest *) OICCalloc(1, sizeof(OCServerRequest) +
251 (reqTotalSize ? reqTotalSize : 1) - 1);
252 VERIFY_NON_NULL(devAddr);
253 VERIFY_NON_NULL(serverRequest);
255 serverRequest->coapID = coapID;
256 serverRequest->delayedResNeeded = delayedResNeeded;
257 serverRequest->notificationFlag = notificationFlag;
259 serverRequest->method = method;
260 serverRequest->numRcvdVendorSpecificHeaderOptions = numRcvdVendorSpecificHeaderOptions;
261 serverRequest->observationOption = observationOption;
262 serverRequest->observeResult = OC_STACK_ERROR;
263 serverRequest->qos = qos;
264 serverRequest->acceptFormat = acceptFormat;
265 serverRequest->ehResponseHandler = HandleSingleResponse;
266 serverRequest->numResponses = 1;
270 OICStrcpy(serverRequest->query, sizeof(serverRequest->query), query);
273 if(rcvdVendorSpecificHeaderOptions)
275 memcpy(serverRequest->rcvdVendorSpecificHeaderOptions, rcvdVendorSpecificHeaderOptions,
276 MAX_HEADER_OPTIONS * sizeof(OCHeaderOption));
278 if(payload && reqTotalSize)
280 // destination is at least 1 greater than the source, so a NULL always exists in the
282 memcpy(serverRequest->payload, payload, reqTotalSize);
283 serverRequest->payloadSize = reqTotalSize;
286 serverRequest->requestComplete = 0;
289 // If tokenLength is zero, the return value depends on the
290 // particular library implementation (it may or may not be a null pointer).
293 serverRequest->requestToken = (CAToken_t) OICMalloc(tokenLength);
294 VERIFY_NON_NULL(serverRequest->requestToken);
295 memcpy(serverRequest->requestToken, requestToken, tokenLength);
299 serverRequest->tokenLength = tokenLength;
303 OICStrcpy(serverRequest->resourceUrl, sizeof(serverRequest->resourceUrl),
307 serverRequest->devAddr = *devAddr;
309 *request = serverRequest;
310 OC_LOG(INFO, TAG, "Server Request Added!!");
311 LL_APPEND (serverRequestList, serverRequest);
317 OICFree(serverRequest);
318 serverRequest = NULL;
321 return OC_STACK_NO_MEMORY;
324 OCStackResult FormOCEntityHandlerRequest(
325 OCEntityHandlerRequest * entityHandlerRequest,
326 OCRequestHandle request,
329 OCResourceHandle resource,
333 uint8_t numVendorOptions,
334 OCHeaderOption * vendorOptions,
335 OCObserveAction observeAction,
336 OCObservationId observeID)
338 if (entityHandlerRequest)
340 entityHandlerRequest->resource = (OCResourceHandle) resource;
341 entityHandlerRequest->requestHandle = request;
342 entityHandlerRequest->method = method;
343 entityHandlerRequest->devAddr = *endpoint;
344 entityHandlerRequest->query = queryBuf;
345 entityHandlerRequest->obsInfo.action = observeAction;
346 entityHandlerRequest->obsInfo.obsId = observeID;
348 if(payload && payloadSize)
350 if(OCParsePayload(&entityHandlerRequest->payload, payload, payloadSize) != OC_STACK_OK)
352 return OC_STACK_ERROR;
357 entityHandlerRequest->payload = NULL;
360 entityHandlerRequest->numRcvdVendorSpecificHeaderOptions = numVendorOptions;
361 entityHandlerRequest->rcvdVendorSpecificHeaderOptions = vendorOptions;
366 return OC_STACK_INVALID_PARAM;
370 * Find a server request in the server request list and delete
372 * @param serverRequest - server request to find and delete
374 void FindAndDeleteServerRequest(OCServerRequest * serverRequest)
376 OCServerRequest* tmp;
379 LL_FOREACH(serverRequestList, tmp)
381 if (serverRequest == tmp)
383 DeleteServerRequest(tmp);
390 CAResponseResult_t ConvertEHResultToCAResult (OCEntityHandlerResult result)
392 CAResponseResult_t caResult = CA_BAD_REQ;
397 caResult = CA_SUCCESS;
400 caResult = CA_BAD_REQ;
402 case OC_EH_RESOURCE_CREATED:
403 caResult = CA_CREATED;
405 case OC_EH_RESOURCE_DELETED:
406 caResult = CA_DELETED;
409 caResult = CA_SUCCESS;
411 case OC_EH_FORBIDDEN:
412 caResult = CA_UNAUTHORIZED_REQ;
414 case OC_EH_RESOURCE_NOT_FOUND:
415 caResult = CA_NOT_FOUND;
418 caResult = CA_BAD_REQ;
426 * Handler function for sending a response from a single resource
428 * @param ehResponse - pointer to the response from the resource
434 OCStackResult HandleSingleResponse(OCEntityHandlerResponse * ehResponse)
436 OCStackResult result = OC_STACK_ERROR;
437 CAEndpoint_t responseEndpoint = {.adapter = CA_DEFAULT_ADAPTER};
438 CAResponseInfo_t responseInfo = {.result = CA_EMPTY};
439 CAHeaderOption_t* optionsPointer = NULL;
441 if(!ehResponse || !ehResponse->requestHandle)
443 return OC_STACK_ERROR;
446 OCServerRequest *serverRequest = (OCServerRequest *)ehResponse->requestHandle;
448 CopyDevAddrToEndpoint(&serverRequest->devAddr, &responseEndpoint);
450 responseInfo.info.resourceUri = serverRequest->resourceUrl;
451 responseInfo.result = ConvertEHResultToCAResult(ehResponse->ehResult);
453 if(serverRequest->notificationFlag && serverRequest->qos == OC_HIGH_QOS)
455 responseInfo.info.type = CA_MSG_CONFIRM;
457 else if(serverRequest->notificationFlag && serverRequest->qos != OC_HIGH_QOS)
459 responseInfo.info.type = CA_MSG_NONCONFIRM;
461 else if(!serverRequest->notificationFlag && !serverRequest->slowFlag &&
462 serverRequest->qos == OC_HIGH_QOS)
464 responseInfo.info.type = CA_MSG_ACKNOWLEDGE;
466 else if(!serverRequest->notificationFlag && serverRequest->slowFlag &&
467 serverRequest->qos == OC_HIGH_QOS)
469 responseInfo.info.type = CA_MSG_CONFIRM;
471 else if(!serverRequest->notificationFlag)
473 responseInfo.info.type = CA_MSG_NONCONFIRM;
476 char rspToken[CA_MAX_TOKEN_LEN + 1] = {};
477 responseInfo.info.messageId = serverRequest->coapID;
478 responseInfo.info.token = (CAToken_t)rspToken;
480 memcpy(responseInfo.info.token, serverRequest->requestToken, serverRequest->tokenLength);
481 responseInfo.info.tokenLength = serverRequest->tokenLength;
483 if(serverRequest->observeResult == OC_STACK_OK)
485 responseInfo.info.numOptions = ehResponse->numSendVendorSpecificHeaderOptions + 1;
489 responseInfo.info.numOptions = ehResponse->numSendVendorSpecificHeaderOptions;
492 if(responseInfo.info.numOptions > 0)
494 responseInfo.info.options = (CAHeaderOption_t *)
495 OICCalloc(responseInfo.info.numOptions,
496 sizeof(CAHeaderOption_t));
498 if(!responseInfo.info.options)
500 OC_LOG(FATAL, TAG, "Memory alloc for options failed");
501 return OC_STACK_NO_MEMORY;
504 optionsPointer = responseInfo.info.options;
506 // TODO: This exposes CoAP specific details. At some point, this should be
507 // re-factored and handled in the CA layer.
508 if(serverRequest->observeResult == OC_STACK_OK)
510 responseInfo.info.options[0].protocolID = CA_COAP_ID;
511 responseInfo.info.options[0].optionID = COAP_OPTION_OBSERVE;
512 responseInfo.info.options[0].optionLength = sizeof(uint32_t);
513 uint8_t* observationData = (uint8_t*)responseInfo.info.options[0].optionData;
514 uint32_t observationOption= serverRequest->observationOption;
516 for (i=sizeof(uint32_t); i; --i)
518 observationData[i-1] = observationOption & 0xFF;
519 observationOption >>=8;
522 // Point to the next header option before copying vender specific header options
526 if (ehResponse->numSendVendorSpecificHeaderOptions)
528 memcpy(optionsPointer, ehResponse->sendVendorSpecificHeaderOptions,
529 sizeof(OCHeaderOption) *
530 ehResponse->numSendVendorSpecificHeaderOptions);
535 responseInfo.info.options = NULL;
538 responseInfo.isMulticast = false;
539 responseInfo.info.payload = NULL;
540 responseInfo.info.payloadSize = 0;
541 responseInfo.info.payloadFormat = CA_FORMAT_UNDEFINED;
543 // Put the JSON prefix and suffix around the payload
544 if(ehResponse->payload)
546 if (ehResponse->payload->type == PAYLOAD_TYPE_PRESENCE)
548 responseInfo.isMulticast = true;
552 responseInfo.isMulticast = false;
555 switch(serverRequest->acceptFormat)
557 case OC_FORMAT_UNDEFINED:
558 // No preference set by the client, so default to CBOR then
560 if((result = OCConvertPayload(ehResponse->payload, &responseInfo.info.payload,
561 &responseInfo.info.payloadSize))
564 OC_LOG(ERROR, TAG, "Error converting payload");
565 OICFree(responseInfo.info.options);
568 responseInfo.info.payloadFormat = CA_FORMAT_APPLICATION_CBOR;
571 responseInfo.result = CA_NOT_ACCEPTABLE;
576 CATransportAdapter_t CAConnTypes[] = {
578 CA_ADAPTER_GATT_BTLE,
579 CA_ADAPTER_RFCOMM_BTEDR
582 , CA_ADAPTER_REMOTE_ACCESS
590 int size = sizeof(CAConnTypes)/ sizeof(CATransportAdapter_t);
592 CATransportAdapter_t adapter = responseEndpoint.adapter;
593 // Default adapter, try to send response out on all adapters.
594 if (adapter == CA_DEFAULT_ADAPTER)
597 (CATransportAdapter_t)(
599 CA_ADAPTER_GATT_BTLE |
600 CA_ADAPTER_RFCOMM_BTEDR
603 | CA_ADAPTER_REMOTE_ACCESS
612 result = OC_STACK_OK;
613 OCStackResult tempResult = OC_STACK_OK;
615 for(int i = 0; i < size; i++ )
617 responseEndpoint.adapter = (CATransportAdapter_t)(adapter & CAConnTypes[i]);
618 if(responseEndpoint.adapter)
620 //The result is set to OC_STACK_OK only if OCSendResponse succeeds in sending the
621 //response on all the n/w interfaces else it is set to OC_STACK_ERROR
622 tempResult = OCSendResponse(&responseEndpoint, &responseInfo);
624 if(OC_STACK_OK != tempResult)
631 OC_LOG(INFO, TAG, "Calling OCSendResponse with:");
632 OC_LOG_V(INFO, TAG, "\tEndpoint address: %s", responseEndpoint.addr);
633 OC_LOG_V(INFO, TAG, "\tEndpoint adapter: %s", responseEndpoint.adapter);
634 OC_LOG_V(INFO, TAG, "\tResponse result : %s", responseInfo.result);
635 OC_LOG_V(INFO, TAG, "\tResponse for uri: %s", responseInfo.info.resourceUri);
637 result = OCSendResponse(&responseEndpoint, &responseInfo);
640 OICFree(responseInfo.info.payload);
641 OICFree(responseInfo.info.options);
643 FindAndDeleteServerRequest(serverRequest);
648 * Handler function for sending a response from multiple resources, such as a collection.
649 * Aggregates responses from multiple resource until all responses are received then sends the
650 * concatenated response
652 * TODO: Need to add a timeout in case a (remote?) resource does not respond
654 * @param ehResponse - pointer to the response from the resource
659 OCStackResult HandleAggregateResponse(OCEntityHandlerResponse * ehResponse)
661 OCStackResult stackRet = OC_STACK_ERROR;
662 OCServerRequest * serverRequest = NULL;
663 OCServerResponse * serverResponse = NULL;
665 if(!ehResponse || !ehResponse->payload)
667 OC_LOG(ERROR, TAG, "HandleAggregateResponse invalid parameters");
668 return OC_STACK_INVALID_PARAM;
671 OC_LOG(INFO, TAG, "Inside HandleAggregateResponse");
673 serverRequest = GetServerRequestUsingHandle((OCServerRequest *)ehResponse->requestHandle);
674 serverResponse = GetServerResponseUsingHandle((OCServerRequest *)ehResponse->requestHandle);
680 OC_LOG(INFO, TAG, "This is the first response fragment");
681 stackRet = AddServerResponse(&serverResponse, ehResponse->requestHandle);
682 if (OC_STACK_OK != stackRet)
684 OC_LOG(ERROR, TAG, "Error adding server response");
687 VERIFY_NON_NULL(serverResponse);
690 if(ehResponse->payload->type != PAYLOAD_TYPE_REPRESENTATION)
692 stackRet = OC_STACK_ERROR;
693 OC_LOG(ERROR, TAG, "Error adding payload, as it was the incorrect type");
697 if(!serverResponse->payload)
699 serverResponse->payload = ehResponse->payload;
703 OCRepPayloadAppend((OCRepPayload*)serverResponse->payload,
704 (OCRepPayload*)ehResponse->payload);
708 (serverRequest->numResponses)--;
710 if(serverRequest->numResponses == 0)
712 OC_LOG(INFO, TAG, "This is the last response fragment");
713 ehResponse->payload = serverResponse->payload;
714 stackRet = HandleSingleResponse(ehResponse);
715 //Delete the request and response
716 FindAndDeleteServerRequest(serverRequest);
717 FindAndDeleteServerResponse(serverResponse);
721 OC_LOG(INFO, TAG, "More response fragments to come");
722 stackRet = OC_STACK_OK;