WingMan – Diff between revs 1 and 2

Subversion Repositories:

?pathlinks?

Rev 1 – Rev 3 – Go to most recent revision – Details – Blame – Last modification – View Log

 using WingMan.Communication;
 using WingMan.Host;
 namespace WingMan
 {
-    public partial class Form1 : Form
+    public partial class WingManForm : Form
     {
-        private MQTTServer MQTTServer { get; set; } = new MQTTServer();
+        private MQTTServer MQTTServer { get; set; }
-        private MQTTClient MQTTClient { get; set; } = new MQTTClient();
+        private MQTTClient MQTTClient { get; set; }
         private SemaphoreSlim MQTTServerSemaphore {get; set;} =  new SemaphoreSlim(1, 1);
+        private SemaphoreSlim MQTTClientSemaphore { get; set; } = new SemaphoreSlim(1, 1);
+        public WingManForm()
         private SemaphoreSlim MQTTClientSemaphore { get; set; } = new SemaphoreSlim(1, 1);
             InitializeComponent();
         public Form1()
             MQTTClient = new MQTTClient(this);
                 ConnectButton.Enabled = true;
                 return;
             }
-            if (!ValidateAddressPort(out var ipAddress, out var port))
+            if (!ValidateAddressPort(out var ipAddress, out var port, out var nick))
                 return;
             // Start the MQTT server.
-            await StartServer(ipAddress, port);
+            await StartServer(ipAddress, port, nick);
             toolStripStatusLabel.Text = Properties.Strings.Server_started;
             HostButton.BackColor = Color.Aquamarine;
             ConnectButton.Enabled = false;
+        }
         private bool ValidateAddressPort(out IPAddress address, out int port, out string nick)
-        private bool ValidateAddressPort(out IPAddress address, out int port)
+        {
+            address = IPAddress.Any;
             port = 0;
-            address = IPAddress.Any;
+            nick = string.Empty;
             port = 0;
+            if (string.IsNullOrEmpty(Address.Text) &&
                 string.IsNullOrEmpty(Port.Text) &&
-            if (string.IsNullOrEmpty(Address.Text) &&
+                string.IsNullOrEmpty(Nick.Text))
                 string.IsNullOrEmpty(Port.Text))
                 Address.BackColor = Color.LightPink;
                 return false;
+            }
+            port = (int) uPort;
+            if (string.IsNullOrEmpty(Nick.Text))
+            {
+                Nick.BackColor = Color.LightPink;
+                return false;
+            }
-            port = (int) uPort;
+            nick = Nick.Text;
+            Address.BackColor = Color.Empty;
-            Address.BackColor = Color.Empty;
+            Port.BackColor = Color.Empty;
-            Port.BackColor = Color.Empty;
+            Nick.BackColor = Color.Empty;
             return true;
+        }
-        private async Task StartServer(IPAddress ipAddress, int port)
+        private async Task StartServer(IPAddress ipAddress, int port, string nick)
         {
             await MQTTServerSemaphore.WaitAsync();
             try
+            {
-                await MQTTServer.Start(ipAddress, port);
+                await MQTTServer.Start(ipAddress, port, nick);
+            }
                 HostButton.Enabled = true;
                 return;
             }
-            if (!ValidateAddressPort(out var ipAddress, out var port))
+            if (!ValidateAddressPort(out var ipAddress, out var port, out var nick))
                 return;
-            await StartClient(ipAddress, port);
+            await StartClient(ipAddress, port, nick);
+            {
                 MQTTClientSemaphore.Release();
+            }
+        }
-        private async Task StartClient(IPAddress ipAddress, int port)
+        private async Task StartClient(IPAddress ipAddress, int port, string nick)
+        {
             await MQTTClientSemaphore.WaitAsync();
             try
             {
-                await MQTTClient.Start(ipAddress, port);
+                await MQTTClient.Start(ipAddress, port, nick);
+            }
             finally
+            {
                 MQTTClientSemaphore.Release();
+            }
+        }
+        private async void LobbySayTextBoxKeyDown(object sender, KeyEventArgs e)
+        {
+            if (e.KeyCode != Keys.Enter)
+                return;
+            if (MQTTServer.ServerRunning)
+            {
+                await MQTTServer.BroadcastLobbyMessage(LobbySayTextBox.Text);
+            }
+            if (MQTTClient.ClientRunning)
+            {
+                await MQTTClient.BroadcastLobbyMessage(LobbySayTextBox.Text);
+            }
+        }
+    }