Refactor downloadWindData to use parseObsTimeLocal for timestamp comp…

…arison
bluescorpian · Feb 5, 2025 · a051589 · a051589
1 parent 3454be1
commit a051589
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/backend/main.ts b/backend/main.ts
@@ -44,7 +44,9 @@ async function downloadWindData(stationId: number) {
 	const latestEntryTimestamp = stationStats.value?.latestEntryTimestamp || 0;
 
 	const newTableData = data.tableData.filter(
-		(entry) => new Date(entry.obsTimeLocal).getTime() > latestEntryTimestamp
+		(entry) =>
+			parseObsTimeLocal(entry.obsTimeLocal).getTime() >
+			latestEntryTimestamp
 	);
 
 	if (newTableData.length) {
@@ -59,7 +61,7 @@ async function downloadWindData(stationId: number) {
 		transaction.set(["station", data.station.id], {
 			...data.station,
 			entries: (stationStats.value?.entries ?? 0) + newTableData.length,
-			latestEntryTimestamp: new Date(
+			latestEntryTimestamp: parseObsTimeLocal(
 				newTableData[0].obsTimeLocal
 			).getTime(),
 		});
@@ -78,6 +80,10 @@ async function downloadWindData(stationId: number) {
 	}
 }
 
+function parseObsTimeLocal(obsTimeLocal: string): Date {
+	return new Date(obsTimeLocal + "+02:00");
+}
+
 const router = new Router();
 
 router.post("/login", async (ctx) => {