Jim Carver / Mbed OS mbed-cloud-workshop-connect-PIR

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.

Dependencies:   HTS221

Fork of mbed-cloud-workshop-connect-HTS221 by Jim Carver

simple-mbed-cloud-client/mbed-cloud-client/mbed-client/source/m2mobject.cpp@0:6b753f761943, 2018-10-12 (annotated)

Committer:
JimCarver
Date:
Fri Oct 12 21:22:49 2018 +0000
Revision:
0:6b753f761943
Initial commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
JimCarver 0:6b753f761943 1 /*
JimCarver 0:6b753f761943 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
JimCarver 0:6b753f761943 3 * SPDX-License-Identifier: Apache-2.0
JimCarver 0:6b753f761943 4 * Licensed under the Apache License, Version 2.0 (the License); you may
JimCarver 0:6b753f761943 5 * not use this file except in compliance with the License.
JimCarver 0:6b753f761943 6 * You may obtain a copy of the License at
JimCarver 0:6b753f761943 7 *
JimCarver 0:6b753f761943 8 * http://www.apache.org/licenses/LICENSE-2.0
JimCarver 0:6b753f761943 9 *
JimCarver 0:6b753f761943 10 * Unless required by applicable law or agreed to in writing, software
JimCarver 0:6b753f761943 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
JimCarver 0:6b753f761943 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
JimCarver 0:6b753f761943 13 * See the License for the specific language governing permissions and
JimCarver 0:6b753f761943 14 * limitations under the License.
JimCarver 0:6b753f761943 15 */
JimCarver 0:6b753f761943 16
JimCarver 0:6b753f761943 17 // Note: this macro is needed on armcc to get the the PRI*32 macros
JimCarver 0:6b753f761943 18 // from inttypes.h in a C++ code.
JimCarver 0:6b753f761943 19 #ifndef __STDC_FORMAT_MACROS
JimCarver 0:6b753f761943 20 #define __STDC_FORMAT_MACROS
JimCarver 0:6b753f761943 21 #endif
JimCarver 0:6b753f761943 22 #include <inttypes.h>
JimCarver 0:6b753f761943 23
JimCarver 0:6b753f761943 24 #include "mbed-client/m2mobject.h"
JimCarver 0:6b753f761943 25 #include "mbed-client/m2mendpoint.h"
JimCarver 0:6b753f761943 26 #include "mbed-client/m2mconstants.h"
JimCarver 0:6b753f761943 27 #include "include/m2mtlvserializer.h"
JimCarver 0:6b753f761943 28 #include "include/m2mtlvdeserializer.h"
JimCarver 0:6b753f761943 29 #include "include/m2mreporthandler.h"
JimCarver 0:6b753f761943 30 #include "mbed-trace/mbed_trace.h"
JimCarver 0:6b753f761943 31 #include "mbed-client/m2mstringbuffer.h"
JimCarver 0:6b753f761943 32 #include "include/m2mcallbackstorage.h"
JimCarver 0:6b753f761943 33
JimCarver 0:6b753f761943 34 #include <stdlib.h>
JimCarver 0:6b753f761943 35
JimCarver 0:6b753f761943 36 #define BUFFER_SIZE 10
JimCarver 0:6b753f761943 37 #define TRACE_GROUP "mClt"
JimCarver 0:6b753f761943 38
JimCarver 0:6b753f761943 39 M2MObject::M2MObject(const String &object_name, char *path, bool external_blockwise_store)
JimCarver 0:6b753f761943 40 : M2MBase(object_name,
JimCarver 0:6b753f761943 41 M2MBase::Dynamic,
JimCarver 0:6b753f761943 42 #ifndef DISABLE_RESOURCE_TYPE
JimCarver 0:6b753f761943 43 "",
JimCarver 0:6b753f761943 44 #endif
JimCarver 0:6b753f761943 45 path,
JimCarver 0:6b753f761943 46 external_blockwise_store,
JimCarver 0:6b753f761943 47 false),
JimCarver 0:6b753f761943 48 _observation_handler(NULL)
JimCarver 0:6b753f761943 49 #ifdef MBED_CLOUD_CLIENT_EDGE_EXTENSION
JimCarver 0:6b753f761943 50 ,_endpoint(NULL)
JimCarver 0:6b753f761943 51 #endif
JimCarver 0:6b753f761943 52 {
JimCarver 0:6b753f761943 53 M2MBase::set_base_type(M2MBase::Object);
JimCarver 0:6b753f761943 54 M2MBase::set_operation(M2MBase::GET_ALLOWED);
JimCarver 0:6b753f761943 55 if(M2MBase::name_id() != -1) {
JimCarver 0:6b753f761943 56 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE_OLD);
JimCarver 0:6b753f761943 57 }
JimCarver 0:6b753f761943 58 }
JimCarver 0:6b753f761943 59
JimCarver 0:6b753f761943 60 M2MObject::M2MObject(const M2MBase::lwm2m_parameters_s* static_res)
JimCarver 0:6b753f761943 61 : M2MBase(static_res),
JimCarver 0:6b753f761943 62 _observation_handler(NULL)
JimCarver 0:6b753f761943 63 #ifdef MBED_CLOUD_CLIENT_EDGE_EXTENSION
JimCarver 0:6b753f761943 64 ,_endpoint(NULL)
JimCarver 0:6b753f761943 65 #endif
JimCarver 0:6b753f761943 66 {
JimCarver 0:6b753f761943 67 M2MBase::set_operation(M2MBase::GET_ALLOWED);
JimCarver 0:6b753f761943 68 if(M2MBase::name_id() != -1) {
JimCarver 0:6b753f761943 69 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE_OLD);
JimCarver 0:6b753f761943 70 }
JimCarver 0:6b753f761943 71 }
JimCarver 0:6b753f761943 72
JimCarver 0:6b753f761943 73 M2MObject::~M2MObject()
JimCarver 0:6b753f761943 74 {
JimCarver 0:6b753f761943 75 if(!_instance_list.empty()) {
JimCarver 0:6b753f761943 76
JimCarver 0:6b753f761943 77 M2MObjectInstanceList::const_iterator it;
JimCarver 0:6b753f761943 78 it = _instance_list.begin();
JimCarver 0:6b753f761943 79 M2MObjectInstance* obj = NULL;
JimCarver 0:6b753f761943 80 uint16_t index = 0;
JimCarver 0:6b753f761943 81 for (; it!=_instance_list.end(); it++, index++ ) {
JimCarver 0:6b753f761943 82 //Free allocated memory for object instances.
JimCarver 0:6b753f761943 83 obj = *it;
JimCarver 0:6b753f761943 84 delete obj;
JimCarver 0:6b753f761943 85 }
JimCarver 0:6b753f761943 86
JimCarver 0:6b753f761943 87 _instance_list.clear();
JimCarver 0:6b753f761943 88 }
JimCarver 0:6b753f761943 89
JimCarver 0:6b753f761943 90 free_resources();
JimCarver 0:6b753f761943 91 }
JimCarver 0:6b753f761943 92
JimCarver 0:6b753f761943 93 M2MObjectInstance* M2MObject::create_object_instance(uint16_t instance_id)
JimCarver 0:6b753f761943 94 {
JimCarver 0:6b753f761943 95 tr_debug("M2MObject::create_object_instance - id: %d", instance_id);
JimCarver 0:6b753f761943 96 M2MObjectInstance *instance = NULL;
JimCarver 0:6b753f761943 97 if(!object_instance(instance_id)) {
JimCarver 0:6b753f761943 98 char* path = create_path(*this, instance_id);
JimCarver 0:6b753f761943 99 if (path) {
JimCarver 0:6b753f761943 100 // Note: the object instance's name contains actually object's name.
JimCarver 0:6b753f761943 101 instance = new M2MObjectInstance(*this, "", path);
JimCarver 0:6b753f761943 102 if(instance) {
JimCarver 0:6b753f761943 103 instance->add_observation_level(observation_level());
JimCarver 0:6b753f761943 104 instance->set_instance_id(instance_id);
JimCarver 0:6b753f761943 105 if(M2MBase::name_id() != -1) {
JimCarver 0:6b753f761943 106 instance->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE_OLD);
JimCarver 0:6b753f761943 107 }
JimCarver 0:6b753f761943 108 _instance_list.push_back(instance);
JimCarver 0:6b753f761943 109 set_changed();
JimCarver 0:6b753f761943 110 }
JimCarver 0:6b753f761943 111 }
JimCarver 0:6b753f761943 112 }
JimCarver 0:6b753f761943 113 return instance;
JimCarver 0:6b753f761943 114 }
JimCarver 0:6b753f761943 115
JimCarver 0:6b753f761943 116
JimCarver 0:6b753f761943 117 M2MObjectInstance* M2MObject::create_object_instance(const lwm2m_parameters_s* s)
JimCarver 0:6b753f761943 118 {
JimCarver 0:6b753f761943 119 tr_debug("M2MObject::create_object_instance - id: %d", s->identifier.instance_id);
JimCarver 0:6b753f761943 120 M2MObjectInstance *instance = NULL;
JimCarver 0:6b753f761943 121 if(!object_instance(s->identifier.instance_id)) {
JimCarver 0:6b753f761943 122
JimCarver 0:6b753f761943 123 instance = new M2MObjectInstance(*this, s);
JimCarver 0:6b753f761943 124 if(instance) {
JimCarver 0:6b753f761943 125 instance->add_observation_level(observation_level());
JimCarver 0:6b753f761943 126 //instance->set_instance_id(instance_id);
JimCarver 0:6b753f761943 127 //if(M2MBase::name_id() != -1) {
JimCarver 0:6b753f761943 128 // instance->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE_OLD);
JimCarver 0:6b753f761943 129 //}
JimCarver 0:6b753f761943 130 _instance_list.push_back(instance);
JimCarver 0:6b753f761943 131 set_changed();
JimCarver 0:6b753f761943 132 }
JimCarver 0:6b753f761943 133 }
JimCarver 0:6b753f761943 134 return instance;
JimCarver 0:6b753f761943 135 }
JimCarver 0:6b753f761943 136
JimCarver 0:6b753f761943 137 bool M2MObject::remove_object_instance(uint16_t inst_id)
JimCarver 0:6b753f761943 138 {
JimCarver 0:6b753f761943 139 tr_debug("M2MObject::remove_object_instance(inst_id %d)", inst_id);
JimCarver 0:6b753f761943 140 bool success = false;
JimCarver 0:6b753f761943 141 if(!_instance_list.empty()) {
JimCarver 0:6b753f761943 142 M2MObjectInstance* obj = NULL;
JimCarver 0:6b753f761943 143 M2MObjectInstanceList::const_iterator it;
JimCarver 0:6b753f761943 144 it = _instance_list.begin();
JimCarver 0:6b753f761943 145 int pos = 0;
JimCarver 0:6b753f761943 146 for ( ; it != _instance_list.end(); it++, pos++ ) {
JimCarver 0:6b753f761943 147 if((*it)->instance_id() == inst_id) {
JimCarver 0:6b753f761943 148 // Instance found and deleted.
JimCarver 0:6b753f761943 149 obj = *it;
JimCarver 0:6b753f761943 150
JimCarver 0:6b753f761943 151 _instance_list.erase(pos);
JimCarver 0:6b753f761943 152 delete obj;
JimCarver 0:6b753f761943 153 success = true;
JimCarver 0:6b753f761943 154 set_changed();
JimCarver 0:6b753f761943 155 break;
JimCarver 0:6b753f761943 156 }
JimCarver 0:6b753f761943 157 }
JimCarver 0:6b753f761943 158 }
JimCarver 0:6b753f761943 159 return success;
JimCarver 0:6b753f761943 160 }
JimCarver 0:6b753f761943 161
JimCarver 0:6b753f761943 162 M2MObjectInstance* M2MObject::object_instance(uint16_t inst_id) const
JimCarver 0:6b753f761943 163 {
JimCarver 0:6b753f761943 164 tr_debug("M2MObject::object_instance(inst_id %d)", inst_id);
JimCarver 0:6b753f761943 165 M2MObjectInstance *obj = NULL;
JimCarver 0:6b753f761943 166 if(!_instance_list.empty()) {
JimCarver 0:6b753f761943 167 M2MObjectInstanceList::const_iterator it;
JimCarver 0:6b753f761943 168 it = _instance_list.begin();
JimCarver 0:6b753f761943 169 for ( ; it != _instance_list.end(); it++ ) {
JimCarver 0:6b753f761943 170 if((*it)->instance_id() == inst_id) {
JimCarver 0:6b753f761943 171 // Instance found.
JimCarver 0:6b753f761943 172 obj = *it;
JimCarver 0:6b753f761943 173 break;
JimCarver 0:6b753f761943 174 }
JimCarver 0:6b753f761943 175 }
JimCarver 0:6b753f761943 176 }
JimCarver 0:6b753f761943 177 return obj;
JimCarver 0:6b753f761943 178 }
JimCarver 0:6b753f761943 179
JimCarver 0:6b753f761943 180 const M2MObjectInstanceList& M2MObject::instances() const
JimCarver 0:6b753f761943 181 {
JimCarver 0:6b753f761943 182 return _instance_list;
JimCarver 0:6b753f761943 183 }
JimCarver 0:6b753f761943 184
JimCarver 0:6b753f761943 185 uint16_t M2MObject::instance_count() const
JimCarver 0:6b753f761943 186 {
JimCarver 0:6b753f761943 187 return (uint16_t)_instance_list.size();
JimCarver 0:6b753f761943 188 }
JimCarver 0:6b753f761943 189
JimCarver 0:6b753f761943 190 M2MObservationHandler* M2MObject::observation_handler() const
JimCarver 0:6b753f761943 191 {
JimCarver 0:6b753f761943 192 // XXX: need to check the flag too
JimCarver 0:6b753f761943 193 return _observation_handler;
JimCarver 0:6b753f761943 194 }
JimCarver 0:6b753f761943 195
JimCarver 0:6b753f761943 196 void M2MObject::set_observation_handler(M2MObservationHandler *handler)
JimCarver 0:6b753f761943 197 {
JimCarver 0:6b753f761943 198 tr_debug("M2MObject::set_observation_handler - handler: 0x%p", (void*)handler);
JimCarver 0:6b753f761943 199 _observation_handler = handler;
JimCarver 0:6b753f761943 200 }
JimCarver 0:6b753f761943 201
JimCarver 0:6b753f761943 202 void M2MObject::add_observation_level(M2MBase::Observation observation_level)
JimCarver 0:6b753f761943 203 {
JimCarver 0:6b753f761943 204 M2MBase::add_observation_level(observation_level);
JimCarver 0:6b753f761943 205 if(!_instance_list.empty()) {
JimCarver 0:6b753f761943 206 M2MObjectInstanceList::const_iterator it;
JimCarver 0:6b753f761943 207 it = _instance_list.begin();
JimCarver 0:6b753f761943 208 for ( ; it != _instance_list.end(); it++ ) {
JimCarver 0:6b753f761943 209 (*it)->add_observation_level(observation_level);
JimCarver 0:6b753f761943 210 }
JimCarver 0:6b753f761943 211 }
JimCarver 0:6b753f761943 212 }
JimCarver 0:6b753f761943 213
JimCarver 0:6b753f761943 214 void M2MObject::remove_observation_level(M2MBase::Observation observation_level)
JimCarver 0:6b753f761943 215 {
JimCarver 0:6b753f761943 216 M2MBase::remove_observation_level(observation_level);
JimCarver 0:6b753f761943 217 if(!_instance_list.empty()) {
JimCarver 0:6b753f761943 218 M2MObjectInstanceList::const_iterator it;
JimCarver 0:6b753f761943 219 it = _instance_list.begin();
JimCarver 0:6b753f761943 220 for ( ; it != _instance_list.end(); it++ ) {
JimCarver 0:6b753f761943 221 (*it)->remove_observation_level(observation_level);
JimCarver 0:6b753f761943 222 }
JimCarver 0:6b753f761943 223 }
JimCarver 0:6b753f761943 224 }
JimCarver 0:6b753f761943 225
JimCarver 0:6b753f761943 226 sn_coap_hdr_s* M2MObject::handle_get_request(nsdl_s *nsdl,
JimCarver 0:6b753f761943 227 sn_coap_hdr_s *received_coap_header,
JimCarver 0:6b753f761943 228 M2MObservationHandler *observation_handler)
JimCarver 0:6b753f761943 229 {
JimCarver 0:6b753f761943 230 tr_info("M2MObject::handle_get_request()");
JimCarver 0:6b753f761943 231 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
JimCarver 0:6b753f761943 232 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
JimCarver 0:6b753f761943 233 received_coap_header,
JimCarver 0:6b753f761943 234 msg_code);
JimCarver 0:6b753f761943 235 uint8_t *data = NULL;
JimCarver 0:6b753f761943 236 uint32_t data_length = 0;
JimCarver 0:6b753f761943 237 if(received_coap_header) {
JimCarver 0:6b753f761943 238 // process the GET if we have registered a callback for it
JimCarver 0:6b753f761943 239 if ((operation() & SN_GRS_GET_ALLOWED) != 0) {
JimCarver 0:6b753f761943 240 if(coap_response) {
JimCarver 0:6b753f761943 241 bool content_type_present = false;
JimCarver 0:6b753f761943 242 bool is_content_type_supported = true;
JimCarver 0:6b753f761943 243
JimCarver 0:6b753f761943 244 if (received_coap_header->options_list_ptr &&
JimCarver 0:6b753f761943 245 received_coap_header->options_list_ptr->accept != COAP_CT_NONE) {
JimCarver 0:6b753f761943 246 content_type_present = true;
JimCarver 0:6b753f761943 247 coap_response->content_format = received_coap_header->options_list_ptr->accept;
JimCarver 0:6b753f761943 248
JimCarver 0:6b753f761943 249 }
JimCarver 0:6b753f761943 250
JimCarver 0:6b753f761943 251 // Check if preferred content type is supported
JimCarver 0:6b753f761943 252 if (content_type_present) {
JimCarver 0:6b753f761943 253 if (coap_response->content_format != COAP_CONTENT_OMA_TLV_TYPE_OLD &&
JimCarver 0:6b753f761943 254 coap_response->content_format != COAP_CONTENT_OMA_TLV_TYPE) {
JimCarver 0:6b753f761943 255 is_content_type_supported = false;
JimCarver 0:6b753f761943 256 }
JimCarver 0:6b753f761943 257 }
JimCarver 0:6b753f761943 258
JimCarver 0:6b753f761943 259 if (is_content_type_supported) {
JimCarver 0:6b753f761943 260 if(!content_type_present &&
JimCarver 0:6b753f761943 261 (M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE ||
JimCarver 0:6b753f761943 262 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE_OLD)) {
JimCarver 0:6b753f761943 263 coap_response->content_format = sn_coap_content_format_e(M2MBase::coap_content_type());
JimCarver 0:6b753f761943 264 }
JimCarver 0:6b753f761943 265
JimCarver 0:6b753f761943 266 // fill in the CoAP response payload
JimCarver 0:6b753f761943 267 if(COAP_CONTENT_OMA_TLV_TYPE == coap_response->content_format ||
JimCarver 0:6b753f761943 268 COAP_CONTENT_OMA_TLV_TYPE_OLD == coap_response->content_format) {
JimCarver 0:6b753f761943 269 set_coap_content_type(coap_response->content_format);
JimCarver 0:6b753f761943 270 data = M2MTLVSerializer::serialize(_instance_list, data_length);
JimCarver 0:6b753f761943 271 }
JimCarver 0:6b753f761943 272
JimCarver 0:6b753f761943 273 coap_response->payload_len = data_length;
JimCarver 0:6b753f761943 274 coap_response->payload_ptr = data;
JimCarver 0:6b753f761943 275 if(data){
JimCarver 0:6b753f761943 276 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
JimCarver 0:6b753f761943 277 if(coap_response->options_list_ptr){
JimCarver 0:6b753f761943 278 coap_response->options_list_ptr->max_age = max_age();
JimCarver 0:6b753f761943 279 }
JimCarver 0:6b753f761943 280 if(received_coap_header->options_list_ptr) {
JimCarver 0:6b753f761943 281 if(received_coap_header->options_list_ptr->observe != -1) {
JimCarver 0:6b753f761943 282 if (is_observable()) {
JimCarver 0:6b753f761943 283 uint32_t number = 0;
JimCarver 0:6b753f761943 284 uint8_t observe_option = 0;
JimCarver 0:6b753f761943 285 observe_option = received_coap_header->options_list_ptr->observe;
JimCarver 0:6b753f761943 286
JimCarver 0:6b753f761943 287 if(START_OBSERVATION == observe_option) {
JimCarver 0:6b753f761943 288 // If the observe length is 0 means register for observation.
JimCarver 0:6b753f761943 289 if(received_coap_header->options_list_ptr->observe != -1) {
JimCarver 0:6b753f761943 290 number = received_coap_header->options_list_ptr->observe;
JimCarver 0:6b753f761943 291 }
JimCarver 0:6b753f761943 292
JimCarver 0:6b753f761943 293 // If the observe value is 0 means register for observation.
JimCarver 0:6b753f761943 294 if(number == 0) {
JimCarver 0:6b753f761943 295 tr_info("M2MObject::handle_get_request - put resource under observation");
JimCarver 0:6b753f761943 296 set_under_observation(true,observation_handler);
JimCarver 0:6b753f761943 297 add_observation_level(M2MBase::O_Attribute);
JimCarver 0:6b753f761943 298 send_notification_delivery_status(*this, NOTIFICATION_STATUS_SUBSCRIBED);
JimCarver 0:6b753f761943 299 if(coap_response->options_list_ptr){
JimCarver 0:6b753f761943 300 coap_response->options_list_ptr->observe = observation_number();
JimCarver 0:6b753f761943 301 }
JimCarver 0:6b753f761943 302 }
JimCarver 0:6b753f761943 303
JimCarver 0:6b753f761943 304 if(received_coap_header->token_ptr) {
JimCarver 0:6b753f761943 305 set_observation_token(received_coap_header->token_ptr,
JimCarver 0:6b753f761943 306 received_coap_header->token_len);
JimCarver 0:6b753f761943 307 }
JimCarver 0:6b753f761943 308 } else if (STOP_OBSERVATION == observe_option) {
JimCarver 0:6b753f761943 309 tr_info("M2MObject::handle_get_request - stops observation");
JimCarver 0:6b753f761943 310 // If the observe options_list_ptr->observe value is 1 means de-register from observation.
JimCarver 0:6b753f761943 311 set_under_observation(false, NULL);
JimCarver 0:6b753f761943 312 remove_observation_level(M2MBase::O_Attribute);
JimCarver 0:6b753f761943 313 send_notification_delivery_status(*this, NOTIFICATION_STATUS_UNSUBSCRIBED);
JimCarver 0:6b753f761943 314 }
JimCarver 0:6b753f761943 315 msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
JimCarver 0:6b753f761943 316 }
JimCarver 0:6b753f761943 317 else {
JimCarver 0:6b753f761943 318 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 319 }
JimCarver 0:6b753f761943 320 }
JimCarver 0:6b753f761943 321 }
JimCarver 0:6b753f761943 322 } else {
JimCarver 0:6b753f761943 323 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
JimCarver 0:6b753f761943 324 }
JimCarver 0:6b753f761943 325 } else {
JimCarver 0:6b753f761943 326 tr_error("M2MObject::handle_get_request() - Content-Type %d not supported", coap_response->content_format);
JimCarver 0:6b753f761943 327 msg_code = COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE;
JimCarver 0:6b753f761943 328 }
JimCarver 0:6b753f761943 329 }
JimCarver 0:6b753f761943 330 }else {
JimCarver 0:6b753f761943 331 tr_error("M2MResource::handle_get_request - Return COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
JimCarver 0:6b753f761943 332 // Operation is not allowed.
JimCarver 0:6b753f761943 333 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 334 }
JimCarver 0:6b753f761943 335 } else {
JimCarver 0:6b753f761943 336 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 337 }
JimCarver 0:6b753f761943 338 if(coap_response) {
JimCarver 0:6b753f761943 339 coap_response->msg_code = msg_code;
JimCarver 0:6b753f761943 340 }
JimCarver 0:6b753f761943 341 return coap_response;
JimCarver 0:6b753f761943 342 }
JimCarver 0:6b753f761943 343
JimCarver 0:6b753f761943 344 sn_coap_hdr_s* M2MObject::handle_put_request(nsdl_s *nsdl,
JimCarver 0:6b753f761943 345 sn_coap_hdr_s *received_coap_header,
JimCarver 0:6b753f761943 346 M2MObservationHandler */*observation_handler*/,
JimCarver 0:6b753f761943 347 bool &/*execute_value_updated*/)
JimCarver 0:6b753f761943 348 {
JimCarver 0:6b753f761943 349 tr_info("M2MObject::handle_put_request()");
JimCarver 0:6b753f761943 350 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
JimCarver 0:6b753f761943 351 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
JimCarver 0:6b753f761943 352 received_coap_header,
JimCarver 0:6b753f761943 353 msg_code);
JimCarver 0:6b753f761943 354 if(received_coap_header) {
JimCarver 0:6b753f761943 355 if(received_coap_header->content_format != COAP_CT_NONE) {
JimCarver 0:6b753f761943 356 set_coap_content_type(received_coap_header->content_format);
JimCarver 0:6b753f761943 357 }
JimCarver 0:6b753f761943 358 if(received_coap_header->options_list_ptr &&
JimCarver 0:6b753f761943 359 received_coap_header->options_list_ptr->uri_query_ptr) {
JimCarver 0:6b753f761943 360 char *query = (char*)alloc_string_copy(received_coap_header->options_list_ptr->uri_query_ptr,
JimCarver 0:6b753f761943 361 received_coap_header->options_list_ptr->uri_query_len);
JimCarver 0:6b753f761943 362
JimCarver 0:6b753f761943 363 if (query){
JimCarver 0:6b753f761943 364 tr_info("M2MObject::handle_put_request() - query %s", query);
JimCarver 0:6b753f761943 365 // if anything was updated, re-initialize the stored notification attributes
JimCarver 0:6b753f761943 366 if (!handle_observation_attribute(query)){
JimCarver 0:6b753f761943 367 tr_debug("M2MObject::handle_put_request() - Invalid query");
JimCarver 0:6b753f761943 368 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
JimCarver 0:6b753f761943 369 }
JimCarver 0:6b753f761943 370 free(query);
JimCarver 0:6b753f761943 371 }
JimCarver 0:6b753f761943 372 } else {
JimCarver 0:6b753f761943 373 tr_error("M2MObject::handle_put_request() - COAP_MSG_CODE_RESPONSE_BAD_REQUEST - Empty URI_QUERY");
JimCarver 0:6b753f761943 374 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
JimCarver 0:6b753f761943 375 }
JimCarver 0:6b753f761943 376 } else {
JimCarver 0:6b753f761943 377 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 378 }
JimCarver 0:6b753f761943 379 if(coap_response) {
JimCarver 0:6b753f761943 380 coap_response->msg_code = msg_code;
JimCarver 0:6b753f761943 381 }
JimCarver 0:6b753f761943 382 return coap_response;
JimCarver 0:6b753f761943 383 }
JimCarver 0:6b753f761943 384
JimCarver 0:6b753f761943 385
JimCarver 0:6b753f761943 386 sn_coap_hdr_s* M2MObject::handle_post_request(nsdl_s *nsdl,
JimCarver 0:6b753f761943 387 sn_coap_hdr_s *received_coap_header,
JimCarver 0:6b753f761943 388 M2MObservationHandler *observation_handler,
JimCarver 0:6b753f761943 389 bool &execute_value_updated,
JimCarver 0:6b753f761943 390 sn_nsdl_addr_s *)
JimCarver 0:6b753f761943 391 {
JimCarver 0:6b753f761943 392 tr_info("M2MObject::handle_post_request()");
JimCarver 0:6b753f761943 393 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
JimCarver 0:6b753f761943 394 // process the POST if we have registered a callback for it
JimCarver 0:6b753f761943 395 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
JimCarver 0:6b753f761943 396 received_coap_header,
JimCarver 0:6b753f761943 397 msg_code);
JimCarver 0:6b753f761943 398
JimCarver 0:6b753f761943 399 if (received_coap_header) {
JimCarver 0:6b753f761943 400 if ((operation() & SN_GRS_POST_ALLOWED) != 0) {
JimCarver 0:6b753f761943 401 if (received_coap_header->content_format != COAP_CT_NONE) {
JimCarver 0:6b753f761943 402 set_coap_content_type(received_coap_header->content_format);
JimCarver 0:6b753f761943 403 }
JimCarver 0:6b753f761943 404 if(received_coap_header->payload_ptr) {
JimCarver 0:6b753f761943 405 tr_debug("M2MObject::handle_post_request() - Update Object with new values");
JimCarver 0:6b753f761943 406 uint16_t coap_content_type = 0;
JimCarver 0:6b753f761943 407 bool content_type_present = false;
JimCarver 0:6b753f761943 408 if(received_coap_header->content_format != COAP_CT_NONE) {
JimCarver 0:6b753f761943 409 content_type_present = true;
JimCarver 0:6b753f761943 410 if(coap_response) {
JimCarver 0:6b753f761943 411 coap_content_type = received_coap_header->content_format;
JimCarver 0:6b753f761943 412 }
JimCarver 0:6b753f761943 413 } // if(received_coap_header->content_format)
JimCarver 0:6b753f761943 414 if(!content_type_present &&
JimCarver 0:6b753f761943 415 (M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE ||
JimCarver 0:6b753f761943 416 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE_OLD)) {
JimCarver 0:6b753f761943 417 coap_content_type = M2MBase::coap_content_type();
JimCarver 0:6b753f761943 418 }
JimCarver 0:6b753f761943 419
JimCarver 0:6b753f761943 420 tr_debug("M2MObject::handle_post_request() - Request Content-type: %d", coap_content_type);
JimCarver 0:6b753f761943 421
JimCarver 0:6b753f761943 422 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type ||
JimCarver 0:6b753f761943 423 COAP_CONTENT_OMA_TLV_TYPE_OLD == coap_content_type) {
JimCarver 0:6b753f761943 424 set_coap_content_type(coap_content_type);
JimCarver 0:6b753f761943 425 uint32_t instance_id = 0;
JimCarver 0:6b753f761943 426 // Check next free instance id
JimCarver 0:6b753f761943 427 for(instance_id = 0; instance_id <= MAX_UNINT_16_COUNT; instance_id++) {
JimCarver 0:6b753f761943 428 if(NULL == object_instance(instance_id)) {
JimCarver 0:6b753f761943 429 break;
JimCarver 0:6b753f761943 430 }
JimCarver 0:6b753f761943 431 if(instance_id == MAX_UNINT_16_COUNT) {
JimCarver 0:6b753f761943 432 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 433 break;
JimCarver 0:6b753f761943 434 }
JimCarver 0:6b753f761943 435 }
JimCarver 0:6b753f761943 436 if(COAP_MSG_CODE_RESPONSE_CHANGED == msg_code) {
JimCarver 0:6b753f761943 437 bool is_obj_instance = false;
JimCarver 0:6b753f761943 438 bool obj_instance_exists = false;
JimCarver 0:6b753f761943 439 is_obj_instance = M2MTLVDeserializer::is_object_instance(received_coap_header->payload_ptr);
JimCarver 0:6b753f761943 440 if (is_obj_instance) {
JimCarver 0:6b753f761943 441 instance_id = M2MTLVDeserializer::instance_id(received_coap_header->payload_ptr);
JimCarver 0:6b753f761943 442 tr_debug("M2MObject::handle_post_request() - instance id in TLV: %" PRIu32, instance_id);
JimCarver 0:6b753f761943 443 // Check if instance id already exists
JimCarver 0:6b753f761943 444 if (object_instance(instance_id)){
JimCarver 0:6b753f761943 445 obj_instance_exists = true;
JimCarver 0:6b753f761943 446 }
JimCarver 0:6b753f761943 447 }
JimCarver 0:6b753f761943 448 if (!obj_instance_exists && coap_response) {
JimCarver 0:6b753f761943 449 M2MObjectInstance *obj_instance = create_object_instance(instance_id);
JimCarver 0:6b753f761943 450 if (obj_instance) {
JimCarver 0:6b753f761943 451 obj_instance->set_operation(M2MBase::GET_PUT_ALLOWED);
JimCarver 0:6b753f761943 452 }
JimCarver 0:6b753f761943 453
JimCarver 0:6b753f761943 454 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
JimCarver 0:6b753f761943 455 if(is_obj_instance) {
JimCarver 0:6b753f761943 456 tr_debug("M2MObject::handle_post_request() - TLV data contains ObjectInstance");
JimCarver 0:6b753f761943 457 error = M2MTLVDeserializer::deserialise_object_instances(received_coap_header->payload_ptr,
JimCarver 0:6b753f761943 458 received_coap_header->payload_len,
JimCarver 0:6b753f761943 459 *this,
JimCarver 0:6b753f761943 460 M2MTLVDeserializer::Post);
JimCarver 0:6b753f761943 461 } else if(obj_instance &&
JimCarver 0:6b753f761943 462 (M2MTLVDeserializer::is_resource(received_coap_header->payload_ptr) ||
JimCarver 0:6b753f761943 463 M2MTLVDeserializer::is_multiple_resource(received_coap_header->payload_ptr))) {
JimCarver 0:6b753f761943 464 tr_debug("M2MObject::handle_post_request() - TLV data contains Resources");
JimCarver 0:6b753f761943 465 error = M2MTLVDeserializer::deserialize_resources(received_coap_header->payload_ptr,
JimCarver 0:6b753f761943 466 received_coap_header->payload_len,
JimCarver 0:6b753f761943 467 *obj_instance,
JimCarver 0:6b753f761943 468 M2MTLVDeserializer::Post);
JimCarver 0:6b753f761943 469 } else {
JimCarver 0:6b753f761943 470 error = M2MTLVDeserializer::NotValid;
JimCarver 0:6b753f761943 471 }
JimCarver 0:6b753f761943 472 switch(error) {
JimCarver 0:6b753f761943 473 case M2MTLVDeserializer::None:
JimCarver 0:6b753f761943 474 if(observation_handler) {
JimCarver 0:6b753f761943 475 execute_value_updated = true;
JimCarver 0:6b753f761943 476 }
JimCarver 0:6b753f761943 477 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
JimCarver 0:6b753f761943 478
JimCarver 0:6b753f761943 479 if (coap_response->options_list_ptr) {
JimCarver 0:6b753f761943 480
JimCarver 0:6b753f761943 481 StringBuffer<MAX_OBJECT_PATH_NAME> obj_name;
JimCarver 0:6b753f761943 482
JimCarver 0:6b753f761943 483 if (obj_name.ensure_space(M2MBase::resource_name_length() + (1 + 5 + 1))) {
JimCarver 0:6b753f761943 484 obj_name.append(M2MBase::name());
JimCarver 0:6b753f761943 485 obj_name.append('/');
JimCarver 0:6b753f761943 486 obj_name.append_int(instance_id);
JimCarver 0:6b753f761943 487
JimCarver 0:6b753f761943 488 coap_response->options_list_ptr->location_path_len = obj_name.get_size();
JimCarver 0:6b753f761943 489 coap_response->options_list_ptr->location_path_ptr =
JimCarver 0:6b753f761943 490 alloc_copy((uint8_t*)obj_name.c_str(), obj_name.get_size());
JimCarver 0:6b753f761943 491 // todo: else return error
JimCarver 0:6b753f761943 492 }
JimCarver 0:6b753f761943 493 }
JimCarver 0:6b753f761943 494 // todo: else return error
JimCarver 0:6b753f761943 495 msg_code = COAP_MSG_CODE_RESPONSE_CREATED;
JimCarver 0:6b753f761943 496 break;
JimCarver 0:6b753f761943 497 case M2MTLVDeserializer::NotAllowed:
JimCarver 0:6b753f761943 498 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
JimCarver 0:6b753f761943 499 break;
JimCarver 0:6b753f761943 500 case M2MTLVDeserializer::NotValid:
JimCarver 0:6b753f761943 501 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
JimCarver 0:6b753f761943 502 break;
JimCarver 0:6b753f761943 503 case M2MTLVDeserializer::NotFound:
JimCarver 0:6b753f761943 504 msg_code = COAP_MSG_CODE_RESPONSE_NOT_FOUND;
JimCarver 0:6b753f761943 505 break;
JimCarver 0:6b753f761943 506 case M2MTLVDeserializer::OutOfMemory:
JimCarver 0:6b753f761943 507 msg_code = COAP_MSG_CODE_RESPONSE_REQUEST_ENTITY_TOO_LARGE;
JimCarver 0:6b753f761943 508 break;
JimCarver 0:6b753f761943 509 }
JimCarver 0:6b753f761943 510
JimCarver 0:6b753f761943 511 } else {
JimCarver 0:6b753f761943 512 tr_error("M2MObject::handle_post_request() - COAP_MSG_CODE_RESPONSE_BAD_REQUEST");
JimCarver 0:6b753f761943 513 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
JimCarver 0:6b753f761943 514 }
JimCarver 0:6b753f761943 515 }
JimCarver 0:6b753f761943 516 } else {
JimCarver 0:6b753f761943 517 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
JimCarver 0:6b753f761943 518 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
JimCarver 0:6b753f761943 519 } else {
JimCarver 0:6b753f761943 520 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_BAD_REQUEST - Missing Payload");
JimCarver 0:6b753f761943 521 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; //
JimCarver 0:6b753f761943 522 }
JimCarver 0:6b753f761943 523 } else { // if ((object->operation() & SN_GRS_POST_ALLOWED) != 0)
JimCarver 0:6b753f761943 524 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
JimCarver 0:6b753f761943 525 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; // 4.05
JimCarver 0:6b753f761943 526 }
JimCarver 0:6b753f761943 527 } else { //if(received_coap_header)
JimCarver 0:6b753f761943 528 tr_error("M2MObject::handle_post_request - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
JimCarver 0:6b753f761943 529 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; // 4.05
JimCarver 0:6b753f761943 530 }
JimCarver 0:6b753f761943 531
JimCarver 0:6b753f761943 532 if(coap_response) {
JimCarver 0:6b753f761943 533 coap_response->msg_code = msg_code;
JimCarver 0:6b753f761943 534 }
JimCarver 0:6b753f761943 535 return coap_response;
JimCarver 0:6b753f761943 536 }
JimCarver 0:6b753f761943 537
JimCarver 0:6b753f761943 538 void M2MObject::notification_update(uint16_t obj_instance_id)
JimCarver 0:6b753f761943 539 {
JimCarver 0:6b753f761943 540 tr_debug("M2MObject::notification_update - id: %d", obj_instance_id);
JimCarver 0:6b753f761943 541 M2MReportHandler *report_handler = M2MBase::report_handler();
JimCarver 0:6b753f761943 542 if(report_handler && is_under_observation()) {
JimCarver 0:6b753f761943 543 report_handler->set_notification_trigger(obj_instance_id);
JimCarver 0:6b753f761943 544 }
JimCarver 0:6b753f761943 545 }
JimCarver 0:6b753f761943 546
JimCarver 0:6b753f761943 547 #ifdef MBED_CLOUD_CLIENT_EDGE_EXTENSION
JimCarver 0:6b753f761943 548 void M2MObject::set_endpoint(M2MEndpoint *endpoint)
JimCarver 0:6b753f761943 549 {
JimCarver 0:6b753f761943 550 _endpoint = endpoint;
JimCarver 0:6b753f761943 551 }
JimCarver 0:6b753f761943 552
JimCarver 0:6b753f761943 553 M2MEndpoint* M2MObject::get_endpoint() const
JimCarver 0:6b753f761943 554 {
JimCarver 0:6b753f761943 555 return _endpoint;
JimCarver 0:6b753f761943 556 }
JimCarver 0:6b753f761943 557 #endif
JimCarver 0:6b753f761943 558
JimCarver 0:6b753f761943 559 M2MBase *M2MObject::get_parent() const
JimCarver 0:6b753f761943 560 {
JimCarver 0:6b753f761943 561 #ifdef MBED_CLOUD_CLIENT_EDGE_EXTENSION
JimCarver 0:6b753f761943 562 return (M2MBase *) get_endpoint();
JimCarver 0:6b753f761943 563 #else
JimCarver 0:6b753f761943 564 return NULL;
JimCarver 0:6b753f761943 565 #endif
JimCarver 0:6b753f761943 566 }