Diff: simple-mbed-cloud-client/resource.cpp

Revision:

0:6b753f761943

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/simple-mbed-cloud-client/resource.cpp	Fri Oct 12 21:22:49 2018 +0000
@@ -0,0 +1,94 @@
+// ----------------------------------------------------------------------------
+// Copyright 2016-2018 ARM Ltd.
+//
+// SPDX-License-Identifier: Apache-2.0
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// ----------------------------------------------------------------------------
+
+#include "mbed-cloud-client/MbedCloudClient.h"
+#include "m2mresource.h"
+#include "mbed-client/m2minterface.h"
+#include <stdio.h>
+#include <string.h>
+#include "mbed.h"
+
+static void notification_delivery_status_cb_thunk(const M2MBase& base,
+                                                  const NoticationDeliveryStatus status,
+                                                  void *client_args) {
+    ((Callback<void(const M2MBase& base, const NoticationDeliveryStatus status)>*)client_args)->call(base, status);
+}
+
+M2MResource* add_resource(M2MObjectList *list, uint16_t object_id, uint16_t instance_id,
+                          uint16_t resource_id, const char *resource_type, M2MResourceInstance::ResourceType data_type,
+                          M2MBase::Operation allowed, const char *value, bool observable, Callback<void(const char*)> *put_cb,
+                          Callback<void(void*)> *post_cb,
+                          Callback<void(const M2MBase&, const NoticationDeliveryStatus)> *notification_status_cb)
+{
+    M2MObject *object = NULL;
+    M2MObjectInstance* object_instance = NULL;
+    M2MResource* resource = NULL;
+    char name[6];
+
+    //check if object already exists.
+    if (!list->empty()) {
+        M2MObjectList::const_iterator it;
+        it = list->begin();
+        for ( ; it != list->end(); it++ ) {
+            if ((*it)->name_id() == object_id) {
+                object = (*it);
+                break;
+            }
+        }
+    }
+    //Create new object if needed.
+    if (!object) {
+        snprintf(name, 6, "%d", object_id);
+        object = M2MInterfaceFactory::create_object(name);
+        list->push_back(object);
+    } else {
+        //check if instance already exists.
+        object_instance = object->object_instance(instance_id);
+    }
+    //Create new instance if needed.
+    if (!object_instance) {
+        object_instance = object->create_object_instance(instance_id);
+    }
+    //create the recource.
+    snprintf(name, 6, "%d", resource_id);
+    resource = object_instance->create_dynamic_resource(name, resource_type, data_type, observable);
+    //Set value if available.
+    if (strcmp(value, "") != 0) {
+        resource->set_value((const unsigned char*)value, strlen(value));
+    }
+    //Set allowed operations for accessing the resource.
+    resource->set_operation(allowed);
+    if (observable) {
+        resource->set_notification_delivery_status_cb(notification_delivery_status_cb_thunk, notification_status_cb);
+    }
+
+    if (put_cb) {
+        resource->set_value_updated_function(
+            FP1<void, const char*>(put_cb,
+                (void (Callback<void(const char*)>::*)(const char*))
+                    &Callback<void(const char*)>::call));
+    }
+
+    if (post_cb) {
+        resource->set_execute_function(FP1<void, void*>(post_cb,
+            (void (Callback<void(void*)>::*)(void*))
+                &Callback<void(void*)>::call));
+    }
+
+    return resource;
+}