Added function that enables RI passing message ID from CA
[platform/upstream/iotivity.git] / resource / csdk / stack / src / ocresource.c
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 // Defining _POSIX_C_SOURCE macro with 200112L (or greater) as value
22 // causes header files to expose definitions
23 // corresponding to the POSIX.1-2001 base
24 // specification (excluding the XSI extension).
25 // For POSIX.1-2001 base specification,
26 // Refer http://pubs.opengroup.org/onlinepubs/009695399/
27 #define _POSIX_C_SOURCE 200112L
28
29 #ifdef WITH_ARDUINO
30 #include <string.h>
31 #else
32 #include <strings.h>
33 #endif
34
35 #include "ocresource.h"
36 #include "ocresourcehandler.h"
37 #include "ocobserve.h"
38 #include "occollection.h"
39 #include "oic_malloc.h"
40 #include "oic_string.h"
41 #include "logger.h"
42 #include "cJSON.h"
43 #include "ocpayload.h"
44 #include "secureresourcemanager.h"
45 #include "cacommon.h"
46 #include "cainterface.h"
47 #include "rdpayload.h"
48 #include "ocpayload.h"
49
50 #ifdef WITH_RD
51 #include "rd_server.h"
52 #endif
53
54 #ifdef ROUTING_GATEWAY
55 #include "routingmanager.h"
56 #endif
57
58 /// Module Name
59 #define TAG "OIC_RI_RESOURCE"
60
61 #define VERIFY_SUCCESS(op, successCode) { if (op != successCode) \
62             {OIC_LOG_V(FATAL, TAG, "%s failed!!", #op); goto exit;} }
63
64 #define VERIFY_NON_NULL(arg, logLevel, retVal) { if (!(arg)) { OIC_LOG((logLevel), \
65              TAG, #arg " is NULL"); return (retVal); } }
66
67 extern OCResource *headResource;
68 static OCPlatformInfo savedPlatformInfo = {0};
69 static OCDeviceInfo savedDeviceInfo = {0};
70
71 /**
72  * Prepares a Payload for response.
73  */
74 static OCStackResult BuildVirtualResourceResponse(const OCResource *resourcePtr,
75                                                   OCDiscoveryPayload* payload,
76                                                   OCDevAddr *endpoint,
77                                                   bool rdResponse);
78
79 //-----------------------------------------------------------------------------
80 // Default resource entity handler function
81 //-----------------------------------------------------------------------------
82 OCEntityHandlerResult defaultResourceEHandler(OCEntityHandlerFlag flag,
83         OCEntityHandlerRequest * request, void* callbackParam)
84 {
85     //TODO ("Implement me!!!!");
86     // TODO:  remove silence unused param warnings
87     (void) flag;
88     (void) request;
89     (void) callbackParam;
90     return  OC_EH_OK; // Making sure that the Default EH and the Vendor EH have matching signatures
91 }
92
93 /* This method will retrieve the port at which the secure resource is hosted */
94 static OCStackResult GetSecurePortInfo(OCDevAddr *endpoint, uint16_t *port)
95 {
96     uint16_t p = 0;
97
98     if (endpoint->adapter == OC_ADAPTER_IP)
99     {
100         if (endpoint->flags & OC_IP_USE_V6)
101         {
102             p = caglobals.ip.u6s.port;
103         }
104         else if (endpoint->flags & OC_IP_USE_V4)
105         {
106             p = caglobals.ip.u4s.port;
107         }
108     }
109
110     *port = p;
111     return OC_STACK_OK;
112 }
113
114 #ifdef TCP_ADAPTER
115 /* This method will retrieve the tcp port */
116 static OCStackResult GetTCPPortInfo(OCDevAddr *endpoint, uint16_t *port)
117 {
118     uint16_t p = 0;
119
120     if (endpoint->adapter == OC_ADAPTER_IP)
121     {
122         if (endpoint->flags & OC_IP_USE_V4)
123         {
124             p = caglobals.tcp.ipv4.port;
125         }
126         else if (endpoint->flags & OC_IP_USE_V6)
127         {
128             p = caglobals.tcp.ipv6.port;
129         }
130     }
131
132     *port = p;
133     return OC_STACK_OK;
134 }
135 #endif
136
137 /*
138  * Function will extract 0, 1 or 2 filters from query.
139  * More than 2 filters or unsupported filters will result in error.
140  * If both filters are of the same supported type, the 2nd one will be picked.
141  * Resource and device filters in the SAME query are NOT validated
142  * and resources will likely not clear filters.
143  */
144 static OCStackResult ExtractFiltersFromQuery(char *query, char **filterOne, char **filterTwo)
145 {
146
147     char *key = NULL;
148     char *value = NULL;
149     char *restOfQuery = NULL;
150     int numKeyValuePairsParsed = 0;
151
152     *filterOne = NULL;
153     *filterTwo = NULL;
154
155     OIC_LOG_V(INFO, TAG, "Extracting params from %s", query);
156
157     char *keyValuePair = strtok_r (query, OC_QUERY_SEPARATOR, &restOfQuery);
158
159     while(keyValuePair)
160     {
161         if (numKeyValuePairsParsed >= 2)
162         {
163             OIC_LOG(ERROR, TAG, "More than 2 queries params in URI.");
164             return OC_STACK_INVALID_QUERY;
165         }
166
167         key = strtok_r(keyValuePair, OC_KEY_VALUE_DELIMITER, &value);
168
169         if (!key || !value)
170         {
171             return OC_STACK_INVALID_QUERY;
172         }
173         else if (strncasecmp(key, OC_RSRVD_INTERFACE, sizeof(OC_RSRVD_INTERFACE) - 1) == 0)
174         {
175             *filterOne = value;     // if
176         }
177         else if (strncasecmp(key, OC_RSRVD_RESOURCE_TYPE, sizeof(OC_RSRVD_INTERFACE) - 1) == 0)
178         {
179             *filterTwo = value;     // rt
180         }
181         else
182         {
183             OIC_LOG_V(ERROR, TAG, "Unsupported query key: %s", key);
184             return OC_STACK_INVALID_QUERY;
185         }
186         ++numKeyValuePairsParsed;
187
188         keyValuePair = strtok_r(NULL, OC_QUERY_SEPARATOR, &restOfQuery);
189     }
190
191     OIC_LOG_V(INFO, TAG, "Extracted params if: %s and rt: %s.", *filterOne, *filterTwo);
192     return OC_STACK_OK;
193 }
194
195 static OCVirtualResources GetTypeOfVirtualURI(const char *uriInRequest)
196 {
197     if (strcmp(uriInRequest, OC_RSRVD_WELL_KNOWN_URI) == 0)
198     {
199         return OC_WELL_KNOWN_URI;
200     }
201     else if (strcmp(uriInRequest, OC_RSRVD_DEVICE_URI) == 0)
202     {
203         return OC_DEVICE_URI;
204     }
205     else if (strcmp(uriInRequest, OC_RSRVD_PLATFORM_URI) == 0)
206     {
207         return OC_PLATFORM_URI;
208     }
209     else if (strcmp(uriInRequest, OC_RSRVD_RESOURCE_TYPES_URI) == 0)
210     {
211         return OC_RESOURCE_TYPES_URI;
212     }
213 #ifdef ROUTING_GATEWAY
214     else if (0 == strcmp(uriInRequest, OC_RSRVD_GATEWAY_URI))
215     {
216         return OC_GATEWAY_URI;
217     }
218 #endif
219 #ifdef WITH_PRESENCE
220     else if (strcmp(uriInRequest, OC_RSRVD_PRESENCE_URI) == 0)
221     {
222         return OC_PRESENCE;
223     }
224 #endif //WITH_PRESENCE
225     return OC_UNKNOWN_URI;
226 }
227
228 static OCStackResult getQueryParamsForFiltering (OCVirtualResources uri, char *query,
229                                             char **filterOne, char **filterTwo)
230 {
231     if(!filterOne || !filterTwo)
232     {
233         return OC_STACK_INVALID_PARAM;
234     }
235
236     *filterOne = NULL;
237     *filterTwo = NULL;
238
239     #ifdef WITH_PRESENCE
240     if (uri == OC_PRESENCE)
241     {
242         //Nothing needs to be done, except for pass a OC_PRESENCE query through as OC_STACK_OK.
243         OIC_LOG(INFO, TAG, "OC_PRESENCE Request for virtual resource.");
244         return OC_STACK_OK;
245     }
246     #endif
247
248     OCStackResult result = OC_STACK_OK;
249
250     if (query && *query)
251     {
252         result = ExtractFiltersFromQuery(query, filterOne, filterTwo);
253     }
254
255     return result;
256 }
257
258 OCStackResult BuildResponseRepresentation(const OCResource *resourcePtr,
259                     OCRepPayload** payload)
260 {
261     OCRepPayload *tempPayload = OCRepPayloadCreate();
262
263     if (!resourcePtr)
264     {
265         OCRepPayloadDestroy(tempPayload);
266         return OC_STACK_INVALID_PARAM;
267     }
268
269     if(!tempPayload)
270     {
271         return OC_STACK_NO_MEMORY;
272     }
273
274     OCRepPayloadSetUri(tempPayload, resourcePtr->uri);
275
276     OCResourceType *resType = resourcePtr->rsrcType;
277     while(resType)
278     {
279         OCRepPayloadAddResourceType(tempPayload, resType->resourcetypename);
280         resType = resType->next;
281     }
282
283     OCResourceInterface *resInterface = resourcePtr->rsrcInterface;
284     while(resInterface)
285     {
286         OCRepPayloadAddInterface(tempPayload, resInterface->name);
287         resInterface = resInterface->next;
288     }
289
290     OCAttribute *resAttrib = resourcePtr->rsrcAttributes;
291     while(resAttrib)
292     {
293         OCRepPayloadSetPropString(tempPayload, resAttrib->attrName,
294                                 resAttrib->attrValue);
295         resAttrib = resAttrib->next;
296     }
297
298     if(!*payload)
299     {
300         *payload = tempPayload;
301     }
302     else
303     {
304         OCRepPayloadAppend(*payload, tempPayload);
305     }
306
307     return OC_STACK_OK;
308 }
309
310 OCStackResult BuildVirtualResourceResponse(const OCResource *resourcePtr,
311                         OCDiscoveryPayload *payload, OCDevAddr *devAddr, bool rdResponse)
312 {
313     if (!resourcePtr || !payload)
314     {
315         return OC_STACK_INVALID_PARAM;
316     }
317     uint16_t securePort = 0;
318     if (resourcePtr->resourceProperties & OC_SECURE)
319     {
320        if (GetSecurePortInfo(devAddr, &securePort) != OC_STACK_OK)
321        {
322            securePort = 0;
323        }
324     }
325
326     if (rdResponse)
327     {
328         securePort = devAddr->port;
329     }
330
331     uint16_t tcpPort = 0;
332 #ifdef TCP_ADAPTER
333     if (GetTCPPortInfo(devAddr, &tcpPort) != OC_STACK_OK)
334     {
335         tcpPort = 0;
336     }
337     OCDiscoveryPayloadAddResource(payload, resourcePtr, securePort, tcpPort);
338 #else
339     OCDiscoveryPayloadAddResource(payload, resourcePtr, securePort);
340 #endif
341
342     return OC_STACK_OK;
343 }
344
345 uint8_t IsCollectionResource (OCResource *resource)
346 {
347     if(!resource)
348     {
349         return 0;
350     }
351
352     if(resource->rsrcChildResourcesHead != NULL)
353     {
354         return 1;
355     }
356
357     return 0;
358 }
359
360 OCResource *FindResourceByUri(const char* resourceUri)
361 {
362     if(!resourceUri)
363     {
364         return NULL;
365     }
366
367     OCResource * pointer = headResource;
368     while (pointer)
369     {
370         if (strcmp(resourceUri, pointer->uri) == 0)
371         {
372             return pointer;
373         }
374         pointer = pointer->next;
375     }
376     OIC_LOG_V(INFO, TAG, "Resource %s not found", resourceUri);
377     return NULL;
378 }
379
380
381 OCStackResult DetermineResourceHandling (const OCServerRequest *request,
382                                          ResourceHandling *handling,
383                                          OCResource **resource)
384 {
385     if(!request || !handling || !resource)
386     {
387         return OC_STACK_INVALID_PARAM;
388     }
389
390     OIC_LOG_V(INFO, TAG, "DetermineResourceHandling for %s", request->resourceUrl);
391
392     // Check if virtual resource
393     if (GetTypeOfVirtualURI(request->resourceUrl) != OC_UNKNOWN_URI)
394     {
395         OIC_LOG_V (INFO, TAG, "%s is virtual", request->resourceUrl);
396         *handling = OC_RESOURCE_VIRTUAL;
397         *resource = headResource;
398         return OC_STACK_OK;
399     }
400     if (strlen((const char*)(request->resourceUrl)) == 0)
401     {
402         // Resource URL not specified
403         *handling = OC_RESOURCE_NOT_SPECIFIED;
404         return OC_STACK_NO_RESOURCE;
405     }
406     else
407     {
408         OCResource *resourcePtr = FindResourceByUri((const char*)request->resourceUrl);
409         *resource = resourcePtr;
410         if (!resourcePtr)
411         {
412             if(defaultDeviceHandler)
413             {
414                 *handling = OC_RESOURCE_DEFAULT_DEVICE_ENTITYHANDLER;
415                 return OC_STACK_OK;
416             }
417
418             // Resource does not exist
419             // and default device handler does not exist
420             *handling = OC_RESOURCE_NOT_SPECIFIED;
421             return OC_STACK_NO_RESOURCE;
422         }
423
424         if (IsCollectionResource (resourcePtr))
425         {
426             // Collection resource
427             if (resourcePtr->entityHandler != defaultResourceEHandler)
428             {
429                 *handling = OC_RESOURCE_COLLECTION_WITH_ENTITYHANDLER;
430                 return OC_STACK_OK;
431             }
432             else
433             {
434                 *handling = OC_RESOURCE_COLLECTION_DEFAULT_ENTITYHANDLER;
435                 return OC_STACK_OK;
436             }
437         }
438         else
439         {
440             // Resource not a collection
441             if (resourcePtr->entityHandler != defaultResourceEHandler)
442             {
443                 *handling = OC_RESOURCE_NOT_COLLECTION_WITH_ENTITYHANDLER;
444                 return OC_STACK_OK;
445             }
446             else
447             {
448                 *handling = OC_RESOURCE_NOT_COLLECTION_DEFAULT_ENTITYHANDLER;
449                 return OC_STACK_OK;
450             }
451         }
452     }
453 }
454
455 OCStackResult EntityHandlerCodeToOCStackCode(OCEntityHandlerResult ehResult)
456 {
457     OCStackResult result;
458
459     switch (ehResult)
460     {
461         case OC_EH_OK:
462             result = OC_STACK_OK;
463             break;
464         case OC_EH_SLOW:
465             result = OC_STACK_SLOW_RESOURCE;
466             break;
467         case OC_EH_ERROR:
468             result = OC_STACK_ERROR;
469             break;
470         case OC_EH_FORBIDDEN:
471             result = OC_STACK_RESOURCE_ERROR;
472             break;
473         case OC_EH_RESOURCE_CREATED:
474             result = OC_STACK_RESOURCE_CREATED;
475             break;
476         case OC_EH_RESOURCE_DELETED:
477             result = OC_STACK_RESOURCE_DELETED;
478             break;
479         case OC_EH_RESOURCE_NOT_FOUND:
480             result = OC_STACK_NO_RESOURCE;
481             break;
482         default:
483             result = OC_STACK_ERROR;
484     }
485
486     return result;
487 }
488
489 static bool resourceMatchesRTFilter(OCResource *resource, char *resourceTypeFilter)
490 {
491     if (!resource)
492     {
493         return false;
494     }
495
496     // Null or empty is analogous to no filter.
497     if (resourceTypeFilter == NULL || *resourceTypeFilter == 0)
498     {
499         return true;
500     }
501
502     OCResourceType *resourceTypePtr = resource->rsrcType;
503
504     while (resourceTypePtr)
505     {
506         if (strcmp (resourceTypePtr->resourcetypename, resourceTypeFilter) == 0)
507         {
508             return true;
509         }
510         resourceTypePtr = resourceTypePtr->next;
511     }
512
513     OIC_LOG_V(INFO, TAG, "%s does not contain rt=%s.", resource->uri, resourceTypeFilter);
514     return false;
515 }
516
517 static bool resourceMatchesIFFilter(OCResource *resource, char *interfaceFilter)
518 {
519     if (!resource)
520     {
521         return false;
522     }
523
524     // Null or empty is analogous to no filter.
525     if (interfaceFilter == NULL || *interfaceFilter == 0)
526     {
527         return true;
528     }
529
530     OCResourceInterface *interfacePtr = resource->rsrcInterface;
531
532     while (interfacePtr)
533     {
534         if ((strcmp (interfacePtr->name, interfaceFilter) == 0) &&
535             (strcmp (OC_RSRVD_INTERFACE_LL, interfaceFilter) == 0 ||
536              strcmp (OC_RSRVD_INTERFACE_DEFAULT, interfaceFilter) == 0))
537         {
538             return true;
539         }
540         interfacePtr = interfacePtr->next;
541     }
542
543     OIC_LOG_V(INFO, TAG, "%s does not contain if=%s.", resource->uri, interfaceFilter);
544     return false;
545 }
546
547 /*
548  * If the filters are null, they will be assumed to NOT be present
549  * and the resource will not be matched against them.
550  * Function will return true if all non null AND non empty filters passed in find a match.
551  */
552 static bool includeThisResourceInResponse(OCResource *resource,
553                                           char *interfaceFilter,
554                                           char *resourceTypeFilter)
555 {
556     if (!resource)
557     {
558         OIC_LOG(ERROR, TAG, "Invalid resource");
559         return false;
560     }
561
562     if (resource->resourceProperties & OC_EXPLICIT_DISCOVERABLE)
563     {
564         /*
565          * At least one valid filter should be available to
566          * include the resource in discovery response
567          */
568         if (!(resourceTypeFilter && *resourceTypeFilter))
569         {
570             OIC_LOG_V(INFO, TAG, "%s no query string for EXPLICIT_DISCOVERABLE \
571                 resource", resource->uri);
572             return false;
573         }
574     }
575     else if ( !(resource->resourceProperties & OC_ACTIVE) ||
576          !(resource->resourceProperties & OC_DISCOVERABLE))
577     {
578         OIC_LOG_V(INFO, TAG, "%s not ACTIVE or DISCOVERABLE", resource->uri);
579         return false;
580     }
581
582     return resourceMatchesIFFilter(resource, interfaceFilter) &&
583            resourceMatchesRTFilter(resource, resourceTypeFilter);
584
585 }
586
587 OCStackResult SendNonPersistantDiscoveryResponse(OCServerRequest *request, OCResource *resource,
588                                 OCPayload *discoveryPayload, OCEntityHandlerResult ehResult)
589 {
590     OCEntityHandlerResponse response = {0};
591
592     response.ehResult = ehResult;
593     response.payload = discoveryPayload;
594     response.persistentBufferFlag = 0;
595     response.requestHandle = (OCRequestHandle) request;
596     response.resourceHandle = (OCResourceHandle) resource;
597
598     return OCDoResponse(&response);
599 }
600
601 #ifdef WITH_RD
602 static OCStackResult checkResourceExistsAtRD(const char *interfaceType, const char *resourceType,
603      OCResource **payload, OCDevAddr *devAddr)
604 {
605     OCResourceCollectionPayload *repPayload;
606     if (!payload)
607     {
608         return OC_STACK_ERROR;
609     }
610     if (OCRDCheckPublishedResource(interfaceType, resourceType, &repPayload, devAddr) == OC_STACK_OK)
611     {
612         if (!repPayload)
613         {
614             return OC_STACK_ERROR;
615         }
616         OCResource *ptr = ((OCResource *) OICCalloc(1, sizeof(OCResource)));
617         if (!ptr)
618         {
619            return OC_STACK_NO_MEMORY;
620         }
621
622         ptr->uri = OICStrdup(repPayload->setLinks->href);
623         if (!ptr->uri)
624         {
625            return OC_STACK_NO_MEMORY;
626         }
627         OCStringLL *rt = repPayload->setLinks->rt;
628         while (rt)
629         {
630             OCResourceType *temp = (OCResourceType *) OICCalloc(1, sizeof(OCResourceType));
631             if(!temp)
632             {
633                 OICFree(ptr->uri);
634                 return OC_STACK_NO_MEMORY;
635             }
636             temp->next = NULL;
637             temp->resourcetypename = OICStrdup(rt->value);
638             if (!ptr->rsrcType)
639             {
640                 ptr->rsrcType = temp;
641             }
642             else
643             {
644                 OCResourceType *type = ptr->rsrcType;
645                 while (type->next)
646                 {
647                     type = type->next;
648                 }
649                 type->next = temp;
650             }
651             rt = rt->next;
652         }
653
654         OCStringLL *itf = repPayload->setLinks->itf;
655         while (itf)
656         {
657             OCResourceInterface *temp = (OCResourceInterface *) OICCalloc(1, sizeof(OCResourceInterface));
658             if (!temp)
659             {
660                 OICFree(ptr->uri);
661
662                 return OC_STACK_NO_MEMORY;
663             }
664             temp->next = NULL;
665             temp->name = OICStrdup(itf->value);
666             if (!ptr->rsrcInterface)
667             {
668                 ptr->rsrcInterface = temp;
669             }
670             else
671             {
672                 OCResourceInterface *type = ptr->rsrcInterface;
673                 while (type->next)
674                 {
675                     type = type->next;
676                 }
677                 type->next = temp;
678             }
679             itf = itf->next;
680         }
681
682         ptr->resourceProperties = (OCResourceProperty) repPayload->tags->bitmap;
683
684         OCFreeCollectionResource(repPayload);
685         *payload = ptr;
686         return OC_STACK_OK;
687     }
688     else
689     {
690         OIC_LOG_V(ERROR, TAG, "The resource type or interface type doe not exist \
691                              on the resource directory");
692     }
693     return OC_STACK_ERROR;
694 }
695 #endif
696
697 static OCStackResult HandleVirtualResource (OCServerRequest *request, OCResource* resource)
698 {
699     if (!request || !resource)
700     {
701         return OC_STACK_INVALID_PARAM;
702     }
703
704     OCStackResult discoveryResult = OC_STACK_ERROR;
705
706     bool bMulticast    = false;     // Was the discovery request a multicast request?
707     OCPayload* payload = NULL;
708
709     OIC_LOG(INFO, TAG, "Entering HandleVirtualResource");
710
711     OCVirtualResources virtualUriInRequest = GetTypeOfVirtualURI (request->resourceUrl);
712
713     // Step 1: Generate the response to discovery request
714     if (virtualUriInRequest == OC_WELL_KNOWN_URI)
715     {
716         if (request->method == OC_REST_PUT || request->method == OC_REST_POST || request->method == OC_REST_DELETE)
717         {
718             OIC_LOG_V(ERROR, TAG, "Resource : %s not permitted for method: %d", request->resourceUrl, request->method);
719             return OC_STACK_UNAUTHORIZED_REQ;
720         }
721
722         char *interfaceQuery = NULL;
723         char *resourceTypeQuery = NULL;
724
725         discoveryResult = getQueryParamsForFiltering (virtualUriInRequest, request->query,
726                 &interfaceQuery, &resourceTypeQuery);
727         bool interfaceQueryAllocated = false;
728         if (!interfaceQuery && !resourceTypeQuery)
729         {
730             interfaceQueryAllocated = true;
731             interfaceQuery = OICStrdup(OC_RSRVD_INTERFACE_LL);
732         }
733
734         if (discoveryResult == OC_STACK_OK)
735         {
736             payload = (OCPayload *)OCDiscoveryPayloadCreate();
737
738             if (payload)
739             {
740                 OCDiscoveryPayload *discPayload = (OCDiscoveryPayload *)payload;
741                 discPayload->sid = (char *)OICCalloc(1, UUID_STRING_SIZE);
742                 VERIFY_NON_NULL(discPayload->sid, ERROR, OC_STACK_NO_MEMORY);
743
744                 const char* uid = OCGetServerInstanceIDString();
745                 if (uid)
746                 {
747                     memcpy(discPayload->sid, uid, UUID_STRING_SIZE);
748                 }
749
750                 if (!resourceTypeQuery && interfaceQuery && (0 == strcmp(interfaceQuery, OC_RSRVD_INTERFACE_LL)))
751                 {
752                     for (; resource && discoveryResult == OC_STACK_OK; resource = resource->next)
753                     {
754                         bool result = false;
755                         if (resource->resourceProperties & OC_DISCOVERABLE)
756                         {
757                             result = true;
758                         }
759
760                         if (result)
761                         {
762                             discoveryResult = BuildVirtualResourceResponse(resource,
763                             discPayload, &request->devAddr, false);
764                         }
765                     }
766                 }
767                 else
768                 {
769                     if (interfaceQuery && (0 != strcmp(interfaceQuery, OC_RSRVD_INTERFACE_LL)))
770                     {
771                         discPayload->uri = OICStrdup(OC_RSRVD_WELL_KNOWN_URI);
772                         VERIFY_NON_NULL(discPayload->uri, ERROR, OC_STACK_NO_MEMORY);
773                         if (savedDeviceInfo.deviceName)
774                         {
775                             discPayload->name = OICStrdup(savedDeviceInfo.deviceName);
776                             VERIFY_NON_NULL(discPayload->name, ERROR, OC_STACK_NO_MEMORY);
777                         }
778                         discPayload->type = OICStrdup(OC_RSRVD_RESOURCE_TYPE_RES);
779                         VERIFY_NON_NULL(discPayload->type, ERROR, OC_STACK_NO_MEMORY);
780                         OCResourcePayloadAddStringLL(&discPayload->interface, OC_RSRVD_INTERFACE_LL);
781                         OCResourcePayloadAddStringLL(&discPayload->interface, OC_RSRVD_INTERFACE_DEFAULT);
782                         VERIFY_NON_NULL(discPayload->interface, ERROR, OC_STACK_NO_MEMORY);
783                     }
784                     bool foundResourceAtRD = false;
785                     for (;resource && discoveryResult == OC_STACK_OK; resource = resource->next)
786                     {
787 #ifdef WITH_RD
788                         if (strcmp(resource->uri, OC_RSRVD_RD_URI) == 0)
789                         {
790                             OCResource *resource1 = NULL;
791                             OCDevAddr devAddr;
792                             discoveryResult = checkResourceExistsAtRD(interfaceQuery,
793                                 resourceTypeQuery, &resource1, &devAddr);
794                             if (discoveryResult != OC_STACK_OK)
795                             {
796                                  break;
797                             }
798                             discoveryResult = BuildVirtualResourceResponse(resource1,
799                                 discPayload, &devAddr, true);
800                             if (payload)
801                             {
802                                 discPayload->baseURI = OICStrdup(devAddr.addr);
803                             }
804                             OICFree(resource1->uri);
805                             for (OCResourceType *rsrcRt = resource1->rsrcType, *rsrcRtNext = NULL; rsrcRt; )
806                             {
807                                 rsrcRtNext = rsrcRt->next;
808                                 OICFree(rsrcRt->resourcetypename);
809                                 OICFree(rsrcRt);
810                                 rsrcRt = rsrcRtNext;
811                             }
812
813                             for (OCResourceInterface *rsrcPtr = resource1->rsrcInterface, *rsrcNext = NULL; rsrcPtr; )
814                             {
815                                 rsrcNext = rsrcPtr->next;
816                                 OICFree(rsrcPtr->name);
817                                 OICFree(rsrcPtr);
818                                 rsrcPtr = rsrcNext;
819                             }
820                             foundResourceAtRD = true;
821                         }
822 #endif
823                         if (!foundResourceAtRD && includeThisResourceInResponse(resource, interfaceQuery, resourceTypeQuery))
824                         {
825                             discoveryResult = BuildVirtualResourceResponse(resource,
826                                 discPayload, &request->devAddr, false);
827                         }
828                     }
829                     // Set discoveryResult appropriately if no 'valid' resources are available
830                     if (discPayload->resources == NULL && !foundResourceAtRD)
831                     {
832                         discoveryResult = OC_STACK_NO_RESOURCE;
833                     }
834                 }
835             }
836             else
837             {
838                 discoveryResult = OC_STACK_NO_MEMORY;
839             }
840         }
841         else
842         {
843             OIC_LOG_V(ERROR, TAG, "Error (%d) parsing query.", discoveryResult);
844         }
845         if (interfaceQueryAllocated)
846         {
847             OICFree(interfaceQuery);
848         }
849     }
850     else if (virtualUriInRequest == OC_DEVICE_URI)
851     {
852         if (request->method == OC_REST_PUT || request->method == OC_REST_POST || request->method == OC_REST_DELETE)
853         {
854             OIC_LOG_V(ERROR, TAG, "Resource : %s not permitted for method: %d", request->resourceUrl, request->method);
855             return OC_STACK_UNAUTHORIZED_REQ;
856         }
857
858         const char* deviceId = OCGetServerInstanceIDString();
859         if (!deviceId)
860         {
861             discoveryResult = OC_STACK_ERROR;
862         }
863         else
864         {
865             payload = (OCPayload*) OCDevicePayloadCreate(deviceId, savedDeviceInfo.deviceName,
866                 savedDeviceInfo.types, savedDeviceInfo.specVersion, savedDeviceInfo.dataModelVersion);
867             if (!payload)
868             {
869                 discoveryResult = OC_STACK_NO_MEMORY;
870             }
871             else
872             {
873                 discoveryResult = OC_STACK_OK;
874             }
875         }
876     }
877     else if (virtualUriInRequest == OC_PLATFORM_URI)
878     {
879         if (request->method == OC_REST_PUT || request->method == OC_REST_POST || request->method == OC_REST_DELETE)
880         {
881             OIC_LOG_V(ERROR, TAG, "Resource : %s not permitted for method: %d", request->resourceUrl, request->method);
882             return OC_STACK_UNAUTHORIZED_REQ;
883         }
884
885         payload = (OCPayload*)OCPlatformPayloadCreate(&savedPlatformInfo);
886         if (!payload)
887         {
888             discoveryResult = OC_STACK_NO_MEMORY;
889         }
890         else
891         {
892             discoveryResult = OC_STACK_OK;
893         }
894     }
895 #ifdef ROUTING_GATEWAY
896     else if (OC_GATEWAY_URI == virtualUriInRequest)
897     {
898         // Received request for a gateway
899         OIC_LOG(INFO, TAG, "Request is for Gateway Virtual Request");
900         discoveryResult = RMHandleGatewayRequest(request, resource);
901
902     }
903 #endif
904
905     /**
906      * Step 2: Send the discovery response
907      *
908      * Iotivity should respond to discovery requests in below manner:
909      * 1)If query filter matching fails and discovery request is multicast,
910      *   it should NOT send any response.
911      * 2)If query filter matching fails and discovery request is unicast,
912      *   it should send an error(RESOURCE_NOT_FOUND - 404) response.
913      * 3)If Server does not have any 'DISCOVERABLE' resources and discovery
914      *   request is multicast, it should NOT send any response.
915      * 4)If Server does not have any 'DISCOVERABLE' resources and discovery
916      *   request is unicast, it should send an error(RESOURCE_NOT_FOUND - 404) response.
917      */
918
919 #ifdef WITH_PRESENCE
920     if ((virtualUriInRequest == OC_PRESENCE) &&
921         (resource->resourceProperties & OC_ACTIVE))
922     {
923         // Presence uses observer notification api to respond via SendPresenceNotification.
924         SendPresenceNotification(resource->rsrcType, OC_PRESENCE_TRIGGER_CHANGE);
925     }
926     else
927     #endif
928 #ifdef ROUTING_GATEWAY
929     // Gateway uses the RMHandleGatewayRequest to respond to the request.
930     if (OC_GATEWAY_URI != virtualUriInRequest)
931 #endif
932     {
933         if(discoveryResult == OC_STACK_OK)
934         {
935             SendNonPersistantDiscoveryResponse(request, resource, payload, OC_EH_OK);
936         }
937         else if(bMulticast == false && (request->devAddr.adapter != OC_ADAPTER_RFCOMM_BTEDR) &&
938                (request->devAddr.adapter != OC_ADAPTER_GATT_BTLE))
939         {
940             OIC_LOG_V(ERROR, TAG, "Sending a (%d) error to (%d)  \
941                 discovery request", discoveryResult, virtualUriInRequest);
942             SendNonPersistantDiscoveryResponse(request, resource, NULL,
943                 (discoveryResult == OC_STACK_NO_RESOURCE) ? OC_EH_RESOURCE_NOT_FOUND : OC_EH_ERROR);
944         }
945         else
946         {
947             // Ignoring the discovery request as per RFC 7252, Section #8.2
948             OIC_LOG(INFO, TAG, "Silently ignoring the request since device does not have \
949                 any useful data to send");
950         }
951     }
952
953     OCPayloadDestroy(payload);
954
955     return OC_STACK_OK;
956 }
957
958 static OCStackResult
959 HandleDefaultDeviceEntityHandler (OCServerRequest *request)
960 {
961     if(!request)
962     {
963         return OC_STACK_INVALID_PARAM;
964     }
965
966     OCStackResult result = OC_STACK_OK;
967     OCEntityHandlerResult ehResult = OC_EH_ERROR;
968     OCEntityHandlerRequest ehRequest = {0};
969
970     OIC_LOG(INFO, TAG, "Entering HandleResourceWithDefaultDeviceEntityHandler");
971     result = FormOCEntityHandlerRequest(&ehRequest,
972                                         (OCRequestHandle) request,
973                                         request->method,
974                                         &request->devAddr,
975                                         (OCResourceHandle) NULL, request->query,
976                                         PAYLOAD_TYPE_REPRESENTATION,
977                                         request->payload,
978                                         request->payloadSize,
979                                         request->numRcvdVendorSpecificHeaderOptions,
980                                         request->rcvdVendorSpecificHeaderOptions,
981                                         (OCObserveAction)request->observationOption,
982                                         (OCObservationId)0,
983                                         request->coapID);
984     VERIFY_SUCCESS(result, OC_STACK_OK);
985
986     // At this point we know for sure that defaultDeviceHandler exists
987     ehResult = defaultDeviceHandler(OC_REQUEST_FLAG, &ehRequest,
988                                   (char*) request->resourceUrl, defaultDeviceHandlerCallbackParameter);
989     if(ehResult == OC_EH_SLOW)
990     {
991         OIC_LOG(INFO, TAG, "This is a slow resource");
992         request->slowFlag = 1;
993     }
994     else if(ehResult == OC_EH_ERROR)
995     {
996         FindAndDeleteServerRequest(request);
997     }
998     result = EntityHandlerCodeToOCStackCode(ehResult);
999 exit:
1000     OCPayloadDestroy(ehRequest.payload);
1001     return result;
1002 }
1003
1004 static OCStackResult
1005 HandleResourceWithEntityHandler (OCServerRequest *request,
1006                                  OCResource *resource,
1007                                  uint8_t collectionResource)
1008 {
1009     if(!request || ! resource)
1010     {
1011         return OC_STACK_INVALID_PARAM;
1012     }
1013
1014     OCStackResult result = OC_STACK_ERROR;
1015     OCEntityHandlerResult ehResult = OC_EH_ERROR;
1016     OCEntityHandlerFlag ehFlag = OC_REQUEST_FLAG;
1017     ResourceObserver *resObs = NULL;
1018
1019     OCEntityHandlerRequest ehRequest = {0};
1020
1021     OIC_LOG(INFO, TAG, "Entering HandleResourceWithEntityHandler");
1022     OCPayloadType type = PAYLOAD_TYPE_REPRESENTATION;
1023     // check the security resource
1024     if (request && request->resourceUrl && SRMIsSecurityResourceURI(request->resourceUrl))
1025     {
1026         type = PAYLOAD_TYPE_SECURITY;
1027
1028     }
1029
1030     if (request && strcmp(request->resourceUrl, OC_RSRVD_RD_URI) == 0)
1031     {
1032         type = PAYLOAD_TYPE_RD;
1033     }
1034
1035     result = FormOCEntityHandlerRequest(&ehRequest,
1036                                         (OCRequestHandle)request,
1037                                         request->method,
1038                                         &request->devAddr,
1039                                         (OCResourceHandle)resource,
1040                                         request->query,
1041                                         type,
1042                                         request->payload,
1043                                         request->payloadSize,
1044                                         request->numRcvdVendorSpecificHeaderOptions,
1045                                         request->rcvdVendorSpecificHeaderOptions,
1046                                         (OCObserveAction)request->observationOption,
1047                                         0,
1048                                         request->coapID);
1049     VERIFY_SUCCESS(result, OC_STACK_OK);
1050
1051     if(ehRequest.obsInfo.action == OC_OBSERVE_NO_OPTION)
1052     {
1053         OIC_LOG(INFO, TAG, "No observation requested");
1054         ehFlag = OC_REQUEST_FLAG;
1055     }
1056     else if(ehRequest.obsInfo.action == OC_OBSERVE_REGISTER && !collectionResource)
1057     {
1058         OIC_LOG(INFO, TAG, "Observation registration requested");
1059
1060         ResourceObserver *obs = GetObserverUsingToken (request->requestToken,
1061                                     request->tokenLength);
1062
1063         if (obs)
1064         {
1065             OIC_LOG (INFO, TAG, "Observer with this token already present");
1066             OIC_LOG (INFO, TAG, "Possibly re-transmitted CON OBS request");
1067             OIC_LOG (INFO, TAG, "Not adding observer. Not responding to client");
1068             OIC_LOG (INFO, TAG, "The first request for this token is already ACKED.");
1069
1070             // server requests are usually free'd when the response is sent out
1071             // for the request in ocserverrequest.c : HandleSingleResponse()
1072             // Since we are making an early return and not responding, the server request
1073             // needs to be deleted.
1074             FindAndDeleteServerRequest (request);
1075             return OC_STACK_OK;
1076         }
1077
1078         result = GenerateObserverId(&ehRequest.obsInfo.obsId);
1079         VERIFY_SUCCESS(result, OC_STACK_OK);
1080
1081         result = AddObserver ((const char*)(request->resourceUrl),
1082                 (const char *)(request->query),
1083                 ehRequest.obsInfo.obsId, request->requestToken, request->tokenLength,
1084                 resource, request->qos, request->acceptFormat,
1085                 &request->devAddr);
1086
1087         if(result == OC_STACK_OK)
1088         {
1089             OIC_LOG(INFO, TAG, "Added observer successfully");
1090             request->observeResult = OC_STACK_OK;
1091             ehFlag = (OCEntityHandlerFlag)(OC_REQUEST_FLAG | OC_OBSERVE_FLAG);
1092         }
1093         else
1094         {
1095             // The error in observeResult for the request will be used when responding to this
1096             // request by omitting the observation option/sequence number.
1097             request->observeResult = OC_STACK_ERROR;
1098             OIC_LOG(ERROR, TAG, "Observer Addition failed");
1099             ehFlag = OC_REQUEST_FLAG;
1100             FindAndDeleteServerRequest(request);
1101             goto exit;
1102         }
1103
1104     }
1105     else if(ehRequest.obsInfo.action == OC_OBSERVE_DEREGISTER &&
1106             !collectionResource)
1107     {
1108         OIC_LOG(INFO, TAG, "Deregistering observation requested");
1109
1110         resObs = GetObserverUsingToken (request->requestToken, request->tokenLength);
1111
1112         if (NULL == resObs)
1113         {
1114             // Stack does not contain this observation request
1115             // Either token is incorrect or observation list is corrupted
1116             result = OC_STACK_ERROR;
1117             goto exit;
1118         }
1119         ehRequest.obsInfo.obsId = resObs->observeId;
1120         ehFlag = (OCEntityHandlerFlag)(ehFlag | OC_OBSERVE_FLAG);
1121
1122         result = DeleteObserverUsingToken (request->requestToken, request->tokenLength);
1123
1124         if(result == OC_STACK_OK)
1125         {
1126             OIC_LOG(INFO, TAG, "Removed observer successfully");
1127             request->observeResult = OC_STACK_OK;
1128         }
1129         else
1130         {
1131             request->observeResult = OC_STACK_ERROR;
1132             OIC_LOG(ERROR, TAG, "Observer Removal failed");
1133             FindAndDeleteServerRequest(request);
1134             goto exit;
1135         }
1136     }
1137     else
1138     {
1139         result = OC_STACK_ERROR;
1140         goto exit;
1141     }
1142
1143     ehResult = resource->entityHandler(ehFlag, &ehRequest, resource->entityHandlerCallbackParam);
1144     if(ehResult == OC_EH_SLOW)
1145     {
1146         OIC_LOG(INFO, TAG, "This is a slow resource");
1147         request->slowFlag = 1;
1148     }
1149     else if(ehResult == OC_EH_ERROR)
1150     {
1151         FindAndDeleteServerRequest(request);
1152     }
1153     result = EntityHandlerCodeToOCStackCode(ehResult);
1154 exit:
1155     OCPayloadDestroy(ehRequest.payload);
1156     return result;
1157 }
1158
1159 static OCStackResult
1160 HandleCollectionResourceDefaultEntityHandler (OCServerRequest *request,
1161                                               OCResource *resource)
1162 {
1163     if(!request || !resource)
1164     {
1165         return OC_STACK_INVALID_PARAM;
1166     }
1167
1168     OCStackResult result = OC_STACK_ERROR;
1169     OCEntityHandlerRequest ehRequest = {0};
1170
1171     result = FormOCEntityHandlerRequest(&ehRequest,
1172                                         (OCRequestHandle)request,
1173                                         request->method,
1174                                         &request->devAddr,
1175                                         (OCResourceHandle)resource,
1176                                         request->query,
1177                                         PAYLOAD_TYPE_REPRESENTATION,
1178                                         request->payload,
1179                                         request->payloadSize,
1180                                         request->numRcvdVendorSpecificHeaderOptions,
1181                                         request->rcvdVendorSpecificHeaderOptions,
1182                                         (OCObserveAction)request->observationOption,
1183                                         (OCObservationId)0,
1184                                         request->coapID);
1185     if(result == OC_STACK_OK)
1186     {
1187         result = DefaultCollectionEntityHandler (OC_REQUEST_FLAG, &ehRequest);
1188     }
1189
1190     OCPayloadDestroy(ehRequest.payload);
1191     return result;
1192 }
1193
1194 OCStackResult
1195 ProcessRequest(ResourceHandling resHandling, OCResource *resource, OCServerRequest *request)
1196 {
1197     OCStackResult ret = OC_STACK_OK;
1198
1199     switch (resHandling)
1200     {
1201         case OC_RESOURCE_VIRTUAL:
1202         {
1203             ret = HandleVirtualResource (request, resource);
1204             break;
1205         }
1206         case OC_RESOURCE_DEFAULT_DEVICE_ENTITYHANDLER:
1207         {
1208             ret = HandleDefaultDeviceEntityHandler(request);
1209             break;
1210         }
1211         case OC_RESOURCE_NOT_COLLECTION_DEFAULT_ENTITYHANDLER:
1212         {
1213             OIC_LOG(INFO, TAG, "OC_RESOURCE_NOT_COLLECTION_DEFAULT_ENTITYHANDLER");
1214             return OC_STACK_ERROR;
1215         }
1216         case OC_RESOURCE_NOT_COLLECTION_WITH_ENTITYHANDLER:
1217         {
1218             ret = HandleResourceWithEntityHandler (request, resource, 0);
1219             break;
1220         }
1221         case OC_RESOURCE_COLLECTION_WITH_ENTITYHANDLER:
1222         {
1223             ret = HandleResourceWithEntityHandler (request, resource, 1);
1224             break;
1225         }
1226         case OC_RESOURCE_COLLECTION_DEFAULT_ENTITYHANDLER:
1227         {
1228             ret = HandleCollectionResourceDefaultEntityHandler (request, resource);
1229             break;
1230         }
1231         case OC_RESOURCE_NOT_SPECIFIED:
1232         {
1233             ret = OC_STACK_NO_RESOURCE;
1234             break;
1235         }
1236         default:
1237         {
1238             OIC_LOG(INFO, TAG, "Invalid Resource Determination");
1239             return OC_STACK_ERROR;
1240         }
1241     }
1242     return ret;
1243 }
1244
1245 void DeletePlatformInfo()
1246 {
1247     OIC_LOG(INFO, TAG, "Deleting platform info.");
1248
1249     OICFree(savedPlatformInfo.platformID);
1250     savedPlatformInfo.platformID = NULL;
1251
1252     OICFree(savedPlatformInfo.manufacturerName);
1253     savedPlatformInfo.manufacturerName = NULL;
1254
1255     OICFree(savedPlatformInfo.manufacturerUrl);
1256     savedPlatformInfo.manufacturerUrl = NULL;
1257
1258     OICFree(savedPlatformInfo.modelNumber);
1259     savedPlatformInfo.modelNumber = NULL;
1260
1261     OICFree(savedPlatformInfo.dateOfManufacture);
1262     savedPlatformInfo.dateOfManufacture = NULL;
1263
1264     OICFree(savedPlatformInfo.platformVersion);
1265     savedPlatformInfo.platformVersion = NULL;
1266
1267     OICFree(savedPlatformInfo.operatingSystemVersion);
1268     savedPlatformInfo.operatingSystemVersion = NULL;
1269
1270     OICFree(savedPlatformInfo.hardwareVersion);
1271     savedPlatformInfo.hardwareVersion = NULL;
1272
1273     OICFree(savedPlatformInfo.firmwareVersion);
1274     savedPlatformInfo.firmwareVersion = NULL;
1275
1276     OICFree(savedPlatformInfo.supportUrl);
1277     savedPlatformInfo.supportUrl = NULL;
1278
1279     OICFree(savedPlatformInfo.systemTime);
1280     savedPlatformInfo.systemTime = NULL;
1281 }
1282
1283 static OCStackResult DeepCopyPlatFormInfo(OCPlatformInfo info)
1284 {
1285     savedPlatformInfo.platformID = OICStrdup(info.platformID);
1286     savedPlatformInfo.manufacturerName = OICStrdup(info.manufacturerName);
1287     savedPlatformInfo.manufacturerUrl = OICStrdup(info.manufacturerUrl);
1288     savedPlatformInfo.modelNumber = OICStrdup(info.modelNumber);
1289     savedPlatformInfo.dateOfManufacture = OICStrdup(info.dateOfManufacture);
1290     savedPlatformInfo.platformVersion = OICStrdup(info.platformVersion);
1291     savedPlatformInfo.operatingSystemVersion = OICStrdup(info.operatingSystemVersion);
1292     savedPlatformInfo.hardwareVersion = OICStrdup(info.hardwareVersion);
1293     savedPlatformInfo.firmwareVersion = OICStrdup(info.firmwareVersion);
1294     savedPlatformInfo.supportUrl = OICStrdup(info.supportUrl);
1295     savedPlatformInfo.systemTime = OICStrdup(info.systemTime);
1296
1297     if ((!savedPlatformInfo.platformID && info.platformID)||
1298         (!savedPlatformInfo.manufacturerName && info.manufacturerName)||
1299         (!savedPlatformInfo.manufacturerUrl && info.manufacturerUrl)||
1300         (!savedPlatformInfo.modelNumber && info.modelNumber)||
1301         (!savedPlatformInfo.dateOfManufacture && info.dateOfManufacture)||
1302         (!savedPlatformInfo.platformVersion && info.platformVersion)||
1303         (!savedPlatformInfo.operatingSystemVersion && info.operatingSystemVersion)||
1304         (!savedPlatformInfo.hardwareVersion && info.hardwareVersion)||
1305         (!savedPlatformInfo.firmwareVersion && info.firmwareVersion)||
1306         (!savedPlatformInfo.supportUrl && info.supportUrl)||
1307         (!savedPlatformInfo.systemTime && info.systemTime))
1308     {
1309         DeletePlatformInfo();
1310         return OC_STACK_INVALID_PARAM;
1311     }
1312
1313     return OC_STACK_OK;
1314
1315 }
1316
1317 OCStackResult SavePlatformInfo(OCPlatformInfo info)
1318 {
1319     DeletePlatformInfo();
1320
1321     OCStackResult res = DeepCopyPlatFormInfo(info);
1322
1323     if (res != OC_STACK_OK)
1324     {
1325         OIC_LOG_V(ERROR, TAG, "Failed to save platform info. errno(%d)", res);
1326     }
1327     else
1328     {
1329         OIC_LOG(INFO, TAG, "Platform info saved.");
1330     }
1331
1332     return res;
1333 }
1334
1335 void DeleteDeviceInfo()
1336 {
1337     OIC_LOG(INFO, TAG, "Deleting device info.");
1338
1339     OICFree(savedDeviceInfo.deviceName);
1340     OCFreeOCStringLL(savedDeviceInfo.types);
1341     OICFree(savedDeviceInfo.specVersion);
1342     OICFree(savedDeviceInfo.dataModelVersion);
1343     savedDeviceInfo.deviceName = NULL;
1344     savedDeviceInfo.specVersion = NULL;
1345     savedDeviceInfo.dataModelVersion = NULL;
1346 }
1347
1348 static OCStackResult DeepCopyDeviceInfo(OCDeviceInfo info)
1349 {
1350     savedDeviceInfo.deviceName = OICStrdup(info.deviceName);
1351
1352     if(!savedDeviceInfo.deviceName && info.deviceName)
1353     {
1354         DeleteDeviceInfo();
1355         return OC_STACK_NO_MEMORY;
1356     }
1357
1358     if (info.types)
1359     {
1360         savedDeviceInfo.types = CloneOCStringLL(info.types);
1361         if(!savedDeviceInfo.types && info.types)
1362         {
1363             DeleteDeviceInfo();
1364             return OC_STACK_NO_MEMORY;
1365         }
1366     }
1367
1368     if (info.specVersion)
1369     {
1370         savedDeviceInfo.specVersion = OICStrdup(info.specVersion);
1371         if(!savedDeviceInfo.specVersion && info.specVersion)
1372         {
1373             DeleteDeviceInfo();
1374             return OC_STACK_NO_MEMORY;
1375         }
1376     }
1377     else
1378     {
1379         savedDeviceInfo.specVersion = OICStrdup(OC_SPEC_VERSION);
1380         if(!savedDeviceInfo.specVersion && OC_SPEC_VERSION)
1381         {
1382             DeleteDeviceInfo();
1383             return OC_STACK_NO_MEMORY;
1384         }
1385     }
1386
1387     if (info.dataModelVersion)
1388     {
1389         savedDeviceInfo.dataModelVersion = OICStrdup(info.dataModelVersion);
1390         if(!savedDeviceInfo.dataModelVersion && info.dataModelVersion)
1391         {
1392             DeleteDeviceInfo();
1393             return OC_STACK_NO_MEMORY;
1394         }
1395     }
1396     else
1397     {
1398         savedDeviceInfo.dataModelVersion = OICStrdup(OC_DATA_MODEL_VERSION);
1399         if(!savedDeviceInfo.dataModelVersion && OC_DATA_MODEL_VERSION)
1400         {
1401             DeleteDeviceInfo();
1402             return OC_STACK_NO_MEMORY;
1403         }
1404     }
1405
1406     return OC_STACK_OK;
1407 }
1408
1409 OCStackResult SaveDeviceInfo(OCDeviceInfo info)
1410 {
1411     OCStackResult res = OC_STACK_OK;
1412
1413     DeleteDeviceInfo();
1414
1415     res = DeepCopyDeviceInfo(info);
1416
1417     VERIFY_SUCCESS(res, OC_STACK_OK);
1418
1419     if (OCGetServerInstanceIDString() == NULL)
1420     {
1421         OIC_LOG(INFO, TAG, "Device ID generation failed");
1422         res =  OC_STACK_ERROR;
1423         goto exit;
1424     }
1425
1426     OIC_LOG(INFO, TAG, "Device initialized successfully.");
1427     return OC_STACK_OK;
1428
1429 exit:
1430     DeleteDeviceInfo();
1431     return res;
1432 }