WingMan – Diff between revs 27 and 32

Subversion Repositories:

?pathlinks?

Rev 27 – Rev 33 – Go to most recent revision – Details – Blame – Last modification – View Log

 using MQTTnet.Extensions.ManagedClient;
 using MQTTnet.Server;
 using WingMan.AutoCompletion;
 using WingMan.Bindings;
 using WingMan.Communication;
+using WingMan.Discovery;
 using WingMan.Lobby;
 using WingMan.Properties;
 using WingMan.Utilities;
             InitializeComponent();
             FormTaskScheduler = TaskScheduler.FromCurrentSynchronizationContext();
+            FormCancellationTokenSource = new CancellationTokenSource();
+            // Set up discovery.
+            Discovery = new Discovery.Discovery(FormCancellationTokenSource, FormTaskScheduler);
-            FormCancellationTokenSource = new CancellationTokenSource();
+            Discovery.OnPortMapFailed += OnDiscoveryPortMapFailed;
             // Set up autocompletion.
             AutoCompletion = new AutoCompletion.AutoCompletion(FormTaskScheduler, FormCancellationTokenSource.Token);
             KeySimulator = new KeySimulator(LocalKeyBindings, MqttCommunication, FormTaskScheduler,
                 FormCancellationTokenSource.Token);
             KeySimulator.OnMouseKeyBindingExecuting += OnMouseKeyBindingExecuting;
+        }
         private static Discovery.Discovery Discovery { get; set; }
         private static AutoCompletion.AutoCompletion AutoCompletion { get; set; }
         private static CancellationTokenSource FormCancellationTokenSource { get; set; }
         public KeyInterceptor KeyInterceptor { get; set; }
+        public KeySimulator KeySimulator { get; set; }
+        public void OnDiscoveryPortMapFailed(object sender, DiscoveryFailedEventArgs args)
+        {
+            switch (args.Type)
+            {
+                case DiscoveryType.UPnP:
+                    ActivityTextBox.AppendText(
+                        $"{Strings.Failed_to_create_UPnP_port_mapping}{Environment.NewLine}");
+                    break;
+                case DiscoveryType.PMP:
+                    ActivityTextBox.AppendText(
+                        $"{Strings.Failed_to_create_PMP_port_mapping}{Environment.NewLine}");
+                    break;
+            }
         public KeySimulator KeySimulator { get; set; }
         private void LocalCheckedListBoxBindingSourceOnListChanged(object sender, ListChangedEventArgs e)
             if (!ValidateConnectionParameters(out var ipAddress, out var port, out var nick, out var password))
                 return;
+            StoreConnectionAutocomplete();
+            // Try to reserve port: try UPnP followed by PMP.
+            if (!await Discovery.CreateMapping(DiscoveryType.UPnP, port) &&
+                !await Discovery.CreateMapping(DiscoveryType.PMP, port))
+                ActivityTextBox.AppendText(
-            StoreConnectionAutocomplete();
+                    $"{Strings.Failed_creating_automatic_port_mapping_please_make_sure_the_port_is_routed_properly}{Environment.NewLine}");
             // Start the MQTT server.
             if (!await MqttCommunication
                 .Start(MqttCommunicationType.Server, ipAddress, port, nick, password))