/**
 * @brief 分布式消息框架拓扑
 * @param platform消息平台，消息总线挂载在消息平台上
 * @param bus消息总线,消息总线每个主题对应一条消息总线
 * @param node角色节点，订阅主题，挂载到消息总线上
 * @param msg消息体，携带topic信息和数据载荷
 * @param handler消息处理函数，收到到msg时执行
 * platform
 *     |--bus1(topic.001)
 *         |--node1
 *              |--[msg1, msg2, msg3,...]
 *              |--{topic.001, handler1}
 *              |--{topic.002, handler2}
 *         |--node2
 *              |--[msg1, msg2, msg3,...]
 *              |--{topic.001, handler1}
 *              |--{topic.003, handler3}
 *     |--bus2(topic.002)
 *         |--node1
 *              |--[]
 *              |--{topic.001, handler1}
 *              |--{topic.003, handler3}
 *     |--bus3(topic.003)
 *         |--node2
 *              |--[msgA, msgB, msgC, ...]
 *              |--{topic.001, handler1}
 *              |--{topic.003, handler3}
 */

#include <unistd.h>
#include <string.h>
#include <stdio.h>
#include <math.h>
#include <thread>
#include <sstream>
#include <iostream>
#include "ldds.h"

/**
 * @brief 消息模型
 * 模块a[订阅、发布]
 * 模块b[订阅、发布]
 * 模块c[订阅、发布]
 * ...
 * 模块x[订阅、发布]
 */

// 模块：监听消息到来，并处理消息
std::thread node_listener(ldds_node_t node) {
    while (true) {
        int msg_count = ldds_dispatch(node);

        if (msg_count > 0) {
            printf("msg_count=%d\n", msg_count);
        }

        usleep(1000);
    }
}

void on_adc1_change(ldds_msg_t msg) {
    // 处理ADC1数据变化事件
}

void on_adc2_change(ldds_msg_t msg) {
    // 处理ADC2数据变化事件
}

// 订阅ADC1_change主题
void sub_adc1(void) {
    ldds_node_t node = ldds_new();
    ldds_sub(ADC1_node, "ADC1_change", on_adc1_change);

    std::thread(node_listener, std::ref(ADC1_node)).detach();
}

// 订阅ADC2_change主题
void sub_adc2(void) {
    ldds_node_t node = ldds_new();
    ldds_sub(ADC2_node, "ADC2_change", on_adc2_change);

    std::thread(node_listener, std::ref(ADC2_node)).detach();
}

// 模拟adc1驱动，读取数据
void adc1_reader(void) {
    static int adc_value = 0;
    
    int tmp = random() % 4096;
    if (tmp != adc_value) {
        adc_value = tmp;
        ldds_pub("ADC1_change", &adc_value, strlen(adc_value));
    }
}

// 模拟adc2驱动，读取数据
void adc2_reader(void) {
    static int adc_value = 0;
    
    int tmp = random() % 4096;
    if (tmp != adc_value) {
        adc_value = tmp;
        ldds_pub("ADC2_change", &adc_value, strlen(adc_value));
    }
}

int main(void) {
    sub_adc1();
    sub_adc2();

    while (1) {
        adc1_reader();
        adc2_reader();
        ldds_task_delay(1000 * 1000);
    }

    return 0;
}