jeka/utun2
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Files
2a439754bacb4b061fad5360923ce9264bfb4020
utun2/tools/chatgui/tests/test_radio_mute_bridge.cpp
T

221 lines
13 KiB
C++
Raw Blame History

/* Настоящие worker, Qt bridge и модель: речь, обновление списка, локальный mute и три формы динамика. */
#include "../transport/utun_node.h"
#include "../transport/gui_bridge.h"
#include "../src/accountdelegate.h"
#include "../src/memberlistmodel.h"
#include <QtTest>
#include <QFile>
#include <QTemporaryDir>
#include <QListView>
extern "C" {
#include "utun_instance.h"
#include "chat/chat_core.h"
#include "chat/chat_member.h"
#include "routing_layer/topo_group.h"
#include "routing_layer/topo_node_sqlite.h"
#include "u_async.h"
#include "debug_config.h"
}
struct Probe {
QObject* receiver = nullptr;
MemberListModel* model = nullptr;
QString channel;
bool ready = false, setup_ok = false, polling_running = false;
int updates = 0;
QList<bool> results;
};
static Probe* current;
static void prepare_channel(void* arg) {
auto* probe = static_cast<Probe*>(arg);
debug_set_category_level(DEBUG_CATEGORY_RADIO, DEBUG_LEVEL_DEBUG); debug_enable_console(1);
UTUN_INSTANCE* inst = gui_bridge_get_inst();
chat_core_create_channel_auto(inst, "radio mute bridge");
TOPO_GROUP* channel = nullptr;
for (ll_entry* e = inst->topo_groups->group_list->head; e; e = e->next) {
auto* group = reinterpret_cast<TOPO_GROUP*>(e);
if (group->group_type == TOPO_GROUP_TYPE_CHAT) channel = group;
}
const uint8_t key[32] = {1};
const bool ok = channel && topo_node_sqlite_member_placeholder_put(inst->topo_sqlite_db, channel->channel_id, 42, key, key) == 0 &&
topo_node_sqlite_member_placeholder_put(inst->topo_sqlite_db, channel->channel_id, 43, key, key) == 0;
const QString id = channel ? QString::fromUtf8(channel->channel_id) : QString();
const int running = uasync_is_running(inst->ua);
DEBUG_INFO(DEBUG_CATEGORY_RADIO, "radio: desktop bridge probe setup=%d poll_running=%d inst=%p ua=%p ch=%s",
ok, running, (void*)inst, (void*)inst->ua, qPrintable(id));
QMetaObject::invokeMethod(probe->receiver, [probe, ok, running, id] {
probe->setup_ok = ok; probe->polling_running = running; probe->channel = id; probe->ready = true;
}, Qt::QueuedConnection);
}
static void member_updated(const uint8_t* data, int len) {
if (!current || !data || len < 2 || len != data[0] + 2 + CHAT_MEMBER_DISPLAY_SIZE) return;
chat_member_display member{};
if (chat_core_deserialize_member(data + data[0] + 2, &member) < 0) return;
if (member.node_id == 42) ++current->updates;
const QString channel = QString::fromUtf8((const char*)data + 1, data[0]);
current->model->onMemberUpdated(channel, data + data[0] + 2);
}
static void member_list(const uint8_t* data, int len) {
if (!current || !data || len < 3 || len < data[0] + 3) return;
uint16_t count; memcpy(&count, data + data[0] + 1, 2);
current->model->onMemberList(QString::fromUtf8((const char*)data + 1, data[0]), count, data + data[0] + 3, len - data[0] - 3);
}
/* Реальный queued bridge, без сетевых пакетов: проверяем доставку START/STOP в GUI. */
static void post_talk(uint64_t group, uint64_t source, bool on) {
uint8_t data[19] = {0};
memcpy(data, &group, 8); memcpy(data + 8, &source, 8); data[18] = on;
DEBUG_INFO(DEBUG_CATEGORY_RADIO, "radio members test: post group=%016llx node=%016llx on=%d",
(unsigned long long)group, (unsigned long long)source, on);
gui_bridge_post(GUI_EVT_RADIO_TALK, data, sizeof(data));
}
static void mute_result(const uint8_t* data, int len) {
if (current && len == 17) current->results.append(data[16] != 0);
}
class RadioMuteBridgeTest : public QObject {
Q_OBJECT
private slots:
void cleanup() {
gui_bridge_set_member_updated_cb(nullptr); gui_bridge_set_radio_mute_result_cb(nullptr);
gui_bridge_set_member_list_cb(nullptr); gui_bridge_set_radio_talk_cb(nullptr);
gui_bridge_set_inst(nullptr); gui_bridge_set_uasync(nullptr); current = nullptr;
debug_disable_file_output();
}
void desktopWorkerAcceptsIconToggleAndReturnsConfirmedState() {
QTemporaryDir directory; QVERIFY(directory.isValid());
const QString path = directory.filePath("node.cfg");
QFile config(path); QVERIFY(config.open(QIODevice::WriteOnly));
const QByteArray text = "[global]\nmy_private_key=704f2e012c8fa8768130cb0f988a997dccb628372bc5ceccacc78dcbfec5916f\n"
"my_public_key=b3193173def895bd0fcea6f86af077c7d77216f10395275f627ac18242ec0f01\n"
"[chatserver]\ngroup_autoconnect=0\nstorage_autoload=0\n[ntp]\nenabled=no\n";
QCOMPARE(config.write(text), text.size()); config.close();
gui_bridge_init();
MemberListModel model;
Probe probe; probe.receiver = this; probe.model = &model; current = &probe;
gui_bridge_set_member_updated_cb(member_updated); gui_bridge_set_radio_mute_result_cb(mute_result);
gui_bridge_set_member_list_cb(member_list);
gui_bridge_set_radio_talk_cb([](uint64_t group, uint64_t source, uint8_t on) {
if (current) current->model->onRadioTalk(group, source, on != 0);
});
UtunNode node; node.setDbPath(directory.filePath("db"));
node.setDebugFile(qEnvironmentVariable("UTUN_TEST_DIAGNOSTIC_LOG", directory.filePath("diagnostic.log")));
node.setDebugLevel("warn"); node.setDebugCategories("radio=debug,general=debug");
QVERIFY(node.start(path)); QTRY_VERIFY_WITH_TIMEOUT(gui_bridge_is_uasync_ready(), 3000);
gui_bridge_post_uasync_fn(prepare_channel, &probe);
QTRY_VERIFY_WITH_TIMEOUT(probe.ready, 3000); QVERIFY(probe.setup_ok);
const quint64 group = probe.channel.toULongLong();
model.setChannel(probe.channel, false);
model.setRadioState(group, true, false);
model.onRadioTalk(group, 43, true); // START до загрузки строки не должен потеряться.
QTRY_COMPARE_WITH_TIMEOUT(model.rowCount(), 3, 3000);
auto memberIndex = [&](quint64 id) {
for (int row = 0; row < model.rowCount(); ++row) if (model.nodeIdAt(row) == id) return model.index(row, 0);
return QModelIndex();
};
const QModelIndex source = memberIndex(42), other = memberIndex(43);
QVERIFY(source.isValid() && other.isValid());
QVERIFY(other.data(MemberListModel::RadioSpeakingRole).toBool());
QListView view; AccountDelegate delegate;
view.setModel(&model); view.setItemDelegate(&delegate); view.resize(340, 160); view.show(); QTest::qWait(30);
int accepted = -2;
connect(&delegate, &AccountDelegate::radioMuteRequested, &view, [&](const QModelIndex&) {
accepted = gui_bridge_toggle_member_radio_mute(probe.channel.toUtf8().constData(), 42);
});
const QRect row = view.visualRect(source); const QPoint button(row.right() - 50, row.center().y());
auto iconImage = [&] {
return view.viewport()->grab().toImage().copy(QRect(row.right() - 63, row.center().y() - 14, 28, 28));
};
auto iconHasColor = [&](const QColor& color) {
const QImage image = view.viewport()->grab().toImage();
for (int y = row.top(); y <= row.bottom(); ++y)
for (int x = row.right() - 63; x < row.right() - 35; ++x) if (image.pixelColor(x, y) == color) return true;
return false;
};
QVERIFY(iconHasColor(QColor("#9E9E9E"))); QVERIFY(!iconHasColor(QColor("#4CAF50")));
const QImage silent = iconImage();
QSignalSpy changed(&model, &QAbstractItemModel::dataChanged);
post_talk(group, 42, true);
QTRY_VERIFY(source.data(MemberListModel::RadioSpeakingRole).toBool());
QVERIFY(iconHasColor(QColor("#4CAF50"))); QVERIFY(iconImage() != silent);
QVERIFY(!changed.isEmpty()); QCOMPARE(qvariant_cast<QModelIndex>(changed.last()[0]), source);
QVERIFY(other.data(MemberListModel::RadioSpeakingRole).toBool());
QTest::mouseClick(view.viewport(), Qt::LeftButton, Qt::NoModifier, button);
QCOMPARE(accepted, 0); QVERIFY(probe.polling_running);
QTRY_COMPARE_WITH_TIMEOUT(probe.results.size(), 1, 3000); QVERIFY(probe.results[0]);
QCOMPARE(probe.updates, 1); QVERIFY(source.data(Qt::UserRole + 3).toInt() & CHAT_MEMBER_FLAG_RADIO_MUTED);
QVERIFY(iconHasColor(QColor("#EF5350"))); QVERIFY(!iconHasColor(QColor("#4CAF50")));
const QImage mutedSpeaking = iconImage();
auto redPixel = [](const QImage& image, int x, int y) {
const QColor color = image.pixelColor(x, y);
return color.red() > color.green() + 50;
};
QVERIFY(redPixel(mutedSpeaking, 21, 5)); // Красное перечёркивание правее корпуса динамика.
QVERIFY(redPixel(mutedSpeaking, 23, 13)); // Волна видна и при локальном mute.
post_talk(group, 42, false);
QTRY_VERIFY(!source.data(MemberListModel::RadioSpeakingRole).toBool());
const QImage mutedSilent = iconImage();
QVERIFY(mutedSilent != mutedSpeaking);
QVERIFY(redPixel(mutedSilent, 21, 5)); QVERIFY(!redPixel(mutedSilent, 23, 13));
QVERIFY(other.data(MemberListModel::RadioSpeakingRole).toBool());
QTest::mouseClick(view.viewport(), Qt::LeftButton, Qt::NoModifier, button);
QCOMPARE(accepted, 0); QTRY_COMPARE_WITH_TIMEOUT(probe.results.size(), 2, 3000); QVERIFY(probe.results[1]);
QCOMPARE(probe.updates, 2); QVERIFY(!(source.data(Qt::UserRole + 3).toInt() & CHAT_MEMBER_FLAG_RADIO_MUTED));
QVERIFY(iconHasColor(QColor("#9E9E9E"))); QVERIFY(!iconHasColor(QColor("#EF5350")));
post_talk(group, 42, true);
QTRY_VERIFY(source.data(MemberListModel::RadioSpeakingRole).toBool());
const int beforeDuplicate = changed.size();
post_talk(group, 42, true); QTest::qWait(20); QCOMPARE(changed.size(), beforeDuplicate);
model.refresh();
QTRY_COMPARE_WITH_TIMEOUT(model.rowCount(), 3, 3000);
QVERIFY(memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
QVERIFY(memberIndex(43).data(MemberListModel::RadioSpeakingRole).toBool());
model.refreshRtt(); QTest::qWait(50);
QVERIFY(memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
post_talk(group + 1, 42, false); QTest::qWait(20);
QVERIFY(memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
QModelIndex self;
for (int i = 0; i < model.rowCount(); ++i) if (model.index(i, 0).data(Qt::UserRole + 2).toBool()) self = model.index(i, 0);
QVERIFY(self.isValid());
model.setRadioState(group, true, true); QVERIFY(self.data(MemberListModel::RadioSpeakingRole).toBool());
const QRect selfRow = view.visualRect(self);
QTest::mouseClick(view.viewport(), Qt::LeftButton, Qt::NoModifier, QPoint(selfRow.right() - 50, selfRow.center().y()));
QCOMPARE(probe.results.size(), 2); // Собственный динамик не переключает mute.
model.setRadioState(group, true, false); QVERIFY(!self.data(MemberListModel::RadioSpeakingRole).toBool());
// Удаление первой строки сдвигает индексы; STOP следующего источника должен попасть в его новую строку.
const quint64 removed = model.nodeIdAt(0);
model.onMemberRemoved(probe.channel, removed); QCOMPARE(model.rowCount(), 2);
QVERIFY(model.nodeIdAt(0) && model.nodeIdAt(1));
const quint64 remaining = model.nodeIdAt(1);
post_talk(group, remaining, true); QTest::qWait(20);
post_talk(group, remaining, false); QTest::qWait(20);
QVERIFY(!memberIndex(remaining).data(MemberListModel::RadioSpeakingRole).toBool());
model.refresh(); QTRY_COMPARE_WITH_TIMEOUT(model.rowCount(), 3, 3000);
post_talk(group, 42, true); QTRY_VERIFY(memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
model.setRadioState(0, false, false);
QVERIFY(!memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
post_talk(group, 42, true); QTest::qWait(20);
QVERIFY(!memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
model.setRadioState(group, true, false); post_talk(group, 42, true);
QTRY_VERIFY(memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
model.setChannel(QString(), false); QCOMPARE(model.rowCount(), 0);
model.setChannel(probe.channel, false); QTRY_COMPARE_WITH_TIMEOUT(model.rowCount(), 3, 3000);
QVERIFY(!memberIndex(42).data(MemberListModel::RadioSpeakingRole).toBool());
DEBUG_INFO(DEBUG_CATEGORY_RADIO, "radio members test: shapes, speech while muted, multiple speakers, refresh, self and reset PASS");
node.stop(); QVERIFY(!gui_bridge_is_uasync_ready());
QCOMPARE(gui_bridge_toggle_member_radio_mute(probe.channel.toUtf8().constData(), 42), -1);
gui_bridge_set_member_updated_cb(nullptr); gui_bridge_set_radio_mute_result_cb(nullptr); current = nullptr;
debug_disable_file_output();
}
};
QTEST_MAIN(RadioMuteBridgeTest)
#include "test_radio_mute_bridge.moc"
Reference in new issue View Git Blame Copy Permalink