Michael Koster / mbedConnectorInterface_custom

custom for >5 resources

Fork of mbedConnectorInterface by Doug Anson

api/DynamicResource.cpp@37:5de33aed0cac, 2015-04-10 (annotated)

Committer:
ansond
Date:
Fri Apr 10 06:09:34 2015 +0000
Revision:
37:5de33aed0cac
Parent:
36:1c6c45584c13
Child:
48:4b9ee3e32f93
removed logging in notify as it was messing up ISR based endpoints

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
ansond 31:bacc63106754 28 // ResourceObserver help
ansond 31:bacc63106754 29 #include "ResourceObserver.h"
ansond 31:bacc63106754 30
ansond 36:1c6c45584c13 31 // Leaving this disabled until the CoAP draft spec is further along...
ansond 36:1c6c45584c13 32 #ifdef GET_ENABLE_DISABLE_OBS
ansond 36:1c6c45584c13 33 // GET verb can Start/Stop Observations...
ansond 36:1c6c45584c13 34 #define START_OBS 0
ansond 36:1c6c45584c13 35 #define STOP_OBS 1
ansond 36:1c6c45584c13 36 #endif
ansond 31:bacc63106754 37
sam_grove 2:853f9ecc12df 38 // default constructor
sam_grove 2:853f9ecc12df 39 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 40 {
ansond 0:b438482ebbfc 41 this->m_res_type = string(res_type);
ansond 0:b438482ebbfc 42 this->m_observable = observable;
sam_grove 2:853f9ecc12df 43 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 44 this->m_obs_number = 0;
ansond 21:8487990a3baa 45 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 46 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 47 this->m_data_wrapper = NULL;
ansond 31:bacc63106754 48 this->m_observer = NULL;
sam_grove 2:853f9ecc12df 49 }
sam_grove 2:853f9ecc12df 50
sam_grove 2:853f9ecc12df 51 // constructor (input initial value)
sam_grove 2:853f9ecc12df 52 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 53 {
ansond 0:b438482ebbfc 54 this->m_res_type = string(res_type);
ansond 0:b438482ebbfc 55 this->m_observable = observable;
sam_grove 2:853f9ecc12df 56 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 57 this->m_obs_number = 0;
ansond 21:8487990a3baa 58 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 59 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 60 this->m_data_wrapper = NULL;
ansond 36:1c6c45584c13 61 this->m_observer = NULL;
sam_grove 2:853f9ecc12df 62 }
sam_grove 2:853f9ecc12df 63
sam_grove 2:853f9ecc12df 64 // constructor (strings)
sam_grove 2:853f9ecc12df 65 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 66 {
ansond 0:b438482ebbfc 67 this->m_res_type = res_type;
ansond 0:b438482ebbfc 68 this->m_observable = observable;
sam_grove 2:853f9ecc12df 69 this->m_res_mask = res_mask;
ansond 21:8487990a3baa 70 this->m_obs_number = 0;
ansond 21:8487990a3baa 71 this->m_obs_token_ptr = NULL;
ansond 21:8487990a3baa 72 this->m_obs_token_len = 0;
ansond 24:a6915e19814e 73 this->m_data_wrapper = NULL;
ansond 36:1c6c45584c13 74 this->m_observer = NULL;
sam_grove 2:853f9ecc12df 75 }
sam_grove 2:853f9ecc12df 76
sam_grove 2:853f9ecc12df 77 // copy constructor
sam_grove 2:853f9ecc12df 78 DynamicResource::DynamicResource(const DynamicResource &resource) : Resource<string>((const Resource<string> &)resource)
sam_grove 2:853f9ecc12df 79 {
ansond 0:b438482ebbfc 80 this->m_res_type = resource.m_res_type;
ansond 0:b438482ebbfc 81 this->m_observable = resource.m_observable;
ansond 0:b438482ebbfc 82 this->m_res_mask = resource.m_res_mask;
ansond 21:8487990a3baa 83 this->m_obs_number = resource.m_obs_number;
ansond 21:8487990a3baa 84 this->m_obs_token_ptr = resource.m_obs_token_ptr;
ansond 21:8487990a3baa 85 this->m_obs_token_len = resource.m_obs_token_len;
ansond 24:a6915e19814e 86 this->m_data_wrapper = resource.m_data_wrapper;
ansond 36:1c6c45584c13 87 this->m_observer = resource.m_observer;
sam_grove 2:853f9ecc12df 88 }
sam_grove 2:853f9ecc12df 89
sam_grove 2:853f9ecc12df 90 // destructor
sam_grove 2:853f9ecc12df 91 DynamicResource::~DynamicResource()
sam_grove 2:853f9ecc12df 92 {
ansond 21:8487990a3baa 93 if(this->m_obs_token_ptr) free(this->m_obs_token_ptr);
sam_grove 2:853f9ecc12df 94 }
sam_grove 2:853f9ecc12df 95
sam_grove 2:853f9ecc12df 96 // bind resource to NSDL
sam_grove 2:853f9ecc12df 97 void DynamicResource::bind(void *p)
sam_grove 2:853f9ecc12df 98 {
ansond 0:b438482ebbfc 99 if (p != NULL) {
ansond 0:b438482ebbfc 100 sn_nsdl_resource_info_s *resource_ptr = (sn_nsdl_resource_info_s *)p;
ansond 0:b438482ebbfc 101 const uint8_t *name = (const uint8_t *)(this->getName().c_str());
ansond 0:b438482ebbfc 102 const uint8_t *res_type = (const uint8_t *)this->m_res_type.c_str();
ansond 0:b438482ebbfc 103 int name_length = this->getName().size();
ansond 0:b438482ebbfc 104 int res_type_length = this->m_res_type.size();
sam_grove 2:853f9ecc12df 105 int is_observable = 0;
sam_grove 2:853f9ecc12df 106 if (this->m_observable == true) is_observable = 1;
ansond 0:b438482ebbfc 107 const string *key = new string(this->getName());
ansond 0:b438482ebbfc 108 ipt_helper_add_instance_pointer(key,this);
ansond 0:b438482ebbfc 109 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 110 this->logger()->log("DynamicResource: [%s] type: [%s] bound (observable: %d)",name,res_type,is_observable);
sam_grove 2:853f9ecc12df 111 } else {
ansond 5:a929d65eb385 112 this->logger()->log("DynamicResource: NULL parameter in bind()");
ansond 0:b438482ebbfc 113 }
sam_grove 2:853f9ecc12df 114 }
ansond 0:b438482ebbfc 115
sam_grove 2:853f9ecc12df 116 // process NSDL message
sam_grove 2:853f9ecc12df 117 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 118 {
ansond 0:b438482ebbfc 119 sn_coap_hdr_s *coap_res_ptr = 0;
ansond 31:bacc63106754 120
ansond 0:b438482ebbfc 121 // create our key for debugging output...
ansond 25:1fc958ac14d1 122 DataWrapper *hold = this->getDataWrapper();
ansond 25:1fc958ac14d1 123 this->setDataWrapper(NULL);
ansond 0:b438482ebbfc 124 string key = this->coapDataToString(received_coap_ptr->uri_path_ptr,received_coap_ptr->uri_path_len);
ansond 25:1fc958ac14d1 125 this->setDataWrapper(hold);
sam_grove 2:853f9ecc12df 126
sam_grove 2:853f9ecc12df 127 if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_GET) {
ansond 0:b438482ebbfc 128 coap_res_ptr = sn_coap_build_response(received_coap_ptr, COAP_MSG_CODE_RESPONSE_CONTENT);
sam_grove 2:853f9ecc12df 129
sam_grove 2:853f9ecc12df 130 // process the GET if we have registered a callback for it...
ansond 0:b438482ebbfc 131 if ((this->m_res_mask&SN_GRS_GET_ALLOWED) != 0) {
ansond 0:b438482ebbfc 132 // call the resource get() to get the resource value
ansond 5:a929d65eb385 133 this->logger()->log("Calling resource(GET) for [%s]...",key.c_str());
ansond 0:b438482ebbfc 134 string value = this->get();
sam_grove 2:853f9ecc12df 135
ansond 24:a6915e19814e 136 // convert the string from the GET to something suitable for CoAP payloads
ansond 24:a6915e19814e 137 if (this->getDataWrapper() != NULL) {
ansond 24:a6915e19814e 138 // wrap the data...
ansond 24:a6915e19814e 139 this->getDataWrapper()->wrap((uint8_t *)value.c_str(),(int)value.size());
ansond 24:a6915e19814e 140
ansond 24:a6915e19814e 141 // announce (after wrap)
ansond 24:a6915e19814e 142 this->logger()->log("Building payload for [%s]=[%s]...",key.c_str(),this->getDataWrapper()->get());
ansond 24:a6915e19814e 143
ansond 24:a6915e19814e 144 // fill in the CoAP response payload
ansond 24:a6915e19814e 145 coap_res_ptr->payload_len = this->getDataWrapper()->length();
ansond 24:a6915e19814e 146 coap_res_ptr->payload_ptr = this->getDataWrapper()->get();
ansond 24:a6915e19814e 147 }
ansond 24:a6915e19814e 148 else {
ansond 24:a6915e19814e 149 // announce (no wrap)
ansond 24:a6915e19814e 150 this->logger()->log("Building payload for [%s]=[%s]...",key.c_str(),value.c_str());
ansond 24:a6915e19814e 151
ansond 24:a6915e19814e 152 // do not wrap the data...
ansond 24:a6915e19814e 153 coap_res_ptr->payload_len = value.size();
ansond 24:a6915e19814e 154 coap_res_ptr->payload_ptr = (uint8_t *)value.c_str();
ansond 24:a6915e19814e 155 }
ansond 21:8487990a3baa 156
ansond 21:8487990a3baa 157 // Observation handling...
ansond 21:8487990a3baa 158 if(received_coap_ptr->token_ptr) {
ansond 21:8487990a3baa 159 if(this->m_obs_token_ptr) {
ansond 21:8487990a3baa 160 free(this->m_obs_token_ptr);
ansond 21:8487990a3baa 161 this->m_obs_token_ptr = NULL;
ansond 23:caa0260acc21 162 this->m_obs_token_len = 0;
ansond 21:8487990a3baa 163 }
ansond 22:192b598ba389 164
ansond 21:8487990a3baa 165 this->m_obs_token_ptr = (uint8_t*)malloc(received_coap_ptr->token_len);
ansond 21:8487990a3baa 166 if(this->m_obs_token_ptr) {
ansond 21:8487990a3baa 167 memcpy(this->m_obs_token_ptr, received_coap_ptr->token_ptr,received_coap_ptr->token_len);
ansond 21:8487990a3baa 168 this->m_obs_token_len = received_coap_ptr->token_len;
ansond 21:8487990a3baa 169 }
ansond 21:8487990a3baa 170 }
ansond 21:8487990a3baa 171
ansond 22:192b598ba389 172 // Observation handling...
ansond 36:1c6c45584c13 173 if(received_coap_ptr->options_list_ptr && received_coap_ptr->options_list_ptr->observe) {
ansond 31:bacc63106754 174 // create the options list pointer
ansond 21:8487990a3baa 175 coap_res_ptr->options_list_ptr = (sn_coap_options_list_s*)malloc(sizeof(sn_coap_options_list_s));
ansond 21:8487990a3baa 176 memset(coap_res_ptr->options_list_ptr, 0, sizeof(sn_coap_options_list_s));
ansond 36:1c6c45584c13 177
ansond 36:1c6c45584c13 178 // Leaving this disabled until the CoAP draft spec is further along...
ansond 36:1c6c45584c13 179 #ifdef GET_ENABLE_DISABLE_OBS
ansond 36:1c6c45584c13 180 // ResourceObserver
ansond 36:1c6c45584c13 181 ResourceObserver *observer = (ResourceObserver *)this->m_observer;
ansond 36:1c6c45584c13 182
ansond 31:bacc63106754 183 // get observe start/stop value from received options list pointer
ansond 31:bacc63106754 184 uint8_t OBS_command = *received_coap_ptr->options_list_ptr->observe_ptr;
ansond 31:bacc63106754 185 if (OBS_command == START_OBS) {
ansond 36:1c6c45584c13 186 coap_res_ptr->options_list_ptr->observe_ptr = &this->m_obs_number; // see nullify note below...
ansond 31:bacc63106754 187 coap_res_ptr->options_list_ptr->observe_len = 1;
ansond 31:bacc63106754 188 this->m_obs_number++;
ansond 31:bacc63106754 189 if (observer != NULL) observer->beginObservation();
ansond 31:bacc63106754 190 }
ansond 31:bacc63106754 191 if (OBS_command == STOP_OBS) {
ansond 31:bacc63106754 192 if (observer != NULL) observer->stopObservation();
ansond 31:bacc63106754 193 }
ansond 36:1c6c45584c13 194 #else
ansond 36:1c6c45584c13 195 // simply fill in the observation requirements...
ansond 36:1c6c45584c13 196 coap_res_ptr->options_list_ptr->observe_ptr = &this->m_obs_number; // see nullify note below...
ansond 36:1c6c45584c13 197 coap_res_ptr->options_list_ptr->observe_len = 1;
ansond 36:1c6c45584c13 198 this->m_obs_number++;
ansond 36:1c6c45584c13 199 #endif
ansond 21:8487990a3baa 200 }
sam_grove 2:853f9ecc12df 201
sam_grove 2:853f9ecc12df 202 // build out the response and send...
ansond 21:8487990a3baa 203 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 22:192b598ba389 204
ansond 22:192b598ba389 205 //
ansond 22:192b598ba389 206 // nullify note:
ansond 22:192b598ba389 207 //
ansond 22:192b598ba389 208 // because our obs_number (assigned to observe_ptr) is part of this object instance, we dont
ansond 22:192b598ba389 209 // want to have the underlying free() try to free it... to just nullify here
ansond 22:192b598ba389 210 //
ansond 22:192b598ba389 211 if (coap_res_ptr->options_list_ptr) coap_res_ptr->options_list_ptr->observe_ptr = 0;
ansond 21:8487990a3baa 212 }
ansond 21:8487990a3baa 213 else {
ansond 5:a929d65eb385 214 this->logger()->log("ERROR: resource(GET) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 0:b438482ebbfc 215 }
sam_grove 2:853f9ecc12df 216 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_PUT) {
sam_grove 2:853f9ecc12df 217 if(received_coap_ptr->payload_len > 0) {
ansond 0:b438482ebbfc 218 // process the PUT if we have registered a callback for it...
ansond 0:b438482ebbfc 219 if ((this->m_res_mask&SN_GRS_PUT_ALLOWED) != 0) {
ansond 28:8fd9336edeb9 220 // put() delivers values as std::string
ansond 0:b438482ebbfc 221 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
sam_grove 2:853f9ecc12df 222
ansond 0:b438482ebbfc 223 // call the resource put() to set the resource value
ansond 5:a929d65eb385 224 this->logger()->log("Calling resource(PUT) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 0:b438482ebbfc 225 this->put(value);
sam_grove 2:853f9ecc12df 226
ansond 0:b438482ebbfc 227 // build out the response and send...
ansond 5:a929d65eb385 228 this->logger()->log("resource(PUT) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 229 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 230 sn_nsdl_send_coap_message(address,coap_res_ptr);
sam_grove 2:853f9ecc12df 231 } else {
ansond 5:a929d65eb385 232 this->logger()->log("ERROR: resource(PUT) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 0:b438482ebbfc 233 }
sam_grove 2:853f9ecc12df 234 } else {
ansond 5:a929d65eb385 235 this->logger()->log("ERROR: Binder(PUT) payload is NULL...");
ansond 0:b438482ebbfc 236 }
ansond 21:8487990a3baa 237 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) {
ansond 21:8487990a3baa 238 if(received_coap_ptr->payload_len > 0) {
ansond 21:8487990a3baa 239 // process the POST if we have registered a callback for it...
ansond 21:8487990a3baa 240 if ((this->m_res_mask&SN_GRS_POST_ALLOWED) != 0) {
ansond 28:8fd9336edeb9 241 // post() delivers values as std::string
ansond 21:8487990a3baa 242 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
ansond 21:8487990a3baa 243
ansond 21:8487990a3baa 244 // call the resource post() to set the resource value
ansond 21:8487990a3baa 245 this->logger()->log("Calling resource(POST) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 21:8487990a3baa 246 this->post(value);
ansond 21:8487990a3baa 247
ansond 21:8487990a3baa 248 // build out the response and send...
ansond 21:8487990a3baa 249 this->logger()->log("resource(POST) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 250 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 251 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 21:8487990a3baa 252 } else {
ansond 21:8487990a3baa 253 this->logger()->log("ERROR: resource(POST) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 21:8487990a3baa 254 }
ansond 21:8487990a3baa 255 } else {
ansond 21:8487990a3baa 256 this->logger()->log("ERROR: Binder(POST) payload is NULL...");
ansond 21:8487990a3baa 257 }
ansond 21:8487990a3baa 258 } else if(received_coap_ptr->msg_code == COAP_MSG_CODE_REQUEST_DELETE) {
ansond 21:8487990a3baa 259 if(received_coap_ptr->payload_len > 0) {
ansond 21:8487990a3baa 260 // process the DELETE if we have registered a callback for it...
ansond 21:8487990a3baa 261 if ((this->m_res_mask&SN_GRS_DELETE_ALLOWED) != 0) {
ansond 28:8fd9336edeb9 262 // del() delivers values as std::string
ansond 21:8487990a3baa 263 string value = this->coapDataToString(received_coap_ptr->payload_ptr,received_coap_ptr->payload_len);
ansond 21:8487990a3baa 264
ansond 21:8487990a3baa 265 // call the resource del() to set the resource value
ansond 21:8487990a3baa 266 this->logger()->log("Calling resource(DELETE) with [%s]=[%s]...",key.c_str(),value.c_str());
ansond 21:8487990a3baa 267 this->del(value);
ansond 21:8487990a3baa 268
ansond 21:8487990a3baa 269 // build out the response and send...
ansond 21:8487990a3baa 270 this->logger()->log("resource(DELETE) completed for [%s]...",key.c_str());
ansond 21:8487990a3baa 271 coap_res_ptr = sn_coap_build_response(received_coap_ptr,COAP_MSG_CODE_RESPONSE_CHANGED);
ansond 21:8487990a3baa 272 sn_nsdl_send_coap_message(address,coap_res_ptr);
ansond 21:8487990a3baa 273 } else {
ansond 21:8487990a3baa 274 this->logger()->log("ERROR: resource(DELETE) mask is munged (mask: 0x%x)",this->m_res_mask);
ansond 21:8487990a3baa 275 }
ansond 21:8487990a3baa 276 } else {
ansond 21:8487990a3baa 277 this->logger()->log("ERROR: Binder(DELETE) payload is NULL...");
ansond 21:8487990a3baa 278 }
ansond 0:b438482ebbfc 279 }
ansond 0:b438482ebbfc 280
ansond 0:b438482ebbfc 281 sn_coap_parser_release_allocated_coap_msg_mem(coap_res_ptr);
ansond 22:192b598ba389 282
ansond 0:b438482ebbfc 283 return 0;
sam_grove 2:853f9ecc12df 284 }
sam_grove 2:853f9ecc12df 285
ansond 21:8487990a3baa 286 // send the notification
ansond 21:8487990a3baa 287 int DynamicResource::notify(const string data) {
ansond 21:8487990a3baa 288 return this->notify((uint8_t *)data.c_str(),(int)data.length());
ansond 21:8487990a3baa 289 }
ansond 21:8487990a3baa 290
ansond 21:8487990a3baa 291 // send the notification
ansond 21:8487990a3baa 292 int DynamicResource::notify(uint8_t *data,int data_length) {
ansond 27:eb6818ad257a 293 uint8_t *notify_data = NULL;
ansond 27:eb6818ad257a 294 int notify_data_length = 0;
ansond 27:eb6818ad257a 295
ansond 27:eb6818ad257a 296 // convert the string from the GET to something suitable for CoAP payloads
ansond 27:eb6818ad257a 297 if (this->getDataWrapper() != NULL) {
ansond 27:eb6818ad257a 298 // wrap the data...
ansond 27:eb6818ad257a 299 this->getDataWrapper()->wrap((uint8_t *)data,data_length);
ansond 27:eb6818ad257a 300
ansond 27:eb6818ad257a 301 // announce (after wrap)
ansond 37:5de33aed0cac 302 //this->logger()->log("Notify payload [%s]...",this->getDataWrapper()->get());
ansond 27:eb6818ad257a 303
ansond 27:eb6818ad257a 304 // fill notify
ansond 27:eb6818ad257a 305 notify_data_length = this->getDataWrapper()->length();
ansond 27:eb6818ad257a 306 notify_data = this->getDataWrapper()->get();
ansond 27:eb6818ad257a 307 }
ansond 27:eb6818ad257a 308 else {
ansond 27:eb6818ad257a 309 // announce (no wrap)
ansond 37:5de33aed0cac 310 //this->logger()->log("Notify payload [%s]...",data);
ansond 27:eb6818ad257a 311
ansond 27:eb6818ad257a 312 // do not wrap the data...
ansond 27:eb6818ad257a 313 notify_data_length = data_length;
ansond 27:eb6818ad257a 314 notify_data = data;
ansond 27:eb6818ad257a 315 }
ansond 27:eb6818ad257a 316
ansond 27:eb6818ad257a 317 // send the observation...
ansond 27:eb6818ad257a 318 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 319 if (status == 0) {
ansond 21:8487990a3baa 320 this->logger()->log("ERROR: resource(NOTIFY) send failed...");
ansond 21:8487990a3baa 321 }
ansond 27:eb6818ad257a 322
ansond 27:eb6818ad257a 323 // return our status
ansond 21:8487990a3baa 324 return status;
ansond 21:8487990a3baa 325 }
ansond 21:8487990a3baa 326
sam_grove 2:853f9ecc12df 327 // default PUT (does nothing)
sam_grove 2:853f9ecc12df 328 void DynamicResource::put(const string value)
sam_grove 2:853f9ecc12df 329 {
sam_grove 2:853f9ecc12df 330 // not used by default
sam_grove 2:853f9ecc12df 331 ;
sam_grove 2:853f9ecc12df 332 }
sam_grove 2:853f9ecc12df 333
ansond 21:8487990a3baa 334 // default POST (does nothing)
ansond 21:8487990a3baa 335 void DynamicResource::post(const string value)
ansond 21:8487990a3baa 336 {
ansond 21:8487990a3baa 337 // not used by default
ansond 21:8487990a3baa 338 ;
ansond 21:8487990a3baa 339 }
ansond 21:8487990a3baa 340
ansond 21:8487990a3baa 341 // default DELETE (does nothing)
ansond 21:8487990a3baa 342 void DynamicResource::del(const string value)
ansond 21:8487990a3baa 343 {
ansond 21:8487990a3baa 344 // not used by default
ansond 21:8487990a3baa 345 ;
ansond 21:8487990a3baa 346 }
ansond 21:8487990a3baa 347
ansond 30:113c2a1d8db2 348 // default observe behavior
ansond 30:113c2a1d8db2 349 void DynamicResource::observe() {
ansond 30:113c2a1d8db2 350 if (this->m_observable == true) {
ansond 30:113c2a1d8db2 351 this->notify(this->get());
ansond 30:113c2a1d8db2 352 }
ansond 30:113c2a1d8db2 353 }
ansond 30:113c2a1d8db2 354
ansond 31:bacc63106754 355 // set the observer pointer
ansond 31:bacc63106754 356 void DynamicResource::setObserver(void *observer) {
ansond 31:bacc63106754 357 this->m_observer = observer;
ansond 31:bacc63106754 358 }
ansond 31:bacc63106754 359
sam_grove 2:853f9ecc12df 360 // convenience method to get the URI from its buffer field...
sam_grove 2:853f9ecc12df 361 string DynamicResource::coapDataToString(uint8_t *coap_data_ptr,int coap_data_ptr_length)
sam_grove 2:853f9ecc12df 362 {
ansond 0:b438482ebbfc 363 if (coap_data_ptr != NULL && coap_data_ptr_length > 0) {
ansond 24:a6915e19814e 364 if (this->getDataWrapper() != NULL) {
ansond 24:a6915e19814e 365 // unwrap the data...
ansond 24:a6915e19814e 366 this->getDataWrapper()->unwrap(coap_data_ptr,coap_data_ptr_length);
ansond 24:a6915e19814e 367 char *buf = (char *)this->getDataWrapper()->get(); // assumes data is null terminated in DataWrapper...
ansond 24:a6915e19814e 368 return string(buf);
ansond 24:a6915e19814e 369 }
ansond 24:a6915e19814e 370 else {
ansond 24:a6915e19814e 371 // no unwrap of the data...
ansond 24:a6915e19814e 372 char buf[MAX_VALUE_BUFFER_LENGTH+1];
ansond 24:a6915e19814e 373 memset(buf,0,MAX_VALUE_BUFFER_LENGTH+1);
ansond 24:a6915e19814e 374 memcpy(buf,(char *)coap_data_ptr,coap_data_ptr_length);
ansond 24:a6915e19814e 375 return string(buf);
ansond 24:a6915e19814e 376 }
ansond 0:b438482ebbfc 377 }
ansond 0:b438482ebbfc 378 return string("");
sam_grove 2:853f9ecc12df 379 }