iot/sprocket-device-illucat
1
0
Fork 0
mirror of https://gitlab.com/zwirbel/illucat.git synced 2025-12-16 10:04:30 +01:00
Code Issues Packages Projects Releases Wiki Activity

chat backend

Browse Source
This commit is contained in:
0x1d
2018-11-19 22:58:44 +01:00
parent f754e7640f
commit 6f1afc1bc1
1 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/var/illuchat/main.cpp
View File

@@ -44,16 +44,23 @@ void setup()
webServerPlugin->server->serveStatic(PIXEL_CONFIG_FILE, SPIFFS, "pixelConfig.json"); webServerPlugin->server->serveStatic(PIXEL_CONFIG_FILE, SPIFFS, "pixelConfig.json");
webServerPlugin->server->serveStatic(MQTT_CONFIG_FILE, SPIFFS, "mqttConfig.json"); webServerPlugin->server->serveStatic(MQTT_CONFIG_FILE, SPIFFS, "mqttConfig.json");
const char* mqttChatTopic = (String(MQTT_ROOT_TOPIC) + "/out/chat/log").c_str(); const char* mqChatTopic = "wirelos/chat/log";
sprocket->subscribe("chat/log", [mqttChatTopic](String msg) { const char* outChatTopic = "out/chat/log";
PRINT_MSG(Serial, "CHAT", msg.c_str()); const char* chatUser = "user";
});
sprocket->subscribe("mqtt/connect", [mqttChatTopic](String msg) { sprocket->subscribe("mqtt/connect", [mqChatTopic, outChatTopic, chatUser](String msg) {
if (msg.length() > 0) if (msg.length() > 0)
{ {
mqttPlugin->client->subscribe(mqttChatTopic); mqttPlugin->client->subscribe(mqChatTopic);
sprocket->subscribe("/out/chat/log", [](String msg) { sprocket->subscribe(mqChatTopic, [](String msg) {
PRINT_MSG(Serial, "CHAT", String("incoming: " + msg).c_str()); PRINT_MSG(Serial, "CHAT", String("incoming: " + msg).c_str());
webApiPlugin->ws->textAll(msg);
});
// send message from WS to this topic
sprocket->subscribe(outChatTopic, [mqChatTopic, chatUser](String msg) {
PRINT_MSG(Serial, "CHAT", msg.c_str());
mqttPlugin->client->publish(mqChatTopic, (String(chatUser) + ": " + msg).c_str());
}); });
} }
}); });