opex62541

/*
 *  Copyright 2016 Frank Hunleth
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#ifndef UTIL_H
#define UTIL_H

#include <stdio.h>
#include <stdlib.h>
#include <stdint.h>
#include "open62541.h"
#include "erlcmd.h"

//#define DEBUG
#define ERLCMD_BUF_SIZE 32768

#ifdef DEBUG
FILE *log_location;
#define LOG_LOCATION log_location
#define debug(...) do { fprintf(log_location, __VA_ARGS__); fprintf(log_location, "\r\n"); fflush(log_location); } while(0)
#else
#define LOG_LOCATION stderr
#define debug(...)
#endif

#ifndef __WIN32__
#include <err.h>
#else
// If err.h doesn't exist, define substitutes.
#define err(STATUS, MSG, ...) do { fprintf(LOG_LOCATION, "nerves_uart: " MSG "\n", ## __VA_ARGS__); fflush(LOG_LOCATION); exit(STATUS); } while (0)
#define errx(STATUS, MSG, ...) do { fprintf(LOG_LOCATION, "nerves_uart: " MSG "\n", ## __VA_ARGS__); fflush(LOG_LOCATION); exit(STATUS); } while (0)
#define warn(MSG, ...) do { fprintf(LOG_LOCATION, "nerves_uart: " MSG "\n", ## __VA_ARGS__); fflush(LOG_LOCATION); } while (0)
#define warnx(MSG, ...) do { fprintf(LOG_LOCATION, "nerves_uart: " MSG "\n", ## __VA_ARGS__); fflush(LOG_LOCATION); } while (0)
#endif

#define ONE_YEAR_MILLIS (1000ULL * 60 * 60 * 24 * 365)
uint64_t current_time();
#endif // UTIL_H

static char *caller_function;

static char *caller_metadata_ptr;
static size_t caller_metadata_size = 0;

//Client and Server common functions
UA_NodeId assemble_node_id(const char *req, int *req_index);
UA_ExpandedNodeId assemble_expanded_node_id(const char *req, int *req_index);
UA_QualifiedName assemble_qualified_name(const char *req, int *req_index);

// Elixir Message assemblers
void encode_client_config(char *resp, int *resp_index, void *data);
void encode_server_on_the_network_struct(char *resp, int *resp_index, void *data, int data_len);
void encode_application_description_struct(char *resp, int *resp_index, void *data, int data_len);
void encode_endpoint_description_struct(char *resp, int *resp_index, void *data, int data_len);
void encode_array_dimensions_struct(char *resp, int *resp_index, void *data, int data_len);
void encode_server_config(char *resp, int *resp_index, void *data);
void send_subscription_timeout_response(void *data, int data_type, int data_len);
void send_subscription_deleted_response(void *data, int data_type, int data_len);
void send_monitored_item_response(void *subscription_id, void *monitored_id, void *data, int data_type);
void send_monitored_item_delete_response(void *subscription_id, void *monitored_id);
void send_data_response(void *data, int data_type, int data_len);
void send_error_response(const char *reason);
void send_ok_response();
void send_opex_response(uint32_t reason);

//Elixir message decoders
void handle_caller_metadata(const char *req, int *req_index, const char* cmd);
void free_caller_metadata();

//Client and Server common handlers
void handle_test(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_variable_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_variable_type_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_object_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_object_type_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_view_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_reference_type_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_data_type_node(void *entity, bool entity_type, const char *req, int *req_index);
void handle_add_reference(void *entity, bool entity_type, const char *req, int *req_index);
void handle_delete_reference(void *entity, bool entity_type, const char *req, int *req_index);
void handle_delete_node(void *entity, bool entity_type, const char *req, int *req_index);

void handle_write_node_browse_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_display_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_description(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_write_mask(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_is_abstract(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_inverse_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_data_type(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_value_rank(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_access_level(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_array_dimensions(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_minimum_sampling_interval(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_historizing(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_executable(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_event_notifier(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_value(void *entity, bool entity_type, const char *req, int *req_index);
void handle_write_node_blank_array(void *entity, bool entity_type, const char *req, int *req_index);

void handle_read_node_node_id(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_node_class(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_browse_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_display_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_description(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_write_mask(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_is_abstract(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_symmetric(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_inverse_name(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_contains_no_loops(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_data_type(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_value_rank(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_array_dimensions(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_access_level(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_minimum_sampling_interval(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_historizing(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_executable(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_event_notifier(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_value(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_value_by_index(void *entity, bool entity_type, const char *req, int *req_index);
void handle_read_node_value_by_data_type(void *entity, bool entity_type, const char *req, int *req_index);