Dan Lopez / osisoft-omf

Separate library that holds helper functions for the main OMF code.

osisoft-omf.cpp@19:9b357e31f61d, 2018-11-29 (annotated)

Committer:
danielelopez
Date:
Thu Nov 29 18:53:59 2018 +0000
Revision:
19:9b357e31f61d
Parent:
18:c6c9cce5d990 
Made edits to remove old socket-based approach and removed debug settings that are now deprecated in the latest med-http library.

Who changed what in which revision?

UserRevisionLine numberNew contents of line
danielelopez 14:6ed67a160616 1 //Copyright 2018 OSIsoft, LLC
danielelopez 0:6156b29d3c91 2 //
danielelopez 0:6156b29d3c91 3 //Licensed under the Apache License, Version 2.0 (the "License");
danielelopez 0:6156b29d3c91 4 //you may not use this file except in compliance with the License.
danielelopez 0:6156b29d3c91 5 //You may obtain a copy of the License at
danielelopez 0:6156b29d3c91 6 //
danielelopez 0:6156b29d3c91 7 //<http://www.apache.org/licenses/LICENSE-2.0>
danielelopez 0:6156b29d3c91 8 //
danielelopez 0:6156b29d3c91 9 //Unless required by applicable law or agreed to in writing, software
danielelopez 0:6156b29d3c91 10 //distributed under the License is distributed on an "AS IS" BASIS,
danielelopez 0:6156b29d3c91 11 //WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
danielelopez 0:6156b29d3c91 12 //See the License for the specific language governing permissions and
danielelopez 0:6156b29d3c91 13 //limitations under the License.
danielelopez 0:6156b29d3c91 14
danielelopez 0:6156b29d3c91 15 #include "osisoft-omf.h"
danielelopez 0:6156b29d3c91 16 #include "mbed.h"
danielelopez 0:6156b29d3c91 17 #include "https_request.h"
danielelopez 0:6156b29d3c91 18 #include "ntp-client/NTPClient.h"
danielelopez 10:844e209f1d79 19 #include "config.egressSettings.h"
danielelopez 8:e5fe40b77f8f 20 #include "config.SSLCertificates.h"
danielelopez 8:e5fe40b77f8f 21 #include "config.producerToken.h"
danielelopez 17:cc05a00e6ee6 22 #include "config.OMFContainerAndLINKJSON.h"
danielelopez 17:cc05a00e6ee6 23 #include "config.OMFDynamicAndStaticTypesAndAssetJSON.h"
danielelopez 0:6156b29d3c91 24
danielelopez 0:6156b29d3c91 25 // ---------------------------------------------------------------------------------------------------
danielelopez 0:6156b29d3c91 26
danielelopez 0:6156b29d3c91 27 // The clock is set usign NTP; if that fails, the clock defaults to the below time
danielelopez 0:6156b29d3c91 28 const int DEFAULT_HARD_CODED_UTC_TIME = 1513175347;
danielelopez 0:6156b29d3c91 29
danielelopez 0:6156b29d3c91 30 // ---------------------------------------------------------------------------------------------------
danielelopez 0:6156b29d3c91 31
danielelopez 0:6156b29d3c91 32 // ************************************************************************
danielelopez 0:6156b29d3c91 33 // Helper function: prints out an HTTP response
danielelopez 0:6156b29d3c91 34 // ************************************************************************
danielelopez 0:6156b29d3c91 35
danielelopez 1:1c31b413ba0c 36 void OMFLib_dump_response(HttpResponse* res)
danielelopez 0:6156b29d3c91 37 {
danielelopez 1:1c31b413ba0c 38 printf("\n\r----- HTTPS POST response -----\n\r");
danielelopez 0:6156b29d3c91 39 // Print the status code
danielelopez 1:1c31b413ba0c 40 mbedtls_printf("Status: %d - %s\n\r", res->get_status_code(), res->get_status_message().c_str());
danielelopez 0:6156b29d3c91 41 // Print the headers
danielelopez 1:1c31b413ba0c 42 mbedtls_printf("Response headers:\n\r");
danielelopez 0:6156b29d3c91 43 for (size_t ix = 0; ix < res->get_headers_length(); ix++) {
danielelopez 1:1c31b413ba0c 44 mbedtls_printf("\t%s: %s\n\r", res->get_headers_fields()[ix]->c_str(), res->get_headers_values()[ix]->c_str());
danielelopez 0:6156b29d3c91 45 }
danielelopez 0:6156b29d3c91 46 // Print the body
danielelopez 0:6156b29d3c91 47 mbedtls_printf("Response body (%d bytes):\n\n%s", res->get_body_length(), res->get_body_as_string().c_str());
danielelopez 0:6156b29d3c91 48 }
danielelopez 0:6156b29d3c91 49
danielelopez 0:6156b29d3c91 50 // ************************************************************************
danielelopez 0:6156b29d3c91 51 // Helper function that casts floats into strings
danielelopez 0:6156b29d3c91 52 // ************************************************************************
danielelopez 0:6156b29d3c91 53
danielelopez 0:6156b29d3c91 54 string OMFLib_float_to_string(float f) {
danielelopez 0:6156b29d3c91 55 char buffer[20];
danielelopez 0:6156b29d3c91 56 int n = sprintf (buffer, "%f", f);
danielelopez 13:61d3de73a844 57 // Return -1 if a parse failure ocurred
danielelopez 13:61d3de73a844 58 if (string(buffer) == "NaN") {
danielelopez 13:61d3de73a844 59 return string("-1");
danielelopez 13:61d3de73a844 60 } else {
danielelopez 13:61d3de73a844 61 return string(buffer);
danielelopez 13:61d3de73a844 62 }
danielelopez 0:6156b29d3c91 63 }
danielelopez 0:6156b29d3c91 64
danielelopez 19:9b357e31f61d 65 /* Deprecated after changes to TLS Socket
danielelopez 0:6156b29d3c91 66 // ************************************************************************
danielelopez 0:6156b29d3c91 67 // Helper function that sends an actual web request
danielelopez 0:6156b29d3c91 68 // ************************************************************************
danielelopez 0:6156b29d3c91 69
danielelopez 0:6156b29d3c91 70 void OMFLib_sendMessageToEndpoint(TLSSocket* socket, const char* action, const char* message_type, const char* body) {
danielelopez 1:1c31b413ba0c 71 printf("\n\r----- HTTPS POST request -----\n\r");
danielelopez 0:6156b29d3c91 72
danielelopez 0:6156b29d3c91 73 // Create the new request
danielelopez 0:6156b29d3c91 74 //HttpsRequest* post_req = new HttpsRequest(network, SSL_CA_PEM, HTTP_POST, TARGET_URL); // Old: doesn't re-use sockets
danielelopez 0:6156b29d3c91 75 HttpsRequest* post_req = new HttpsRequest(socket, HTTP_POST, TARGET_URL);
danielelopez 0:6156b29d3c91 76
danielelopez 19:9b357e31f61d 77 // Turn on debugging - this hides TLS connection information (deprecated)
danielelopez 19:9b357e31f61d 78 //post_req->set_debug(true);
danielelopez 0:6156b29d3c91 79
danielelopez 0:6156b29d3c91 80 // Add headers: content type and authentication
danielelopez 0:6156b29d3c91 81 post_req->set_header("Content-Type", "application/json");
danielelopez 0:6156b29d3c91 82
danielelopez 0:6156b29d3c91 83 // Set OMF headers
danielelopez 0:6156b29d3c91 84 post_req->set_header("producertoken", PRODUCER_TOKEN);
danielelopez 0:6156b29d3c91 85 post_req->set_header("messagetype", message_type);
danielelopez 0:6156b29d3c91 86 post_req->set_header("action", action);
danielelopez 0:6156b29d3c91 87 post_req->set_header("messageformat", "JSON");
danielelopez 0:6156b29d3c91 88 post_req->set_header("omfversion", "1.0");
danielelopez 0:6156b29d3c91 89
danielelopez 0:6156b29d3c91 90 // Send the body
danielelopez 0:6156b29d3c91 91 printf("Now sending request...");
danielelopez 1:1c31b413ba0c 92 printf("\n\rOutgoing message headers:\n\tmessagetype: %s\n\taction: %s", message_type, action);
danielelopez 1:1c31b413ba0c 93 printf("\n\rOutgoing message body:\n\t%s\n\r", body);
danielelopez 0:6156b29d3c91 94 HttpResponse* post_res = post_req->send(body, strlen(body));
danielelopez 0:6156b29d3c91 95
danielelopez 0:6156b29d3c91 96 // Check the response for an error
danielelopez 0:6156b29d3c91 97 if (!post_res) {
danielelopez 1:1c31b413ba0c 98 printf("HttpRequest failed (error code %d)\n\r", post_req->get_error());
danielelopez 1:1c31b413ba0c 99 printf("Socket connection status after error: %d\n\r", socket->connected());
danielelopez 0:6156b29d3c91 100 //return 1;
danielelopez 0:6156b29d3c91 101 } else {
danielelopez 0:6156b29d3c91 102 // Print the response
danielelopez 1:1c31b413ba0c 103 OMFLib_dump_response(post_res);
danielelopez 1:1c31b413ba0c 104 }
danielelopez 1:1c31b413ba0c 105
danielelopez 1:1c31b413ba0c 106 // Free up the request object
danielelopez 1:1c31b413ba0c 107 delete post_req;
danielelopez 1:1c31b413ba0c 108 }
danielelopez 19:9b357e31f61d 109 */
danielelopez 1:1c31b413ba0c 110
danielelopez 1:1c31b413ba0c 111 // ************************************************************************
danielelopez 1:1c31b413ba0c 112 // Helper function that sends an actual web request; does not reuse sockets
danielelopez 1:1c31b413ba0c 113 // ************************************************************************
danielelopez 1:1c31b413ba0c 114
danielelopez 18:c6c9cce5d990 115 #if ENABLE_PRINTOUTS == YES_ENABLE_PRINTOUTS
danielelopez 18:c6c9cce5d990 116 void OMFLib_sendMessageToEndpoint_NoSocketReuse(NetworkInterface* network, const char* action, const char* message_type, const char* body) {
danielelopez 18:c6c9cce5d990 117
danielelopez 18:c6c9cce5d990 118 printf("\n\r----- HTTPS POST request -----\n\r");
danielelopez 18:c6c9cce5d990 119
danielelopez 18:c6c9cce5d990 120 // Create the new request
danielelopez 18:c6c9cce5d990 121 HttpsRequest* post_req = new HttpsRequest(network, SSL_CA_PEM, HTTP_POST, TARGET_URL);
danielelopez 12:8fb2bb26528f 122
danielelopez 19:9b357e31f61d 123 // Turn on debugging - this hides TLS connection information (deprecated)
danielelopez 18:c6c9cce5d990 124 //post_req->set_debug(true);
danielelopez 1:1c31b413ba0c 125
danielelopez 18:c6c9cce5d990 126 // Add headers: content type
danielelopez 18:c6c9cce5d990 127 post_req->set_header("Content-Type", CONTENT_TYPE);
danielelopez 18:c6c9cce5d990 128
danielelopez 18:c6c9cce5d990 129 // Set OMF headers
danielelopez 18:c6c9cce5d990 130 post_req->set_header("producertoken", PRODUCER_TOKEN);
danielelopez 18:c6c9cce5d990 131 post_req->set_header("messagetype", message_type);
danielelopez 18:c6c9cce5d990 132 post_req->set_header("action", action);
danielelopez 18:c6c9cce5d990 133 post_req->set_header("messageformat", OMF_MESSAGE_FORMAT);
danielelopez 18:c6c9cce5d990 134 post_req->set_header("omfversion", OMF_VERSION);
danielelopez 18:c6c9cce5d990 135
danielelopez 18:c6c9cce5d990 136 // Send the body
danielelopez 18:c6c9cce5d990 137 printf("Now sending request... ");
danielelopez 18:c6c9cce5d990 138 //printf("\n\rOutgoing message headers:\n\tmessagetype: %s\n\taction: %s", message_type, action);
danielelopez 18:c6c9cce5d990 139 //printf("\n\rOutgoing message body:\n\t%s\n\r", body);
danielelopez 18:c6c9cce5d990 140 HttpResponse* post_res = post_req->send(body, strlen(body));
danielelopez 1:1c31b413ba0c 141
danielelopez 18:c6c9cce5d990 142 // Check the response for an error
danielelopez 18:c6c9cce5d990 143 if (!post_res) {
danielelopez 18:c6c9cce5d990 144 printf("HttpRequest failed (error code %d)\n\r", post_req->get_error());
danielelopez 18:c6c9cce5d990 145 //return 1;
danielelopez 18:c6c9cce5d990 146 } else {
danielelopez 18:c6c9cce5d990 147 // Print the response
danielelopez 18:c6c9cce5d990 148 printf("Success!\n\r");
danielelopez 18:c6c9cce5d990 149 //OMFLib_dump_response(post_res);
danielelopez 18:c6c9cce5d990 150 }
danielelopez 12:8fb2bb26528f 151
danielelopez 18:c6c9cce5d990 152 // Free up the request object
danielelopez 18:c6c9cce5d990 153 delete post_req;
danielelopez 0:6156b29d3c91 154 }
danielelopez 18:c6c9cce5d990 155 #endif
danielelopez 0:6156b29d3c91 156
danielelopez 18:c6c9cce5d990 157 // Option if printouts should be hidden
danielelopez 18:c6c9cce5d990 158 #if ENABLE_PRINTOUTS == DO_NOT_ENABLE_PRINTOUTS
danielelopez 18:c6c9cce5d990 159 void OMFLib_sendMessageToEndpoint_NoSocketReuse(NetworkInterface* network, const char* action, const char* message_type, const char* body) {
danielelopez 18:c6c9cce5d990 160
danielelopez 18:c6c9cce5d990 161 // Create the new request
danielelopez 18:c6c9cce5d990 162 HttpsRequest* post_req = new HttpsRequest(network, SSL_CA_PEM, HTTP_POST, TARGET_URL);
danielelopez 18:c6c9cce5d990 163
danielelopez 19:9b357e31f61d 164 // Turn on debugging - this hides TLS connection information (deprecated)
danielelopez 18:c6c9cce5d990 165 //post_req->set_debug(true);
danielelopez 18:c6c9cce5d990 166
danielelopez 18:c6c9cce5d990 167 // Add headers: content type
danielelopez 18:c6c9cce5d990 168 post_req->set_header("Content-Type", CONTENT_TYPE);
danielelopez 18:c6c9cce5d990 169
danielelopez 18:c6c9cce5d990 170 // Set OMF headers
danielelopez 18:c6c9cce5d990 171 post_req->set_header("producertoken", PRODUCER_TOKEN);
danielelopez 18:c6c9cce5d990 172 post_req->set_header("messagetype", message_type);
danielelopez 18:c6c9cce5d990 173 post_req->set_header("action", action);
danielelopez 18:c6c9cce5d990 174 post_req->set_header("messageformat", OMF_MESSAGE_FORMAT);
danielelopez 18:c6c9cce5d990 175 post_req->set_header("omfversion", OMF_VERSION);
danielelopez 18:c6c9cce5d990 176
danielelopez 18:c6c9cce5d990 177 // Send the body
danielelopez 18:c6c9cce5d990 178 HttpResponse* post_res = post_req->send(body, strlen(body));
danielelopez 18:c6c9cce5d990 179
danielelopez 18:c6c9cce5d990 180 // Free up the request object
danielelopez 18:c6c9cce5d990 181 delete post_req;
danielelopez 18:c6c9cce5d990 182 }
danielelopez 18:c6c9cce5d990 183 #endif
danielelopez 0:6156b29d3c91 184
danielelopez 0:6156b29d3c91 185 // ************************************************************************
danielelopez 0:6156b29d3c91 186 // Gets the current time in the appropriate OMF format
danielelopez 18:c6c9cce5d990 187 // See https://os.mbed.com/blog/entry/103/
danielelopez 0:6156b29d3c91 188 // ************************************************************************
danielelopez 18:c6c9cce5d990 189 const int TIMESTAMP_BUFFER_SIZE = 21;
danielelopez 0:6156b29d3c91 190 string OMFLib_getCurrentTimeString() {
danielelopez 0:6156b29d3c91 191 // Declar vars
danielelopez 18:c6c9cce5d990 192 char timestampBuffer[TIMESTAMP_BUFFER_SIZE]; // The format is YYYY-MM-DDThh:mm:ssZ
danielelopez 0:6156b29d3c91 193 time_t now;
danielelopez 18:c6c9cce5d990 194 //struct tm ts;
danielelopez 0:6156b29d3c91 195
danielelopez 18:c6c9cce5d990 196 // Set the "now" var to the current time
danielelopez 0:6156b29d3c91 197 time(&now);
danielelopez 0:6156b29d3c91 198
danielelopez 18:c6c9cce5d990 199 // Cast the current time into UTC seconds
danielelopez 18:c6c9cce5d990 200 //ts = *localtime(&now);
danielelopez 18:c6c9cce5d990 201
danielelopez 18:c6c9cce5d990 202 // Print out the time in seconds as a formatted string to the timestamp buffer
danielelopez 18:c6c9cce5d990 203 //strftime(timestampBuffer, sizeof(timestampBuffer), "%Y-%m-%dT%H:%M:%SZ", &ts);
danielelopez 18:c6c9cce5d990 204 //strftime(timestampBuffer, sizeof(timestampBuffer), "%Y-%m-%dT%H:%M:%SZ", &ts);
danielelopez 18:c6c9cce5d990 205 strftime(timestampBuffer, TIMESTAMP_BUFFER_SIZE, "%Y-%m-%dT%H:%M:%SZ", localtime(&now));
danielelopez 0:6156b29d3c91 206
danielelopez 0:6156b29d3c91 207 // Return the result
danielelopez 0:6156b29d3c91 208 return string(timestampBuffer);
danielelopez 0:6156b29d3c91 209 }
danielelopez 0:6156b29d3c91 210
danielelopez 0:6156b29d3c91 211 // ************************************************************************
danielelopez 9:e2d177cf9135 212 // Sets the clock via NTP via the nwtwork; can point to a local or internet-based server
danielelopez 0:6156b29d3c91 213 // ************************************************************************
danielelopez 0:6156b29d3c91 214
danielelopez 0:6156b29d3c91 215 void OMFLib_syncClockViaNTP(NetworkInterface* network) {
danielelopez 0:6156b29d3c91 216 // Hard-code a start time... see https://www.epochconverter.com/
danielelopez 0:6156b29d3c91 217 set_time(DEFAULT_HARD_CODED_UTC_TIME);
danielelopez 0:6156b29d3c91 218
danielelopez 1:1c31b413ba0c 219 printf("\n\r----- Setting internal clock -----\n\r");
danielelopez 0:6156b29d3c91 220 // See https://github.com/ARMmbed/ntp-client-example/blob/master/main.cpp
danielelopez 0:6156b29d3c91 221
danielelopez 9:e2d177cf9135 222 // Connect the ntp object to the network
danielelopez 0:6156b29d3c91 223 NTPClient ntp(network);
danielelopez 9:e2d177cf9135 224
danielelopez 9:e2d177cf9135 225 // Set the ntp server to either an internet-based server OR to a local server
danielelopez 9:e2d177cf9135 226 ntp.set_server("2.pool.ntp.org", 123);
danielelopez 9:e2d177cf9135 227
danielelopez 9:e2d177cf9135 228 // Get the timestamp via NTP
danielelopez 0:6156b29d3c91 229 time_t timestamp = ntp.get_timestamp();
danielelopez 18:c6c9cce5d990 230
danielelopez 18:c6c9cce5d990 231 // Set the current timestamp to the NTP timestamp
danielelopez 18:c6c9cce5d990 232 set_time(timestamp);
danielelopez 18:c6c9cce5d990 233
danielelopez 18:c6c9cce5d990 234 // Print the result
danielelopez 18:c6c9cce5d990 235 printf("Attempt done; clock set to UTC %s", ctime(&timestamp));
danielelopez 15:32ada27d82b4 236 }
danielelopez 15:32ada27d82b4 237
danielelopez 15:32ada27d82b4 238 // ************************************************************************
danielelopez 15:32ada27d82b4 239 // Sends the dynamic types, static types, assets, and links messages
danielelopez 18:c6c9cce5d990 240 // Uses the SEND_ASSETS_AND_LINKS MACRO found in config.egressSettings and
danielelopez 15:32ada27d82b4 241 // Uses the custom OMF JSON found in config.customOMFJSONStructures.h
danielelopez 15:32ada27d82b4 242 // ************************************************************************
danielelopez 15:32ada27d82b4 243
danielelopez 18:c6c9cce5d990 244 #if SEND_ASSETS_AND_LINKS == YES_SEND_ASSETS_AND_LINKS
danielelopez 18:c6c9cce5d990 245 void OMFLib_sendInitialOMFMessages(NetworkInterface* __network_interface) {
danielelopez 18:c6c9cce5d990 246 // Send the DYNAMIC types message, so that these types can be referenced in all later messages
danielelopez 18:c6c9cce5d990 247 printf("\n\r!!!!!!!! Sending DYNAMIC Types message... !!!!!!!!\n\r");
danielelopez 18:c6c9cce5d990 248 //OMFLib_sendMessageToEndpoint(socket, "create", "Type", dynamic_types_message_JSON.c_str());
danielelopez 18:c6c9cce5d990 249 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Type", DYNAMIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 250 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Type", DYNAMIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 251
danielelopez 18:c6c9cce5d990 252 // Send the container message, to instantiate this particular container; we can now directly start sending data to it using its Id
danielelopez 18:c6c9cce5d990 253 printf("\n\r!!!!!!!! Sending Containers message... !!!!!!!!\n\r");
danielelopez 18:c6c9cce5d990 254 //OMFLib_sendMessageToEndpoint(socket, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 255 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 256 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 257
danielelopez 15:32ada27d82b4 258 // ************************************************************************
danielelopez 15:32ada27d82b4 259 // Send the STATIC types message, so that these types can be referenced in all later messages
danielelopez 15:32ada27d82b4 260 // ************************************************************************
danielelopez 15:32ada27d82b4 261
danielelopez 15:32ada27d82b4 262 printf("\n\r!!!!!!!! Sending STATIC Types message... !!!!!!!!\n\r");
danielelopez 15:32ada27d82b4 263 //OMFLib_sendMessageToEndpoint(socket, "create", "Type", static_types_message_JSON.c_str());
danielelopez 15:32ada27d82b4 264 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Type", STATIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 265 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Type", STATIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 266
danielelopez 15:32ada27d82b4 267 // ************************************************************************
danielelopez 15:32ada27d82b4 268 // Send the message to create the PI AF asset; it will not appear in PI AF, though, because it has not yet been positioned...
danielelopez 15:32ada27d82b4 269 // ************************************************************************
danielelopez 15:32ada27d82b4 270
danielelopez 15:32ada27d82b4 271 printf("\n\r!!!!!!!! Sending Assets message... !!!!!!!!\n\r");
danielelopez 15:32ada27d82b4 272 //OMFLib_sendMessageToEndpoint(socket, "create", "Data", assets_message_JSON.c_str());
danielelopez 15:32ada27d82b4 273 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Data", ASSETS_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 274 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Data", ASSETS_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 275
danielelopez 15:32ada27d82b4 276 // ************************************************************************
danielelopez 15:32ada27d82b4 277 // Send the message to link the PI AF asset
danielelopez 15:32ada27d82b4 278 // ************************************************************************
danielelopez 15:32ada27d82b4 279
danielelopez 15:32ada27d82b4 280 printf("\n\r!!!!!!!! Sending Links message... !!!!!!!!\n\r");
danielelopez 15:32ada27d82b4 281 //OMFLib_sendMessageToEndpoint(socket, "create", "Data", LINKS_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 282 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Data", LINKS_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 283 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Data", LINKS_MESSAGE_JSON.c_str());
danielelopez 15:32ada27d82b4 284 }
danielelopez 18:c6c9cce5d990 285 #endif
danielelopez 18:c6c9cce5d990 286
danielelopez 18:c6c9cce5d990 287 // If assets and links should be skipped...
danielelopez 18:c6c9cce5d990 288 #if SEND_ASSETS_AND_LINKS == DO_NOT_SEND_ASSETS_AND_LINKS
danielelopez 18:c6c9cce5d990 289 void OMFLib_sendInitialOMFMessages(NetworkInterface* __network_interface) {
danielelopez 18:c6c9cce5d990 290 // Send the DYNAMIC types message, so that these types can be referenced in all later messages
danielelopez 18:c6c9cce5d990 291 printf("\n\r!!!!!!!! Sending DYNAMIC Types message... !!!!!!!!\n\r");
danielelopez 18:c6c9cce5d990 292 //OMFLib_sendMessageToEndpoint(socket, "create", "Type", dynamic_types_message_JSON.c_str());
danielelopez 18:c6c9cce5d990 293 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Type", DYNAMIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 294 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Type", DYNAMIC_TYPES_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 295
danielelopez 18:c6c9cce5d990 296 // Send the container message, to instantiate this particular container; we can now directly start sending data to it using its Id
danielelopez 18:c6c9cce5d990 297 printf("\n\r!!!!!!!! Sending Containers message... !!!!!!!!\n\r");
danielelopez 18:c6c9cce5d990 298 //OMFLib_sendMessageToEndpoint(socket, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 299 //OMFLib_sendMessageToEndpoint_NoSocketReuse(network, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 300 OMFLib_sendMessageToEndpoint_NoSocketReuse(__network_interface, "create", "Container", CONTAINERS_MESSAGE_JSON.c_str());
danielelopez 18:c6c9cce5d990 301 }
danielelopez 18:c6c9cce5d990 302 #endif