feat(core): support package-based monorepo

Author: manfredsteyer

angular-architects-native-federation-1.0.0-beta.1.tgz

@@ -1,10 +1,10 @@
 {
   "name": "@softarc/native-federation",
-  "version": "1.0.3",
+  "version": "1.1.0-beta.0",
   "type": "commonjs",
   "dependencies": {
     "json5": "^2.2.0",
     "npmlog": "^6.0.2",
-    "@softarc/native-federation-runtime": "1.0.3"
+    "@softarc/native-federation-runtime": "1.1.0-beta.0"
   }
 }

libs/native-federation-core/package.json

@@ -21,7 +21,9 @@ export async function bundleExposed(
     const entryPoint = config.exposes[key];
 
     const localPath = normalize(
-      path.join(options.workspaceRoot, config.exposes[key])
+      path.join(
+        options.projectRoot ?? options.workspaceRoot, 
+        config.exposes[key])
     );
 
     logger.info(`Bundling exposed module ${entryPoint}`);
@@ -76,7 +78,9 @@ export function describeExposed(
 
   for (const key in config.exposes) {
     const localPath = normalize(
-      path.join(options.workspaceRoot, config.exposes[key])
+      path.join(
+        options.projectRoot ?? options.workspaceRoot, 
+        config.exposes[key])
     );
 
     result.push({

libs/native-federation-core/src/lib/core/bundle-exposed.ts

@@ -18,7 +18,11 @@ export async function bundleShared(
   const result: Array<SharedInfo> = [];
   const packageInfos = Object.keys(config.shared)
     // .filter((packageName) => !isInSkipList(packageName, PREPARED_DEFAULT_SKIP_LIST))
-    .map((packageName) => getPackageInfo(packageName, fedOptions.workspaceRoot))
+    .map((packageName) => getPackageInfo(
+      packageName, 
+      fedOptions.workspaceRoot,
+      fedOptions.projectRoot ?? fedOptions.workspaceRoot
+    ))
     .filter((pi) => !!pi) as PackageInfo[];
 
   // logger.notice('Shared packages are only bundled once as they are cached');
@@ -106,7 +110,7 @@ export async function bundleShared(
     });
 
     const fullOutputPath = path.join(
-      fedOptions.workspaceRoot,
+      fedOptions.projectRoot ?? fedOptions.workspaceRoot,
       fedOptions.outputPath,
       outFileName
     );

libs/native-federation-core/src/lib/core/bundle-shared.ts

@@ -1,5 +1,9 @@
 export interface FederationOptions {
   workspaceRoot: string;
+  /**
+   * Defaults to workspaceRoot
+   */
+  projectRoot?: string;
   outputPath: string;
   federationConfig: string;
   tsConfig?: string;

libs/native-federation-core/src/lib/core/federation-options.ts

@@ -7,7 +7,7 @@ export async function loadFederationConfig(
   fedOptions: FederationOptions
 ): Promise<NormalizedFederationConfig> {
   const fullConfigPath = path.join(
-    fedOptions.workspaceRoot,
+    fedOptions.projectRoot ?? fedOptions.workspaceRoot,
     fedOptions.federationConfig
   );
 

libs/native-federation-core/src/lib/core/load-federation-config.ts

@@ -8,7 +8,7 @@ export function writeFederationInfo(
   fedOptions: FederationOptions
 ) {
   const metaDataPath = path.join(
-    fedOptions.workspaceRoot,
+    fedOptions.projectRoot ?? fedOptions.workspaceRoot,
     fedOptions.outputPath,
     'remoteEntry.json'
   );

libs/native-federation-core/src/lib/core/write-federation-info.ts

@@ -16,7 +16,7 @@ export function writeImportMap(
 
   const importMap = { imports };
   const importMapPath = path.join(
-    fedOption.workspaceRoot,
+    fedOption.projectRoot ?? fedOption.workspaceRoot,
     fedOption.outputPath,
     'importmap.json'
   );

libs/native-federation-core/src/lib/core/write-import-map.ts

@@ -1,3 +1,17 @@
-export function normalize(path: string): string {
-  return path.replace(/\\/g, '/');
-}
+export function normalize(path: string, trailingSlash?: boolean): string {
+  let cand = path.replace(/\\/g, '/');
+
+  if (typeof trailingSlash === 'undefined') {
+    return cand;
+  }
+
+  while (cand.endsWith('/')) {
+    cand = cand.substring(0, cand.length-1);
+  }
+
+  if (trailingSlash) {
+    return cand + '/'
+  }
+
+  return cand;
+}

libs/native-federation-core/src/lib/utils/normalize.ts

@@ -1,6 +1,7 @@
 import * as fs from 'fs';
 import * as path from 'path';
 import { logger } from './logger';
+import { normalize } from './normalize';
 
 export interface PackageInfo {
   packageName: string;
@@ -16,18 +17,50 @@ export interface PartialPackageJson {
 
 export function getPackageInfo(
   packageName: string,
-  workspaceRoot: string
+  workspaceRoot: string,
+  projectRoot: string
 ): PackageInfo | null {
-  const projectRoot = workspaceRoot;
+
+  let currentPath = projectRoot;
+
+  workspaceRoot = normalize(path.dirname(workspaceRoot), true);
+  projectRoot = normalize(path.dirname(projectRoot), true);
+
+  while (workspaceRoot !== currentPath) {
+
+    const cand = _getPackageInfo(packageName, currentPath);
+    if (cand) {
+      return cand;
+    }
+
+    currentPath = normalize(path.dirname(currentPath), true);
+  }
+
+  const result = _getPackageInfo(packageName, currentPath);
+
+  if (!result) {
+    logger.warn('No meta data found for shared lib ' + packageName);
+  }
+
+  return result;
+
+}
+
+export function _getPackageInfo(
+  packageName: string,
+  currentPath: string,
+): PackageInfo | null {
+
+
   const mainPkgName = getPkgFolder(packageName);
 
-  const mainPkgPath = path.join(projectRoot, 'node_modules', mainPkgName);
+  const mainPkgPath = path.join(currentPath, 'node_modules', mainPkgName);
   const mainPkgJsonPath = path.join(mainPkgPath, 'package.json');
 
   if (!fs.existsSync(mainPkgPath)) {
     // TODO: Add logger
     // context.logger.warn('No package.json found for ' + packageName);
-    logger.warn('No package.json found for ' + packageName);
+    logger.verbose('No package.json found for ' + packageName + ' in ' + mainPkgPath);
 
     return null;
   }
@@ -105,7 +138,7 @@ export function getPackageInfo(
     };
   }
 
-  const secondaryPgkPath = path.join(projectRoot, 'node_modules', packageName);
+  const secondaryPgkPath = path.join(currentPath, 'node_modules', packageName);
   const secondaryPgkJsonPath = path.join(secondaryPgkPath, 'package.json');
   let secondaryPgkJson: PartialPackageJson | null = null;
   if (fs.existsSync(secondaryPgkJsonPath)) {