Donald Meyers / Mbed OS evan

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

mbed-client/source/m2mobjectinstance.cpp@0:06ee5f8a484a, 2017-03-18 (annotated)

Committer:
djmeyers
Date:
Sat Mar 18 22:37:16 2017 +0000
Revision:
0:06ee5f8a484a
Initial commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
djmeyers 0:06ee5f8a484a 1 /*
djmeyers 0:06ee5f8a484a 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
djmeyers 0:06ee5f8a484a 3 * SPDX-License-Identifier: Apache-2.0
djmeyers 0:06ee5f8a484a 4 * Licensed under the Apache License, Version 2.0 (the License); you may
djmeyers 0:06ee5f8a484a 5 * not use this file except in compliance with the License.
djmeyers 0:06ee5f8a484a 6 * You may obtain a copy of the License at
djmeyers 0:06ee5f8a484a 7 *
djmeyers 0:06ee5f8a484a 8 * http://www.apache.org/licenses/LICENSE-2.0
djmeyers 0:06ee5f8a484a 9 *
djmeyers 0:06ee5f8a484a 10 * Unless required by applicable law or agreed to in writing, software
djmeyers 0:06ee5f8a484a 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
djmeyers 0:06ee5f8a484a 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
djmeyers 0:06ee5f8a484a 13 * See the License for the specific language governing permissions and
djmeyers 0:06ee5f8a484a 14 * limitations under the License.
djmeyers 0:06ee5f8a484a 15 */
djmeyers 0:06ee5f8a484a 16 #include "mbed-client/m2mobjectinstance.h"
djmeyers 0:06ee5f8a484a 17 #include "mbed-client/m2mobject.h"
djmeyers 0:06ee5f8a484a 18 #include "mbed-client/m2mconstants.h"
djmeyers 0:06ee5f8a484a 19 #include "mbed-client/m2mresource.h"
djmeyers 0:06ee5f8a484a 20 #include "mbed-client/m2mresource.h"
djmeyers 0:06ee5f8a484a 21 #include "mbed-client/m2mobservationhandler.h"
djmeyers 0:06ee5f8a484a 22 #include "mbed-client/m2mstring.h"
djmeyers 0:06ee5f8a484a 23 #include "mbed-client/m2mstringbuffer.h"
djmeyers 0:06ee5f8a484a 24 #include "include/m2mtlvserializer.h"
djmeyers 0:06ee5f8a484a 25 #include "include/m2mtlvdeserializer.h"
djmeyers 0:06ee5f8a484a 26 #include "include/nsdllinker.h"
djmeyers 0:06ee5f8a484a 27 #include "include/m2mreporthandler.h"
djmeyers 0:06ee5f8a484a 28 #include "mbed-trace/mbed_trace.h"
djmeyers 0:06ee5f8a484a 29
djmeyers 0:06ee5f8a484a 30 #include <stdlib.h>
djmeyers 0:06ee5f8a484a 31
djmeyers 0:06ee5f8a484a 32 #define BUFFER_SIZE 10
djmeyers 0:06ee5f8a484a 33 #define TRACE_GROUP "mClt"
djmeyers 0:06ee5f8a484a 34
djmeyers 0:06ee5f8a484a 35 M2MObjectInstance::M2MObjectInstance(M2MObject& parent, const String &object_name,
djmeyers 0:06ee5f8a484a 36 const String &resource_type,
djmeyers 0:06ee5f8a484a 37 char *path,
djmeyers 0:06ee5f8a484a 38 bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 39 : M2MBase(object_name,
djmeyers 0:06ee5f8a484a 40 M2MBase::Dynamic,
djmeyers 0:06ee5f8a484a 41 resource_type,
djmeyers 0:06ee5f8a484a 42 path,
djmeyers 0:06ee5f8a484a 43 external_blockwise_store),
djmeyers 0:06ee5f8a484a 44 _parent(parent)
djmeyers 0:06ee5f8a484a 45 {
djmeyers 0:06ee5f8a484a 46 M2MBase::set_base_type(M2MBase::ObjectInstance);
djmeyers 0:06ee5f8a484a 47 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 48 }
djmeyers 0:06ee5f8a484a 49
djmeyers 0:06ee5f8a484a 50 M2MObjectInstance::M2MObjectInstance(M2MObject& parent, const lwm2m_parameters_s* static_res)
djmeyers 0:06ee5f8a484a 51 : M2MBase(static_res), _parent(parent)
djmeyers 0:06ee5f8a484a 52 {
djmeyers 0:06ee5f8a484a 53 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 54 }
djmeyers 0:06ee5f8a484a 55
djmeyers 0:06ee5f8a484a 56 M2MObjectInstance::~M2MObjectInstance()
djmeyers 0:06ee5f8a484a 57 {
djmeyers 0:06ee5f8a484a 58 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 59 M2MResource* res = NULL;
djmeyers 0:06ee5f8a484a 60 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 61 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 62 for (; it!=_resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 63 //Free allocated memory for resources.
djmeyers 0:06ee5f8a484a 64 res = *it;
djmeyers 0:06ee5f8a484a 65 delete res;
djmeyers 0:06ee5f8a484a 66 }
djmeyers 0:06ee5f8a484a 67 _resource_list.clear();
djmeyers 0:06ee5f8a484a 68 }
djmeyers 0:06ee5f8a484a 69 }
djmeyers 0:06ee5f8a484a 70
djmeyers 0:06ee5f8a484a 71 // TBD, ResourceType to the base class struct?? TODO!
djmeyers 0:06ee5f8a484a 72 M2MResource* M2MObjectInstance::create_static_resource(const lwm2m_parameters_s* static_res,
djmeyers 0:06ee5f8a484a 73 M2MResourceInstance::ResourceType type)
djmeyers 0:06ee5f8a484a 74 {
djmeyers 0:06ee5f8a484a 75 tr_debug("M2MObjectInstance::create_static_resource(lwm2m_parameters_s resource_name %s)", static_res->name);
djmeyers 0:06ee5f8a484a 76 M2MResource *res = NULL;
djmeyers 0:06ee5f8a484a 77 if (validate_string_length(static_res->name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 78 return res;
djmeyers 0:06ee5f8a484a 79 }
djmeyers 0:06ee5f8a484a 80 if(!resource(static_res->name)) {
djmeyers 0:06ee5f8a484a 81 res = new M2MResource(*this, static_res, type, (const uint16_t) M2MBase::instance_id());
djmeyers 0:06ee5f8a484a 82 if(res) {
djmeyers 0:06ee5f8a484a 83 res->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 84 //if (multiple_instance) {
djmeyers 0:06ee5f8a484a 85 //res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 86 //}
djmeyers 0:06ee5f8a484a 87 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 88 }
djmeyers 0:06ee5f8a484a 89 }
djmeyers 0:06ee5f8a484a 90 return res;
djmeyers 0:06ee5f8a484a 91 }
djmeyers 0:06ee5f8a484a 92
djmeyers 0:06ee5f8a484a 93 M2MResource* M2MObjectInstance::create_static_resource(const String &resource_name,
djmeyers 0:06ee5f8a484a 94 const String &resource_type,
djmeyers 0:06ee5f8a484a 95 M2MResourceInstance::ResourceType type,
djmeyers 0:06ee5f8a484a 96 const uint8_t *value,
djmeyers 0:06ee5f8a484a 97 const uint8_t value_length,
djmeyers 0:06ee5f8a484a 98 bool multiple_instance,
djmeyers 0:06ee5f8a484a 99 bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 100 {
djmeyers 0:06ee5f8a484a 101 tr_debug("M2MObjectInstance::create_static_resource(resource_name %s)",resource_name.c_str());
djmeyers 0:06ee5f8a484a 102 M2MResource *res = NULL;
djmeyers 0:06ee5f8a484a 103 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 104 return res;
djmeyers 0:06ee5f8a484a 105 }
djmeyers 0:06ee5f8a484a 106 if(!resource(resource_name)) {
djmeyers 0:06ee5f8a484a 107 char *path = create_path(*this, resource_name.c_str());
djmeyers 0:06ee5f8a484a 108
djmeyers 0:06ee5f8a484a 109 if (path) {
djmeyers 0:06ee5f8a484a 110 res = new M2MResource(*this, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 111 value, value_length, path, M2MBase::instance_id(),
djmeyers 0:06ee5f8a484a 112 multiple_instance, external_blockwise_store);
djmeyers 0:06ee5f8a484a 113 if(res) {
djmeyers 0:06ee5f8a484a 114 res->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 115 if (multiple_instance) {
djmeyers 0:06ee5f8a484a 116 res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 117 }
djmeyers 0:06ee5f8a484a 118 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 119 }
djmeyers 0:06ee5f8a484a 120 }
djmeyers 0:06ee5f8a484a 121 }
djmeyers 0:06ee5f8a484a 122 return res;
djmeyers 0:06ee5f8a484a 123 }
djmeyers 0:06ee5f8a484a 124
djmeyers 0:06ee5f8a484a 125 M2MResource* M2MObjectInstance::create_dynamic_resource(const lwm2m_parameters_s* static_res,
djmeyers 0:06ee5f8a484a 126 M2MResourceInstance::ResourceType type,
djmeyers 0:06ee5f8a484a 127 bool observable)
djmeyers 0:06ee5f8a484a 128 {
djmeyers 0:06ee5f8a484a 129 tr_debug("M2MObjectInstance::create_dynamic_resource(resource_name %s)", static_res->name);
djmeyers 0:06ee5f8a484a 130 M2MResource *res = NULL;
djmeyers 0:06ee5f8a484a 131
djmeyers 0:06ee5f8a484a 132 if (validate_string_length(static_res->name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 133 return res;
djmeyers 0:06ee5f8a484a 134 }
djmeyers 0:06ee5f8a484a 135 if(!resource(static_res->name)) {
djmeyers 0:06ee5f8a484a 136 res = new M2MResource(*this, static_res, type, M2MBase::instance_id());
djmeyers 0:06ee5f8a484a 137 if(res) {
djmeyers 0:06ee5f8a484a 138 //if (multiple_instance) { // TODO!
djmeyers 0:06ee5f8a484a 139 // res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 140 //}
djmeyers 0:06ee5f8a484a 141 res->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 142 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 143 }
djmeyers 0:06ee5f8a484a 144 }
djmeyers 0:06ee5f8a484a 145 return res;
djmeyers 0:06ee5f8a484a 146 }
djmeyers 0:06ee5f8a484a 147
djmeyers 0:06ee5f8a484a 148 M2MResource* M2MObjectInstance::create_dynamic_resource(const String &resource_name,
djmeyers 0:06ee5f8a484a 149 const String &resource_type,
djmeyers 0:06ee5f8a484a 150 M2MResourceInstance::ResourceType type,
djmeyers 0:06ee5f8a484a 151 bool observable,
djmeyers 0:06ee5f8a484a 152 bool multiple_instance,
djmeyers 0:06ee5f8a484a 153 bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 154 {
djmeyers 0:06ee5f8a484a 155 tr_debug("M2MObjectInstance::create_dynamic_resource(resource_name %s)",resource_name.c_str());
djmeyers 0:06ee5f8a484a 156 M2MResource *res = NULL;
djmeyers 0:06ee5f8a484a 157 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 158 return res;
djmeyers 0:06ee5f8a484a 159 }
djmeyers 0:06ee5f8a484a 160 if(!resource(resource_name)) {
djmeyers 0:06ee5f8a484a 161 char *path = create_path(*this, resource_name.c_str());
djmeyers 0:06ee5f8a484a 162 if (path) {
djmeyers 0:06ee5f8a484a 163 res = new M2MResource(*this, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 164 observable, path, M2MBase::instance_id(),
djmeyers 0:06ee5f8a484a 165 multiple_instance, external_blockwise_store);
djmeyers 0:06ee5f8a484a 166 if(res) {
djmeyers 0:06ee5f8a484a 167 if (multiple_instance) {
djmeyers 0:06ee5f8a484a 168 res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 169 }
djmeyers 0:06ee5f8a484a 170 res->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 171 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 172 }
djmeyers 0:06ee5f8a484a 173 }
djmeyers 0:06ee5f8a484a 174 }
djmeyers 0:06ee5f8a484a 175 return res;
djmeyers 0:06ee5f8a484a 176 }
djmeyers 0:06ee5f8a484a 177
djmeyers 0:06ee5f8a484a 178 M2MResourceInstance* M2MObjectInstance::create_static_resource_instance(const String &resource_name,
djmeyers 0:06ee5f8a484a 179 const String &resource_type,
djmeyers 0:06ee5f8a484a 180 M2MResourceInstance::ResourceType type,
djmeyers 0:06ee5f8a484a 181 const uint8_t *value,
djmeyers 0:06ee5f8a484a 182 const uint8_t value_length,
djmeyers 0:06ee5f8a484a 183 uint16_t instance_id,
djmeyers 0:06ee5f8a484a 184 bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 185 {
djmeyers 0:06ee5f8a484a 186 tr_debug("M2MObjectInstance::create_static_resource_instance(resource_name %s)",resource_name.c_str());
djmeyers 0:06ee5f8a484a 187 M2MResourceInstance *instance = NULL;
djmeyers 0:06ee5f8a484a 188 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 189
djmeyers 0:06ee5f8a484a 190 return instance;
djmeyers 0:06ee5f8a484a 191 }
djmeyers 0:06ee5f8a484a 192 M2MResource *res = resource(resource_name);
djmeyers 0:06ee5f8a484a 193 if(!res) {
djmeyers 0:06ee5f8a484a 194 char *path = create_path(*this, resource_name.c_str());
djmeyers 0:06ee5f8a484a 195 if (path) {
djmeyers 0:06ee5f8a484a 196 res = new M2MResource(*this, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 197 value, value_length, path, M2MBase::instance_id(),
djmeyers 0:06ee5f8a484a 198 true, external_blockwise_store);
djmeyers 0:06ee5f8a484a 199 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 200 res->set_operation(M2MBase::GET_ALLOWED);
djmeyers 0:06ee5f8a484a 201 res->set_observable(false);
djmeyers 0:06ee5f8a484a 202 res->set_register_uri(false);
djmeyers 0:06ee5f8a484a 203 }
djmeyers 0:06ee5f8a484a 204 }
djmeyers 0:06ee5f8a484a 205 if(res && res->supports_multiple_instances()&& (res->resource_instance(instance_id) == NULL)) {
djmeyers 0:06ee5f8a484a 206 char *path = M2MBase::create_path(*res, instance_id);
djmeyers 0:06ee5f8a484a 207 if (path) {
djmeyers 0:06ee5f8a484a 208 instance = new M2MResourceInstance(*res, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 209 value, value_length,
djmeyers 0:06ee5f8a484a 210 M2MBase::instance_id(),
djmeyers 0:06ee5f8a484a 211 path, external_blockwise_store);
djmeyers 0:06ee5f8a484a 212 if(instance) {
djmeyers 0:06ee5f8a484a 213 instance->set_operation(M2MBase::GET_ALLOWED);
djmeyers 0:06ee5f8a484a 214 instance->set_instance_id(instance_id);
djmeyers 0:06ee5f8a484a 215 res->add_resource_instance(instance);
djmeyers 0:06ee5f8a484a 216 }
djmeyers 0:06ee5f8a484a 217 }
djmeyers 0:06ee5f8a484a 218 }
djmeyers 0:06ee5f8a484a 219 return instance;
djmeyers 0:06ee5f8a484a 220 }
djmeyers 0:06ee5f8a484a 221
djmeyers 0:06ee5f8a484a 222 M2MResourceInstance* M2MObjectInstance::create_dynamic_resource_instance(const String &resource_name,
djmeyers 0:06ee5f8a484a 223 const String &resource_type,
djmeyers 0:06ee5f8a484a 224 M2MResourceInstance::ResourceType type,
djmeyers 0:06ee5f8a484a 225 bool observable,
djmeyers 0:06ee5f8a484a 226 uint16_t instance_id,
djmeyers 0:06ee5f8a484a 227 bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 228 {
djmeyers 0:06ee5f8a484a 229 tr_debug("M2MObjectInstance::create_dynamic_resource_instance(resource_name %s)",resource_name.c_str());
djmeyers 0:06ee5f8a484a 230 M2MResourceInstance *instance = NULL;
djmeyers 0:06ee5f8a484a 231 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
djmeyers 0:06ee5f8a484a 232 return instance;
djmeyers 0:06ee5f8a484a 233 }
djmeyers 0:06ee5f8a484a 234 M2MResource *res = resource(resource_name);
djmeyers 0:06ee5f8a484a 235 if(!res) {
djmeyers 0:06ee5f8a484a 236 char *path = create_path(*this, resource_name.c_str());
djmeyers 0:06ee5f8a484a 237 if (path) {
djmeyers 0:06ee5f8a484a 238 res = new M2MResource(*this, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 239 false, path, M2MBase::instance_id(), true);
djmeyers 0:06ee5f8a484a 240 _resource_list.push_back(res);
djmeyers 0:06ee5f8a484a 241 res->set_register_uri(false);
djmeyers 0:06ee5f8a484a 242 res->set_operation(M2MBase::GET_ALLOWED);
djmeyers 0:06ee5f8a484a 243 }
djmeyers 0:06ee5f8a484a 244 }
djmeyers 0:06ee5f8a484a 245 if (res && res->supports_multiple_instances() && (res->resource_instance(instance_id) == NULL)) {
djmeyers 0:06ee5f8a484a 246 char *path = create_path(*res, instance_id);
djmeyers 0:06ee5f8a484a 247 if (path) {
djmeyers 0:06ee5f8a484a 248 instance = new M2MResourceInstance(*res, resource_name, resource_type, type,
djmeyers 0:06ee5f8a484a 249 M2MBase::instance_id(),
djmeyers 0:06ee5f8a484a 250 path, external_blockwise_store);
djmeyers 0:06ee5f8a484a 251 if(instance) {
djmeyers 0:06ee5f8a484a 252 instance->set_operation(M2MBase::GET_ALLOWED);
djmeyers 0:06ee5f8a484a 253 instance->set_observable(observable);
djmeyers 0:06ee5f8a484a 254 instance->set_instance_id(instance_id);
djmeyers 0:06ee5f8a484a 255 res->add_resource_instance(instance);
djmeyers 0:06ee5f8a484a 256 }
djmeyers 0:06ee5f8a484a 257 }
djmeyers 0:06ee5f8a484a 258 }
djmeyers 0:06ee5f8a484a 259 return instance;
djmeyers 0:06ee5f8a484a 260 }
djmeyers 0:06ee5f8a484a 261
djmeyers 0:06ee5f8a484a 262 bool M2MObjectInstance::remove_resource(const String &resource_name)
djmeyers 0:06ee5f8a484a 263 {
djmeyers 0:06ee5f8a484a 264 return remove_resource(resource_name.c_str());
djmeyers 0:06ee5f8a484a 265 }
djmeyers 0:06ee5f8a484a 266
djmeyers 0:06ee5f8a484a 267 bool M2MObjectInstance::remove_resource(const char *resource_name)
djmeyers 0:06ee5f8a484a 268 {
djmeyers 0:06ee5f8a484a 269 tr_debug("M2MObjectInstance::remove_resource(resource_name %s)", resource_name);
djmeyers 0:06ee5f8a484a 270
djmeyers 0:06ee5f8a484a 271 bool success = false;
djmeyers 0:06ee5f8a484a 272 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 273 M2MResource* res = NULL;
djmeyers 0:06ee5f8a484a 274 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 275 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 276 int pos = 0;
djmeyers 0:06ee5f8a484a 277 for ( ; it != _resource_list.end(); it++, pos++ ) {
djmeyers 0:06ee5f8a484a 278 if(strcmp((*it)->name(), resource_name) == 0) {
djmeyers 0:06ee5f8a484a 279 // Resource found and deleted.
djmeyers 0:06ee5f8a484a 280 res = *it;
djmeyers 0:06ee5f8a484a 281 delete res;
djmeyers 0:06ee5f8a484a 282 res = NULL;
djmeyers 0:06ee5f8a484a 283 _resource_list.erase(pos);
djmeyers 0:06ee5f8a484a 284 success = true;
djmeyers 0:06ee5f8a484a 285 break;
djmeyers 0:06ee5f8a484a 286 }
djmeyers 0:06ee5f8a484a 287 }
djmeyers 0:06ee5f8a484a 288 }
djmeyers 0:06ee5f8a484a 289 return success;
djmeyers 0:06ee5f8a484a 290 }
djmeyers 0:06ee5f8a484a 291
djmeyers 0:06ee5f8a484a 292 bool M2MObjectInstance::remove_resource_instance(const String &resource_name,
djmeyers 0:06ee5f8a484a 293 uint16_t inst_id)
djmeyers 0:06ee5f8a484a 294 {
djmeyers 0:06ee5f8a484a 295 tr_debug("M2MObjectInstance::remove_resource_instance(resource_name %s inst_id %d)",
djmeyers 0:06ee5f8a484a 296 resource_name.c_str(), inst_id);
djmeyers 0:06ee5f8a484a 297 bool success = false;
djmeyers 0:06ee5f8a484a 298 M2MResource *res = resource(resource_name);
djmeyers 0:06ee5f8a484a 299 if(res) {
djmeyers 0:06ee5f8a484a 300 M2MResourceInstanceList list = res->resource_instances();
djmeyers 0:06ee5f8a484a 301 M2MResourceInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 302 it = list.begin();
djmeyers 0:06ee5f8a484a 303 for ( ; it != list.end(); it++) {
djmeyers 0:06ee5f8a484a 304 if((*it)->instance_id() == inst_id) {
djmeyers 0:06ee5f8a484a 305 success = res->remove_resource_instance(inst_id);
djmeyers 0:06ee5f8a484a 306 if(res->resource_instance_count() == 0) {
djmeyers 0:06ee5f8a484a 307 M2MResourceList::const_iterator itr;
djmeyers 0:06ee5f8a484a 308 itr = _resource_list.begin();
djmeyers 0:06ee5f8a484a 309 int pos = 0;
djmeyers 0:06ee5f8a484a 310 for ( ; itr != _resource_list.end(); itr++, pos++ ) {
djmeyers 0:06ee5f8a484a 311 if(strcmp((*itr)->name(),resource_name.c_str()) == 0) {
djmeyers 0:06ee5f8a484a 312 delete res;
djmeyers 0:06ee5f8a484a 313 res = NULL;
djmeyers 0:06ee5f8a484a 314 _resource_list.erase(pos);
djmeyers 0:06ee5f8a484a 315 break;
djmeyers 0:06ee5f8a484a 316 }
djmeyers 0:06ee5f8a484a 317 }
djmeyers 0:06ee5f8a484a 318 }
djmeyers 0:06ee5f8a484a 319 break;
djmeyers 0:06ee5f8a484a 320 }
djmeyers 0:06ee5f8a484a 321 }
djmeyers 0:06ee5f8a484a 322 }
djmeyers 0:06ee5f8a484a 323 return success;
djmeyers 0:06ee5f8a484a 324 }
djmeyers 0:06ee5f8a484a 325
djmeyers 0:06ee5f8a484a 326 M2MResource* M2MObjectInstance::resource(const String &resource_name) const
djmeyers 0:06ee5f8a484a 327 {
djmeyers 0:06ee5f8a484a 328 return resource(resource_name.c_str());
djmeyers 0:06ee5f8a484a 329 }
djmeyers 0:06ee5f8a484a 330
djmeyers 0:06ee5f8a484a 331 M2MResource* M2MObjectInstance::resource(const char *resource_name) const
djmeyers 0:06ee5f8a484a 332 {
djmeyers 0:06ee5f8a484a 333 M2MResource *res = NULL;
djmeyers 0:06ee5f8a484a 334 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 335 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 336 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 337 for (; it!=_resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 338 if(strcmp((*it)->name(), resource_name) == 0) {
djmeyers 0:06ee5f8a484a 339 res = *it;
djmeyers 0:06ee5f8a484a 340 break;
djmeyers 0:06ee5f8a484a 341 }
djmeyers 0:06ee5f8a484a 342 }
djmeyers 0:06ee5f8a484a 343 }
djmeyers 0:06ee5f8a484a 344 return res;
djmeyers 0:06ee5f8a484a 345 }
djmeyers 0:06ee5f8a484a 346
djmeyers 0:06ee5f8a484a 347 const M2MResourceList& M2MObjectInstance::resources() const
djmeyers 0:06ee5f8a484a 348 {
djmeyers 0:06ee5f8a484a 349 return _resource_list;
djmeyers 0:06ee5f8a484a 350 }
djmeyers 0:06ee5f8a484a 351
djmeyers 0:06ee5f8a484a 352 uint16_t M2MObjectInstance::resource_count() const
djmeyers 0:06ee5f8a484a 353 {
djmeyers 0:06ee5f8a484a 354 uint16_t count = 0;
djmeyers 0:06ee5f8a484a 355 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 356 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 357 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 358 for ( ; it != _resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 359 if((*it)->supports_multiple_instances()) {
djmeyers 0:06ee5f8a484a 360 count += (*it)->resource_instance_count();
djmeyers 0:06ee5f8a484a 361 } else {
djmeyers 0:06ee5f8a484a 362 count++;
djmeyers 0:06ee5f8a484a 363 }
djmeyers 0:06ee5f8a484a 364 }
djmeyers 0:06ee5f8a484a 365 }
djmeyers 0:06ee5f8a484a 366 return count;
djmeyers 0:06ee5f8a484a 367 }
djmeyers 0:06ee5f8a484a 368
djmeyers 0:06ee5f8a484a 369 uint16_t M2MObjectInstance::resource_count(const String& resource) const
djmeyers 0:06ee5f8a484a 370 {
djmeyers 0:06ee5f8a484a 371
djmeyers 0:06ee5f8a484a 372 return resource_count(resource.c_str());
djmeyers 0:06ee5f8a484a 373 }
djmeyers 0:06ee5f8a484a 374
djmeyers 0:06ee5f8a484a 375 uint16_t M2MObjectInstance::resource_count(const char *resource) const
djmeyers 0:06ee5f8a484a 376 {
djmeyers 0:06ee5f8a484a 377 uint16_t count = 0;
djmeyers 0:06ee5f8a484a 378 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 379 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 380 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 381 for ( ; it != _resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 382 if(strcmp((*it)->name(), resource) == 0) {
djmeyers 0:06ee5f8a484a 383 if((*it)->supports_multiple_instances()) {
djmeyers 0:06ee5f8a484a 384 count += (*it)->resource_instance_count();
djmeyers 0:06ee5f8a484a 385 } else {
djmeyers 0:06ee5f8a484a 386 count++;
djmeyers 0:06ee5f8a484a 387 }
djmeyers 0:06ee5f8a484a 388 }
djmeyers 0:06ee5f8a484a 389 }
djmeyers 0:06ee5f8a484a 390 }
djmeyers 0:06ee5f8a484a 391 return count;
djmeyers 0:06ee5f8a484a 392 }
djmeyers 0:06ee5f8a484a 393
djmeyers 0:06ee5f8a484a 394 M2MBase::BaseType M2MObjectInstance::base_type() const
djmeyers 0:06ee5f8a484a 395 {
djmeyers 0:06ee5f8a484a 396 return M2MBase::base_type();
djmeyers 0:06ee5f8a484a 397 }
djmeyers 0:06ee5f8a484a 398
djmeyers 0:06ee5f8a484a 399 void M2MObjectInstance::add_observation_level(M2MBase::Observation observation_level)
djmeyers 0:06ee5f8a484a 400 {
djmeyers 0:06ee5f8a484a 401 M2MBase::add_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 402 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 403 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 404 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 405 for ( ; it != _resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 406 (*it)->add_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 407 }
djmeyers 0:06ee5f8a484a 408 }
djmeyers 0:06ee5f8a484a 409 }
djmeyers 0:06ee5f8a484a 410
djmeyers 0:06ee5f8a484a 411 void M2MObjectInstance::remove_observation_level(M2MBase::Observation observation_level)
djmeyers 0:06ee5f8a484a 412 {
djmeyers 0:06ee5f8a484a 413 M2MBase::remove_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 414 if(!_resource_list.empty()) {
djmeyers 0:06ee5f8a484a 415 M2MResourceList::const_iterator it;
djmeyers 0:06ee5f8a484a 416 it = _resource_list.begin();
djmeyers 0:06ee5f8a484a 417 for ( ; it != _resource_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 418 (*it)->remove_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 419 }
djmeyers 0:06ee5f8a484a 420 }
djmeyers 0:06ee5f8a484a 421 }
djmeyers 0:06ee5f8a484a 422
djmeyers 0:06ee5f8a484a 423 sn_coap_hdr_s* M2MObjectInstance::handle_get_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 424 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 425 M2MObservationHandler *observation_handler)
djmeyers 0:06ee5f8a484a 426 {
djmeyers 0:06ee5f8a484a 427 tr_debug("M2MObjectInstance::handle_get_request()");
djmeyers 0:06ee5f8a484a 428 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
djmeyers 0:06ee5f8a484a 429 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 430 received_coap_header,
djmeyers 0:06ee5f8a484a 431 msg_code);
djmeyers 0:06ee5f8a484a 432 uint8_t * data = NULL;
djmeyers 0:06ee5f8a484a 433 uint32_t data_length = 0;
djmeyers 0:06ee5f8a484a 434 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 435 // process the GET if we have registered a callback for it
djmeyers 0:06ee5f8a484a 436 if ((operation() & SN_GRS_GET_ALLOWED) != 0) {
djmeyers 0:06ee5f8a484a 437 if(coap_response) {
djmeyers 0:06ee5f8a484a 438 uint16_t coap_content_type = 0;
djmeyers 0:06ee5f8a484a 439 bool content_type_present = false;
djmeyers 0:06ee5f8a484a 440
djmeyers 0:06ee5f8a484a 441 if(received_coap_header->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 442 content_type_present = true;
djmeyers 0:06ee5f8a484a 443 coap_content_type = received_coap_header->content_format;
djmeyers 0:06ee5f8a484a 444 }
djmeyers 0:06ee5f8a484a 445 if(!content_type_present &&
djmeyers 0:06ee5f8a484a 446 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
djmeyers 0:06ee5f8a484a 447 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
djmeyers 0:06ee5f8a484a 448 }
djmeyers 0:06ee5f8a484a 449
djmeyers 0:06ee5f8a484a 450 tr_debug("M2MObjectInstance::handle_get_request() - Request Content-Type %d", coap_content_type);
djmeyers 0:06ee5f8a484a 451 if (coap_response->content_format == COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 452 coap_response->content_format = sn_coap_content_format_e(coap_content_type);
djmeyers 0:06ee5f8a484a 453
djmeyers 0:06ee5f8a484a 454 if (coap_response->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 455 set_coap_content_type(coap_content_type);
djmeyers 0:06ee5f8a484a 456 }
djmeyers 0:06ee5f8a484a 457 }
djmeyers 0:06ee5f8a484a 458 // fill in the CoAP response payload
djmeyers 0:06ee5f8a484a 459 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
djmeyers 0:06ee5f8a484a 460 M2MTLVSerializer serializer;
djmeyers 0:06ee5f8a484a 461 data = serializer.serialize(_resource_list, data_length);
djmeyers 0:06ee5f8a484a 462 } else {
djmeyers 0:06ee5f8a484a 463 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
djmeyers 0:06ee5f8a484a 464 }
djmeyers 0:06ee5f8a484a 465
djmeyers 0:06ee5f8a484a 466 coap_response->payload_len = data_length;
djmeyers 0:06ee5f8a484a 467 coap_response->payload_ptr = data;
djmeyers 0:06ee5f8a484a 468
djmeyers 0:06ee5f8a484a 469 if(data) {
djmeyers 0:06ee5f8a484a 470 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
djmeyers 0:06ee5f8a484a 471
djmeyers 0:06ee5f8a484a 472 coap_response->options_list_ptr->max_age = max_age();
djmeyers 0:06ee5f8a484a 473
djmeyers 0:06ee5f8a484a 474 if(received_coap_header->options_list_ptr) {
djmeyers 0:06ee5f8a484a 475 if(received_coap_header->options_list_ptr->observe != -1) {
djmeyers 0:06ee5f8a484a 476 if (is_observable()) {
djmeyers 0:06ee5f8a484a 477 uint32_t number = 0;
djmeyers 0:06ee5f8a484a 478 uint8_t observe_option = 0;
djmeyers 0:06ee5f8a484a 479 observe_option = received_coap_header->options_list_ptr->observe;
djmeyers 0:06ee5f8a484a 480 if(START_OBSERVATION == observe_option) {
djmeyers 0:06ee5f8a484a 481 tr_debug("M2MObjectInstance::handle_get_request - Starts Observation");
djmeyers 0:06ee5f8a484a 482 // If the observe length is 0 means register for observation.
djmeyers 0:06ee5f8a484a 483 if(received_coap_header->options_list_ptr->observe != -1) {
djmeyers 0:06ee5f8a484a 484 number = received_coap_header->options_list_ptr->observe;
djmeyers 0:06ee5f8a484a 485 }
djmeyers 0:06ee5f8a484a 486 if(received_coap_header->token_ptr) {
djmeyers 0:06ee5f8a484a 487 tr_debug("M2MObjectInstance::handle_get_request - Sets Observation Token to resource");
djmeyers 0:06ee5f8a484a 488 set_observation_token(received_coap_header->token_ptr,
djmeyers 0:06ee5f8a484a 489 received_coap_header->token_len);
djmeyers 0:06ee5f8a484a 490 }
djmeyers 0:06ee5f8a484a 491
djmeyers 0:06ee5f8a484a 492 // If the observe value is 0 means register for observation.
djmeyers 0:06ee5f8a484a 493 if(number == 0) {
djmeyers 0:06ee5f8a484a 494 tr_debug("M2MObjectInstance::handle_get_request - Put Resource under Observation");
djmeyers 0:06ee5f8a484a 495 set_under_observation(true,observation_handler);
djmeyers 0:06ee5f8a484a 496 add_observation_level(M2MBase::OI_Attribute);
djmeyers 0:06ee5f8a484a 497 coap_response->options_list_ptr->observe = observation_number();
djmeyers 0:06ee5f8a484a 498 }
djmeyers 0:06ee5f8a484a 499 } else if (STOP_OBSERVATION == observe_option) {
djmeyers 0:06ee5f8a484a 500 tr_debug("M2MObjectInstance::handle_get_request - Stops Observation");
djmeyers 0:06ee5f8a484a 501 set_under_observation(false,NULL);
djmeyers 0:06ee5f8a484a 502 remove_observation_level(M2MBase::OI_Attribute);
djmeyers 0:06ee5f8a484a 503
djmeyers 0:06ee5f8a484a 504 }
djmeyers 0:06ee5f8a484a 505 msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
djmeyers 0:06ee5f8a484a 506 }
djmeyers 0:06ee5f8a484a 507 else {
djmeyers 0:06ee5f8a484a 508 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 509 }
djmeyers 0:06ee5f8a484a 510 }
djmeyers 0:06ee5f8a484a 511 }
djmeyers 0:06ee5f8a484a 512 } else {
djmeyers 0:06ee5f8a484a 513 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
djmeyers 0:06ee5f8a484a 514 }
djmeyers 0:06ee5f8a484a 515 }
djmeyers 0:06ee5f8a484a 516 }else {
djmeyers 0:06ee5f8a484a 517 tr_error("M2MObjectInstance::handle_get_request - Return COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 518 // Operation is not allowed.
djmeyers 0:06ee5f8a484a 519 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 520 }
djmeyers 0:06ee5f8a484a 521 } else {
djmeyers 0:06ee5f8a484a 522 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 523 }
djmeyers 0:06ee5f8a484a 524 if(coap_response) {
djmeyers 0:06ee5f8a484a 525 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 526 }
djmeyers 0:06ee5f8a484a 527 return coap_response;
djmeyers 0:06ee5f8a484a 528 }
djmeyers 0:06ee5f8a484a 529
djmeyers 0:06ee5f8a484a 530 sn_coap_hdr_s* M2MObjectInstance::handle_put_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 531 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 532 M2MObservationHandler *observation_handler,
djmeyers 0:06ee5f8a484a 533 bool &/*execute_value_updated*/)
djmeyers 0:06ee5f8a484a 534 {
djmeyers 0:06ee5f8a484a 535 tr_debug("M2MObjectInstance::handle_put_request()");
djmeyers 0:06ee5f8a484a 536 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
djmeyers 0:06ee5f8a484a 537 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 538 received_coap_header,
djmeyers 0:06ee5f8a484a 539 msg_code);;
djmeyers 0:06ee5f8a484a 540 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 541 uint16_t coap_content_type = 0;
djmeyers 0:06ee5f8a484a 542 bool content_type_present = false;
djmeyers 0:06ee5f8a484a 543 if(received_coap_header->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 544 content_type_present = true;
djmeyers 0:06ee5f8a484a 545 if(coap_response) {
djmeyers 0:06ee5f8a484a 546 coap_content_type = received_coap_header->content_format;
djmeyers 0:06ee5f8a484a 547 }
djmeyers 0:06ee5f8a484a 548 }
djmeyers 0:06ee5f8a484a 549 if(received_coap_header->options_list_ptr &&
djmeyers 0:06ee5f8a484a 550 received_coap_header->options_list_ptr->uri_query_ptr) {
djmeyers 0:06ee5f8a484a 551 char *query = (char*)alloc_string_copy(received_coap_header->options_list_ptr->uri_query_ptr,
djmeyers 0:06ee5f8a484a 552 received_coap_header->options_list_ptr->uri_query_len);
djmeyers 0:06ee5f8a484a 553 if (query){
djmeyers 0:06ee5f8a484a 554 tr_debug("M2MObjectInstance::handle_put_request() - Query %s", query);
djmeyers 0:06ee5f8a484a 555 // if anything was updated, re-initialize the stored notification attributes
djmeyers 0:06ee5f8a484a 556 if (!handle_observation_attribute(query)){
djmeyers 0:06ee5f8a484a 557 tr_debug("M2MObjectInstance::handle_put_request() - Invalid query");
djmeyers 0:06ee5f8a484a 558 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
djmeyers 0:06ee5f8a484a 559 } else {
djmeyers 0:06ee5f8a484a 560 msg_code =COAP_MSG_CODE_RESPONSE_CHANGED;
djmeyers 0:06ee5f8a484a 561 }
djmeyers 0:06ee5f8a484a 562 free(query);
djmeyers 0:06ee5f8a484a 563 }
djmeyers 0:06ee5f8a484a 564 } else if ((operation() & SN_GRS_PUT_ALLOWED) != 0) {
djmeyers 0:06ee5f8a484a 565 if(!content_type_present &&
djmeyers 0:06ee5f8a484a 566 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
djmeyers 0:06ee5f8a484a 567 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
djmeyers 0:06ee5f8a484a 568 }
djmeyers 0:06ee5f8a484a 569
djmeyers 0:06ee5f8a484a 570 tr_debug("M2MObjectInstance::handle_put_request() - Request Content-Type %d", coap_content_type);
djmeyers 0:06ee5f8a484a 571
djmeyers 0:06ee5f8a484a 572 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
djmeyers 0:06ee5f8a484a 573 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
djmeyers 0:06ee5f8a484a 574 M2MTLVDeserializer deserializer;
djmeyers 0:06ee5f8a484a 575 if(received_coap_header->payload_ptr) {
djmeyers 0:06ee5f8a484a 576 error = deserializer.deserialize_resources(received_coap_header->payload_ptr,
djmeyers 0:06ee5f8a484a 577 received_coap_header->payload_len,
djmeyers 0:06ee5f8a484a 578 *this,
djmeyers 0:06ee5f8a484a 579 M2MTLVDeserializer::Put);
djmeyers 0:06ee5f8a484a 580 switch(error) {
djmeyers 0:06ee5f8a484a 581 case M2MTLVDeserializer::None:
djmeyers 0:06ee5f8a484a 582 if(observation_handler) {
djmeyers 0:06ee5f8a484a 583 observation_handler->value_updated(this);
djmeyers 0:06ee5f8a484a 584 }
djmeyers 0:06ee5f8a484a 585 msg_code = COAP_MSG_CODE_RESPONSE_CHANGED;
djmeyers 0:06ee5f8a484a 586 break;
djmeyers 0:06ee5f8a484a 587 case M2MTLVDeserializer::NotFound:
djmeyers 0:06ee5f8a484a 588 msg_code = COAP_MSG_CODE_RESPONSE_NOT_FOUND;
djmeyers 0:06ee5f8a484a 589 break;
djmeyers 0:06ee5f8a484a 590 case M2MTLVDeserializer::NotAllowed:
djmeyers 0:06ee5f8a484a 591 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 592 break;
djmeyers 0:06ee5f8a484a 593 case M2MTLVDeserializer::NotValid:
djmeyers 0:06ee5f8a484a 594 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
djmeyers 0:06ee5f8a484a 595 break;
djmeyers 0:06ee5f8a484a 596 }
djmeyers 0:06ee5f8a484a 597 }
djmeyers 0:06ee5f8a484a 598 } else {
djmeyers 0:06ee5f8a484a 599 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
djmeyers 0:06ee5f8a484a 600 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
djmeyers 0:06ee5f8a484a 601 } else {
djmeyers 0:06ee5f8a484a 602 // Operation is not allowed.
djmeyers 0:06ee5f8a484a 603 tr_error("M2MObjectInstance::handle_put_request() - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 604 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 605 }
djmeyers 0:06ee5f8a484a 606 } else {
djmeyers 0:06ee5f8a484a 607 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 608 }
djmeyers 0:06ee5f8a484a 609 if(coap_response) {
djmeyers 0:06ee5f8a484a 610 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 611 }
djmeyers 0:06ee5f8a484a 612 return coap_response;
djmeyers 0:06ee5f8a484a 613 }
djmeyers 0:06ee5f8a484a 614
djmeyers 0:06ee5f8a484a 615
djmeyers 0:06ee5f8a484a 616
djmeyers 0:06ee5f8a484a 617
djmeyers 0:06ee5f8a484a 618 sn_coap_hdr_s* M2MObjectInstance::handle_post_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 619 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 620 M2MObservationHandler *observation_handler,
djmeyers 0:06ee5f8a484a 621 bool &execute_value_updated,
djmeyers 0:06ee5f8a484a 622 sn_nsdl_addr_s *)
djmeyers 0:06ee5f8a484a 623 {
djmeyers 0:06ee5f8a484a 624 tr_debug("M2MObjectInstance::handle_post_request()");
djmeyers 0:06ee5f8a484a 625 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
djmeyers 0:06ee5f8a484a 626 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 627 received_coap_header,
djmeyers 0:06ee5f8a484a 628 msg_code);
djmeyers 0:06ee5f8a484a 629 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 630 if ((operation() & SN_GRS_POST_ALLOWED) != 0) {
djmeyers 0:06ee5f8a484a 631 uint16_t coap_content_type = 0;
djmeyers 0:06ee5f8a484a 632 bool content_type_present = false;
djmeyers 0:06ee5f8a484a 633 if(received_coap_header->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 634 content_type_present = true;
djmeyers 0:06ee5f8a484a 635 if(coap_response) {
djmeyers 0:06ee5f8a484a 636 coap_content_type = received_coap_header->content_format;
djmeyers 0:06ee5f8a484a 637 }
djmeyers 0:06ee5f8a484a 638 }
djmeyers 0:06ee5f8a484a 639 if(!content_type_present &&
djmeyers 0:06ee5f8a484a 640 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
djmeyers 0:06ee5f8a484a 641 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
djmeyers 0:06ee5f8a484a 642 }
djmeyers 0:06ee5f8a484a 643
djmeyers 0:06ee5f8a484a 644 tr_debug("M2MObjectInstance::handle_post_request() - Request Content-Type %d", coap_content_type);
djmeyers 0:06ee5f8a484a 645
djmeyers 0:06ee5f8a484a 646 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
djmeyers 0:06ee5f8a484a 647 M2MTLVDeserializer deserializer;
djmeyers 0:06ee5f8a484a 648 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
djmeyers 0:06ee5f8a484a 649 error = deserializer.deserialize_resources(received_coap_header->payload_ptr,
djmeyers 0:06ee5f8a484a 650 received_coap_header->payload_len,
djmeyers 0:06ee5f8a484a 651 *this,
djmeyers 0:06ee5f8a484a 652 M2MTLVDeserializer::Post);
djmeyers 0:06ee5f8a484a 653
djmeyers 0:06ee5f8a484a 654 uint16_t instance_id = deserializer.instance_id(received_coap_header->payload_ptr);
djmeyers 0:06ee5f8a484a 655 switch(error) {
djmeyers 0:06ee5f8a484a 656 case M2MTLVDeserializer::None:
djmeyers 0:06ee5f8a484a 657 if(observation_handler) {
djmeyers 0:06ee5f8a484a 658 execute_value_updated = true;
djmeyers 0:06ee5f8a484a 659 }
djmeyers 0:06ee5f8a484a 660 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
djmeyers 0:06ee5f8a484a 661
djmeyers 0:06ee5f8a484a 662 if (coap_response->options_list_ptr) {
djmeyers 0:06ee5f8a484a 663
djmeyers 0:06ee5f8a484a 664 StringBuffer<MAX_PATH_SIZE_3> obj_name;
djmeyers 0:06ee5f8a484a 665 if(!build_path(obj_name, M2MBase::name(), M2MBase::instance_id(), instance_id))
djmeyers 0:06ee5f8a484a 666 {
djmeyers 0:06ee5f8a484a 667 msg_code = COAP_MSG_CODE_RESPONSE_INTERNAL_SERVER_ERROR;
djmeyers 0:06ee5f8a484a 668 break;
djmeyers 0:06ee5f8a484a 669 }
djmeyers 0:06ee5f8a484a 670
djmeyers 0:06ee5f8a484a 671 coap_response->options_list_ptr->location_path_len = obj_name.get_size();
djmeyers 0:06ee5f8a484a 672 coap_response->options_list_ptr->location_path_ptr =
djmeyers 0:06ee5f8a484a 673 alloc_string_copy((uint8_t*)obj_name.c_str(),
djmeyers 0:06ee5f8a484a 674 coap_response->options_list_ptr->location_path_len);
djmeyers 0:06ee5f8a484a 675 // todo: handle allocation error
djmeyers 0:06ee5f8a484a 676 }
djmeyers 0:06ee5f8a484a 677 msg_code = COAP_MSG_CODE_RESPONSE_CREATED;
djmeyers 0:06ee5f8a484a 678 break;
djmeyers 0:06ee5f8a484a 679 case M2MTLVDeserializer::NotAllowed:
djmeyers 0:06ee5f8a484a 680 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 681 break;
djmeyers 0:06ee5f8a484a 682 case M2MTLVDeserializer::NotValid:
djmeyers 0:06ee5f8a484a 683 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
djmeyers 0:06ee5f8a484a 684 break;
djmeyers 0:06ee5f8a484a 685 default:
djmeyers 0:06ee5f8a484a 686 break;
djmeyers 0:06ee5f8a484a 687 }
djmeyers 0:06ee5f8a484a 688 } else {
djmeyers 0:06ee5f8a484a 689 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
djmeyers 0:06ee5f8a484a 690 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
djmeyers 0:06ee5f8a484a 691 } else {
djmeyers 0:06ee5f8a484a 692 // Operation is not allowed.
djmeyers 0:06ee5f8a484a 693 tr_error("M2MObjectInstance::handle_post_request() - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 694 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 695 }
djmeyers 0:06ee5f8a484a 696 } else {
djmeyers 0:06ee5f8a484a 697 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 698 }
djmeyers 0:06ee5f8a484a 699 if(coap_response) {
djmeyers 0:06ee5f8a484a 700 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 701 }
djmeyers 0:06ee5f8a484a 702 return coap_response;
djmeyers 0:06ee5f8a484a 703 }
djmeyers 0:06ee5f8a484a 704
djmeyers 0:06ee5f8a484a 705 void M2MObjectInstance::notification_update(M2MBase::Observation observation_level)
djmeyers 0:06ee5f8a484a 706 {
djmeyers 0:06ee5f8a484a 707 tr_debug("M2MObjectInstance::notification_update() - level(%d)", observation_level);
djmeyers 0:06ee5f8a484a 708 if((M2MBase::O_Attribute & observation_level) == M2MBase::O_Attribute) {
djmeyers 0:06ee5f8a484a 709 tr_debug("M2MObjectInstance::notification_update() - object callback");
djmeyers 0:06ee5f8a484a 710 _parent.notification_update(instance_id());
djmeyers 0:06ee5f8a484a 711 }
djmeyers 0:06ee5f8a484a 712 if((M2MBase::OI_Attribute & observation_level) == M2MBase::OI_Attribute) {
djmeyers 0:06ee5f8a484a 713 tr_debug("M2MObjectInstance::notification_update() - object instance callback");
djmeyers 0:06ee5f8a484a 714 M2MReportHandler *report_handler = M2MBase::report_handler();
djmeyers 0:06ee5f8a484a 715 if(report_handler && is_under_observation()) {
djmeyers 0:06ee5f8a484a 716 report_handler->set_notification_trigger();
djmeyers 0:06ee5f8a484a 717 }
djmeyers 0:06ee5f8a484a 718
djmeyers 0:06ee5f8a484a 719 }
djmeyers 0:06ee5f8a484a 720 }