From e6c3c72677709af1135948b490a99d8f0c6a48bd Mon Sep 17 00:00:00 2001
From: Malek <malek.zoabi@amdocs.com>
Date: Tue, 16 Oct 2018 16:44:41 +0300
Subject: Add worker to onboard notification

Issue-ID: SDC-1840
Change-Id: I0506df2073beb14de2aea5a01233f05ce9a6d7f7
Signed-off-by: Malek <malek.zoabi@amdocs.com>
---
 .../src/nfvo-utils/Notifications.worker.js         | 59 ++++++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 openecomp-ui/src/nfvo-utils/Notifications.worker.js

(limited to 'openecomp-ui/src/nfvo-utils/Notifications.worker.js')

diff --git a/openecomp-ui/src/nfvo-utils/Notifications.worker.js b/openecomp-ui/src/nfvo-utils/Notifications.worker.js
new file mode 100644
index 0000000000..3e9f688c57
--- /dev/null
+++ b/openecomp-ui/src/nfvo-utils/Notifications.worker.js
@@ -0,0 +1,59 @@
+/*
+* Copyright © 2018 European Support Limited
+*
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*      http: //www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*/
+
+import axios from 'axios';
+
+let prevLastScanned;
+let updateNotificationsTimeout;
+let config;
+let notificationsWorkerUpdateMillisecond;
+
+function updateNotifications() {
+    axios(config)
+        .then(response => {
+            const notifications = response.data;
+
+            let lastScanned = notifications.lastScanned;
+            if (prevLastScanned !== lastScanned) {
+                postMessage(notifications);
+            }
+            prevLastScanned = lastScanned;
+        })
+        .catch(() => {});
+
+    updateNotificationsTimeout = setTimeout(
+        updateNotifications,
+        notificationsWorkerUpdateMillisecond
+    );
+}
+
+navigator.connection.onchange = () => {
+    clearTimeout(updateNotificationsTimeout);
+
+    if (navigator.onLine && config && notificationsWorkerUpdateMillisecond) {
+        updateNotifications();
+    }
+};
+
+onmessage = ({ data }) => {
+    if (data && data.config && data.notificationsWorkerUpdateMillisecond) {
+        config = data.config;
+        notificationsWorkerUpdateMillisecond =
+            data.notificationsWorkerUpdateMillisecond;
+
+        updateNotifications();
+    }
+};
-- 
cgit 1.2.3-korg