/* MicroFlo - Flow-Based Programming for microcontrollers
 * Copyright (c) 2013 Jon Nordby <jononor@gmail.com>
 * MicroFlo may be freely distributed under the MIT license
 */

#include "microflo.h"
#include "linux_mqtt.hpp"

#include "microflo.hpp"
#include "linux.hpp"

/* Fail with an error message. */
static void die(const char *msg) {
    fprintf(stderr, "%s", msg);
    exit(1);
}

// TODO: introspect from Network/cmdstream instead of graph metadata
bool findPorts(ParticipantInfo *info) {
    // FIXME: don't assume graph data is in 'graph_*'

    // Exported ports
    for (size_t i=0; i<graph_inports_length; i++) {
        const char *name = graph_inports_name[i];
        MicroFlo::PortId portId = graph_inports_port[i];
        MicroFlo::NodeId nodeId = graph_inports_node[i];
        info->addInport(name, nodeId, portId);
    }
    for (size_t i=0; i<graph_outports_length; i++) {
        const char *name = graph_outports_name[i];
        MicroFlo::PortId portId = graph_outports_port[i];
        MicroFlo::NodeId nodeId = graph_outports_node[i];
        info->addOutport(name, nodeId, portId);
    }

    // Graph name
    // TODO: replace with command stream command for graph name
    info->component = graph_name;

    return true;
}

int main(int argc, char **argv) {
    LinuxIO io;
    LinuxMqttHostTransport transport;
    FixedMessageQueue queue;
    Network network(&io, &queue);
    MqttOptions options;
    

    const bool parsed = mqttParseOptions(&options, argc, argv);
    if (!parsed) {
        die("options parsing error\n");
    }

    findPorts(&options.info);

    MqttMount mount(&network, options);

    transport.setup(&io, &mount);
    mount.setup(&network, &transport);

    MICROFLO_LOAD_STATIC_GRAPH((&mount), graph);

    const bool connected = mount.connect();
    if (connected) {
        printf("Connected to %s:%d\n", options.brokerHostname, options.brokerPort);
        fflush(stdout);
    } else {
        die("connect() failure\n");
    }

    const bool success = MqttMount::runForever(&mount);
    return (success) ? 0 : 1;
}