new coach topic

Author: durandom

docs/crew_chief_mqtt_telemetry.json

@@ -5,7 +5,7 @@
     "Password": "crewchief",
     "Port": 30883,
     "UpdateRateLimit": 0,
-    "SubscribeTopic": "/coach",
+    "SubscribeTopic": "coach",
     "UseTLS": true,
     "AllowSoundDownload": false,
     "DebugResponse": false,

docs/new-architecture.md

@@ -0,0 +1,8 @@
+You're a software architect. We need to design a system around telemetry data of games.
+
+There will be multiple games. A local agent running on the game windows machine or on the game
+server will send telemetry data to our system.
+The telemetry data stream can
+
+
+https://www.kai-waehner.de/blog/2024/06/15/the-shift-left-architecture-from-batch-and-lakehouse-to-real-time-data-products-with-data-streaming/

telemetry/pitcrew/coach_app.py

@@ -16,7 +16,7 @@ class CoachApp(LoggingMixin):
     def __init__(self, history: History, coach_model: Coach, debug=False):
         self.history = history
         self.coach_model = coach_model
-        self.response_topic = f"/coach/{coach_model.driver.name}"
+        self.response_topic = f"coach/{coach_model.driver.name}"
         self.init_variables()
 
     def init_variables(self):

telemetry/pitcrew/coach_copilots_no_history.py

@@ -14,7 +14,7 @@
 class CoachCopilotsNoHistory(LoggingMixin):
     def __init__(self, coach_model: Coach, debug=False):
         self.coach_model = coach_model
-        self.response_topic = f"/coach/{coach_model.driver.name}"
+        self.response_topic = f"coach/{coach_model.driver.name}"
         driver = coach_model.driver
         self.persister = PersisterDb(driver, debug=debug)
         self.init_variables()