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/m2mobject.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/m2mobject.h"
djmeyers 0:06ee5f8a484a 17 #include "mbed-client/m2mobservationhandler.h"
djmeyers 0:06ee5f8a484a 18 #include "mbed-client/m2mconstants.h"
djmeyers 0:06ee5f8a484a 19 #include "include/m2mtlvserializer.h"
djmeyers 0:06ee5f8a484a 20 #include "include/m2mtlvdeserializer.h"
djmeyers 0:06ee5f8a484a 21 #include "include/m2mreporthandler.h"
djmeyers 0:06ee5f8a484a 22 #include "mbed-trace/mbed_trace.h"
djmeyers 0:06ee5f8a484a 23 #include "mbed-client/m2mstringbuffer.h"
djmeyers 0:06ee5f8a484a 24
djmeyers 0:06ee5f8a484a 25 #include <stdlib.h>
djmeyers 0:06ee5f8a484a 26
djmeyers 0:06ee5f8a484a 27 #define BUFFER_SIZE 10
djmeyers 0:06ee5f8a484a 28 #define TRACE_GROUP "mClt"
djmeyers 0:06ee5f8a484a 29
djmeyers 0:06ee5f8a484a 30 M2MObject::M2MObject(const String &object_name, char *path, bool external_blockwise_store)
djmeyers 0:06ee5f8a484a 31 : M2MBase(object_name,
djmeyers 0:06ee5f8a484a 32 M2MBase::Dynamic,
djmeyers 0:06ee5f8a484a 33 "",
djmeyers 0:06ee5f8a484a 34 path,
djmeyers 0:06ee5f8a484a 35 external_blockwise_store),
djmeyers 0:06ee5f8a484a 36 _max_instance_count(MAX_UNINT_16_COUNT)
djmeyers 0:06ee5f8a484a 37 {
djmeyers 0:06ee5f8a484a 38 M2MBase::set_base_type(M2MBase::Object);
djmeyers 0:06ee5f8a484a 39 if(M2MBase::name_id() != -1) {
djmeyers 0:06ee5f8a484a 40 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 41 }
djmeyers 0:06ee5f8a484a 42 }
djmeyers 0:06ee5f8a484a 43
djmeyers 0:06ee5f8a484a 44 M2MObject::M2MObject(const M2MBase::lwm2m_parameters_s* static_res)
djmeyers 0:06ee5f8a484a 45 : M2MBase(static_res),
djmeyers 0:06ee5f8a484a 46 _max_instance_count(MAX_UNINT_16_COUNT)
djmeyers 0:06ee5f8a484a 47 {
djmeyers 0:06ee5f8a484a 48 if(static_res->name_id != -1) {
djmeyers 0:06ee5f8a484a 49 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 50 }
djmeyers 0:06ee5f8a484a 51 }
djmeyers 0:06ee5f8a484a 52
djmeyers 0:06ee5f8a484a 53 M2MObject::~M2MObject()
djmeyers 0:06ee5f8a484a 54 {
djmeyers 0:06ee5f8a484a 55 if(!_instance_list.empty()) {
djmeyers 0:06ee5f8a484a 56
djmeyers 0:06ee5f8a484a 57 M2MObjectInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 58 it = _instance_list.begin();
djmeyers 0:06ee5f8a484a 59 M2MObjectInstance* obj = NULL;
djmeyers 0:06ee5f8a484a 60 uint16_t index = 0;
djmeyers 0:06ee5f8a484a 61 for (; it!=_instance_list.end(); it++, index++ ) {
djmeyers 0:06ee5f8a484a 62 //Free allocated memory for object instances.
djmeyers 0:06ee5f8a484a 63 obj = *it;
djmeyers 0:06ee5f8a484a 64 delete obj;
djmeyers 0:06ee5f8a484a 65 }
djmeyers 0:06ee5f8a484a 66
djmeyers 0:06ee5f8a484a 67 _instance_list.clear();
djmeyers 0:06ee5f8a484a 68 }
djmeyers 0:06ee5f8a484a 69 }
djmeyers 0:06ee5f8a484a 70
djmeyers 0:06ee5f8a484a 71 M2MObjectInstance* M2MObject::create_object_instance(uint16_t instance_id)
djmeyers 0:06ee5f8a484a 72 {
djmeyers 0:06ee5f8a484a 73 tr_debug("M2MObject::create_object_instance - id: %d", instance_id);
djmeyers 0:06ee5f8a484a 74 M2MObjectInstance *instance = NULL;
djmeyers 0:06ee5f8a484a 75 if(!object_instance(instance_id)) {
djmeyers 0:06ee5f8a484a 76 char* path = create_path(*this, instance_id);
djmeyers 0:06ee5f8a484a 77 // Note: the object instance's name contains actually object's name.
djmeyers 0:06ee5f8a484a 78 instance = new M2MObjectInstance(*this, this->name(), "", path);
djmeyers 0:06ee5f8a484a 79 if(instance) {
djmeyers 0:06ee5f8a484a 80 instance->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 81 instance->set_instance_id(instance_id);
djmeyers 0:06ee5f8a484a 82 if(M2MBase::name_id() != -1) {
djmeyers 0:06ee5f8a484a 83 instance->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 84 }
djmeyers 0:06ee5f8a484a 85 _instance_list.push_back(instance);
djmeyers 0:06ee5f8a484a 86 }
djmeyers 0:06ee5f8a484a 87 }
djmeyers 0:06ee5f8a484a 88 return instance;
djmeyers 0:06ee5f8a484a 89 }
djmeyers 0:06ee5f8a484a 90
djmeyers 0:06ee5f8a484a 91 // KS: is this needed for object instance?? TODO!
djmeyers 0:06ee5f8a484a 92 M2MObjectInstance* M2MObject::create_object_instance(const lwm2m_parameters_s* s)
djmeyers 0:06ee5f8a484a 93 {
djmeyers 0:06ee5f8a484a 94 tr_debug("M2MObject::create_object_instance - id: %d", s->instance_id);
djmeyers 0:06ee5f8a484a 95 M2MObjectInstance *instance = NULL;
djmeyers 0:06ee5f8a484a 96 if(!object_instance(s->instance_id)) {
djmeyers 0:06ee5f8a484a 97
djmeyers 0:06ee5f8a484a 98 instance = new M2MObjectInstance(*this, s);
djmeyers 0:06ee5f8a484a 99 if(instance) {
djmeyers 0:06ee5f8a484a 100 instance->add_observation_level(observation_level());
djmeyers 0:06ee5f8a484a 101 //instance->set_instance_id(instance_id);
djmeyers 0:06ee5f8a484a 102 //if(M2MBase::name_id() != -1) {
djmeyers 0:06ee5f8a484a 103 // instance->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
djmeyers 0:06ee5f8a484a 104 //}
djmeyers 0:06ee5f8a484a 105 _instance_list.push_back(instance);
djmeyers 0:06ee5f8a484a 106 }
djmeyers 0:06ee5f8a484a 107 }
djmeyers 0:06ee5f8a484a 108 return instance;
djmeyers 0:06ee5f8a484a 109 }
djmeyers 0:06ee5f8a484a 110
djmeyers 0:06ee5f8a484a 111 bool M2MObject::remove_object_instance(uint16_t inst_id)
djmeyers 0:06ee5f8a484a 112 {
djmeyers 0:06ee5f8a484a 113 tr_debug("M2MObject::remove_object_instance(inst_id %d)", inst_id);
djmeyers 0:06ee5f8a484a 114 bool success = false;
djmeyers 0:06ee5f8a484a 115 if(!_instance_list.empty()) {
djmeyers 0:06ee5f8a484a 116 M2MObjectInstance* obj = NULL;
djmeyers 0:06ee5f8a484a 117 M2MObjectInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 118 it = _instance_list.begin();
djmeyers 0:06ee5f8a484a 119 int pos = 0;
djmeyers 0:06ee5f8a484a 120 for ( ; it != _instance_list.end(); it++, pos++ ) {
djmeyers 0:06ee5f8a484a 121 if((*it)->instance_id() == inst_id) {
djmeyers 0:06ee5f8a484a 122 // Instance found and deleted.
djmeyers 0:06ee5f8a484a 123 obj = *it;
djmeyers 0:06ee5f8a484a 124
djmeyers 0:06ee5f8a484a 125 _instance_list.erase(pos);
djmeyers 0:06ee5f8a484a 126 delete obj;
djmeyers 0:06ee5f8a484a 127 success = true;
djmeyers 0:06ee5f8a484a 128 break;
djmeyers 0:06ee5f8a484a 129 }
djmeyers 0:06ee5f8a484a 130 }
djmeyers 0:06ee5f8a484a 131 }
djmeyers 0:06ee5f8a484a 132 return success;
djmeyers 0:06ee5f8a484a 133 }
djmeyers 0:06ee5f8a484a 134
djmeyers 0:06ee5f8a484a 135 M2MObjectInstance* M2MObject::object_instance(uint16_t inst_id) const
djmeyers 0:06ee5f8a484a 136 {
djmeyers 0:06ee5f8a484a 137 tr_debug("M2MObject::object_instance(inst_id %d)", inst_id);
djmeyers 0:06ee5f8a484a 138 M2MObjectInstance *obj = NULL;
djmeyers 0:06ee5f8a484a 139 if(!_instance_list.empty()) {
djmeyers 0:06ee5f8a484a 140 M2MObjectInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 141 it = _instance_list.begin();
djmeyers 0:06ee5f8a484a 142 for ( ; it != _instance_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 143 if((*it)->instance_id() == inst_id) {
djmeyers 0:06ee5f8a484a 144 // Instance found.
djmeyers 0:06ee5f8a484a 145 obj = *it;
djmeyers 0:06ee5f8a484a 146 break;
djmeyers 0:06ee5f8a484a 147 }
djmeyers 0:06ee5f8a484a 148 }
djmeyers 0:06ee5f8a484a 149 }
djmeyers 0:06ee5f8a484a 150 return obj;
djmeyers 0:06ee5f8a484a 151 }
djmeyers 0:06ee5f8a484a 152
djmeyers 0:06ee5f8a484a 153 const M2MObjectInstanceList& M2MObject::instances() const
djmeyers 0:06ee5f8a484a 154 {
djmeyers 0:06ee5f8a484a 155 return _instance_list;
djmeyers 0:06ee5f8a484a 156 }
djmeyers 0:06ee5f8a484a 157
djmeyers 0:06ee5f8a484a 158 uint16_t M2MObject::instance_count() const
djmeyers 0:06ee5f8a484a 159 {
djmeyers 0:06ee5f8a484a 160 return (uint16_t)_instance_list.size();
djmeyers 0:06ee5f8a484a 161 }
djmeyers 0:06ee5f8a484a 162
djmeyers 0:06ee5f8a484a 163 M2MBase::BaseType M2MObject::base_type() const
djmeyers 0:06ee5f8a484a 164 {
djmeyers 0:06ee5f8a484a 165 return M2MBase::base_type();
djmeyers 0:06ee5f8a484a 166 }
djmeyers 0:06ee5f8a484a 167
djmeyers 0:06ee5f8a484a 168 void M2MObject::add_observation_level(M2MBase::Observation observation_level)
djmeyers 0:06ee5f8a484a 169 {
djmeyers 0:06ee5f8a484a 170 M2MBase::add_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 171 if(!_instance_list.empty()) {
djmeyers 0:06ee5f8a484a 172 M2MObjectInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 173 it = _instance_list.begin();
djmeyers 0:06ee5f8a484a 174 for ( ; it != _instance_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 175 (*it)->add_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 176 }
djmeyers 0:06ee5f8a484a 177 }
djmeyers 0:06ee5f8a484a 178 }
djmeyers 0:06ee5f8a484a 179
djmeyers 0:06ee5f8a484a 180 void M2MObject::remove_observation_level(M2MBase::Observation observation_level)
djmeyers 0:06ee5f8a484a 181 {
djmeyers 0:06ee5f8a484a 182 M2MBase::remove_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 183 if(!_instance_list.empty()) {
djmeyers 0:06ee5f8a484a 184 M2MObjectInstanceList::const_iterator it;
djmeyers 0:06ee5f8a484a 185 it = _instance_list.begin();
djmeyers 0:06ee5f8a484a 186 for ( ; it != _instance_list.end(); it++ ) {
djmeyers 0:06ee5f8a484a 187 (*it)->remove_observation_level(observation_level);
djmeyers 0:06ee5f8a484a 188 }
djmeyers 0:06ee5f8a484a 189 }
djmeyers 0:06ee5f8a484a 190 }
djmeyers 0:06ee5f8a484a 191
djmeyers 0:06ee5f8a484a 192 sn_coap_hdr_s* M2MObject::handle_get_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 193 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 194 M2MObservationHandler *observation_handler)
djmeyers 0:06ee5f8a484a 195 {
djmeyers 0:06ee5f8a484a 196 tr_debug("M2MObject::handle_get_request()");
djmeyers 0:06ee5f8a484a 197 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
djmeyers 0:06ee5f8a484a 198 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 199 received_coap_header,
djmeyers 0:06ee5f8a484a 200 msg_code);
djmeyers 0:06ee5f8a484a 201 uint8_t * data = NULL;
djmeyers 0:06ee5f8a484a 202 uint32_t data_length = 0;
djmeyers 0:06ee5f8a484a 203 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 204 // process the GET if we have registered a callback for it
djmeyers 0:06ee5f8a484a 205 if ((operation() & SN_GRS_GET_ALLOWED) != 0) {
djmeyers 0:06ee5f8a484a 206 if(coap_response) {
djmeyers 0:06ee5f8a484a 207 uint16_t coap_content_type = 0;
djmeyers 0:06ee5f8a484a 208 bool content_type_present = false;
djmeyers 0:06ee5f8a484a 209 if(received_coap_header->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 210 content_type_present = true;
djmeyers 0:06ee5f8a484a 211 coap_content_type = received_coap_header->content_format;
djmeyers 0:06ee5f8a484a 212 }
djmeyers 0:06ee5f8a484a 213 if(!content_type_present &&
djmeyers 0:06ee5f8a484a 214 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
djmeyers 0:06ee5f8a484a 215 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
djmeyers 0:06ee5f8a484a 216 }
djmeyers 0:06ee5f8a484a 217
djmeyers 0:06ee5f8a484a 218 tr_debug("M2MObject::handle_get_request() - Request Content-Type %d", coap_content_type);
djmeyers 0:06ee5f8a484a 219 if (coap_response->content_format == COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 220 coap_response->content_format = sn_coap_content_format_e(coap_content_type);
djmeyers 0:06ee5f8a484a 221
djmeyers 0:06ee5f8a484a 222 if (coap_response->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 223 set_coap_content_type(coap_content_type);
djmeyers 0:06ee5f8a484a 224 }
djmeyers 0:06ee5f8a484a 225 }
djmeyers 0:06ee5f8a484a 226 // fill in the CoAP response payload
djmeyers 0:06ee5f8a484a 227 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
djmeyers 0:06ee5f8a484a 228 M2MTLVSerializer serializer;
djmeyers 0:06ee5f8a484a 229 data = serializer.serialize(_instance_list, data_length);
djmeyers 0:06ee5f8a484a 230
djmeyers 0:06ee5f8a484a 231 } else { // TOD0: Implement JSON Format.
djmeyers 0:06ee5f8a484a 232 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
djmeyers 0:06ee5f8a484a 233 }
djmeyers 0:06ee5f8a484a 234
djmeyers 0:06ee5f8a484a 235 coap_response->payload_len = data_length;
djmeyers 0:06ee5f8a484a 236 coap_response->payload_ptr = data;
djmeyers 0:06ee5f8a484a 237
djmeyers 0:06ee5f8a484a 238 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
djmeyers 0:06ee5f8a484a 239
djmeyers 0:06ee5f8a484a 240 coap_response->options_list_ptr->max_age = max_age();
djmeyers 0:06ee5f8a484a 241
djmeyers 0:06ee5f8a484a 242 if(data){
djmeyers 0:06ee5f8a484a 243 if(received_coap_header->options_list_ptr) {
djmeyers 0:06ee5f8a484a 244 if(received_coap_header->options_list_ptr->observe != -1) {
djmeyers 0:06ee5f8a484a 245 if (is_observable()) {
djmeyers 0:06ee5f8a484a 246 uint32_t number = 0;
djmeyers 0:06ee5f8a484a 247 uint8_t observe_option = 0;
djmeyers 0:06ee5f8a484a 248 observe_option = received_coap_header->options_list_ptr->observe;
djmeyers 0:06ee5f8a484a 249
djmeyers 0:06ee5f8a484a 250 if(START_OBSERVATION == observe_option) {
djmeyers 0:06ee5f8a484a 251 tr_debug("M2MObject::handle_get_request - Starts Observation");
djmeyers 0:06ee5f8a484a 252 // If the observe length is 0 means register for observation.
djmeyers 0:06ee5f8a484a 253 if(received_coap_header->options_list_ptr->observe != -1) {
djmeyers 0:06ee5f8a484a 254 number = received_coap_header->options_list_ptr->observe;
djmeyers 0:06ee5f8a484a 255 }
djmeyers 0:06ee5f8a484a 256 if(received_coap_header->token_ptr) {
djmeyers 0:06ee5f8a484a 257 tr_debug("M2MObject::handle_get_request - Sets Observation Token to resource");
djmeyers 0:06ee5f8a484a 258 set_observation_token(received_coap_header->token_ptr,
djmeyers 0:06ee5f8a484a 259 received_coap_header->token_len);
djmeyers 0:06ee5f8a484a 260 }
djmeyers 0:06ee5f8a484a 261
djmeyers 0:06ee5f8a484a 262 // If the observe value is 0 means register for observation.
djmeyers 0:06ee5f8a484a 263 if(number == 0) {
djmeyers 0:06ee5f8a484a 264 tr_debug("M2MObject::handle_get_request - Put Resource under Observation");
djmeyers 0:06ee5f8a484a 265 set_under_observation(true,observation_handler);
djmeyers 0:06ee5f8a484a 266 add_observation_level(M2MBase::O_Attribute);
djmeyers 0:06ee5f8a484a 267 tr_debug("M2MObject::handle_get_request - Observation Number %d", observation_number());
djmeyers 0:06ee5f8a484a 268 coap_response->options_list_ptr->observe = observation_number();
djmeyers 0:06ee5f8a484a 269 }
djmeyers 0:06ee5f8a484a 270 } else if (STOP_OBSERVATION == observe_option) {
djmeyers 0:06ee5f8a484a 271 tr_debug("M2MObject::handle_get_request - Stops Observation");
djmeyers 0:06ee5f8a484a 272 // If the observe options_list_ptr->observe value is 1 means de-register from observation.
djmeyers 0:06ee5f8a484a 273 set_under_observation(false,NULL);
djmeyers 0:06ee5f8a484a 274 remove_observation_level(M2MBase::O_Attribute);
djmeyers 0:06ee5f8a484a 275 }
djmeyers 0:06ee5f8a484a 276 msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
djmeyers 0:06ee5f8a484a 277 }
djmeyers 0:06ee5f8a484a 278 else {
djmeyers 0:06ee5f8a484a 279 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 280 }
djmeyers 0:06ee5f8a484a 281 }
djmeyers 0:06ee5f8a484a 282 }
djmeyers 0:06ee5f8a484a 283 } else {
djmeyers 0:06ee5f8a484a 284 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
djmeyers 0:06ee5f8a484a 285 }
djmeyers 0:06ee5f8a484a 286 }
djmeyers 0:06ee5f8a484a 287 }else {
djmeyers 0:06ee5f8a484a 288 tr_error("M2MResource::handle_get_request - Return COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 289 // Operation is not allowed.
djmeyers 0:06ee5f8a484a 290 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 291 }
djmeyers 0:06ee5f8a484a 292 } else {
djmeyers 0:06ee5f8a484a 293 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 294 }
djmeyers 0:06ee5f8a484a 295 if(coap_response) {
djmeyers 0:06ee5f8a484a 296 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 297 }
djmeyers 0:06ee5f8a484a 298 return coap_response;
djmeyers 0:06ee5f8a484a 299 }
djmeyers 0:06ee5f8a484a 300
djmeyers 0:06ee5f8a484a 301 sn_coap_hdr_s* M2MObject::handle_put_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 302 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 303 M2MObservationHandler */*observation_handler*/,
djmeyers 0:06ee5f8a484a 304 bool &/*execute_value_updated*/)
djmeyers 0:06ee5f8a484a 305 {
djmeyers 0:06ee5f8a484a 306 tr_debug("M2MObject::handle_put_request()");
djmeyers 0:06ee5f8a484a 307 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
djmeyers 0:06ee5f8a484a 308 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 309 received_coap_header,
djmeyers 0:06ee5f8a484a 310 msg_code);
djmeyers 0:06ee5f8a484a 311 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 312 if(received_coap_header->options_list_ptr &&
djmeyers 0:06ee5f8a484a 313 received_coap_header->options_list_ptr->uri_query_ptr) {
djmeyers 0:06ee5f8a484a 314 char *query = (char*)alloc_string_copy(received_coap_header->options_list_ptr->uri_query_ptr,
djmeyers 0:06ee5f8a484a 315 received_coap_header->options_list_ptr->uri_query_len);
djmeyers 0:06ee5f8a484a 316 if (query){
djmeyers 0:06ee5f8a484a 317 tr_debug("M2MObject::handle_put_request() - Query %s", query);
djmeyers 0:06ee5f8a484a 318 // if anything was updated, re-initialize the stored notification attributes
djmeyers 0:06ee5f8a484a 319 if (!handle_observation_attribute(query)){
djmeyers 0:06ee5f8a484a 320 tr_debug("M2MObject::handle_put_request() - Invalid query");
djmeyers 0:06ee5f8a484a 321 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
djmeyers 0:06ee5f8a484a 322 }
djmeyers 0:06ee5f8a484a 323 free(query);
djmeyers 0:06ee5f8a484a 324 }
djmeyers 0:06ee5f8a484a 325 } else {
djmeyers 0:06ee5f8a484a 326 tr_error("M2MObject::handle_put_request() - COAP_MSG_CODE_RESPONSE_BAD_REQUEST - Empty URI_QUERY");
djmeyers 0:06ee5f8a484a 327 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
djmeyers 0:06ee5f8a484a 328 }
djmeyers 0:06ee5f8a484a 329 } else {
djmeyers 0:06ee5f8a484a 330 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 331 }
djmeyers 0:06ee5f8a484a 332 if(coap_response) {
djmeyers 0:06ee5f8a484a 333 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 334 }
djmeyers 0:06ee5f8a484a 335 return coap_response;
djmeyers 0:06ee5f8a484a 336 }
djmeyers 0:06ee5f8a484a 337
djmeyers 0:06ee5f8a484a 338
djmeyers 0:06ee5f8a484a 339 sn_coap_hdr_s* M2MObject::handle_post_request(nsdl_s *nsdl,
djmeyers 0:06ee5f8a484a 340 sn_coap_hdr_s *received_coap_header,
djmeyers 0:06ee5f8a484a 341 M2MObservationHandler *observation_handler,
djmeyers 0:06ee5f8a484a 342 bool &execute_value_updated,
djmeyers 0:06ee5f8a484a 343 sn_nsdl_addr_s *)
djmeyers 0:06ee5f8a484a 344 {
djmeyers 0:06ee5f8a484a 345 tr_debug("M2MObject::handle_post_request()");
djmeyers 0:06ee5f8a484a 346 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
djmeyers 0:06ee5f8a484a 347 // process the POST if we have registered a callback for it
djmeyers 0:06ee5f8a484a 348 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
djmeyers 0:06ee5f8a484a 349 received_coap_header,
djmeyers 0:06ee5f8a484a 350 msg_code);
djmeyers 0:06ee5f8a484a 351
djmeyers 0:06ee5f8a484a 352 if(received_coap_header) {
djmeyers 0:06ee5f8a484a 353 if ((operation() & SN_GRS_POST_ALLOWED) != 0) {
djmeyers 0:06ee5f8a484a 354 if(received_coap_header->payload_ptr) {
djmeyers 0:06ee5f8a484a 355 tr_debug("M2MObject::handle_post_request() - Update Object with new values");
djmeyers 0:06ee5f8a484a 356 uint16_t coap_content_type = 0;
djmeyers 0:06ee5f8a484a 357 bool content_type_present = false;
djmeyers 0:06ee5f8a484a 358 if(received_coap_header->content_format != COAP_CT_NONE) {
djmeyers 0:06ee5f8a484a 359 content_type_present = true;
djmeyers 0:06ee5f8a484a 360 if(coap_response) {
djmeyers 0:06ee5f8a484a 361 coap_content_type = received_coap_header->content_format;
djmeyers 0:06ee5f8a484a 362 }
djmeyers 0:06ee5f8a484a 363 } // if(received_coap_header->content_format)
djmeyers 0:06ee5f8a484a 364 if(!content_type_present &&
djmeyers 0:06ee5f8a484a 365 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
djmeyers 0:06ee5f8a484a 366 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
djmeyers 0:06ee5f8a484a 367 }
djmeyers 0:06ee5f8a484a 368
djmeyers 0:06ee5f8a484a 369 tr_debug("M2MObject::handle_post_request() - Request Content-Type %d", coap_content_type);
djmeyers 0:06ee5f8a484a 370
djmeyers 0:06ee5f8a484a 371 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
djmeyers 0:06ee5f8a484a 372 uint16_t instance_id = 0;
djmeyers 0:06ee5f8a484a 373 // Check next free instance id
djmeyers 0:06ee5f8a484a 374 for(instance_id = 0; instance_id <= _max_instance_count; instance_id++) {
djmeyers 0:06ee5f8a484a 375 if(NULL == object_instance(instance_id)) {
djmeyers 0:06ee5f8a484a 376 break;
djmeyers 0:06ee5f8a484a 377 }
djmeyers 0:06ee5f8a484a 378 if(instance_id == _max_instance_count) {
djmeyers 0:06ee5f8a484a 379 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 380 break;
djmeyers 0:06ee5f8a484a 381 }
djmeyers 0:06ee5f8a484a 382 }
djmeyers 0:06ee5f8a484a 383 if(COAP_MSG_CODE_RESPONSE_CHANGED == msg_code) {
djmeyers 0:06ee5f8a484a 384 M2MTLVDeserializer deserializer;
djmeyers 0:06ee5f8a484a 385 bool is_obj_instance = false;
djmeyers 0:06ee5f8a484a 386 bool obj_instance_exists = false;
djmeyers 0:06ee5f8a484a 387 is_obj_instance = deserializer.is_object_instance(received_coap_header->payload_ptr);
djmeyers 0:06ee5f8a484a 388 if (is_obj_instance) {
djmeyers 0:06ee5f8a484a 389 instance_id = deserializer.instance_id(received_coap_header->payload_ptr);
djmeyers 0:06ee5f8a484a 390 tr_debug("M2MObject::handle_post_request() - instance id in TLV: %d", instance_id);
djmeyers 0:06ee5f8a484a 391 // Check if instance id already exists
djmeyers 0:06ee5f8a484a 392 if (object_instance(instance_id)){
djmeyers 0:06ee5f8a484a 393 obj_instance_exists = true;
djmeyers 0:06ee5f8a484a 394 }
djmeyers 0:06ee5f8a484a 395 }
djmeyers 0:06ee5f8a484a 396 if (!obj_instance_exists) {
djmeyers 0:06ee5f8a484a 397 M2MObjectInstance *obj_instance = create_object_instance(instance_id);
djmeyers 0:06ee5f8a484a 398 if(obj_instance) {
djmeyers 0:06ee5f8a484a 399 obj_instance->set_operation(M2MBase::GET_PUT_ALLOWED);
djmeyers 0:06ee5f8a484a 400 }
djmeyers 0:06ee5f8a484a 401
djmeyers 0:06ee5f8a484a 402 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
djmeyers 0:06ee5f8a484a 403 if(is_obj_instance) {
djmeyers 0:06ee5f8a484a 404 tr_debug("M2MObject::handle_post_request() - TLV data contains ObjectInstance");
djmeyers 0:06ee5f8a484a 405 error = deserializer.deserialise_object_instances(received_coap_header->payload_ptr,
djmeyers 0:06ee5f8a484a 406 received_coap_header->payload_len,
djmeyers 0:06ee5f8a484a 407 *this,
djmeyers 0:06ee5f8a484a 408 M2MTLVDeserializer::Post);
djmeyers 0:06ee5f8a484a 409 } else if(obj_instance &&
djmeyers 0:06ee5f8a484a 410 (deserializer.is_resource(received_coap_header->payload_ptr) ||
djmeyers 0:06ee5f8a484a 411 deserializer.is_multiple_resource(received_coap_header->payload_ptr))) {
djmeyers 0:06ee5f8a484a 412 tr_debug("M2MObject::handle_post_request() - TLV data contains Resources");
djmeyers 0:06ee5f8a484a 413 error = deserializer.deserialize_resources(received_coap_header->payload_ptr,
djmeyers 0:06ee5f8a484a 414 received_coap_header->payload_len,
djmeyers 0:06ee5f8a484a 415 *obj_instance,
djmeyers 0:06ee5f8a484a 416 M2MTLVDeserializer::Post);
djmeyers 0:06ee5f8a484a 417 } else {
djmeyers 0:06ee5f8a484a 418 error = M2MTLVDeserializer::NotValid;
djmeyers 0:06ee5f8a484a 419 }
djmeyers 0:06ee5f8a484a 420 switch(error) {
djmeyers 0:06ee5f8a484a 421 case M2MTLVDeserializer::None:
djmeyers 0:06ee5f8a484a 422 if(observation_handler) {
djmeyers 0:06ee5f8a484a 423 execute_value_updated = true;
djmeyers 0:06ee5f8a484a 424 }
djmeyers 0:06ee5f8a484a 425 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
djmeyers 0:06ee5f8a484a 426
djmeyers 0:06ee5f8a484a 427 if (coap_response->options_list_ptr) {
djmeyers 0:06ee5f8a484a 428
djmeyers 0:06ee5f8a484a 429 StringBuffer<MAX_OBJECT_PATH_NAME> obj_name;
djmeyers 0:06ee5f8a484a 430
djmeyers 0:06ee5f8a484a 431 if (obj_name.ensure_space(M2MBase::resource_name_length() + (1 + 5 + 1))) {
djmeyers 0:06ee5f8a484a 432 obj_name.append(M2MBase::name());
djmeyers 0:06ee5f8a484a 433 obj_name.append('/');
djmeyers 0:06ee5f8a484a 434 obj_name.append_int(instance_id);
djmeyers 0:06ee5f8a484a 435
djmeyers 0:06ee5f8a484a 436 coap_response->options_list_ptr->location_path_len = obj_name.get_size();
djmeyers 0:06ee5f8a484a 437 coap_response->options_list_ptr->location_path_ptr =
djmeyers 0:06ee5f8a484a 438 alloc_copy((uint8_t*)obj_name.c_str(), obj_name.get_size());
djmeyers 0:06ee5f8a484a 439 // todo: else return error
djmeyers 0:06ee5f8a484a 440 }
djmeyers 0:06ee5f8a484a 441 }
djmeyers 0:06ee5f8a484a 442 // todo: else return error
djmeyers 0:06ee5f8a484a 443 msg_code = COAP_MSG_CODE_RESPONSE_CREATED;
djmeyers 0:06ee5f8a484a 444 break;
djmeyers 0:06ee5f8a484a 445 case M2MTLVDeserializer::NotAllowed:
djmeyers 0:06ee5f8a484a 446 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
djmeyers 0:06ee5f8a484a 447 break;
djmeyers 0:06ee5f8a484a 448 case M2MTLVDeserializer::NotValid:
djmeyers 0:06ee5f8a484a 449 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
djmeyers 0:06ee5f8a484a 450 break;
djmeyers 0:06ee5f8a484a 451 case M2MTLVDeserializer::NotFound:
djmeyers 0:06ee5f8a484a 452 msg_code = COAP_MSG_CODE_RESPONSE_NOT_FOUND;
djmeyers 0:06ee5f8a484a 453 break;
djmeyers 0:06ee5f8a484a 454 }
djmeyers 0:06ee5f8a484a 455
djmeyers 0:06ee5f8a484a 456 } else {
djmeyers 0:06ee5f8a484a 457 tr_debug("M2MObject::handle_post_request() - COAP_MSG_CODE_RESPONSE_BAD_REQUEST");
djmeyers 0:06ee5f8a484a 458 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
djmeyers 0:06ee5f8a484a 459 }
djmeyers 0:06ee5f8a484a 460 }
djmeyers 0:06ee5f8a484a 461 } else {
djmeyers 0:06ee5f8a484a 462 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
djmeyers 0:06ee5f8a484a 463 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
djmeyers 0:06ee5f8a484a 464 } else {
djmeyers 0:06ee5f8a484a 465 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_BAD_REQUEST - Missing Payload");
djmeyers 0:06ee5f8a484a 466 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; //
djmeyers 0:06ee5f8a484a 467 }
djmeyers 0:06ee5f8a484a 468 } else { // if ((object->operation() & SN_GRS_POST_ALLOWED) != 0)
djmeyers 0:06ee5f8a484a 469 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 470 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; // 4.05
djmeyers 0:06ee5f8a484a 471 }
djmeyers 0:06ee5f8a484a 472 } else { //if(received_coap_header)
djmeyers 0:06ee5f8a484a 473 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
djmeyers 0:06ee5f8a484a 474 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; // 4.05
djmeyers 0:06ee5f8a484a 475 }
djmeyers 0:06ee5f8a484a 476
djmeyers 0:06ee5f8a484a 477 if(coap_response) {
djmeyers 0:06ee5f8a484a 478 coap_response->msg_code = msg_code;
djmeyers 0:06ee5f8a484a 479 }
djmeyers 0:06ee5f8a484a 480 return coap_response;
djmeyers 0:06ee5f8a484a 481 }
djmeyers 0:06ee5f8a484a 482
djmeyers 0:06ee5f8a484a 483 void M2MObject::notification_update(uint16_t obj_instance_id)
djmeyers 0:06ee5f8a484a 484 {
djmeyers 0:06ee5f8a484a 485 tr_debug("M2MObject::notification_update - id: %d", obj_instance_id);
djmeyers 0:06ee5f8a484a 486 M2MReportHandler *report_handler = M2MBase::report_handler();
djmeyers 0:06ee5f8a484a 487 if(report_handler && is_under_observation()) {
djmeyers 0:06ee5f8a484a 488 report_handler->set_notification_trigger(obj_instance_id);
djmeyers 0:06ee5f8a484a 489 }
djmeyers 0:06ee5f8a484a 490 }
djmeyers 0:06ee5f8a484a 491