Updated TwitchLib.Communication to newest version

Updated code to be more async
Aligned code with Communication lib changes

.gitignore

@@ -233,4 +233,6 @@ $RECYCLE.BIN/
 *.msp
 
 # Windows shortcuts
-*.lnk
+*.lnk
+
+.idea/*

TwitchLib.PubSub/Interfaces/ITwitchPubSub.cs

@@ -1,4 +1,5 @@
 using System;
+using System.Threading.Tasks;
 using TwitchLib.PubSub.Events;
 
 namespace TwitchLib.PubSub.Interfaces
@@ -169,10 +170,22 @@ public interface ITwitchPubSub
         /// Connects this instance.
         /// </summary>
         void Connect();
+
+        /// <summary>
+        /// Connects this instance.
+        /// </summary>
+        Task ConnectAsync();
+
         /// <summary>
         /// Disconnects this instance.
         /// </summary>
         void Disconnect();
+
+        /// <summary>
+        /// Disconnects this instance.
+        /// </summary>
+        Task DisconnectAsync();
+
         /// <summary>
         /// Listens to bits events.
         /// </summary>
@@ -248,6 +261,14 @@ public interface ITwitchPubSub
         /// <param name="oauth">The oauth.</param>
         /// <param name="unlisten">if set to <c>true</c> [unlisten].</param>
         void SendTopics(string oauth = null, bool unlisten = false);
+
+        /// <summary>
+        /// Sends the topics.
+        /// </summary>
+        /// <param name="oauth">The oauth.</param>
+        /// <param name="unlisten">if set to <c>true</c> [unlisten].</param>
+        Task SendTopicsAsync(string oauth = null, bool unlisten = false);
+
         /// <summary>
         /// Tests the message parser.
         /// </summary>

TwitchLib.PubSub/TwitchLib.PubSub.csproj

@@ -25,6 +25,6 @@
   <ItemGroup>
     <PackageReference Include="Newtonsoft.Json" Version="13.0.2" />
     <PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="7.0.0" />
-    <PackageReference Include="TwitchLib.Communication" Version="1.0.4" />
+    <PackageReference Include="TwitchLib.Communication" Version="2.0.0-preview-8108207851b6bbef87062f15a497036183ffea70" />
   </ItemGroup>
 </Project>

TwitchLib.PubSub/TwitchPubSub.cs

@@ -4,6 +4,7 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading;
+using System.Threading.Tasks;
 using System.Timers;
 using TwitchLib.Communication.Clients;
 using TwitchLib.Communication.Enums;
@@ -288,7 +289,7 @@ public TwitchPubSub(ILogger<TwitchPubSub> logger = null)
         {
             _logger = logger;
 
-            var options = new ClientOptions { ClientType = ClientType.PubSub };
+            var options = new ClientOptions(clientType: ClientType.PubSub);
             _socket = new WebSocketClient(options);
 
             _socket.OnConnected += Socket_OnConnected;
@@ -297,7 +298,7 @@ public TwitchPubSub(ILogger<TwitchPubSub> logger = null)
             _socket.OnDisconnected += Socket_OnDisconnected;
 
             _pongTimer.Interval = 15000; //15 seconds, we should get a pong back within 10 seconds.
-            _pongTimer.Elapsed += PongTimerTick;
+            _pongTimer.Elapsed += PongTimerTickAsync;
         }
 
         /// <summary>
@@ -345,7 +346,7 @@ private void Socket_OnConnected(object sender, EventArgs e)
         {
             _logger?.LogInformation("PubSub Websocket connection established");
             _pingTimer.Interval = 180000;
-            _pingTimer.Elapsed += PingTimerTick;
+            _pingTimer.Elapsed += PingTimerTickAsync;
             _pingTimer.Start();
             OnPubSubServiceConnected?.Invoke(this, null);
         }
@@ -355,7 +356,7 @@ private void Socket_OnConnected(object sender, EventArgs e)
         /// </summary>
         /// <param name="sender">The sender.</param>
         /// <param name="e">The <see cref="ElapsedEventArgs"/> instance containing the event data.</param>
-        private void PingTimerTick(object sender, ElapsedEventArgs e)
+        private async void PingTimerTickAsync(object sender, ElapsedEventArgs e)
         {
             //Reset pong state.
             _pongReceived = false;
@@ -364,7 +365,8 @@ private void PingTimerTick(object sender, ElapsedEventArgs e)
             var data = new JObject(
                 new JProperty("type", "PING")
             );
-            _socket.Send(data.ToString());
+
+            await _socket.SendAsync(data.ToString());
 
             //Start pong timer.
             _pongTimer.Start();
@@ -375,7 +377,7 @@ private void PingTimerTick(object sender, ElapsedEventArgs e)
         /// </summary>
         /// <param name="sender">The sender.</param>
         /// <param name="e">The <see cref="ElapsedEventArgs"/> instance containing the event data.</param>
-        private void PongTimerTick(object sender, ElapsedEventArgs e)
+        private async void PongTimerTickAsync(object sender, ElapsedEventArgs e)
         {
             //Stop the pong timer.
             _pongTimer.Stop();
@@ -388,7 +390,7 @@ private void PongTimerTick(object sender, ElapsedEventArgs e)
             else
             {
                 //Otherwise we're disconnected so close the socket.
-                _socket.Close();
+                await _socket.CloseAsync();
             }
         }
 
@@ -680,7 +682,11 @@ private void ParseMessage(string message)
                 case "pong":
                     _pongReceived = true;
                     return;
-                case "reconnect": _socket.Close(); break;
+                case "reconnect":
+                    // This does not fit here. This method parses message, it shouldn't do any action.
+                    // TODO: Fire event to trigger socket close
+                    _socket.CloseAsync().GetAwaiter().GetResult(); 
+                    break;
             }
             UnaccountedFor(message);
         }
@@ -720,13 +726,19 @@ private void ListenToTopics(params string[] topics)
             }
         }
 
+        /// <inheritdoc />
+        public void SendTopics(string oauth = null, bool unlisten = false)
+        {
+            SendTopicsAsync(oauth, unlisten).GetAwaiter().GetResult();
+        }
+
         /// <inheritdoc />
         /// <summary>
         /// Sends the topics.
         /// </summary>
         /// <param name="oauth">The oauth.</param>
         /// <param name="unlisten">if set to <c>true</c> [unlisten].</param>
-        public void SendTopics(string oauth = null, bool unlisten = false)
+        public async Task SendTopicsAsync(string oauth = null, bool unlisten = false)
         {
             if (oauth != null && oauth.Contains("oauth:"))
             {
@@ -764,7 +776,7 @@ public void SendTopics(string oauth = null, bool unlisten = false)
                 ((JObject)jsonData.SelectToken("data"))?.Add(new JProperty("auth_token", oauth));
             }
 
-            _socket.Send(jsonData.ToString());
+            await _socket.SendAsync(jsonData.ToString());
 
             _topicList.Clear();
         }
@@ -968,16 +980,25 @@ public void ListenToPredictions(string channelTwitchId)
         /// </summary>
         public void Connect()
         {
-            _socket.Open();
+            ConnectAsync().GetAwaiter().GetResult();
+        }
+
+        /// <inheritdoc />
+        public async Task ConnectAsync()
+        {
+            await _socket.OpenAsync();
         }
 
         /// <inheritdoc />
-        /// <summary>
-        /// What do you think it does? :)
-        /// </summary>
         public void Disconnect()
         {
-            _socket.Close();
+            DisconnectAsync().GetAwaiter().GetResult();
+        }
+
+        /// <inheritdoc />
+        public async Task DisconnectAsync()
+        {
+            await _socket.CloseAsync();
         }
 
         /// <inheritdoc />