Bump node.js from v14.20.1 to v18.12.0

Revert "add node fiber to improve performance (opensearch-project#2319)" Revert "[CVE-2022-25758] Use dart-sass instead of node-sass (opensearch-project#2054)" Revert back to use node-sass and bump to 8.0.0 Change lmdb-store to lmdb Bump node.js to 18 and fix errors Issue Resolved: opensearch-project#3601 Signed-off-by: Anan Zhuang <ananzh@amazon.com>
ananzh · Mar 14, 2023 · 93c468c · 93c468c
1 parent 1e127b0
commit 93c468c
Show file tree

Hide file tree

Showing 30 changed files with 452 additions and 132 deletions.
diff --git a/.node-version b/.node-version
@@ -1 +1 @@
-14.21.3
+18.15.0
diff --git a/.nvmrc b/.nvmrc
@@ -1 +1 @@
-14.21.3
+18.15.0
diff --git a/Dockerfile b/Dockerfile
@@ -1,4 +1,4 @@
-ARG NODE_VERSION=14.20.1
+ARG NODE_VERSION=18.15.0
 FROM node:${NODE_VERSION} AS base
 
 ENV HOME '.'

diff --git a/config/node.options b/config/node.options
@@ -4,3 +4,4 @@
 
 ## max size of old space in megabytes
 #--max-old-space-size=4096
+--openssl-legacy-provider
diff --git a/package.json b/package.json
@@ -81,7 +81,7 @@
     "url": "https://github.com/opensearch-project/opensearch-dashboards.git"
   },
   "resolutions": {
-    "**/@types/node": "^14.17.32",
+    "**/@types/node": "18.11.18",
     "**/ansi-regex": "^5.0.1",
     "**/async": "^3.2.3",
     "**/d3-color": "^3.1.0",
@@ -300,7 +300,7 @@
     "@types/mock-fs": "^4.10.0",
     "@types/moment-timezone": "^0.5.12",
     "@types/mustache": "^0.8.31",
-    "@types/node": "^14.17.32",
+    "@types/node": "18.11.18",
     "@types/node-forge": "^1.0.1",
     "@types/normalize-path": "^3.0.0",
     "@types/pegjs": "^0.10.1",
@@ -467,7 +467,7 @@
     "zlib": "^1.0.5"
   },
   "engines": {
-    "node": "^14.20.1",
+    "node": "^18.15.0",
     "yarn": "^1.22.10"
   }
 }
diff --git a/packages/osd-config/src/env.ts b/packages/osd-config/src/env.ts
@@ -134,7 +134,7 @@ export class Env {
       resolve(this.homeDir, 'src', 'plugins'),
       resolve(this.homeDir, 'plugins'),
       ...(options.cliArgs.runExamples ? [resolve(this.homeDir, 'examples')] : []),
-      resolve(this.homeDir, '..', 'opensearch-dashboards-extra'),
+      //resolve(this.homeDir, '..', 'opensearch-dashboards-extra'),
     ];
 
     this.cliArgs = Object.freeze(options.cliArgs);

diff --git a/packages/osd-dev-utils/src/proc_runner/proc.ts b/packages/osd-dev-utils/src/proc_runner/proc.ts
@@ -153,15 +153,15 @@ export function startProc(name: string, options: ProcOptions, log: ToolingLog) {
     await withTimeout(
       async () => {
         log.debug(`Sending "${signal}" to proc "${name}"`);
-        await treeKillAsync(childProcess.pid, signal);
+        await treeKillAsync(childProcess.pid!, signal);
         await outcomePromise;
       },
       STOP_TIMEOUT,
       async () => {
         log.warning(
           `Proc "${name}" was sent "${signal}" didn't emit the "exit" or "error" events after ${STOP_TIMEOUT} ms, sending SIGKILL`
         );
-        await treeKillAsync(childProcess.pid, 'SIGKILL');
+        await treeKillAsync(childProcess.pid!, 'SIGKILL');
       }
     );
 

diff --git a/packages/osd-interpreter/package.json b/packages/osd-interpreter/package.json
@@ -27,7 +27,7 @@
     "del": "^6.1.1",
     "getopts": "^2.2.5",
     "pegjs": "0.10.0",
-    "sass-loader": "^10.2.0",
+    "sass-loader": "^10.4.1",
     "style-loader": "^1.1.3",
     "supports-color": "^7.0.0",
     "url-loader": "^2.2.0",

diff --git a/packages/osd-monaco/package.json b/packages/osd-monaco/package.json
@@ -5,7 +5,7 @@
   "main": "./target/index.js",
   "license": "Apache-2.0",
   "scripts": {
-    "build": "node ./scripts/build.js",
+    "build": "export NODE_OPTIONS=--openssl-legacy-provider && node ./scripts/build.js",
     "osd:bootstrap": "yarn build --dev"
   },
   "dependencies": {

diff --git a/packages/osd-optimizer/package.json b/packages/osd-optimizer/package.json
@@ -25,16 +25,15 @@
     "dedent": "^0.7.0",
     "del": "^6.1.1",
     "execa": "^4.0.2",
-    "fibers": "^5.0.3",
     "jest-diff": "^27.5.1",
     "js-yaml": "^3.14.0",
     "json-stable-stringify": "^1.0.1",
-    "lmdb-store": "^1.6.11",
+    "lmdb": "^2.7.10",
+    "node-sass": "^8.0.0",
     "normalize-path": "^3.0.0",
     "pirates": "^4.0.1",
     "postcss": "^8.4.5",
     "rxjs": "^6.5.5",
-    "sass": "~1.26.11",
     "source-map-support": "^0.5.19",
     "terser-webpack-plugin": "^2.1.2",
     "tinymath": "1.2.1",
@@ -54,7 +53,7 @@
     "loader-utils": "^2.0.4",
     "postcss-loader": "^4.2.0",
     "raw-loader": "^4.0.2",
-    "sass-loader": "^10.2.0",
+    "sass-loader": "^10.4.1",
     "style-loader": "^1.1.3",
     "url-loader": "^2.2.0",
     "val-loader": "^2.1.2",

diff --git a/packages/osd-optimizer/src/integration_tests/__snapshots__/basic_optimization.test.ts.snap b/packages/osd-optimizer/src/integration_tests/__snapshots__/basic_optimization.test.ts.snap
diff --git a/packages/osd-optimizer/src/node/cache.ts b/packages/osd-optimizer/src/node/cache.ts
@@ -32,7 +32,7 @@ import Path from 'path';
 import { Writable } from 'stream';
 
 import chalk from 'chalk';
-import * as LmdbStore from 'lmdb-store';
+import * as LmdbStore from 'lmdb';
 import { getMatchingRoot } from '@osd/cross-platform';
 
 const GLOBAL_ATIME = `${Date.now()}`;
@@ -96,8 +96,8 @@ export class Cache {
     // keys which haven't been used in 30 days. We use `unref()` to
     // make sure this timer doesn't hold other processes open
     // unexpectedly
-    this.timer = setTimeout(() => {
-      this.pruneOldKeys();
+    this.timer = setTimeout(async () => {
+      await this.pruneOldKeys();
     }, 30 * MINUTE);
 
     // timer.unref is not defined in jest which emulates the dom by default
@@ -134,12 +134,13 @@ export class Cache {
   async update(path: string, file: { mtime: string; code: string; map: any }) {
     const key = this.getKey(path);
 
-    await Promise.all([
-      this.safePut(this.atimes, key, GLOBAL_ATIME),
-      this.safePut(this.mtimes, key, file.mtime),
-      this.safePut(this.codes, key, file.code),
-      this.safePut(this.sourceMaps, key, JSON.stringify(file.map)),
-    ]);
+    this.safePut(this.atimes, key, GLOBAL_ATIME);
+    this.safePut(this.mtimes, key, file.mtime);
+    this.safePut(this.codes, key, file.code);
+
+    if (file.map != null) {
+      this.safePut(this.sourceMaps, key, JSON.stringify(file.map));
+    }
   }
 
   close() {
@@ -172,9 +173,9 @@ export class Cache {
     }
   }
 
-  private async safePut<V>(db: LmdbStore.Database<V, string>, key: string, value: V) {
+  private safePut<V>(db: LmdbStore.Database<V, string>, key: string, value: V) {
     try {
-      await db.put(key, value);
+      db.putSync(key, value);
       this.debug('PUT', db, key);
     } catch (error) {
       this.logError('PUT', db, key, error);
@@ -204,7 +205,6 @@ export class Cache {
       const validKeys: string[] = [];
       const invalidKeys: string[] = [];
 
-      // @ts-expect-error See https://github.com/DoctorEvidence/lmdb-store/pull/18
       for (const { key, value } of this.atimes.getRange()) {
         const atime = parseInt(`${value}`, 10);
         if (Number.isNaN(atime) || atime < ATIME_LIMIT) {

diff --git a/packages/osd-optimizer/src/optimizer/observe_worker.ts b/packages/osd-optimizer/src/optimizer/observe_worker.ts
@@ -89,6 +89,7 @@ function usingWorkerProc<T>(
             ? [`${inspectFlag}=${inspectPortCounter++}`]
             : []),
           ...(config.maxWorkerCount <= 3 ? ['--max-old-space-size=2048'] : []),
+          '--openssl-legacy-provider',
         ],
         buffer: false,
         stderr: 'pipe',

diff --git a/packages/osd-optimizer/src/optimizer/optimizer_config.ts b/packages/osd-optimizer/src/optimizer/optimizer_config.ts
@@ -179,7 +179,7 @@ export class OptimizerConfig {
       Path.resolve(repoRoot, 'src/plugins'),
       Path.resolve(repoRoot, 'plugins'),
       ...(examples ? [Path.resolve('examples')] : []),
-      Path.resolve(repoRoot, 'opensearch-dashboards-extra'),
+      //Path.resolve(repoRoot, 'opensearch-dashboards-extra'),
     ];
 
     if (!pluginScanDirs.every((p) => Path.isAbsolute(p))) {

diff --git a/packages/osd-optimizer/src/worker/webpack.config.ts b/packages/osd-optimizer/src/worker/webpack.config.ts
@@ -176,12 +176,11 @@ export function getWebpackConfig(bundle: Bundle, bundleRefs: BundleRefs, worker:
                       )};\n${content}`;
                     },
                     webpackImporter: false,
-                    implementation: require('sass'),
+                    implementation: require('node-sass'),
                     sassOptions: {
-                      outputStyle: 'compressed',
+                      outputStyle: 'nested',
                       includePaths: [Path.resolve(worker.repoRoot, 'node_modules')],
                       sourceMapRoot: `/${bundle.type}:${bundle.id}`,
-                      fiber: require('fibers'),
                     },
                   },
                 },

diff --git a/packages/osd-pm/dist/index.js b/packages/osd-pm/dist/index.js
@@ -27293,14 +27293,13 @@ function getProjectPaths({
   projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, 'examples/*'));
 
   if (!skipOpenSearchDashboardsPlugins) {
-    projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*'));
-    projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*/packages/*'));
-    projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*/plugins/*'));
+    //projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*'));
+    //projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*/packages/*'));
+    //projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, '../opensearch-dashboards-extra/*/plugins/*'));
     projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, 'plugins/*'));
     projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, 'plugins/*/packages/*'));
     projectPaths.push(Object(path__WEBPACK_IMPORTED_MODULE_0__["resolve"])(rootPath, 'plugins/*/plugins/*'));
   }
-
   return projectPaths;
 }
 

diff --git a/packages/osd-pm/package.json b/packages/osd-pm/package.json
@@ -28,7 +28,7 @@
     "@types/lodash": "^4.14.170",
     "@types/log-symbols": "^2.0.0",
     "@types/ncp": "^2.0.1",
-    "@types/node": "^14.17.32",
+    "@types/node": "18.11.18",
     "@types/ora": "^1.3.5",
     "@types/read-pkg": "^4.0.0",
     "@types/strip-ansi": "^5.2.1",

diff --git a/packages/osd-pm/src/config.ts b/packages/osd-pm/src/config.ts
@@ -56,9 +56,9 @@ export function getProjectPaths({ rootPath, ossOnly, skipOpenSearchDashboardsPlu
   projectPaths.push(resolve(rootPath, 'examples/*'));
 
   if (!skipOpenSearchDashboardsPlugins) {
-    projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*'));
-    projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*/packages/*'));
-    projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*/plugins/*'));
+    //projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*'));
+    //projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*/packages/*'));
+    //projectPaths.push(resolve(rootPath, '../opensearch-dashboards-extra/*/plugins/*'));
     projectPaths.push(resolve(rootPath, 'plugins/*'));
     projectPaths.push(resolve(rootPath, 'plugins/*/packages/*'));
     projectPaths.push(resolve(rootPath, 'plugins/*/plugins/*'));

diff --git a/packages/osd-ui-framework/Gruntfile.js b/packages/osd-ui-framework/Gruntfile.js
@@ -28,7 +28,7 @@
  * under the License.
  */
 
-const sass = require('sass');
+const sass = require('node-sass');
 const postcss = require('postcss');
 const postcssConfig = require('@osd/optimizer/postcss.config.js');
 

diff --git a/packages/osd-ui-framework/package.json b/packages/osd-ui-framework/package.json
@@ -30,7 +30,7 @@
     "grunt-babel": "^8.0.0",
     "grunt-contrib-clean": "^2.0.0",
     "grunt-contrib-copy": "^1.0.0",
-    "sass": "~1.26.11",
+    "node-sass": "^8.0.0",
     "postcss": "^8.4.5",
     "sinon": "^7.4.2"
   }

diff --git a/packages/osd-ui-shared-deps/package.json b/packages/osd-ui-shared-deps/package.json
@@ -4,8 +4,8 @@
   "private": true,
   "license": "Apache-2.0",
   "scripts": {
-    "build": "node scripts/build",
-    "osd:bootstrap": "node scripts/build --dev",
+    "build": "node --openssl-legacy-provider scripts/build",
+    "osd:bootstrap": "node --openssl-legacy-provider scripts/build --dev",
     "osd:watch": "node scripts/build --dev --watch"
   },
   "dependencies": {

diff --git a/scripts/bwc/opensearch_dashboards_service.sh b/scripts/bwc/opensearch_dashboards_service.sh
@@ -12,6 +12,7 @@ function setup_dashboards() {
   [ $SECURITY_ENABLED == "false" ] && echo "server.host: 0.0.0.0" >> config/opensearch_dashboards.yml
   echo "csp.warnLegacyBrowsers: false" >> config/opensearch_dashboards.yml
   echo "--max-old-space-size=5120" >> config/node.options
+  echo "--openssl-legacy-provider" >> config/node.options
 }
 
 # Starts OpenSearch Dashboards
@@ -29,4 +30,4 @@ function check_dashboards_status {
   cd "$DIR"
   check_status $DASHBOARDS_PATH "$DASHBOARDS_MSG" $DASHBOARDS_URL "$OPENSEARCH_ARGS" >> /dev/null 2>&1
   echo "OpenSearch Dashboards is up!"
-} 
+}
diff --git a/src/core/server/bootstrap.ts b/src/core/server/bootstrap.ts
@@ -29,11 +29,13 @@
  */
 
 import chalk from 'chalk';
-import { isMaster as isClusterManager } from 'cluster';
+import cluster from 'cluster';
 import { CliArgs, Env, RawConfigService } from './config';
 import { Root } from './root';
 import { CriticalError } from './errors';
 
+let isClusterManager = cluster.isMaster;
+
 interface OpenSearchDashboardsFeatures {
   // Indicates whether we can run OpenSearch Dashboards in a so called cluster mode in which
   // OpenSearch Dashboards is run as a "worker" process together with optimizer "worker" process
@@ -97,7 +99,7 @@ export async function bootstrap({
   // in order to be able to reload the log configuration
   // under the cluster mode
   process.on('message', (msg) => {
-    if (!msg || msg.reloadLoggingConfig !== true) {
+    if (!msg || (msg as any).reloadLoggingConfig !== true) {
       return;
     }
 

diff --git a/src/core/server/legacy/legacy_service.ts b/src/core/server/legacy/legacy_service.ts
@@ -165,6 +165,7 @@ export class LegacyService implements CoreService {
         startDeps
       );
     }
+    this.log.debug('finished legacy service');
   }
 
   public async stop() {

diff --git a/src/core/server/opensearch/opensearch_service.ts b/src/core/server/opensearch/opensearch_service.ts
@@ -116,21 +116,22 @@ export class OpenSearchService
     };
   }
   public async start({ auditTrail }: StartDeps): Promise<InternalOpenSearchServiceStart> {
+    this.log.debug('I am here000');
     this.auditorFactory = auditTrail;
     if (!this.legacyClient || !this.createLegacyCustomClient) {
       throw new Error('OpenSearchService needs to be setup before calling start');
     }
-
+    this.log.debug('I am here111');
     const config = await this.config$.pipe(first()).toPromise();
-
+    this.log.debug('I am here222');
     const createClient = (
       type: string,
       clientConfig: Partial<OpenSearchClientConfig> = {}
     ): ICustomClusterClient => {
       const finalConfig = merge({}, config, clientConfig);
       return this.createClusterClient(type, finalConfig);
     };
-
+    this.log.debug('I am here333');
     return {
       client: this.client!,
       createClient,

diff --git a/src/core/server/plugins/plugins_service.ts b/src/core/server/plugins/plugins_service.ts
@@ -154,6 +154,7 @@ export class PluginsService implements CoreService<PluginsServiceSetup, PluginsS
   public async start(deps: PluginsServiceStartDeps) {
     this.log.debug('Plugins service starts plugins');
     const contracts = await this.pluginsSystem.startPlugins(deps);
+    this.log.debug('Plugins service done');
     return { contracts };
   }
 

diff --git a/src/core/server/status/plugins_status.ts b/src/core/server/status/plugins_status.ts
@@ -43,7 +43,7 @@ interface Deps {
 
 export class PluginsStatusService {
   private readonly pluginStatuses = new Map<PluginName, Observable<ServiceStatus>>();
-  private readonly update$ = new BehaviorSubject(true);
+  private readonly update$ = new BehaviorSubject<boolean>(true);
   private readonly defaultInheritedStatus$: Observable<ServiceStatus>;
 
   constructor(private readonly deps: Deps) {
@@ -121,7 +121,7 @@ export class PluginsStatusService {
 
         return combineLatest(pluginStatuses).pipe(
           map((statuses) => Object.fromEntries(statuses)),
-          distinctUntilChanged(isDeepStrictEqual)
+          distinctUntilChanged<Record<PluginName, ServiceStatus>>(isDeepStrictEqual)
         );
       })
     );

diff --git a/src/core/server/status/status_service.ts b/src/core/server/status/status_service.ts
@@ -95,7 +95,7 @@ export class StatusService implements CoreService<InternalStatusServiceSetup> {
         this.logger.debug(`Recalculated overall status`, { status: summary });
         return summary;
       }),
-      distinctUntilChanged(isDeepStrictEqual),
+      distinctUntilChanged<ServiceStatus<unknown>>(isDeepStrictEqual),
       shareReplay(1)
     );
 
@@ -149,7 +149,7 @@ export class StatusService implements CoreService<InternalStatusServiceSetup> {
         opensearch: opensearchStatus,
         savedObjects: savedObjectsStatus,
       })),
-      distinctUntilChanged(isDeepStrictEqual),
+      distinctUntilChanged<CoreStatus>(isDeepStrictEqual),
       shareReplay(1)
     );
   }