Fix all yarn lints for server directory

common/constants/notebooks.ts

@@ -4,10 +4,11 @@
  */
 
 export const NOTEBOOKS_API_PREFIX = '/api/observability/notebooks';
-export const NOTEBOOKS_SELECTED_BACKEND = 'DEFAULT'; // ZEPPELIN || DEFAULT
+export const NOTEBOOKS_SELECTED_BACKEND: 'ZEPPELIN' | 'DEFAULT' = 'DEFAULT';
 export const NOTEBOOKS_FETCH_SIZE = 1000;
 export const CREATE_NOTE_MESSAGE = 'Enter a name to describe the purpose of this notebook.';
-export const NOTEBOOKS_DOCUMENTATION_URL = 'https://opensearch.org/docs/latest/observability-plugin/notebooks/';
+export const NOTEBOOKS_DOCUMENTATION_URL =
+  'https://opensearch.org/docs/latest/observability-plugin/notebooks/';
 
 export const zeppelinURL = 'http://localhost:8080';
 

package.json

@@ -58,7 +58,6 @@
     "husky": "6.0.0",
     "jest-dom": "^4.0.0",
     "lint-staged": "^13.1.0",
-    "mock-fs": "^4.12.0",
     "ts-jest": "^29.1.0"
   },
   "resolutions": {
@@ -81,4 +80,4 @@
     "node_modules/*",
     "target/*"
   ]
-}
+}

server/adaptors/custom_panels/custom_panel_adaptor.ts

@@ -8,7 +8,7 @@ import { PanelType, VisualizationType } from '../../../common/types/custom_panel
 import { ILegacyScopedClusterClient } from '../../../../../src/core/server';
 import { createDemoPanel } from '../../../common/constants/custom_panels';
 
-interface boxType {
+interface BoxType {
   x1: number;
   y1: number;
   x2: number;
@@ -142,7 +142,6 @@ export class CustomPanelsAdaptor {
     }
   };
 
-
   // Rename an existing panel
   renamePanel = async (client: ILegacyScopedClusterClient, panelId: string, panelName: string) => {
     const updatePanelBody = {
@@ -275,14 +274,14 @@ export class CustomPanelsAdaptor {
     }
   };
 
-  calculatOverlapArea = (bb1: boxType, bb2: boxType) => {
-    const x_left = Math.max(bb1.x1, bb2.x1);
-    const y_top = Math.max(bb1.y1, bb2.y1);
-    const x_right = Math.min(bb1.x2, bb2.x2);
-    const y_bottom = Math.min(bb1.y2, bb2.y2);
+  calculatOverlapArea = (bb1: BoxType, bb2: BoxType) => {
+    const xLeft = Math.max(bb1.x1, bb2.x1);
+    const yTop = Math.max(bb1.y1, bb2.y1);
+    const xRight = Math.min(bb1.x2, bb2.x2);
+    const yBottom = Math.min(bb1.y2, bb2.y2);
 
-    if (x_right < x_left || y_bottom < y_top) return 0;
-    return (x_right - x_left) * (y_bottom - y_top);
+    if (xRight < xLeft || yBottom < yTop) return 0;
+    return (xRight - xLeft) * (yBottom - yTop);
   };
 
   getTotalOverlapArea = (panelVisualizations: VisualizationType[]) => {
@@ -380,7 +379,7 @@ export class CustomPanelsAdaptor {
     savedVisualizationIds: string[]
   ) => {
     try {
-      let allPanelVisualizations = await this.getVisualizations(client, panelId);
+      const allPanelVisualizations = await this.getVisualizations(client, panelId);
 
       let newDimensions;
       let visualizationsList = [...allPanelVisualizations];

server/adaptors/notebooks/default_backend.ts

@@ -77,7 +77,7 @@ export class DefaultBackend implements NotebookAdaptor {
         objectId: noteId,
       });
       if (response.observabilityObjectList.length === 0) {
-        throw 'notebook id not found';
+        throw new Error('notebook id not found');
       }
       return response.observabilityObjectList[0];
     } catch (error) {
@@ -262,7 +262,7 @@ export class DefaultBackend implements NotebookAdaptor {
     _wreckOptions: optionsType
   ) {
     try {
-      let newNoteObject = { ...noteObj };
+      const newNoteObject = { ...noteObj };
       newNoteObject.id = 'note_' + uuid();
       newNoteObject.dateCreated = new Date().toISOString();
       newNoteObject.dateModified = new Date().toISOString();
@@ -283,7 +283,7 @@ export class DefaultBackend implements NotebookAdaptor {
    *         paragraphInput -> Input to be added
    */
   updateParagraph = function (
-    paragraphs: Array<DefaultParagraph>,
+    paragraphs: DefaultParagraph[],
     paragraphId: string,
     paragraphInput: string,
     paragraphType?: string
@@ -324,7 +324,7 @@ export class DefaultBackend implements NotebookAdaptor {
         inputType: paragraphType,
         inputText: paragraphInput,
       };
-      const outputObjects: Array<DefaultOutput> = [
+      const outputObjects: DefaultOutput[] = [
         {
           outputType: paragraphType,
           result: '',
@@ -350,7 +350,7 @@ export class DefaultBackend implements NotebookAdaptor {
    * UI renders Markdown
    */
   runParagraph = async function (
-    paragraphs: Array<DefaultParagraph>,
+    paragraphs: DefaultParagraph[],
     paragraphId: string,
     client: ILegacyScopedClusterClient
   ) {
@@ -526,7 +526,7 @@ export class DefaultBackend implements NotebookAdaptor {
       const newParagraph = this.createParagraph(params.paragraphInput, params.inputType);
       paragraphs.splice(params.paragraphIndex, 0, newParagraph);
       const updateNotebook = {
-        paragraphs: paragraphs,
+        paragraphs,
         dateModified: new Date().toISOString(),
       };
       const opensearchClientResponse = await this.updateNote(client, params.noteId, updateNotebook);
@@ -586,10 +586,10 @@ export class DefaultBackend implements NotebookAdaptor {
   ) {
     try {
       const opensearchClientGetResponse = await this.getNote(client, params.noteId);
-      let updatedparagraphs: DefaultParagraph[] = [];
+      const updatedparagraphs: DefaultParagraph[] = [];
       opensearchClientGetResponse.notebook.paragraphs.map(
         (paragraph: DefaultParagraph, index: number) => {
-          let updatedParagraph = { ...paragraph };
+          const updatedParagraph = { ...paragraph };
           updatedParagraph.output = [];
           updatedparagraphs.push(updatedParagraph);
         }

server/adaptors/notebooks/index.ts

@@ -8,10 +8,8 @@ import { DefaultBackend } from './default_backend';
 import { NOTEBOOKS_SELECTED_BACKEND } from '../../../common/constants/notebooks';
 
 // Selects backend based on config
-let BACKEND = new DefaultBackend();
+export let BACKEND: DefaultBackend | ZeppelinBackend = new DefaultBackend();
 
-if (NOTEBOOKS_SELECTED_BACKEND == 'ZEPPELIN') {
+if (NOTEBOOKS_SELECTED_BACKEND === 'ZEPPELIN') {
   BACKEND = new ZeppelinBackend();
 }
-
-export default BACKEND;

server/adaptors/ppl_datasource.ts

@@ -4,19 +4,12 @@
  */
 
 import _ from 'lodash';
-import {
-  IPPLEventsDataSource,
-  IPPLVisualizationDataSource
-} from '../common/types';
+import { IPPLEventsDataSource, IPPLVisualizationDataSource } from '../common/types';
 
 type PPLResponse = IPPLEventsDataSource & IPPLVisualizationDataSource;
 
 export class PPLDataSource {
-
-  constructor(
-    private pplDataSource: PPLResponse,
-    private dataType: string
-  ) {
+  constructor(private pplDataSource: PPLResponse, private dataType: string) {
     if (this.dataType === 'jdbc') {
       this.addSchemaRowMapping();
     } else if (this.dataType === 'viz') {
@@ -42,9 +35,9 @@ export class PPLDataSource {
      *  agent: "chrome",
      *  avg(bytes): 5648
      *  ...
-     * }] 
+     * }]
      */
-    let res = [];
+    const res = [];
     if (visData?.metadata?.fields) {
       const queriedFields = visData.metadata.fields;
       for (let i = 0; i < visData.size; i++) {
@@ -55,29 +48,27 @@ export class PPLDataSource {
         });
         res.push(entry);
       }
-      visData['jsonData'] = res;
+      visData.jsonData = res;
     }
-  }
+  };
 
   /**
    * Add 'schemaName: data' entries for UI rendering
    */
   private addSchemaRowMapping = () => {
-
     const pplRes = this.pplDataSource;
-    
+
     const data: any[] = [];
 
     _.forEach(pplRes.datarows, (row) => {
       const record: any = {};
-      
+
       for (let i = 0; i < pplRes.schema.length; i++) {
-
         const cur = pplRes.schema[i];
-        
-        if (typeof(row[i]) === 'object') {
+
+        if (typeof row[i] === 'object') {
           record[cur.name] = JSON.stringify(row[i]);
-        } else if (typeof(row[i]) === 'boolean') {
+        } else if (typeof row[i] === 'boolean') {
           record[cur.name] = row[i].toString();
         } else {
           record[cur.name] = row[i];
@@ -86,8 +77,8 @@ export class PPLDataSource {
 
       data.push(record);
     });
-    pplRes['jsonData'] = data;
+    pplRes.jsonData = data;
   };
 
-  public getDataSource = () : PPLResponse => this.pplDataSource;
-}
+  public getDataSource = (): PPLResponse => this.pplDataSource;
+}

server/common/helpers/notebooks/default_notebook_schema.ts

@@ -5,27 +5,27 @@
 
 // Default Backend Notebook Schema
 
-export type DefaultInput = {
+export interface DefaultInput {
   inputType: string;
   inputText: string;
-};
+}
 
-export type DefaultOutput = {
+export interface DefaultOutput {
   outputType: string;
   result: string;
   execution_time: string;
-};
-export type DefaultParagraph = {
+}
+export interface DefaultParagraph {
   id: string;
   dateCreated: string;
   dateModified: string;
   input: DefaultInput;
-  output: Array<DefaultOutput>;
-};
-export type DefaultNotebooks = {
+  output: DefaultOutput[];
+}
+export interface DefaultNotebooks {
   name: string;
   dateCreated: string;
   dateModified: string;
   backend: string;
-  paragraphs: Array<DefaultParagraph>;
-};
+  paragraphs: DefaultParagraph[];
+}

server/common/helpers/notebooks/query_helpers.ts

@@ -3,33 +3,34 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-import QueryService from "../../../services/queryService";
+import { QueryService } from '../../../services/queryService';
 
 export const inputIsQuery = (inputText: string) => {
-  return (inputIsSQL(inputText) || inputIsPPL(inputText));
-}
+  return inputIsSQL(inputText) || inputIsPPL(inputText);
+};
 
 export const inputIsSQL = (inputText: string) => {
   return inputText.substring(0, 4) === '%sql';
-}
+};
 
 export const inputIsPPL = (inputText: string) => {
   return inputText.substring(0, 4) === '%ppl';
-}
+};
 
 export const getQueryOutput = async (inputText: string, queryService: QueryService) => {
   let output = {};
   if (inputIsSQL(inputText)) {
     output = await queryService.describeSQLQuery(inputText);
-  }
-  else if (inputIsPPL(inputText)) {
+  } else if (inputIsPPL(inputText)) {
     output = await queryService.describePPLQuery(inputText);
   }
   return output;
-}
+};
 
 export const formatNotRecognized = (inputText: string) => {
-  return (inputText.substring(0, 4) != '%sql' &&
-          inputText.substring(0, 4) != '%ppl' &&
-          inputText.substring(0, 3) != '%md')
-}
+  return (
+    inputText.substring(0, 4) !== '%sql' &&
+    inputText.substring(0, 4) !== '%ppl' &&
+    inputText.substring(0, 3) !== '%md'
+  );
+};