DEMRUM-773: Network Monitor Module

Package.swift

@@ -58,6 +58,7 @@ func generateMainTargets() -> [Target] {
                 "SplunkSessionReplayProxy",
                 "SplunkNavigation",
                 "SplunkNetwork",
+                "SplunkNetworkMonitor",
                 "SplunkSlowFrameDetector",
                 "SplunkOpenTelemetry",
                 .product(name: "OpenTelemetryApi", package: "opentelemetry-swift"),
@@ -125,10 +126,27 @@ func generateMainTargets() -> [Target] {
             dependencies: ["SplunkNetwork"],
             path: "SplunkNetwork/Tests"
         ),
+
+
+        // MARK: - Splunk Network Monitor
 
-
+        .target(
+            name: "SplunkNetworkMonitor",
+            dependencies: [
+                "SplunkCommon",
+                "SplunkOpenTelemetry"
+            ],
+            path: "SplunkNetworkMonitor/Sources"
+        ),
+        .testTarget(
+            name: "SplunkNetworkMonitorTests",
+            dependencies: ["SplunkNetworkMonitor"],
+            path: "SplunkNetworkMonitor/Tests"
+        ),
+
+
         // MARK: - Splunk Common
-
+        
         .target(
             name: "SplunkCommon",
             path: "SplunkCommon/Sources"

SplunkAgent/Sources/SplunkAgent/Agent/Modules/Pool/DefaultModulesPool.swift

@@ -33,6 +33,10 @@ internal import SplunkCommon
     internal import SplunkNetwork
 #endif
 
+#if canImport(SplunkNetworkMonitor)
+    internal import SplunkNetworkMonitor
+#endif
+
 #if canImport(CiscoSessionReplay)
     internal import CiscoSessionReplay
     internal import SplunkSessionReplayProxy
@@ -79,6 +83,11 @@ class DefaultModulesPool: AgentModulesPool {
             knownModules.append(NetworkInstrumentation.self)
         #endif
 
+        // Network Monitor
+        #if canImport(SplunkNetworkMonitor)
+            knownModules.append(NetworkMonitor.self)
+        #endif
+
         // Slow Frame Detector
         #if canImport(SplunkSlowFrameDetector)
             knownModules.append(SlowFrameDetector.self)

SplunkAgent/Sources/SplunkAgent/Agent/Modules/SplunkRum+Modules.swift

@@ -20,6 +20,7 @@ internal import CiscoSessionReplay
 internal import SplunkAppStart
 internal import SplunkNavigation
 internal import SplunkNetwork
+internal import SplunkNetworkMonitor
 
 #if canImport(SplunkCrashReports)
     internal import SplunkCrashReports
@@ -55,7 +56,9 @@ extension SplunkRum {
         customizeNavigation()
         customizeNetwork()
         customizeAppStart()
+        customizeNetworkMonitor()
         customizeWebView()
+
     }
 
     /// Perform operations specific to the SessionReplay module.
@@ -148,6 +151,13 @@ extension SplunkRum {
         appStartModule?.sharedState = sharedState
     }
 
+    /// Configure NetworkMonitor module
+    private func customizeNetworkMonitor() {
+        let networkMonitorModule = modulesManager?.module(ofType: SplunkNetworkMonitor.NetworkMonitor.self)
+
+        networkMonitorModule?.sharedState = sharedState
+    }
+
     /// Configure WebView Instrumentation module with shared state.
     private func customizeWebView() {
         // Get WebViewInstrumentation module, set its sharedState

SplunkNetworkMonitor/Sources/SplunkNetworkMonitor/Module/NetworkMonitor+Module.swift

@@ -0,0 +1,56 @@
+//
+/*
+Copyright 2025 Splunk Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import Foundation
+import SplunkCommon
+
+
+public struct NetworkMonitorData: ModuleEventData {}
+
+public struct NetworkMonitorMetadata: ModuleEventMetadata {
+    public var timestamp = Date()
+    public var eventName: String = "network.change"
+}
+
+extension NetworkMonitor: Module {
+
+    // MARK: - Module types
+
+    public typealias Configuration = NetworkMonitorConfiguration
+    public typealias RemoteConfiguration = NetworkMonitorRemoteConfiguration
+
+    public typealias EventMetadata = NetworkMonitorMetadata
+    public typealias EventData = NetworkMonitorData
+
+
+    // MARK: - Module methods
+
+    public func install(with configuration: (any ModuleConfiguration)?, remoteConfiguration: (any RemoteModuleConfiguration)?) {
+        let config = configuration as? Configuration
+
+        // Start the network monitor if it's enabled or if no configuration is provided.
+        if config?.isEnabled ?? true {
+            startDetection()
+        }
+    }
+
+
+    // MARK: - Type transparency helpers
+
+    public func deleteData(for metadata: any ModuleEventMetadata) {}
+    public func onPublish(data: @escaping (NetworkMonitorMetadata, NetworkMonitorData) -> Void) {}
+}

SplunkNetworkMonitor/Sources/SplunkNetworkMonitor/Module/NetworkMonitorConfiguration.swift

@@ -0,0 +1,36 @@
+//
+/*
+Copyright 2025 Splunk Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import Foundation
+import SplunkCommon
+
+/// NetworkMonitor module configuration, minimal configuration for module conformance.
+public struct NetworkMonitorConfiguration: ModuleConfiguration {
+
+    // MARK: - Module management
+
+    /// Indicates whether the Module is enabled. Default value is `true`.
+    public var isEnabled: Bool = true
+
+    /// Initializes new module configuration with preconfigured values.
+    ///
+    /// - Parameters:
+    ///   - isEnabled: A `Boolean` value sets whether the module is enabled.
+    public init(isEnabled: Bool) {
+        self.isEnabled = isEnabled
+    }
+}

SplunkNetworkMonitor/Sources/SplunkNetworkMonitor/Module/NetworkMonitorRemoteConfiguration.swift

@@ -0,0 +1,54 @@
+//
+/*
+Copyright 2025 Splunk Inc.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+import Foundation
+import SplunkCommon
+
+/// NetworkMonitor remote configuration.
+public struct NetworkMonitorRemoteConfiguration: RemoteModuleConfiguration {
+
+    // MARK: - Internal decoding
+
+    struct NetworkMonitor: Decodable {
+        let enabled: Bool
+    }
+
+    struct MRUMRoot: Decodable {
+        let NetworkMonitor: NetworkMonitor
+    }
+
+    struct Configuration: Decodable {
+        let mrum: MRUMRoot
+    }
+
+    struct Root: Decodable {
+        let configuration: Configuration
+    }
+
+
+    // MARK: - Public
+
+    public var enabled: Bool
+
+    public init?(from data: Data) {
+        guard let root = try? JSONDecoder().decode(Root.self, from: data) else {
+            return nil
+        }
+
+        enabled = root.configuration.mrum.NetworkMonitor.enabled
+    }
+}