[Backport 2.x] [@osd/pm] Fix linked deps resolution

packages/osd-pm/src/utils/__fixtures__/opensearch-dashboards-dev/package.json

@@ -0,0 +1,14 @@
+{
+  "name": "opensearch-dashboards",
+  "version": "1.0.0",
+  "private": "true",
+  "dependencies": {
+    "foo": "1.0.0",
+    "@scoped/baz": "file:../other-plugins/baz"
+  },
+  "workspaces": {
+    "packages": [
+      "packages/*"
+    ]
+  }
+}

packages/osd-pm/src/utils/__fixtures__/opensearch-dashboards-dev/packages/bar/package.json

@@ -0,0 +1,8 @@
+{
+  "name": "bar",
+  "version": "1.0.0",
+  "dependencies": {
+    "foo": "1.0.0",
+    "@scoped/baz": "file:../../../other-plugins/baz"
+  }
+}

packages/osd-pm/src/utils/__fixtures__/opensearch-dashboards-dev/packages/foo/package.json

@@ -0,0 +1,4 @@
+{
+  "name": "foo",
+  "version": "1.0.0"
+}

packages/osd-pm/src/utils/__fixtures__/opensearch-dashboards-dev/yarn.lock

@@ -0,0 +1,6 @@
+# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
+# yarn lockfile v1
+
+
+"@scoped/baz@file:../other-plugins/baz":
+  version "1.0.0"

packages/osd-pm/src/utils/yarn_lock.test.ts

@@ -0,0 +1,40 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { resolve } from 'path';
+import { OpenSearchDashboards } from './opensearch_dashboards';
+import { readYarnLock } from './yarn_lock';
+
+const rootPath = resolve(`${__dirname}/__fixtures__/opensearch-dashboards-dev`);
+
+const linkedDepmarker = 'file:';
+const linkedDepmarkerLength = linkedDepmarker.length;
+
+describe('#readYarnLock', () => {
+  it('includes an entry with the absolute path to a linked dependency', async () => {
+    const devProject = await OpenSearchDashboards.loadFrom(rootPath);
+    const { allDependencies } = devProject.getProject('opensearch-dashboards');
+    const expectedObject = Object.keys(allDependencies).reduce(
+      (accumulator: { [key: string]: any }, key) => {
+        if (allDependencies[key].startsWith('file:')) {
+          accumulator[
+            key +
+              '@file:' +
+              resolve(
+                devProject.getAbsolute(),
+                allDependencies[key].substring(linkedDepmarkerLength)
+              )
+          ] = expect.any(Object);
+        }
+        return accumulator;
+      },
+      {}
+    );
+
+    const result = await readYarnLock(devProject);
+
+    expect(result).toMatchObject(expectedObject);
+  });
+});

packages/osd-pm/src/utils/yarn_lock.ts

@@ -30,6 +30,8 @@
 
 // @ts-expect-error published types are worthless
 import { parse as parseLockfile } from '@yarnpkg/lockfile';
+import { standardize } from '@osd/cross-platform';
+import { resolve, isAbsolute } from 'path';
 
 import { readFile } from '../utils/fs';
 import { OpenSearchDashboards } from '../utils/opensearch_dashboards';
@@ -62,7 +64,7 @@ export async function readYarnLock(osd: OpenSearchDashboards): Promise<YarnLock>
     const yarnLock = parseLockfile(contents);
 
     if (yarnLock.type === 'success') {
-      return yarnLock.object;
+      return fixFileLinks(yarnLock.object, osd.getAbsolute());
     }
 
     throw new Error('unable to read yarn.lock file, please run `yarn osd bootstrap`');
@@ -75,6 +77,33 @@ export async function readYarnLock(osd: OpenSearchDashboards): Promise<YarnLock>
   return {};
 }
 
+/**
+ * Converts relative `file:` paths to absolute paths
+ * Yarn parsing method converts all file URIs to relative paths and this
+ * breaks the single-version requirement as dependencies to the same path
+ * would differ in their URIs across OSD and packages.
+ */
+function fixFileLinks(yarnLock: YarnLock, projectRoot: string): YarnLock {
+  const fileLinkDelimiter = '@file:';
+
+  const linkedKeys = Object.keys(yarnLock).filter((key) => key.includes(fileLinkDelimiter));
+
+  if (linkedKeys.length === 0) return yarnLock;
+
+  const updatedYarnLock = { ...yarnLock };
+  for (const key of linkedKeys) {
+    const [keyName, keyPath, ...rest] = key.split(fileLinkDelimiter);
+    if (!isAbsolute(keyPath)) {
+      const updatedKeyName = [keyName, standardize(resolve(projectRoot, keyPath)), ...rest].join(
+        fileLinkDelimiter
+      );
+      updatedYarnLock[updatedKeyName] = updatedYarnLock[key];
+    }
+  }
+
+  return updatedYarnLock;
+}
+
 /**
  * Get a list of the absolute dependencies of this project, as resolved
  * in the yarn.lock file, does not include other projects in the workspace

src/dev/build/tasks/__fixtures__/opensearch-dashboards-dev/yarn.lock

@@ -0,0 +1,17 @@
+# THIS IS AN AUTOGENERATED FILE. DO NOT EDIT THIS FILE DIRECTLY.
+# yarn lockfile v1
+
+
+"@scoped/foo@file:../linked/foo":
+  version "1.0.0"
+
+"bar@file:../../deeper/linked/bar, @scoped/bar@file:../../deeper/linked/bar":
+  version "1.0.0"
+
+"baz@file:/absolute/baz":
+  version "1.0.0"
+
+# impossible but used for validating the transformer
+"qux@^1.0.0, qux@file:../linked/qux, @scoped/qux@^1.0.0, @scoped/qux@file:../linked/qux":
+  version "1.0.0"
+  resolved "https://user@file:password@some.registry/package"

src/dev/build/tasks/copy_source_task.test.ts

@@ -0,0 +1,27 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+import { join, resolve } from 'path';
+import { mkdirSync, readFileSync, rmSync } from 'fs';
+import { copyYarnLock } from './copy_source_task';
+
+const repoRoot = resolve(`${__dirname}/__fixtures__/opensearch-dashboards-dev`);
+const disposableRoot = join(repoRoot, 'build');
+const buildRoot = join(repoRoot, 'build/opensearch-dashboards-dev');
+
+describe('copy source task', () => {
+  beforeEach(() => {
+    mkdirSync(buildRoot, { recursive: true });
+  });
+
+  afterEach(() => {
+    rmSync(disposableRoot, { force: true, recursive: true });
+  });
+
+  it('transform relative paths while copying yarn.lock', async () => {
+    await copyYarnLock(repoRoot, buildRoot);
+    expect(readFileSync(join(buildRoot, 'yarn.lock'), 'utf8')).toMatchSnapshot();
+  });
+});

src/dev/build/tasks/copy_source_task.ts

@@ -28,16 +28,21 @@
  * under the License.
  */
 
+import { createInterface } from 'readline';
+import { join, isAbsolute, relative } from 'path';
+import { createReadStream, createWriteStream } from 'fs';
 import { copyAll, Task } from '../lib';
 
 export const CopySource: Task = {
   description: 'Copying source into platform-generic build directory',
 
   async run(config, log, build) {
-    await copyAll(config.resolveFromRepo(), build.resolvePath(), {
+    const repoRoot = config.resolveFromRepo();
+    const buildRoot = build.resolvePath();
+
+    await copyAll(repoRoot, buildRoot, {
       dot: false,
       select: [
-        'yarn.lock',
         'src/**',
         '!src/**/*.{test,test.mocks,mock}.{js,ts,tsx}',
         '!src/**/mocks.ts', // special file who imports .mock files
@@ -60,5 +65,67 @@
         'opensearch_dashboards.d.ts',
       ],
     });
+
+    await copyYarnLock(repoRoot, buildRoot);
   },
 };
+
+/*
+ * Dependencies linked using `file:` in the `yarn.lock` file are
+ * referenced with relative paths. Moving them to the `build`
+ * folder, these paths need to be transformed.
+ */
+export const copyYarnLock = async (repoRoot: string, buildRoot: string) => {
+  const writeStream = createWriteStream(join(buildRoot, 'yarn.lock'));
+  const writeLine = (line: string) =>
+    new Promise((resolve) => {
+      if (writeStream.write(line + '\n')) return resolve();
+      writeStream.once('drain', resolve);
+    });
+
+  const returnPromise = new Promise((resolve) => {
+    writeStream.once('close', resolve);
+  });
+
+  /*
+   * Dependency patterns are comma separated `name@range` values, followed
+   * by a colon, like `AAAA:` and `AAAA, BBBB, CCCC:`
+   * Some are wrapped in quotes, like `"AAAA":` and `"AAAA, BBBB, CCCC":`
+   *
+   * The linked file will have `@file:` in it and the inner strings will
+   * not have commas or colons.
+   *
+   * Zero-width lookbehind and lookaheads allow getting only the part
+   * required for processing the patterns. `\S` is to avoid matching
+   * spaces after commas.
+   */
+  const linkedFileDepPattern = /(?<=^"?|,\s*)(\S+?[^,:]+)@file:([^,:]+)(?=,\s*|"?:\s*$)/g;
+  const fileLinkDelimiter = '@file:';
+
+  const reader = createInterface({
+    input: createReadStream(join(repoRoot, 'yarn.lock')),
+    crlfDelay: Infinity,
+  });
+
+  for await (const line of reader) {
+    /*
+     * For added safety, we make sure the line doesn't start with whitespace
+     * before we check that it has `@file:`.
+     */
+    if (!line.startsWith(' ') && line.includes(fileLinkDelimiter)) {
+      await writeLine(
+        line.replace(linkedFileDepPattern, (match, m1, m2) => {
+          if (isAbsolute(m2)) return `${m1}${fileLinkDelimiter}${m2}`;
+          // Join the relative path and repoRoot and find how to ge there from buildRoot
+          return `${m1}${fileLinkDelimiter}${relative(buildRoot, join(repoRoot, m2))}`;
+        })
+      );
+    } else {
+      await writeLine(line);
+    }
+  }
+
+  writeStream.end();
+
+  return returnPromise;
+};

src/dev/precommit_hook/casing_check_config.js

@@ -101,6 +101,7 @@ export const IGNORE_DIRECTORY_GLOBS = [
   'src/legacy/ui/public/flot-charts',
   'test/functional/fixtures/opensearch_archiver/visualize_source-filters',
   'packages/osd-pm/src/utils/__fixtures__/*',
+  'src/dev/build/tasks/__fixtures__/*',
 ];
 
 /**