ci: target macos-14 runner label for Xcode 16 / macOS 14+ SDK support

.gitea/workflows/build.yml

@@ -0,0 +1,84 @@
+name: MacMonitor CI/CD Pipeline
+
+on:
+  push:
+    branches:
+      - main
+      - develop
+      - 'milestone/**'
+      - 'feat/**'
+  pull_request:
+    branches:
+      - main
+      - develop
+      - 'milestone/**'
+
+concurrency:
+  group: ${{ github.workflow }}-${{ github.ref }}
+  cancel-in-progress: true
+
+jobs:
+  build-and-test:
+    name: Build & Test (Intel x86_64)
+    runs-on: macos-14
+
+    steps:
+      - name: Check out repository
+        uses: actions/checkout@v4
+
+      - name: Inspect Toolchain & Environment
+        run: |
+          echo "=== Host Architecture ==="
+          uname -m
+          echo "=== macOS Version ==="
+          sw_vers
+          echo "=== Active Xcode Version ==="
+          xcodebuild -version
+          echo "=== Available macOS SDKs ==="
+          xcrun --show-sdk-path
+
+      - name: Generate Xcode Project
+        run: |
+          if command -v xcodegen &> /dev/null; then
+            xcodegen generate
+          else
+            echo "xcodegen not preinstalled, using tracked MacMonitor.xcodeproj"
+          fi
+
+      - name: Run SwiftLint Linting
+        run: |
+          if command -v swiftlint &> /dev/null; then
+            swiftlint lint --reporter emoji
+          else
+            echo "swiftlint not found, skipping lint step"
+          fi
+
+      - name: Build MacMonitor Scheme
+        run: |
+          set -o pipefail
+          if command -v xcbeautify &> /dev/null; then
+            xcodebuild clean build \
+              -scheme MacMonitor \
+              -destination 'generic/platform=macOS,arch=x86_64' \
+              CODE_SIGNING_ALLOWED=NO | xcbeautify
+          else
+            xcodebuild clean build \
+              -scheme MacMonitor \
+              -destination 'generic/platform=macOS,arch=x86_64' \
+              CODE_SIGNING_ALLOWED=NO
+          fi
+
+      - name: Run Unit Tests
+        run: |
+          set -o pipefail
+          if command -v xcbeautify &> /dev/null; then
+            xcodebuild test \
+              -scheme MacMonitor \
+              -destination 'platform=macOS,arch=x86_64' \
+              CODE_SIGNING_ALLOWED=NO | xcbeautify
+          else
+            xcodebuild test \
+              -scheme MacMonitor \
+              -destination 'platform=macOS,arch=x86_64' \
+              CODE_SIGNING_ALLOWED=NO
+          fi

MacMonitor.xcodeproj/project.pbxproj

@@ -7,16 +7,52 @@
 	objects = {
 
 /* Begin PBXBuildFile section */
+		0A7117B3B7CC7112F2527574 /* MMPowerTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 02F5FDE260999C39E978D849 /* MMPowerTelemetryProvider.m */; };
+		160334CC765E091A7CBE21AA /* MMCPULoadTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 4CE92B1A8D7FDBB6499448E1 /* MMCPULoadTests.swift */; };
 		1879A3DCF6E305D7F2CD472E /* CoreFoundation.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = 2345555FF9780B02A90CC7A9 /* CoreFoundation.framework */; };
+		1B15F48F6B19E9EA4556ECD5 /* MMStorageTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 78325870C7CD8312AECA2236 /* MMStorageTests.swift */; };
 		1B3F1C8ABF0ADFAA290FF6F6 /* MMSMCParser.m in Sources */ = {isa = PBXBuildFile; fileRef = 375AA781A2AA0A20B119C7B7 /* MMSMCParser.m */; };
+		22CA7351A745F7837E487051 /* MMPeripheralsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = D1486E1512594482380CB492 /* MMPeripheralsTests.swift */; };
+		2C0F7AB93691ED8AA86FBCF0 /* MMProcessDetailInspector.m in Sources */ = {isa = PBXBuildFile; fileRef = 52E641F8A664D456518EDBA4 /* MMProcessDetailInspector.m */; };
+		3BA6709B727B1AAC6C4310B5 /* MMProcessDetailsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 7187632FF63B3B0D07FE9194 /* MMProcessDetailsTests.swift */; };
 		3C0AC14F803C813287D8A663 /* IOKit.framework in Frameworks */ = {isa = PBXBuildFile; fileRef = 007F48A5A599AB4E8D216D16 /* IOKit.framework */; };
+		4419FE7554489B23976E2970 /* MMCPULoadProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = D68FC8100D08DB6202F46339 /* MMCPULoadProvider.m */; };
+		4752C49841375B88194F7635 /* MMPeripheralsProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 2E6A10A13A49E22E51862895 /* MMPeripheralsProvider.m */; };
+		4C1A92F4DEF4C824976115C2 /* MMNetworkSocketsTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 374B1BF631CC4738CB52CA3B /* MMNetworkSocketsTests.swift */; };
+		57BA02AE1CE24DBD02BD03A4 /* MMComponentThermalTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = B288C7402E2C00E75F8CD016 /* MMComponentThermalTests.swift */; };
+		5D31906EA986E2BA92E86FA8 /* MMNetworkBandwidthTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 27C612287333D757C92A076A /* MMNetworkBandwidthTests.swift */; };
+		6201FD599FED061F6C736E8B /* MMMemoryTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 099DCF7EF03A58ADA40A94A1 /* MMMemoryTests.swift */; };
+		655366D7066478A02EDA91BB /* MMFanTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = C9ED8F75E082D4F8AC2FF2F5 /* MMFanTelemetryProvider.m */; };
+		6A4FDB46AE5E0DAF85CCAB56 /* MMDiskIOTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = E9DAC4D5C09C974EE833DC7C /* MMDiskIOTests.swift */; };
+		6D973241BBE61F0B053239DB /* MMGPUTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = D61AB99733A4AA52459BA7C4 /* MMGPUTelemetryProvider.m */; };
+		7C9AE2ADAED52E593B52F3AE /* MMProcessTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 52471E871E5CC1E444318070 /* MMProcessTests.swift */; };
+		87818E46CEA5145A8215D0E3 /* MMCPUThermalTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 0F2BD3777A674DC4EB442890 /* MMCPUThermalTests.swift */; };
+		87A9E18362486D0D385BBC4A /* MMCPUThermalProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 62C377EFD025D6A6B5563E77 /* MMCPUThermalProvider.m */; };
 		88387CDAE2AC1CC74EF89B57 /* MacMonitorApp.swift in Sources */ = {isa = PBXBuildFile; fileRef = ADEA6BD38BA8D887B1DB64A9 /* MacMonitorApp.swift */; };
+		8EDDC2171C55B6E7FC999DAB /* MMBatteryTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 9C92D0D2B62B3081ECCA9920 /* MMBatteryTelemetryProvider.m */; };
+		901EF4853E785A2856E54BC9 /* MMKernelTelemetryTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = DE40072F9A1F9DBD1C48A3B1 /* MMKernelTelemetryTests.swift */; };
+		925245C5B5F8D8DA3C89C4BA /* MMComponentThermalProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = C65F5835516BC2A65BCE25D2 /* MMComponentThermalProvider.m */; };
+		93EF83FE087C6DEAAE3EC0CC /* MMProcessTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 728C692778909D2B7451C07B /* MMProcessTelemetryProvider.m */; };
+		951DBA5D3BBAB753322A5DF9 /* MMLoadAverageProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = B5F2256DF514DD737306302B /* MMLoadAverageProvider.m */; };
+		9B5C651AD2AF7DE2738F0C44 /* MMPowerTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = D48698681374BD25B980C000 /* MMPowerTests.swift */; };
 		9BCE74C5454F81EF80492E75 /* MacMonitorTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 2EC3EDFCD5C50CB352FCED87 /* MacMonitorTests.swift */; };
+		9D12825C7904FB0DAE664CA0 /* MMAudioTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 10D16E1ABE6D28B676EA83FF /* MMAudioTests.swift */; };
+		A521961E035DD50ED8B0C1A9 /* MMKernelTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = F444F4543F0A7421C8F8E636 /* MMKernelTelemetryProvider.m */; };
+		A599E974E56F0B8D94A7E480 /* MMNetworkSocketsProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = D78F76C1996D7FCA241CE532 /* MMNetworkSocketsProvider.m */; };
 		A7609CE56D49EC3419987468 /* SystemTelemetryStore.swift in Sources */ = {isa = PBXBuildFile; fileRef = E4B4E94FB2886C60D5548A2A /* SystemTelemetryStore.swift */; };
 		A9FCAEC0BF27A419DB148C4A /* ContentView.swift in Sources */ = {isa = PBXBuildFile; fileRef = E142AE61F9B87757997870DD /* ContentView.swift */; };
+		ACC914C61AB3762EB0C40513 /* MMLoadAverageTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 7EB05C092C94C3972727AAA7 /* MMLoadAverageTests.swift */; };
+		AE3C28BDC3CEF40A9E8F2B20 /* MMGPUTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 80A0F723121CDF9597316F58 /* MMGPUTests.swift */; };
+		B9C2D6574E808B517BA34C83 /* MMMemoryTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 991AEEAF262F3C6BE930BC77 /* MMMemoryTelemetryProvider.m */; };
+		BC487DB86227F09CB0603894 /* MMBatteryTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = B0EB61D811D989279BCBE478 /* MMBatteryTests.swift */; };
 		CD91FC663B19DA1FEA3D49D7 /* MMAppleSMCClient.m in Sources */ = {isa = PBXBuildFile; fileRef = 5555436CD3CB8A73F5D6504F /* MMAppleSMCClient.m */; };
+		D7784A61FE4635275CFB3D6C /* MMAudioTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 3189D2403E6E984D4924AE4D /* MMAudioTelemetryProvider.m */; };
+		E3CCE93A7D4D1EB0187D3E52 /* MMNetworkBandwidthProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = C539AEA27C794C6F428EA875 /* MMNetworkBandwidthProvider.m */; };
+		E6F2F695B8D3E7045967C082 /* MMFanTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 336CEE35A745F3C7E9F70F43 /* MMFanTests.swift */; };
 		EAFAF5A10502D4ACC64F4720 /* MMTelemetryCoordinator.m in Sources */ = {isa = PBXBuildFile; fileRef = F9F9AD1268F906761032AF4D /* MMTelemetryCoordinator.m */; };
 		EC9FA3E4A119277B89E73F8D /* MMSMCTests.swift in Sources */ = {isa = PBXBuildFile; fileRef = 940D608A1AF80F75584E744E /* MMSMCTests.swift */; };
+		F2F7A141F2452EC1B4FB45D8 /* MMStorageTelemetryProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 6DCBCEA450103E2404761B78 /* MMStorageTelemetryProvider.m */; };
+		FED88F290A2F2FBD63DDEC31 /* MMDiskIOProvider.m in Sources */ = {isa = PBXBuildFile; fileRef = 3E13917CAF525640D856ECD9 /* MMDiskIOProvider.m */; };
 /* End PBXBuildFile section */
 
 /* Begin PBXContainerItemProxy section */
@@ -31,21 +67,75 @@
 
 /* Begin PBXFileReference section */
 		007F48A5A599AB4E8D216D16 /* IOKit.framework */ = {isa = PBXFileReference; lastKnownFileType = wrapper.framework; name = IOKit.framework; path = System/Library/Frameworks/IOKit.framework; sourceTree = SDKROOT; };
+		0130BD1E18972DF9E2955334 /* MMMemoryTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMMemoryTelemetryProvider.h; sourceTree = "<group>"; };
+		02F5FDE260999C39E978D849 /* MMPowerTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMPowerTelemetryProvider.m; sourceTree = "<group>"; };
+		09475741B5D0D4B89B863C3D /* MMComponentThermalProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMComponentThermalProvider.h; sourceTree = "<group>"; };
+		099DCF7EF03A58ADA40A94A1 /* MMMemoryTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMMemoryTests.swift; sourceTree = "<group>"; };
+		0C94CCFBE8C9E1370368A28C /* MMNetworkSocketsProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMNetworkSocketsProvider.h; sourceTree = "<group>"; };
+		0F2BD3777A674DC4EB442890 /* MMCPUThermalTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMCPUThermalTests.swift; sourceTree = "<group>"; };
+		10D16E1ABE6D28B676EA83FF /* MMAudioTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMAudioTests.swift; sourceTree = "<group>"; };
 		1AD9EEE571CD904BBCD1C96B /* MMSMCParser.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMSMCParser.h; sourceTree = "<group>"; };
+		1B07A683AD0EFBA8E1FB6C9D /* MMProcessDetailInspector.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMProcessDetailInspector.h; sourceTree = "<group>"; };
 		2345555FF9780B02A90CC7A9 /* CoreFoundation.framework */ = {isa = PBXFileReference; lastKnownFileType = wrapper.framework; name = CoreFoundation.framework; path = System/Library/Frameworks/CoreFoundation.framework; sourceTree = SDKROOT; };
+		27C612287333D757C92A076A /* MMNetworkBandwidthTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMNetworkBandwidthTests.swift; sourceTree = "<group>"; };
+		2C55E977DBFBE7FF04621608 /* MMLoadAverageProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMLoadAverageProvider.h; sourceTree = "<group>"; };
+		2DC6E55C9D3F646A1C62133D /* MMBatteryTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMBatteryTelemetryProvider.h; sourceTree = "<group>"; };
+		2E6A10A13A49E22E51862895 /* MMPeripheralsProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMPeripheralsProvider.m; sourceTree = "<group>"; };
 		2EC3EDFCD5C50CB352FCED87 /* MacMonitorTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MacMonitorTests.swift; sourceTree = "<group>"; };
+		3189D2403E6E984D4924AE4D /* MMAudioTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMAudioTelemetryProvider.m; sourceTree = "<group>"; };
 		32340166F6100A08105308D3 /* MMTelemetryCoordinator.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMTelemetryCoordinator.h; sourceTree = "<group>"; };
+		336CEE35A745F3C7E9F70F43 /* MMFanTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMFanTests.swift; sourceTree = "<group>"; };
+		374B1BF631CC4738CB52CA3B /* MMNetworkSocketsTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMNetworkSocketsTests.swift; sourceTree = "<group>"; };
 		375AA781A2AA0A20B119C7B7 /* MMSMCParser.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMSMCParser.m; sourceTree = "<group>"; };
+		3A14D7B97200EA4C102FEE67 /* MMNetworkBandwidthProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMNetworkBandwidthProvider.h; sourceTree = "<group>"; };
+		3CFC5B905E428A6B854E0AB4 /* MMFanTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMFanTelemetryProvider.h; sourceTree = "<group>"; };
+		3E13917CAF525640D856ECD9 /* MMDiskIOProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMDiskIOProvider.m; sourceTree = "<group>"; };
+		41478843A6B013478D94F739 /* MMProcessTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMProcessTelemetryProvider.h; sourceTree = "<group>"; };
+		46DE3AE12DAE26C4FE58034C /* MMStorageTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMStorageTelemetryProvider.h; sourceTree = "<group>"; };
+		4CE92B1A8D7FDBB6499448E1 /* MMCPULoadTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMCPULoadTests.swift; sourceTree = "<group>"; };
+		52471E871E5CC1E444318070 /* MMProcessTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMProcessTests.swift; sourceTree = "<group>"; };
+		52E641F8A664D456518EDBA4 /* MMProcessDetailInspector.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMProcessDetailInspector.m; sourceTree = "<group>"; };
 		5555436CD3CB8A73F5D6504F /* MMAppleSMCClient.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMAppleSMCClient.m; sourceTree = "<group>"; };
 		5635101F862DE680856BDE6E /* MMTelemetryDomain.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMTelemetryDomain.h; sourceTree = "<group>"; };
 		56E285A0A1746AE659981F22 /* MacMonitorTests.xctest */ = {isa = PBXFileReference; explicitFileType = wrapper.cfbundle; includeInIndex = 0; path = MacMonitorTests.xctest; sourceTree = BUILT_PRODUCTS_DIR; };
+		57845310A3D4EC67E48A3B11 /* MMCPULoadProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMCPULoadProvider.h; sourceTree = "<group>"; };
+		5C45D1EB09E045A53A154136 /* MMAudioTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMAudioTelemetryProvider.h; sourceTree = "<group>"; };
+		62C377EFD025D6A6B5563E77 /* MMCPUThermalProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMCPUThermalProvider.m; sourceTree = "<group>"; };
 		6D0E5CAF25DFA9A1D2A698A0 /* MMTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMTelemetryProvider.h; sourceTree = "<group>"; };
+		6DCBCEA450103E2404761B78 /* MMStorageTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMStorageTelemetryProvider.m; sourceTree = "<group>"; };
+		7187632FF63B3B0D07FE9194 /* MMProcessDetailsTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMProcessDetailsTests.swift; sourceTree = "<group>"; };
 		726005CB5A6C86E7D80D3CA0 /* MMAppleSMCClient.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMAppleSMCClient.h; sourceTree = "<group>"; };
+		728C692778909D2B7451C07B /* MMProcessTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMProcessTelemetryProvider.m; sourceTree = "<group>"; };
+		78325870C7CD8312AECA2236 /* MMStorageTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMStorageTests.swift; sourceTree = "<group>"; };
+		7EB05C092C94C3972727AAA7 /* MMLoadAverageTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMLoadAverageTests.swift; sourceTree = "<group>"; };
+		80A0F723121CDF9597316F58 /* MMGPUTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMGPUTests.swift; sourceTree = "<group>"; };
 		8FBB436F3D9472194D8C6EDD /* MMSMCDefines.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMSMCDefines.h; sourceTree = "<group>"; };
 		940D608A1AF80F75584E744E /* MMSMCTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMSMCTests.swift; sourceTree = "<group>"; };
+		991AEEAF262F3C6BE930BC77 /* MMMemoryTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMMemoryTelemetryProvider.m; sourceTree = "<group>"; };
+		9C92D0D2B62B3081ECCA9920 /* MMBatteryTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMBatteryTelemetryProvider.m; sourceTree = "<group>"; };
+		9DC54CCE276F93D5AF0A0C28 /* MMGPUTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMGPUTelemetryProvider.h; sourceTree = "<group>"; };
 		ADEA6BD38BA8D887B1DB64A9 /* MacMonitorApp.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MacMonitorApp.swift; sourceTree = "<group>"; };
+		AFA681E2464EA78CC19B54E0 /* MMDiskIOProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMDiskIOProvider.h; sourceTree = "<group>"; };
+		B0EB61D811D989279BCBE478 /* MMBatteryTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMBatteryTests.swift; sourceTree = "<group>"; };
+		B288C7402E2C00E75F8CD016 /* MMComponentThermalTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMComponentThermalTests.swift; sourceTree = "<group>"; };
+		B5F2256DF514DD737306302B /* MMLoadAverageProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMLoadAverageProvider.m; sourceTree = "<group>"; };
+		C539AEA27C794C6F428EA875 /* MMNetworkBandwidthProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMNetworkBandwidthProvider.m; sourceTree = "<group>"; };
+		C65F5835516BC2A65BCE25D2 /* MMComponentThermalProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMComponentThermalProvider.m; sourceTree = "<group>"; };
+		C9ED8F75E082D4F8AC2FF2F5 /* MMFanTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMFanTelemetryProvider.m; sourceTree = "<group>"; };
+		CBA91906CA8B7936CC82A36B /* MMPowerTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMPowerTelemetryProvider.h; sourceTree = "<group>"; };
+		CDE2777944B8F12EC7D2EAB5 /* MMPeripheralsProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMPeripheralsProvider.h; sourceTree = "<group>"; };
+		D1486E1512594482380CB492 /* MMPeripheralsTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMPeripheralsTests.swift; sourceTree = "<group>"; };
+		D48698681374BD25B980C000 /* MMPowerTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMPowerTests.swift; sourceTree = "<group>"; };
+		D61AB99733A4AA52459BA7C4 /* MMGPUTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMGPUTelemetryProvider.m; sourceTree = "<group>"; };
+		D68FC8100D08DB6202F46339 /* MMCPULoadProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMCPULoadProvider.m; sourceTree = "<group>"; };
+		D73CCC7B5E6BF1825EA68E2B /* MMCPUThermalProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMCPUThermalProvider.h; sourceTree = "<group>"; };
+		D78F76C1996D7FCA241CE532 /* MMNetworkSocketsProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMNetworkSocketsProvider.m; sourceTree = "<group>"; };
+		DE40072F9A1F9DBD1C48A3B1 /* MMKernelTelemetryTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMKernelTelemetryTests.swift; sourceTree = "<group>"; };
 		E142AE61F9B87757997870DD /* ContentView.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ContentView.swift; sourceTree = "<group>"; };
 		E4B4E94FB2886C60D5548A2A /* SystemTelemetryStore.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = SystemTelemetryStore.swift; sourceTree = "<group>"; };
+		E6D9BB71DFE7384D0F0E6AA3 /* MMKernelTelemetryProvider.h */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.h; path = MMKernelTelemetryProvider.h; sourceTree = "<group>"; };
+		E9DAC4D5C09C974EE833DC7C /* MMDiskIOTests.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = MMDiskIOTests.swift; sourceTree = "<group>"; };
+		F444F4543F0A7421C8F8E636 /* MMKernelTelemetryProvider.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMKernelTelemetryProvider.m; sourceTree = "<group>"; };
 		F5EC59DCDA5FABDA409CDBCB /* MacMonitor.app */ = {isa = PBXFileReference; explicitFileType = wrapper.application; includeInIndex = 0; path = MacMonitor.app; sourceTree = BUILT_PRODUCTS_DIR; };
 		F9F9AD1268F906761032AF4D /* MMTelemetryCoordinator.m */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.c.objc; path = MMTelemetryCoordinator.m; sourceTree = "<group>"; };
 /* End PBXFileReference section */
@@ -79,6 +169,7 @@
 				4D8D8B40632C525CBC1D0E43 /* App */,
 				54787E6270EA7B9A1BE11359 /* Core */,
 				9844EC526E3527F6A582179F /* Hardware */,
+				8BF79E3BCB76E7A1669DC930 /* Telemetry */,
 				3E4A0B53C583BD0B7A68EACE /* UI */,
 			);
 			path = Sources;
@@ -112,6 +203,86 @@
 			path = Core;
 			sourceTree = "<group>";
 		};
+		65251E6B5694734BAAF1C1F1 /* Peripherals */ = {
+			isa = PBXGroup;
+			children = (
+				CDE2777944B8F12EC7D2EAB5 /* MMPeripheralsProvider.h */,
+				2E6A10A13A49E22E51862895 /* MMPeripheralsProvider.m */,
+			);
+			path = Peripherals;
+			sourceTree = "<group>";
+		};
+		78383CED205BCA772701AE48 /* CPU */ = {
+			isa = PBXGroup;
+			children = (
+				57845310A3D4EC67E48A3B11 /* MMCPULoadProvider.h */,
+				D68FC8100D08DB6202F46339 /* MMCPULoadProvider.m */,
+			);
+			path = CPU;
+			sourceTree = "<group>";
+		};
+		8719744C366432DD7C2B9644 /* Process */ = {
+			isa = PBXGroup;
+			children = (
+				1B07A683AD0EFBA8E1FB6C9D /* MMProcessDetailInspector.h */,
+				52E641F8A664D456518EDBA4 /* MMProcessDetailInspector.m */,
+				41478843A6B013478D94F739 /* MMProcessTelemetryProvider.h */,
+				728C692778909D2B7451C07B /* MMProcessTelemetryProvider.m */,
+			);
+			path = Process;
+			sourceTree = "<group>";
+		};
+		8B31CE7F9319FEC373E6CDC6 /* Power */ = {
+			isa = PBXGroup;
+			children = (
+				2DC6E55C9D3F646A1C62133D /* MMBatteryTelemetryProvider.h */,
+				9C92D0D2B62B3081ECCA9920 /* MMBatteryTelemetryProvider.m */,
+				CBA91906CA8B7936CC82A36B /* MMPowerTelemetryProvider.h */,
+				02F5FDE260999C39E978D849 /* MMPowerTelemetryProvider.m */,
+			);
+			path = Power;
+			sourceTree = "<group>";
+		};
+		8BF79E3BCB76E7A1669DC930 /* Telemetry */ = {
+			isa = PBXGroup;
+			children = (
+				92E1EF545807CF318620FEAA /* Audio */,
+				78383CED205BCA772701AE48 /* CPU */,
+				AD2995435E44FA3E1790A4F3 /* Fan */,
+				F99AF003017BA9F19F7AEB1E /* GPU */,
+				CA2F30473D63EC64CBD65437 /* Kernel */,
+				EE2F5EFC9DC33CEDA79A131F /* Memory */,
+				901D54FEAB6E9D6E787E599D /* Network */,
+				65251E6B5694734BAAF1C1F1 /* Peripherals */,
+				8B31CE7F9319FEC373E6CDC6 /* Power */,
+				8719744C366432DD7C2B9644 /* Process */,
+				B6EB3F6545276C40212C2992 /* Storage */,
+				A8658D19E71E34F1DDD87097 /* System */,
+				DBDC37231C01F0A2D4A7FC73 /* Thermal */,
+			);
+			path = Telemetry;
+			sourceTree = "<group>";
+		};
+		901D54FEAB6E9D6E787E599D /* Network */ = {
+			isa = PBXGroup;
+			children = (
+				3A14D7B97200EA4C102FEE67 /* MMNetworkBandwidthProvider.h */,
+				C539AEA27C794C6F428EA875 /* MMNetworkBandwidthProvider.m */,
+				0C94CCFBE8C9E1370368A28C /* MMNetworkSocketsProvider.h */,
+				D78F76C1996D7FCA241CE532 /* MMNetworkSocketsProvider.m */,
+			);
+			path = Network;
+			sourceTree = "<group>";
+		};
+		92E1EF545807CF318620FEAA /* Audio */ = {
+			isa = PBXGroup;
+			children = (
+				5C45D1EB09E045A53A154136 /* MMAudioTelemetryProvider.h */,
+				3189D2403E6E984D4924AE4D /* MMAudioTelemetryProvider.m */,
+			);
+			path = Audio;
+			sourceTree = "<group>";
+		};
 		9844EC526E3527F6A582179F /* Hardware */ = {
 			isa = PBXGroup;
 			children = (
@@ -120,6 +291,35 @@
 			path = Hardware;
 			sourceTree = "<group>";
 		};
+		A8658D19E71E34F1DDD87097 /* System */ = {
+			isa = PBXGroup;
+			children = (
+				2C55E977DBFBE7FF04621608 /* MMLoadAverageProvider.h */,
+				B5F2256DF514DD737306302B /* MMLoadAverageProvider.m */,
+			);
+			path = System;
+			sourceTree = "<group>";
+		};
+		AD2995435E44FA3E1790A4F3 /* Fan */ = {
+			isa = PBXGroup;
+			children = (
+				3CFC5B905E428A6B854E0AB4 /* MMFanTelemetryProvider.h */,
+				C9ED8F75E082D4F8AC2FF2F5 /* MMFanTelemetryProvider.m */,
+			);
+			path = Fan;
+			sourceTree = "<group>";
+		};
+		B6EB3F6545276C40212C2992 /* Storage */ = {
+			isa = PBXGroup;
+			children = (
+				AFA681E2464EA78CC19B54E0 /* MMDiskIOProvider.h */,
+				3E13917CAF525640D856ECD9 /* MMDiskIOProvider.m */,
+				46DE3AE12DAE26C4FE58034C /* MMStorageTelemetryProvider.h */,
+				6DCBCEA450103E2404761B78 /* MMStorageTelemetryProvider.m */,
+			);
+			path = Storage;
+			sourceTree = "<group>";
+		};
 		C80C3EEE8F912F4B214102E3 /* Products */ = {
 			isa = PBXGroup;
 			children = (
@@ -133,11 +333,49 @@
 			isa = PBXGroup;
 			children = (
 				2EC3EDFCD5C50CB352FCED87 /* MacMonitorTests.swift */,
+				10D16E1ABE6D28B676EA83FF /* MMAudioTests.swift */,
+				B0EB61D811D989279BCBE478 /* MMBatteryTests.swift */,
+				B288C7402E2C00E75F8CD016 /* MMComponentThermalTests.swift */,
+				4CE92B1A8D7FDBB6499448E1 /* MMCPULoadTests.swift */,
+				0F2BD3777A674DC4EB442890 /* MMCPUThermalTests.swift */,
+				E9DAC4D5C09C974EE833DC7C /* MMDiskIOTests.swift */,
+				336CEE35A745F3C7E9F70F43 /* MMFanTests.swift */,
+				80A0F723121CDF9597316F58 /* MMGPUTests.swift */,
+				DE40072F9A1F9DBD1C48A3B1 /* MMKernelTelemetryTests.swift */,
+				7EB05C092C94C3972727AAA7 /* MMLoadAverageTests.swift */,
+				099DCF7EF03A58ADA40A94A1 /* MMMemoryTests.swift */,
+				27C612287333D757C92A076A /* MMNetworkBandwidthTests.swift */,
+				374B1BF631CC4738CB52CA3B /* MMNetworkSocketsTests.swift */,
+				D1486E1512594482380CB492 /* MMPeripheralsTests.swift */,
+				D48698681374BD25B980C000 /* MMPowerTests.swift */,
+				7187632FF63B3B0D07FE9194 /* MMProcessDetailsTests.swift */,
+				52471E871E5CC1E444318070 /* MMProcessTests.swift */,
 				940D608A1AF80F75584E744E /* MMSMCTests.swift */,
+				78325870C7CD8312AECA2236 /* MMStorageTests.swift */,
 			);
 			path = Tests;
 			sourceTree = "<group>";
 		};
+		CA2F30473D63EC64CBD65437 /* Kernel */ = {
+			isa = PBXGroup;
+			children = (
+				E6D9BB71DFE7384D0F0E6AA3 /* MMKernelTelemetryProvider.h */,
+				F444F4543F0A7421C8F8E636 /* MMKernelTelemetryProvider.m */,
+			);
+			path = Kernel;
+			sourceTree = "<group>";
+		};
+		DBDC37231C01F0A2D4A7FC73 /* Thermal */ = {
+			isa = PBXGroup;
+			children = (
+				09475741B5D0D4B89B863C3D /* MMComponentThermalProvider.h */,
+				C65F5835516BC2A65BCE25D2 /* MMComponentThermalProvider.m */,
+				D73CCC7B5E6BF1825EA68E2B /* MMCPUThermalProvider.h */,
+				62C377EFD025D6A6B5563E77 /* MMCPUThermalProvider.m */,
+			);
+			path = Thermal;
+			sourceTree = "<group>";
+		};
 		E012FBB26EF9E35A2FAF87E2 /* AppleSMC */ = {
 			isa = PBXGroup;
 			children = (
@@ -159,6 +397,24 @@
 			name = Frameworks;
 			sourceTree = "<group>";
 		};
+		EE2F5EFC9DC33CEDA79A131F /* Memory */ = {
+			isa = PBXGroup;
+			children = (
+				0130BD1E18972DF9E2955334 /* MMMemoryTelemetryProvider.h */,
+				991AEEAF262F3C6BE930BC77 /* MMMemoryTelemetryProvider.m */,
+			);
+			path = Memory;
+			sourceTree = "<group>";
+		};
+		F99AF003017BA9F19F7AEB1E /* GPU */ = {
+			isa = PBXGroup;
+			children = (
+				9DC54CCE276F93D5AF0A0C28 /* MMGPUTelemetryProvider.h */,
+				D61AB99733A4AA52459BA7C4 /* MMGPUTelemetryProvider.m */,
+			);
+			path = GPU;
+			sourceTree = "<group>";
+		};
 /* End PBXGroup section */
 
 /* Begin PBXNativeTarget section */
@@ -234,7 +490,25 @@
 			isa = PBXSourcesBuildPhase;
 			buildActionMask = 2147483647;
 			files = (
+				9D12825C7904FB0DAE664CA0 /* MMAudioTests.swift in Sources */,
+				BC487DB86227F09CB0603894 /* MMBatteryTests.swift in Sources */,
+				160334CC765E091A7CBE21AA /* MMCPULoadTests.swift in Sources */,
+				87818E46CEA5145A8215D0E3 /* MMCPUThermalTests.swift in Sources */,
+				57BA02AE1CE24DBD02BD03A4 /* MMComponentThermalTests.swift in Sources */,
+				6A4FDB46AE5E0DAF85CCAB56 /* MMDiskIOTests.swift in Sources */,
+				E6F2F695B8D3E7045967C082 /* MMFanTests.swift in Sources */,
+				AE3C28BDC3CEF40A9E8F2B20 /* MMGPUTests.swift in Sources */,
+				901EF4853E785A2856E54BC9 /* MMKernelTelemetryTests.swift in Sources */,
+				ACC914C61AB3762EB0C40513 /* MMLoadAverageTests.swift in Sources */,
+				6201FD599FED061F6C736E8B /* MMMemoryTests.swift in Sources */,
+				5D31906EA986E2BA92E86FA8 /* MMNetworkBandwidthTests.swift in Sources */,
+				4C1A92F4DEF4C824976115C2 /* MMNetworkSocketsTests.swift in Sources */,
+				22CA7351A745F7837E487051 /* MMPeripheralsTests.swift in Sources */,
+				9B5C651AD2AF7DE2738F0C44 /* MMPowerTests.swift in Sources */,
+				3BA6709B727B1AAC6C4310B5 /* MMProcessDetailsTests.swift in Sources */,
+				7C9AE2ADAED52E593B52F3AE /* MMProcessTests.swift in Sources */,
 				EC9FA3E4A119277B89E73F8D /* MMSMCTests.swift in Sources */,
+				1B15F48F6B19E9EA4556ECD5 /* MMStorageTests.swift in Sources */,
 				9BCE74C5454F81EF80492E75 /* MacMonitorTests.swift in Sources */,
 			);
 			runOnlyForDeploymentPostprocessing = 0;
@@ -245,7 +519,25 @@
 			files = (
 				A9FCAEC0BF27A419DB148C4A /* ContentView.swift in Sources */,
 				CD91FC663B19DA1FEA3D49D7 /* MMAppleSMCClient.m in Sources */,
+				D7784A61FE4635275CFB3D6C /* MMAudioTelemetryProvider.m in Sources */,
+				8EDDC2171C55B6E7FC999DAB /* MMBatteryTelemetryProvider.m in Sources */,
+				4419FE7554489B23976E2970 /* MMCPULoadProvider.m in Sources */,
+				87A9E18362486D0D385BBC4A /* MMCPUThermalProvider.m in Sources */,
+				925245C5B5F8D8DA3C89C4BA /* MMComponentThermalProvider.m in Sources */,
+				FED88F290A2F2FBD63DDEC31 /* MMDiskIOProvider.m in Sources */,
+				655366D7066478A02EDA91BB /* MMFanTelemetryProvider.m in Sources */,
+				6D973241BBE61F0B053239DB /* MMGPUTelemetryProvider.m in Sources */,
+				A521961E035DD50ED8B0C1A9 /* MMKernelTelemetryProvider.m in Sources */,
+				951DBA5D3BBAB753322A5DF9 /* MMLoadAverageProvider.m in Sources */,
+				B9C2D6574E808B517BA34C83 /* MMMemoryTelemetryProvider.m in Sources */,
+				E3CCE93A7D4D1EB0187D3E52 /* MMNetworkBandwidthProvider.m in Sources */,
+				A599E974E56F0B8D94A7E480 /* MMNetworkSocketsProvider.m in Sources */,
+				4752C49841375B88194F7635 /* MMPeripheralsProvider.m in Sources */,
+				0A7117B3B7CC7112F2527574 /* MMPowerTelemetryProvider.m in Sources */,
+				2C0F7AB93691ED8AA86FBCF0 /* MMProcessDetailInspector.m in Sources */,
+				93EF83FE087C6DEAAE3EC0CC /* MMProcessTelemetryProvider.m in Sources */,
 				1B3F1C8ABF0ADFAA290FF6F6 /* MMSMCParser.m in Sources */,
+				F2F7A141F2452EC1B4FB45D8 /* MMStorageTelemetryProvider.m in Sources */,
 				EAFAF5A10502D4ACC64F4720 /* MMTelemetryCoordinator.m in Sources */,
 				88387CDAE2AC1CC74EF89B57 /* MacMonitorApp.swift in Sources */,
 				A7609CE56D49EC3419987468 /* SystemTelemetryStore.swift in Sources */,

Sources/App/SystemTelemetryStore.swift

@@ -2,6 +2,224 @@ import Foundation
 import SwiftUI
 import Observation
 
+// MARK: - Typed Telemetry Models
+
+public struct CPULoadMetrics: Sendable {
+    public var systemLoad: Double = 0
+    public var userLoad: Double = 0
+    public var idleLoad: Double = 100
+    public var totalLoad: Double = 0
+    public var perCoreLoad: [Double] = []
+    public var cpuFrequencyMHz: Double = 0
+    public var isThrottled: Bool = false
+}
+
+public struct MemoryMetrics: Sendable {
+    public var totalBytes: UInt64 = 0
+    public var usedBytes: UInt64 = 0
+    public var freeBytes: UInt64 = 0
+    public var activeBytes: UInt64 = 0
+    public var inactiveBytes: UInt64 = 0
+    public var wiredBytes: UInt64 = 0
+    public var compressedBytes: UInt64 = 0
+    public var swapTotalBytes: UInt64 = 0
+    public var swapUsedBytes: UInt64 = 0
+    public var utilizationPercentage: Double = 0
+    public var pressureLevel: String = "Normal"
+}
+
+public struct StorageVolumeItem: Identifiable, Sendable {
+    public var id: String { mountPoint }
+    public let mountPoint: String
+    public let volumeName: String
+    public let fileSystem: String
+    public let totalBytes: UInt64
+    public let freeBytes: UInt64
+    public let usedBytes: UInt64
+    public let usedPercentage: Double
+    public let isReadOnly: Bool
+}
+
+public struct CPUThermalMetrics: Sendable {
+    public var packageTemperature: Double = 0
+    public var averageCoreTemperature: Double = 0
+    public var peakCoreTemperature: Double = 0
+    public var coreTemperatures: [(index: Int, key: String, temperature: Double)] = []
+    public var thermalPressureState: String = "Nominal"
+    public var isThrottling: Bool = false
+}
+
+public struct FanTelemetryItem: Identifiable, Sendable {
+    public var id: Int { index }
+    public let index: Int
+    public let name: String
+    public let currentRPM: Double
+    public let minRPM: Double
+    public let maxRPM: Double
+    public let targetRPM: Double
+    public let utilization: Double
+}
+
+public struct ComponentThermalItem: Identifiable, Sendable {
+    public var id: String { key }
+    public let key: String
+    public let name: String
+    public let category: String
+    public let temperature: Double
+}
+
+public struct PowerMetrics: Sendable {
+    public var systemTotalWatts: Double = 0
+    public var cpuWatts: Double = 0
+    public var gpuWatts: Double = 0
+    public var memoryWatts: Double = 0
+    public var cpuVoltage: Double = 0
+    public var cpuCurrent: Double = 0
+    public var powerSource: String = "AC Power"
+    public var isCharging: Bool = false
+    public var batteryLevel: Double = 100.0
+    public var sensorReadings: [(key: String, name: String, value: Double, unit: String)] = []
+}
+
+// MARK: - Milestone 3 Advanced Telemetry Models
+
+public struct KernelCountersMetrics: Sendable {
+    public var contextSwitchesPerSec: Double = 0
+    public var syscallsPerSec: Double = 0
+    public var pageFaultsPerSec: Double = 0
+    public var cowFaultsPerSec: Double = 0
+    public var zeroFillFaultsPerSec: Double = 0
+    public var pageinsPerSec: Double = 0
+    public var pageoutsPerSec: Double = 0
+    public var totalContextSwitches: UInt64 = 0
+    public var totalSyscalls: UInt64 = 0
+    public var totalPageFaults: UInt64 = 0
+}
+
+public struct SystemLoadMetrics: Sendable {
+    public var load1Min: Double = 0
+    public var load5Min: Double = 0
+    public var load15Min: Double = 0
+    public var taskCount: Int = 0
+    public var threadCount: Int = 0
+    public var machFactor: Double = 0
+}
+
+public struct DiskIOItem: Identifiable, Sendable {
+    public var id: String { bsdName }
+    public let bsdName: String
+    public let readBps: Double
+    public let writeBps: Double
+    public let readIOPS: Double
+    public let writeIOPS: Double
+    public let totalBytesRead: UInt64
+    public let totalBytesWritten: UInt64
+}
+
+public struct NetworkBandwidthItem: Identifiable, Sendable {
+    public var id: String { interfaceName }
+    public let interfaceName: String
+    public let ipAddress: String
+    public let isUp: Bool
+    public let downloadBps: Double
+    public let uploadBps: Double
+    public let downloadPps: Double
+    public let uploadPps: Double
+    public let totalBytesIn: UInt64
+    public let totalBytesOut: UInt64
+}
+
+public struct SocketItem: Identifiable, Sendable {
+    public var id: String { "\(pid)_\(fd)_\(localAddress):\(localPort)" }
+    public let pid: Int32
+    public let fd: Int32
+    public let processName: String
+    public let protocolName: String
+    public let localAddress: String
+    public let localPort: UInt16
+    public let remoteAddress: String
+    public let remotePort: UInt16
+    public let tcpState: String
+}
+
+public struct ProcessItem: Identifiable, Sendable {
+    public var id: Int32 { pid }
+    public let pid: Int32
+    public let ppid: Int32
+    public let name: String
+    public let cpuPercent: Double
+    public let residentSize: UInt64
+    public let virtualSize: UInt64
+    public let threadCount: Int32
+    public let uid: UInt32
+    public let username: String
+    public let isStopped: Bool
+    public let isZombie: Bool
+}
+
+public struct GPUCardItem: Identifiable, Sendable {
+    public var id: String { name }
+    public let name: String
+    public let isDiscrete: Bool
+    public let isLowPower: Bool
+    public let vramTotalBytes: UInt64
+    public let vramUsedBytes: UInt64
+    public let utilizationPercent: Double
+    public let temperature: Double
+}
+
+public struct BatteryHealthMetrics: Sendable {
+    public var hasBattery: Bool = false
+    public var installed: Bool = false
+    public var healthCondition: String = "Normal"
+    public var healthPercent: Double = 100.0
+    public var cycleCount: Int = 0
+    public var designCycleCount: Int = 1000
+    public var currentCapacity: Int = 0
+    public var maxCapacity: Int = 0
+    public var designCapacity: Int = 0
+    public var temperature: Double = 0
+    public var voltage: Double = 0
+    public var amperage: Double = 0
+    public var watts: Double = 0
+    public var isCharging: Bool = false
+    public var isCharged: Bool = false
+    public var externalConnected: Bool = false
+    public var timeRemainingMinutes: Int = -1
+    public var manufacturer: String = "Apple"
+    public var serial: String = ""
+    public var adapterWatts: Int = 0
+}
+
+public struct PeripheralDeviceItem: Identifiable, Sendable {
+    public var id: String { "\(busType)_\(locationID)_\(name)" }
+    public let name: String
+    public let busType: String
+    public let vendorName: String
+    public let vendorID: UInt32
+    public let productID: UInt32
+    public let serialNumber: String
+    public let locationID: UInt64
+    public let isBuiltIn: Bool
+}
+
+public struct AudioDeviceItem: Identifiable, Sendable {
+    public var id: UInt32 { deviceID }
+    public let deviceID: UInt32
+    public let name: String
+    public let manufacturer: String
+    public let isInput: Bool
+    public let isOutput: Bool
+    public let isDefaultInput: Bool
+    public let isDefaultOutput: Bool
+    public let sampleRate: Double
+    public let channelCount: UInt32
+    public let volume: Float
+    public let isMuted: Bool
+}
+
+// MARK: - SystemTelemetryStore
+
 @Observable
 @MainActor
 public final class SystemTelemetryStore {
@@ -14,6 +232,30 @@ public final class SystemTelemetryStore {
     /// Raw snapshots organized by provider identifier
     public private(set) var latestSnapshot: [String: [String: Any]] = [:]
     
+    /// Milestone 2 Structured Metrics
+    public private(set) var cpuLoad = CPULoadMetrics()
+    public private(set) var memory = MemoryMetrics()
+    public private(set) var storageVolumes: [StorageVolumeItem] = []
+    public private(set) var cpuThermal = CPUThermalMetrics()
+    public private(set) var fans: [FanTelemetryItem] = []
+    public private(set) var componentTemps: [ComponentThermalItem] = []
+    public private(set) var power = PowerMetrics()
+    
+    /// Milestone 3 Structured Metrics
+    public private(set) var kernelCounters = KernelCountersMetrics()
+    public private(set) var systemLoad = SystemLoadMetrics()
+    public private(set) var diskIO: [DiskIOItem] = []
+    public private(set) var networkBandwidth: [NetworkBandwidthItem] = []
+    public private(set) var networkSockets: [SocketItem] = []
+    public private(set) var processes: [ProcessItem] = []
+    public private(set) var gpus: [GPUCardItem] = []
+    public private(set) var batteryHealth = BatteryHealthMetrics()
+    public private(set) var peripherals: [PeripheralDeviceItem] = []
+    public private(set) var audioDevices: [AudioDeviceItem] = []
+    
+    /// Process detail inspection helper
+    public let processInspector = MMProcessDetailInspector()
+    
     /// System identification
     public let hostModel: String
     public let osVersion: String
@@ -30,18 +272,393 @@ public final class SystemTelemetryStore {
         self.physicalCpuCount = SystemTelemetryStore.readSysctlInt("hw.physicalcpu") ?? 1
         self.logicalCpuCount = SystemTelemetryStore.readSysctlInt("hw.logicalcpu") ?? 1
         
+        registerDefaultProviders()
         setupCoordinator()
     }
     
+    private func registerDefaultProviders() {
+        // Milestone 2 Primary System & Thermal Telemetry
+        coordinator.register(MMCPULoadProvider())
+        coordinator.register(MMMemoryTelemetryProvider())
+        coordinator.register(MMStorageTelemetryProvider())
+        coordinator.register(MMCPUThermalProvider())
+        coordinator.register(MMFanTelemetryProvider())
+        coordinator.register(MMComponentThermalProvider())
+        coordinator.register(MMPowerTelemetryProvider())
+        
+        // Milestone 3 Advanced Kernel, Process & Peripheral Telemetry
+        coordinator.register(MMKernelTelemetryProvider())
+        coordinator.register(MMLoadAverageProvider())
+        coordinator.register(MMDiskIOProvider())
+        coordinator.register(MMNetworkBandwidthProvider())
+        coordinator.register(MMNetworkSocketsProvider())
+        coordinator.register(MMProcessTelemetryProvider())
+        coordinator.register(MMGPUTelemetryProvider())
+        coordinator.register(MMBatteryTelemetryProvider())
+        coordinator.register(MMPeripheralsProvider())
+        coordinator.register(MMAudioTelemetryProvider())
+    }
+    
     private func setupCoordinator() {
         coordinator.sampleInterval = self.sampleInterval
         coordinator.snapshotHandler = { [weak self] snapshot in
             guard let self else { return }
             self.latestSnapshot = snapshot
             self.lastUpdateTimestamp = Date()
+            self.decodeSnapshot(snapshot)
         }
     }
     
+    private func decodeSnapshot(_ snapshot: [String: [String: Any]]) {
+        // 1. CPU Load
+        if let cpuDict = snapshot["com.i3omb.macmonitor.telemetry.cpu"] {
+            var m = CPULoadMetrics()
+            m.systemLoad = (cpuDict["systemLoad"] as? NSNumber)?.doubleValue ?? 0
+            m.userLoad = (cpuDict["userLoad"] as? NSNumber)?.doubleValue ?? 0
+            m.idleLoad = (cpuDict["idleLoad"] as? NSNumber)?.doubleValue ?? 100
+            m.totalLoad = (cpuDict["totalLoad"] as? NSNumber)?.doubleValue ?? 0
+            if let perCore = cpuDict["perCoreLoad"] as? [NSNumber] {
+                m.perCoreLoad = perCore.map { $0.doubleValue }
+            }
+            m.cpuFrequencyMHz = (cpuDict["cpuFrequencyMHz"] as? NSNumber)?.doubleValue ?? 0
+            m.isThrottled = (cpuDict["isThrottled"] as? NSNumber)?.boolValue ?? false
+            self.cpuLoad = m
+        }
+        
+        // 2. Memory
+        if let memDict = snapshot["com.i3omb.macmonitor.telemetry.memory"] {
+            var m = MemoryMetrics()
+            m.totalBytes = (memDict["totalBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.usedBytes = (memDict["usedBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.freeBytes = (memDict["freeBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.activeBytes = (memDict["activeBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.inactiveBytes = (memDict["inactiveBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.wiredBytes = (memDict["wiredBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.compressedBytes = (memDict["compressedBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.swapTotalBytes = (memDict["swapTotalBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.swapUsedBytes = (memDict["swapUsedBytes"] as? NSNumber)?.uint64Value ?? 0
+            m.utilizationPercentage = (memDict["utilizationPercentage"] as? NSNumber)?.doubleValue ?? 0
+            m.pressureLevel = memDict["pressureLevel"] as? String ?? "Normal"
+            self.memory = m
+        }
+        
+        // 3. Storage Volumes
+        if let stgDict = snapshot["com.i3omb.macmonitor.telemetry.storage"],
+           let volArray = stgDict["volumes"] as? [[String: Any]] {
+            self.storageVolumes = volArray.compactMap { dict in
+                guard let mount = dict["mountPoint"] as? String else { return nil }
+                return StorageVolumeItem(
+                    mountPoint: mount,
+                    volumeName: dict["volumeName"] as? String ?? mount,
+                    fileSystem: dict["fileSystem"] as? String ?? "APFS",
+                    totalBytes: (dict["totalBytes"] as? NSNumber)?.uint64Value ?? 0,
+                    freeBytes: (dict["freeBytes"] as? NSNumber)?.uint64Value ?? 0,
+                    usedBytes: (dict["usedBytes"] as? NSNumber)?.uint64Value ?? 0,
+                    usedPercentage: (dict["usedPercentage"] as? NSNumber)?.doubleValue ?? 0,
+                    isReadOnly: (dict["isReadOnly"] as? NSNumber)?.boolValue ?? false
+                )
+            }
+        }
+        
+        // 4. CPU Thermal
+        if let thDict = snapshot["com.i3omb.macmonitor.telemetry.thermal.cpu"] {
+            var m = CPUThermalMetrics()
+            m.packageTemperature = (thDict["packageTemperature"] as? NSNumber)?.doubleValue ?? 0
+            m.averageCoreTemperature = (thDict["averageCoreTemperature"] as? NSNumber)?.doubleValue ?? 0
+            m.peakCoreTemperature = (thDict["peakCoreTemperature"] as? NSNumber)?.doubleValue ?? 0
+            m.thermalPressureState = thDict["thermalPressureState"] as? String ?? "Nominal"
+            m.isThrottling = (thDict["isThrottling"] as? NSNumber)?.boolValue ?? false
+            if let coresList = thDict["coreTemperatures"] as? [[String: Any]] {
+                m.coreTemperatures = coresList.compactMap { d in
+                    let idx = (d["coreIndex"] as? NSNumber)?.intValue ?? 0
+                    let key = d["key"] as? String ?? "TC\(idx)C"
+                    let temp = (d["temperature"] as? NSNumber)?.doubleValue ?? 0
+                    return (index: idx, key: key, temperature: temp)
+                }
+            }
+            self.cpuThermal = m
+        }
+        
+        // 5. Fans
+        if let fanDict = snapshot["com.i3omb.macmonitor.telemetry.fan"],
+           let fanArray = fanDict["fans"] as? [[String: Any]] {
+            self.fans = fanArray.compactMap { d in
+                let idx = (d["index"] as? NSNumber)?.intValue ?? 0
+                return FanTelemetryItem(
+                    index: idx,
+                    name: d["name"] as? String ?? "Fan \(idx + 1)",
+                    currentRPM: (d["currentRPM"] as? NSNumber)?.doubleValue ?? 0,
+                    minRPM: (d["minRPM"] as? NSNumber)?.doubleValue ?? 0,
+                    maxRPM: (d["maxRPM"] as? NSNumber)?.doubleValue ?? 0,
+                    targetRPM: (d["targetRPM"] as? NSNumber)?.doubleValue ?? 0,
+                    utilization: (d["utilization"] as? NSNumber)?.doubleValue ?? 0
+                )
+            }
+        }
+        
+        // 6. Component Thermals
+        if let compDict = snapshot["com.i3omb.macmonitor.telemetry.thermal.components"],
+           let compArray = compDict["components"] as? [[String: Any]] {
+            self.componentTemps = compArray.compactMap { d in
+                guard let key = d["key"] as? String else { return nil }
+                return ComponentThermalItem(
+                    key: key,
+                    name: d["name"] as? String ?? key,
+                    category: d["category"] as? String ?? "Other",
+                    temperature: (d["temperature"] as? NSNumber)?.doubleValue ?? 0
+                )
+            }
+        }
+        
+        // 7. Power
+        if let pwrDict = snapshot["com.i3omb.macmonitor.telemetry.power"] {
+            var m = PowerMetrics()
+            m.systemTotalWatts = (pwrDict["systemTotalWatts"] as? NSNumber)?.doubleValue ?? 0
+            m.cpuWatts = (pwrDict["cpuWatts"] as? NSNumber)?.doubleValue ?? 0
+            m.gpuWatts = (pwrDict["gpuWatts"] as? NSNumber)?.doubleValue ?? 0
+            m.memoryWatts = (pwrDict["memoryWatts"] as? NSNumber)?.doubleValue ?? 0
+            m.cpuVoltage = (pwrDict["cpuVoltage"] as? NSNumber)?.doubleValue ?? 0
+            m.cpuCurrent = (pwrDict["cpuCurrent"] as? NSNumber)?.doubleValue ?? 0
+            m.powerSource = pwrDict["powerSource"] as? String ?? "AC Power"
+            m.isCharging = (pwrDict["isCharging"] as? NSNumber)?.boolValue ?? false
+            m.batteryLevel = (pwrDict["batteryLevel"] as? NSNumber)?.doubleValue ?? 100.0
+            if let sensorList = pwrDict["sensors"] as? [[String: Any]] {
+                m.sensorReadings = sensorList.compactMap { d in
+                    guard let k = d["key"] as? String else { return nil }
+                    let n = d["name"] as? String ?? k
+                    let v = (d["value"] as? NSNumber)?.doubleValue ?? 0
+                    let u = d["unit"] as? String ?? ""
+                    return (key: k, name: n, value: v, unit: u)
+                }
+            }
+            self.power = m
+        }
+        
+        // 8. Kernel Counters
+        if let kDict = snapshot["com.i3omb.macmonitor.telemetry.kernel"] {
+            var m = KernelCountersMetrics()
+            m.contextSwitchesPerSec = (kDict["contextSwitchesPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.syscallsPerSec = (kDict["syscallsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.pageFaultsPerSec = (kDict["pageFaultsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.cowFaultsPerSec = (kDict["cowFaultsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.zeroFillFaultsPerSec = (kDict["zeroFillFaultsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.pageinsPerSec = (kDict["pageinsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.pageoutsPerSec = (kDict["pageoutsPerSec"] as? NSNumber)?.doubleValue ?? 0
+            m.totalContextSwitches = (kDict["totalContextSwitches"] as? NSNumber)?.uint64Value ?? 0
+            m.totalSyscalls = (kDict["totalSyscalls"] as? NSNumber)?.uint64Value ?? 0
+            m.totalPageFaults = (kDict["totalPageFaults"] as? NSNumber)?.uint64Value ?? 0
+            self.kernelCounters = m
+        }
+        
+        // 9. System Load Average & Mach Factor
+        if let loadDict = snapshot["com.i3omb.macmonitor.telemetry.systemload"] {
+            var m = SystemLoadMetrics()
+            m.load1Min = (loadDict["load1Min"] as? NSNumber)?.doubleValue ?? 0
+            m.load5Min = (loadDict["load5Min"] as? NSNumber)?.doubleValue ?? 0
+            m.load15Min = (loadDict["load15Min"] as? NSNumber)?.doubleValue ?? 0
+            m.taskCount = (loadDict["taskCount"] as? NSNumber)?.intValue ?? 0
+            m.threadCount = (loadDict["threadCount"] as? NSNumber)?.intValue ?? 0
+            m.machFactor = (loadDict["machFactor"] as? NSNumber)?.doubleValue ?? 0
+            self.systemLoad = m
+        }
+        
+        // 10. Disk I/O & IOPS
+        if let diskDict = snapshot["com.i3omb.macmonitor.telemetry.diskio"],
+           let disks = diskDict["disks"] as? [[String: Any]] {
+            self.diskIO = disks.compactMap { d in
+                guard let bsd = d["bsdName"] as? String else { return nil }
+                return DiskIOItem(
+                    bsdName: bsd,
+                    readBps: (d["readBps"] as? NSNumber)?.doubleValue ?? 0,
+                    writeBps: (d["writeBps"] as? NSNumber)?.doubleValue ?? 0,
+                    readIOPS: (d["readIOPS"] as? NSNumber)?.doubleValue ?? 0,
+                    writeIOPS: (d["writeIOPS"] as? NSNumber)?.doubleValue ?? 0,
+                    totalBytesRead: (d["totalBytesRead"] as? NSNumber)?.uint64Value ?? 0,
+                    totalBytesWritten: (d["totalBytesWritten"] as? NSNumber)?.uint64Value ?? 0
+                )
+            }
+        }
+        
+        // 11. Network Bandwidth
+        if let netDict = snapshot["com.i3omb.macmonitor.telemetry.network.bandwidth"],
+           let ifaces = netDict["interfaces"] as? [[String: Any]] {
+            self.networkBandwidth = ifaces.compactMap { d in
+                guard let name = d["interfaceName"] as? String else { return nil }
+                return NetworkBandwidthItem(
+                    interfaceName: name,
+                    ipAddress: d["ipAddress"] as? String ?? "",
+                    isUp: (d["isUp"] as? NSNumber)?.boolValue ?? false,
+                    downloadBps: (d["downloadBps"] as? NSNumber)?.doubleValue ?? 0,
+                    uploadBps: (d["uploadBps"] as? NSNumber)?.doubleValue ?? 0,
+                    downloadPps: (d["downloadPps"] as? NSNumber)?.doubleValue ?? 0,
+                    uploadPps: (d["uploadPps"] as? NSNumber)?.doubleValue ?? 0,
+                    totalBytesIn: (d["totalBytesIn"] as? NSNumber)?.uint64Value ?? 0,
+                    totalBytesOut: (d["totalBytesOut"] as? NSNumber)?.uint64Value ?? 0
+                )
+            }
+        }
+        
+        // 12. Network Sockets
+        if let sockDict = snapshot["com.i3omb.macmonitor.telemetry.network.sockets"],
+           let socks = sockDict["sockets"] as? [[String: Any]] {
+            self.networkSockets = socks.compactMap { d in
+                let pid = (d["pid"] as? NSNumber)?.int32Value ?? 0
+                let fd = (d["fd"] as? NSNumber)?.int32Value ?? 0
+                return SocketItem(
+                    pid: pid,
+                    fd: fd,
+                    processName: d["processName"] as? String ?? "",
+                    protocolName: d["protocol"] as? String ?? "TCP",
+                    localAddress: d["localAddress"] as? String ?? "*",
+                    localPort: (d["localPort"] as? NSNumber)?.uint16Value ?? 0,
+                    remoteAddress: d["remoteAddress"] as? String ?? "*",
+                    remotePort: (d["remotePort"] as? NSNumber)?.uint16Value ?? 0,
+                    tcpState: d["tcpState"] as? String ?? "ESTABLISHED"
+                )
+            }
+        }
+        
+        // 13. Processes
+        if let procDict = snapshot["com.i3omb.macmonitor.telemetry.process"],
+           let procs = procDict["processes"] as? [[String: Any]] {
+            self.processes = procs.compactMap { d in
+                guard let pid = (d["pid"] as? NSNumber)?.int32Value else { return nil }
+                return ProcessItem(
+                    pid: pid,
+                    ppid: (d["ppid"] as? NSNumber)?.int32Value ?? 0,
+                    name: d["name"] as? String ?? "Unknown",
+                    cpuPercent: (d["cpuPercent"] as? NSNumber)?.doubleValue ?? 0,
+                    residentSize: (d["residentSize"] as? NSNumber)?.uint64Value ?? 0,
+                    virtualSize: (d["virtualSize"] as? NSNumber)?.uint64Value ?? 0,
+                    threadCount: (d["threadCount"] as? NSNumber)?.int32Value ?? 1,
+                    uid: (d["uid"] as? NSNumber)?.uint32Value ?? 0,
+                    username: d["username"] as? String ?? "",
+                    isStopped: (d["isStopped"] as? NSNumber)?.boolValue ?? false,
+                    isZombie: (d["isZombie"] as? NSNumber)?.boolValue ?? false
+                )
+            }
+        }
+        
+        // 14. GPU Telemetry
+        if let gpuDict = snapshot["com.i3omb.macmonitor.telemetry.gpu"],
+           let cards = gpuDict["gpus"] as? [[String: Any]] {
+            self.gpus = cards.compactMap { d in
+                guard let name = d["name"] as? String else { return nil }
+                return GPUCardItem(
+                    name: name,
+                    isDiscrete: (d["isDiscrete"] as? NSNumber)?.boolValue ?? false,
+                    isLowPower: (d["isLowPower"] as? NSNumber)?.boolValue ?? false,
+                    vramTotalBytes: (d["vramTotalBytes"] as? NSNumber)?.uint64Value ?? 0,
+                    vramUsedBytes: (d["vramUsedBytes"] as? NSNumber)?.uint64Value ?? 0,
+                    utilizationPercent: (d["utilizationPercent"] as? NSNumber)?.doubleValue ?? 0,
+                    temperature: (d["temperature"] as? NSNumber)?.doubleValue ?? 0
+                )
+            }
+        }
+        
+        // 15. Battery Health
+        if let battDict = snapshot["com.i3omb.macmonitor.telemetry.battery"] {
+            var m = BatteryHealthMetrics()
+            m.hasBattery = (battDict["hasBattery"] as? NSNumber)?.boolValue ?? false
+            m.installed = (battDict["installed"] as? NSNumber)?.boolValue ?? false
+            m.healthCondition = battDict["healthCondition"] as? String ?? "Normal"
+            m.healthPercent = (battDict["healthPercent"] as? NSNumber)?.doubleValue ?? 100.0
+            m.cycleCount = (battDict["cycleCount"] as? NSNumber)?.intValue ?? 0
+            m.designCycleCount = (battDict["designCycleCount"] as? NSNumber)?.intValue ?? 1000
+            m.currentCapacity = (battDict["currentCapacity"] as? NSNumber)?.intValue ?? 0
+            m.maxCapacity = (battDict["maxCapacity"] as? NSNumber)?.intValue ?? 0
+            m.designCapacity = (battDict["designCapacity"] as? NSNumber)?.intValue ?? 0
+            m.temperature = (battDict["temperature"] as? NSNumber)?.doubleValue ?? 0
+            m.voltage = (battDict["voltage"] as? NSNumber)?.doubleValue ?? 0
+            m.amperage = (battDict["amperage"] as? NSNumber)?.doubleValue ?? 0
+            m.watts = (battDict["watts"] as? NSNumber)?.doubleValue ?? 0
+            m.isCharging = (battDict["isCharging"] as? NSNumber)?.boolValue ?? false
+            m.isCharged = (battDict["isCharged"] as? NSNumber)?.boolValue ?? false
+            m.externalConnected = (battDict["externalConnected"] as? NSNumber)?.boolValue ?? false
+            m.timeRemainingMinutes = (battDict["timeRemainingMinutes"] as? NSNumber)?.intValue ?? -1
+            m.manufacturer = battDict["manufacturer"] as? String ?? "Apple"
+            m.serial = battDict["serial"] as? String ?? ""
+            m.adapterWatts = (battDict["adapterWatts"] as? NSNumber)?.intValue ?? 0
+            self.batteryHealth = m
+        }
+        
+        // 16. Connected Peripherals
+        if let periphDict = snapshot["com.i3omb.macmonitor.telemetry.peripherals"] {
+            var allDevs: [PeripheralDeviceItem] = []
+            if let usb = periphDict["usbDevices"] as? [[String: Any]] {
+                allDevs.append(contentsOf: usb.compactMap { d in
+                    guard let name = d["name"] as? String else { return nil }
+                    return PeripheralDeviceItem(
+                        name: name,
+                        busType: "USB",
+                        vendorName: d["vendorName"] as? String ?? "",
+                        vendorID: (d["vendorID"] as? NSNumber)?.uint32Value ?? 0,
+                        productID: (d["productID"] as? NSNumber)?.uint32Value ?? 0,
+                        serialNumber: d["serialNumber"] as? String ?? "",
+                        locationID: (d["locationID"] as? NSNumber)?.uint64Value ?? 0,
+                        isBuiltIn: (d["isBuiltIn"] as? NSNumber)?.boolValue ?? false
+                    )
+                })
+            }
+            if let tb = periphDict["thunderboltDevices"] as? [[String: Any]] {
+                allDevs.append(contentsOf: tb.compactMap { d in
+                    guard let name = d["name"] as? String else { return nil }
+                    return PeripheralDeviceItem(
+                        name: name,
+                        busType: "Thunderbolt",
+                        vendorName: d["vendorName"] as? String ?? "",
+                        vendorID: (d["vendorID"] as? NSNumber)?.uint32Value ?? 0,
+                        productID: (d["productID"] as? NSNumber)?.uint32Value ?? 0,
+                        serialNumber: "",
+                        locationID: 0,
+                        isBuiltIn: false
+                    )
+                })
+            }
+            if let pci = periphDict["pciDevices"] as? [[String: Any]] {
+                allDevs.append(contentsOf: pci.compactMap { d in
+                    guard let name = d["name"] as? String else { return nil }
+                    return PeripheralDeviceItem(
+                        name: name,
+                        busType: "PCI",
+                        vendorName: "Apple / Intel",
+                        vendorID: (d["vendorID"] as? NSNumber)?.uint32Value ?? 0,
+                        productID: (d["productID"] as? NSNumber)?.uint32Value ?? 0,
+                        serialNumber: "",
+                        locationID: 0,
+                        isBuiltIn: true
+                    )
+                })
+            }
+            self.peripherals = allDevs
+        }
+        
+        // 17. Audio Devices
+        if let audioDict = snapshot["com.i3omb.macmonitor.telemetry.audio"],
+           let devs = audioDict["devices"] as? [[String: Any]] {
+            self.audioDevices = devs.compactMap { d in
+                guard let devID = (d["deviceID"] as? NSNumber)?.uint32Value else { return nil }
+                return AudioDeviceItem(
+                    deviceID: devID,
+                    name: d["name"] as? String ?? "Audio Device",
+                    manufacturer: d["manufacturer"] as? String ?? "Apple Inc.",
+                    isInput: (d["isInput"] as? NSNumber)?.boolValue ?? false,
+                    isOutput: (d["isOutput"] as? NSNumber)?.boolValue ?? false,
+                    isDefaultInput: (d["isDefaultInput"] as? NSNumber)?.boolValue ?? false,
+                    isDefaultOutput: (d["isDefaultOutput"] as? NSNumber)?.boolValue ?? false,
+                    sampleRate: (d["sampleRate"] as? NSNumber)?.doubleValue ?? 44100.0,
+                    channelCount: (d["channelCount"] as? NSNumber)?.uint32Value ?? 2,
+                    volume: (d["volume"] as? NSNumber)?.floatValue ?? 0,
+                    isMuted: (d["isMuted"] as? NSNumber)?.boolValue ?? false
+                )
+            }
+        }
+    }
+    
+    public func terminateProcess(pid: pid_t, force: Bool) -> Bool {
+        return MMProcessTelemetryProvider.terminateProcess(withPID: pid, force: force)
+    }
+    
     public func start() {
         coordinator.start()
         isRunning = coordinator.isRunning

Sources/Bridging/MacMonitor-Bridging-Header.h

@@ -11,4 +11,24 @@
 #import "MMSMCParser.h"
 #import "MMAppleSMCClient.h"
 
+// Telemetry Providers
+#import "MMCPULoadProvider.h"
+#import "MMMemoryTelemetryProvider.h"
+#import "MMStorageTelemetryProvider.h"
+#import "MMCPUThermalProvider.h"
+#import "MMFanTelemetryProvider.h"
+#import "MMComponentThermalProvider.h"
+#import "MMPowerTelemetryProvider.h"
+#import "MMKernelTelemetryProvider.h"
+#import "MMLoadAverageProvider.h"
+#import "MMDiskIOProvider.h"
+#import "MMNetworkBandwidthProvider.h"
+#import "MMNetworkSocketsProvider.h"
+#import "MMProcessTelemetryProvider.h"
+#import "MMProcessDetailInspector.h"
+#import "MMGPUTelemetryProvider.h"
+#import "MMBatteryTelemetryProvider.h"
+#import "MMPeripheralsProvider.h"
+#import "MMAudioTelemetryProvider.h"
+
 #endif /* MacMonitor_Bridging_Header_h */

Sources/Hardware/AppleSMC/MMSMCParser.m

@@ -40,6 +40,13 @@
            (uint32_t)bytes[3];
 }
 
+static int hexDigitValue(unichar c) {
+    if (c >= '0' && c <= '9') return c - '0';
+    if (c >= 'a' && c <= 'f') return c - 'a' + 10;
+    if (c >= 'A' && c <= 'F') return c - 'A' + 10;
+    return -1;
+}
+
 + (nullable NSNumber *)decodeValueWithDataType:(NSString *)dataType bytes:(const uint8_t *)bytes size:(NSUInteger)size {
     if (!bytes || size == 0) return nil;
     
@@ -49,7 +56,7 @@
         if (size >= 2) return @([self decodeSP78:bytes]);
     } else if ([trimmedType isEqualToString:@"fpe2"]) {
         if (size >= 2) return @([self decodeFPE2:bytes]);
-    } else if ([trimmedType isEqualToString:@"flt"]) {
+    } else if ([trimmedType isEqualToString:@"flt"] || [trimmedType isEqualToString:@"ioft"]) {
         if (size >= 4) return @([self decodeFLT:bytes]);
     } else if ([trimmedType isEqualToString:@"ui8"]) {
         if (size >= 1) return @([self decodeUI8:bytes]);
@@ -59,6 +66,18 @@
         if (size >= 4) return @([self decodeUI32:bytes]);
     } else if ([trimmedType isEqualToString:@"flag"]) {
         if (size >= 1) return @(bytes[0] != 0);
+    } else if (trimmedType.length == 4 && [trimmedType hasPrefix:@"sp"] && size >= 2) {
+        int fracBits = hexDigitValue([trimmedType characterAtIndex:3]);
+        if (fracBits >= 0 && fracBits <= 15) {
+            int16_t raw = (int16_t)(((uint16_t)bytes[0] << 8) | (uint16_t)bytes[1]);
+            return @((float)raw / (float)(1 << fracBits));
+        }
+    } else if (trimmedType.length == 4 && [trimmedType hasPrefix:@"fp"] && size >= 2) {
+        int fracBits = hexDigitValue([trimmedType characterAtIndex:3]);
+        if (fracBits >= 0 && fracBits <= 15) {
+            uint16_t raw = ((uint16_t)bytes[0] << 8) | (uint16_t)bytes[1];
+            return @((float)raw / (float)(1 << fracBits));
+        }
     }
     
     return nil;

Sources/Telemetry/Audio/MMAudioTelemetryProvider.h

@@ -0,0 +1,40 @@
+//
+//  MMAudioTelemetryProvider.h
+//  MacMonitor
+//
+//  Telemetry provider enumerating CoreAudio input/output devices, sample rates, volume, and active status.
+//
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+@interface MMAudioDevice : NSObject
+
+@property (nonatomic, assign) uint32_t deviceID;
+@property (nonatomic, copy) NSString *name;
+@property (nonatomic, copy) NSString *manufacturer;
+@property (nonatomic, copy) NSString *uid;
+@property (nonatomic, assign) BOOL isInput;
+@property (nonatomic, assign) BOOL isOutput;
+@property (nonatomic, assign) BOOL isDefaultInput;
+@property (nonatomic, assign) BOOL isDefaultOutput;
+@property (nonatomic, assign) double sampleRate;
+@property (nonatomic, assign) uint32_t channelCount;
+@property (nonatomic, assign) float volume;
+@property (nonatomic, assign) BOOL isMuted;
+
+- (NSDictionary<NSString *, id> *)toDictionary;
+
+@end
+
+@interface MMAudioTelemetryProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
++ (NSArray<MMAudioDevice *> *)sampleAudioDevices;
+
+@end
+
+NS_ASSUME_NONNULL_END

Sources/Telemetry/Audio/MMAudioTelemetryProvider.m

@@ -0,0 +1,232 @@
+//
+//  MMAudioTelemetryProvider.m
+//  MacMonitor
+//
+//  Telemetry provider enumerating CoreAudio input/output devices, sample rates, volume, and active status.
+//
+
+#import "MMAudioTelemetryProvider.h"
+#import <CoreAudio/CoreAudio.h>
+
+@implementation MMAudioDevice
+
+- (NSDictionary<NSString *, id> *)toDictionary {
+    return @{
+        @"deviceID": @(self.deviceID),
+        @"name": self.name ?: @"Unknown Audio Device",
+        @"manufacturer": self.manufacturer ?: @"Unknown",
+        @"uid": self.uid ?: @"",
+        @"isInput": @(self.isInput),
+        @"isOutput": @(self.isOutput),
+        @"isDefaultInput": @(self.isDefaultInput),
+        @"isDefaultOutput": @(self.isDefaultOutput),
+        @"sampleRate": @(self.sampleRate),
+        @"channelCount": @(self.channelCount),
+        @"volume": @(roundf(self.volume * 100.0f) / 100.0f),
+        @"isMuted": @(self.isMuted)
+    };
+}
+
+@end
+
+@implementation MMAudioTelemetryProvider
+
+- (instancetype)init {
+    self = [super init];
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainAudio;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.audio";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (AudioDeviceID)defaultDeviceForProperty:(AudioObjectPropertySelector)selector {
+    AudioObjectPropertyAddress address = {
+        .mSelector = selector,
+        .mScope = kAudioObjectPropertyScopeGlobal,
+        .mElement = kAudioObjectPropertyElementMain
+    };
+    AudioDeviceID deviceID = kAudioObjectUnknown;
+    UInt32 size = sizeof(AudioDeviceID);
+    OSStatus status = AudioObjectGetPropertyData(kAudioObjectSystemObject, &address, 0, NULL, &size, &deviceID);
+    if (status == noErr) {
+        return deviceID;
+    }
+    return kAudioObjectUnknown;
+}
+
++ (NSArray<MMAudioDevice *> *)sampleAudioDevices {
+    AudioObjectPropertyAddress address = {
+        .mSelector = kAudioHardwarePropertyDevices,
+        .mScope = kAudioObjectPropertyScopeGlobal,
+        .mElement = kAudioObjectPropertyElementMain
+    };
+    
+    UInt32 dataSize = 0;
+    OSStatus status = AudioObjectGetPropertyDataSize(kAudioObjectSystemObject, &address, 0, NULL, &dataSize);
+    if (status != noErr || dataSize == 0) {
+        return @[];
+    }
+    
+    UInt32 deviceCount = dataSize / sizeof(AudioDeviceID);
+    AudioDeviceID *deviceIDs = (AudioDeviceID *)malloc(dataSize);
+    if (!deviceIDs) return @[];
+    
+    status = AudioObjectGetPropertyData(kAudioObjectSystemObject, &address, 0, NULL, &dataSize, deviceIDs);
+    if (status != noErr) {
+        free(deviceIDs);
+        return @[];
+    }
+    
+    AudioDeviceID defaultIn = [self defaultDeviceForProperty:kAudioHardwarePropertyDefaultInputDevice];
+    AudioDeviceID defaultOut = [self defaultDeviceForProperty:kAudioHardwarePropertyDefaultOutputDevice];
+    
+    NSMutableArray<MMAudioDevice *> *devices = [NSMutableArray arrayWithCapacity:deviceCount];
+    
+    for (UInt32 i = 0; i < deviceCount; i++) {
+        AudioDeviceID devID = deviceIDs[i];
+        
+        // Name
+        CFStringRef nameRef = NULL;
+        UInt32 propSize = sizeof(CFStringRef);
+        AudioObjectPropertyAddress nameAddr = {
+            .mSelector = kAudioObjectPropertyName,
+            .mScope = kAudioObjectPropertyScopeGlobal,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        NSString *name = @"Audio Device";
+        if (AudioObjectGetPropertyData(devID, &nameAddr, 0, NULL, &propSize, &nameRef) == noErr && nameRef) {
+            name = (__bridge_transfer NSString *)nameRef;
+        }
+        
+        // Manufacturer
+        CFStringRef mfrRef = NULL;
+        propSize = sizeof(CFStringRef);
+        AudioObjectPropertyAddress mfrAddr = {
+            .mSelector = kAudioObjectPropertyManufacturer,
+            .mScope = kAudioObjectPropertyScopeGlobal,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        NSString *mfr = @"Apple Inc.";
+        if (AudioObjectGetPropertyData(devID, &mfrAddr, 0, NULL, &propSize, &mfrRef) == noErr && mfrRef) {
+            mfr = (__bridge_transfer NSString *)mfrRef;
+        }
+        
+        // UID
+        CFStringRef uidRef = NULL;
+        propSize = sizeof(CFStringRef);
+        AudioObjectPropertyAddress uidAddr = {
+            .mSelector = kAudioDevicePropertyDeviceUID,
+            .mScope = kAudioObjectPropertyScopeGlobal,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        NSString *uid = @"";
+        if (AudioObjectGetPropertyData(devID, &uidAddr, 0, NULL, &propSize, &uidRef) == noErr && uidRef) {
+            uid = (__bridge_transfer NSString *)uidRef;
+        }
+        
+        // Channels & Input / Output determination
+        AudioObjectPropertyAddress inputStreamsAddr = {
+            .mSelector = kAudioDevicePropertyStreams,
+            .mScope = kAudioDevicePropertyScopeInput,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        UInt32 inStreamSize = 0;
+        AudioObjectGetPropertyDataSize(devID, &inputStreamsAddr, 0, NULL, &inStreamSize);
+        BOOL isInput = (inStreamSize > 0);
+        
+        AudioObjectPropertyAddress outputStreamsAddr = {
+            .mSelector = kAudioDevicePropertyStreams,
+            .mScope = kAudioDevicePropertyScopeOutput,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        UInt32 outStreamSize = 0;
+        AudioObjectGetPropertyDataSize(devID, &outputStreamsAddr, 0, NULL, &outStreamSize);
+        BOOL isOutput = (outStreamSize > 0);
+        
+        // Sample rate
+        Float64 sampleRate = 0.0;
+        propSize = sizeof(Float64);
+        AudioObjectPropertyAddress rateAddr = {
+            .mSelector = kAudioDevicePropertyNominalSampleRate,
+            .mScope = kAudioObjectPropertyScopeGlobal,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        AudioObjectGetPropertyData(devID, &rateAddr, 0, NULL, &propSize, &sampleRate);
+        
+        // Volume
+        Float32 volume = 0.0f;
+        AudioObjectPropertyScope volScope = isOutput ? kAudioDevicePropertyScopeOutput : kAudioDevicePropertyScopeInput;
+        AudioObjectPropertyAddress volAddr = {
+            .mSelector = kAudioDevicePropertyVolumeScalar,
+            .mScope = volScope,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        propSize = sizeof(Float32);
+        if (AudioObjectHasProperty(devID, &volAddr)) {
+            AudioObjectGetPropertyData(devID, &volAddr, 0, NULL, &propSize, &volume);
+        }
+        
+        // Mute status
+        UInt32 mute = 0;
+        AudioObjectPropertyAddress muteAddr = {
+            .mSelector = kAudioDevicePropertyMute,
+            .mScope = volScope,
+            .mElement = kAudioObjectPropertyElementMain
+        };
+        propSize = sizeof(UInt32);
+        if (AudioObjectHasProperty(devID, &muteAddr)) {
+            AudioObjectGetPropertyData(devID, &muteAddr, 0, NULL, &propSize, &mute);
+        }
+        
+        MMAudioDevice *device = [[MMAudioDevice alloc] init];
+        device.deviceID = devID;
+        device.name = name;
+        device.manufacturer = mfr;
+        device.uid = uid;
+        device.isInput = isInput;
+        device.isOutput = isOutput;
+        device.isDefaultInput = (devID == defaultIn);
+        device.isDefaultOutput = (devID == defaultOut);
+        device.sampleRate = (double)sampleRate;
+        device.channelCount = (inStreamSize / sizeof(AudioStreamID)) + (outStreamSize / sizeof(AudioStreamID));
+        device.volume = volume;
+        device.isMuted = (mute != 0);
+        
+        [devices addObject:device];
+    }
+    
+    free(deviceIDs);
+    return devices;
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    NSArray<MMAudioDevice *> *devices = [MMAudioTelemetryProvider sampleAudioDevices];
+    NSMutableArray<NSDictionary<NSString *, id> *> *deviceList = [NSMutableArray arrayWithCapacity:devices.count];
+    
+    MMAudioDevice *defaultIn = nil;
+    MMAudioDevice *defaultOut = nil;
+    
+    for (MMAudioDevice *d in devices) {
+        [deviceList addObject:[d toDictionary]];
+        if (d.isDefaultInput) defaultIn = d;
+        if (d.isDefaultOutput) defaultOut = d;
+    }
+    
+    return @{
+        @"devices": deviceList,
+        @"deviceCount": @(devices.count),
+        @"defaultInputDevice": defaultIn ? [defaultIn toDictionary] : [NSNull null],
+        @"defaultOutputDevice": defaultOut ? [defaultOut toDictionary] : [NSNull null]
+    };
+}
+
+@end

Sources/Telemetry/CPU/MMCPULoadProvider.h

@@ -0,0 +1,31 @@
+#ifndef MMCPULoadProvider_h
+#define MMCPULoadProvider_h
+
+#import <Foundation/Foundation.h>
+#import <mach/mach.h>
+#import <mach/processor_info.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMCPULoadProvider
+ * Samples real-time Mach host processor CPU load ticks, per-core utilization percentages,
+ * and CPU operating frequency.
+ */
+@interface MMCPULoadProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, readonly) natural_t coreCount;
+
+/**
+ * Static calculator method facilitating deterministic unit testing with mock tick data.
+ */
++ (NSDictionary<NSString *, id> *)calculateLoadFromPreviousTicks:(const struct processor_cpu_load_info * _Nullable)prevTicks
+                                                    currentTicks:(const struct processor_cpu_load_info *)currTicks
+                                                       coreCount:(natural_t)coreCount;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMCPULoadProvider_h */

Sources/Telemetry/CPU/MMCPULoadProvider.m

@@ -0,0 +1,201 @@
+#import "MMCPULoadProvider.h"
+#import <sys/sysctl.h>
+#import <os/lock.h>
+
+@interface MMCPULoadProvider () {
+    os_unfair_lock _lock;
+    processor_cpu_load_info_t _previousCpuInfo;
+    mach_msg_type_number_t _previousCpuInfoCount;
+    natural_t _coreCount;
+    uint64_t _maxFrequencyHz;
+}
+@end
+
+@implementation MMCPULoadProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _lock = OS_UNFAIR_LOCK_INIT;
+        _previousCpuInfo = NULL;
+        _previousCpuInfoCount = 0;
+        
+        // Read CPU core count
+        natural_t cCount = 1;
+        size_t size = sizeof(cCount);
+        sysctlbyname("hw.logicalcpu", &cCount, &size, NULL, 0);
+        _coreCount = cCount;
+        
+        // Read maximum frequency
+        uint64_t maxFreq = 0;
+        size = sizeof(maxFreq);
+        if (sysctlbyname("hw.cpufrequency_max", &maxFreq, &size, NULL, 0) != 0) {
+            sysctlbyname("hw.cpufrequency", &maxFreq, &size, NULL, 0);
+        }
+        _maxFrequencyHz = maxFreq;
+    }
+    return self;
+}
+
+- (void)dealloc {
+    if (_previousCpuInfo != NULL) {
+        free(_previousCpuInfo);
+        _previousCpuInfo = NULL;
+    }
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainCPU;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.cpuload";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
+- (natural_t)coreCount {
+    return _coreCount;
+}
+
++ (NSDictionary<NSString *, id> *)calculateLoadFromPreviousTicks:(const struct processor_cpu_load_info * _Nullable)prevTicks
+                                                    currentTicks:(const struct processor_cpu_load_info *)currTicks
+                                                       coreCount:(natural_t)coreCount {
+    if (!currTicks || coreCount == 0) return @{};
+    
+    NSMutableArray<NSDictionary<NSString *, NSNumber *> *> *coresList = [NSMutableArray arrayWithCapacity:coreCount];
+    double totalUserPercent = 0.0;
+    double totalSystemPercent = 0.0;
+    double totalIdlePercent = 0.0;
+    double totalActivePercent = 0.0;
+    
+    for (natural_t i = 0; i < coreCount; i++) {
+        uint64_t user = currTicks[i].cpu_ticks[CPU_STATE_USER];
+        uint64_t system = currTicks[i].cpu_ticks[CPU_STATE_SYSTEM];
+        uint64_t idle = currTicks[i].cpu_ticks[CPU_STATE_IDLE];
+        uint64_t nice = currTicks[i].cpu_ticks[CPU_STATE_NICE];
+        
+        uint64_t deltaUser = 0;
+        uint64_t deltaSystem = 0;
+        uint64_t deltaIdle = 0;
+        uint64_t deltaNice = 0;
+        
+        if (prevTicks != NULL) {
+            deltaUser = (user >= prevTicks[i].cpu_ticks[CPU_STATE_USER]) ? (user - prevTicks[i].cpu_ticks[CPU_STATE_USER]) : 0;
+            deltaSystem = (system >= prevTicks[i].cpu_ticks[CPU_STATE_SYSTEM]) ? (system - prevTicks[i].cpu_ticks[CPU_STATE_SYSTEM]) : 0;
+            deltaIdle = (idle >= prevTicks[i].cpu_ticks[CPU_STATE_IDLE]) ? (idle - prevTicks[i].cpu_ticks[CPU_STATE_IDLE]) : 0;
+            deltaNice = (nice >= prevTicks[i].cpu_ticks[CPU_STATE_NICE]) ? (nice - prevTicks[i].cpu_ticks[CPU_STATE_NICE]) : 0;
+        }
+        
+        uint64_t deltaTotal = deltaUser + deltaSystem + deltaIdle + deltaNice;
+        double uPct = 0.0, sPct = 0.0, iPct = 100.0, aPct = 0.0;
+        
+        if (deltaTotal > 0) {
+            uPct = ((double)deltaUser / (double)deltaTotal) * 100.0;
+            sPct = ((double)deltaSystem / (double)deltaTotal) * 100.0;
+            iPct = ((double)deltaIdle / (double)deltaTotal) * 100.0;
+            aPct = 100.0 - iPct;
+            if (aPct < 0.0) aPct = 0.0;
+            if (aPct > 100.0) aPct = 100.0;
+        }
+        
+        totalUserPercent += uPct;
+        totalSystemPercent += sPct;
+        totalIdlePercent += iPct;
+        totalActivePercent += aPct;
+        
+        [coresList addObject:@{
+            @"coreIndex": @(i),
+            @"userPercent": @(uPct),
+            @"systemPercent": @(sPct),
+            @"idlePercent": @(iPct),
+            @"totalPercent": @(aPct)
+        }];
+    }
+    
+    double avgUser = coreCount > 0 ? (totalUserPercent / coreCount) : 0.0;
+    double avgSystem = coreCount > 0 ? (totalSystemPercent / coreCount) : 0.0;
+    double avgIdle = coreCount > 0 ? (totalIdlePercent / coreCount) : 100.0;
+    double avgTotal = coreCount > 0 ? (totalActivePercent / coreCount) : 0.0;
+    
+    return @{
+        @"cores": coresList,
+        @"coreCount": @(coreCount),
+        @"userPercent": @(avgUser),
+        @"systemPercent": @(avgSystem),
+        @"idlePercent": @(avgIdle),
+        @"totalPercent": @(avgTotal)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    natural_t numCPUs = 0;
+    processor_info_array_t cpuInfo = NULL;
+    mach_msg_type_number_t numCpuInfo = 0;
+    
+    kern_return_t kr = host_processor_info(
+        mach_host_self(),
+        PROCESSOR_CPU_LOAD_INFO,
+        &numCPUs,
+        &cpuInfo,
+        &numCpuInfo
+    );
+    
+    if (kr != KERN_SUCCESS || cpuInfo == NULL) {
+        if (error) {
+            *error = [NSError errorWithDomain:@"com.i3omb.MacMonitor.CPU"
+                                         code:kr
+                                     userInfo:@{NSLocalizedDescriptionKey: @"host_processor_info failed to read CPU ticks"}];
+        }
+        return nil;
+    }
+    
+    os_unfair_lock_lock(&_lock);
+    
+    processor_cpu_load_info_t currentCpuInfo = (processor_cpu_load_info_t)cpuInfo;
+    NSDictionary<NSString *, id> *metrics = [MMCPULoadProvider calculateLoadFromPreviousTicks:_previousCpuInfo
+                                                                                 currentTicks:currentCpuInfo
+                                                                                    coreCount:numCPUs];
+    
+    // Free previous malloc buffer
+    if (_previousCpuInfo != NULL) {
+        free(_previousCpuInfo);
+        _previousCpuInfo = NULL;
+    }
+    
+    // Allocate new buffer to preserve state for the next delta
+    vm_size_t bufferSize = numCpuInfo * sizeof(integer_t);
+    _previousCpuInfo = (processor_cpu_load_info_t)malloc(bufferSize);
+    if (_previousCpuInfo != NULL) {
+        memcpy(_previousCpuInfo, cpuInfo, bufferSize);
+        _previousCpuInfoCount = numCpuInfo;
+    }
+    
+    // Deallocate the buffer returned by the kernel
+    vm_deallocate(mach_task_self(), (vm_address_t)cpuInfo, numCpuInfo * sizeof(integer_t));
+    
+    os_unfair_lock_unlock(&_lock);
+    
+    // Read current frequency
+    uint64_t currentFreq = 0;
+    size_t size = sizeof(currentFreq);
+    if (sysctlbyname("hw.cpufrequency", &currentFreq, &size, NULL, 0) != 0) {
+        currentFreq = _maxFrequencyHz;
+    }
+    
+    // Thermal State
+    NSProcessInfoThermalState thermalState = [NSProcessInfo processInfo].thermalState;
+    BOOL isThrottled = (thermalState >= NSProcessInfoThermalStateSerious);
+    
+    NSMutableDictionary<NSString *, id> *result = [metrics mutableCopy];
+    result[@"frequencyHz"] = @(currentFreq);
+    result[@"maxFrequencyHz"] = @(_maxFrequencyHz);
+    result[@"thermalState"] = @(thermalState);
+    result[@"isThrottled"] = @(isThrottled);
+    
+    return [result copy];
+}
+
+@end

Sources/Telemetry/Fan/MMFanTelemetryProvider.h

@@ -0,0 +1,31 @@
+#ifndef MMFanTelemetryProvider_h
+#define MMFanTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+#import "MMAppleSMCClient.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMFanTelemetryProvider
+ * Samples multi-fan telemetry from AppleSMC: current RPM, min RPM, max RPM, target RPM,
+ * and fan utilization percentages.
+ */
+@interface MMFanTelemetryProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, strong, readonly) MMAppleSMCClient *smcClient;
+@property (nonatomic, readonly) NSInteger fanCount;
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client;
+
+/**
+ * Static calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateFanMetricsFromFanList:(NSArray<NSDictionary<NSString *, NSNumber *> *> *)fanList;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMFanTelemetryProvider_h */

Sources/Telemetry/Fan/MMFanTelemetryProvider.m

@@ -0,0 +1,147 @@
+#import "MMFanTelemetryProvider.h"
+
+@interface MMFanTelemetryProvider () {
+    MMAppleSMCClient *_smcClient;
+    NSInteger _probedFanCount;
+}
+@end
+
+@implementation MMFanTelemetryProvider
+
+- (instancetype)init {
+    return [self initWithSMCClient:[MMAppleSMCClient sharedClient]];
+}
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client {
+    self = [super init];
+    if (self) {
+        _smcClient = client;
+        _probedFanCount = -1;
+        [self probeFans];
+    }
+    return self;
+}
+
+- (void)probeFans {
+    if (!_smcClient.isAvailable) return;
+    
+    NSNumber *num = [_smcClient readNumericValueForKey:@"FNum" error:nil];
+    if (num) {
+        _probedFanCount = [num integerValue];
+    } else {
+        // Fallback probe F0Ac
+        NSNumber *f0 = [_smcClient readNumericValueForKey:@"F0Ac" error:nil];
+        if (f0 && [f0 doubleValue] >= 0.0) {
+            _probedFanCount = 1;
+            NSNumber *f1 = [_smcClient readNumericValueForKey:@"F1Ac" error:nil];
+            if (f1 && [f1 doubleValue] >= 0.0) {
+                _probedFanCount = 2;
+            }
+        } else {
+            _probedFanCount = 0;
+        }
+    }
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainFan;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.fan";
+}
+
+- (BOOL)isAvailable {
+    return _smcClient.isAvailable;
+}
+
+- (MMAppleSMCClient *)smcClient {
+    return _smcClient;
+}
+
+- (NSInteger)fanCount {
+    return (_probedFanCount >= 0) ? _probedFanCount : 0;
+}
+
++ (NSDictionary<NSString *, id> *)calculateFanMetricsFromFanList:(NSArray<NSDictionary<NSString *, NSNumber *> *> *)fanList {
+    if (!fanList || fanList.count == 0) {
+        return @{
+            @"fanCount": @(0),
+            @"fans": @[],
+            @"averageRPM": @(0.0),
+            @"peakRPM": @(0.0)
+        };
+    }
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *resultList = [NSMutableArray arrayWithCapacity:fanList.count];
+    double sumRPM = 0.0;
+    double peakRPM = 0.0;
+    
+    for (NSUInteger i = 0; i < fanList.count; i++) {
+        NSDictionary<NSString *, NSNumber *> *raw = fanList[i];
+        double current = [raw[@"currentRPM"] doubleValue];
+        double min = [raw[@"minRPM"] doubleValue];
+        double max = [raw[@"maxRPM"] doubleValue];
+        double target = [raw[@"targetRPM"] doubleValue];
+        
+        double util = 0.0;
+        if (max > min && current >= min) {
+            util = ((current - min) / (max - min)) * 100.0;
+            if (util < 0.0) util = 0.0;
+            if (util > 100.0) util = 100.0;
+        }
+        
+        if (current > peakRPM) peakRPM = current;
+        sumRPM += current;
+        
+        [resultList addObject:@{
+            @"fanIndex": @(i),
+            @"currentRPM": @(current),
+            @"minRPM": @(min),
+            @"maxRPM": @(max),
+            @"targetRPM": @(target),
+            @"utilizationPercent": @(util)
+        }];
+    }
+    
+    double avgRPM = fanList.count > 0 ? (sumRPM / fanList.count) : 0.0;
+    
+    return @{
+        @"fanCount": @(fanList.count),
+        @"fans": [resultList copy],
+        @"averageRPM": @(avgRPM),
+        @"peakRPM": @(peakRPM)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    if (_probedFanCount < 0 && _smcClient.isAvailable) {
+        [self probeFans];
+    }
+    
+    NSInteger count = [self fanCount];
+    NSMutableArray<NSDictionary<NSString *, NSNumber *> *> *rawList = [NSMutableArray arrayWithCapacity:count];
+    
+    for (NSInteger i = 0; i < count; i++) {
+        NSString *acKey = [NSString stringWithFormat:@"F%ldAc", (long)i];
+        NSString *mnKey = [NSString stringWithFormat:@"F%ldMn", (long)i];
+        NSString *mxKey = [NSString stringWithFormat:@"F%ldMx", (long)i];
+        NSString *tgKey = [NSString stringWithFormat:@"F%ldTg", (long)i];
+        
+        NSNumber *ac = [_smcClient readNumericValueForKey:acKey error:nil] ?: @(0.0);
+        NSNumber *mn = [_smcClient readNumericValueForKey:mnKey error:nil] ?: @(0.0);
+        NSNumber *mx = [_smcClient readNumericValueForKey:mxKey error:nil] ?: @(6000.0);
+        NSNumber *tg = [_smcClient readNumericValueForKey:tgKey error:nil] ?: ac;
+        
+        [rawList addObject:@{
+            @"currentRPM": ac,
+            @"minRPM": mn,
+            @"maxRPM": mx,
+            @"targetRPM": tg
+        }];
+    }
+    
+    return [MMFanTelemetryProvider calculateFanMetricsFromFanList:rawList];
+}
+
+@end

Sources/Telemetry/GPU/MMGPUTelemetryProvider.h

@@ -0,0 +1,31 @@
+#ifndef MMGPUTelemetryProvider_h
+#define MMGPUTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+#import "MMAppleSMCClient.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMGPUTelemetryProvider
+ * Samples Intel Integrated Graphics (Iris/UHD) and AMD Discrete Graphics (Radeon/Vega)
+ * utilization, VRAM allocation, and thermal metrics via IOKit and Metal.
+ */
+@interface MMGPUTelemetryProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, strong, readonly) MMAppleSMCClient *smcClient;
+
+- (instancetype)init;
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateGPUMetricsWithDevices:(NSArray<NSDictionary<NSString *, id> *> *)gpuDevices;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMGPUTelemetryProvider_h */

Sources/Telemetry/GPU/MMGPUTelemetryProvider.m

@@ -0,0 +1,184 @@
+#import "MMGPUTelemetryProvider.h"
+#import <IOKit/IOKitLib.h>
+#import <Metal/Metal.h>
+
+@interface MMGPUTelemetryProvider () {
+    MMAppleSMCClient *_smcClient;
+}
+@end
+
+@implementation MMGPUTelemetryProvider
+
+- (instancetype)init {
+    return [self initWithSMCClient:[MMAppleSMCClient sharedClient]];
+}
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client {
+    self = [super init];
+    if (self) {
+        _smcClient = client;
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainGPU;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.gpu";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
+- (MMAppleSMCClient *)smcClient {
+    return _smcClient;
+}
+
++ (NSDictionary<NSString *, id> *)calculateGPUMetricsWithDevices:(NSArray<NSDictionary<NSString *, id> *> *)gpuDevices {
+    double totalUtil = 0.0;
+    double peakUtil = 0.0;
+    NSString *activeGPU = @"None";
+    
+    for (NSDictionary<NSString *, id> *gpu in gpuDevices) {
+        double util = [gpu[@"utilization"] doubleValue];
+        totalUtil += util;
+        if (util > peakUtil) {
+            peakUtil = util;
+            activeGPU = gpu[@"name"] ?: @"GPU";
+        }
+    }
+    
+    double avgUtil = gpuDevices.count > 0 ? (totalUtil / (double)gpuDevices.count) : 0.0;
+    if ([activeGPU isEqualToString:@"None"] && gpuDevices.count > 0) {
+        activeGPU = gpuDevices[0][@"name"] ?: @"GPU";
+    }
+    
+    return @{
+        @"gpuCount": @(gpuDevices.count),
+        @"averageUtilization": @(avgUtil),
+        @"peakUtilization": @(peakUtil),
+        @"activeGPUName": activeGPU,
+        @"devices": gpuDevices
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    // 1. Query IOKit IOAccelerator performance statistics
+    NSMutableDictionary<NSString *, NSDictionary *> *accelStatsByName = [NSMutableDictionary dictionary];
+    
+    CFMutableDictionaryRef matching = IOServiceMatching("IOAccelerator");
+    io_iterator_t iterator = IO_OBJECT_NULL;
+    if (IOServiceGetMatchingServices(kIOMainPortDefault, matching, &iterator) == KERN_SUCCESS && iterator != IO_OBJECT_NULL) {
+        io_registry_entry_t entry;
+        while ((entry = IOIteratorNext(iterator)) != IO_OBJECT_NULL) {
+            CFMutableDictionaryRef props = NULL;
+            if (IORegistryEntryCreateCFProperties(entry, &props, kCFAllocatorDefault, 0) == KERN_SUCCESS && props) {
+                NSDictionary *dict = (__bridge NSDictionary *)props;
+                NSDictionary *stats = dict[@"PerformanceStatistics"];
+                io_name_t entryName;
+                if (IORegistryEntryGetName(entry, entryName) == KERN_SUCCESS && stats) {
+                    accelStatsByName[[NSString stringWithUTF8String:entryName]] = stats;
+                }
+                CFRelease(props);
+            }
+            IOObjectRelease(entry);
+        }
+        IOObjectRelease(iterator);
+    }
+    
+    // 2. Query SMC for GPU temperature fallback
+    NSNumber *smcGpuTemp = nil;
+    if (_smcClient.isAvailable) {
+        smcGpuTemp = [_smcClient readNumericValueForKey:@"TG0D" error:nil];
+        if (!smcGpuTemp) {
+            smcGpuTemp = [_smcClient readNumericValueForKey:@"TG0P" error:nil];
+        }
+    }
+    
+    // 3. Enumerate Metal devices
+    NSArray<id<MTLDevice>> *metalDevices = MTLCopyAllDevices();
+    NSMutableArray<NSDictionary<NSString *, id> *> *deviceList = [NSMutableArray array];
+    
+    for (id<MTLDevice> dev in metalDevices) {
+        NSString *name = dev.name;
+        BOOL isLowPower = dev.isLowPower;
+        BOOL isRemovable = dev.isRemovable;
+        uint64_t maxMem = dev.recommendedMaxWorkingSetSize;
+        
+        // Find matching stats
+        double util = 0.0;
+        uint64_t vramUsed = 0;
+        uint64_t vramTotal = maxMem;
+        double temp = smcGpuTemp ? [smcGpuTemp doubleValue] : 0.0;
+        
+        for (NSString *accelName in accelStatsByName) {
+            NSDictionary *stats = accelStatsByName[accelName];
+            
+            // Check Intel stats
+            if ([name containsString:@"Intel"] || [accelName containsString:@"Intel"]) {
+                if (stats[@"Device Utilization %"]) {
+                    util = [stats[@"Device Utilization %"] doubleValue];
+                }
+                if (stats[@"gartUsedBytes"]) {
+                    vramUsed = [stats[@"gartUsedBytes"] unsignedLongLongValue];
+                }
+                if (stats[@"gartSizeBytes"]) {
+                    vramTotal = [stats[@"gartSizeBytes"] unsignedLongLongValue];
+                }
+            } else {
+                // AMD / Discrete stats
+                if (stats[@"GPU Activity(%)"]) {
+                    util = [stats[@"GPU Activity(%)"] doubleValue];
+                } else if (stats[@"Device Utilization %"]) {
+                    util = [stats[@"Device Utilization %"] doubleValue];
+                }
+                if (stats[@"vramUsedBytes"]) {
+                    vramUsed = [stats[@"vramUsedBytes"] unsignedLongLongValue];
+                }
+                if (stats[@"vramFreeBytes"]) {
+                    uint64_t freeBytes = [stats[@"vramFreeBytes"] unsignedLongLongValue];
+                    vramTotal = vramUsed + freeBytes;
+                }
+                if (stats[@"Temperature(C)"]) {
+                    temp = [stats[@"Temperature(C)"] doubleValue];
+                }
+            }
+        }
+        
+        NSString *gpuType = isLowPower || [name containsString:@"Intel"] ? @"Integrated" : @"Discrete";
+        
+        [deviceList addObject:@{
+            @"name": name,
+            @"type": gpuType,
+            @"utilization": @(util),
+            @"vramUsedBytes": @(vramUsed),
+            @"vramTotalBytes": @(vramTotal),
+            @"temperature": @(temp),
+            @"isLowPower": @(isLowPower),
+            @"isRemovable": @(isRemovable),
+            @"recommendedMaxWorkingSetBytes": @(maxMem)
+        }];
+    }
+    
+    // Fallback if no Metal devices enumerated (headless / virtualization)
+    if (deviceList.count == 0) {
+        [deviceList addObject:@{
+            @"name": @"Default GPU",
+            @"type": @"Integrated",
+            @"utilization": @(0.0),
+            @"vramUsedBytes": @(0),
+            @"vramTotalBytes": @(1024 * 1024 * 1024),
+            @"temperature": @(0.0),
+            @"isLowPower": @(YES),
+            @"isRemovable": @(NO),
+            @"recommendedMaxWorkingSetBytes": @(1024 * 1024 * 1024)
+        }];
+    }
+    
+    return [MMGPUTelemetryProvider calculateGPUMetricsWithDevices:deviceList];
+}
+
+@end

Sources/Telemetry/Kernel/MMKernelTelemetryProvider.h

@@ -0,0 +1,30 @@
+#ifndef MMKernelTelemetryProvider_h
+#define MMKernelTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMKernelTelemetryProvider
+ * Samples low-level Mach kernel performance counters: context switches, system calls,
+ * page faults (soft, COW, zero-fill), pageins/pageouts, and computes instantaneous rates per second.
+ */
+@interface MMKernelTelemetryProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Static calculator method for deterministic unit testing.
+ * Computes event rates per second based on previous and current cumulative counters over delta time.
+ */
++ (NSDictionary<NSString *, id> *)calculateRatesWithCurrentCounters:(NSDictionary<NSString *, NSNumber *> *)current
+                                                   previousCounters:(nullable NSDictionary<NSString *, NSNumber *> *)previous
+                                                          timeDelta:(NSTimeInterval)timeDelta;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMKernelTelemetryProvider_h */

Sources/Telemetry/Kernel/MMKernelTelemetryProvider.m

@@ -0,0 +1,131 @@
+#import "MMKernelTelemetryProvider.h"
+#import <mach/mach.h>
+#import <mach/mach_time.h>
+#import <libproc.h>
+#import <os/lock.h>
+
+@interface MMKernelTelemetryProvider () {
+    os_unfair_lock _lock;
+    NSDictionary<NSString *, NSNumber *> *_previousCounters;
+    uint64_t _previousTimestamp;
+    mach_timebase_info_data_t _timebase;
+}
+@end
+
+@implementation MMKernelTelemetryProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _lock = OS_UNFAIR_LOCK_INIT;
+        _previousCounters = nil;
+        _previousTimestamp = 0;
+        mach_timebase_info(&_timebase);
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainSystem;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.kernel.counters";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSDictionary<NSString *, id> *)calculateRatesWithCurrentCounters:(NSDictionary<NSString *, NSNumber *> *)current
+                                                   previousCounters:(nullable NSDictionary<NSString *, NSNumber *> *)previous
+                                                          timeDelta:(NSTimeInterval)timeDelta {
+    NSMutableDictionary<NSString *, id> *result = [NSMutableDictionary dictionary];
+    
+    // Copy all current cumulative counters into result
+    [current enumerateKeysAndObjectsUsingBlock:^(NSString *key, NSNumber *val, BOOL *stop) {
+        result[[@"cumulative_" stringByAppendingString:key]] = val;
+    }];
+    
+    NSArray<NSString *> *rateKeys = @[
+        @"contextSwitches", @"syscalls", @"pageFaults", @"cowFaults",
+        @"zeroFills", @"pageins", @"pageouts", @"decompressions", @"compressions"
+    ];
+    
+    for (NSString *key in rateKeys) {
+        double currentVal = [current[key] doubleValue];
+        double prevVal = previous ? [previous[key] doubleValue] : currentVal;
+        double delta = (currentVal >= prevVal) ? (currentVal - prevVal) : 0.0;
+        double rate = (timeDelta > 0.0001) ? (delta / timeDelta) : 0.0;
+        result[[key stringByAppendingString:@"Rate"]] = @(rate);
+    }
+    
+    result[@"timeDelta"] = @(timeDelta);
+    return result;
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    uint64_t now = mach_absolute_time();
+    
+    // 1. Query Mach VM Statistics for page faults, COW, zero fills, pageins/outs
+    vm_statistics64_data_t vmStats;
+    mach_msg_type_number_t count = HOST_VM_INFO64_COUNT;
+    kern_return_t kr = host_statistics64(mach_host_self(), HOST_VM_INFO64, (host_info64_t)&vmStats, &count);
+    if (kr != KERN_SUCCESS) {
+        if (error) {
+            *error = [NSError errorWithDomain:@"com.i3omb.macmonitor.kernel"
+                                         code:kr
+                                     userInfo:@{NSLocalizedDescriptionKey: @"Failed to query host_statistics64"}];
+        }
+        return nil;
+    }
+    
+    // 2. Query process table for cumulative context switches and system calls
+    int pids[4096];
+    int bytes = proc_listpids(PROC_ALL_PIDS, 0, pids, sizeof(pids));
+    int pidCount = bytes / sizeof(int);
+    
+    uint64_t totalCSW = 0;
+    uint64_t totalSyscalls = 0;
+    
+    for (int i = 0; i < pidCount; i++) {
+        if (pids[i] <= 0) continue;
+        struct proc_taskinfo ti;
+        if (proc_pidinfo(pids[i], PROC_PIDTASKINFO, 0, &ti, sizeof(ti)) == sizeof(ti)) {
+            totalCSW += ti.pti_csw;
+            totalSyscalls += (uint64_t)ti.pti_syscalls_unix + (uint64_t)ti.pti_syscalls_mach;
+        }
+    }
+    
+    NSDictionary<NSString *, NSNumber *> *currentCounters = @{
+        @"contextSwitches": @(totalCSW),
+        @"syscalls": @(totalSyscalls),
+        @"pageFaults": @(vmStats.faults),
+        @"cowFaults": @(vmStats.cow_faults),
+        @"zeroFills": @(vmStats.zero_fill_count),
+        @"pageins": @(vmStats.pageins),
+        @"pageouts": @(vmStats.pageouts),
+        @"decompressions": @(vmStats.decompressions),
+        @"compressions": @(vmStats.compressions)
+    };
+    
+    os_unfair_lock_lock(&_lock);
+    NSDictionary<NSString *, NSNumber *> *prev = _previousCounters;
+    uint64_t prevTime = _previousTimestamp;
+    
+    _previousCounters = currentCounters;
+    _previousTimestamp = now;
+    os_unfair_lock_unlock(&_lock);
+    
+    NSTimeInterval timeDelta = 1.0;
+    if (prevTime > 0) {
+        uint64_t elapsed = now - prevTime;
+        timeDelta = (double)elapsed * _timebase.numer / _timebase.denom / 1e9;
+    }
+    
+    return [MMKernelTelemetryProvider calculateRatesWithCurrentCounters:currentCounters
+                                                       previousCounters:prev
+                                                              timeDelta:timeDelta];
+}
+
+@end

Sources/Telemetry/Memory/MMMemoryTelemetryProvider.h

@@ -0,0 +1,32 @@
+#ifndef MMMemoryTelemetryProvider_h
+#define MMMemoryTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import <mach/mach.h>
+#import <sys/sysctl.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMMemoryTelemetryProvider
+ * Samples Mach virtual memory statistics, wired/active/inactive/compressed memory allocations,
+ * swap usage, and system-wide memory pressure levels.
+ */
+@interface MMMemoryTelemetryProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, readonly) uint64_t totalPhysicalMemoryBytes;
+
+/**
+ * Deterministic helper method for unit testing VM metric calculations.
+ */
++ (NSDictionary<NSString *, id> *)calculateMemoryMetricsWithVMInfo:(const vm_statistics64_data_t *)vmInfo
+                                                           pageSize:(vm_size_t)pageSize
+                                                   totalPhysicalRAM:(uint64_t)totalRAM
+                                                          swapUsage:(const struct xsw_usage * _Nullable)swap;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMMemoryTelemetryProvider_h */

Sources/Telemetry/Memory/MMMemoryTelemetryProvider.m

@@ -0,0 +1,135 @@
+#import "MMMemoryTelemetryProvider.h"
+#import <sys/sysctl.h>
+
+@interface MMMemoryTelemetryProvider () {
+    uint64_t _totalPhysicalMemoryBytes;
+    vm_size_t _pageSize;
+}
+@end
+
+@implementation MMMemoryTelemetryProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        // Read physical memory size
+        uint64_t memSize = 0;
+        size_t size = sizeof(memSize);
+        sysctlbyname("hw.memsize", &memSize, &size, NULL, 0);
+        _totalPhysicalMemoryBytes = memSize;
+        
+        // Read virtual memory page size
+        vm_size_t pSize = 4096;
+        host_page_size(mach_host_self(), &pSize);
+        _pageSize = pSize;
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainMemory;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.memory";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
+- (uint64_t)totalPhysicalMemoryBytes {
+    return _totalPhysicalMemoryBytes;
+}
+
++ (NSDictionary<NSString *, id> *)calculateMemoryMetricsWithVMInfo:(const vm_statistics64_data_t *)vmInfo
+                                                           pageSize:(vm_size_t)pageSize
+                                                   totalPhysicalRAM:(uint64_t)totalRAM
+                                                          swapUsage:(const struct xsw_usage * _Nullable)swap {
+    if (!vmInfo) return @{};
+    
+    uint64_t appMemory = (vmInfo->internal_page_count > vmInfo->purgeable_count)
+        ? (uint64_t)(vmInfo->internal_page_count - vmInfo->purgeable_count) * pageSize
+        : 0;
+    uint64_t wired = (uint64_t)vmInfo->wire_count * pageSize;
+    uint64_t compressed = (uint64_t)vmInfo->compressor_page_count * pageSize;
+    uint64_t used = appMemory + wired + compressed;
+    
+    uint64_t freeRAM = (uint64_t)vmInfo->free_count * pageSize;
+    uint64_t purgeable = (uint64_t)vmInfo->purgeable_count * pageSize;
+    uint64_t active = (uint64_t)vmInfo->active_count * pageSize;
+    uint64_t inactive = (uint64_t)vmInfo->inactive_count * pageSize;
+    
+    // Calculate Memory Pressure percentage
+    uint64_t availableForUse = (uint64_t)(vmInfo->free_count + vmInfo->inactive_count) * pageSize;
+    double pressurePct = 0.0;
+    if (totalRAM > 0) {
+        pressurePct = (1.0 - ((double)availableForUse / (double)totalRAM)) * 100.0;
+        if (pressurePct < 0.0) pressurePct = 0.0;
+        if (pressurePct > 100.0) pressurePct = 100.0;
+    }
+    
+    NSString *pressureStatus = @"Normal";
+    if (pressurePct >= 80.0) {
+        pressureStatus = @"Critical";
+    } else if (pressurePct >= 60.0) {
+        pressureStatus = @"Warning";
+    }
+    
+    uint64_t swapTotal = swap ? swap->xsu_total : 0;
+    uint64_t swapUsed = swap ? swap->xsu_used : 0;
+    uint64_t swapFree = swap ? swap->xsu_avail : 0;
+    
+    return @{
+        @"totalBytes": @(totalRAM),
+        @"usedBytes": @(used),
+        @"freeBytes": @(freeRAM),
+        @"appMemoryBytes": @(appMemory),
+        @"wiredBytes": @(wired),
+        @"compressedBytes": @(compressed),
+        @"purgeableBytes": @(purgeable),
+        @"activeBytes": @(active),
+        @"inactiveBytes": @(inactive),
+        @"memoryPressurePercent": @(pressurePct),
+        @"memoryPressureStatus": pressureStatus,
+        @"swapTotalBytes": @(swapTotal),
+        @"swapUsedBytes": @(swapUsed),
+        @"swapFreeBytes": @(swapFree)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    vm_statistics64_data_t vmInfo = {0};
+    mach_msg_type_number_t count = HOST_VM_INFO64_COUNT;
+    
+    kern_return_t kr = host_statistics64(
+        mach_host_self(),
+        HOST_VM_INFO64,
+        (host_info64_t)&vmInfo,
+        &count
+    );
+    
+    if (kr != KERN_SUCCESS) {
+        if (error) {
+            *error = [NSError errorWithDomain:@"com.i3omb.MacMonitor.Memory"
+                                         code:kr
+                                     userInfo:@{NSLocalizedDescriptionKey: @"host_statistics64 failed to sample VM metrics"}];
+        }
+        return nil;
+    }
+    
+    // Read swap usage
+    struct xsw_usage swap = {0};
+    size_t swapSize = sizeof(swap);
+    struct xsw_usage *swapPtr = NULL;
+    if (sysctlbyname("vm.swapusage", &swap, &swapSize, NULL, 0) == 0) {
+        swapPtr = &swap;
+    }
+    
+    return [MMMemoryTelemetryProvider calculateMemoryMetricsWithVMInfo:&vmInfo
+                                                              pageSize:_pageSize
+                                                      totalPhysicalRAM:_totalPhysicalMemoryBytes
+                                                             swapUsage:swapPtr];
+}
+
+@end

Sources/Telemetry/Network/MMNetworkBandwidthProvider.h

@@ -0,0 +1,30 @@
+#ifndef MMNetworkBandwidthProvider_h
+#define MMNetworkBandwidthProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMNetworkBandwidthProvider
+ * Samples real-time network download and upload throughput, packets/sec, and error counts
+ * across physical (Wi-Fi, Ethernet) and virtual (VPN, bridge) network interfaces.
+ */
+@interface MMNetworkBandwidthProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateBandwidthMetricsWithCurrentSnapshots:(NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)current
+                                                              previousSnapshots:(nullable NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)previous
+                                                                      timeDelta:(NSTimeInterval)timeDelta
+                                                                    ipAddresses:(nullable NSDictionary<NSString *, NSString *> *)ipAddresses;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMNetworkBandwidthProvider_h */

Sources/Telemetry/Network/MMNetworkBandwidthProvider.m

@@ -0,0 +1,211 @@
+#import "MMNetworkBandwidthProvider.h"
+#import <sys/sysctl.h>
+#import <net/if.h>
+#import <net/if_dl.h>
+#import <net/route.h>
+#import <ifaddrs.h>
+#import <arpa/inet.h>
+#import <mach/mach_time.h>
+#import <os/lock.h>
+
+@interface MMNetworkBandwidthProvider () {
+    os_unfair_lock _lock;
+    NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *_previousSnapshots;
+    uint64_t _previousTimestamp;
+    mach_timebase_info_data_t _timebase;
+}
+@end
+
+@implementation MMNetworkBandwidthProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _lock = OS_UNFAIR_LOCK_INIT;
+        _previousSnapshots = nil;
+        _previousTimestamp = 0;
+        mach_timebase_info(&_timebase);
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainNetwork;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.network.bandwidth";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSDictionary<NSString *, id> *)calculateBandwidthMetricsWithCurrentSnapshots:(NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)current
+                                                              previousSnapshots:(nullable NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)previous
+                                                                      timeDelta:(NSTimeInterval)timeDelta
+                                                                    ipAddresses:(nullable NSDictionary<NSString *, NSString *> *)ipAddresses {
+    double totalDownBps = 0.0;
+    double totalUpBps = 0.0;
+    double totalDownPps = 0.0;
+    double totalUpPps = 0.0;
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *interfaces = [NSMutableArray arrayWithCapacity:current.count];
+    NSArray<NSString *> *sortedNames = [current.allKeys sortedArrayUsingSelector:@selector(compare:)];
+    
+    NSString *primaryInterface = @"";
+    double maxActivity = -1.0;
+    
+    for (NSString *name in sortedNames) {
+        // Skip loopback for aggregate statistics
+        BOOL isLoopback = [name hasPrefix:@"lo"];
+        
+        NSDictionary<NSString *, NSNumber *> *curr = current[name];
+        NSDictionary<NSString *, NSNumber *> *prev = previous ? previous[name] : nil;
+        
+        uint64_t currInBytes = [curr[@"inBytes"] unsignedLongLongValue];
+        uint64_t currOutBytes = [curr[@"outBytes"] unsignedLongLongValue];
+        uint64_t currInPackets = [curr[@"inPackets"] unsignedLongLongValue];
+        uint64_t currOutPackets = [curr[@"outPackets"] unsignedLongLongValue];
+        uint64_t inErrors = [curr[@"inErrors"] unsignedLongLongValue];
+        uint64_t outErrors = [curr[@"outErrors"] unsignedLongLongValue];
+        
+        uint64_t prevInBytes = prev ? [prev[@"inBytes"] unsignedLongLongValue] : currInBytes;
+        uint64_t prevOutBytes = prev ? [prev[@"outBytes"] unsignedLongLongValue] : currOutBytes;
+        uint64_t prevInPackets = prev ? [prev[@"inPackets"] unsignedLongLongValue] : currInPackets;
+        uint64_t prevOutPackets = prev ? [prev[@"outPackets"] unsignedLongLongValue] : currOutPackets;
+        
+        double deltaInBytes = (currInBytes >= prevInBytes) ? (double)(currInBytes - prevInBytes) : 0.0;
+        double deltaOutBytes = (currOutBytes >= prevOutBytes) ? (double)(currOutBytes - prevOutBytes) : 0.0;
+        double deltaInPackets = (currInPackets >= prevInPackets) ? (double)(currInPackets - prevInPackets) : 0.0;
+        double deltaOutPackets = (currOutPackets >= prevOutPackets) ? (double)(currOutPackets - prevOutPackets) : 0.0;
+        
+        double downBps = (timeDelta > 0.0001) ? (deltaInBytes / timeDelta) : 0.0;
+        double upBps = (timeDelta > 0.0001) ? (deltaOutBytes / timeDelta) : 0.0;
+        double downPps = (timeDelta > 0.0001) ? (deltaInPackets / timeDelta) : 0.0;
+        double upPps = (timeDelta > 0.0001) ? (deltaOutPackets / timeDelta) : 0.0;
+        
+        if (!isLoopback) {
+            totalDownBps += downBps;
+            totalUpBps += upBps;
+            totalDownPps += downPps;
+            totalUpPps += upPps;
+            
+            double activity = downBps + upBps;
+            if (activity > maxActivity) {
+                maxActivity = activity;
+                primaryInterface = name;
+            }
+        }
+        
+        NSString *ip = ipAddresses[name] ?: @"";
+        
+        [interfaces addObject:@{
+            @"name": name,
+            @"downloadBytesPerSec": @(downBps),
+            @"uploadBytesPerSec": @(upBps),
+            @"downloadPacketsPerSec": @(downPps),
+            @"uploadPacketsPerSec": @(upPps),
+            @"cumulativeInBytes": @(currInBytes),
+            @"cumulativeOutBytes": @(currOutBytes),
+            @"cumulativeInPackets": @(currInPackets),
+            @"cumulativeOutPackets": @(currOutPackets),
+            @"inErrors": @(inErrors),
+            @"outErrors": @(outErrors),
+            @"ipv4Address": ip,
+            @"isLoopback": @(isLoopback)
+        }];
+    }
+    
+    if (primaryInterface.length == 0 && current[@"en0"]) {
+        primaryInterface = @"en0";
+    }
+    
+    return @{
+        @"interfaces": interfaces,
+        @"totalDownloadBytesPerSec": @(totalDownBps),
+        @"totalUploadBytesPerSec": @(totalUpBps),
+        @"totalDownloadPacketsPerSec": @(totalDownPps),
+        @"totalUploadPacketsPerSec": @(totalUpPps),
+        @"primaryInterface": primaryInterface,
+        @"timeDelta": @(timeDelta)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    uint64_t now = mach_absolute_time();
+    
+    // 1. Read 64-bit interface stats via NET_RT_IFLIST2
+    NSMutableDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *currentSnapshots = [NSMutableDictionary dictionary];
+    
+    int mib[] = { CTL_NET, PF_ROUTE, 0, 0, NET_RT_IFLIST2, 0 };
+    size_t len = 0;
+    if (sysctl(mib, 6, NULL, &len, NULL, 0) == 0 && len > 0) {
+        char *buf = malloc(len);
+        if (buf && sysctl(mib, 6, buf, &len, NULL, 0) == 0) {
+            char *next = buf;
+            char *lim = buf + len;
+            while (next < lim) {
+                struct if_msghdr *ifm = (struct if_msghdr *)next;
+                next += ifm->ifm_msglen;
+                if (ifm->ifm_type == RTM_IFINFO2) {
+                    struct if_msghdr2 *if2m = (struct if_msghdr2 *)ifm;
+                    struct sockaddr_dl *sdl = (struct sockaddr_dl *)(if2m + 1);
+                    if (sdl->sdl_nlen > 0 && sdl->sdl_nlen < 32) {
+                        char nameBuf[33] = {0};
+                        memcpy(nameBuf, sdl->sdl_data, sdl->sdl_nlen);
+                        NSString *name = [NSString stringWithUTF8String:nameBuf];
+                        
+                        currentSnapshots[name] = @{
+                            @"inBytes": @(if2m->ifm_data.ifi_ibytes),
+                            @"outBytes": @(if2m->ifm_data.ifi_obytes),
+                            @"inPackets": @(if2m->ifm_data.ifi_ipackets),
+                            @"outPackets": @(if2m->ifm_data.ifi_opackets),
+                            @"inErrors": @(if2m->ifm_data.ifi_ierrors),
+                            @"outErrors": @(if2m->ifm_data.ifi_oerrors)
+                        };
+                    }
+                }
+            }
+        }
+        if (buf) free(buf);
+    }
+    
+    // 2. Query IPv4 addresses via getifaddrs
+    NSMutableDictionary<NSString *, NSString *> *ipDict = [NSMutableDictionary dictionary];
+    struct ifaddrs *ifap = NULL;
+    if (getifaddrs(&ifap) == 0) {
+        for (struct ifaddrs *ifa = ifap; ifa != NULL; ifa = ifa->ifa_next) {
+            if (ifa->ifa_addr && ifa->ifa_addr->sa_family == AF_INET) {
+                char ipBuf[INET_ADDRSTRLEN] = {0};
+                struct sockaddr_in *sin = (struct sockaddr_in *)ifa->ifa_addr;
+                if (inet_ntop(AF_INET, &sin->sin_addr, ipBuf, sizeof(ipBuf))) {
+                    NSString *name = [NSString stringWithUTF8String:ifa->ifa_name];
+                    ipDict[name] = [NSString stringWithUTF8String:ipBuf];
+                }
+            }
+        }
+        freeifaddrs(ifap);
+    }
+    
+    os_unfair_lock_lock(&_lock);
+    NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *prev = _previousSnapshots;
+    uint64_t prevTime = _previousTimestamp;
+    
+    _previousSnapshots = currentSnapshots;
+    _previousTimestamp = now;
+    os_unfair_lock_unlock(&_lock);
+    
+    NSTimeInterval timeDelta = 1.0;
+    if (prevTime > 0) {
+        uint64_t elapsed = now - prevTime;
+        timeDelta = (double)elapsed * _timebase.numer / _timebase.denom / 1e9;
+    }
+    
+    return [MMNetworkBandwidthProvider calculateBandwidthMetricsWithCurrentSnapshots:currentSnapshots
+                                                                   previousSnapshots:prev
+                                                                           timeDelta:timeDelta
+                                                                         ipAddresses:ipDict];
+}
+
+@end

Sources/Telemetry/Network/MMNetworkSocketsProvider.h

@@ -0,0 +1,27 @@
+#ifndef MMNetworkSocketsProvider_h
+#define MMNetworkSocketsProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMNetworkSocketsProvider
+ * Inspects system-wide open TCP and UDP sockets, local/remote endpoints, connection states,
+ * and owning processes.
+ */
+@interface MMNetworkSocketsProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Pure calculator / summarizer method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateSocketSummaryWithSocketList:(NSArray<NSDictionary<NSString *, id> *> *)sockets;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMNetworkSocketsProvider_h */

Sources/Telemetry/Network/MMNetworkSocketsProvider.m

@@ -0,0 +1,152 @@
+#import "MMNetworkSocketsProvider.h"
+#import <libproc.h>
+#import <sys/proc_info.h>
+#import <arpa/inet.h>
+
+@implementation MMNetworkSocketsProvider
+
+- (instancetype)init {
+    self = [super init];
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainNetwork;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.network.sockets";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
+static NSString *tcpStateString(int state) {
+    switch (state) {
+        case 0: return @"CLOSED";
+        case 1: return @"LISTEN";
+        case 2: return @"SYN_SENT";
+        case 3: return @"SYN_RCVD";
+        case 4: return @"ESTABLISHED";
+        case 5: return @"CLOSE_WAIT";
+        case 6: return @"FIN_WAIT_1";
+        case 7: return @"CLOSING";
+        case 8: return @"LAST_ACK";
+        case 9: return @"FIN_WAIT_2";
+        case 10: return @"TIME_WAIT";
+        default: return @"UNKNOWN";
+    }
+}
+
++ (NSDictionary<NSString *, id> *)calculateSocketSummaryWithSocketList:(NSArray<NSDictionary<NSString *, id> *> *)sockets {
+    NSUInteger tcpCount = 0;
+    NSUInteger udpCount = 0;
+    NSUInteger listenCount = 0;
+    NSUInteger establishedCount = 0;
+    
+    for (NSDictionary<NSString *, id> *sock in sockets) {
+        NSString *proto = sock[@"protocol"];
+        NSString *state = sock[@"state"];
+        
+        if ([proto isEqualToString:@"TCP"]) {
+            tcpCount++;
+            if ([state isEqualToString:@"LISTEN"]) {
+                listenCount++;
+            } else if ([state isEqualToString:@"ESTABLISHED"]) {
+                establishedCount++;
+            }
+        } else if ([proto isEqualToString:@"UDP"]) {
+            udpCount++;
+        }
+    }
+    
+    return @{
+        @"socketCount": @(sockets.count),
+        @"tcpCount": @(tcpCount),
+        @"udpCount": @(udpCount),
+        @"listenCount": @(listenCount),
+        @"establishedCount": @(establishedCount),
+        @"sockets": sockets
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    int pids[2048];
+    int bytes = proc_listpids(PROC_ALL_PIDS, 0, pids, sizeof(pids));
+    int pidCount = bytes / sizeof(int);
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *sockets = [NSMutableArray array];
+    
+    for (int i = 0; i < pidCount; i++) {
+        pid_t pid = pids[i];
+        if (pid <= 0) continue;
+        
+        int sz = proc_pidinfo(pid, PROC_PIDLISTFDS, 0, NULL, 0);
+        if (sz <= 0) continue;
+        
+        struct proc_fdinfo *fds = malloc(sz);
+        if (!fds) continue;
+        
+        int actual = proc_pidinfo(pid, PROC_PIDLISTFDS, 0, fds, sz);
+        int fdCount = actual / sizeof(struct proc_fdinfo);
+        
+        char procNameBuf[256] = {0};
+        BOOL procNameFetched = NO;
+        
+        for (int j = 0; j < fdCount; j++) {
+            if (fds[j].proc_fdtype == PROX_FDTYPE_SOCKET) {
+                struct socket_fdinfo si;
+                if (proc_pidfdinfo(pid, fds[j].proc_fd, PROC_PIDFDSOCKETINFO, &si, sizeof(si)) == sizeof(si)) {
+                    int family = si.psi.soi_family;
+                    if (family == AF_INET || family == AF_INET6) {
+                        if (!procNameFetched) {
+                            proc_name(pid, procNameBuf, sizeof(procNameBuf));
+                            procNameFetched = YES;
+                        }
+                        
+                        char localIP[INET6_ADDRSTRLEN] = {0};
+                        char remoteIP[INET6_ADDRSTRLEN] = {0};
+                        int lport = 0, rport = 0;
+                        NSString *familyStr = (family == AF_INET) ? @"IPv4" : @"IPv6";
+                        NSString *proto = (si.psi.soi_type == SOCK_STREAM) ? @"TCP" : @"UDP";
+                        NSString *state = @"NONE";
+                        
+                        if (family == AF_INET) {
+                            inet_ntop(AF_INET, &si.psi.soi_proto.pri_in.insi_laddr.ina_46.i46a_addr4, localIP, sizeof(localIP));
+                            inet_ntop(AF_INET, &si.psi.soi_proto.pri_in.insi_faddr.ina_46.i46a_addr4, remoteIP, sizeof(remoteIP));
+                            lport = ntohs(si.psi.soi_proto.pri_in.insi_lport);
+                            rport = ntohs(si.psi.soi_proto.pri_in.insi_fport);
+                        } else {
+                            inet_ntop(AF_INET6, &si.psi.soi_proto.pri_in.insi_laddr.ina_6, localIP, sizeof(localIP));
+                            inet_ntop(AF_INET6, &si.psi.soi_proto.pri_in.insi_faddr.ina_6, remoteIP, sizeof(remoteIP));
+                            lport = ntohs(si.psi.soi_proto.pri_in.insi_lport);
+                            rport = ntohs(si.psi.soi_proto.pri_in.insi_fport);
+                        }
+                        
+                        if (si.psi.soi_type == SOCK_STREAM) {
+                            state = tcpStateString(si.psi.soi_proto.pri_tcp.tcpsi_state);
+                        }
+                        
+                        [sockets addObject:@{
+                            @"pid": @(pid),
+                            @"processName": [NSString stringWithUTF8String:procNameBuf],
+                            @"protocol": proto,
+                            @"family": familyStr,
+                            @"localAddress": [NSString stringWithUTF8String:localIP],
+                            @"localPort": @(lport),
+                            @"remoteAddress": [NSString stringWithUTF8String:remoteIP],
+                            @"remotePort": @(rport),
+                            @"state": state
+                        }];
+                    }
+                }
+            }
+        }
+        free(fds);
+    }
+    
+    return [MMNetworkSocketsProvider calculateSocketSummaryWithSocketList:sockets];
+}
+
+@end

Sources/Telemetry/Peripherals/MMPeripheralsProvider.h

@@ -0,0 +1,45 @@
+//
+//  MMPeripheralsProvider.h
+//  MacMonitor
+//
+//  Telemetry provider enumerating connected USB, Thunderbolt, and PCI peripheral devices via IOKit.
+//
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+typedef NS_ENUM(NSInteger, MMPeripheralBusType) {
+    MMPeripheralBusTypeUSB,
+    MMPeripheralBusTypeThunderbolt,
+    MMPeripheralBusTypePCI
+};
+
+@interface MMPeripheralDevice : NSObject
+
+@property (nonatomic, copy) NSString *name;
+@property (nonatomic, assign) MMPeripheralBusType busType;
+@property (nonatomic, copy) NSString *vendorName;
+@property (nonatomic, assign) uint32_t vendorID;
+@property (nonatomic, assign) uint32_t productID;
+@property (nonatomic, copy, nullable) NSString *serialNumber;
+@property (nonatomic, copy, nullable) NSString *deviceClass;
+@property (nonatomic, assign) uint64_t locationID;
+@property (nonatomic, assign) BOOL isBuiltIn;
+
+- (NSDictionary<NSString *, id> *)toDictionary;
+
+@end
+
+@interface MMPeripheralsProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
++ (NSArray<MMPeripheralDevice *> *)sampleUSBDevices;
++ (NSArray<MMPeripheralDevice *> *)sampleThunderboltDevices;
++ (NSArray<MMPeripheralDevice *> *)samplePCIDevices;
+
+@end
+
+NS_ASSUME_NONNULL_END

Sources/Telemetry/Peripherals/MMPeripheralsProvider.m

@@ -0,0 +1,255 @@
+//
+//  MMPeripheralsProvider.m
+//  MacMonitor
+//
+//  Telemetry provider enumerating connected USB, Thunderbolt, and PCI peripheral devices via IOKit.
+//
+
+#import "MMPeripheralsProvider.h"
+#import <IOKit/IOKitLib.h>
+
+@implementation MMPeripheralDevice
+
+- (NSDictionary<NSString *, id> *)toDictionary {
+    NSString *busStr = @"USB";
+    if (self.busType == MMPeripheralBusTypeThunderbolt) {
+        busStr = @"Thunderbolt";
+    } else if (self.busType == MMPeripheralBusTypePCI) {
+        busStr = @"PCI";
+    }
+    
+    return @{
+        @"name": self.name ?: @"Unknown Device",
+        @"busType": busStr,
+        @"vendorName": self.vendorName ?: @"Unknown",
+        @"vendorID": @(self.vendorID),
+        @"productID": @(self.productID),
+        @"serialNumber": self.serialNumber ?: @"",
+        @"deviceClass": self.deviceClass ?: @"",
+        @"locationID": @(self.locationID),
+        @"isBuiltIn": @(self.isBuiltIn)
+    };
+}
+
+@end
+
+@implementation MMPeripheralsProvider
+
+- (instancetype)init {
+    self = [super init];
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainPeripherals;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.peripherals";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSArray<MMPeripheralDevice *> *)sampleUSBDevices {
+    NSMutableArray<MMPeripheralDevice *> *devices = [NSMutableArray array];
+    
+    // Query both IOUSBHostDevice (macOS modern) and IOUSBDevice (legacy/fallback)
+    const char *classes[] = { "IOUSBHostDevice", "IOUSBDevice" };
+    NSMutableSet<NSNumber *> *seenRegistryIDs = [NSMutableSet set];
+    
+    for (int i = 0; i < 2; i++) {
+        CFMutableDictionaryRef matching = IOServiceMatching(classes[i]);
+        if (!matching) continue;
+        
+        io_iterator_t iterator = IO_OBJECT_NULL;
+        kern_return_t kr = IOServiceGetMatchingServices(kIOMainPortDefault, matching, &iterator);
+        if (kr != KERN_SUCCESS || iterator == IO_OBJECT_NULL) continue;
+        
+        io_service_t service = IO_OBJECT_NULL;
+        while ((service = IOIteratorNext(iterator)) != IO_OBJECT_NULL) {
+            uint64_t regID = 0;
+            IORegistryEntryGetRegistryEntryID(service, &regID);
+            if ([seenRegistryIDs containsObject:@(regID)]) {
+                IOObjectRelease(service);
+                continue;
+            }
+            [seenRegistryIDs addObject:@(regID)];
+            
+            CFMutableDictionaryRef props = NULL;
+            if (IORegistryEntryCreateCFProperties(service, &props, kCFAllocatorDefault, 0) == KERN_SUCCESS && props) {
+                NSDictionary *dict = (__bridge NSDictionary *)props;
+                
+                NSString *name = dict[@"USB Product Name"] ?: (dict[@"kUSBProductString"] ?: dict[@"IOName"]);
+                if (!name || name.length == 0) {
+                    name = @"USB Device";
+                }
+                
+                NSString *vendor = dict[@"USB Vendor Name"] ?: (dict[@"kUSBVendorString"] ?: @"");
+                uint32_t vendorID = [dict[@"idVendor"] unsignedIntValue];
+                uint32_t productID = [dict[@"idProduct"] unsignedIntValue];
+                NSString *serial = dict[@"USB Serial Number"] ?: dict[@"kUSBSerialNumberString"];
+                uint64_t locID = [dict[@"locationID"] unsignedLongLongValue];
+                
+                BOOL builtIn = NO;
+                if (dict[@"Built-In"]) {
+                    builtIn = [dict[@"Built-In"] boolValue];
+                } else if ([dict[@"non-removable"] isKindOfClass:[NSString class]]) {
+                    builtIn = [dict[@"non-removable"] isEqualToString:@"yes"];
+                }
+                
+                MMPeripheralDevice *dev = [[MMPeripheralDevice alloc] init];
+                dev.name = name;
+                dev.busType = MMPeripheralBusTypeUSB;
+                dev.vendorName = vendor;
+                dev.vendorID = vendorID;
+                dev.productID = productID;
+                dev.serialNumber = serial;
+                dev.locationID = locID;
+                dev.isBuiltIn = builtIn;
+                
+                [devices addObject:dev];
+                CFRelease(props);
+            }
+            IOObjectRelease(service);
+        }
+        IOObjectRelease(iterator);
+    }
+    
+    return devices;
+}
+
++ (NSArray<MMPeripheralDevice *> *)sampleThunderboltDevices {
+    NSMutableArray<MMPeripheralDevice *> *devices = [NSMutableArray array];
+    
+    CFMutableDictionaryRef matching = IOServiceMatching("IOThunderboltDevice");
+    if (!matching) return devices;
+    
+    io_iterator_t iterator = IO_OBJECT_NULL;
+    kern_return_t kr = IOServiceGetMatchingServices(kIOMainPortDefault, matching, &iterator);
+    if (kr != KERN_SUCCESS || iterator == IO_OBJECT_NULL) return devices;
+    
+    io_service_t service = IO_OBJECT_NULL;
+    while ((service = IOIteratorNext(iterator)) != IO_OBJECT_NULL) {
+        CFMutableDictionaryRef props = NULL;
+        if (IORegistryEntryCreateCFProperties(service, &props, kCFAllocatorDefault, 0) == KERN_SUCCESS && props) {
+            NSDictionary *dict = (__bridge NSDictionary *)props;
+            
+            NSString *name = dict[@"Device Name"] ?: dict[@"IOName"];
+            if (!name) name = @"Thunderbolt Device";
+            
+            NSString *vendor = dict[@"Vendor Name"] ?: @"";
+            uint32_t vendorID = [dict[@"Vendor ID"] unsignedIntValue];
+            uint32_t productID = [dict[@"Device ID"] unsignedIntValue];
+            
+            MMPeripheralDevice *dev = [[MMPeripheralDevice alloc] init];
+            dev.name = name;
+            dev.busType = MMPeripheralBusTypeThunderbolt;
+            dev.vendorName = vendor;
+            dev.vendorID = vendorID;
+            dev.productID = productID;
+            dev.isBuiltIn = NO;
+            
+            [devices addObject:dev];
+            CFRelease(props);
+        }
+        IOObjectRelease(service);
+    }
+    IOObjectRelease(iterator);
+    return devices;
+}
+
+static uint32_t ParseDataUInt32(NSData *data) {
+    if (![data isKindOfClass:[NSData class]] || data.length == 0) return 0;
+    uint32_t val = 0;
+    size_t copyLen = MIN(sizeof(val), data.length);
+    memcpy(&val, data.bytes, copyLen);
+    return val;
+}
+
++ (NSArray<MMPeripheralDevice *> *)samplePCIDevices {
+    NSMutableArray<MMPeripheralDevice *> *devices = [NSMutableArray array];
+    
+    CFMutableDictionaryRef matching = IOServiceMatching("IOPCIDevice");
+    if (!matching) return devices;
+    
+    io_iterator_t iterator = IO_OBJECT_NULL;
+    kern_return_t kr = IOServiceGetMatchingServices(kIOMainPortDefault, matching, &iterator);
+    if (kr != KERN_SUCCESS || iterator == IO_OBJECT_NULL) return devices;
+    
+    io_service_t service = IO_OBJECT_NULL;
+    while ((service = IOIteratorNext(iterator)) != IO_OBJECT_NULL) {
+        CFMutableDictionaryRef props = NULL;
+        if (IORegistryEntryCreateCFProperties(service, &props, kCFAllocatorDefault, 0) == KERN_SUCCESS && props) {
+            NSDictionary *dict = (__bridge NSDictionary *)props;
+            
+            NSString *name = nil;
+            if ([dict[@"model"] isKindOfClass:[NSData class]]) {
+                name = [[NSString alloc] initWithData:dict[@"model"] encoding:NSUTF8StringEncoding];
+                name = [name stringByTrimmingCharactersInSet:[NSCharacterSet controlCharacterSet]];
+            }
+            if (!name || name.length == 0) {
+                name = dict[@"IOName"];
+            }
+            if (!name || name.length == 0) {
+                name = @"PCI Device";
+            }
+            
+            uint32_t vendorID = 0;
+            if ([dict[@"vendor-id"] isKindOfClass:[NSData class]]) {
+                vendorID = ParseDataUInt32(dict[@"vendor-id"]);
+            }
+            
+            uint32_t deviceID = 0;
+            if ([dict[@"device-id"] isKindOfClass:[NSData class]]) {
+                deviceID = ParseDataUInt32(dict[@"device-id"]);
+            }
+            
+            MMPeripheralDevice *dev = [[MMPeripheralDevice alloc] init];
+            dev.name = name;
+            dev.busType = MMPeripheralBusTypePCI;
+            dev.vendorID = vendorID;
+            dev.productID = deviceID;
+            dev.isBuiltIn = YES;
+            
+            [devices addObject:dev];
+            CFRelease(props);
+        }
+        IOObjectRelease(service);
+    }
+    IOObjectRelease(iterator);
+    return devices;
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    NSArray<MMPeripheralDevice *> *usb = [MMPeripheralsProvider sampleUSBDevices];
+    NSArray<MMPeripheralDevice *> *tb = [MMPeripheralsProvider sampleThunderboltDevices];
+    NSArray<MMPeripheralDevice *> *pci = [MMPeripheralsProvider samplePCIDevices];
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *usbList = [NSMutableArray arrayWithCapacity:usb.count];
+    for (MMPeripheralDevice *d in usb) {
+        [usbList addObject:[d toDictionary]];
+    }
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *tbList = [NSMutableArray arrayWithCapacity:tb.count];
+    for (MMPeripheralDevice *d in tb) {
+        [tbList addObject:[d toDictionary]];
+    }
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *pciList = [NSMutableArray arrayWithCapacity:pci.count];
+    for (MMPeripheralDevice *d in pci) {
+        [pciList addObject:[d toDictionary]];
+    }
+    
+    NSUInteger totalCount = usb.count + tb.count + pci.count;
+    
+    return @{
+        @"totalDeviceCount": @(totalCount),
+        @"usbDevices": usbList,
+        @"thunderboltDevices": tbList,
+        @"pciDevices": pciList
+    };
+}
+
+@end

Sources/Telemetry/Power/MMBatteryTelemetryProvider.h

@@ -0,0 +1,23 @@
+//
+//  MMBatteryTelemetryProvider.h
+//  MacMonitor
+//
+//  Telemetry provider for AppleSmartBattery health, cycle count, capacity, and adapter info.
+//
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+@interface MMBatteryTelemetryProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, readonly) BOOL hasBattery;
+
+- (instancetype)init;
+
++ (NSDictionary<NSString *, id> *)calculateBatteryHealthWithProperties:(nullable NSDictionary<NSString *, id> *)rawProps;
+
+@end
+
+NS_ASSUME_NONNULL_END

Sources/Telemetry/Power/MMBatteryTelemetryProvider.m

@@ -0,0 +1,179 @@
+//
+//  MMBatteryTelemetryProvider.m
+//  MacMonitor
+//
+//  Telemetry provider for AppleSmartBattery health, cycle count, capacity, and adapter info.
+//
+
+#import "MMBatteryTelemetryProvider.h"
+#import <IOKit/IOKitLib.h>
+#import <IOKit/ps/IOPowerSources.h>
+#import <IOKit/ps/IOPSKeys.h>
+
+@implementation MMBatteryTelemetryProvider
+
+- (instancetype)init {
+    self = [super init];
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainPower;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.battery";
+}
+
+- (BOOL)isAvailable {
+    io_service_t service = IOServiceGetMatchingService(kIOMainPortDefault, IOServiceMatching("AppleSmartBattery"));
+    if (service != IO_OBJECT_NULL) {
+        IOObjectRelease(service);
+        return YES;
+    }
+    return NO;
+}
+
+- (BOOL)hasBattery {
+    return [self isAvailable];
+}
+
++ (NSDictionary<NSString *, id> *)calculateBatteryHealthWithProperties:(nullable NSDictionary<NSString *, id> *)rawProps {
+    if (!rawProps || rawProps.count == 0) {
+        return @{
+            @"hasBattery": @(NO),
+            @"installed": @(NO),
+            @"healthCondition": @"No Battery",
+            @"healthPercent": @(0.0),
+            @"cycleCount": @(0),
+            @"designCycleCount": @(0),
+            @"currentCapacity": @(0),
+            @"maxCapacity": @(0),
+            @"designCapacity": @(0),
+            @"temperature": @(0.0),
+            @"voltage": @(0.0),
+            @"amperage": @(0.0),
+            @"watts": @(0.0),
+            @"isCharging": @(NO),
+            @"isCharged": @(NO),
+            @"externalConnected": @(NO),
+            @"timeRemainingMinutes": @(-1),
+            @"manufacturer": @"N/A",
+            @"serial": @"N/A",
+            @"deviceName": @"N/A"
+        };
+    }
+
+    BOOL installed = [rawProps[@"BatteryInstalled"] boolValue];
+    NSInteger cycleCount = [rawProps[@"CycleCount"] integerValue];
+    NSInteger designCycleCount = rawProps[@"DesignCycleCount9C"] ? [rawProps[@"DesignCycleCount9C"] integerValue] : 1000;
+    
+    NSInteger currentCapacity = [rawProps[@"CurrentCapacity"] integerValue];
+    NSInteger maxCapacity = [rawProps[@"MaxCapacity"] integerValue];
+    
+    // DesignCapacity might be at top level or inside BatteryData
+    NSInteger designCapacity = [rawProps[@"DesignCapacity"] integerValue];
+    if (designCapacity <= 0 && [rawProps[@"BatteryData"] isKindOfClass:[NSDictionary class]]) {
+        designCapacity = [rawProps[@"BatteryData"][@"DesignCapacity"] integerValue];
+    }
+    
+    // Health percentage = (MaxCapacity / DesignCapacity) * 100.0
+    double healthPercent = 0.0;
+    if (designCapacity > 0) {
+        healthPercent = ((double)maxCapacity / (double)designCapacity) * 100.0;
+        if (healthPercent > 100.0) healthPercent = 100.0;
+    } else if (maxCapacity > 0) {
+        healthPercent = 100.0;
+    }
+    
+    // Health condition evaluation
+    NSString *condition = @"Normal";
+    BOOL permanentFailure = [rawProps[@"PermanentFailureStatus"] integerValue] != 0;
+    if (permanentFailure) {
+        condition = @"Permanent Failure";
+    } else if (healthPercent < 70.0 || (designCycleCount > 0 && cycleCount > designCycleCount)) {
+        condition = @"Service Recommended";
+    } else if (healthPercent < 80.0) {
+        condition = @"Fair";
+    } else {
+        condition = @"Normal";
+    }
+    
+    // Temperature: AppleSmartBattery returns in units of 0.01 deg C or 0.1 deg C (e.g. 3151 = 31.51 deg C)
+    double rawTemp = [rawProps[@"Temperature"] doubleValue];
+    double tempC = rawTemp > 1000.0 ? (rawTemp / 100.0) : (rawTemp > 100.0 ? rawTemp / 10.0 : rawTemp);
+    
+    double voltage = [rawProps[@"Voltage"] doubleValue] / 1000.0; // mV -> V
+    
+    // Amperage can be signed 64-bit stored as unsigned in dict
+    int64_t rawAmp = [rawProps[@"InstantAmperage"] longLongValue];
+    if (rawAmp == 0) {
+        rawAmp = [rawProps[@"Amperage"] longLongValue];
+    }
+    int32_t signedAmp = (int32_t)rawAmp; // standard cast from uint32/uint64 representation
+    double amperage = ((double)signedAmp) / 1000.0; // mA -> A
+    double watts = fabs(voltage * amperage);
+    
+    BOOL isCharging = [rawProps[@"IsCharging"] boolValue];
+    BOOL fullyCharged = [rawProps[@"FullyCharged"] boolValue];
+    BOOL externalConnected = [rawProps[@"ExternalConnected"] boolValue];
+    NSInteger timeRemaining = [rawProps[@"TimeRemaining"] integerValue];
+    if (timeRemaining == 65535) {
+        timeRemaining = -1;
+    }
+    
+    NSString *manufacturer = rawProps[@"Manufacturer"] ?: @"Apple";
+    NSString *serial = rawProps[@"Serial"] ?: @"";
+    NSString *deviceName = rawProps[@"DeviceName"] ?: @"";
+    
+    // Power adapter details
+    NSDictionary *adapterDetails = [rawProps[@"AdapterDetails"] isKindOfClass:[NSDictionary class]] ? rawProps[@"AdapterDetails"] : nil;
+    NSInteger adapterWatts = 0;
+    if (adapterDetails && adapterDetails[@"Watts"]) {
+        adapterWatts = [adapterDetails[@"Watts"] integerValue];
+    }
+    
+    return @{
+        @"hasBattery": @(YES),
+        @"installed": @(installed),
+        @"healthCondition": condition,
+        @"healthPercent": @(round(healthPercent * 10.0) / 10.0),
+        @"cycleCount": @(cycleCount),
+        @"designCycleCount": @(designCycleCount),
+        @"currentCapacity": @(currentCapacity),
+        @"maxCapacity": @(maxCapacity),
+        @"designCapacity": @(designCapacity),
+        @"temperature": @(round(tempC * 10.0) / 10.0),
+        @"voltage": @(round(voltage * 100.0) / 100.0),
+        @"amperage": @(round(amperage * 100.0) / 100.0),
+        @"watts": @(round(watts * 10.0) / 10.0),
+        @"isCharging": @(isCharging),
+        @"isCharged": @(fullyCharged),
+        @"externalConnected": @(externalConnected),
+        @"timeRemainingMinutes": @(timeRemaining),
+        @"manufacturer": manufacturer,
+        @"serial": serial,
+        @"deviceName": deviceName,
+        @"adapterWatts": @(adapterWatts)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    io_service_t service = IOServiceGetMatchingService(kIOMainPortDefault, IOServiceMatching("AppleSmartBattery"));
+    if (service == IO_OBJECT_NULL) {
+        return [MMBatteryTelemetryProvider calculateBatteryHealthWithProperties:nil];
+    }
+    
+    CFMutableDictionaryRef props = NULL;
+    kern_return_t kr = IORegistryEntryCreateCFProperties(service, &props, kCFAllocatorDefault, 0);
+    IOObjectRelease(service);
+    
+    if (kr != KERN_SUCCESS || !props) {
+        return [MMBatteryTelemetryProvider calculateBatteryHealthWithProperties:nil];
+    }
+    
+    NSDictionary *dict = (__bridge_transfer NSDictionary *)props;
+    return [MMBatteryTelemetryProvider calculateBatteryHealthWithProperties:dict];
+}
+
+@end

Sources/Telemetry/Power/MMPowerTelemetryProvider.h

@@ -0,0 +1,45 @@
+#ifndef MMPowerTelemetryProvider_h
+#define MMPowerTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+#import "MMAppleSMCClient.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMPowerTelemetryProvider
+ * Samples system power draw, CPU/GPU package wattage, rail voltages, and currents
+ * via AppleSMC and AppleSmartBattery IOKit interfaces.
+ */
+@interface MMPowerTelemetryProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, strong, readonly) MMAppleSMCClient *smcClient;
+@property (nonatomic, readonly) NSArray<NSString *> *discoveredPowerKeys;
+@property (nonatomic, readonly) NSArray<NSString *> *discoveredVoltageKeys;
+@property (nonatomic, readonly) NSArray<NSString *> *discoveredCurrentKeys;
+
+- (instancetype)init;
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client;
+
+/**
+ * Friendly name for power, voltage, and current SMC keys.
+ */
++ (NSString *)humanReadableNameForKey:(NSString *)key;
+
+/**
+ * Unit of measurement for SMC key ("W", "V", "A").
+ */
++ (NSString *)unitForKey:(NSString *)key;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculatePowerMetricsWithReadings:(NSDictionary<NSString *, NSNumber *> *)readings
+                                                        batteryInfo:(nullable NSDictionary<NSString *, id> *)batteryInfo;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMPowerTelemetryProvider_h */

Sources/Telemetry/Power/MMPowerTelemetryProvider.m

@@ -0,0 +1,314 @@
+#import "MMPowerTelemetryProvider.h"
+#import <IOKit/IOKitLib.h>
+#import <IOKit/ps/IOPowerSources.h>
+#import <IOKit/ps/IOPSKeys.h>
+
+@interface MMPowerTelemetryProvider () {
+    MMAppleSMCClient *_smcClient;
+    NSMutableArray<NSString *> *_discoveredPowerKeys;
+    NSMutableArray<NSString *> *_discoveredVoltageKeys;
+    NSMutableArray<NSString *> *_discoveredCurrentKeys;
+    BOOL _probed;
+}
+@end
+
+@implementation MMPowerTelemetryProvider
+
+- (instancetype)init {
+    return [self initWithSMCClient:[MMAppleSMCClient sharedClient]];
+}
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client {
+    self = [super init];
+    if (self) {
+        _smcClient = client;
+        _discoveredPowerKeys = [NSMutableArray array];
+        _discoveredVoltageKeys = [NSMutableArray array];
+        _discoveredCurrentKeys = [NSMutableArray array];
+        [self probeSensors];
+    }
+    return self;
+}
+
+- (void)probeSensors {
+    if (!_smcClient.isAvailable) return;
+    
+    NSArray<NSString *> *powerCandidates = @[
+        @"PSTR", @"PDTR", @"PCPR", @"PCTR", @"PC0C", @"PCPT",
+        @"PG0R", @"PGTR", @"PMSR", @"PM0R", @"PCPC"
+    ];
+    
+    NSArray<NSString *> *voltageCandidates = @[
+        @"VC0C", @"VD0R", @"VN0C", @"VM0R", @"VP0R"
+    ];
+    
+    NSArray<NSString *> *currentCandidates = @[
+        @"IC0C", @"ID0R", @"IG0C", @"IM0R"
+    ];
+    
+    [_discoveredPowerKeys removeAllObjects];
+    for (NSString *key in powerCandidates) {
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val && [val doubleValue] > 0.0 && [val doubleValue] < 5000.0) {
+            [_discoveredPowerKeys addObject:key];
+        }
+    }
+    
+    [_discoveredVoltageKeys removeAllObjects];
+    for (NSString *key in voltageCandidates) {
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val && [val doubleValue] > 0.0) {
+            [_discoveredVoltageKeys addObject:key];
+        }
+    }
+    
+    [_discoveredCurrentKeys removeAllObjects];
+    for (NSString *key in currentCandidates) {
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val && [val doubleValue] > 0.0) {
+            [_discoveredCurrentKeys addObject:key];
+        }
+    }
+    
+    _probed = YES;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainPower;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.power";
+}
+
+- (BOOL)isAvailable {
+    return _smcClient.isAvailable;
+}
+
+- (MMAppleSMCClient *)smcClient {
+    return _smcClient;
+}
+
+- (NSArray<NSString *> *)discoveredPowerKeys {
+    return [_discoveredPowerKeys copy];
+}
+
+- (NSArray<NSString *> *)discoveredVoltageKeys {
+    return [_discoveredVoltageKeys copy];
+}
+
+- (NSArray<NSString *> *)discoveredCurrentKeys {
+    return [_discoveredCurrentKeys copy];
+}
+
++ (NSString *)unitForKey:(NSString *)key {
+    if ([key hasPrefix:@"P"]) return @"W";
+    if ([key hasPrefix:@"V"]) return @"V";
+    if ([key hasPrefix:@"I"]) return @"A";
+    return @"";
+}
+
++ (NSString *)humanReadableNameForKey:(NSString *)key {
+    static NSDictionary<NSString *, NSString *> *names = nil;
+    static dispatch_once_t onceToken;
+    dispatch_once(&onceToken, ^{
+        names = @{
+            @"PSTR": @"Total System Power",
+            @"PDTR": @"DC-In Total Power",
+            @"PCPR": @"CPU Package Power",
+            @"PCTR": @"CPU Total Power",
+            @"PC0C": @"CPU Core Power",
+            @"PCPT": @"CPU Package Total Power",
+            @"PG0R": @"GPU 0 Power",
+            @"PGTR": @"GPU Total Power",
+            @"PMSR": @"Memory Subsystem Power",
+            @"PM0R": @"Memory Rail Power",
+            @"PCPC": @"Power Supply In / AC",
+            @"VC0C": @"CPU Core Voltage",
+            @"VD0R": @"DC-In Rail Voltage",
+            @"VN0C": @"PCH Rail Voltage",
+            @"VM0R": @"Memory Rail Voltage",
+            @"VP0R": @"Power Supply Voltage",
+            @"IC0C": @"CPU Core Current",
+            @"ID0R": @"DC-In Rail Current",
+            @"IG0C": @"GPU Rail Current",
+            @"IM0R": @"Memory Rail Current"
+        };
+    });
+    
+    NSString *match = names[key];
+    return match ?: key;
+}
+
++ (NSDictionary<NSString *, id> *)calculatePowerMetricsWithReadings:(NSDictionary<NSString *, NSNumber *> *)readings
+                                                        batteryInfo:(nullable NSDictionary<NSString *, id> *)batteryInfo {
+    // Determine system total power
+    double systemTotal = 0.0;
+    if (readings[@"PSTR"]) {
+        systemTotal = [readings[@"PSTR"] doubleValue];
+    } else if (readings[@"PDTR"]) {
+        systemTotal = [readings[@"PDTR"] doubleValue];
+    } else if (batteryInfo[@"batteryWatts"]) {
+        systemTotal = [batteryInfo[@"batteryWatts"] doubleValue];
+    }
+    
+    // CPU wattage
+    double cpuWatts = 0.0;
+    if (readings[@"PCPR"]) {
+        cpuWatts = [readings[@"PCPR"] doubleValue];
+    } else if (readings[@"PCTR"]) {
+        cpuWatts = [readings[@"PCTR"] doubleValue];
+    } else if (readings[@"PC0C"]) {
+        cpuWatts = [readings[@"PC0C"] doubleValue];
+    } else if (readings[@"PCPT"]) {
+        cpuWatts = [readings[@"PCPT"] doubleValue];
+    }
+    
+    // Voltage & Current
+    double cpuVoltage = readings[@"VC0C"] ? [readings[@"VC0C"] doubleValue] : 0.0;
+    double cpuCurrent = readings[@"IC0C"] ? [readings[@"IC0C"] doubleValue] : 0.0;
+    
+    // Fallback: calculate cpuWatts from V * I if SMC didn't provide direct wattage
+    if (cpuWatts == 0.0 && cpuVoltage > 0.0 && cpuCurrent > 0.0) {
+        cpuWatts = cpuVoltage * cpuCurrent;
+    }
+    
+    // GPU wattage
+    double gpuWatts = 0.0;
+    if (readings[@"PG0R"]) {
+        gpuWatts = [readings[@"PG0R"] doubleValue];
+    } else if (readings[@"PGTR"]) {
+        gpuWatts = [readings[@"PGTR"] doubleValue];
+    }
+    
+    // Memory wattage
+    double memoryWatts = 0.0;
+    if (readings[@"PMSR"]) {
+        memoryWatts = [readings[@"PMSR"] doubleValue];
+    } else if (readings[@"PM0R"]) {
+        memoryWatts = [readings[@"PM0R"] doubleValue];
+    }
+    
+    // Collect all individual sensor entries
+    NSMutableArray<NSDictionary<NSString *, id> *> *sensors = [NSMutableArray arrayWithCapacity:readings.count];
+    NSArray<NSString *> *sortedKeys = [readings.allKeys sortedArrayUsingSelector:@selector(compare:)];
+    for (NSString *k in sortedKeys) {
+        double val = [readings[k] doubleValue];
+        [sensors addObject:@{
+            @"key": k,
+            @"name": [self humanReadableNameForKey:k],
+            @"value": @(val),
+            @"unit": [self unitForKey:k]
+        }];
+    }
+    
+    NSString *powerSource = batteryInfo[@"powerSource"] ?: @"AC Power";
+    BOOL isCharging = [batteryInfo[@"isCharging"] boolValue];
+    double batteryLevel = [batteryInfo[@"batteryLevel"] doubleValue];
+    
+    return @{
+        @"systemTotalWatts": @(systemTotal),
+        @"cpuWatts": @(cpuWatts),
+        @"gpuWatts": @(gpuWatts),
+        @"memoryWatts": @(memoryWatts),
+        @"cpuVoltage": @(cpuVoltage),
+        @"cpuCurrent": @(cpuCurrent),
+        @"powerSource": powerSource,
+        @"isCharging": @(isCharging),
+        @"batteryLevel": @(batteryLevel),
+        @"sensors": sensors
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleBatteryInfo {
+    CFTypeRef psInfo = IOPSCopyPowerSourcesInfo();
+    if (!psInfo) return nil;
+    
+    CFArrayRef psList = IOPSCopyPowerSourcesList(psInfo);
+    if (!psList) {
+        CFRelease(psInfo);
+        return nil;
+    }
+    
+    NSString *stateStr = @"AC Power";
+    BOOL isCharging = NO;
+    double capacity = 100.0;
+    
+    if (CFArrayGetCount(psList) > 0) {
+        CFTypeRef ps = CFArrayGetValueAtIndex(psList, 0);
+        CFDictionaryRef desc = IOPSGetPowerSourceDescription(psInfo, ps);
+        if (desc) {
+            NSDictionary *dict = (__bridge NSDictionary *)desc;
+            stateStr = dict[@"Power Source State"] ?: @"AC Power";
+            isCharging = [dict[@"Is Charging"] boolValue];
+            if (dict[@"Current Capacity"]) {
+                capacity = [dict[@"Current Capacity"] doubleValue];
+            }
+        }
+    }
+    CFRelease(psList);
+    CFRelease(psInfo);
+    
+    // Sample AppleSmartBattery for instantaneous voltage and current
+    double batteryWatts = 0.0;
+    double batteryVoltage = 0.0;
+    double batteryAmperage = 0.0;
+    
+    io_service_t service = IOServiceGetMatchingService(kIOMainPortDefault, IOServiceMatching("AppleSmartBattery"));
+    if (service != IO_OBJECT_NULL) {
+        CFMutableDictionaryRef props = NULL;
+        if (IORegistryEntryCreateCFProperties(service, &props, kCFAllocatorDefault, 0) == KERN_SUCCESS && props) {
+            NSDictionary *dict = (__bridge NSDictionary *)props;
+            double v_mV = [dict[@"Voltage"] doubleValue];
+            double a_mA = dict[@"InstantAmperage"] ? [dict[@"InstantAmperage"] doubleValue] : [dict[@"Amperage"] doubleValue];
+            
+            batteryVoltage = v_mV / 1000.0;
+            batteryAmperage = fabs(a_mA) / 1000.0;
+            batteryWatts = batteryVoltage * batteryAmperage;
+            
+            CFRelease(props);
+        }
+        IOObjectRelease(service);
+    }
+    
+    return @{
+        @"powerSource": stateStr,
+        @"isCharging": @(isCharging),
+        @"batteryLevel": @(capacity),
+        @"batteryVoltage": @(batteryVoltage),
+        @"batteryAmperage": @(batteryAmperage),
+        @"batteryWatts": @(batteryWatts)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    if (!_probed && _smcClient.isAvailable) {
+        [self probeSensors];
+    }
+    
+    NSMutableDictionary<NSString *, NSNumber *> *readings = [NSMutableDictionary dictionary];
+    
+    NSMutableArray<NSString *> *allKeys = [NSMutableArray arrayWithArray:_discoveredPowerKeys];
+    [allKeys addObjectsFromArray:_discoveredVoltageKeys];
+    [allKeys addObjectsFromArray:_discoveredCurrentKeys];
+    
+    for (NSString *key in allKeys) {
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val) {
+            double v = [val doubleValue];
+            // Normalize mV or mA if values appear raw
+            if ([key hasPrefix:@"V"] && v > 100.0) {
+                v /= 1000.0;
+            } else if ([key hasPrefix:@"I"] && v > 500.0) {
+                v /= 1000.0;
+            }
+            readings[key] = @(v);
+        }
+    }
+    
+    NSDictionary<NSString *, id> *batteryInfo = [self sampleBatteryInfo];
+    return [MMPowerTelemetryProvider calculatePowerMetricsWithReadings:readings
+                                                           batteryInfo:batteryInfo];
+}
+
+@end

Sources/Telemetry/Process/MMProcessDetailInspector.h

@@ -0,0 +1,32 @@
+#ifndef MMProcessDetailInspector_h
+#define MMProcessDetailInspector_h
+
+#import <Foundation/Foundation.h>
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMProcessDetailInspector
+ * Provides deep per-process inspection: open file descriptors, vnode file paths,
+ * active network sockets, and thread states.
+ */
+@interface MMProcessDetailInspector : NSObject
+
+/**
+ * Inspects a running process by PID.
+ */
++ (nullable NSDictionary<NSString *, id> *)inspectProcessWithPID:(pid_t)pid;
+
+/**
+ * Pure summarizer method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)summarizeInspectionResultsWithPID:(pid_t)pid
+                                                            threads:(NSArray<NSDictionary<NSString *, id> *> *)threads
+                                                                fds:(NSArray<NSDictionary<NSString *, id> *> *)fds
+                                                            sockets:(NSArray<NSDictionary<NSString *, id> *> *)sockets;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMProcessDetailInspector_h */

Sources/Telemetry/Process/MMProcessDetailInspector.m

@@ -0,0 +1,176 @@
+#import "MMProcessDetailInspector.h"
+#import <libproc.h>
+#import <sys/proc_info.h>
+#import <arpa/inet.h>
+
+@implementation MMProcessDetailInspector
+
++ (NSDictionary<NSString *, id> *)summarizeInspectionResultsWithPID:(pid_t)pid
+                                                            threads:(NSArray<NSDictionary<NSString *, id> *> *)threads
+                                                                fds:(NSArray<NSDictionary<NSString *, id> *> *)fds
+                                                            sockets:(NSArray<NSDictionary<NSString *, id> *> *)sockets {
+    return @{
+        @"pid": @(pid),
+        @"threadCount": @(threads.count),
+        @"openFDCount": @(fds.count),
+        @"socketCount": @(sockets.count),
+        @"threads": threads,
+        @"fileDescriptors": fds,
+        @"sockets": sockets
+    };
+}
+
+static NSString *runStateString(int state) {
+    switch (state) {
+        case 1: return @"Running";
+        case 2: return @"Stopped";
+        case 3: return @"Waiting";
+        case 4: return @"Uninterruptible";
+        case 5: return @"Halted";
+        default: return @"Unknown";
+    }
+}
+
+static NSString *tcpStateString(int state) {
+    switch (state) {
+        case 0: return @"CLOSED";
+        case 1: return @"LISTEN";
+        case 2: return @"SYN_SENT";
+        case 3: return @"SYN_RCVD";
+        case 4: return @"ESTABLISHED";
+        case 5: return @"CLOSE_WAIT";
+        case 6: return @"FIN_WAIT_1";
+        case 7: return @"CLOSING";
+        case 8: return @"LAST_ACK";
+        case 9: return @"FIN_WAIT_2";
+        case 10: return @"TIME_WAIT";
+        default: return @"UNKNOWN";
+    }
+}
+
++ (nullable NSDictionary<NSString *, id> *)inspectProcessWithPID:(pid_t)pid {
+    if (pid <= 0) return nil;
+    
+    // 1. Enumerate threads
+    uint64_t threadIds[512];
+    int threadBytes = proc_pidinfo(pid, PROC_PIDLISTTHREADS, 0, threadIds, sizeof(threadIds));
+    int threadCount = threadBytes / sizeof(uint64_t);
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *threads = [NSMutableArray arrayWithCapacity:threadCount];
+    for (int t = 0; t < threadCount; t++) {
+        uint64_t tid = threadIds[t];
+        struct proc_threadinfo thi;
+        if (proc_pidinfo(pid, PROC_PIDTHREADINFO, tid, &thi, sizeof(thi)) == sizeof(thi)) {
+            [threads addObject:@{
+                @"threadId": @(tid),
+                @"userTimeNs": @(thi.pth_user_time),
+                @"systemTimeNs": @(thi.pth_system_time),
+                @"cpuPercent": @(thi.pth_cpu_usage),
+                @"state": runStateString(thi.pth_run_state),
+                @"priority": @(thi.pth_priority),
+                @"currentPriority": @(thi.pth_curpri)
+            }];
+        }
+    }
+    
+    // 2. Enumerate File Descriptors & Sockets
+    NSMutableArray<NSDictionary<NSString *, id> *> *fdsList = [NSMutableArray array];
+    NSMutableArray<NSDictionary<NSString *, id> *> *socketsList = [NSMutableArray array];
+    
+    int sz = proc_pidinfo(pid, PROC_PIDLISTFDS, 0, NULL, 0);
+    if (sz > 0) {
+        struct proc_fdinfo *fds = malloc(sz);
+        if (fds) {
+            int actual = proc_pidinfo(pid, PROC_PIDLISTFDS, 0, fds, sz);
+            int fdCount = actual / sizeof(struct proc_fdinfo);
+            
+            for (int j = 0; j < fdCount; j++) {
+                int fd = fds[j].proc_fd;
+                uint32_t fdType = fds[j].proc_fdtype;
+                
+                if (fdType == PROX_FDTYPE_VNODE) {
+                    struct vnode_fdinfowithpath vi;
+                    if (proc_pidfdinfo(pid, fd, PROC_PIDFDVNODEPATHINFO, &vi, sizeof(vi)) == sizeof(vi)) {
+                        NSString *path = [NSString stringWithUTF8String:vi.pvip.vip_path];
+                        [fdsList addObject:@{
+                            @"fd": @(fd),
+                            @"type": @"File",
+                            @"path": path ?: @"(unknown)"
+                        }];
+                    }
+                } else if (fdType == PROX_FDTYPE_SOCKET) {
+                    struct socket_fdinfo si;
+                    if (proc_pidfdinfo(pid, fd, PROC_PIDFDSOCKETINFO, &si, sizeof(si)) == sizeof(si)) {
+                        int family = si.psi.soi_family;
+                        if (family == AF_INET || family == AF_INET6) {
+                            char localIP[INET6_ADDRSTRLEN] = {0};
+                            char remoteIP[INET6_ADDRSTRLEN] = {0};
+                            int lport = 0, rport = 0;
+                            NSString *proto = (si.psi.soi_type == SOCK_STREAM) ? @"TCP" : @"UDP";
+                            NSString *state = @"NONE";
+                            
+                            if (family == AF_INET) {
+                                inet_ntop(AF_INET, &si.psi.soi_proto.pri_in.insi_laddr.ina_46.i46a_addr4, localIP, sizeof(localIP));
+                                inet_ntop(AF_INET, &si.psi.soi_proto.pri_in.insi_faddr.ina_46.i46a_addr4, remoteIP, sizeof(remoteIP));
+                                lport = ntohs(si.psi.soi_proto.pri_in.insi_lport);
+                                rport = ntohs(si.psi.soi_proto.pri_in.insi_fport);
+                            } else {
+                                inet_ntop(AF_INET6, &si.psi.soi_proto.pri_in.insi_laddr.ina_6, localIP, sizeof(localIP));
+                                inet_ntop(AF_INET6, &si.psi.soi_proto.pri_in.insi_faddr.ina_6, remoteIP, sizeof(remoteIP));
+                                lport = ntohs(si.psi.soi_proto.pri_in.insi_lport);
+                                rport = ntohs(si.psi.soi_proto.pri_in.insi_fport);
+                            }
+                            
+                            if (si.psi.soi_type == SOCK_STREAM) {
+                                state = tcpStateString(si.psi.soi_proto.pri_tcp.tcpsi_state);
+                            }
+                            
+                            NSDictionary<NSString *, id> *sockDict = @{
+                                @"fd": @(fd),
+                                @"protocol": proto,
+                                @"localAddress": [NSString stringWithUTF8String:localIP],
+                                @"localPort": @(lport),
+                                @"remoteAddress": [NSString stringWithUTF8String:remoteIP],
+                                @"remotePort": @(rport),
+                                @"state": state
+                            };
+                            
+                            [socketsList addObject:sockDict];
+                            [fdsList addObject:@{
+                                @"fd": @(fd),
+                                @"type": @"Socket",
+                                @"path": [NSString stringWithFormat:@"%@ %@:%d -> %@:%d", proto, [NSString stringWithUTF8String:localIP], lport, [NSString stringWithUTF8String:remoteIP], rport]
+                            }];
+                        } else {
+                            [fdsList addObject:@{
+                                @"fd": @(fd),
+                                @"type": @"Socket (Unix/Other)",
+                                @"path": @"Unix Domain Socket"
+                            }];
+                        }
+                    }
+                } else if (fdType == PROX_FDTYPE_PIPE) {
+                    [fdsList addObject:@{
+                        @"fd": @(fd),
+                        @"type": @"Pipe",
+                        @"path": @"FIFO/Pipe"
+                    }];
+                } else {
+                    [fdsList addObject:@{
+                        @"fd": @(fd),
+                        @"type": @"Other",
+                        @"path": @""
+                    }];
+                }
+            }
+            free(fds);
+        }
+    }
+    
+    return [MMProcessDetailInspector summarizeInspectionResultsWithPID:pid
+                                                               threads:threads
+                                                                   fds:fdsList
+                                                               sockets:socketsList];
+}
+
+@end

Sources/Telemetry/Process/MMProcessTelemetryProvider.h

@@ -0,0 +1,34 @@
+#ifndef MMProcessTelemetryProvider_h
+#define MMProcessTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMProcessTelemetryProvider
+ * Live process explorer sampling CPU utilization, resident memory (RSS),
+ * virtual memory, thread counts, and process hierarchy.
+ */
+@interface MMProcessTelemetryProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Safely terminates a process via SIGTERM or SIGKILL.
+ */
++ (BOOL)terminateProcessWithPID:(pid_t)pid force:(BOOL)force;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSArray<NSDictionary<NSString *, id> *> *)calculateProcessListWithRawProcesses:(NSArray<NSDictionary<NSString *, id> *> *)rawProcesses
+                                                                previousCPUTimes:(nullable NSDictionary<NSNumber *, NSNumber *> *)previousCPUTimes
+                                                                       timeDelta:(NSTimeInterval)timeDelta;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMProcessTelemetryProvider_h */

Sources/Telemetry/Process/MMProcessTelemetryProvider.m

@@ -0,0 +1,160 @@
+#import "MMProcessTelemetryProvider.h"
+#import <libproc.h>
+#import <sys/proc_info.h>
+#import <pwd.h>
+#import <signal.h>
+#import <mach/mach_time.h>
+#import <os/lock.h>
+
+@interface MMProcessTelemetryProvider () {
+    os_unfair_lock _lock;
+    NSMutableDictionary<NSNumber *, NSNumber *> *_previousCPUTimes;
+    uint64_t _previousTimestamp;
+    mach_timebase_info_data_t _timebase;
+    NSMutableDictionary<NSNumber *, NSString *> *_usernameCache;
+}
+@end
+
+@implementation MMProcessTelemetryProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _lock = OS_UNFAIR_LOCK_INIT;
+        _previousCPUTimes = [NSMutableDictionary dictionary];
+        _previousTimestamp = 0;
+        _usernameCache = [NSMutableDictionary dictionary];
+        mach_timebase_info(&_timebase);
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainProcess;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.process";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (BOOL)terminateProcessWithPID:(pid_t)pid force:(BOOL)force {
+    int sig = force ? SIGKILL : SIGTERM;
+    return kill(pid, sig) == 0;
+}
+
++ (NSArray<NSDictionary<NSString *, id> *> *)calculateProcessListWithRawProcesses:(NSArray<NSDictionary<NSString *, id> *> *)rawProcesses
+                                                                previousCPUTimes:(nullable NSDictionary<NSNumber *, NSNumber *> *)previousCPUTimes
+                                                                       timeDelta:(NSTimeInterval)timeDelta {
+    NSMutableArray<NSDictionary<NSString *, id> *> *processed = [NSMutableArray arrayWithCapacity:rawProcesses.count];
+    
+    for (NSDictionary<NSString *, id> *raw in rawProcesses) {
+        NSNumber *pidNum = raw[@"pid"];
+        uint64_t currCPUTime = [raw[@"cpuTimeNs"] unsignedLongLongValue];
+        
+        double cpuPercent = 0.0;
+        if (previousCPUTimes && previousCPUTimes[pidNum]) {
+            uint64_t prevCPUTime = [previousCPUTimes[pidNum] unsignedLongLongValue];
+            if (currCPUTime >= prevCPUTime && timeDelta > 0.001) {
+                uint64_t deltaNs = currCPUTime - prevCPUTime;
+                double deltaSec = (double)deltaNs / 1e9;
+                cpuPercent = (deltaSec / timeDelta) * 100.0;
+            }
+        }
+        
+        NSMutableDictionary<NSString *, id> *entry = [raw mutableCopy];
+        entry[@"cpuPercent"] = @(cpuPercent);
+        [processed addObject:entry];
+    }
+    
+    // Sort descending by cpuPercent
+    [processed sortUsingComparator:^NSComparisonResult(NSDictionary<NSString *, id> *obj1, NSDictionary<NSString *, id> *obj2) {
+        NSNumber *c1 = obj1[@"cpuPercent"];
+        NSNumber *c2 = obj2[@"cpuPercent"];
+        return [c2 compare:c1];
+    }];
+    
+    return processed;
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    uint64_t now = mach_absolute_time();
+    
+    int pids[4096];
+    int bytes = proc_listpids(PROC_ALL_PIDS, 0, pids, sizeof(pids));
+    int pidCount = bytes / sizeof(int);
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *rawList = [NSMutableArray arrayWithCapacity:pidCount];
+    NSMutableDictionary<NSNumber *, NSNumber *> *currentCPUTimes = [NSMutableDictionary dictionaryWithCapacity:pidCount];
+    
+    NSUInteger totalThreads = 0;
+    
+    for (int i = 0; i < pidCount; i++) {
+        pid_t pid = pids[i];
+        if (pid <= 0) continue;
+        
+        struct proc_taskallinfo tai;
+        if (proc_pidinfo(pid, PROC_PIDTASKALLINFO, 0, &tai, sizeof(tai)) != sizeof(tai)) {
+            continue;
+        }
+        
+        uint64_t cpuTimeNs = tai.ptinfo.pti_total_user + tai.ptinfo.pti_total_system;
+        currentCPUTimes[@(pid)] = @(cpuTimeNs);
+        
+        totalThreads += tai.ptinfo.pti_threadnum;
+        
+        // Resolve username
+        NSNumber *uidNum = @(tai.pbsd.pbi_uid);
+        NSString *username = _usernameCache[uidNum];
+        if (!username) {
+            struct passwd *pw = getpwuid(tai.pbsd.pbi_uid);
+            username = pw ? [NSString stringWithUTF8String:pw->pw_name] : [uidNum stringValue];
+            _usernameCache[uidNum] = username;
+        }
+        
+        NSString *pname = [NSString stringWithUTF8String:tai.pbsd.pbi_name];
+        
+        [rawList addObject:@{
+            @"pid": @(pid),
+            @"ppid": @(tai.pbsd.pbi_ppid),
+            @"uid": uidNum,
+            @"username": username,
+            @"name": pname,
+            @"cpuTimeNs": @(cpuTimeNs),
+            @"residentBytes": @(tai.ptinfo.pti_resident_size),
+            @"virtualBytes": @(tai.ptinfo.pti_virtual_size),
+            @"threadCount": @(tai.ptinfo.pti_threadnum),
+            @"runningThreads": @(tai.ptinfo.pti_numrunning)
+        }];
+    }
+    
+    os_unfair_lock_lock(&_lock);
+    NSDictionary<NSNumber *, NSNumber *> *prev = [_previousCPUTimes copy];
+    uint64_t prevTime = _previousTimestamp;
+    
+    _previousCPUTimes = currentCPUTimes;
+    _previousTimestamp = now;
+    os_unfair_lock_unlock(&_lock);
+    
+    NSTimeInterval timeDelta = 1.0;
+    if (prevTime > 0) {
+        uint64_t elapsed = now - prevTime;
+        timeDelta = (double)elapsed * _timebase.numer / _timebase.denom / 1e9;
+    }
+    
+    NSArray<NSDictionary<NSString *, id> *> *processed = [MMProcessTelemetryProvider calculateProcessListWithRawProcesses:rawList
+                                                                                                          previousCPUTimes:prev
+                                                                                                                 timeDelta:timeDelta];
+    
+    return @{
+        @"processCount": @(processed.count),
+        @"totalThreads": @(totalThreads),
+        @"processes": processed,
+        @"timeDelta": @(timeDelta)
+    };
+}
+
+@end

Sources/Telemetry/Storage/MMDiskIOProvider.h

@@ -0,0 +1,29 @@
+#ifndef MMDiskIOProvider_h
+#define MMDiskIOProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMDiskIOProvider
+ * Samples real-time storage disk transfer rates (read/write bytes per second)
+ * and transaction rates (read/write IOPS) across internal and external block storage devices.
+ */
+@interface MMDiskIOProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateDiskIOMetricsWithCurrentSnapshots:(NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)current
+                                                           previousSnapshots:(nullable NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)previous
+                                                                   timeDelta:(NSTimeInterval)timeDelta;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMDiskIOProvider_h */

Sources/Telemetry/Storage/MMDiskIOProvider.m

@@ -0,0 +1,170 @@
+#import "MMDiskIOProvider.h"
+#import <IOKit/IOKitLib.h>
+#import <IOKit/storage/IOBlockStorageDriver.h>
+#import <mach/mach_time.h>
+#import <os/lock.h>
+
+@interface MMDiskIOProvider () {
+    os_unfair_lock _lock;
+    NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *_previousSnapshots;
+    uint64_t _previousTimestamp;
+    mach_timebase_info_data_t _timebase;
+}
+@end
+
+@implementation MMDiskIOProvider
+
+- (instancetype)init {
+    self = [super init];
+    if (self) {
+        _lock = OS_UNFAIR_LOCK_INIT;
+        _previousSnapshots = nil;
+        _previousTimestamp = 0;
+        mach_timebase_info(&_timebase);
+    }
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainStorage;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.storage.io";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSDictionary<NSString *, id> *)calculateDiskIOMetricsWithCurrentSnapshots:(NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)current
+                                                           previousSnapshots:(nullable NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *)previous
+                                                                   timeDelta:(NSTimeInterval)timeDelta {
+    double totalReadBps = 0.0;
+    double totalWriteBps = 0.0;
+    double totalReadIOPS = 0.0;
+    double totalWriteIOPS = 0.0;
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *disks = [NSMutableArray arrayWithCapacity:current.count];
+    NSArray<NSString *> *sortedBsdNames = [current.allKeys sortedArrayUsingSelector:@selector(compare:)];
+    
+    for (NSString *bsdName in sortedBsdNames) {
+        NSDictionary<NSString *, NSNumber *> *curr = current[bsdName];
+        NSDictionary<NSString *, NSNumber *> *prev = previous ? previous[bsdName] : nil;
+        
+        uint64_t currReadBytes = [curr[@"readBytes"] unsignedLongLongValue];
+        uint64_t currWriteBytes = [curr[@"writeBytes"] unsignedLongLongValue];
+        uint64_t currReadOps = [curr[@"readOps"] unsignedLongLongValue];
+        uint64_t currWriteOps = [curr[@"writeOps"] unsignedLongLongValue];
+        
+        uint64_t prevReadBytes = prev ? [prev[@"readBytes"] unsignedLongLongValue] : currReadBytes;
+        uint64_t prevWriteBytes = prev ? [prev[@"writeBytes"] unsignedLongLongValue] : currWriteBytes;
+        uint64_t prevReadOps = prev ? [prev[@"readOps"] unsignedLongLongValue] : currReadOps;
+        uint64_t prevWriteOps = prev ? [prev[@"writeOps"] unsignedLongLongValue] : currWriteOps;
+        
+        double deltaReadBytes = (currReadBytes >= prevReadBytes) ? (double)(currReadBytes - prevReadBytes) : 0.0;
+        double deltaWriteBytes = (currWriteBytes >= prevWriteBytes) ? (double)(currWriteBytes - prevWriteBytes) : 0.0;
+        double deltaReadOps = (currReadOps >= prevReadOps) ? (double)(currReadOps - prevReadOps) : 0.0;
+        double deltaWriteOps = (currWriteOps >= prevWriteOps) ? (double)(currWriteOps - prevWriteOps) : 0.0;
+        
+        double readBps = (timeDelta > 0.0001) ? (deltaReadBytes / timeDelta) : 0.0;
+        double writeBps = (timeDelta > 0.0001) ? (deltaWriteBytes / timeDelta) : 0.0;
+        double readIOPS = (timeDelta > 0.0001) ? (deltaReadOps / timeDelta) : 0.0;
+        double writeIOPS = (timeDelta > 0.0001) ? (deltaWriteOps / timeDelta) : 0.0;
+        
+        totalReadBps += readBps;
+        totalWriteBps += writeBps;
+        totalReadIOPS += readIOPS;
+        totalWriteIOPS += writeIOPS;
+        
+        [disks addObject:@{
+            @"bsdName": bsdName,
+            @"readBytesPerSec": @(readBps),
+            @"writeBytesPerSec": @(writeBps),
+            @"readIOPS": @(readIOPS),
+            @"writeIOPS": @(writeIOPS),
+            @"cumulativeReadBytes": @(currReadBytes),
+            @"cumulativeWriteBytes": @(currWriteBytes),
+            @"cumulativeReadOps": @(currReadOps),
+            @"cumulativeWriteOps": @(currWriteOps)
+        }];
+    }
+    
+    return @{
+        @"disks": disks,
+        @"totalReadBytesPerSec": @(totalReadBps),
+        @"totalWriteBytesPerSec": @(totalWriteBps),
+        @"totalReadIOPS": @(totalReadIOPS),
+        @"totalWriteIOPS": @(totalWriteIOPS),
+        @"timeDelta": @(timeDelta)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    uint64_t now = mach_absolute_time();
+    
+    NSMutableDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *currentSnapshots = [NSMutableDictionary dictionary];
+    
+    CFMutableDictionaryRef matching = IOServiceMatching(kIOBlockStorageDriverClass);
+    io_iterator_t iterator = IO_OBJECT_NULL;
+    if (IOServiceGetMatchingServices(kIOMainPortDefault, matching, &iterator) == KERN_SUCCESS && iterator != IO_OBJECT_NULL) {
+        io_registry_entry_t entry;
+        while ((entry = IOIteratorNext(iterator)) != IO_OBJECT_NULL) {
+            NSString *bsdName = nil;
+            io_iterator_t childIterator;
+            if (IORegistryEntryGetChildIterator(entry, kIOServicePlane, &childIterator) == KERN_SUCCESS) {
+                io_registry_entry_t child;
+                while ((child = IOIteratorNext(childIterator)) != IO_OBJECT_NULL) {
+                    CFTypeRef nameRef = IORegistryEntryCreateCFProperty(child, CFSTR("BSD Name"), kCFAllocatorDefault, 0);
+                    if (nameRef) {
+                        bsdName = CFBridgingRelease(nameRef);
+                        IOObjectRelease(child);
+                        break;
+                    }
+                    IOObjectRelease(child);
+                }
+                IOObjectRelease(childIterator);
+            }
+            
+            if (bsdName) {
+                CFTypeRef statsRef = IORegistryEntryCreateCFProperty(entry, CFSTR("Statistics"), kCFAllocatorDefault, 0);
+                if (statsRef) {
+                    NSDictionary *stats = CFBridgingRelease(statsRef);
+                    NSNumber *readBytes = stats[@"Bytes (Read)"] ?: @0;
+                    NSNumber *writeBytes = stats[@"Bytes (Write)"] ?: @0;
+                    NSNumber *readOps = stats[@"Operations (Read)"] ?: @0;
+                    NSNumber *writeOps = stats[@"Operations (Write)"] ?: @0;
+                    
+                    currentSnapshots[bsdName] = @{
+                        @"readBytes": readBytes,
+                        @"writeBytes": writeBytes,
+                        @"readOps": readOps,
+                        @"writeOps": writeOps
+                    };
+                }
+            }
+            IOObjectRelease(entry);
+        }
+        IOObjectRelease(iterator);
+    }
+    
+    os_unfair_lock_lock(&_lock);
+    NSDictionary<NSString *, NSDictionary<NSString *, NSNumber *> *> *prev = _previousSnapshots;
+    uint64_t prevTime = _previousTimestamp;
+    
+    _previousSnapshots = currentSnapshots;
+    _previousTimestamp = now;
+    os_unfair_lock_unlock(&_lock);
+    
+    NSTimeInterval timeDelta = 1.0;
+    if (prevTime > 0) {
+        uint64_t elapsed = now - prevTime;
+        timeDelta = (double)elapsed * _timebase.numer / _timebase.denom / 1e9;
+    }
+    
+    return [MMDiskIOProvider calculateDiskIOMetricsWithCurrentSnapshots:currentSnapshots
+                                                      previousSnapshots:prev
+                                                              timeDelta:timeDelta];
+}
+
+@end

Sources/Telemetry/Storage/MMStorageTelemetryProvider.h

@@ -0,0 +1,26 @@
+#ifndef MMStorageTelemetryProvider_h
+#define MMStorageTelemetryProvider_h
+
+#import <Foundation/Foundation.h>
+#import <sys/mount.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMStorageTelemetryProvider
+ * Samples mounted disk volumes, APFS containers, used/free storage capacity,
+ * and mount filesystem attributes.
+ */
+@interface MMStorageTelemetryProvider : NSObject <MMTelemetryProvider>
+
+/**
+ * Static parser method for converting statfs structures into volume dictionaries.
+ */
++ (NSArray<NSDictionary<NSString *, id> *> *)parseStatFSBuffer:(const struct statfs *)buffer count:(int)count;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMStorageTelemetryProvider_h */

Sources/Telemetry/Storage/MMStorageTelemetryProvider.m

@@ -0,0 +1,108 @@
+#import "MMStorageTelemetryProvider.h"
+
+@implementation MMStorageTelemetryProvider
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainStorage;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.storage";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSArray<NSDictionary<NSString *, id> *> *)parseStatFSBuffer:(const struct statfs *)buffer count:(int)count {
+    if (!buffer || count <= 0) return @[];
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *volumes = [NSMutableArray arrayWithCapacity:count];
+    
+    for (int i = 0; i < count; i++) {
+        const struct statfs *mnt = &buffer[i];
+        
+        // Only include local mounts
+        if (!(mnt->f_flags & MNT_LOCAL)) {
+            continue;
+        }
+        
+        NSString *mountPoint = [NSString stringWithUTF8String:mnt->f_mntonname];
+        NSString *deviceName = [NSString stringWithUTF8String:mnt->f_mntfromname];
+        NSString *fsType = [NSString stringWithUTF8String:mnt->f_fstypename];
+        
+        // Exclude virtual/internal devfs, autodefs, and synthetic system roots
+        if ([fsType isEqualToString:@"devfs"] ||
+            [fsType isEqualToString:@"autofs"] ||
+            [mountPoint hasPrefix:@"/System/Volumes/Data/"] ||
+            [deviceName containsString:@"com.apple.os.update"]) {
+            continue;
+        }
+        
+        uint64_t blockSize = (uint64_t)mnt->f_bsize;
+        uint64_t totalBytes = (uint64_t)mnt->f_blocks * blockSize;
+        uint64_t freeBytes = (uint64_t)mnt->f_bfree * blockSize;
+        uint64_t availBytes = (uint64_t)mnt->f_bavail * blockSize;
+        uint64_t usedBytes = (totalBytes >= freeBytes) ? (totalBytes - freeBytes) : 0;
+        
+        if (totalBytes == 0) continue;
+        
+        double usedPercent = ((double)usedBytes / (double)totalBytes) * 100.0;
+        if (usedPercent < 0.0) usedPercent = 0.0;
+        if (usedPercent > 100.0) usedPercent = 100.0;
+        
+        NSString *volumeName = [mountPoint lastPathComponent];
+        if ([mountPoint isEqualToString:@"/"]) {
+            volumeName = @"Macintosh HD";
+        }
+        
+        BOOL isReadOnly = (mnt->f_flags & MNT_RDONLY) != 0;
+        
+        [volumes addObject:@{
+            @"volumeName": volumeName,
+            @"mountPoint": mountPoint,
+            @"devicePath": deviceName,
+            @"fsType": fsType,
+            @"totalBytes": @(totalBytes),
+            @"usedBytes": @(usedBytes),
+            @"freeBytes": @(freeBytes),
+            @"availableBytes": @(availBytes),
+            @"usedPercent": @(usedPercent),
+            @"isReadOnly": @(isReadOnly)
+        }];
+    }
+    
+    return [volumes copy];
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    struct statfs *mntbuf = NULL;
+    int count = getmntinfo(&mntbuf, MNT_WAIT);
+    
+    if (count <= 0 || mntbuf == NULL) {
+        if (error) {
+            *error = [NSError errorWithDomain:@"com.i3omb.MacMonitor.Storage"
+                                         code:-1
+                                     userInfo:@{NSLocalizedDescriptionKey: @"getmntinfo returned no mounted filesystems"}];
+        }
+        return nil;
+    }
+    
+    NSArray *volumes = [MMStorageTelemetryProvider parseStatFSBuffer:mntbuf count:count];
+    
+    uint64_t totalStorage = 0;
+    uint64_t totalUsed = 0;
+    for (NSDictionary *v in volumes) {
+        totalStorage += [v[@"totalBytes"] unsignedLongLongValue];
+        totalUsed += [v[@"usedBytes"] unsignedLongLongValue];
+    }
+    
+    return @{
+        @"volumes": volumes,
+        @"volumeCount": @(volumes.count),
+        @"aggregateTotalBytes": @(totalStorage),
+        @"aggregateUsedBytes": @(totalUsed)
+    };
+}
+
+@end

Sources/Telemetry/System/MMLoadAverageProvider.h

@@ -0,0 +1,33 @@
+#ifndef MMLoadAverageProvider_h
+#define MMLoadAverageProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMLoadAverageProvider
+ * Samples 1m, 5m, and 15m system load averages, Mach concurrency factors,
+ * and system-wide task and thread counts.
+ */
+@interface MMLoadAverageProvider : NSObject <MMTelemetryProvider>
+
+- (instancetype)init;
+
+/**
+ * Pure calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateLoadMetricsWithLoad1:(double)load1
+                                                          load5:(double)load5
+                                                         load15:(double)load15
+                                                      taskCount:(int)taskCount
+                                                    threadCount:(int)threadCount
+                                                       cpuCount:(int)cpuCount
+                                                     machFactor:(double)machFactor;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMLoadAverageProvider_h */

Sources/Telemetry/System/MMLoadAverageProvider.m

@@ -0,0 +1,92 @@
+#import "MMLoadAverageProvider.h"
+#import <mach/mach.h>
+#import <mach/processor_info.h>
+#import <sys/sysctl.h>
+#import <stdlib.h>
+
+@implementation MMLoadAverageProvider
+
+- (instancetype)init {
+    self = [super init];
+    return self;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainSystem;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.system.load";
+}
+
+- (BOOL)isAvailable {
+    return YES;
+}
+
++ (NSDictionary<NSString *, id> *)calculateLoadMetricsWithLoad1:(double)load1
+                                                          load5:(double)load5
+                                                         load15:(double)load15
+                                                      taskCount:(int)taskCount
+                                                    threadCount:(int)threadCount
+                                                       cpuCount:(int)cpuCount
+                                                     machFactor:(double)machFactor {
+    int safeCpus = cpuCount > 0 ? cpuCount : 1;
+    double norm1 = load1 / (double)safeCpus;
+    double norm5 = load5 / (double)safeCpus;
+    double norm15 = load15 / (double)safeCpus;
+    
+    return @{
+        @"load1m": @(load1),
+        @"load5m": @(load5),
+        @"load15m": @(load15),
+        @"normalizedLoad1m": @(norm1),
+        @"normalizedLoad5m": @(norm5),
+        @"normalizedLoad15m": @(norm15),
+        @"taskCount": @(taskCount),
+        @"threadCount": @(threadCount),
+        @"logicalCpuCount": @(safeCpus),
+        @"machFactor": @(machFactor),
+        @"isOverloaded": @(norm1 > 1.0)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    // 1. Get BSD load averages
+    double load[3] = {0.0, 0.0, 0.0};
+    int ret = getloadavg(load, 3);
+    if (ret <= 0) {
+        load[0] = 0.0;
+        load[1] = 0.0;
+        load[2] = 0.0;
+    }
+    
+    // 2. Query Mach processor set for task & thread counts and mach factor
+    mach_port_t host = mach_host_self();
+    processor_set_name_port_t pset = MACH_PORT_NULL;
+    processor_set_load_info_data_t loadInfo = {0};
+    mach_msg_type_number_t count = PROCESSOR_SET_LOAD_INFO_COUNT;
+    
+    kern_return_t kr = processor_set_default(host, &pset);
+    if (kr == KERN_SUCCESS && MACH_PORT_VALID(pset)) {
+        kr = processor_set_statistics(pset, PROCESSOR_SET_LOAD_INFO, (processor_set_info_t)&loadInfo, &count);
+        mach_port_deallocate(mach_task_self(), pset);
+    }
+    
+    double machFactor = (double)loadInfo.mach_factor / (double)LOAD_SCALE;
+    
+    // 3. Query logical CPU core count
+    int cpuCount = 1;
+    size_t size = sizeof(cpuCount);
+    sysctlbyname("hw.logicalcpu", &cpuCount, &size, NULL, 0);
+    if (cpuCount <= 0) cpuCount = 1;
+    
+    return [MMLoadAverageProvider calculateLoadMetricsWithLoad1:load[0]
+                                                          load5:load[1]
+                                                         load15:load[2]
+                                                      taskCount:loadInfo.task_count
+                                                    threadCount:loadInfo.thread_count
+                                                       cpuCount:cpuCount
+                                                     machFactor:machFactor];
+}
+
+@end

Sources/Telemetry/Thermal/MMCPUThermalProvider.h

@@ -0,0 +1,34 @@
+#ifndef MMCPUThermalProvider_h
+#define MMCPUThermalProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+#import "MMAppleSMCClient.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMCPUThermalProvider
+ * Samples real-time CPU die, proximity, and per-core temperature sensors from AppleSMC
+ * alongside OS thermal pressure states.
+ */
+@interface MMCPUThermalProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, strong, readonly) MMAppleSMCClient *smcClient;
+@property (nonatomic, readonly) NSArray<NSString *> *discoveredCoreKeys;
+@property (nonatomic, readonly, nullable) NSString *packageKey;
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client;
+
+/**
+ * Static calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateThermalMetricsWithPackageTemp:(nullable NSNumber *)pkgTemp
+                                                               coreTemps:(NSDictionary<NSString *, NSNumber *> *)coreDict
+                                                            thermalState:(NSProcessInfoThermalState)state;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMCPUThermalProvider_h */

Sources/Telemetry/Thermal/MMCPUThermalProvider.m

@@ -0,0 +1,151 @@
+#import "MMCPUThermalProvider.h"
+#import <sys/sysctl.h>
+
+@interface MMCPUThermalProvider () {
+    MMAppleSMCClient *_smcClient;
+    NSMutableArray<NSString *> *_discoveredCoreKeys;
+    NSString *_packageKey;
+    BOOL _probed;
+}
+@end
+
+@implementation MMCPUThermalProvider
+
+- (instancetype)init {
+    return [self initWithSMCClient:[MMAppleSMCClient sharedClient]];
+}
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client {
+    self = [super init];
+    if (self) {
+        _smcClient = client;
+        _discoveredCoreKeys = [NSMutableArray array];
+        [self probeSensors];
+    }
+    return self;
+}
+
+- (void)probeSensors {
+    if (!_smcClient.isAvailable) return;
+    
+    // Probe package temperature key
+    NSArray<NSString *> *packageCandidates = @[@"TC0P", @"TC0D", @"TC0H", @"TCXC"];
+    for (NSString *candidate in packageCandidates) {
+        NSNumber *val = [_smcClient readNumericValueForKey:candidate error:nil];
+        if (val && [val doubleValue] > 0.0 && [val doubleValue] < 125.0) {
+            _packageKey = candidate;
+            break;
+        }
+    }
+    
+    // Probe core keys (TC0C, TC1C, etc.)
+    int coreCount = 1;
+    size_t size = sizeof(coreCount);
+    sysctlbyname("hw.physicalcpu", &coreCount, &size, NULL, 0);
+    if (coreCount <= 0) coreCount = 4;
+    
+    for (int i = 0; i < coreCount && i < 32; i++) {
+        NSString *key = [NSString stringWithFormat:@"TC%dC", i];
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val && [val doubleValue] > 0.0 && [val doubleValue] < 125.0) {
+            [_discoveredCoreKeys addObject:key];
+        }
+    }
+    
+    _probed = YES;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainThermal;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.thermal.cpu";
+}
+
+- (BOOL)isAvailable {
+    return _smcClient.isAvailable;
+}
+
+- (MMAppleSMCClient *)smcClient {
+    return _smcClient;
+}
+
+- (NSArray<NSString *> *)discoveredCoreKeys {
+    return [_discoveredCoreKeys copy];
+}
+
+- (NSString *)packageKey {
+    return _packageKey;
+}
+
++ (NSDictionary<NSString *, id> *)calculateThermalMetricsWithPackageTemp:(nullable NSNumber *)pkgTemp
+                                                               coreTemps:(NSDictionary<NSString *, NSNumber *> *)coreDict
+                                                            thermalState:(NSProcessInfoThermalState)state {
+    double peak = pkgTemp ? [pkgTemp doubleValue] : 0.0;
+    double sum = 0.0;
+    int count = 0;
+    
+    NSMutableArray<NSDictionary<NSString *, id> *> *coresList = [NSMutableArray arrayWithCapacity:coreDict.count];
+    NSArray<NSString *> *sortedKeys = [coreDict.allKeys sortedArrayUsingSelector:@selector(compare:)];
+    
+    for (NSUInteger idx = 0; idx < sortedKeys.count; idx++) {
+        NSString *k = sortedKeys[idx];
+        double temp = [coreDict[k] doubleValue];
+        if (temp > peak) peak = temp;
+        sum += temp;
+        count++;
+        
+        [coresList addObject:@{
+            @"coreIndex": @(idx),
+            @"key": k,
+            @"temperature": @(temp)
+        }];
+    }
+    
+    double avg = (count > 0) ? (sum / count) : (pkgTemp ? [pkgTemp doubleValue] : 0.0);
+    
+    NSString *stateStr = @"Nominal";
+    switch (state) {
+        case NSProcessInfoThermalStateNominal: stateStr = @"Nominal"; break;
+        case NSProcessInfoThermalStateFair: stateStr = @"Fair"; break;
+        case NSProcessInfoThermalStateSerious: stateStr = @"Serious"; break;
+        case NSProcessInfoThermalStateCritical: stateStr = @"Critical"; break;
+    }
+    
+    return @{
+        @"packageTemperature": pkgTemp ?: @(0.0),
+        @"averageCoreTemperature": @(avg),
+        @"peakCoreTemperature": @(peak),
+        @"coreTemperatures": coresList,
+        @"thermalPressureState": stateStr,
+        @"isThrottling": @(state >= NSProcessInfoThermalStateSerious)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    if (!_probed && _smcClient.isAvailable) {
+        [self probeSensors];
+    }
+    
+    NSNumber *pkgTemp = nil;
+    if (_packageKey) {
+        pkgTemp = [_smcClient readNumericValueForKey:_packageKey error:nil];
+    }
+    
+    NSMutableDictionary<NSString *, NSNumber *> *coreTemps = [NSMutableDictionary dictionary];
+    for (NSString *coreKey in _discoveredCoreKeys) {
+        NSNumber *t = [_smcClient readNumericValueForKey:coreKey error:nil];
+        if (t) {
+            coreTemps[coreKey] = t;
+        }
+    }
+    
+    NSProcessInfoThermalState thermalState = [NSProcessInfo processInfo].thermalState;
+    
+    return [MMCPUThermalProvider calculateThermalMetricsWithPackageTemp:pkgTemp
+                                                              coreTemps:coreTemps
+                                                           thermalState:thermalState];
+}
+
+@end

Sources/Telemetry/Thermal/MMComponentThermalProvider.h

@@ -0,0 +1,42 @@
+#ifndef MMComponentThermalProvider_h
+#define MMComponentThermalProvider_h
+
+#import <Foundation/Foundation.h>
+#import "MMTelemetryProvider.h"
+#import "MMAppleSMCClient.h"
+
+NS_ASSUME_NONNULL_BEGIN
+
+/**
+ * MMComponentThermalProvider
+ * Samples motherboard, PCH chipset, heatsink, memory, and enclosure ambient temperatures
+ * via AppleSMC.
+ */
+@interface MMComponentThermalProvider : NSObject <MMTelemetryProvider>
+
+@property (nonatomic, strong, readonly) MMAppleSMCClient *smcClient;
+@property (nonatomic, readonly) NSArray<NSString *> *discoveredKeys;
+
+- (instancetype)init;
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client;
+
+/**
+ * Categorize SMC temperature key into component domain (e.g., PCH / Chipset, Heatsink, Memory, etc.)
+ */
++ (NSString *)categoryForKey:(NSString *)key;
+
+/**
+ * Human-readable friendly name for known component SMC keys.
+ */
++ (NSString *)humanReadableNameForKey:(NSString *)key;
+
+/**
+ * Static calculator method for deterministic unit testing.
+ */
++ (NSDictionary<NSString *, id> *)calculateComponentMetricsFromDictionary:(NSDictionary<NSString *, NSNumber *> *)readings;
+
+@end
+
+NS_ASSUME_NONNULL_END
+
+#endif /* MMComponentThermalProvider_h */

Sources/Telemetry/Thermal/MMComponentThermalProvider.m

@@ -0,0 +1,174 @@
+#import "MMComponentThermalProvider.h"
+
+@interface MMComponentThermalProvider () {
+    MMAppleSMCClient *_smcClient;
+    NSMutableArray<NSString *> *_discoveredKeys;
+    BOOL _probed;
+}
+@end
+
+@implementation MMComponentThermalProvider
+
+- (instancetype)init {
+    return [self initWithSMCClient:[MMAppleSMCClient sharedClient]];
+}
+
+- (instancetype)initWithSMCClient:(MMAppleSMCClient *)client {
+    self = [super init];
+    if (self) {
+        _smcClient = client;
+        _discoveredKeys = [NSMutableArray array];
+        [self probeSensors];
+    }
+    return self;
+}
+
+- (void)probeSensors {
+    if (!_smcClient.isAvailable) return;
+    
+    NSArray<NSString *> *candidates = @[
+        @"TPCD", @"TP0P", @"TP0D",
+        @"Th0H", @"Th1H", @"Th2H", @"Th3H",
+        @"TM0P", @"TM1P", @"TM2P", @"TM3P", @"TM0S", @"TM1S",
+        @"Tp0P", @"Tp1P", @"Tp2P", @"Tp0C",
+        @"TA0P", @"TA1P", @"TA0S", @"TA1S",
+        @"TTLD", @"TT1D", @"TB0T", @"TB1T"
+    ];
+    
+    [_discoveredKeys removeAllObjects];
+    for (NSString *key in candidates) {
+        NSNumber *val = [_smcClient readNumericValueForKey:key error:nil];
+        if (val && [val doubleValue] > 0.0 && [val doubleValue] < 125.0) {
+            [_discoveredKeys addObject:key];
+        }
+    }
+    
+    _probed = YES;
+}
+
+- (MMTelemetryDomain)domain {
+    return MMTelemetryDomainThermal;
+}
+
+- (NSString *)providerIdentifier {
+    return @"com.i3omb.macmonitor.telemetry.thermal.components";
+}
+
+- (BOOL)isAvailable {
+    return _smcClient.isAvailable;
+}
+
+- (MMAppleSMCClient *)smcClient {
+    return _smcClient;
+}
+
+- (NSArray<NSString *> *)discoveredKeys {
+    return [_discoveredKeys copy];
+}
+
++ (NSString *)categoryForKey:(NSString *)key {
+    if ([key hasPrefix:@"TP"]) return @"PCH / Chipset";
+    if ([key hasPrefix:@"Th"]) return @"Heatsink";
+    if ([key hasPrefix:@"TM"]) return @"Memory";
+    if ([key hasPrefix:@"Tp"]) return @"Power Supply";
+    if ([key hasPrefix:@"TA"]) return @"Ambient / Enclosure";
+    if ([key hasPrefix:@"TT"] || [key hasPrefix:@"TB"] || [key hasPrefix:@"TI"]) return @"Thunderbolt / IO";
+    return @"Other";
+}
+
++ (NSString *)humanReadableNameForKey:(NSString *)key {
+    static NSDictionary<NSString *, NSString *> *names = nil;
+    static dispatch_once_t onceToken;
+    dispatch_once(&onceToken, ^{
+        names = @{
+            @"TPCD": @"Platform Controller Hub (Die)",
+            @"TP0P": @"Platform Controller Hub (Proximity)",
+            @"TP0D": @"Platform Controller Hub (Die Alternate)",
+            @"Th0H": @"Main Heatsink A",
+            @"Th1H": @"Main Heatsink B",
+            @"Th2H": @"Main Heatsink C",
+            @"Th3H": @"Main Heatsink D",
+            @"TM0P": @"Memory Bank 0 Proximity",
+            @"TM1P": @"Memory Bank 1 Proximity",
+            @"TM2P": @"Memory Bank 2 Proximity",
+            @"TM3P": @"Memory Bank 3 Proximity",
+            @"TM0S": @"Memory Module 0",
+            @"TM1S": @"Memory Module 1",
+            @"Tp0P": @"Power Supply Primary",
+            @"Tp1P": @"Power Supply Secondary",
+            @"Tp2P": @"Power Supply Tertiary",
+            @"Tp0C": @"Power Supply Core",
+            @"TA0P": @"Ambient Air Intake",
+            @"TA1P": @"Ambient Air Exhaust",
+            @"TA0S": @"Ambient Air Enclosure",
+            @"TA1S": @"Ambient Air Secondary",
+            @"TTLD": @"Thunderbolt Controller Die",
+            @"TT1D": @"Thunderbolt Controller Secondary",
+            @"TB0T": @"Thunderbolt Port 0",
+            @"TB1T": @"Thunderbolt Port 1"
+        };
+    });
+    
+    NSString *match = names[key];
+    return match ?: key;
+}
+
++ (NSDictionary<NSString *, id> *)calculateComponentMetricsFromDictionary:(NSDictionary<NSString *, NSNumber *> *)readings {
+    NSMutableArray<NSDictionary<NSString *, id> *> *components = [NSMutableArray arrayWithCapacity:readings.count];
+    NSMutableDictionary<NSString *, NSMutableArray<NSDictionary<NSString *, id> *> *> *categorized = [NSMutableDictionary dictionary];
+    
+    NSArray<NSString *> *sortedKeys = [readings.allKeys sortedArrayUsingSelector:@selector(compare:)];
+    double peak = 0.0;
+    double sum = 0.0;
+    
+    for (NSString *k in sortedKeys) {
+        double temp = [readings[k] doubleValue];
+        if (temp > peak) peak = temp;
+        sum += temp;
+        
+        NSString *cat = [self categoryForKey:k];
+        NSString *name = [self humanReadableNameForKey:k];
+        
+        NSDictionary<NSString *, id> *entry = @{
+            @"key": k,
+            @"name": name,
+            @"category": cat,
+            @"temperature": @(temp)
+        };
+        
+        [components addObject:entry];
+        
+        if (!categorized[cat]) {
+            categorized[cat] = [NSMutableArray array];
+        }
+        [categorized[cat] addObject:entry];
+    }
+    
+    double avg = readings.count > 0 ? (sum / (double)readings.count) : 0.0;
+    
+    return @{
+        @"components": components,
+        @"categorized": categorized,
+        @"sensorCount": @(readings.count),
+        @"peakTemperature": @(peak),
+        @"averageTemperature": @(avg)
+    };
+}
+
+- (nullable NSDictionary<NSString *, id> *)sampleTelemetryWithError:(NSError **)error {
+    if (!_probed && _smcClient.isAvailable) {
+        [self probeSensors];
+    }
+    
+    NSMutableDictionary<NSString *, NSNumber *> *readings = [NSMutableDictionary dictionary];
+    for (NSString *key in _discoveredKeys) {
+        NSNumber *temp = [_smcClient readNumericValueForKey:key error:nil];
+        if (temp) {
+            readings[key] = temp;
+        }
+    }
+    
+    return [MMComponentThermalProvider calculateComponentMetricsFromDictionary:readings];
+}
+
+@end

Tests/MMAudioTests.swift

@@ -0,0 +1,80 @@
+//
+//  MMAudioTests.swift
+//  MacMonitorTests
+//
+//  Unit and integration tests for MMAudioTelemetryProvider.
+//
+
+import XCTest
+@testable import MacMonitor
+
+final class MMAudioTests: XCTestCase {
+    var provider: MMAudioTelemetryProvider!
+
+    override func setUp() {
+        super.setUp()
+        provider = MMAudioTelemetryProvider()
+    }
+
+    override func tearDown() {
+        provider = nil
+        super.tearDown()
+    }
+
+    func testDomainAndIdentifier() {
+        XCTAssertEqual(provider.domain, .audio)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.audio")
+        XCTAssertTrue(provider.isAvailable)
+    }
+
+    func testSampleAudioDevicesLive() {
+        do {
+            let sample = try provider.sampleTelemetry()
+            XCTAssertNotNil(sample)
+            
+            let count = sample["deviceCount"] as? Int ?? 0
+            XCTAssertGreaterThanOrEqual(count, 0)
+            
+            let devices = sample["devices"] as? [[String: Any]] ?? []
+            XCTAssertEqual(devices.count, count)
+            
+            if count > 0 {
+                for dev in devices {
+                    XCTAssertNotNil(dev["name"])
+                    XCTAssertNotNil(dev["deviceID"])
+                    XCTAssertNotNil(dev["isInput"])
+                    XCTAssertNotNil(dev["isOutput"])
+                }
+            }
+        } catch {
+            XCTFail("sampleTelemetry threw error: \(error)")
+        }
+    }
+
+    func testAudioDeviceModel() {
+        let dev = MMAudioDevice()
+        dev.deviceID = 42
+        dev.name = "External USB DAC"
+        dev.manufacturer = "FiiO"
+        dev.uid = "USB:1234"
+        dev.isInput = false
+        dev.isOutput = true
+        dev.isDefaultOutput = true
+        dev.isDefaultInput = false
+        dev.sampleRate = 96000.0
+        dev.channelCount = 2
+        dev.volume = 0.75
+        dev.isMuted = false
+
+        let dict = dev.toDictionary()
+        XCTAssertEqual(dict["deviceID"] as? UInt32, 42)
+        XCTAssertEqual(dict["name"] as? String, "External USB DAC")
+        XCTAssertEqual(dict["manufacturer"] as? String, "FiiO")
+        XCTAssertEqual(dict["isOutput"] as? Bool, true)
+        XCTAssertEqual(dict["isDefaultOutput"] as? Bool, true)
+        XCTAssertEqual(dict["sampleRate"] as? Double, 96000.0)
+        XCTAssertEqual(dict["channelCount"] as? UInt32, 2)
+        XCTAssertEqual(dict["volume"] as? Float, 0.75)
+        XCTAssertEqual(dict["isMuted"] as? Bool, false)
+    }
+}

Tests/MMBatteryTests.swift

@@ -0,0 +1,109 @@
+//
+//  MMBatteryTests.swift
+//  MacMonitorTests
+//
+//  Unit and integration tests for MMBatteryTelemetryProvider.
+//
+
+import XCTest
+@testable import MacMonitor
+
+final class MMBatteryTests: XCTestCase {
+    var provider: MMBatteryTelemetryProvider!
+
+    override func setUp() {
+        super.setUp()
+        provider = MMBatteryTelemetryProvider()
+    }
+
+    override func tearDown() {
+        provider = nil
+        super.tearDown()
+    }
+
+    func testDomainAndIdentifier() {
+        XCTAssertEqual(provider.domain, .power)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.battery")
+    }
+
+    func testCalculateBatteryHealthWithSimulatedNormalBattery() {
+        let raw: [String: Any] = [
+            "BatteryInstalled": true,
+            "CycleCount": 250,
+            "DesignCycleCount9C": 1000,
+            "CurrentCapacity": 3000,
+            "MaxCapacity": 4000,
+            "DesignCapacity": 4400,
+            "Temperature": 3150, // 31.5 C
+            "Voltage": 11100, // 11.1 V
+            "Amperage": -1500, // -1.5 A
+            "IsCharging": false,
+            "FullyCharged": false,
+            "ExternalConnected": false,
+            "TimeRemaining": 120,
+            "Manufacturer": "SMP",
+            "Serial": "TEST123456",
+            "DeviceName": "bq20z451"
+        ]
+
+        let health = MMBatteryTelemetryProvider.calculateBatteryHealth(withProperties: raw)
+        XCTAssertEqual(health["hasBattery"] as? Bool, true)
+        XCTAssertEqual(health["installed"] as? Bool, true)
+        XCTAssertEqual(health["healthCondition"] as? String, "Normal")
+        
+        let healthPercent = (health["healthPercent"] as? Double) ?? 0.0
+        XCTAssertEqual(healthPercent, 90.9, accuracy: 0.1)
+        XCTAssertEqual(health["cycleCount"] as? Int, 250)
+        XCTAssertEqual(health["designCycleCount"] as? Int, 1000)
+        XCTAssertEqual(health["temperature"] as? Double, 31.5)
+        let watts = (health["watts"] as? Double) ?? 0.0
+        XCTAssertEqual(watts, 16.7, accuracy: 0.2)
+        XCTAssertEqual(health["manufacturer"] as? String, "SMP")
+    }
+
+    func testCalculateBatteryHealthWithServiceRecommended() {
+        let raw: [String: Any] = [
+            "BatteryInstalled": true,
+            "CycleCount": 1100,
+            "DesignCycleCount9C": 1000,
+            "CurrentCapacity": 1500,
+            "MaxCapacity": 2500,
+            "DesignCapacity": 4400, // ~56.8% health
+            "Temperature": 3200,
+            "Voltage": 10800,
+            "Amperage": -1000,
+            "IsCharging": false,
+            "FullyCharged": false,
+            "ExternalConnected": false,
+            "TimeRemaining": 90,
+            "Manufacturer": "Apple"
+        ]
+
+        let health = MMBatteryTelemetryProvider.calculateBatteryHealth(withProperties: raw)
+        XCTAssertEqual(health["healthCondition"] as? String, "Service Recommended")
+        let healthPercent = (health["healthPercent"] as? Double) ?? 0.0
+        XCTAssertLessThan(healthPercent, 70.0)
+    }
+
+    func testCalculateBatteryHealthWithNil() {
+        let health = MMBatteryTelemetryProvider.calculateBatteryHealth(withProperties: nil)
+        XCTAssertEqual(health["hasBattery"] as? Bool, false)
+        XCTAssertEqual(health["installed"] as? Bool, false)
+        XCTAssertEqual(health["healthCondition"] as? String, "No Battery")
+    }
+
+    func testLiveSampleBattery() {
+        do {
+            let sample = try provider.sampleTelemetry()
+            XCTAssertNotNil(sample)
+            if provider.hasBattery {
+                XCTAssertEqual(sample["hasBattery"] as? Bool, true)
+                XCTAssertNotNil(sample["cycleCount"])
+                XCTAssertNotNil(sample["healthPercent"])
+                XCTAssertNotNil(sample["healthCondition"])
+            }
+        } catch {
+            XCTFail("sampleTelemetry threw error: \(error)")
+        }
+    }
+}

Tests/MMCPULoadTests.swift

@@ -0,0 +1,65 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMCPULoadTests: XCTestCase {
+    
+    func testTickDeltaCalculation() {
+        var prevTicks = [processor_cpu_load_info_data_t]()
+        var currTicks = [processor_cpu_load_info_data_t]()
+        
+        // Setup mock Core 0: 20% user, 10% system, 70% idle
+        var core0Prev = processor_cpu_load_info_data_t()
+        core0Prev.cpu_ticks.0 = 100 // USER
+        core0Prev.cpu_ticks.1 = 50  // SYSTEM
+        core0Prev.cpu_ticks.2 = 850 // IDLE
+        core0Prev.cpu_ticks.3 = 0   // NICE
+        prevTicks.append(core0Prev)
+        
+        var core0Curr = processor_cpu_load_info_data_t()
+        core0Curr.cpu_ticks.0 = 300 // USER (+200)
+        core0Curr.cpu_ticks.1 = 150 // SYSTEM (+100)
+        core0Curr.cpu_ticks.2 = 1550 // IDLE (+700)
+        core0Curr.cpu_ticks.3 = 0   // NICE (+0)
+        currTicks.append(core0Curr)
+        
+        prevTicks.withUnsafeBufferPointer { prevBuf in
+            currTicks.withUnsafeBufferPointer { currBuf in
+                let metrics = MMCPULoadProvider.calculateLoad(
+                    fromPreviousTicks: prevBuf.baseAddress,
+                    currentTicks: currBuf.baseAddress!,
+                    coreCount: 1
+                )
+                
+                let totalPct = metrics["totalPercent"] as? Double ?? 0
+                let userPct = metrics["userPercent"] as? Double ?? 0
+                let systemPct = metrics["systemPercent"] as? Double ?? 0
+                let idlePct = metrics["idlePercent"] as? Double ?? 0
+                
+                // Total delta = 200 + 100 + 700 = 1000
+                // User = 20%, System = 10%, Idle = 70%, Total Active = 30%
+                XCTAssertEqual(totalPct, 30.0, accuracy: 0.1)
+                XCTAssertEqual(userPct, 20.0, accuracy: 0.1)
+                XCTAssertEqual(systemPct, 10.0, accuracy: 0.1)
+                XCTAssertEqual(idlePct, 70.0, accuracy: 0.1)
+            }
+        }
+    }
+    
+    func testLiveCPULoadProvider() throws {
+        let provider = MMCPULoadProvider()
+        XCTAssertTrue(provider.isAvailable)
+        XCTAssertEqual(provider.domain, .cpu)
+        XCTAssertGreaterThan(provider.coreCount, 0)
+        
+        // Initial sample establishes baseline
+        let sample1 = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample1)
+        
+        // Second sample produces live deltas
+        usleep(100_000) // 100ms
+        let sample2 = try provider.sampleTelemetry()
+        let cores = sample2["cores"] as? [[String: Any]]
+        XCTAssertNotNil(cores)
+        XCTAssertEqual(cores?.count, Int(provider.coreCount))
+    }
+}

Tests/MMCPUThermalTests.swift

@@ -0,0 +1,54 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMCPUThermalTests: XCTestCase {
+    
+    func testThermalMetricsCalculation() {
+        let pkgTemp = NSNumber(value: 55.0)
+        let coreDict: [String: NSNumber] = [
+            "TC0C": NSNumber(value: 52.0),
+            "TC1C": NSNumber(value: 56.0),
+            "TC2C": NSNumber(value: 54.0),
+            "TC3C": NSNumber(value: 58.0)
+        ]
+        
+        let metrics = MMCPUThermalProvider.calculateThermalMetrics(
+            withPackageTemp: pkgTemp,
+            coreTemps: coreDict,
+            thermalState: .nominal
+        )
+        
+        let peak = metrics["peakCoreTemperature"] as? Double ?? 0
+        let avg = metrics["averageCoreTemperature"] as? Double ?? 0
+        let state = metrics["thermalPressureState"] as? String ?? ""
+        let isThrottling = metrics["isThrottling"] as? Bool ?? true
+        
+        XCTAssertEqual(peak, 58.0, accuracy: 0.1)
+        XCTAssertEqual(avg, 55.0, accuracy: 0.1)
+        XCTAssertEqual(state, "Nominal")
+        XCTAssertFalse(isThrottling)
+    }
+    
+    func testThermalThrottlingDetection() {
+        let metrics = MMCPUThermalProvider.calculateThermalMetrics(
+            withPackageTemp: NSNumber(value: 99.0),
+            coreTemps: [:],
+            thermalState: .serious
+        )
+        
+        let isThrottling = metrics["isThrottling"] as? Bool ?? false
+        let state = metrics["thermalPressureState"] as? String ?? ""
+        
+        XCTAssertTrue(isThrottling)
+        XCTAssertEqual(state, "Serious")
+    }
+    
+    func testLiveCPUThermalProvider() throws {
+        let provider = MMCPUThermalProvider()
+        XCTAssertEqual(provider.domain, .thermal)
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["thermalPressureState"])
+    }
+}

Tests/MMComponentThermalTests.swift

@@ -0,0 +1,80 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMComponentThermalTests: XCTestCase {
+    
+    func testCategoryClassification() {
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TPCD"), "PCH / Chipset")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TP0P"), "PCH / Chipset")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "Th0H"), "Heatsink")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "Th1H"), "Heatsink")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TM0P"), "Memory")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TM1S"), "Memory")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "Tp0P"), "Power Supply")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TA0P"), "Ambient / Enclosure")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TTLD"), "Thunderbolt / IO")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "TB0T"), "Thunderbolt / IO")
+        XCTAssertEqual(MMComponentThermalProvider.category(forKey: "ZZ99"), "Other")
+    }
+    
+    func testHumanReadableNames() {
+        XCTAssertEqual(MMComponentThermalProvider.humanReadableName(forKey: "TPCD"), "Platform Controller Hub (Die)")
+        XCTAssertEqual(MMComponentThermalProvider.humanReadableName(forKey: "Th0H"), "Main Heatsink A")
+        XCTAssertEqual(MMComponentThermalProvider.humanReadableName(forKey: "TA0P"), "Ambient Air Intake")
+        XCTAssertEqual(MMComponentThermalProvider.humanReadableName(forKey: "CUSTOM"), "CUSTOM")
+    }
+    
+    func testComponentMetricsCalculation() {
+        let readings: [String: NSNumber] = [
+            "TPCD": NSNumber(value: 65.5),
+            "Th0H": NSNumber(value: 48.0),
+            "TM0P": NSNumber(value: 42.0),
+            "TA0P": NSNumber(value: 28.5)
+        ]
+        
+        let metrics = MMComponentThermalProvider.calculateComponentMetrics(from: readings)
+        
+        let peak = metrics["peakTemperature"] as? Double ?? 0
+        let avg = metrics["averageTemperature"] as? Double ?? 0
+        let count = metrics["sensorCount"] as? Int ?? 0
+        let components = metrics["components"] as? [[String: Any]] ?? []
+        let categorized = metrics["categorized"] as? [String: [[String: Any]]] ?? [:]
+        
+        XCTAssertEqual(peak, 65.5, accuracy: 0.1)
+        XCTAssertEqual(avg, (65.5 + 48.0 + 42.0 + 28.5) / 4.0, accuracy: 0.1)
+        XCTAssertEqual(count, 4)
+        XCTAssertEqual(components.count, 4)
+        
+        let pchList = categorized["PCH / Chipset"]
+        XCTAssertNotNil(pchList)
+        let firstPchName = pchList?.first?["name"] as? String
+        XCTAssertEqual(firstPchName, "Platform Controller Hub (Die)")
+        XCTAssertEqual(categorized["Heatsink"]?.count, 1)
+        XCTAssertEqual(categorized["Memory"]?.count, 1)
+        XCTAssertEqual(categorized["Ambient / Enclosure"]?.count, 1)
+    }
+    
+    func testEmptyReadingsCalculation() {
+        let metrics = MMComponentThermalProvider.calculateComponentMetrics(from: [:])
+        
+        let peak = metrics["peakTemperature"] as? Double ?? -1
+        let avg = metrics["averageTemperature"] as? Double ?? -1
+        let count = metrics["sensorCount"] as? Int ?? -1
+        
+        XCTAssertEqual(peak, 0.0)
+        XCTAssertEqual(avg, 0.0)
+        XCTAssertEqual(count, 0)
+    }
+    
+    func testLiveComponentThermalProvider() throws {
+        let provider = MMComponentThermalProvider()
+        XCTAssertEqual(provider.domain, .thermal)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.thermal.components")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["sensorCount"])
+        XCTAssertNotNil(sample["components"])
+        XCTAssertNotNil(sample["categorized"])
+    }
+}

Tests/MMDiskIOTests.swift

@@ -0,0 +1,73 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMDiskIOTests: XCTestCase {
+    
+    func testDiskIOMetricsCalculation() {
+        let prev: [String: [String: NSNumber]] = [
+            "disk0": [
+                "readBytes": NSNumber(value: 10_000_000),
+                "writeBytes": NSNumber(value: 5_000_000),
+                "readOps": NSNumber(value: 1_000),
+                "writeOps": NSNumber(value: 500)
+            ],
+            "disk1": [
+                "readBytes": NSNumber(value: 2_000_000),
+                "writeBytes": NSNumber(value: 1_000_000),
+                "readOps": NSNumber(value: 200),
+                "writeOps": NSNumber(value: 100)
+            ]
+        ]
+        
+        let curr: [String: [String: NSNumber]] = [
+            "disk0": [
+                "readBytes": NSNumber(value: 20_000_000), // delta = 10,000,000 bytes
+                "writeBytes": NSNumber(value: 7_000_000),  // delta = 2,000,000 bytes
+                "readOps": NSNumber(value: 1_200),         // delta = 200 ops
+                "writeOps": NSNumber(value: 600)           // delta = 100 ops
+            ],
+            "disk1": [
+                "readBytes": NSNumber(value: 4_000_000),  // delta = 2,000,000 bytes
+                "writeBytes": NSNumber(value: 1_000_000),  // delta = 0
+                "readOps": NSNumber(value: 250),           // delta = 50 ops
+                "writeOps": NSNumber(value: 100)           // delta = 0 ops
+            ]
+        ]
+        
+        let timeDelta: TimeInterval = 2.0 // 2 seconds
+        
+        let metrics = MMDiskIOProvider.calculateDiskIOMetrics(
+            withCurrentSnapshots: curr,
+            previousSnapshots: prev,
+            timeDelta: timeDelta
+        )
+        
+        let totalReadBps = metrics["totalReadBytesPerSec"] as? Double ?? 0
+        let totalWriteBps = metrics["totalWriteBytesPerSec"] as? Double ?? 0
+        let totalReadIOPS = metrics["totalReadIOPS"] as? Double ?? 0
+        let totalWriteIOPS = metrics["totalWriteIOPS"] as? Double ?? 0
+        let disks = metrics["disks"] as? [[String: Any]] ?? []
+        
+        // (10MB + 2MB) / 2s = 6,000,000 B/s
+        XCTAssertEqual(totalReadBps, 6_000_000.0, accuracy: 1.0)
+        // (2MB + 0) / 2s = 1,000,000 B/s
+        XCTAssertEqual(totalWriteBps, 1_000_000.0, accuracy: 1.0)
+        // (200 + 50) / 2s = 125 IOPS
+        XCTAssertEqual(totalReadIOPS, 125.0, accuracy: 0.1)
+        // (100 + 0) / 2s = 50 IOPS
+        XCTAssertEqual(totalWriteIOPS, 50.0, accuracy: 0.1)
+        XCTAssertEqual(disks.count, 2)
+    }
+    
+    func testLiveDiskIOProvider() throws {
+        let provider = MMDiskIOProvider()
+        XCTAssertEqual(provider.domain, .storage)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.storage.io")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["totalReadBytesPerSec"])
+        XCTAssertNotNil(sample["totalWriteBytesPerSec"])
+        XCTAssertNotNil(sample["disks"])
+    }
+}

Tests/MMFanTests.swift

@@ -0,0 +1,48 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMFanTests: XCTestCase {
+    
+    func testFanUtilizationCalculation() {
+        let fanList: [[String: NSNumber]] = [
+            [
+                "currentRPM": NSNumber(value: 2000.0),
+                "minRPM": NSNumber(value: 1200.0),
+                "maxRPM": NSNumber(value: 5000.0),
+                "targetRPM": NSNumber(value: 2000.0)
+            ],
+            [
+                "currentRPM": NSNumber(value: 2500.0),
+                "minRPM": NSNumber(value: 1200.0),
+                "maxRPM": NSNumber(value: 5000.0),
+                "targetRPM": NSNumber(value: 2500.0)
+            ]
+        ]
+        
+        let metrics = MMFanTelemetryProvider.calculateFanMetrics(fromFanList: fanList)
+        
+        let count = metrics["fanCount"] as? Int ?? 0
+        let avgRPM = metrics["averageRPM"] as? Double ?? 0
+        let peakRPM = metrics["peakRPM"] as? Double ?? 0
+        let fans = metrics["fans"] as? [[String: Any]] ?? []
+        
+        XCTAssertEqual(count, 2)
+        XCTAssertEqual(avgRPM, 2250.0, accuracy: 0.1)
+        XCTAssertEqual(peakRPM, 2500.0, accuracy: 0.1)
+        XCTAssertEqual(fans.count, 2)
+        
+        let fan0 = fans[0]
+        let util0 = fan0["utilizationPercent"] as? Double ?? 0
+        // (2000 - 1200) / 3800 * 100 = 21.05%
+        XCTAssertEqual(util0, 21.05, accuracy: 0.1)
+    }
+    
+    func testLiveFanProvider() throws {
+        let provider = MMFanTelemetryProvider()
+        XCTAssertEqual(provider.domain, .fan)
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["fanCount"])
+    }
+}

Tests/MMGPUTests.swift

@@ -0,0 +1,54 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMGPUTests: XCTestCase {
+    
+    func testGPUMetricsCalculation() {
+        let mockGPUs: [[String: Any]] = [
+            [
+                "name": "Intel Iris Plus Graphics 655",
+                "type": "Integrated",
+                "utilization": 15.0,
+                "vramUsedBytes": 500_000_000,
+                "vramTotalBytes": 1_500_000_000,
+                "temperature": 45.0,
+                "isLowPower": true,
+                "isRemovable": false
+            ],
+            [
+                "name": "AMD Radeon Pro 560X",
+                "type": "Discrete",
+                "utilization": 75.0,
+                "vramUsedBytes": 3_000_000_000,
+                "vramTotalBytes": 4_000_000_000,
+                "temperature": 68.0,
+                "isLowPower": false,
+                "isRemovable": false
+            ]
+        ]
+        
+        let metrics = MMGPUTelemetryProvider.calculateGPUMetrics(withDevices: mockGPUs)
+        
+        let count = metrics["gpuCount"] as? Int ?? 0
+        let avg = metrics["averageUtilization"] as? Double ?? 0
+        let peak = metrics["peakUtilization"] as? Double ?? 0
+        let active = metrics["activeGPUName"] as? String ?? ""
+        
+        XCTAssertEqual(count, 2)
+        XCTAssertEqual(avg, 45.0, accuracy: 0.1)
+        XCTAssertEqual(peak, 75.0, accuracy: 0.1)
+        XCTAssertEqual(active, "AMD Radeon Pro 560X")
+    }
+    
+    func testLiveGPUProvider() throws {
+        let provider = MMGPUTelemetryProvider()
+        XCTAssertEqual(provider.domain, .gpu)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.gpu")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["gpuCount"])
+        XCTAssertNotNil(sample["devices"])
+        XCTAssertNotNil(sample["activeGPUName"])
+    }
+}

Tests/MMKernelTelemetryTests.swift

@@ -0,0 +1,70 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMKernelTelemetryTests: XCTestCase {
+    
+    func testKernelRatesCalculation() {
+        let prev: [String: NSNumber] = [
+            "contextSwitches": NSNumber(value: 100_000),
+            "syscalls": NSNumber(value: 200_000),
+            "pageFaults": NSNumber(value: 50_000),
+            "cowFaults": NSNumber(value: 1_000),
+            "zeroFills": NSNumber(value: 10_000),
+            "pageins": NSNumber(value: 500),
+            "pageouts": NSNumber(value: 100),
+            "decompressions": NSNumber(value: 200),
+            "compressions": NSNumber(value: 300)
+        ]
+        
+        let curr: [String: NSNumber] = [
+            "contextSwitches": NSNumber(value: 102_500), // delta = 2,500
+            "syscalls": NSNumber(value: 210_000),        // delta = 10,000
+            "pageFaults": NSNumber(value: 51_000),       // delta = 1,000
+            "cowFaults": NSNumber(value: 1_050),         // delta = 50
+            "zeroFills": NSNumber(value: 10_200),        // delta = 200
+            "pageins": NSNumber(value: 520),             // delta = 20
+            "pageouts": NSNumber(value: 105),            // delta = 5
+            "decompressions": NSNumber(value: 210),      // delta = 10
+            "compressions": NSNumber(value: 315)         // delta = 15
+        ]
+        
+        let timeDelta: TimeInterval = 2.0 // 2 seconds
+        
+        let rates = MMKernelTelemetryProvider.calculateRates(
+            withCurrentCounters: curr,
+            previousCounters: prev,
+            timeDelta: timeDelta
+        )
+        
+        let cswRate = rates["contextSwitchesRate"] as? Double ?? 0
+        let syscallRate = rates["syscallsRate"] as? Double ?? 0
+        let faultRate = rates["pageFaultsRate"] as? Double ?? 0
+        let cowRate = rates["cowFaultsRate"] as? Double ?? 0
+        let zeroFillRate = rates["zeroFillsRate"] as? Double ?? 0
+        let pageinsRate = rates["pageinsRate"] as? Double ?? 0
+        
+        XCTAssertEqual(cswRate, 1250.0, accuracy: 0.1)
+        XCTAssertEqual(syscallRate, 5000.0, accuracy: 0.1)
+        XCTAssertEqual(faultRate, 500.0, accuracy: 0.1)
+        XCTAssertEqual(cowRate, 25.0, accuracy: 0.1)
+        XCTAssertEqual(zeroFillRate, 100.0, accuracy: 0.1)
+        XCTAssertEqual(pageinsRate, 10.0, accuracy: 0.1)
+        
+        let cumCSW = rates["cumulative_contextSwitches"] as? UInt64 ?? 0
+        XCTAssertEqual(cumCSW, 102_500)
+    }
+    
+    func testLiveKernelProvider() throws {
+        let provider = MMKernelTelemetryProvider()
+        XCTAssertEqual(provider.domain, .system)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.kernel.counters")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["cumulative_contextSwitches"])
+        XCTAssertNotNil(sample["cumulative_syscalls"])
+        XCTAssertNotNil(sample["cumulative_pageFaults"])
+        XCTAssertNotNil(sample["contextSwitchesRate"])
+        XCTAssertNotNil(sample["syscallsRate"])
+    }
+}

Tests/MMLoadAverageTests.swift

@@ -0,0 +1,62 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMLoadAverageTests: XCTestCase {
+    
+    func testLoadMetricsCalculation() {
+        let metrics = MMLoadAverageProvider.calculateLoadMetrics(
+            withLoad1: 4.0,
+            load5: 3.5,
+            load15: 2.5,
+            taskCount: 500,
+            threadCount: 2200,
+            cpuCount: 8,
+            machFactor: 1.25
+        )
+        
+        let load1 = metrics["load1m"] as? Double ?? 0
+        let norm1 = metrics["normalizedLoad1m"] as? Double ?? 0
+        let norm5 = metrics["normalizedLoad5m"] as? Double ?? 0
+        let taskCount = metrics["taskCount"] as? Int ?? 0
+        let threadCount = metrics["threadCount"] as? Int ?? 0
+        let isOverloaded = metrics["isOverloaded"] as? Bool ?? true
+        
+        XCTAssertEqual(load1, 4.0, accuracy: 0.01)
+        XCTAssertEqual(norm1, 4.0 / 8.0, accuracy: 0.01)
+        XCTAssertEqual(norm5, 3.5 / 8.0, accuracy: 0.01)
+        XCTAssertEqual(taskCount, 500)
+        XCTAssertEqual(threadCount, 2200)
+        XCTAssertFalse(isOverloaded)
+    }
+    
+    func testOverloadedStateDetection() {
+        let metrics = MMLoadAverageProvider.calculateLoadMetrics(
+            withLoad1: 12.0,
+            load5: 10.0,
+            load15: 8.0,
+            taskCount: 650,
+            threadCount: 3100,
+            cpuCount: 8,
+            machFactor: 0.4
+        )
+        
+        let isOverloaded = metrics["isOverloaded"] as? Bool ?? false
+        let norm1 = metrics["normalizedLoad1m"] as? Double ?? 0
+        
+        XCTAssertTrue(isOverloaded)
+        XCTAssertEqual(norm1, 1.5, accuracy: 0.01)
+    }
+    
+    func testLiveLoadAverageProvider() throws {
+        let provider = MMLoadAverageProvider()
+        XCTAssertEqual(provider.domain, .system)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.system.load")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["load1m"])
+        XCTAssertNotNil(sample["taskCount"])
+        XCTAssertNotNil(sample["threadCount"])
+        XCTAssertNotNil(sample["normalizedLoad1m"])
+    }
+}

Tests/MMMemoryTests.swift

@@ -0,0 +1,64 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMMemoryTests: XCTestCase {
+    
+    func testMemoryMetricCalculation() {
+        var vmInfo = vm_statistics64_data_t()
+        let pageSize: vm_size_t = 4096
+        let totalRAM: UInt64 = 16 * 1024 * 1024 * 1024 // 16 GB
+        
+        // 1GB wired (262144 pages), 2GB app (524288 pages), 1GB compressed (262144 pages)
+        vmInfo.wire_count = 262_144
+        vmInfo.internal_page_count = 524_288
+        vmInfo.purgeable_count = 0
+        vmInfo.compressor_page_count = 262_144
+        vmInfo.active_count = 524_288
+        vmInfo.inactive_count = 1_048_576 // 4GB
+        vmInfo.free_count = 2_097_152     // 8GB
+        
+        var swap = xsw_usage()
+        swap.xsu_total = 2 * 1024 * 1024 * 1024
+        swap.xsu_used = 512 * 1024 * 1024
+        swap.xsu_avail = swap.xsu_total - swap.xsu_used
+        
+        withUnsafePointer(to: vmInfo) { vmPtr in
+            withUnsafePointer(to: swap) { swapPtr in
+                let metrics = MMMemoryTelemetryProvider.calculateMemoryMetrics(
+                    withVMInfo: vmPtr,
+                    pageSize: pageSize,
+                    totalPhysicalRAM: totalRAM,
+                    swapUsage: swapPtr
+                )
+                
+                let wired = metrics["wiredBytes"] as? UInt64 ?? 0
+                let app = metrics["appMemoryBytes"] as? UInt64 ?? 0
+                let compressed = metrics["compressedBytes"] as? UInt64 ?? 0
+                let used = metrics["usedBytes"] as? UInt64 ?? 0
+                let pressureStatus = metrics["memoryPressureStatus"] as? String ?? ""
+                
+                XCTAssertEqual(wired, 1024 * 1024 * 1024)
+                XCTAssertEqual(app, 2 * 1024 * 1024 * 1024)
+                XCTAssertEqual(compressed, 1024 * 1024 * 1024)
+                XCTAssertEqual(used, 4 * 1024 * 1024 * 1024)
+                XCTAssertEqual(pressureStatus, "Normal")
+            }
+        }
+    }
+    
+    func testLiveMemoryProvider() throws {
+        let provider = MMMemoryTelemetryProvider()
+        XCTAssertTrue(provider.isAvailable)
+        XCTAssertEqual(provider.domain, .memory)
+        XCTAssertGreaterThan(provider.totalPhysicalMemoryBytes, 0)
+        
+        let sample = try provider.sampleTelemetry()
+        let total = sample["totalBytes"] as? UInt64 ?? 0
+        let used = sample["usedBytes"] as? UInt64 ?? 0
+        let free = sample["freeBytes"] as? UInt64 ?? 0
+        
+        XCTAssertGreaterThan(total, 0)
+        XCTAssertGreaterThan(used, 0)
+        XCTAssertGreaterThanOrEqual(free, 0)
+    }
+}

Tests/MMNetworkBandwidthTests.swift

@@ -0,0 +1,85 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMNetworkBandwidthTests: XCTestCase {
+    
+    func testNetworkBandwidthCalculation() {
+        let prev: [String: [String: NSNumber]] = [
+            "en0": [
+                "inBytes": NSNumber(value: 50_000_000),
+                "outBytes": NSNumber(value: 10_000_000),
+                "inPackets": NSNumber(value: 40_000),
+                "outPackets": NSNumber(value: 20_000),
+                "inErrors": NSNumber(value: 0),
+                "outErrors": NSNumber(value: 0)
+            ],
+            "lo0": [
+                "inBytes": NSNumber(value: 5_000_000),
+                "outBytes": NSNumber(value: 5_000_000),
+                "inPackets": NSNumber(value: 5_000),
+                "outPackets": NSNumber(value: 5_000),
+                "inErrors": NSNumber(value: 0),
+                "outErrors": NSNumber(value: 0)
+            ]
+        ]
+        
+        let curr: [String: [String: NSNumber]] = [
+            "en0": [
+                "inBytes": NSNumber(value: 60_000_000), // delta in = 10,000,000 bytes
+                "outBytes": NSNumber(value: 12_000_000), // delta out = 2,000,000 bytes
+                "inPackets": NSNumber(value: 48_000),    // delta in = 8,000 pkts
+                "outPackets": NSNumber(value: 24_000),   // delta out = 4,000 pkts
+                "inErrors": NSNumber(value: 0),
+                "outErrors": NSNumber(value: 0)
+            ],
+            "lo0": [
+                "inBytes": NSNumber(value: 7_000_000),
+                "outBytes": NSNumber(value: 7_000_000),
+                "inPackets": NSNumber(value: 7_000),
+                "outPackets": NSNumber(value: 7_000),
+                "inErrors": NSNumber(value: 0),
+                "outErrors": NSNumber(value: 0)
+            ]
+        ]
+        
+        let timeDelta: TimeInterval = 2.0 // 2 seconds
+        let ipDict: [String: String] = ["en0": "192.168.1.100", "lo0": "127.0.0.1"]
+        
+        let metrics = MMNetworkBandwidthProvider.calculateBandwidthMetrics(
+            withCurrentSnapshots: curr,
+            previousSnapshots: prev,
+            timeDelta: timeDelta,
+            ipAddresses: ipDict
+        )
+        
+        let totalDownBps = metrics["totalDownloadBytesPerSec"] as? Double ?? 0
+        let totalUpBps = metrics["totalUploadBytesPerSec"] as? Double ?? 0
+        let totalDownPps = metrics["totalDownloadPacketsPerSec"] as? Double ?? 0
+        let totalUpPps = metrics["totalUploadPacketsPerSec"] as? Double ?? 0
+        let primary = metrics["primaryInterface"] as? String ?? ""
+        let interfaces = metrics["interfaces"] as? [[String: Any]] ?? []
+        
+        // en0 delta in = 10MB / 2s = 5,000,000 B/s (lo0 is excluded from total)
+        XCTAssertEqual(totalDownBps, 5_000_000.0, accuracy: 1.0)
+        // en0 delta out = 2MB / 2s = 1,000,000 B/s
+        XCTAssertEqual(totalUpBps, 1_000_000.0, accuracy: 1.0)
+        // en0 delta in pkts = 8,000 / 2s = 4,000 pps
+        XCTAssertEqual(totalDownPps, 4000.0, accuracy: 0.1)
+        // en0 delta out pkts = 4,000 / 2s = 2,000 pps
+        XCTAssertEqual(totalUpPps, 2000.0, accuracy: 0.1)
+        XCTAssertEqual(primary, "en0")
+        XCTAssertEqual(interfaces.count, 2)
+    }
+    
+    func testLiveNetworkBandwidthProvider() throws {
+        let provider = MMNetworkBandwidthProvider()
+        XCTAssertEqual(provider.domain, .network)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.network.bandwidth")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["totalDownloadBytesPerSec"])
+        XCTAssertNotNil(sample["totalUploadBytesPerSec"])
+        XCTAssertNotNil(sample["interfaces"])
+    }
+}

Tests/MMNetworkSocketsTests.swift

@@ -0,0 +1,68 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMNetworkSocketsTests: XCTestCase {
+    
+    func testSocketSummaryCalculation() {
+        let testSockets: [[String: Any]] = [
+            [
+                "pid": 100,
+                "processName": "web_server",
+                "protocol": "TCP",
+                "family": "IPv4",
+                "localAddress": "0.0.0.0",
+                "localPort": 8080,
+                "remoteAddress": "0.0.0.0",
+                "remotePort": 0,
+                "state": "LISTEN"
+            ],
+            [
+                "pid": 200,
+                "processName": "browser",
+                "protocol": "TCP",
+                "family": "IPv4",
+                "localAddress": "192.168.1.50",
+                "localPort": 54321,
+                "remoteAddress": "142.250.190.46",
+                "remotePort": 443,
+                "state": "ESTABLISHED"
+            ],
+            [
+                "pid": 300,
+                "processName": "dns_daemon",
+                "protocol": "UDP",
+                "family": "IPv4",
+                "localAddress": "0.0.0.0",
+                "localPort": 53,
+                "remoteAddress": "0.0.0.0",
+                "remotePort": 0,
+                "state": "NONE"
+            ]
+        ]
+        
+        let summary = MMNetworkSocketsProvider.calculateSocketSummary(withSocketList: testSockets)
+        
+        let total = summary["socketCount"] as? Int ?? 0
+        let tcp = summary["tcpCount"] as? Int ?? 0
+        let udp = summary["udpCount"] as? Int ?? 0
+        let listen = summary["listenCount"] as? Int ?? 0
+        let established = summary["establishedCount"] as? Int ?? 0
+        
+        XCTAssertEqual(total, 3)
+        XCTAssertEqual(tcp, 2)
+        XCTAssertEqual(udp, 1)
+        XCTAssertEqual(listen, 1)
+        XCTAssertEqual(established, 1)
+    }
+    
+    func testLiveNetworkSocketsProvider() throws {
+        let provider = MMNetworkSocketsProvider()
+        XCTAssertEqual(provider.domain, .network)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.network.sockets")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["socketCount"])
+        XCTAssertNotNil(sample["sockets"])
+    }
+}

Tests/MMPeripheralsTests.swift

@@ -0,0 +1,73 @@
+//
+//  MMPeripheralsTests.swift
+//  MacMonitorTests
+//
+//  Unit and integration tests for MMPeripheralsProvider.
+//
+
+import XCTest
+@testable import MacMonitor
+
+final class MMPeripheralsTests: XCTestCase {
+    var provider: MMPeripheralsProvider!
+
+    override func setUp() {
+        super.setUp()
+        provider = MMPeripheralsProvider()
+    }
+
+    override func tearDown() {
+        provider = nil
+        super.tearDown()
+    }
+
+    func testDomainAndIdentifier() {
+        XCTAssertEqual(provider.domain, .peripherals)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.peripherals")
+        XCTAssertTrue(provider.isAvailable)
+    }
+
+    func testSamplePeripheralsLive() {
+        do {
+            let sample = try provider.sampleTelemetry()
+            XCTAssertNotNil(sample)
+            
+            let total = sample["totalDeviceCount"] as? Int ?? 0
+            XCTAssertGreaterThan(total, 0, "Host system should have at least 1 PCI/USB device")
+            
+            let pci = sample["pciDevices"] as? [[String: Any]] ?? []
+            XCTAssertGreaterThan(pci.count, 0, "Intel Mac should have PCI devices (host bridge, GPU, etc.)")
+            
+            if let firstPCI = pci.first {
+                XCTAssertNotNil(firstPCI["name"])
+                XCTAssertEqual(firstPCI["busType"] as? String, "PCI")
+            }
+            
+            let usb = sample["usbDevices"] as? [[String: Any]] ?? []
+            for dev in usb {
+                XCTAssertEqual(dev["busType"] as? String, "USB")
+                XCTAssertNotNil(dev["name"])
+            }
+        } catch {
+            XCTFail("sampleTelemetry threw error: \(error)")
+        }
+    }
+
+    func testPeripheralDeviceModel() {
+        let dev = MMPeripheralDevice()
+        dev.name = "Magic Trackpad"
+        dev.busType = .USB
+        dev.vendorName = "Apple Inc."
+        dev.vendorID = 0x05ac
+        dev.productID = 0x0265
+        dev.isBuiltIn = false
+        
+        let dict = dev.toDictionary()
+        XCTAssertEqual(dict["name"] as? String, "Magic Trackpad")
+        XCTAssertEqual(dict["busType"] as? String, "USB")
+        XCTAssertEqual(dict["vendorName"] as? String, "Apple Inc.")
+        XCTAssertEqual(dict["vendorID"] as? UInt32, 0x05ac)
+        XCTAssertEqual(dict["productID"] as? UInt32, 0x0265)
+        XCTAssertEqual(dict["isBuiltIn"] as? Bool, false)
+    }
+}

Tests/MMPowerTests.swift

@@ -0,0 +1,101 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMPowerTests: XCTestCase {
+    
+    func testUnitsAndNames() {
+        XCTAssertEqual(MMPowerTelemetryProvider.unit(forKey: "PSTR"), "W")
+        XCTAssertEqual(MMPowerTelemetryProvider.unit(forKey: "VC0C"), "V")
+        XCTAssertEqual(MMPowerTelemetryProvider.unit(forKey: "IC0C"), "A")
+        XCTAssertEqual(MMPowerTelemetryProvider.unit(forKey: "UNKNOWN"), "")
+        
+        XCTAssertEqual(MMPowerTelemetryProvider.humanReadableName(forKey: "PSTR"), "Total System Power")
+        XCTAssertEqual(MMPowerTelemetryProvider.humanReadableName(forKey: "VC0C"), "CPU Core Voltage")
+        XCTAssertEqual(MMPowerTelemetryProvider.humanReadableName(forKey: "IC0C"), "CPU Core Current")
+    }
+    
+    func testPowerMetricsCalculationFromSMC() {
+        let readings: [String: NSNumber] = [
+            "PSTR": NSNumber(value: 45.2),
+            "PCPR": NSNumber(value: 28.4),
+            "PG0R": NSNumber(value: 8.5),
+            "PMSR": NSNumber(value: 3.1),
+            "VC0C": NSNumber(value: 1.15),
+            "IC0C": NSNumber(value: 24.5)
+        ]
+        
+        let batteryInfo: [String: Any] = [
+            "powerSource": "AC Power",
+            "isCharging": false,
+            "batteryLevel": 100.0,
+            "batteryWatts": 0.0
+        ]
+        
+        let metrics = MMPowerTelemetryProvider.calculatePowerMetrics(
+            withReadings: readings,
+            batteryInfo: batteryInfo
+        )
+        
+        let systemWatts = metrics["systemTotalWatts"] as? Double ?? 0
+        let cpuWatts = metrics["cpuWatts"] as? Double ?? 0
+        let gpuWatts = metrics["gpuWatts"] as? Double ?? 0
+        let memWatts = metrics["memoryWatts"] as? Double ?? 0
+        let cpuV = metrics["cpuVoltage"] as? Double ?? 0
+        let cpuI = metrics["cpuCurrent"] as? Double ?? 0
+        let powerSource = metrics["powerSource"] as? String ?? ""
+        let sensors = metrics["sensors"] as? [[String: Any]] ?? []
+        
+        XCTAssertEqual(systemWatts, 45.2, accuracy: 0.1)
+        XCTAssertEqual(cpuWatts, 28.4, accuracy: 0.1)
+        XCTAssertEqual(gpuWatts, 8.5, accuracy: 0.1)
+        XCTAssertEqual(memWatts, 3.1, accuracy: 0.1)
+        XCTAssertEqual(cpuV, 1.15, accuracy: 0.01)
+        XCTAssertEqual(cpuI, 24.5, accuracy: 0.1)
+        XCTAssertEqual(powerSource, "AC Power")
+        XCTAssertEqual(sensors.count, 6)
+    }
+    
+    func testBatteryFallbackCalculation() {
+        // No PSTR, no PCPR, but VC0C and IC0C are present
+        let readings: [String: NSNumber] = [
+            "VC0C": NSNumber(value: 1.2),
+            "IC0C": NSNumber(value: 10.0)
+        ]
+        
+        let batteryInfo: [String: Any] = [
+            "powerSource": "Battery Power",
+            "isCharging": false,
+            "batteryLevel": 75.0,
+            "batteryWatts": 18.5
+        ]
+        
+        let metrics = MMPowerTelemetryProvider.calculatePowerMetrics(
+            withReadings: readings,
+            batteryInfo: batteryInfo
+        )
+        
+        let systemWatts = metrics["systemTotalWatts"] as? Double ?? 0
+        let cpuWatts = metrics["cpuWatts"] as? Double ?? 0
+        let powerSource = metrics["powerSource"] as? String ?? ""
+        let isCharging = metrics["isCharging"] as? Bool ?? true
+        
+        // System watts falls back to batteryWatts (18.5)
+        XCTAssertEqual(systemWatts, 18.5, accuracy: 0.1)
+        // CPU watts calculated from V * I = 1.2 * 10.0 = 12.0 W
+        XCTAssertEqual(cpuWatts, 12.0, accuracy: 0.1)
+        XCTAssertEqual(powerSource, "Battery Power")
+        XCTAssertFalse(isCharging)
+    }
+    
+    func testLivePowerProvider() throws {
+        let provider = MMPowerTelemetryProvider()
+        XCTAssertEqual(provider.domain, .power)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.power")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        XCTAssertNotNil(sample["systemTotalWatts"])
+        XCTAssertNotNil(sample["powerSource"])
+        XCTAssertNotNil(sample["sensors"])
+    }
+}

Tests/MMProcessDetailsTests.swift

@@ -0,0 +1,50 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMProcessDetailsTests: XCTestCase {
+    
+    func testInspectionSummaryCalculation() {
+        let mockThreads: [[String: Any]] = [
+            ["threadId": 1, "state": "Running"],
+            ["threadId": 2, "state": "Waiting"]
+        ]
+        
+        let mockFDs: [[String: Any]] = [
+            ["fd": 0, "type": "File", "path": "/dev/null"],
+            ["fd": 1, "type": "File", "path": "/tmp/test.log"],
+            ["fd": 3, "type": "Socket", "path": "TCP 127.0.0.1:80 -> 127.0.0.1:50000"]
+        ]
+        
+        let mockSockets: [[String: Any]] = [
+            ["fd": 3, "protocol": "TCP", "localAddress": "127.0.0.1", "localPort": 80, "state": "LISTEN"]
+        ]
+        
+        let summary = MMProcessDetailInspector.summarizeInspectionResults(
+            withPID: 1234,
+            threads: mockThreads,
+            fds: mockFDs,
+            sockets: mockSockets
+        )
+        
+        let pid = summary["pid"] as? Int ?? 0
+        let threadCount = summary["threadCount"] as? Int ?? 0
+        let openFDCount = summary["openFDCount"] as? Int ?? 0
+        let socketCount = summary["socketCount"] as? Int ?? 0
+        
+        XCTAssertEqual(pid, 1234)
+        XCTAssertEqual(threadCount, 2)
+        XCTAssertEqual(openFDCount, 3)
+        XCTAssertEqual(socketCount, 1)
+    }
+    
+    func testLiveProcessInspection() {
+        let currentPid = getpid()
+        let result = MMProcessDetailInspector.inspectProcess(withPID: currentPid)
+        
+        XCTAssertNotNil(result)
+        let threadCount = result?["threadCount"] as? Int ?? 0
+        XCTAssertGreaterThan(threadCount, 0)
+        let fds = result?["fileDescriptors"] as? [[String: Any]]
+        XCTAssertNotNil(fds)
+    }
+}

Tests/MMProcessTests.swift

@@ -0,0 +1,69 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMProcessTests: XCTestCase {
+    
+    func testProcessCPUPercentCalculation() {
+        let prevCPUTimes: [NSNumber: NSNumber] = [
+            100: NSNumber(value: 1_000_000_000), // 1.0s
+            200: NSNumber(value: 500_000_000)   // 0.5s
+        ]
+        
+        let rawProcesses: [[String: Any]] = [
+            [
+                "pid": 100,
+                "ppid": 1,
+                "uid": 501,
+                "username": "tester",
+                "name": "cpu_hog",
+                "cpuTimeNs": NSNumber(value: 2_000_000_000), // delta = 1.0s over 2.0s = 50% CPU
+                "residentBytes": NSNumber(value: 50_000_000),
+                "virtualBytes": NSNumber(value: 100_000_000),
+                "threadCount": 4,
+                "runningThreads": 1
+            ],
+            [
+                "pid": 200,
+                "ppid": 1,
+                "uid": 501,
+                "username": "tester",
+                "name": "idle_app",
+                "cpuTimeNs": NSNumber(value: 520_000_000), // delta = 0.02s over 2.0s = 1% CPU
+                "residentBytes": NSNumber(value: 20_000_000),
+                "virtualBytes": NSNumber(value: 50_000_000),
+                "threadCount": 2,
+                "runningThreads": 0
+            ]
+        ]
+        
+        let timeDelta: TimeInterval = 2.0
+        
+        let results = MMProcessTelemetryProvider.calculateProcessList(
+            withRawProcesses: rawProcesses,
+            previousCPUTimes: prevCPUTimes,
+            timeDelta: timeDelta
+        )
+        
+        XCTAssertEqual(results.count, 2)
+        // First entry should be highest CPU
+        XCTAssertEqual(results[0]["name"] as? String, "cpu_hog")
+        let hogCPU = results[0]["cpuPercent"] as? Double ?? 0
+        XCTAssertEqual(hogCPU, 50.0, accuracy: 0.1)
+        
+        let idleCPU = results[1]["cpuPercent"] as? Double ?? 0
+        XCTAssertEqual(idleCPU, 1.0, accuracy: 0.1)
+    }
+    
+    func testLiveProcessProvider() throws {
+        let provider = MMProcessTelemetryProvider()
+        XCTAssertEqual(provider.domain, .process)
+        XCTAssertEqual(provider.providerIdentifier, "com.i3omb.macmonitor.telemetry.process")
+        
+        let sample = try provider.sampleTelemetry()
+        XCTAssertNotNil(sample)
+        let processCount = sample["processCount"] as? Int ?? 0
+        XCTAssertGreaterThan(processCount, 0)
+        XCTAssertNotNil(sample["processes"])
+        XCTAssertNotNil(sample["totalThreads"])
+    }
+}

Tests/MMStorageTests.swift

@@ -0,0 +1,64 @@
+import XCTest
+@testable import MacMonitor
+
+final class MMStorageTests: XCTestCase {
+    
+    func testStatFSBufferParsing() {
+        var stat = statfs()
+        stat.f_bsize = 4096
+        stat.f_blocks = 125_000_000 // 500 GB
+        stat.f_bfree = 50_000_000   // 200 GB
+        stat.f_bavail = 45_000_000
+        stat.f_flags = UInt32(MNT_LOCAL)
+        
+        let mountPath = "/Volumes/External"
+        let devicePath = "/dev/disk2s1"
+        let fsType = "apfs"
+        
+        _ = mountPath.withCString { mntPtr in
+            strncpy(&stat.f_mntonname.0, mntPtr, Int(MNAMELEN))
+        }
+        _ = devicePath.withCString { devPtr in
+            strncpy(&stat.f_mntfromname.0, devPtr, Int(MNAMELEN))
+        }
+        _ = fsType.withCString { fsPtr in
+            strncpy(&stat.f_fstypename.0, fsPtr, Int(MFSTYPENAMELEN))
+        }
+        
+        withUnsafePointer(to: stat) { ptr in
+            let volumes = MMStorageTelemetryProvider.parseStatFSBuffer(ptr, count: 1)
+            XCTAssertEqual(volumes.count, 1)
+            
+            let vol = volumes.first!
+            XCTAssertEqual(vol["volumeName"] as? String, "External")
+            XCTAssertEqual(vol["mountPoint"] as? String, "/Volumes/External")
+            XCTAssertEqual(vol["devicePath"] as? String, "/dev/disk2s1")
+            XCTAssertEqual(vol["fsType"] as? String, "apfs")
+            
+            let total = vol["totalBytes"] as? UInt64 ?? 0
+            let free = vol["freeBytes"] as? UInt64 ?? 0
+            let used = vol["usedBytes"] as? UInt64 ?? 0
+            let pct = vol["usedPercent"] as? Double ?? 0
+            
+            XCTAssertEqual(total, 512_000_000_000)
+            XCTAssertEqual(free, 204_800_000_000)
+            XCTAssertEqual(used, 307_200_000_000)
+            XCTAssertEqual(pct, 60.0, accuracy: 0.1)
+        }
+    }
+    
+    func testLiveStorageProvider() throws {
+        let provider = MMStorageTelemetryProvider()
+        XCTAssertTrue(provider.isAvailable)
+        XCTAssertEqual(provider.domain, .storage)
+        
+        let sample = try provider.sampleTelemetry()
+        let volumes = sample["volumes"] as? [[String: Any]]
+        XCTAssertNotNil(volumes)
+        XCTAssertGreaterThan(volumes?.count ?? 0, 0)
+        
+        let firstVol = volumes?.first
+        XCTAssertNotNil(firstVol?["mountPoint"])
+        XCTAssertGreaterThan(firstVol?["totalBytes"] as? UInt64 ?? 0, 0)
+    }
+}

Tests/MacMonitorTests.swift

@@ -23,4 +23,15 @@ final class MacMonitorCoreTests: XCTestCase {
         let thermalStr = MMTelemetryDomainToString(.thermal)
         XCTAssertEqual(thermalStr, "Thermal")
     }
+    
+    @MainActor
+    func testSystemTelemetryStoreInitialStateAndProviders() {
+        let store = SystemTelemetryStore.shared
+        XCTAssertNotNil(store)
+        XCTAssertEqual(store.registeredProviderCount, 17)
+        XCTAssertFalse(store.hostModel.isEmpty)
+        XCTAssertFalse(store.kernelVersion.isEmpty)
+        XCTAssertGreaterThanOrEqual(store.physicalCpuCount, 1)
+        XCTAssertGreaterThanOrEqual(store.logicalCpuCount, 1)
+    }
 }