feat: add webpush

Author: Angular2Guy

frontend/app/webpush/dedicated-worker.js

@@ -0,0 +1,69 @@
+let jwtToken = '';
+let tokenIntervalRef;
+const refreshToken = (myToken) => {
+    if (!!tokenIntervalRef) {
+        clearInterval(tokenIntervalRef);
+    }
+    jwtToken = myToken;
+    if (!!jwtToken && jwtToken.length > 10) {
+        tokenIntervalRef = setInterval(() => {
+            const requestOptions = {
+                method: 'GET',
+                headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${jwtToken}` },
+            };
+            fetch('/appuser/refreshtoken', requestOptions).then(response => response.json()).then(result => {
+                if ((!result.Message && !!result.Token && result.Token.length > 10)) {
+                    //console.log('Token refreshed.');
+                    jwtToken = result.Token;
+                    /* eslint-disable-next-line no-restricted-globals */
+                    self.postMessage(result);
+                }
+                else {
+                    jwtToken = '';
+                    clearInterval(tokenIntervalRef);
+                }
+            });
+        }, 45000);
+    }
+};
+let firstNotRequest = true;
+let notificationIntervalRef;
+/* eslint-disable-next-line no-restricted-globals */
+self.addEventListener('message', (event) => {
+    const msgData = event.data;
+    refreshToken(msgData.jwtToken);
+    if (!!notificationIntervalRef) {
+        clearInterval(notificationIntervalRef);
+    }
+    notificationIntervalRef = setInterval(() => {
+        if (!jwtToken) {
+            clearInterval(notificationIntervalRef);
+            firstNotRequest = true;
+        }
+        const requestOptions = {
+            method: 'GET',
+            headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${jwtToken}` },
+        };
+        /* eslint-disable-next-line no-restricted-globals */
+        self.fetch(msgData.newNotificationUrl, requestOptions).then(result => result.json()).then(resultJson => {
+            var _a, _b, _c, _d;
+            if (!!resultJson && (resultJson === null || resultJson === void 0 ? void 0 : resultJson.length) > 0) {
+                /* eslint-disable-next-line no-restricted-globals */
+                self.postMessage(resultJson);
+                //Notification
+                //console.log(Notification.permission);
+                if (Notification.permission === 'granted' && !firstNotRequest) {
+                    if ((resultJson === null || resultJson === void 0 ? void 0 : resultJson.length) > 0 && ((_b = (_a = resultJson[0]) === null || _a === void 0 ? void 0 : _a.Message) === null || _b === void 0 ? void 0 : _b.length) > 1 && ((_d = (_c = resultJson[0]) === null || _c === void 0 ? void 0 : _c.Title) === null || _d === void 0 ? void 0 : _d.length) > 1) {
+                        for (let value of resultJson) {
+                            new Notification(value === null || value === void 0 ? void 0 : value.Title, { body: value === null || value === void 0 ? void 0 : value.Message });
+                        }
+                    }
+                }
+                else if (!!firstNotRequest) {
+                    firstNotRequest = false;
+                }
+            }
+        });
+    }, 60000);
+});
+export {};

frontend/app/webpush/dedicated-worker.ts

@@ -0,0 +1,93 @@
+/*
+  - Copyright 2022 Sven Loesekann
+    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.
+*/
+/// <reference lib="webworker" />
+/* eslint-disable-next-line no-restricted-globals */
+declare var self: DedicatedWorkerGlobalScope;
+export { };
+
+interface MsgData {
+  jwtToken: string;
+  newNotificationUrl: string;
+}
+
+interface UserResponse {
+  Token?: string
+  Message?: string
+}
+
+let jwtToken = '';
+let tokenIntervalRef: ReturnType<typeof setInterval>;
+const refreshToken = (myToken: string) => {
+  if (!!tokenIntervalRef) {
+    clearInterval(tokenIntervalRef);
+  }
+  jwtToken = myToken;
+  if (!!jwtToken && jwtToken.length > 10) {
+    tokenIntervalRef = setInterval(() => {
+      const requestOptions = {
+        method: 'GET',
+        headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${jwtToken}` },
+      };
+      fetch('/appuser/refreshtoken', requestOptions).then(response => response.json() as UserResponse).then(result => {
+        if ((!result.Message && !!result.Token && result.Token.length > 10)) {
+          //console.log('Token refreshed.');
+          jwtToken = result.Token;
+          /* eslint-disable-next-line no-restricted-globals */
+          self.postMessage(result);
+        } else {
+          jwtToken = '';
+          clearInterval(tokenIntervalRef);
+        }
+      });
+    }, 45000);
+  }
+}
+
+let firstNotRequest = true;
+let notificationIntervalRef: ReturnType<typeof setInterval>;
+/* eslint-disable-next-line no-restricted-globals */
+self.addEventListener('message', (event: MessageEvent) => {
+  const msgData = event.data as MsgData;
+  refreshToken(msgData.jwtToken);  
+  if (!!notificationIntervalRef) {
+    clearInterval(notificationIntervalRef);
+  }
+  notificationIntervalRef = setInterval(() => {
+    if (!jwtToken) {
+      clearInterval(notificationIntervalRef);
+      firstNotRequest = true;
+    }
+    const requestOptions = {
+      method: 'GET',
+      headers: { 'Content-Type': 'application/json', 'Authorization': `Bearer ${jwtToken}` },
+    };
+    /* eslint-disable-next-line no-restricted-globals */
+    self.fetch(msgData.newNotificationUrl, requestOptions).then(result => result.json()).then(resultJson => {
+      if (!!resultJson && resultJson?.length > 0) {
+        /* eslint-disable-next-line no-restricted-globals */
+        self.postMessage(resultJson);
+        //Notification
+        //console.log(Notification.permission);
+        if (Notification.permission === 'granted' && !firstNotRequest) { 
+          if(resultJson?.length > 0 && resultJson[0]?.Message?.length > 1 && resultJson[0]?.Title?.length > 1) {            
+            for(let value of resultJson) {
+            new Notification(value?.Title, {body: value?.Message});
+            }
+          }                
+        } else if(!!firstNotRequest) {
+          firstNotRequest = false;
+        }
+      }
+    });
+  }, 60000);
+});