Michael Koster / mbedConnectorInterface

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.

Fork of mbedConnectorInterface by Doug Anson

api/DynamicResource.cpp@27:eb6818ad257a, 2015-03-25 (annotated)

Committer:
ansond
Date:
Wed Mar 25 05:12:35 2015 +0000
Revision:
27:eb6818ad257a
Parent:
25:1fc958ac14d1
Child:
28:8fd9336edeb9
updates

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ansond 0:b438482ebbfc 1 /**
ansond 0:b438482ebbfc 2 * @file DynamicResource.cpp
ansond 0:b438482ebbfc 3 * @brief mbed CoAP Endpoint Dynamic Resource class
ansond 0:b438482ebbfc 4 * @author Doug Anson/Chris Paola
ansond 0:b438482ebbfc 5 * @version 1.0
sam_grove 2:853f9ecc12df 6 * @see
ansond 0:b438482ebbfc 7 *
ansond 0:b438482ebbfc 8 * Copyright (c) 2014
ansond 0:b438482ebbfc 9 *
ansond 0:b438482ebbfc 10 * Licensed under the Apache License, Version 2.0 (the "License");
ansond 0:b438482ebbfc 11 * you may not use this file except in compliance with the License.
ansond 0:b438482ebbfc 12 * You may obtain a copy of the License at
ansond 0:b438482ebbfc 13 *
ansond 0:b438482ebbfc 14 * http://www.apache.org/licenses/LICENSE-2.0
ansond 0:b438482ebbfc 15 *
ansond 0:b438482ebbfc 16 * Unless required by applicable law or agreed to in writing, software
ansond 0:b438482ebbfc 17 * distributed under the License is distributed on an "AS IS" BASIS,
ansond 0:b438482ebbfc 18 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
ansond 0:b438482ebbfc 19 * See the License for the specific language governing permissions and
ansond 0:b438482ebbfc 20 * limitations under the License.
ansond 0:b438482ebbfc 21 */
sam_grove 2:853f9ecc12df 22
sam_grove 2:853f9ecc12df 23 #include "DynamicResource.h"
sam_grove 2:853f9ecc12df 24
sam_grove 2:853f9ecc12df 25 // InstancePointerTable Helper
sam_grove 2:853f9ecc12df 26 #include "InstancePointerTableHelper.h"
sam_grove 2:853f9ecc12df 27
sam_grove 2:853f9ecc12df 28 // default constructor
sam_grove 2:853f9ecc12df 29 DynamicResource::DynamicResource(const Logger *logger,const char *name,const char *res_type,uint8_t res_mask,const bool observable) : Resource<string>(logger,string(name),string(""))
sam_grove 2:853f9ecc12df 30 {
ansond 0:b438482ebbfc 31 this->m_res_type = string(res_type);
ansond 0:b438482ebbfc 32 this->m_observable = observable;
sam_grove 2:853f9ecc12df 33 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 34 this->m_obs_number = 0;
ansond 21:8487990a3baa 35 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 36 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 37 this->m_data_wrapper = NULL;
sam_grove 2:853f9ecc12df 38 }
sam_grove 2:853f9ecc12df 39
sam_grove 2:853f9ecc12df 40 // constructor (input initial value)
sam_grove 2:853f9ecc12df 41 DynamicResource::DynamicResource(const Logger *logger,const char *name,const char *res_type,const string value,uint8_t res_mask,const bool observable) : Resource<string>(logger,string(name),value)
sam_grove 2:853f9ecc12df 42 {
ansond 0:b438482ebbfc 43 this->m_res_type = string(res_type);
ansond 0:b438482ebbfc 44 this->m_observable = observable;
sam_grove 2:853f9ecc12df 45 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 46 this->m_obs_number = 0;
ansond 21:8487990a3baa 47 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 48 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 49 this->m_data_wrapper = NULL;
sam_grove 2:853f9ecc12df 50 }
sam_grove 2:853f9ecc12df 51
sam_grove 2:853f9ecc12df 52 // constructor (strings)
sam_grove 2:853f9ecc12df 53 DynamicResource::DynamicResource(const Logger *logger,const string name,const string res_type,const string value,uint8_t res_mask,const bool observable) : Resource<string>(logger,name,value)
sam_grove 2:853f9ecc12df 54 {
ansond 0:b438482ebbfc 55 this->m_res_type = res_type;
ansond 0:b438482ebbfc 56 this->m_observable = observable;
sam_grove 2:853f9ecc12df 57 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 58 this->m_obs_number = 0;
ansond 21:8487990a3baa 59 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 60 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 61 this->m_data_wrapper = NULL;
sam_grove 2:853f9ecc12df 62 }
sam_grove 2:853f9ecc12df 63
sam_grove 2:853f9ecc12df 64 // copy constructor
sam_grove 2:853f9ecc12df 65 DynamicResource::DynamicResource(const DynamicResource &resource) : Resource<string>((const Resource<string> &)resource)
sam_grove 2:853f9ecc12df 66 {
ansond 0:b438482ebbfc 67 this->m_res_type = resource.m_res_type;
ansond 0:b438482ebbfc 68 this->m_observable = resource.m_observable;
ansond 0:b438482ebbfc 69 this->m_res_mask = resource.m_res_mask;
ansond 21:8487990a3baa 70 this->m_obs_number = resource.m_obs_number;
ansond 21:8487990a3baa 71 this->m_obs_token_ptr = resource.m_obs_token_ptr;
ansond 21:8487990a3baa 72 this->m_obs_token_len = resource.m_obs_token_len;
ansond 24:a6915e19814e 73 this->m_data_wrapper = resource.m_data_wrapper;
sam_grove 2:853f9ecc12df 74 }
sam_grove 2:853f9ecc12df 75
sam_grove 2:853f9ecc12df 76 // destructor
sam_grove 2:853f9ecc12df 77 DynamicResource::~DynamicResource()
sam_grove 2:853f9ecc12df 78 {
ansond 21:8487990a3baa 79 if(this->m_obs_token_ptr) free(this->m_obs_token_ptr);
sam_grove 2:853f9ecc12df 80 }
sam_grove 2:853f9ecc12df 81
sam_grove 2:853f9ecc12df 82 // bind resource to NSDL
sam_grove 2:853f9ecc12df 83 void DynamicResource::bind(void *p)
sam_grove 2:853f9ecc12df 84 {
ansond 0:b438482ebbfc 85 if (p != NULL) {
ansond 0:b438482ebbfc 86 sn_nsdl_resource_info_s *resource_ptr = (sn_nsdl_resource_info_s *)p;
ansond 0:b438482ebbfc 87 const uint8_t *name = (const uint8_t *)(this->getName().c_str());
ansond 0:b438482ebbfc 88 const uint8_t *res_type = (const uint8_t *)this->m_res_type.c_str();
ansond 0:b438482ebbfc 89 int name_length = this->getName().size();
ansond 0:b438482ebbfc 90 int res_type_length = this->m_res_type.size();
sam_grove 2:853f9ecc12df 91 int is_observable = 0;
sam_grove 2:853f9ecc12df 92 if (this->m_observable == true) is_observable = 1;
ansond 0:b438482ebbfc 93 const string *key = new string(this->getName());
ansond 0:b438482ebbfc 94 ipt_helper_add_instance_pointer(key,this);
ansond 0:b438482ebbfc 95 nsdl_create_dynamic_resource(resource_ptr,name_length,(uint8_t *)name,res_type_length,(uint8_t *)res_type,is_observable,&ipt_helper_nsdl_callback_stub,this->m_res_mask);
ansond 20:abfbaf524192 96 this->logger()->log("DynamicResource: [%s] type: [%s] bound (observable: %d)",name,res_type,is_observable);
sam_grove 2:853f9ecc12df 97 } else {
ansond 5:a929d65eb385 98 this->logger()->log("DynamicResource: NULL parameter in bind()");
ansond 0:b438482ebbfc 99 }
sam_grove 2:853f9ecc12df 100 }
ansond 0:b438482ebbfc 101
sam_grove 2:853f9ecc12df 102 // process NSDL message
sam_grove 2:853f9ecc12df 103 uint8_t DynamicResource::process(sn_coap_hdr_s *received_coap_ptr, sn_nsdl_addr_s *address, sn_proto_info_s *proto)
sam_grove 2:853f9ecc12df 104 {
ansond 0:b438482ebbfc 105 sn_coap_hdr_s *coap_res_ptr = 0;
sam_grove 2:853f9ecc12df 106
ansond 0:b438482ebbfc 107 // create our key for debugging output...
ansond 25:1fc958ac14d1 108 DataWrapper *hold = this->getDataWrapper();
ansond 25:1fc958ac14d1 109 this->setDataWrapper(NULL);
ansond 0:b438482ebbfc 110 string key = this->coapDataToString(received_coap_ptr->uri_path_ptr,received_coap_ptr->uri_path_len);
ansond 25:1fc958ac14d1 111 this->setDataWrapper(hold);
sam_grove 2:853f9ecc12df 112
sam_grove 2:853f9ecc12df 113 if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_GET) {
ansond 0:b438482ebbfc 114 coap_res_ptr = sn_coap_build_response(received_coap_ptr, COAP_MSG_CODE_RESPONSE_CONTENT);
sam_grove 2:853f9ecc12df 115
sam_grove 2:853f9ecc12df 116 // process the GET if we have registered a callback for it...
ansond 0:b438482ebbfc 117 if ((this->m_res_mask&SN_GRS_GET_ALLOWED) != 0) {
ansond 0:b438482ebbfc 118 // call the resource get() to get the resource value
ansond 5:a929d65eb385 119 this->logger()->log("Calling resource(GET) for [%s]...",key.c_str());
ansond 0:b438482ebbfc 120 string value = this->get();
sam_grove 2:853f9ecc12df 121
ansond 24:a6915e19814e 122 // convert the string from the GET to something suitable for CoAP payloads
ansond 24:a6915e19814e 123 if (this->getDataWrapper() != NULL) {
ansond 24:a6915e19814e 124 // wrap the data...
ansond 24:a6915e19814e 125 this->getDataWrapper()->wrap((uint8_t *)value.c_str(),(int)value.size());
ansond 24:a6915e19814e 126
ansond 24:a6915e19814e 127 // announce (after wrap)
ansond 24:a6915e19814e 128 this->logger()->log("Building payload for [%s]=[%s]...",key.c_str(),this->getDataWrapper()->get());
ansond 24:a6915e19814e 129
ansond 24:a6915e19814e 130 // fill in the CoAP response payload
ansond 24:a6915e19814e 131 coap_res_ptr->payload_len = this->getDataWrapper()->length();
ansond 24:a6915e19814e 132 coap_res_ptr->payload_ptr = this->getDataWrapper()->get();
ansond 24:a6915e19814e 133 }
ansond 24:a6915e19814e 134 else {
ansond 24:a6915e19814e 135 // announce (no wrap)
ansond 24:a6915e19814e 136 this->logger()->log("Building payload for [%s]=[%s]...",key.c_str(),value.c_str());
ansond 24:a6915e19814e 137
ansond 24:a6915e19814e 138 // do not wrap the data...
ansond 24:a6915e19814e 139 coap_res_ptr->payload_len = value.size();
ansond 24:a6915e19814e 140 coap_res_ptr->payload_ptr = (uint8_t *)value.c_str();
ansond 24:a6915e19814e 141 }
ansond 21:8487990a3baa 142
ansond 21:8487990a3baa 143 // Observation handling...
ansond 21:8487990a3baa 144 if(received_coap_ptr->token_ptr) {
ansond 21:8487990a3baa 145 if(this->m_obs_token_ptr) {
ansond 21:8487990a3baa 146 free(this->m_obs_token_ptr);
ansond 21:8487990a3baa 147 this->m_obs_token_ptr = NULL;
ansond 23:caa0260acc21 148 this->m_obs_token_len = 0;
ansond 21:8487990a3baa 149 }
ansond 22:192b598ba389 150
ansond 21:8487990a3baa 151 this->m_obs_token_ptr = (uint8_t*)malloc(received_coap_ptr->token_len);
ansond 21:8487990a3baa 152 if(this->m_obs_token_ptr) {
ansond 21:8487990a3baa 153 memcpy(this->m_obs_token_ptr, received_coap_ptr->token_ptr,received_coap_ptr->token_len);
ansond 21:8487990a3baa 154 this->m_obs_token_len = received_coap_ptr->token_len;
ansond 21:8487990a3baa 155 }
ansond 21:8487990a3baa 156 }
ansond 21:8487990a3baa 157
ansond 22:192b598ba389 158 // Observation handling...
ansond 22:192b598ba389 159 if(received_coap_ptr->options_list_ptr && received_coap_ptr->options_list_ptr->observe) {
ansond 21:8487990a3baa 160 coap_res_ptr->options_list_ptr = (sn_coap_options_list_s*)malloc(sizeof(sn_coap_options_list_s));
ansond 21:8487990a3baa 161 memset(coap_res_ptr->options_list_ptr, 0, sizeof(sn_coap_options_list_s));
ansond 22:192b598ba389 162 coap_res_ptr->options_list_ptr->observe_ptr = &this->m_obs_number; // see nullify note below...
ansond 21:8487990a3baa 163 coap_res_ptr->options_list_ptr->observe_len = 1;
ansond 21:8487990a3baa 164 this->m_obs_number++;
ansond 21:8487990a3baa 165 }
sam_grove 2:853f9ecc12df 166
sam_grove 2:853f9ecc12df 167 // build out the response and send...
ansond 21:8487990a3baa 168 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 22:192b598ba389 169
ansond 22:192b598ba389 170 //
ansond 22:192b598ba389 171 // nullify note:
ansond 22:192b598ba389 172 //
ansond 22:192b598ba389 173 // because our obs_number (assigned to observe_ptr) is part of this object instance, we dont
ansond 22:192b598ba389 174 // want to have the underlying free() try to free it... to just nullify here
ansond 22:192b598ba389 175 //
ansond 22:192b598ba389 176 if (coap_res_ptr->options_list_ptr) coap_res_ptr->options_list_ptr->observe_ptr = 0;
ansond 21:8487990a3baa 177 }
ansond 21:8487990a3baa 178 else {
ansond 5:a929d65eb385 179 this->logger()->log("ERROR: resource(GET) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 0:b438482ebbfc 180 }
sam_grove 2:853f9ecc12df 181 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_PUT) {
sam_grove 2:853f9ecc12df 182 if(received_coap_ptr->payload_len > 0) {
ansond 0:b438482ebbfc 183 // process the PUT if we have registered a callback for it...
ansond 0:b438482ebbfc 184 if ((this->m_res_mask&SN_GRS_PUT_ALLOWED) != 0) {
ansond 0:b438482ebbfc 185 // binder interacts only with strings
ansond 0:b438482ebbfc 186 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
sam_grove 2:853f9ecc12df 187
ansond 0:b438482ebbfc 188 // call the resource put() to set the resource value
ansond 5:a929d65eb385 189 this->logger()->log("Calling resource(PUT) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 0:b438482ebbfc 190 this->put(value);
sam_grove 2:853f9ecc12df 191
ansond 0:b438482ebbfc 192 // build out the response and send...
ansond 5:a929d65eb385 193 this->logger()->log("resource(PUT) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 194 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 195 sn_nsdl_send_coap_message(address,coap_res_ptr);
sam_grove 2:853f9ecc12df 196 } else {
ansond 5:a929d65eb385 197 this->logger()->log("ERROR: resource(PUT) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 0:b438482ebbfc 198 }
sam_grove 2:853f9ecc12df 199 } else {
ansond 5:a929d65eb385 200 this->logger()->log("ERROR: Binder(PUT) payload is NULL...");
ansond 0:b438482ebbfc 201 }
ansond 21:8487990a3baa 202 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) {
ansond 21:8487990a3baa 203 if(received_coap_ptr->payload_len > 0) {
ansond 21:8487990a3baa 204 // process the POST if we have registered a callback for it...
ansond 21:8487990a3baa 205 if ((this->m_res_mask&SN_GRS_POST_ALLOWED) != 0) {
ansond 21:8487990a3baa 206 // binder interacts only with strings
ansond 21:8487990a3baa 207 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
ansond 21:8487990a3baa 208
ansond 21:8487990a3baa 209 // call the resource post() to set the resource value
ansond 21:8487990a3baa 210 this->logger()->log("Calling resource(POST) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 21:8487990a3baa 211 this->post(value);
ansond 21:8487990a3baa 212
ansond 21:8487990a3baa 213 // build out the response and send...
ansond 21:8487990a3baa 214 this->logger()->log("resource(POST) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 215 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 216 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 21:8487990a3baa 217 } else {
ansond 21:8487990a3baa 218 this->logger()->log("ERROR: resource(POST) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 21:8487990a3baa 219 }
ansond 21:8487990a3baa 220 } else {
ansond 21:8487990a3baa 221 this->logger()->log("ERROR: Binder(POST) payload is NULL...");
ansond 21:8487990a3baa 222 }
ansond 21:8487990a3baa 223 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_DELETE) {
ansond 21:8487990a3baa 224 if(received_coap_ptr->payload_len > 0) {
ansond 21:8487990a3baa 225 // process the DELETE if we have registered a callback for it...
ansond 21:8487990a3baa 226 if ((this->m_res_mask&SN_GRS_DELETE_ALLOWED) != 0) {
ansond 21:8487990a3baa 227 // binder interacts only with strings
ansond 21:8487990a3baa 228 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
ansond 21:8487990a3baa 229
ansond 21:8487990a3baa 230 // call the resource del() to set the resource value
ansond 21:8487990a3baa 231 this->logger()->log("Calling resource(DELETE) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 21:8487990a3baa 232 this->del(value);
ansond 21:8487990a3baa 233
ansond 21:8487990a3baa 234 // build out the response and send...
ansond 21:8487990a3baa 235 this->logger()->log("resource(DELETE) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 236 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 237 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 21:8487990a3baa 238 } else {
ansond 21:8487990a3baa 239 this->logger()->log("ERROR: resource(DELETE) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 21:8487990a3baa 240 }
ansond 21:8487990a3baa 241 } else {
ansond 21:8487990a3baa 242 this->logger()->log("ERROR: Binder(DELETE) payload is NULL...");
ansond 21:8487990a3baa 243 }
ansond 0:b438482ebbfc 244 }
ansond 0:b438482ebbfc 245
ansond 0:b438482ebbfc 246 sn_coap_parser_release_allocated_coap_msg_mem(coap_res_ptr);
ansond 22:192b598ba389 247
ansond 0:b438482ebbfc 248 return 0;
sam_grove 2:853f9ecc12df 249 }
sam_grove 2:853f9ecc12df 250
ansond 21:8487990a3baa 251 // send the notification
ansond 21:8487990a3baa 252 int DynamicResource::notify(const string data) {
ansond 21:8487990a3baa 253 return this->notify((uint8_t *)data.c_str(),(int)data.length());
ansond 21:8487990a3baa 254 }
ansond 21:8487990a3baa 255
ansond 21:8487990a3baa 256 // send the notification
ansond 21:8487990a3baa 257 int DynamicResource::notify(uint8_t *data,int data_length) {
ansond 27:eb6818ad257a 258 uint8_t *notify_data = NULL;
ansond 27:eb6818ad257a 259 int notify_data_length = 0;
ansond 27:eb6818ad257a 260
ansond 27:eb6818ad257a 261 // convert the string from the GET to something suitable for CoAP payloads
ansond 27:eb6818ad257a 262 if (this->getDataWrapper() != NULL) {
ansond 27:eb6818ad257a 263 // wrap the data...
ansond 27:eb6818ad257a 264 this->getDataWrapper()->wrap((uint8_t *)data,data_length);
ansond 27:eb6818ad257a 265
ansond 27:eb6818ad257a 266 // announce (after wrap)
ansond 27:eb6818ad257a 267 this->logger()->log("Notify payload [%s]...",this->getDataWrapper()->get());
ansond 27:eb6818ad257a 268
ansond 27:eb6818ad257a 269 // fill notify
ansond 27:eb6818ad257a 270 notify_data_length = this->getDataWrapper()->length();
ansond 27:eb6818ad257a 271 notify_data = this->getDataWrapper()->get();
ansond 27:eb6818ad257a 272 }
ansond 27:eb6818ad257a 273 else {
ansond 27:eb6818ad257a 274 // announce (no wrap)
ansond 27:eb6818ad257a 275 this->logger()->log("Notify payload [%s]...",data);
ansond 27:eb6818ad257a 276
ansond 27:eb6818ad257a 277 // do not wrap the data...
ansond 27:eb6818ad257a 278 notify_data_length = data_length;
ansond 27:eb6818ad257a 279 notify_data = data;
ansond 27:eb6818ad257a 280 }
ansond 27:eb6818ad257a 281
ansond 27:eb6818ad257a 282 // send the observation...
ansond 27:eb6818ad257a 283 int status = sn_nsdl_send_observation_notification(this->m_obs_token_ptr,this->m_obs_token_len,notify_data,notify_data_length,&this->m_obs_number,1,COAP_MSG_TYPE_NON_CONFIRMABLE,0);
ansond 21:8487990a3baa 284 if (status == 0) {
ansond 21:8487990a3baa 285 this->logger()->log("ERROR: resource(NOTIFY) send failed...");
ansond 21:8487990a3baa 286 }
ansond 27:eb6818ad257a 287
ansond 27:eb6818ad257a 288 // return our status
ansond 21:8487990a3baa 289 return status;
ansond 21:8487990a3baa 290 }
ansond 21:8487990a3baa 291
sam_grove 2:853f9ecc12df 292 // default PUT (does nothing)
sam_grove 2:853f9ecc12df 293 void DynamicResource::put(const string value)
sam_grove 2:853f9ecc12df 294 {
sam_grove 2:853f9ecc12df 295 // not used by default
sam_grove 2:853f9ecc12df 296 ;
sam_grove 2:853f9ecc12df 297 }
sam_grove 2:853f9ecc12df 298
ansond 21:8487990a3baa 299 // default POST (does nothing)
ansond 21:8487990a3baa 300 void DynamicResource::post(const string value)
ansond 21:8487990a3baa 301 {
ansond 21:8487990a3baa 302 // not used by default
ansond 21:8487990a3baa 303 ;
ansond 21:8487990a3baa 304 }
ansond 21:8487990a3baa 305
ansond 21:8487990a3baa 306 // default DELETE (does nothing)
ansond 21:8487990a3baa 307 void DynamicResource::del(const string value)
ansond 21:8487990a3baa 308 {
ansond 21:8487990a3baa 309 // not used by default
ansond 21:8487990a3baa 310 ;
ansond 21:8487990a3baa 311 }
ansond 21:8487990a3baa 312
sam_grove 2:853f9ecc12df 313 // convenience method to get the URI from its buffer field...
sam_grove 2:853f9ecc12df 314 string DynamicResource::coapDataToString(uint8_t *coap_data_ptr,int coap_data_ptr_length)
sam_grove 2:853f9ecc12df 315 {
ansond 0:b438482ebbfc 316 if (coap_data_ptr != NULL && coap_data_ptr_length > 0) {
ansond 24:a6915e19814e 317 if (this->getDataWrapper() != NULL) {
ansond 24:a6915e19814e 318 // unwrap the data...
ansond 24:a6915e19814e 319 this->getDataWrapper()->unwrap(coap_data_ptr,coap_data_ptr_length);
ansond 24:a6915e19814e 320 char *buf = (char *)this->getDataWrapper()->get(); // assumes data is null terminated in DataWrapper...
ansond 24:a6915e19814e 321 return string(buf);
ansond 24:a6915e19814e 322 }
ansond 24:a6915e19814e 323 else {
ansond 24:a6915e19814e 324 // no unwrap of the data...
ansond 24:a6915e19814e 325 char buf[MAX_VALUE_BUFFER_LENGTH+1];
ansond 24:a6915e19814e 326 memset(buf,0,MAX_VALUE_BUFFER_LENGTH+1);
ansond 24:a6915e19814e 327 memcpy(buf,(char *)coap_data_ptr,coap_data_ptr_length);
ansond 24:a6915e19814e 328 return string(buf);
ansond 24:a6915e19814e 329 }
ansond 0:b438482ebbfc 330 }
ansond 0:b438482ebbfc 331 return string("");
sam_grove 2:853f9ecc12df 332 }