mqtt-message-specification.md

@@ -18,10 +18,55 @@ Time.io uses different topics and messages to communicate between services. Here
 
 ### Topics
 
-* [frontend_thing_update](mqtt-topic-frontend_thing_update): send (by the `frontend` service) to inform (the `worker-configdb-updater` service) about an update of a thing 
-* [qaqc_settings_update](mqtt-topic-qaqc_settings_update): send (by the `frontend` service) to inform (the `worker-configdb-updater` service) about an update of QC Settings
+* [frontend_thing_update](mqtt-topic-frontend_thing_update): send to inform (the configDB) about an update of a thing
+  * publisher services: 
+    * `frontend`
+      * found here `/tsm-frontend/tsm/mqtt_actions.py` 
+  * subscribed services:
+    *  `worker-configdb-updater`
+* [qaqc_settings_update](mqtt-topic-qaqc_settings_update): send to inform (the configDB) about an update of QC Settings
+  * publisher services: 
+    * `frontend`
+      * found here `/tsm-frontend/tsm/mqtt_actions.py` 
+  * subscribed services:
+    *  `worker-configdb-updater`
 * [configdb_update](mqtt-topic-configdb_update): send to inform that an update in the configDB occurred
+  * publisher services: 
+    * `worker-configdb-updater`
+      * __attention__:
+        * in `/tsm-orchestration/src/run_configdb_updater.py`, the function `qaqc_update` had published a message on that topic, which caused `worker-db-setup` to fail, as there was no thing in the payload
+        * we've commented it out as other services could have failed as well
+  * subscribed services:
+    *  `worker-object-storage-setup`
+    *  `worker-db-setup`
+    *  `worker-frost-setup`
+    *  `worker-mqtt-user-creation`
+    *  `worker-grafana-dashboard`
+    *  `worker-crontab-setup`
 * [data_parsed](mqtt-topic-data_parsed): send if data was parsed successfully
+  * publisher services:
+    * `frontend`
+      * found here `/tsm-frontend/tsm/mqtt_actions.py` 
+    * `worker-file-ingest`
+    * `worker-mqtt-ingest`
+  * subscribed services:
+    *  `worker-run-qaqc`
 * [qaqc_done](mqtt-topic-qaqc_done): send if QC run successfully on data
+  * publisher services: 
+    * `worker-run-qaqc` 
+  * subscribed services:
+    *  __none__
 * [sync_ext_apis](mqtt-topic-sync_ext_apis): send to trigger external api script run
+  * publisher services: 
+    * `sync_ext_apis` 
+    * `worker-crontab-setup`
+      * it's defined in `/src/mqtt_sync_wrapper.py` > `publish_single(get_envvar("API_SYNC_TOPIC"), json.dumps(message))`
+      * and that script `mqtt_sync_wrapper.py` is used in `/src/setup_crontab.py` > `script = "/scripts/mqtt_sync_wrapper.py"`
+  * subscribed services:
+    *  `worker-sync-extapis`
 * [user_login](mqtt-topic-user_login): sent to trigger worker syncing Grafana user permissions
+  * publisher services: 
+    * `frontend`
+      * found here `/tsm-frontend/tsm/mqtt_actions.py` 
+  * subscribed services:
+    *  `worker-grafana-user-orgs`
\ No newline at end of file