From c25c93d05a2130795038a0efe9eea60440830735 Mon Sep 17 00:00:00 2001 From: Di Zou Date: Thu, 4 Jan 2024 15:05:24 -0500 Subject: [PATCH] fix infinite loop problem --- apps/core/services/xplane.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/core/services/xplane.go b/apps/core/services/xplane.go index d9bfbd4..715bf6f 100644 --- a/apps/core/services/xplane.go +++ b/apps/core/services/xplane.go @@ -201,10 +201,11 @@ func (s xplaneService) setupWebsocket() { var lastSyncedFlightStatus models.FlightStatus lastSyncedId, _ := strconv.ParseUint(req, 10, 0) s.db.Model(&models.FlightStatus{}). - Where("arrival_total_weight > 1"). + Where("arrival_total_weight > 10"). Order("id desc"). Limit(1). Find(&lastSyncedFlightStatus) + s.Logger.Infof("lastSyncedFlightStatus: %+v", lastSyncedFlightStatus) if lastSyncedFlightStatus.ID == uint(lastSyncedId) { s.Logger.Infof("Synced flight logs for client") err := ws.WriteMessage(websocket.TextMessage, []byte("SyncFlightLogs|Done")) @@ -219,7 +220,7 @@ func (s xplaneService) setupWebsocket() { s.db.Preload("Locations"). Preload("Events"). Model(&models.FlightStatus{}). - Where("id > ?", lastSyncedId). + Where("id > ? AND arrival_total_weight > 10", lastSyncedId). Order("id asc"). Limit(5). Find(&res)