[AAP-11261] Add MQTT event source

[kubealex]

Adding an MQTT event source for rulebooks - Tested

[kubealex]

hi team, any news on this one?

[kurokobo]

@kubealex
Hi, thanks for introducing this plugin!
I have created small PR with following changes for your branch to make it work with the latest collection: kubealex#1

• Merge latest main branch
• Move mqtt.py from extensions/eda/plugins/event_sources to extensions/eda/plugins/event_source where other plugins are placed
• Remove dict from import to avoid the error ImportError: cannot import name 'dict' from 'typing'
• Add aiomqtt to requirements.txt to make Ansible Builder installable required modules for this plugin

[kubealex]

Thank you @kurokobo! I just merged your contribution into the branch 🚀

[jpmens]

I am very much looking forward to seeing this merged. :)

[tonyskapunk]

I've been using this patch locally and has been working as expected, thanks!!

[Alex-Izquierdo]

Hi @kubealex

We want to express our sincere appreciation for your effort and contribution. After careful consideration, we have concluded that this plugin doesn't align with the scope of our official collection, and unfortunately, it will not be included.

However, this does not diminish the value of your work. We believe your plugin can still be highly beneficial and encourage you to offer it through your own collection. You are welcome to upload it to galaxy with the "eda" tag.

As a fellow Red Hatter, we also suggest reaching out to your product management team to explore if such a collection could be supported within Red Hat as a maintained collection.

Thank you for your understanding and contribution.

[kubealex]

Thank you for the feedback Alex, much appreciated!

@jpmens @tonyskapunk and anyone who could be interested in using or including it, no worries, I'll leave it here [1] the link to the custom collection that includes the plugin.

[1] https://galaxy.ansible.com/kubealex/eda

[kurokobo]

@Alex-Izquierdo
Hi, thanks for working on this.
Do you have any plan to update the documentation for Ansible Rulebook?

In the documentation, the mqtt plugin is mentioned as example of Event Bus Plugins.

1. Event Bus Plugins
   These are plugins that listen to a stream of events from a source where the connection is established by the plugin itself.
   Examples of this are the kafka and mqtt plugins.

https://ansible.readthedocs.io/projects/rulebook/en/stable/sources.html

This is why I reached out here to find the status of MQTT plugin. This documentation might cause users misunderstanding that an officially maintained MQTT plugin exists (yes, I am one of the users who misunderstood).

It would be great if the MQTT plugin is officially implemented as the documentation shows, but since as you stated this plugin no longer merged into this collection, the documentation should be updated.

Please let me know if I should create an issue in ansible-rulebook or create a PR to remove MQTT from the documentation. Thanks in advance!

[Alex-Izquierdo]

Thanks for raising this issue @kurokobo
It will be fixed on ansible/ansible-rulebook#590

[kurokobo]

Thanks for rapid update😃

[jpmens]

@kubealex thanks for the link to the custom collection that includes the plugin (https://galaxy.ansible.com/kubealex/eda), but that is 404 which, I assume, is because of the transition from Galaxy to -NG.

The current link is https://galaxy.ansible.com/ui/repo/published/kubealex/eda/ but I think it's probably safer to mention the link to your repository at https://github.com/kubealex/kubealex.eda