feat: YDBOPS-11509 monium_cluster

Author: astandrik

package-lock.json

@@ -40,6 +40,7 @@
     "history": "^4.10.1",
     "hotkeys-js": "^3.13.9",
     "lodash": "^4.17.21",
+    "lz-string": "^1.5.0",
     "monaco-editor": "^0.52.2",
     "numeral": "^2.0.6",
     "path-to-regexp": "^3.3.0",

package.json

@@ -33,6 +33,22 @@ describe('getLogsLink', () => {
         );
     });
 
+    test('should generate monitoring URL when monium_cluster is present', () => {
+        const loggingData = {
+            url: 'https://logging.url/projects/some_project/logs',
+            monium_cluster: 'ydb-ru-prestable',
+        };
+
+        const result = getLogsLink({
+            logging: JSON.stringify(loggingData),
+            dbName: 'testdb',
+        });
+
+        expect(result).toBe(
+            'https://logging.url/projects/kikimr/logs?query=%7Bproject+%3D+%22kikimr%22%2C+service+%3D+%22ydb%22%2C+cluster+%3D+%22ydb-ru-prestable%22%2C+database+%3D+%22testdb%22%7D&from=now-1d&to=now&columns=level%2Ctime%2Cmessage%2Chost&groupByField=level&chartType=line&linesMode=single',
+        );
+    });
+
     test('should return empty string for invalid data', () => {
         expect(
             getLogsLink({

src/utils/__test__/logs.test.ts

@@ -1,34 +1,78 @@
+const DEFAULT_PROJECT = 'kikimr';
+const DEFAULT_SERVICE = 'ydb';
+const DEFAULT_TIME_RANGE = {
+    from: 'now-1d',
+    to: 'now',
+};
+const DEFAULT_COLUMNS = 'level,time,message,host';
+const DEFAULT_GROUP_BY = 'level';
+const DEFAULT_CHART_TYPE = 'line';
+const DEFAULT_LINES_MODE = 'single';
+
 interface GetLogsLinkProps {
     dbName: string;
     logging: string;
 }
 
 export type GetLogsLink = (props: GetLogsLinkProps) => string;
 
+interface ParsedLogging {
+    url: string;
+    monium_cluster?: string;
+}
+
+function getBaseUrl(urlString: string): string {
+    const url = new URL(urlString);
+    return `${url.protocol}//${url.hostname}`;
+}
+
 export function getLogsLink({dbName, logging}: GetLogsLinkProps): string {
     try {
-        const data = JSON.parse(logging);
+        const data = JSON.parse(logging) as ParsedLogging;
 
-        if (typeof data === 'object' && 'url' in data) {
-            const logUrl = data.url;
-            if (!logUrl) {
-                return '';
-            }
+        if (typeof data === 'object') {
+            if ('url' in data) {
+                const logUrl = data.url;
+                if (!logUrl) {
+                    return '';
+                }
 
-            const url = new URL(logUrl);
+                if (data.monium_cluster) {
+                    const baseUrl = getBaseUrl(logUrl);
+                    const url = new URL(`${baseUrl}/projects/${DEFAULT_PROJECT}/logs`);
 
-            const queryParam = url.searchParams.get('query');
-            if (queryParam) {
-                const decodedQuery = decodeURIComponent(queryParam);
+                    const query = `{project = "${DEFAULT_PROJECT}", service = "${DEFAULT_SERVICE}", cluster = "${data.monium_cluster}", database = "${dbName}"}`;
 
-                const queryBetweenBraces = decodedQuery.slice(1, -1);
-                const witComma = queryBetweenBraces.length > 0;
-                const updatedQuery = `{${queryBetweenBraces}${witComma ? ', ' : ''}database = "${dbName}"}`;
+                    url.searchParams.set('query', query);
+                    url.searchParams.set('from', DEFAULT_TIME_RANGE.from);
+                    url.searchParams.set('to', DEFAULT_TIME_RANGE.to);
+                    url.searchParams.set('columns', DEFAULT_COLUMNS);
+                    url.searchParams.set('groupByField', DEFAULT_GROUP_BY);
+                    url.searchParams.set('chartType', DEFAULT_CHART_TYPE);
+                    url.searchParams.set('linesMode', DEFAULT_LINES_MODE);
 
-                url.searchParams.set('query', updatedQuery);
-            }
+                    // debug-only
+                    console.log('Monium_cluster branch');
+                    return url.toString();
+                }
+
+                const url = new URL(logUrl);
+
+                const queryParam = url.searchParams.get('query');
+                if (queryParam) {
+                    const decodedQuery = decodeURIComponent(queryParam);
 
-            return url.toString();
+                    const queryBetweenBraces = decodedQuery.slice(1, -1);
+                    const witComma = queryBetweenBraces.length > 0;
+                    const updatedQuery = `{${queryBetweenBraces}${witComma ? ', ' : ''}database = "${dbName}"}`;
+
+                    url.searchParams.set('query', updatedQuery);
+                }
+
+                // debug-only
+                console.log('Url parsing branch');
+                return url.toString();
+            }
         }
     } catch {}