Migrate wazuh.yml configuration to opensearch_dashboards.yml

docker/osd-dev/config/2.x/osd/opensearch_dashboards.yml

@@ -6,17 +6,23 @@ opensearch.ssl.verificationMode: certificate
 # opensearch.requestHeadersWhitelist: ["securitytenant","Authorization"]
 #
 # osd 2.0
-opensearch.requestHeadersAllowlist: ["securitytenant", "Authorization"]
+opensearch.requestHeadersAllowlist: ['securitytenant', 'Authorization']
 #
 opensearch_security.multitenancy.enabled: false
-opensearch_security.readonly_mode.roles: ["kibana_read_only"]
+opensearch_security.readonly_mode.roles: ['kibana_read_only']
 server.ssl.enabled: true
-server.ssl.key: "/home/node/kbn/certs/osd.key"
-server.ssl.certificate: "/home/node/kbn/certs/osd.pem"
-opensearch.ssl.certificateAuthorities: ["/home/node/kbn/certs/ca.pem"]
+server.ssl.key: '/home/node/kbn/certs/osd.key'
+server.ssl.certificate: '/home/node/kbn/certs/osd.pem'
+opensearch.ssl.certificateAuthorities: ['/home/node/kbn/certs/ca.pem']
 uiSettings.overrides.defaultRoute: /app/wz-home
-opensearch.username: "kibanaserver"
-opensearch.password: "kibanaserver"
+opensearch.username: 'kibanaserver'
+opensearch.password: 'kibanaserver'
 opensearchDashboards.branding:
   useExpandedHeader: false
-
+wazuh_core.hosts:
+  manager:
+    url: 'https://wazuh.manager'
+    port: 55000
+    username: wazuh-wui
+    password: MyS3cr37P450r.*-
+    run_as: false

plugins/main/public/plugin.ts

@@ -5,6 +5,9 @@ import {
   Plugin,
   PluginInitializerContext,
 } from 'opensearch_dashboards/public';
+import { Cookies } from 'react-cookie';
+import { euiPaletteColorBlind } from '@elastic/eui';
+import { createHashHistory } from 'history';
 import {
   setDataPlugin,
   setHttp,
@@ -27,61 +30,49 @@ import {
   setWazuhEnginePlugin,
   setWazuhFleetPlugin,
 } from './kibana-services';
-import { validate as validateNodeCronInterval } from 'node-cron';
 import {
   AppPluginStartDependencies,
   WazuhSetup,
   WazuhSetupPlugins,
   WazuhStart,
   WazuhStartPlugins,
 } from './types';
-import { Cookies } from 'react-cookie';
 import { AppState } from './react-services/app-state';
 import { setErrorOrchestrator } from './react-services/common-services';
 import { ErrorOrchestratorService } from './react-services/error-orchestrator/error-orchestrator.service';
-import store from './redux/store';
-import { updateAppConfig } from './redux/actions/appConfigActions';
 import {
   initializeInterceptor,
   unregisterInterceptor,
 } from './services/request-handler';
 import { Applications, Categories } from './utils/applications';
-import { euiPaletteColorBlind } from '@elastic/eui';
 import NavigationService from './react-services/navigation-service';
-import { createHashHistory } from 'history';
-import { reportingDefinitions } from './react-services/reporting/reporting-definitions';
 
 export class WazuhPlugin
   implements
     Plugin<WazuhSetup, WazuhStart, WazuhSetupPlugins, WazuhStartPlugins>
 {
   constructor(private readonly initializerContext: PluginInitializerContext) {}
+
   private hideTelemetryBanner?: () => void;
+
   public async setup(
     core: CoreSetup,
     plugins: WazuhSetupPlugins,
   ): Promise<WazuhSetup> {
     // Get custom logos configuration to start up the app with the correct logos
-    let logosInitialState = {};
-    try {
-      logosInitialState = await core.http.get(`/api/logos`);
-    } catch (error) {
-      console.error('plugin.ts: Error getting logos configuration', error);
-    }
 
     // Redefine the mapKeys method to change the properties sent to euiPaletteColorBlind.
     // This is a workaround until the issue reported in Opensearch Dashboards is fixed.
     // https://github.com/opensearch-project/OpenSearch-Dashboards/issues/5422
     // This should be reomved when the issue is fixed. Probably in OSD 2.12.0
     plugins.charts.colors.mappedColors.mapKeys = function (
-      keys: Array<string | number>,
+      keys: (string | number)[],
     ) {
       const configMapping = this.getConfigColorMapping();
       const configColors = _.values(configMapping);
-      const oldColors = _.values(this._oldMap);
-
       let alreadyUsedColors: string[] = [];
-      const keysToMap: Array<string | number> = [];
+      const keysToMap: (string | number)[] = [];
+
       _.each(keys, key => {
         // If this key is mapped in the config, it's unnecessary to have it mapped here
         if (configMapping[key as any]) {
@@ -90,7 +81,7 @@ export class WazuhPlugin
         }
 
         // If this key is mapped to a color used by the config color mapping, we need to remap it
-        if (_.includes(configColors, this._mapping[key])) keysToMap.push(key);
+        if (_.includes(configColors, this._mapping[key])) {keysToMap.push(key);}
 
         // if key exist in oldMap, move it to mapping
         if (this._oldMap[key]) {
@@ -99,13 +90,14 @@ export class WazuhPlugin
         }
 
         // If this key isn't mapped, we need to map it
-        if (this.get(key) == null) keysToMap.push(key);
+        if (this.get(key) === null) {keysToMap.push(key);}
       });
 
       alreadyUsedColors.push(...Object.values(this._mapping));
       alreadyUsedColors = alreadyUsedColors.map(color =>
         color.toLocaleLowerCase(),
       );
+
       // Choose colors from euiPaletteColorBlind and filter out any already assigned to keys
       const colorPalette = euiPaletteColorBlind({
         rotations: Math.ceil(
@@ -120,57 +112,46 @@ export class WazuhPlugin
     };
 
     // Register the applications
-    Applications.forEach(app => {
+    for (const app of Applications) {
       const { category, id, title, redirectTo, order } = app;
+
       core.application.register({
         id,
         title,
         order,
         mount: async (params: AppMountParameters) => {
           try {
-            /* Workaround: Redefine the validation functions of cron.statistics.interval setting.
-            There is an optimization error of the frontend side source code due to some modules can
-            not be loaded
-            */
-            const setting = plugins.wazuhCore.configuration._settings.get(
-              'cron.statistics.interval',
-            );
-            !setting.validateUIForm &&
-              (setting.validateUIForm = function (value) {
-                return this.validate(value);
-              });
-            !setting.validate &&
-              (setting.validate = function (value: string) {
-                return validateNodeCronInterval(value)
-                  ? undefined
-                  : 'Interval is not valid.';
-              });
             setWzCurrentAppID(id);
             // Set the dynamic redirection
             setWzMainParams(redirectTo());
             initializeInterceptor(core);
 
-            // Update redux app state logos with the custom logos
-            if (logosInitialState?.logos) {
-              store.dispatch(updateAppConfig(logosInitialState.logos));
-            }
             // hide the telemetry banner.
             // Set the flag in the telemetry saved object as the notice was seen and dismissed
-            this.hideTelemetryBanner && (await this.hideTelemetryBanner());
+            if (this.hideTelemetryBanner) {
+              await this.hideTelemetryBanner();
+            }
+
             setScopedHistory(params.history);
             // This allows you to add the selectors to the navbar
             setHeaderActionMenuMounter(params.setHeaderActionMenu);
             NavigationService.getInstance(createHashHistory());
+
             // Load application bundle
             const { renderApp } = await import('./application');
+
             setErrorOrchestrator(ErrorOrchestratorService);
             setHttp(core.http);
             setCookies(new Cookies());
+
             if (!AppState.checkCookies()) {
               NavigationService.getInstance().reload();
             }
+
             params.element.classList.add('dscAppWrapper', 'wz-app');
+
             const unmount = await renderApp(params);
+
             return () => {
               unmount();
               unregisterInterceptor();
@@ -183,9 +164,11 @@ export class WazuhPlugin
           ({ id: categoryID }) => categoryID === category,
         ),
       });
-    });
+    }
+
     return {};
   }
+
   public start(
     core: CoreStart,
     plugins: AppPluginStartDependencies,
@@ -194,11 +177,13 @@ export class WazuhPlugin
     if (plugins.securityOss) {
       plugins.securityOss.insecureCluster.hideAlert(true);
     }
+
     if (plugins?.telemetry?.telemetryNotifications?.setOptedInNoticeSeen) {
       // assign to a method to hide the telemetry banner used when the app is mounted
       this.hideTelemetryBanner = () =>
         plugins.telemetry.telemetryNotifications.setOptedInNoticeSeen();
     }
+
     setCore(core);
     setPlugins(plugins);
     setHttp(core.http);
@@ -215,6 +200,7 @@ export class WazuhPlugin
     setWazuhCorePlugin(plugins.wazuhCore);
     setWazuhEnginePlugin(plugins.wazuhEngine);
     setWazuhFleetPlugin(plugins.wazuhFleet);
+
     return {};
   }
 }

plugins/main/server/plugin.ts

@@ -26,17 +26,17 @@
   SharedGlobalConfig,
 } from 'opensearch_dashboards/server';
 
 import { WazuhPluginSetup, WazuhPluginStart, PluginSetup } from './types';
 import { setupRoutes } from './routes';
 import {
   jobInitializeRun,
   jobMonitoringRun,
   jobSchedulerRun,
   jobQueueRun,
   jobMigrationTasksRun,
   jobSanitizeUploadedFilesTasksRun,
 } from './start';
 import { first } from 'rxjs/operators';
 
 declare module 'opensearch_dashboards/server' {
   interface RequestHandlerContext {
@@ -82,7 +82,7 @@
 
     const serverInfo = core.http.getServerInfo();
 
     core.http.registerRouteHandlerContext('wazuh', (context, request) => {
       return {
         // Create a custom logger with a tag composed of HTTP method and path endpoint
         logger: this.logger.get(
@@ -102,12 +102,12 @@
       const additionalHeaders = {
         'x-frame-options': 'sameorigin',
       };
       return toolkit.next({ headers: additionalHeaders });
     });
 
     // Routes
     const router = core.http.createRouter();
     setupRoutes(router, plugins.wazuhCore);
 
     return {};
   }
@@ -118,7 +118,7 @@
         .pipe(first())
         .toPromise();
 
     const contextServer = {
       config: globalConfiguration,
     };
 
@@ -134,6 +134,8 @@
     });
 
     // Sanitize uploaded files tasks
+    // error: [error][plugins][sanitize-uploaded-files-task][wazuh] sanitize:sanitizeUploadedSVG: Error: Configuration undefined not found
+    /*
     jobSanitizeUploadedFilesTasksRun({
       core,
       wazuh: {
@@ -143,6 +145,7 @@
       wazuh_core: plugins.wazuhCore,
       server: contextServer,
     });
+    */
 
     // Migration tasks
     jobMigrationTasksRun({
@@ -155,7 +158,7 @@
       server: contextServer,
     });
 
-    // Monitoring
+    /* Monitoring
     jobMonitoringRun({
       core,
       wazuh: {
@@ -165,8 +168,9 @@
       wazuh_core: plugins.wazuhCore,
       server: contextServer,
     });
+    */
 
-    // Scheduler
+    /* Scheduler
     jobSchedulerRun({
       core,
       wazuh: {
@@ -176,6 +180,7 @@
       wazuh_core: plugins.wazuhCore,
       server: contextServer,
     });
+    */
 
     // Queue
     jobQueueRun({
@@ -187,7 +192,7 @@
       wazuh_core: plugins.wazuhCore,
       server: contextServer,
     });
     return {};
   }
 
   public stop() {}

plugins/main/server/routes/wazuh-api.ts

@@ -128,7 +128,8 @@ export function WazuhApiRoutes(router: IRouter) {
       ctrl.getSyscollector(context, request, response),
   );
 
-  // Return app logos configuration
+  /* Return app logos configuration
+  ToDo: Change (maybe) to get the opensearch logo settings
   router.get(
     {
       path: '/api/logos',
@@ -138,6 +139,7 @@ export function WazuhApiRoutes(router: IRouter) {
     async (context, request, response) =>
       ctrl.getAppLogos(context, request, response),
   );
+  */
 
   // Return binary dashboard
   router.get(

plugins/main/server/start/monitoring/index.ts

@@ -34,7 +34,7 @@ let MONITORING_ENABLED,
 async function initMonitoringConfiguration(context) {
   try {
     context.wazuh.logger.debug('Reading configuration');
-    const appConfig = await context.wazuh_core.configuration.get();
+    const appConfig = await context.wazuh_core.configuration.getAll();
     MONITORING_ENABLED =
       (appConfig['wazuh.monitoring.enabled'] &&
         appConfig['wazuh.monitoring.enabled'] !== 'worker') ||
@@ -90,6 +90,7 @@ async function initMonitoringConfiguration(context) {
  */
 async function init(context) {
   try {
+    const config = await context.wazuh_core.configuration.getAll();
     if (MONITORING_ENABLED) {
       await checkTemplate(context);
     }
@@ -519,7 +520,7 @@ async function fetchAllAgentsFromApiHost(context, apiHost) {
 export async function jobMonitoringRun(context) {
   context.wazuh.logger.debug('Task:Monitoring initializing');
   // Init the monitoring variables
-  await initMonitoringConfiguration(context);
+  //await initMonitoringConfiguration(context);
   // Check Kibana index and if it is prepared, start the initialization of Wazuh App.
   await checkPluginPlatformStatus(context);
   // // Run the cron job only it it's enabled