sfja/h5-projekt-mst
1
0
Fork 0
mirror of https://github.com/Mercantec-GHC/h5-projekt-mst.git synced 2026-08-26 21:27:38 +02:00
Code Issues Packages Projects Releases Wiki Activity

receive skateboard data on backend

Browse Source
This commit is contained in:
sfja 2026-03-28 23:55:42 +01:00
parent 77a21035c3
commit e1f9561937
2 changed files with 18 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/main.cpp
View File

@ -2,6 +2,7 @@
#include "mqtt.hpp"
#include "server.hpp"
#include <chrono>
#include <cstdio>
#include <iostream>
#include <print>
#include <span>
@ -17,15 +18,16 @@ int main(void)
{
auto client = mst::mqtt::Client("localhost", 1883, "test", "1234");
client.subscribe("/", [&](std::string_view text) {
std::cout << std::format("Received '{}'\n", text);
client.subscribe("/skateboard/update", [&](std::string_view text) {
//
std::println("Skateboard: {}", text);
});
auto mqtt_thread = std::thread([&]() {
try {
client.run();
} catch (mst::mqtt::Error& ex) {
std::cerr << std::format("MQTT Client failed: {}", ex.what());
std::println(stderr, "MQTT Client failed: {}", ex.what());
std::abort();
}
});

24
backend/src/mqtt.cpp
View File

@ -6,6 +6,7 @@
#include <iostream>
#include <mosquitto.h>
#include <mutex>
#include <print>
#include <string>
#include <string_view>
#include <thread>
@ -27,8 +28,8 @@ static void lib_init()
int minor;
int revision;
mosquitto_lib_version(&major, &minor, &revision);
std::cout << std::format(
"[MQTT] Initializing mosquitto {}.{}.{}\n", major, minor, revision);
std::println(
"[MQTT] Initializing mosquitto {}.{}.{}", major, minor, revision);
if (mosquitto_lib_init() != MOSQ_ERR_SUCCESS)
throw Error("failed to initialize");
@ -46,7 +47,7 @@ static void lib_deinit()
if (!mosquitto_initialized || use_count < 0)
return;
std::cout << std::format("[MQTT] Deinitializing mosquitto\n");
std::println("[MQTT] Deinitializing mosquitto");
mosquitto_lib_cleanup();
mosquitto_initialized = false;
@ -167,14 +168,15 @@ void Client::subscribe(
{
auto inst = static_cast<struct mosquitto*>(m_inst);
m_subscriptions.emplace_back(topic, std::move(func));
if (auto status = mosquitto_subscribe(inst, NULL, topic.c_str(), 0);
status != MOSQ_ERR_SUCCESS) {
throw Error(std::format(
"could not subscribe ({})", mosquitto_strerror(status)));
}
std::println("[MQTT] Subscribed to '{}'", topic);
m_subscriptions.emplace_back(std::move(topic), std::move(func));
}
void Client::run()
@ -201,22 +203,22 @@ void Client::cb_connect(int rc)
"client could not connect ({})", mosquitto_reason_string(rc)));
}
std::cout << std::format("[MQTT] Client connected\n");
std::println("[MQTT] Client connected");
}
void Client::cb_disconnect()
{
std::cout << std::format("[MQTT] Client disconnected\n");
std::println("[MQTT] Client disconnected");
}
void Client::cb_publish()
{
std::cout << std::format("[MQTT] Message published\n");
std::println("[MQTT] Message published");
}
void Client::cb_message(std::string_view topic, const void* data, size_t size)
{
std::cout << std::format("[MQTT] Message received\n");
std::println("[MQTT] Message received");
auto text = std::string_view(static_cast<const char*>(data), size);
@ -229,12 +231,12 @@ void Client::cb_message(std::string_view topic, const void* data, size_t size)
void Client::cb_subscribe()
{
std::cout << std::format("[MQTT] Client subscribed\n");
std::println("[MQTT] Client subscribed");
}
void Client::cb_unsubscribe()
{
std::cout << std::format("[MQTT] Client unsubscribed\n");
std::println("[MQTT] Client unsubscribed");
}
void Client::publish_raw(