Winify – Diff between revs 18 and 21

Subversion Repositories:

?pathlinks?

Rev 18 – Rev 24 – Go to most recent revision – Details – Blame – Last modification – View Log

+            {
                 do
+                {
                     try
+                    {
-                        _webSocketClient = new ClientWebSocket();
+                        using (_webSocketClient = new ClientWebSocket())
-                        var auth = Convert.ToBase64String(Encoding.Default.GetBytes($"{username}:{password}"));
-                        _webSocketClient.Options.SetRequestHeader("Authorization", $"Basic {auth}");
-                        await _webSocketClient.ConnectAsync(webSocketsUri, cancellationToken);
-                        do
+                        {
-                            var payload = new ArraySegment<byte>(new byte[1024]);
+                            var auth = Convert.ToBase64String(Encoding.Default.GetBytes($"{username}:{password}"));
-                            await _webSocketClient.ReceiveAsync(payload, cancellationToken);
+                            _webSocketClient.Options.SetRequestHeader("Authorization", $"Basic {auth}");
-                            if (payload.Array == null || payload.Count == 0)
-                            {
-                                continue;
-                            }
-                            var message = Encoding.UTF8.GetString(payload.Array, 0, payload.Count);
                             await _webSocketClient.ConnectAsync(webSocketsUri, cancellationToken);
-                            var gotifyNotification = JsonConvert.DeserializeObject<GotifyNotification>(message);
-                            if (gotifyNotification == null)
-                            {
+                            do
+                            {
+                                var payload = new ArraySegment<byte>(new byte[1024]);
-                                continue;
-                            }
+                                var result = await _webSocketClient.ReceiveAsync(payload, cancellationToken);
-                            if (!Uri.TryCreate($"{httpUri}/application", UriKind.Absolute, out var applicationUri))
+                                if (result.Count == 0)
+                                {
+                                    continue;
+                                }
-                            {
-                                continue;
-                            }
-                            var applications = await _httpClient.GetStringAsync(applicationUri);
+                                if (payload.Array == null || payload.Count == 0)
-                            var gotifyApplications = JsonConvert.DeserializeObject<GotifyApplication[]>(applications);
-                            if (gotifyApplications == null)
+                                {
                                     continue;
                                 continue;
+                                var message = Encoding.UTF8.GetString(payload.Array, 0, payload.Count);
-                            foreach (var application in gotifyApplications)
-                                if (application.Id != gotifyNotification.AppId)
+                                var gotifyNotification = JsonConvert.DeserializeObject<GotifyNotification>(message);
                                 if (gotifyNotification == null)
-                                    continue;
+                                {
+                                    continue;
+                                }
-                                }
                                 if (!Uri.TryCreate($"{httpUri}/application", UriKind.Absolute, out var applicationUri))
                                 if (!Uri.TryCreate($"{httpUri}/{application.Image}", UriKind.Absolute,
-                                    out var applicationImageUri))
+                                    continue;
-                                {
+                                }
                                     continue;
+                                var applications = await _httpClient.GetStringAsync(applicationUri);
+                                var gotifyApplications =
+                                    JsonConvert.DeserializeObject<GotifyApplication[]>(applications);
+                                if (gotifyApplications == null)
+                                {
+                                    continue;
+                                }
+                                foreach (var application in gotifyApplications)
+                                {
+                                    if (application.Id != gotifyNotification.AppId)
+                                    {
+                                        continue;
+                                    }
+                                    if (!Uri.TryCreate($"{httpUri}/{application.Image}", UriKind.Absolute,
+                                        out var applicationImageUri))
+                                    {
+                                        continue;
-                                }
+                                    }
+                                    var imageBytes = await _httpClient.GetByteArrayAsync(applicationImageUri);
+                                    if (imageBytes == null || imageBytes.Length == 0)
-                                var imageBytes = await _httpClient.GetByteArrayAsync(applicationImageUri);
+                                    {
+                                        continue;
-                                if (imageBytes == null || imageBytes.Length == 0)
+                                    }
-                                {
-                                    continue;
+                                    using (var memoryStream = new MemoryStream(imageBytes))
-                                }
+                                    {
+                                        var image = Image.FromStream(memoryStream);
-                                using (var memoryStream = new MemoryStream(imageBytes))
                                         GotifyNotification?.Invoke(this,
-                                    var image = Image.FromStream(memoryStream);
+                                            new GotifyNotificationEventArgs(gotifyNotification, image));
+                                    }
                                     GotifyNotification?.Invoke(this,