Neuer Trigger: Ankunft einer MQTT-Nachricht

lmilcent · 29. April 2023 um 09:27

Funktionsbeschreibung
Nach unserer Diskussion hier

Eine Szene sollte ausgelöst werden können, wenn eine MQTT-Nachricht auf einem bestimmten Topic eintrifft.

guim31 · 29. April 2023 um 20:20

Und das wäre in anderen Fällen auch nützlich, denke ich!

Ich muss hier eine Abstimmung freigeben

Lokkye · 13. Oktober 2023 um 08:36

Ich habe einen kleinen Vorschlag für diesen PR gemacht:

github.com/GladysAssistant/Gladys

Run scene when receive message on MQTT (#1911)

master ← callemand:execute_scene_from_mqtt

ouvert 08:33AM - 13 Oct 23 UTC

callemand

+14 -1

### Pull Request check-list To ensure your Pull Request can be accepted as fa…st as possible, make sure to review and check all of these items: - [x] If your changes affects code, did your write the tests? - [x] Are tests passing? (`npm test` on both front/server) - [x] Is the linter passing? (`npm run eslint` on both front/server) - [x] Did you run prettier? (`npm run prettier` on both front/server) - [x] Did you test this pull request in real life? With real devices? If this development is a big feature or a new service, we recommend that you provide a Docker image to the community ([french forum](https://community.gladysassistant.com/)/[english forum](https://en-community.gladysassistant.com/)) for testing before merging. ### Description of change Launch scene when receive MQTT message on channel "gladys/scene/[sceneSelector]" The message must contain "START'

Ich habe keinen neuen Auslöser hinzugefügt. Ich habe nur hinzugefügt, dass man jede Szene über eine MQTT-Nachricht starten kann.

Dazu muss man eine Nachricht « START » im Kanal « gladys/scene/[sceneSelector] » veröffentlichen.

Was haltet ihr davon?

cce66 · 13. Oktober 2023 um 08:55

@Lokkye einfach nur ein Wort: Genial!

Dafür muss eine Nachricht « START » im Channel « gladys/scene/[sceneSelector] » veröffentlicht werden.

Das müsste man erklären, denn so sehe ich nicht das « Wie »?

Ansonsten ist es super, Szenen von außen über MQTT oder Node-Red zu öffnen!
Gratulation an die Entwickler!!!

pierre-gilles · 13. Oktober 2023 um 17:05

Super cool @Lokkye!

Für das Format des Topics sollten wir das aktuelle Format der anderen MQTT-Topics beibehalten, insbesondere das Präfix « master », das anzeigt, dass wir uns an die « Master »-Instanz wenden. Das ist in Gladys noch nicht der Fall, aber die Idee hinter diesem « Master » war, in Zukunft abgekoppelte « Pod »-Instanzen zu haben, die entfernte Dienste ausführen können.

Ich würde mir also etwas wie Folgendes vorstellen:

gladys/master/scene/[sceneSelector]/start

Kein spezifischer Body.

Was hältst du davon?

PS: Ich habe auch eine kleine technische Überprüfung durchgeführt: Run scene when receive message on MQTT by callemand · Pull Request #1911 · GladysAssistant/Gladys · GitHub

Lokkye · 16. Oktober 2023 um 07:26

@pierre-gilles: Ich kannte das Thema ‹ gladys/master/… › nicht.
Ich habe meinen Code entsprechend geändert. Es ist viel einfacher

Danke für das technische Review

pierre-gilles · 16. Oktober 2023 um 07:49

Tatsächlich ist es viel einfacher Super PR, ich habe es getestet und es funktioniert bei mir!

Es ist gemerged und wird in der nächsten Version von Gladys verfügbar sein.

Allerdings bin ich mir nicht sicher, ob wir diese Funktionsanfrage schließen, da es nicht genau das geforderte Feature ist (hier ging es um benutzerdefinierte Topics).

Lokkye · 16. Oktober 2023 um 08:03

Danke @pierre-gilles für das Mergen

Ich werde schauen, ob ich auch den neuen Auslöser in einer Szene in einem anderen PR hinzufüge.

Lokkye · 24. Oktober 2023 um 08:08

@pierre-gilles:
Hier ist der PR, der die Funktion umsetzt:

github.com/GladysAssistant/Gladys

Add scene trigger : MQTT message (#1913)

master ← callemand:trigger_mqtt_message

ouvert 07:08AM - 17 Oct 23 UTC

callemand

+329 -11

### Pull Request check-list To ensure your Pull Request can be accepted as fa…st as possible, make sure to review and check all of these items: - [x] If your changes affects code, did your write the tests? - [x] Are tests passing? (`npm test` on both front/server) - [x] Is the linter passing? (`npm run eslint` on both front/server) - [x] Did you run prettier? (`npm run prettier` on both front/server) - [x] If you are adding a new features/services, did you run integration comparator? (`npm run compare-translations` on front) - [x] Did you test this pull request in real life? With real devices? If this development is a big feature or a new service, we recommend that you provide a Docker image to the community ([french forum](https://community.gladysassistant.com/)/[english forum](https://en-community.gladysassistant.com/)) for testing before merging. ### Description of change Add new scene trigger: received message from message queue <img width="566" alt="Screenshot 2023-10-24 at 10 05 09" src="https://github.com/GladysAssistant/Gladys/assets/11317212/fb4652f9-439e-44e1-ac07-17ecd834ba10"> <img width="574" alt="Screenshot 2023-10-24 at 10 05 02" src="https://github.com/GladysAssistant/Gladys/assets/11317212/839039b1-1b13-411b-b4b3-3ba506868b57">

Sag mir, was du davon hältst

pierre-gilles · 26. Oktober 2023 um 08:38

@Lokkye Ich habe dir eine Review gemacht! Add scene trigger : MQTT message by callemand · Pull Request #1913 · GladysAssistant/Gladys · GitHub

Ich würde die Logik hinter dieser Entwicklung ein bisschen besser verstehen, um die Implementierungsentscheidungen zu verstehen Wenn du lieber hier auf Französisch statt auf Github auf Englisch erklären möchtest, wie du möchtest!

Lokkye · 27. Oktober 2023 um 09:04

@pierre-gilles: Danke für das Gegenlesen.

Dass ich das Wort „mqtt“ nicht verwende, liegt daran, dass ich mich komplett vom Service abkoppeln wollte. Ich mache viel Clean Architecture in meinem Job und trenne daher gerne die Konzepte. Ich wollte auch vermeiden, technische Begriffe in Gladys einzuführen. Aber es stimmt, dass ich dadurch nicht unbedingt klarer werde.
Werden wir in naher oder ferner Zukunft noch andere Message Queues einführen?

pierre-gilles · 27. Oktober 2023 um 11:59

Ich verstehe den Gedanken, aber manchmal verwirrt aus Nutzersicht das « ultra-generische » nur die Nutzung, und es ist besser, « ultra-spezifisch » zu sein, was es ermöglicht, den richtigen Vokabular zu verwenden.

UX-Ebene

In diesem Fall wird der Nutzer, der ein externes MQTT-Skript verbinden möchte, sicherlich nach dem Wort « MQTT » als Auslöser suchen. Es ist zwar technisch, aber wer das möchte, ist technisch versiert.

Wenn MQTT nirgends erwähnt wird, ist es unmöglich zu wissen, was das bedeutet

Selbst wenn wir in Zukunft andere Technologien für Warteschlangen haben, können wir andere spezifische Auslöser für diese Technologien erstellen.

Wenn wir uns das Beispiel von Zapier (https://zapier.com/) ansehen, wenn du einen Trigger auswählst, bieten sie dir direkt alle möglichen Technologien an, damit es klar ist:

Ich denke, wir können MQTT in diesem Fall erwähnen und überall im Code über MQTT sprechen, ohne Probleme

Implementierungsebene

Ich bin mir nicht sicher, ob die Implementierung für diesen speziellen Fall sinnvoll ist, insbesondere die Verwendung von EventEmittern zum Abbrechen von Triggern und zum Setzen von Triggern, da wir keine Garantie für die Ausführung des Codes vor dem Weitergehen haben.

In der aktuellen Implementierung gibt es nichts, was besagt, dass der Listener:

this.gladys.event.on(EVENTS.MESSAGE_QUEUE.UNSUBSCRIBE, this.handleGladysEventUnsubscribe.bind(this));

wird sicher vor ausgeführt:

this.gladys.event.on(EVENTS.MESSAGE_QUEUE.SUBSCRIBE, this.handleGladysEventSubscribe.bind(this));

Daher könnte es sein, dass, wenn ich meine Szene bearbeite, mein Listener ein zweites Mal hinzugefügt und dann entfernt wird, und wir uns in einem « schmutzigen » Zustand befinden

Ich glaube nicht, dass wir eine Wahl haben, ich denke, wir müssen this.service.mqtt in der Szene aufrufen. Übrigens, wenn wir normalerweise von Gladys zu den Diensten gehen, machen wir das im Rest des Codes (zum Beispiel in der Telegram-Integration machen wir das)

Was denkst du?

Lokkye · 27. Oktober 2023 um 14:03

Ok, ich verstehe besser.

pierre-gilles:

UX-Ebene

In diesem Fall wird der Benutzer, der ein externes MQTT-Skript verbinden möchte, sicherlich nach dem Wort „MQTT“ als Auslöser suchen. Es ist zwar technisch, aber wer das möchte, ist technisch versiert.

Wenn MQTT nirgends erwähnt wird, ist es unmöglich zu wissen, was das bedeutet

Selbst wenn wir in Zukunft andere Warteschlangentechnologien haben, können wir andere spezifische Auslöser für diese Technologien erstellen.

Wenn man sich das Beispiel von Zapier (https://zapier.com/) ansieht, werden einem beim Auswählen eines Triggers alle möglichen Technologien direkt vorgeschlagen, damit es klar ist:

Screenshot 2023-10-27 at 13.45.471862×1252 283 KB

Ich denke, wir können MQTT in diesem Fall erwähnen und überall im Code über MQTT sprechen, ohne Probleme

Ja, nach reiflicher Überlegung hast du völlig recht

pierre-gilles:

Implementierungsebene

Ich bin mir nicht sicher, ob die Implementierung für diesen speziellen Fall sinnvoll ist, insbesondere die Verwendung von EventEmittern zum Abbrechen und Setzen von Triggern, da keine Garantie für die Ausführung des Codes vor dem Fortfahren besteht.

In der aktuellen Implementierung gibt es nichts, was besagt, dass der Listener:
this.gladys.event.on(EVENTS.MESSAGE_QUEUE.UNSUBSCRIBE, this.handleGladysEventUnsubscribe.bind(this));
wird tatsächlich ausgeführt, bevor:
this.gladys.event.on(EVENTS.MESSAGE_QUEUE.SUBSCRIBE, this.handleGladysEventSubscribe.bind(this));
Daher könnte es sein, dass, wenn ich meine Szene bearbeite, mein Listener ein zweites Mal hinzugefügt und dann entfernt wird, und wir uns in einem „schmutzigen“ Zustand befinden.

Ich glaube nicht, dass wir eine Wahl haben, ich denke, wir müssen this.service.mqtt in der Szene aufrufen. Übrigens, wenn wir normalerweise von Gladys zu den Diensten gehen, machen wir das im Rest des Codes (zum Beispiel in der Telegram-Integration machen wir das)

Ich dachte nicht, dass der „Kern“ direkt mit den Diensten verbunden werden könnte. Daher müssen wir auch berücksichtigen, dass der Dienst nicht aktiviert ist

Ich kümmere mich darum, das zu erledigen

pierre-gilles · 27. Oktober 2023 um 15:29

Wenn wir das zum Beispiel in der Telegram-Integration machen

github.com/GladysAssistant/Gladys

server/lib/message/message.sendToUser.js

master


      
            // fail without saying which selector was wrong
            logger.warn(`Unable to send message: user "${userSelector}" not found.`);
            throw new NotFoundError(`User ${userSelector} not found`);
          }
          // first, we insert the message in database
          const messageToInsert = {
            text,
            file,
            sender_id: null, // message sent by gladys
            receiver_id: user.id,
            message_type: messageType,
          };
          const messageCreated = (await db.Message.create(messageToInsert)).get({ plain: true });
          // send the message through websocket
          this.event.emit(EVENTS.WEBSOCKET.SEND, {
            type: WEBSOCKET_MESSAGE_TYPES.MESSAGE.NEW,
            userId: user.id,
            payload: messageCreated,
          });
          // "Gladys conversation only": the message is in database and on the
          // websocket, which is all the user asked for. Stop here, before any

Ja, und ich würde sogar sagen, dass es idealerweise in der UI des Triggers auch angezeigt werden sollte, falls der MQTT-Dienst nicht konfiguriert ist.

Lokkye · 5. November 2023 um 11:57

@pierre-gilles : Normalerweise habe ich die Änderungen basierend auf deinem Feedback vorgenommen.

pierre-gilles · 6. November 2023 um 08:34

Super! Ich schaue mir das heute an

pierre-gilles · 6. November 2023 um 09:47

Super cool @Lokkye, läuft perfekt bei mir so

Ich habe dir ein paar Rückmeldungen gegeben, aber nichts Schlimmes

https://github.com/GladysAssistant/Gladys/pull/1913#pullrequestreview-1714640371

Lokkye · 7. November 2023 um 07:23

@pierre-gilles: Ich habe gerade die Änderungen basierend auf deinem Feedback vorgenommen.
Lass es mich wissen, falls ich etwas übersehen habe.

pierre-gilles · 10. November 2023 um 13:09

Danke für die Korrekturen, das ist für mich in Ordnung und wird in der nächsten Version von Gladys veröffentlicht!

pierre-gilles · 20. November 2023 um 16:28

Diese Funktion ist in Gladys Assistant 4.31 verfügbar!

Ich schließe dieses Thema, um die Abstimmungen freizugeben. Zögern Sie nicht, ein neues Thema zu erstellen, falls Sie auf Fehler stoßen

Thema		Antworten	Aufrufe
Déclenchement envoi message MQTT Demandes livrées	12	564	11. Dezember 2023
MQTT - Recevoir une valeur sur un topic personnalisé Demandes livrées mqtt , feature-core	23	1301	13. Mai 2024
Envoyer un message zigbee2mqtt Demandes livrées scene , zigbee2mqtt	11	413	11. November 2024
Déclencher une scène en envoyant un message / phrase à Gladys Demandes livrées scene , feature-core , scene-trigger , communication	6	645	1. November 2023
Nouveau déclencheur dans les scènes : "Gladys démarre" Demandes livrées	8	762	1. November 2023

Neuer Trigger: Ankunft einer MQTT-Nachricht

Verwandte Themen