don't pass route message handler to peer manager in channel manager constructor

Author: arik-so

bindings/batteries/ChannelManagerConstructor.swift

@@ -117,7 +117,10 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
         var messageHandler: MessageHandler!
         if let netGraph = net_graph {
             self.graph_msg_handler = NetGraphMsgHandler(network_graph: netGraph, chain_access: Option_AccessZ.none(), logger: logger)
-            messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
+            
+            // messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
+            // temporarily disable handling routing messages by the peer manager to avoid excessive memory growth
+            messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: noCustomMessages.as_RoutingMessageHandler())
         } else {
             messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: noCustomMessages.as_RoutingMessageHandler())
         }
@@ -162,7 +165,11 @@ public class ChannelManagerConstructor: NativeTypeWrapper {
         if let netGraph = net_graph {
             let noneOption = Option_AccessZ.none()
             self.graph_msg_handler = NetGraphMsgHandler(network_graph: netGraph, chain_access: noneOption, logger: logger)
-            messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
+            
+            
+            // messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: self.graph_msg_handler!.as_RoutingMessageHandler())
+            // temporarily disable handling routing messages by the peer manager to avoid excessive memory growth
+            messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: noCustomMessages.as_RoutingMessageHandler())
         } else {
             messageHandler = MessageHandler(chan_handler_arg: channelManager.as_ChannelMessageHandler(), route_handler_arg: noCustomMessages.as_RoutingMessageHandler())
         }

xcode/DirectBindingsApp/DirectBindingsApp/ContentView.swift

@@ -10,6 +10,8 @@ import SwiftUI
 struct ContentView: View {
 
     @State private var isRunningTestFlow = false
+    
+    @State private var multiPeerSimulation: PolarIntegrationSample.MultiPeerSimulator? = nil
 
     var body: some View {
 
@@ -29,7 +31,30 @@ struct ContentView: View {
             Text("Hello World")
         }).disabled(self.isRunningTestFlow)
 
-
+        if let simulation = self.multiPeerSimulation {
+            Button {
+                // self.multiPeerSimulation = nil
+                Task {
+                    await self.multiPeerSimulation?.interrupt()
+                    
+                    // freeing the simulation
+                    // try! await Task.sleep(nanoseconds: 5_000_000_000)
+                    // self.multiPeerSimulation = nil
+                }
+            } label: {
+                Text("Stop multi-peer simulation")
+            }
+        } else {
+            Button {
+                self.multiPeerSimulation = PolarIntegrationSample.MultiPeerSimulator()
+                Task {
+                    try? await self.multiPeerSimulation!.simulateMultiplePeers()
+                }
+            } label: {
+                Text("Simulate multiple peers")
+            }
+        }
+        
     }
 
     /*@StateObject private var experiment = PolarConnectionExperiment()