Maggie Mei / mbedConnectorInterfaceWithDM

use TCP to connect to mbed connector

Fork of mbedConnectorInterfaceWithDM by Doug Anson

source/Utils.cpp@13:9edad7677211, 2016-06-08 (annotated)

Committer:
ansond
Date:
Wed Jun 08 22:32:08 2016 +0000
Revision:
13:9edad7677211
Parent:
12:d0e61bac8c27
Child:
21:0bbe9057e7b1
updated to latest revision with new DM functions

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ansond 1:16f0fb5b8d97 1 /**
ansond 1:16f0fb5b8d97 2 * @file Utils.cpp
ansond 1:16f0fb5b8d97 3 * @brief mbed CoAP Endpoint misc utils collection
ansond 1:16f0fb5b8d97 4 * @author Doug Anson
ansond 1:16f0fb5b8d97 5 * @version 1.0
ansond 1:16f0fb5b8d97 6 * @see
ansond 1:16f0fb5b8d97 7 *
ansond 1:16f0fb5b8d97 8 * Copyright (c) 2014
ansond 1:16f0fb5b8d97 9 *
ansond 1:16f0fb5b8d97 10 * Licensed under the Apache License, Version 2.0 (the "License");
ansond 1:16f0fb5b8d97 11 * you may not use this file except in compliance with the License.
ansond 1:16f0fb5b8d97 12 * You may obtain a copy of the License at
ansond 1:16f0fb5b8d97 13 *
ansond 1:16f0fb5b8d97 14 * http://www.apache.org/licenses/LICENSE-2.0
ansond 1:16f0fb5b8d97 15 *
ansond 1:16f0fb5b8d97 16 * Unless required by applicable law or agreed to in writing, software
ansond 1:16f0fb5b8d97 17 * distributed under the License is distributed on an "AS IS" BASIS,
ansond 1:16f0fb5b8d97 18 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
ansond 1:16f0fb5b8d97 19 * See the License for the specific language governing permissions and
ansond 1:16f0fb5b8d97 20 * limitations under the License.
ansond 1:16f0fb5b8d97 21 */
ansond 1:16f0fb5b8d97 22
ansond 1:16f0fb5b8d97 23 // mbed Endpoint includes
ansond 1:16f0fb5b8d97 24 #include "mbed-connector-interface/ConnectorEndpoint.h"
ansond 1:16f0fb5b8d97 25 #include "mbed-connector-interface/OptionsBuilder.h"
ansond 6:d4d1105a1777 26 #include "mbed-connector-interface/mbedEndpointNetwork.h"
ansond 13:9edad7677211 27 #include "mbed-connector-interface/DeviceManager.h"
ansond 1:16f0fb5b8d97 28
ansond 10:3f79b5e67c22 29 // Maximum CoAP URL length
ansond 10:3f79b5e67c22 30 #define MAX_CONN_URL_LENGTH 128
ansond 10:3f79b5e67c22 31
ansond 1:16f0fb5b8d97 32 // External references (defined in main.cpp)
ansond 1:16f0fb5b8d97 33 Connector::Options *configure_endpoint(Connector::OptionsBuilder &builder);
ansond 1:16f0fb5b8d97 34 extern Logger logger;
ansond 1:16f0fb5b8d97 35
ansond 8:f950fb1b78c0 36 // Our Endpoint
ansond 8:f950fb1b78c0 37 Connector::Endpoint *__endpoint = NULL;
ansond 8:f950fb1b78c0 38
ansond 1:16f0fb5b8d97 39 // Our Endpoint configured Options
ansond 1:16f0fb5b8d97 40 Connector::OptionsBuilder config;
ansond 1:16f0fb5b8d97 41 Connector::Options *options = NULL;
ansond 1:16f0fb5b8d97 42
ansond 8:f950fb1b78c0 43 // initialize the Connector::Endpoint instance
ansond 8:f950fb1b78c0 44 void *utils_init_endpoint(bool canActAsRouterNode) {
ansond 8:f950fb1b78c0 45 // alloc Endpoint
ansond 8:f950fb1b78c0 46 logger.log("Endpoint: allocating endpoint instance...");
ansond 8:f950fb1b78c0 47 Connector::Endpoint *ep = new Connector::Endpoint(&logger,options);
ansond 8:f950fb1b78c0 48 if (ep != NULL) {
ansond 8:f950fb1b78c0 49 ep->asRouterNode(canActAsRouterNode);
ansond 8:f950fb1b78c0 50 }
ansond 8:f950fb1b78c0 51 return (void *)ep;
ansond 8:f950fb1b78c0 52 }
ansond 1:16f0fb5b8d97 53
ansond 1:16f0fb5b8d97 54 // further simplifies the endpoint main() configuration by removing the final initialization details of the endpoint...
ansond 1:16f0fb5b8d97 55 void utils_configure_endpoint(void *p)
ansond 1:16f0fb5b8d97 56 {
ansond 1:16f0fb5b8d97 57 // our Endpoint
ansond 1:16f0fb5b8d97 58 Connector::Endpoint *ep = (Connector::Endpoint *)p;
ansond 1:16f0fb5b8d97 59
ansond 1:16f0fb5b8d97 60 // NSP/NSDL default configuration - see mbedConnectorInterface.h for definitions...
ansond 1:16f0fb5b8d97 61 logger.log("Endpoint: setting defaults...");
ansond 1:16f0fb5b8d97 62 config.setEndpointNodename(NODE_NAME);
ansond 1:16f0fb5b8d97 63 config.setEndpointType(NSP_ENDPOINT_TYPE);
ansond 1:16f0fb5b8d97 64 config.setRegUpdatePeriod(REG_UPDATE_PERIOD_MS);
ansond 1:16f0fb5b8d97 65 config.setLifetime(REG_LIFETIME_SEC);
ansond 0:1f1f55e73248 66
ansond 1:16f0fb5b8d97 67 // WiFi defaults
ansond 1:16f0fb5b8d97 68 config.setWiFiSSID((char *)WIFI_DEFAULT_SSID); // default: changeme
ansond 12:d0e61bac8c27 69 config.setWiFiAuthType(WIFI_NONE); // default: none
ansond 11:3d4434825cd7 70 config.setWiFiAuthKey((char *)WIFI_DEFAULT_AUTH_KEY); // default: changeme
ansond 11:3d4434825cd7 71
ansond 11:3d4434825cd7 72 // Default CoAP Connection Type
ansond 11:3d4434825cd7 73 config.setCoAPConnectionType(COAP_UDP); // default CoAP Connection Type
ansond 11:3d4434825cd7 74
ansond 11:3d4434825cd7 75 // Set the default IP Address Type
ansond 11:3d4434825cd7 76 config.setIPAddressType(IP_ADDRESS_TYPE_IPV4); // IPv4 is the default
ansond 8:f950fb1b78c0 77
ansond 8:f950fb1b78c0 78 // 802.15.4 defaults
ansond 8:f950fb1b78c0 79 unsigned char psk[16];
ansond 8:f950fb1b78c0 80 unsigned char psk_identity[2];
ansond 8:f950fb1b78c0 81 memset(psk,0,16);
ansond 8:f950fb1b78c0 82 memset(psk_identity,0,2);
ansond 8:f950fb1b78c0 83 config.setPreSharedKey(psk);
ansond 8:f950fb1b78c0 84 config.setPreSharedKeyIdentity(psk_identity);
ansond 1:16f0fb5b8d97 85
ansond 1:16f0fb5b8d97 86 // Establish default CoAP observation behavior
ansond 1:16f0fb5b8d97 87 config.setImmedateObservationEnabled(true);
ansond 1:16f0fb5b8d97 88
ansond 1:16f0fb5b8d97 89 // Establish default CoAP GET-based observation control behavior
ansond 1:16f0fb5b8d97 90 config.setEnableGETObservationControl(false);
ansond 1:16f0fb5b8d97 91
ansond 13:9edad7677211 92 // Device Manager installation
ansond 13:9edad7677211 93 DeviceManager *device_manager = (DeviceManager *)ep->getDeviceManager();
ansond 13:9edad7677211 94 if (device_manager != NULL) {
ansond 13:9edad7677211 95 logger.log("Endpoint: installing and setting up device manager and its resources...");
ansond 13:9edad7677211 96 device_manager->install((void *)ep,(void *)&config);
ansond 13:9edad7677211 97 }
ansond 13:9edad7677211 98 else {
ansond 13:9edad7677211 99 logger.log("Endpoint: no device manager installed...");
ansond 13:9edad7677211 100 }
ansond 13:9edad7677211 101
ansond 1:16f0fb5b8d97 102 // main.cpp can override or change any of the above defaults...
ansond 1:16f0fb5b8d97 103 logger.log("Endpoint: gathering configuration overrides...");
ansond 1:16f0fb5b8d97 104 options = configure_endpoint(config);
ansond 8:f950fb1b78c0 105 ep->setOptions(options);
ansond 8:f950fb1b78c0 106
ansond 1:16f0fb5b8d97 107 // DONE
ansond 1:16f0fb5b8d97 108 logger.log("Endpoint: endpoint configuration completed.");
ansond 1:16f0fb5b8d97 109 }
ansond 1:16f0fb5b8d97 110
ansond 8:f950fb1b78c0 111 // build out the endpoint and its resources
ansond 8:f950fb1b78c0 112 void utils_build_endpoint(void *p)
ansond 1:16f0fb5b8d97 113 {
ansond 1:16f0fb5b8d97 114 if (p != NULL) {
ansond 8:f950fb1b78c0 115 // Build the Endpoint
ansond 8:f950fb1b78c0 116 logger.log("Endpoint: building endpoint and its resources...");
ansond 1:16f0fb5b8d97 117 Connector::Endpoint *ep = (Connector::Endpoint *)p;
ansond 8:f950fb1b78c0 118 ep->build_endpoint();
ansond 1:16f0fb5b8d97 119 }
ansond 10:3f79b5e67c22 120 }
ansond 10:3f79b5e67c22 121
ansond 10:3f79b5e67c22 122 // parse out the CoAP port number from the connection URL
ansond 10:3f79b5e67c22 123 uint16_t extract_port_from_url(char *url,uint16_t default_port)
ansond 10:3f79b5e67c22 124 {
ansond 10:3f79b5e67c22 125 uint16_t port = default_port;
ansond 10:3f79b5e67c22 126
ansond 10:3f79b5e67c22 127 if (url != NULL && strlen(url) > 0) {
ansond 10:3f79b5e67c22 128 char buffer[MAX_CONN_URL_LENGTH+1];
ansond 10:3f79b5e67c22 129 char uri[MAX_CONN_URL_LENGTH+1];
ansond 10:3f79b5e67c22 130 char path[MAX_CONN_URL_LENGTH+1];
ansond 10:3f79b5e67c22 131
ansond 10:3f79b5e67c22 132 // initialize the buffer
ansond 10:3f79b5e67c22 133 memset(buffer,0,MAX_CONN_URL_LENGTH+1);
ansond 10:3f79b5e67c22 134 memset(uri,0,MAX_CONN_URL_LENGTH+1);
ansond 10:3f79b5e67c22 135 memset(path,0,MAX_CONN_URL_LENGTH+1);
ansond 10:3f79b5e67c22 136 int length = strlen(url);
ansond 10:3f79b5e67c22 137
ansond 10:3f79b5e67c22 138 // truncate if needed
ansond 10:3f79b5e67c22 139 if (length >MAX_CONN_URL_LENGTH) length = MAX_CONN_URL_LENGTH;
ansond 10:3f79b5e67c22 140
ansond 10:3f79b5e67c22 141 // make a copy...
ansond 10:3f79b5e67c22 142 memcpy(buffer,url,length);
ansond 10:3f79b5e67c22 143
ansond 10:3f79b5e67c22 144 // remove the forward slashes and colons
ansond 10:3f79b5e67c22 145 for(int i=0;i<length;++i) {
ansond 10:3f79b5e67c22 146 if (buffer[i] == ':') buffer[i] = ' ';
ansond 10:3f79b5e67c22 147 if (buffer[i] == '/') buffer[i] = ' ';
ansond 10:3f79b5e67c22 148 }
ansond 10:3f79b5e67c22 149
ansond 10:3f79b5e67c22 150 // parse
ansond 10:3f79b5e67c22 151 sscanf(buffer,"%s %s %d",uri,path,(int *)&port);
ansond 10:3f79b5e67c22 152 }
ansond 10:3f79b5e67c22 153
ansond 10:3f79b5e67c22 154 // DEBUG
ansond 10:3f79b5e67c22 155 logger.log("Endpoint: CoAP port: %u",port);
ansond 10:3f79b5e67c22 156
ansond 10:3f79b5e67c22 157 // return the port
ansond 10:3f79b5e67c22 158 return port;
ansond 8:f950fb1b78c0 159 }