Add frontend state service

plugins/main/public/components/health-check/container/health-check.container.test.tsx

@@ -68,9 +68,7 @@ jest.mock('../components/check-result', () => ({
 }));
 
 jest.mock('../../../react-services', () => ({
-  AppState: {
-    setPatternSelector: () => {},
-  },
+  AppState: {},
   ErrorHandler: {
     handle: error => error,
   },

plugins/main/public/components/health-check/container/health-check.container.tsx

@@ -131,7 +131,6 @@ function HealthCheckComponent() {
   useEffect(() => {
     if (appConfig.isReady && !checksInitiated.current) {
       checksInitiated.current = true;
-      AppState.setPatternSelector(appConfig.data['ip.selector']);
     }
   }, [appConfig]);
 

plugins/main/public/components/settings/settings.tsx

@@ -299,8 +299,6 @@ class SettingsComponent extends React.Component {
       };
 
       this.setState({ load: false });
-      // TODO: this seems not to be used to display or not the index pattern selector
-      AppState.setPatternSelector(this.props.configurationIPSelector);
       const pattern = AppState.getCurrentPattern();
 
       this.getCurrentAPIIndex();

plugins/main/public/react-services/app-state.js

@@ -79,59 +79,6 @@ export class AppState {
     }
   }
 
-  /**
-   * Set a new value to the 'createdAt' cookie
-   * @param {*} date
-   */
-  static setCreatedAt(date) {
-    try {
-      const createdAt = encodeURI(date);
-      const exp = new Date();
-      exp.setDate(exp.getDate() + 365);
-      getCookies().set('createdAt', createdAt, {
-        expires: exp,
-      });
-    } catch (error) {
-      const options = {
-        context: `${AppState.name}.setCreatedAt`,
-        level: UI_LOGGER_LEVELS.ERROR,
-        severity: UI_ERROR_SEVERITIES.UI,
-        error: {
-          error: error,
-          message: error.message || error,
-          title: `${error.name}: Error set createdAt date`,
-        },
-      };
-      getErrorOrchestrator().handleError(options);
-      throw error;
-    }
-  }
-
-  /**
-   * Get 'createdAt' value
-   */
-  static getCreatedAt() {
-    try {
-      const createdAt = getCookies().get('createdAt')
-        ? decodeURI(getCookies().get('createdAt'))
-        : false;
-      return createdAt ? createdAt : false;
-    } catch (error) {
-      const options = {
-        context: `${AppState.name}.getCreatedAt`,
-        level: UI_LOGGER_LEVELS.ERROR,
-        severity: UI_ERROR_SEVERITIES.UI,
-        error: {
-          error: error,
-          message: error.message || error,
-          title: `${error.name}: Error get createdAt date`,
-        },
-      };
-      getErrorOrchestrator().handleError(options);
-      throw error;
-    }
-  }
-
   /**
    * Get 'API' value
    */
@@ -190,33 +137,6 @@ export class AppState {
     }
   }
 
-  /**
-   * Get 'APISelector' value
-   */
-  static getAPISelector() {
-    return getCookies().get('APISelector')
-      ? decodeURI(getCookies().get('APISelector')) == 'true'
-      : false;
-  }
-
-  /**
-   * Get 'patternSelector' value
-   */
-  static getPatternSelector() {
-    return getCookies().get('patternSelector')
-      ? decodeURI(getCookies().get('patternSelector')) == 'true'
-      : false;
-  }
-
-  /**
-   * Set a new value to the 'patternSelector' cookie
-   * @param {*} value
-   */
-  static setPatternSelector(value) {
-    const encodedPattern = encodeURI(value);
-    getCookies().set('patternSelector', encodedPattern, {});
-  }
-
   /**
    * Set a new value to the 'currentPattern' cookie
    * @param {*} newPattern

plugins/main/public/react-services/wz-api-check.js

@@ -30,16 +30,15 @@ export class ApiCheck {
       const url = getHttp().basePath.prepend('/api/check-stored-api');
       const options = {
         method: 'POST',
-        headers: { ...PLUGIN_PLATFORM_REQUEST_HEADERS, 'content-type': 'application/json' },
+        headers: {
+          ...PLUGIN_PLATFORM_REQUEST_HEADERS,
+          'content-type': 'application/json',
+        },
         url: url,
         data: payload,
-        timeout: timeout || 20000
+        timeout: timeout || 20000,
       };
 
-      if (Object.keys(configuration).length) {
-        AppState.setPatternSelector(configuration['ip.selector']);
-      }
-
       const response = await request(options);
 
       if (response.error) {
@@ -55,8 +54,10 @@ export class ApiCheck {
         return Promise.reject(this.returnErrorInstance(response));
       } else {
         return (err || {}).message || false
-          ? Promise.reject(this.returnErrorInstance(err,err.message))
-          : Promise.reject(this.returnErrorInstance(err,err || 'Server did not respond'));
+          ? Promise.reject(this.returnErrorInstance(err, err.message))
+          : Promise.reject(
+              this.returnErrorInstance(err, err || 'Server did not respond'),
+            );
       }
     }
   }
@@ -65,18 +66,21 @@ export class ApiCheck {
    * Check the status of an API entry
    * @param {String} apiObject
    */
-  static async checkApi(apiEntry, forceRefresh=false) {
+  static async checkApi(apiEntry, forceRefresh = false) {
     try {
       const wazuhConfig = new WazuhConfig();
       const { timeout } = wazuhConfig.getConfig();
       const url = getHttp().basePath.prepend('/api/check-api');
 
       const options = {
         method: 'POST',
-        headers: { ...PLUGIN_PLATFORM_REQUEST_HEADERS, 'content-type': 'application/json' },
+        headers: {
+          ...PLUGIN_PLATFORM_REQUEST_HEADERS,
+          'content-type': 'application/json',
+        },
         url: url,
-        data: {...apiEntry, forceRefresh},
-        timeout: timeout || 20000
+        data: { ...apiEntry, forceRefresh },
+        timeout: timeout || 20000,
       };
 
       const response = await request(options);
@@ -92,23 +96,25 @@ export class ApiCheck {
         return Promise.reject(this.returnErrorInstance(response));
       } else {
         return (err || {}).message || false
-          ? Promise.reject(this.returnErrorInstance(err,err.message))
-          : Promise.reject(this.returnErrorInstance(err,err || 'Server did not respond'));
+          ? Promise.reject(this.returnErrorInstance(err, err.message))
+          : Promise.reject(
+              this.returnErrorInstance(err, err || 'Server did not respond'),
+            );
       }
     }
   }
 
-    /**
+  /**
    * Customize message and return an error object
-   * @param error 
-   * @param message 
+   * @param error
+   * @param message
    * @returns error
    */
-    static returnErrorInstance(error, message){
-      if(!error || typeof error === 'string'){
-        return new Error(message || error);
-      }
-      error.message = message
-      return error
+  static returnErrorInstance(error, message) {
+    if (!error || typeof error === 'string') {
+      return new Error(message || error);
     }
+    error.message = message;
+    return error;
+  }
 }

plugins/wazuh-core/package.json

@@ -24,7 +24,8 @@
     "json2csv": "^4.1.2",
     "jwt-decode": "^3.1.2",
     "md5": "^2.3.0",
-    "node-cron": "^3.0.2"
+    "node-cron": "^3.0.2",
+    "react-cookie": "^7.2.2"
   },
   "devDependencies": {
     "@testing-library/user-event": "^14.5.0",

plugins/wazuh-core/public/plugin.ts

@@ -11,12 +11,24 @@ import {
 } from '../common/constants';
 import { DashboardSecurity } from './utils/dashboard-security';
 import * as hooks from './hooks';
+import { CoreState, State } from './services/state';
+import { ServerHostClusterInfoStateContainer } from './services/state/containers/server-host-cluster-info';
+import { Cookies } from 'react-cookie';
+import { ServerHostStateContainer } from './services/state/containers/server-host';
+import { DataSourceAlertsStateContainer } from './services/state/containers/data-source-alerts';
 
 export class WazuhCorePlugin
   implements Plugin<WazuhCorePluginSetup, WazuhCorePluginStart>
 {
+  runtime: { [key: string]: any } = {
+    state: {},
+  };
   _internal: { [key: string]: any } = {};
-  services: { [key: string]: any } = {};
+  services: {
+    [key: string]: any;
+    dashboardSecurity?: DashboardSecurity;
+    state?: State;
+  } = {};
   public async setup(core: CoreSetup): Promise<WazuhCorePluginSetup> {
     const noop = () => {};
     const logger = {
@@ -46,12 +58,35 @@ export class WazuhCorePlugin
 
     this.services.dashboardSecurity = new DashboardSecurity(logger, core.http);
 
+    this.services.state = new CoreState(logger);
+
+    this.runtime.state.setup = this.services.state.setup();
+    const cookiesStore = new Cookies();
+    this.services.state.register(
+      'server_host_cluster_info',
+      new ServerHostClusterInfoStateContainer(logger, { store: cookiesStore }),
+    );
+    this.services.state.register(
+      'server_host',
+      new ServerHostStateContainer(logger, { store: cookiesStore }),
+    );
+    this.services.state.subscribe('server_host', value => {
+      // TODO: refresh the auth when the server_host data changed and there is value
+    });
+    this.services.state.register(
+      'data_source_alerts',
+      new DataSourceAlertsStateContainer(logger, { store: cookiesStore }),
+    );
+
     await this.services.dashboardSecurity.setup();
 
     return {
       ...this.services,
       utils,
       API_USER_STATUS_RUN_AS,
+      hooks: {
+        ...this.runtime.state.setup.hooks,
+      },
     };
   }
 
@@ -61,14 +96,21 @@ export class WazuhCorePlugin
     setUiSettings(core.uiSettings);
 
     await this.services.configuration.start({ http: core.http });
+    this.services.state.start();
 
     return {
       ...this.services,
       utils,
       API_USER_STATUS_RUN_AS,
-      hooks,
+      // hooks,
+      hooks: {
+        ...hooks,
+        ...this.runtime.state.setup.hooks,
+      },
     };
   }
 
-  public stop() {}
+  public stop() {
+    this.services.state.stop();
+  }
 }