Merge branch 'main' into update-backend-controllers-with-timescale

Author: alexwhelan12

packages/db/src/services/DatabaseService.ts

@@ -210,6 +210,8 @@ export class DatabaseService {
   }
 
   async close(): Promise<void> {
+    if (this.isConnected) {
+      await AppDataSource.destroy();
     if (this.isConnected) {
       await AppDataSource.destroy();
       console.log("Database connection closed");

packages/server/.env.example

@@ -17,6 +17,14 @@ GPS_TABLE_NAME="your-dynamodb-gps-table-name"
 MQTT_USERNAME="primaryuser"
 MQTT_PASSWORD="changeme"
 
+########################
+# Database  #
+########################
+DATABASE_USERNAME=""
+DATABASE_PASSWORD=""
+DATABASE_HOST=""
+DATABASE_PORT=
+
 ########################
 # App secrets / other  #
 ########################

packages/server/src/controllers/BackendController/BackendController.ts

@@ -1,4 +1,5 @@
 import { DatabaseService } from "db";
+import { DatabaseService } from "db";
 import type { IncomingMessage, Server, ServerResponse } from "http";
 
 import type { BackendControllerTypes } from "@/controllers/BackendController/BackendController.types";

packages/server/src/controllers/LapController/LapController.ts

@@ -158,6 +158,7 @@ export class LapController implements LapControllerType {
   // this function is for calling when lap completes via lap digital being true
   public async handleLapData(lapData: ILapData) {
     await this.backendController.socketIO.broadcastLapData(lapData);
+    await this.backendController.mqtt.publishLapData(lapData);
     await this.backendController.dynamoDB.insertLapData(lapData);
   }