BACnetConfigurator.cpp

/*
 * BACnetConfigurator.cpp
 *
 *  Created on: 14.04.2018
 *      Author: Micha Mueller
 */

#include "BACnetConfigurator.h"

#include <boost/property_tree/info_parser.hpp>
#include <boost/foreach.hpp>
#include <boost/optional.hpp>
#include <boost/algorithm/string.hpp>
#include <iostream>

BACnetConfigurator::BACnetConfigurator() {
	_bacClient = NULL;
}

BACnetConfigurator::~BACnetConfigurator() {
	for(auto s : _sensors) {
		delete s;
	}
	delete _bacClient;
}

bool BACnetConfigurator::readConfig(std::string cfgPath) {
	boost::property_tree::iptree cfg;
	boost::property_tree::read_info(cfgPath, cfg);

	_bacClient = new BACnetClient();
	std::string interface, address_cache, mqttPartDevice, mqttPartObject;
	unsigned port = 47808, timeout = 1000, apdu_timeout = 200, apdu_retries = 0;
	unsigned deviceInstance = 0, objInstance = 0;
	BACNET_OBJECT_TYPE objType = OBJECT_DEVICE; /* = 8 */

	//read global variables (if present overwrite those from global.conf)
	BOOST_FOREACH(boost::property_tree::iptree::value_type &global, cfg.get_child("global")) {
		if (boost::iequals(global.first, "address_cache")) {
			address_cache = global.second.data();
			LOG(debug) << "  Address Cache: " << address_cache;
		} else if (boost::iequals(global.first, "interface")) {
			interface = global.second.data();
			LOG(debug) << "  Interface " << interface;
		} else if (boost::iequals(global.first, "port")) {
			port = stoul(global.second.data());
			LOG(debug) << "  Port " << port;
		} else if (boost::iequals(global.first, "timeout")) {
			timeout = stoul(global.second.data());
			LOG(debug) << "  Timeout " << timeout;
		} else if (boost::iequals(global.first, "apdu_timeout")) {
			apdu_timeout = stoul(global.second.data());
			LOG(debug) << "  apdu_timeout " << apdu_timeout;
		} else if (boost::iequals(global.first, "apdu_retries")) {
			apdu_retries = stoul(global.second.data());
			LOG(debug) << "  apdu_retries " << apdu_retries;
		} else if (boost::iequals(global.first, "mqttprefix")) {
			_mqttPrefix = global.second.data();
			if (_mqttPrefix[_mqttPrefix.length()-1] != '/') {
				_mqttPrefix.append("/");
			}
			LOG(debug) << "  Using own MQTT-Prefix " << _mqttPrefix;
		} else if (boost::iequals(global.first, "cacheInterval")) {
			_cacheInterval = stoul(global.second.data());
			LOG(debug) << "  Using own caching interval " << _cacheInterval << " [s]";
			_cacheInterval *= 1000;
		} else {
			LOG(error) << "  Value \"" << global.first << "\" not recognized. Omitting...";
		}
	}

	try {
		_bacClient->init(interface, address_cache, port, timeout, apdu_timeout, apdu_retries);
	} catch (const std::exception& e) {
		LOG(error) << "Could not initialize BACnetClient: " << e.what();
		return false;
	}

	//read template sensors
	BOOST_FOREACH(boost::property_tree::iptree::value_type &sensor, cfg.get_child("templates")) {
		if (boost::iequals(sensor.first, "property")) {
			LOG(debug) << "Template Sensor \"" << sensor.second.data() << "\"";
			if (!sensor.second.empty()) {
				BACnetSensor bacnetSensor(sensor.second.data());
				if(readSensor(bacnetSensor, sensor.second)) {
					_templateSensors.insert(sensorMap_t::value_type(bacnetSensor.getName(), bacnetSensor));
				} else {
					LOG(warning) << "Template sensor \"" << sensor.second.data() << "\" has bad values! Ignoring...";
				}
			}
		}
	}

	BOOST_FOREACH(boost::property_tree::iptree::value_type &device, cfg.get_child("devices")) {
		if (boost::iequals(device.first, ("device"))) {
			LOG(debug) << "Device " << device.second.data();
			if (!device.second.empty()) {
				BOOST_FOREACH(boost::property_tree::iptree::value_type &d, device.second) {
					if (boost::iequals(d.first, "instance")) {
						deviceInstance = stoul(d.second.data());
					} else if (boost::iequals(d.first, "mqttPart")) {
						mqttPartDevice = d.second.data();
					} else if (boost::iequals(d.first, "object")) {
						LOG(debug) << "Object \"" << d.second.data() << "\"";
						if (!d.second.empty()) {
							BOOST_FOREACH(boost::property_tree::iptree::value_type &object, d.second) {
								if (boost::iequals(object.first, "type")) {
									objType = static_cast<BACNET_OBJECT_TYPE>(stoul(object.second.data()));
								} else if (boost::iequals(object.first, "instance")) {
									objInstance = stoul(object.second.data());
								} else if (boost::iequals(object.first, "mqttPart")) {
									mqttPartObject = object.second.data();
								} else if (boost::iequals(object.first, "property")) {
									LOG(debug) << "Property \"" << object.second.data() << "\"";
									if (!object.second.empty()) {
										BACnetSensor * bacSensor = new BACnetSensor(object.second.data());

										//first check if default sensor is given
										boost::optional<boost::property_tree::iptree&> defaultC = object.second.get_child_optional("default");
										if(defaultC) {
											LOG(debug) << "  Using \"" << defaultC.get().data() << "\" as default.";
											sensorMap_t::iterator it = _templateSensors.find(defaultC.get().data());
											if(it != _templateSensors.end()) {
												*bacSensor = it->second;
												bacSensor->setName(object.second.data());
											} else {
												LOG(warning) << "  Template sensor \"" << defaultC.get().data() << "\" not found! Using standard values.";
											}
										}

										//set object and device related data as well as BACnetClient instance
										//assume property aka sensors are read at last
										bacSensor->setDeviceInstance(deviceInstance);
										bacSensor->setObjectInstance(objInstance);
										bacSensor->setObjectType(objType);
										bacSensor->setMqtt(_mqttPrefix + mqttPartDevice + mqttPartObject);
										bacSensor->setBACnetClient(_bacClient);
										//read remaining values
										if(readSensor(*bacSensor, object.second)) {
											_sensors.push_back(bacSensor);
										} else {
											LOG(warning) << "  Sensor \"" << object.second.data() << "\" has bad values! Ignoring..." << std::endl;
										}
									}
								}
							}
						}
					}
				}
			}
		}
	}
	return true;
}

bool BACnetConfigurator::readSensor(BACnetSensor& sensor, boost::property_tree::iptree& config) {
	BOOST_FOREACH(boost::property_tree::iptree::value_type &val, config) {
		if (boost::iequals(val.first, "interval")) {
			sensor.setInterval(stoull(val.second.data()));
		} else if (boost::iequals(val.first, "mqttsuffix")) {
			//assume prefix mqtt part is already set in this sensor. Just append suffix
			sensor.setMqtt(sensor.getMqtt() + val.second.data());
		} else if (boost::iequals(val.first, "minValues")) {
			sensor.setMinValues(stoull(val.second.data()));
		} else if (boost::iequals(val.first, ("factor"))) {
			sensor.setFactor(std::stod(val.second.data()));
		} else if (boost::iequals(val.first, ("id"))) {
			sensor.setPropertyId(static_cast<BACNET_PROPERTY_ID>(stoul(val.second.data())));
		} else if (boost::iequals(val.first, "default")) {
			//avoid unnecessary "Value not recognized" message
		} else {
			LOG(warning) << "  Value \"" << val.first << "\" not recognized. Omitting...";
		}
	}

	sensor.setCacheInterval(_cacheInterval);

	LOG(debug) << "  MQTTtopic:" << sensor.getMqtt();
	LOG(debug) << "  Interval : " << sensor.getInterval();
	LOG(debug) << "  minValues: " << sensor.getMinValues();
	LOG(debug) << "  factor   : " << sensor.getFactor();
	LOG(debug) << "  instance : " << sensor.getDeviceInstance();
	LOG(debug) << "  objInst  : " << sensor.getObjectInstance();
	LOG(debug) << "  objType  : " << sensor.getObjectType();
	LOG(debug) << "  Property : " << sensor.getPropertyId();

	return true;
}