Add Nightscout WebSocket support for real-time data updates

LoopFollow.xcodeproj/project.pbxproj

@@ -430,6 +430,9 @@
 		FCFEEC9E2486E68E00402A7F /* WebKit.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = FCFEEC9D2486E68E00402A7F /* WebKit.framework */; };
 		FCFEECA02488157B00402A7F /* Chart.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCFEEC9F2488157B00402A7F /* Chart.swift */; };
 		FCFEECA2248857A600402A7F /* SettingsViewController.swift in Sources */ = {isa = PBXBuildFile; fileRef = FCFEECA1248857A600402A7F /* SettingsViewController.swift */; };
+		DD50C10A2F60A00000000001 /* SocketIO in Frameworks */ = {isa = PBXBuildFile; productRef = DD50C10A2F60A00000000003 /* SocketIO */; };
+		DD50C10A2F60B00000000002 /* NightscoutSocketManager.swift in Sources */ = {isa = PBXBuildFile; fileRef = DD50C10A2F60B00000000001 /* NightscoutSocketManager.swift */; };
+		DD50C10A2F60B00000000004 /* NightscoutSocketDataHandler.swift in Sources */ = {isa = PBXBuildFile; fileRef = DD50C10A2F60B00000000003 /* NightscoutSocketDataHandler.swift */; };
 /* End PBXBuildFile section */
 
 /* Begin PBXContainerItemProxy section */
@@ -582,6 +585,8 @@
 		DD493AE42ACF2383009A6922 /* Treatments.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = Treatments.swift; sourceTree = "<group>"; };
 		DD493AE62ACF23CF009A6922 /* DeviceStatus.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = DeviceStatus.swift; sourceTree = "<group>"; };
 		DD493AE82ACF2445009A6922 /* BGData.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = BGData.swift; sourceTree = "<group>"; };
+		DD50C10A2F60B00000000001 /* NightscoutSocketManager.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = NightscoutSocketManager.swift; sourceTree = "<group>"; };
+		DD50C10A2F60B00000000003 /* NightscoutSocketDataHandler.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = NightscoutSocketDataHandler.swift; sourceTree = "<group>"; };
 		DD4A407D2E6AFEE6007B318B /* AuthService.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = AuthService.swift; sourceTree = "<group>"; };
 		DD4AFB3A2DB55CB600BB593F /* TimeOfDay.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = TimeOfDay.swift; sourceTree = "<group>"; };
 		DD4AFB3C2DB55D2900BB593F /* AlarmConfiguration.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = AlarmConfiguration.swift; sourceTree = "<group>"; };
@@ -921,6 +926,7 @@
 			isa = PBXFrameworksBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
+				DD50C10A2F60A00000000001 /* SocketIO in Frameworks */,
 				FCFEEC9E2486E68E00402A7F /* WebKit.framework in Frameworks */,
 				3F1335F351590E573D8E6962 /* Pods_LoopFollow.framework in Frameworks */,
 			);
@@ -1167,6 +1173,8 @@
 				DD0C0C5F2C415B9D00DBADDF /* ProfileManager.swift */,
 				DD0C0C612C4175FD00DBADDF /* NSProfile.swift */,
 				DD5334222C60ED3600062F9D /* IAge.swift */,
+				DD50C10A2F60B00000000001 /* NightscoutSocketManager.swift */,
+				DD50C10A2F60B00000000003 /* NightscoutSocketDataHandler.swift */,
 			);
 			path = Nightscout;
 			sourceTree = "<group>";
@@ -1798,6 +1806,7 @@
 			);
 			name = LoopFollow;
 			packageProductDependencies = (
+				DD50C10A2F60A00000000003 /* SocketIO */,
 			);
 			productName = LoopFollow;
 			productReference = FC9788142485969B00A7906C /* Loop Follow.app */;
@@ -1835,6 +1844,7 @@
 			);
 			mainGroup = FC97880B2485969B00A7906C;
 			packageReferences = (
+				DD50C10A2F60A00000000002 /* XCRemoteSwiftPackageReference "socket.io-client-swift" */,
 			);
 			productRefGroup = FC9788152485969B00A7906C /* Products */;
 			projectDirPath = "";
@@ -2206,6 +2216,8 @@
 				DD026E592EA2C8A200A39CB5 /* InsulinPrecisionManager.swift in Sources */,
 				374A77992F5BD8B200E96858 /* APNSClient.swift in Sources */,
 				DD493AE72ACF23CF009A6922 /* DeviceStatus.swift in Sources */,
+				DD50C10A2F60B00000000002 /* NightscoutSocketManager.swift in Sources */,
+				DD50C10A2F60B00000000004 /* NightscoutSocketDataHandler.swift in Sources */,
 				DDC7E5162DBCFA7F00EB1127 /* SnoozerView.swift in Sources */,
 				FCFEECA2248857A600402A7F /* SettingsViewController.swift in Sources */,
 				DD7F4C232DD7A62200D449E9 /* AlarmType+SortDirection.swift in Sources */,
@@ -2822,6 +2834,25 @@
 			versionGroupType = wrapper.xcdatamodel;
 		};
 /* End XCVersionGroup section */
+
+/* Begin XCRemoteSwiftPackageReference section */
+		DD50C10A2F60A00000000002 /* XCRemoteSwiftPackageReference "socket.io-client-swift" */ = {
+			isa = XCRemoteSwiftPackageReference;
+			repositoryURL = "https://github.com/socketio/socket.io-client-swift";
+			requirement = {
+				kind = upToNextMajorVersion;
+				minimumVersion = 16.1.1;
+			};
+		};
+/* End XCRemoteSwiftPackageReference section */
+
+/* Begin XCSwiftPackageProductDependency section */
+		DD50C10A2F60A00000000003 /* SocketIO */ = {
+			isa = XCSwiftPackageProductDependency;
+			package = DD50C10A2F60A00000000002 /* XCRemoteSwiftPackageReference "socket.io-client-swift" */;
+			productName = SocketIO;
+		};
+/* End XCSwiftPackageProductDependency section */
 	};
 	rootObject = FC97880C2485969B00A7906C /* Project object */;
 }

LoopFollow/Controllers/Nightscout/BGData.swift

@@ -176,6 +176,10 @@ extension MainViewController {
                 TaskScheduler.shared.rescheduleTask(id: .alarmCheck, to: Date().addingTimeInterval(3))
             }
 
+            if NightscoutSocketManager.shared.connectionState == .authenticated {
+                delayToSchedule = max(delayToSchedule * 3, 60)
+            }
+
             TaskScheduler.shared.rescheduleTask(id: .fetchBG, to: Date().addingTimeInterval(delayToSchedule))
 
             // Evaluate speak conditions if there is a previous value.

LoopFollow/Controllers/Nightscout/DeviceStatus.swift

@@ -213,37 +213,28 @@ extension MainViewController {
         let secondsAgo = now - (Observable.shared.alertLastLoopTime.value ?? 0)
 
         DispatchQueue.main.async {
+            var interval: Double
             if secondsAgo >= (20 * 60) {
-                TaskScheduler.shared.rescheduleTask(
-                    id: .deviceStatus,
-                    to: Date().addingTimeInterval(5 * 60)
-                )
-
+                interval = 5 * 60
             } else if secondsAgo >= (10 * 60) {
-                TaskScheduler.shared.rescheduleTask(
-                    id: .deviceStatus,
-                    to: Date().addingTimeInterval(60)
-                )
-
+                interval = 60
             } else if secondsAgo >= (7 * 60) {
-                TaskScheduler.shared.rescheduleTask(
-                    id: .deviceStatus,
-                    to: Date().addingTimeInterval(30)
-                )
-
+                interval = 30
             } else if secondsAgo >= (5 * 60) {
-                TaskScheduler.shared.rescheduleTask(
-                    id: .deviceStatus,
-                    to: Date().addingTimeInterval(10)
-                )
+                interval = 10
             } else {
-                let interval = (310 - secondsAgo)
-                TaskScheduler.shared.rescheduleTask(
-                    id: .deviceStatus,
-                    to: Date().addingTimeInterval(interval)
-                )
+                interval = 310 - secondsAgo
                 TaskScheduler.shared.rescheduleTask(id: .alarmCheck, to: Date().addingTimeInterval(3))
             }
+
+            if NightscoutSocketManager.shared.connectionState == .authenticated {
+                interval = max(interval * 3, 60)
+            }
+
+            TaskScheduler.shared.rescheduleTask(
+                id: .deviceStatus,
+                to: Date().addingTimeInterval(interval)
+            )
         }
 
         evaluateNotLooping()

LoopFollow/Controllers/Nightscout/NightscoutSocketDataHandler.swift

@@ -0,0 +1,54 @@
+// LoopFollow
+// NightscoutSocketDataHandler.swift
+
+import Foundation
+
+extension MainViewController {
+    func setupNightscoutSocket() {
+        NightscoutSocketManager.shared.onDataUpdate = { [weak self] data in
+            self?.handleSocketDataUpdate(data)
+        }
+        NightscoutSocketManager.shared.connectIfNeeded()
+    }
+
+    func handleSocketDataUpdate(_ data: [String: Any]) {
+        let isDelta = data["delta"] as? Bool ?? false
+
+        if !isDelta {
+            // Full data on initial connect — trigger all fetches
+            LogManager.shared.log(category: .websocket, message: "Full data received, triggering all fetches")
+            TaskScheduler.shared.rescheduleTask(id: .fetchBG, to: Date())
+            TaskScheduler.shared.rescheduleTask(id: .deviceStatus, to: Date())
+            TaskScheduler.shared.rescheduleTask(id: .treatments, to: Date())
+            TaskScheduler.shared.rescheduleTask(id: .profile, to: Date())
+            return
+        }
+
+        // Selective: only fetch data types present in the delta
+        var triggered: [String] = []
+
+        if data["sgvs"] != nil || data["mbgs"] != nil {
+            TaskScheduler.shared.rescheduleTask(id: .fetchBG, to: Date())
+            triggered.append("BG")
+        }
+
+        if data["devicestatus"] != nil {
+            TaskScheduler.shared.rescheduleTask(id: .deviceStatus, to: Date())
+            triggered.append("DeviceStatus")
+        }
+
+        if data["treatments"] != nil {
+            TaskScheduler.shared.rescheduleTask(id: .treatments, to: Date())
+            triggered.append("Treatments")
+        }
+
+        if data["profiles"] != nil {
+            TaskScheduler.shared.rescheduleTask(id: .profile, to: Date())
+            triggered.append("Profile")
+        }
+
+        if !triggered.isEmpty {
+            LogManager.shared.log(category: .websocket, message: "Delta triggered: \(triggered.joined(separator: ", "))", isDebug: true)
+        }
+    }
+}