Feat/telemetry transport update with beacon

src/WebTelemetryBase.ts

@@ -7,9 +7,10 @@ import {
     WebTelemetryTransport,
     KVDataItem,
 } from './types';
-import { WebTelemetryTransportDebug, WebTelemetryTransportDefault } from './WebTelemetryTransport';
+import { WebTelemetryTransportDefault } from './transport/WebTelemetryTransport';
 import { globalSessionId } from './constants';
 import { stringifyCircularObj } from './helpers';
+import { WebTelemetryTransportDebug } from './transport/WebTelemetryTransportDebug';
 
 /**
  * Базовая имплементация класса для работы с телеметрией

src/presets/WebTelemetryResources.ts

@@ -1,3 +1,4 @@
+import { SALUTE_EYE_URL } from '../transport/WebTelemetryTransport';
 import { WebTelemetryResourcesConfig, WebTelemetryTransport } from '../types';
 import { WebTelemetryBase } from '../WebTelemetryBase';
 
@@ -81,7 +82,12 @@ export class WebTelemetryResources extends WebTelemetryBase<WebTelemetryResource
              * на отправку данных в бекенд. Если этого не сделать, то шедулер будет
              * бесконечно планировать отправку данных после любой отправки данных
              */
-            if (res.name && this.config.endpoint && res.name.includes(this.config.endpoint)) {
+            if (
+                res.name &&
+                (this.config.endpoint || SALUTE_EYE_URL) &&
+                [this.config.endpoint, SALUTE_EYE_URL].some((url) => res.name.includes(url))
+            ) {
+                //
                 // eslint-disable-next-line no-continue
                 continue;
             }

src/transport/WebTelemetryTransport.ts

@@ -0,0 +1,40 @@
+export interface WebTelemetryTransport {
+    send(body: string): void;
+}
+
+export const SALUTE_EYE_URL = 'https://cbdv.sberdevices.ru/amplitude/telemetry/';
+const SALUTE_EYE_API_KEY = '68bfaed5a9b7c036c54cb6a217df1b84';
+
+function getLastPartAfterSlash(url: string): string {
+    const parts = url.split('/');
+    return parts[parts.length - 1];
+}
+
+export class WebTelemetryTransportDefault implements WebTelemetryTransport {
+    private url: string;
+
+    constructor(url: string) {
+        this.url = url;
+    }
+
+    send(body: string) {
+        const headers = {
+            'Content-Type': 'application/json',
+            'X-API-KEY': SALUTE_EYE_API_KEY,
+        };
+
+        if (navigator.sendBeacon) {
+            navigator.sendBeacon(this.url, body);
+            const blob = new Blob([body], { type: headers['Content-Type'] });
+
+            navigator.sendBeacon(SALUTE_EYE_URL + getLastPartAfterSlash(this.url), blob);
+        } else {
+            fetch(this.url, { body, method: 'POST' });
+            fetch(SALUTE_EYE_URL + getLastPartAfterSlash(this.url), {
+                method: 'POST',
+                headers: headers,
+                body: body,
+            });
+        }
+    }
+}

src/transport/WebTelemetryTransportDebug.ts

@@ -0,0 +1,13 @@
+import { WebTelemetryTransport } from '../types';
+
+export class WebTelemetryTransportDebug implements WebTelemetryTransport {
+    send(body: string) {
+        try {
+            // eslint-disable-next-line no-console
+            console.debug('WebTelemetry sent:\n', JSON.parse(body));
+        } catch {
+            // eslint-disable-next-line no-console
+            console.debug(`WebTelemetry sent:\n${body}`);
+        }
+    }
+}