main.cpp

#include <iostream>
#include <cstdio>
#include <getopt.h>
#include <unistd.h>
#include <mosquittopp.h>

#include "serial_observer.h"
#include "serial_device.h"

using namespace std;

int main(int argc, char *argv[])
{
    TMQTTClient::TConfig mqtt_config;
    string templates_folder = "/usr/share/wb-mqtt-serial/templates";
    mqtt_config.Host = "localhost";
    mqtt_config.Port = 1883;
    string config_fname;
    bool debug = false;
    std::string mqtt_prefix = "";
    std::string user = "";
    std::string password = "";

    int c;
    //~ int digit_optind = 0;
    //~ int aopt = 0, bopt = 0;
    //~ char *copt = 0, *dopt = 0;
    while ( (c = getopt(argc, argv, "dsc:h:H:p:u:P:T:")) != -1) {
        //~ int this_option_optind = optind ? optind : 1;
        switch (c) {
        case 'd':
            debug = true;
            break;
        case 'c':
            config_fname = optarg;
            break;
        case 'p':
            mqtt_config.Port = stoi(optarg);
            break;
        case 'h':
        case 'H':
            mqtt_config.Host = optarg;
            break;

        case 'T':
           mqtt_prefix = optarg;
           break;

        case 'u':
            user = optarg;
           break;

        case 'P':
            password = optarg;
            break;

        case '?':
        default:
            printf ("?? getopt returned character code 0%o ??\n", c);

            printf("Usage:\n wb-mqtt-serial [options]\n");
            printf("Options:\n");
            printf("\t-d          \t\t\t enable debuging output\n");
            printf("\t-c config   \t\t\t config file\n");
            printf("\t-p PORT     \t\t\t set to what port wb-mqtt-serial should connect (default: 1883)\n");
            printf("\t-H IP       \t\t\t set to what IP wb-mqtt-serial should connect (default: localhost)\n");
            printf("\t-u USER     \t\t\t MQTT user (optional)\n");
            printf("\t-P PASSWORD \t\t\t MQTT user password (optional)\n");
            printf("\t-T prefix   \t\t\t MQTT topic prefix (optional)\n");

        }
    }

    PHandlerConfig handler_config;
    try {
        TConfigTemplateParser device_parser(templates_folder, debug);
        TConfigParser parser(config_fname, debug, TSerialDeviceFactory::GetRegisterTypes,
                             device_parser.Parse());
        handler_config = parser.Parse();
    } catch (const TConfigParserException& e) {
        cerr << "FATAL: " << e.what() << endl;
        return 1;
    }

	mosqpp::lib_init();

    if (mqtt_config.Id.empty())
        mqtt_config.Id = "wb-modbus";

    PMQTTClient mqtt_client(new TMQTTPrefixedClient(std::move(mqtt_prefix), mqtt_config));
    mqtt_client->Authenticate(user, password);

    try {
        PMQTTSerialObserver observer(new TMQTTSerialObserver(mqtt_client, handler_config));
        observer->SetUp();
        if (observer->WriteInitValues() && handler_config->Debug)
            cerr << "Register-based setup performed." << endl;
        mqtt_client->StartLoop();
        observer->Loop();
    } catch (const TSerialDeviceException& e) {
        cerr << "FATAL: " << e.what() << endl;
        return 1;
    }

    for (;;) sleep(1);

#if 0
    // FIXME: handle Ctrl-C etc.
    mqtt_handler->StopLoop();
	mosqpp::lib_cleanup();
#endif

	return 0;
}
//build-dep libmosquittopp-dev libmosquitto-dev
// dep: libjsoncpp0 libmosquittopp libmosquitto

// TBD: fix race condition that occurs after modbus error on startup
// (slave not active)
// TBD: check json structure
// TBD: proper error checking everywhere (catch exceptions, etc.)
// TBD: automatic tests(?)