Stability improvement

Author: Jojatekok

Diff for: PoloniexApi.Net/LiveTools/Live.cs

@@ -4,6 +4,7 @@
 using System.Threading.Tasks;
 using System.Web;
 using WampSharp.V2;
+using WampSharp.V2.Realm;
 
 namespace Jojatekok.PoloniexAPI.LiveTools
 {
@@ -31,14 +32,53 @@ public ObservableDictionary<CurrencyPair, MarketData> Tickers {
         public void Start()
         {
             WampChannel = new DefaultWampChannelFactory().CreateJsonChannel(Helper.ApiUrlWssBase, "realm1");
+            WampChannel.RealmProxy.Monitor.ConnectionBroken += OnConnectionBroken;
+
             WampChannelOpenTask = WampChannel.Open();
         }
 
         public void Stop()
         {
+            foreach (var subscription in ActiveSubscriptions.Values) {
+                subscription.Dispose();
+            }
+            ActiveSubscriptions.Clear();
+
             WampChannel.Close();
         }
 
+        private void OnConnectionBroken(object sender, WampSessionCloseEventArgs e)
+        {
+            if (e.CloseType != SessionCloseType.Disconnection) {
+                var subscriptions = new string[ActiveSubscriptions.Count];
+                var i = 0;
+                foreach (var subjectName in ActiveSubscriptions.Keys) {
+                    subscriptions[i] = subjectName;
+                    i++;
+                }
+                ActiveSubscriptions.Clear();
+
+                // Re-initialize WampChannel
+                Start();
+
+                // Re-subscribe to subjects
+#pragma warning disable 4014
+                for (var j = subscriptions.Length - 1; j >= 0; j--) {
+                    var subjectName = subscriptions[j];
+                    switch (subjectName) {
+                        case SubjectNameTicker:
+                            SubscribeToTickerAsync();
+                            break;
+
+                        case SubjectNameTrollbox:
+                            SubscribeToTrollboxAsync();
+                            break;
+                    }
+                }
+#pragma warning restore 4014
+            }
+        }
+
         public async Task SubscribeToTickerAsync()
         {
             if (!ActiveSubscriptions.ContainsKey(SubjectNameTicker)) {

Diff for: PoloniexApi.Net/Properties/AssemblyInfo.cs

@@ -29,6 +29,6 @@
 // You can specify all the values or you can default the Build and Revision Numbers 
 // by using the '*' as shown below:
 // [assembly: AssemblyVersion("1.0.*")]
-[assembly: AssemblyVersion("1.1.3")]
-[assembly: AssemblyFileVersion("1.1.3")]
+[assembly: AssemblyVersion("1.1.4")]
+[assembly: AssemblyFileVersion("1.1.4")]
 [assembly: NeutralResourcesLanguageAttribute("en")]