diff --git a/.changeset/tidy-bananas-relax.md b/.changeset/tidy-bananas-relax.md
new file mode 100644
index 00000000000..72deb0db02c
--- /dev/null
+++ b/.changeset/tidy-bananas-relax.md
@@ -0,0 +1,6 @@
+---
+'@module-federation/modern-js-v3': patch
+'@module-federation/sdk': patch
+---
+
+Improve Node-side async startup remote loading by stripping browser HMR bootstrap calls, normalizing async startup container exports, and resolving var/global container shapes reliably for RSC federation flows.
diff --git a/apps/modernjs-rsc/README.md b/apps/modernjs-rsc/README.md
new file mode 100644
index 00000000000..19a2f8fd55a
--- /dev/null
+++ b/apps/modernjs-rsc/README.md
@@ -0,0 +1,16 @@
+# modernjs-rsc
+
+Minimal ModernJS + Module Federation RSC example in `apps/`.
+
+## Run
+
+```bash
+pnpm nx run modernjs-rsc:serve
+```
+
+Open `http://localhost:3060`.
+
+This app enables `experiments.rsc` + `experiments.asyncStartup` and exposes:
+
+- `modernjs_rsc/ServerMessage`
+- `modernjs_rsc/ClientCounter`
diff --git a/apps/modernjs-rsc/modern.config.ts b/apps/modernjs-rsc/modern.config.ts
new file mode 100644
index 00000000000..ddee2a9e488
--- /dev/null
+++ b/apps/modernjs-rsc/modern.config.ts
@@ -0,0 +1,13 @@
+import { appTools, defineConfig } from '@modern-js/app-tools';
+import { moduleFederationPlugin } from '@module-federation/modern-js-v3';
+
+export default defineConfig({
+ server: {
+ port: 3060,
+ ssr: {
+ mode: 'stream',
+ },
+ rsc: true,
+ },
+ plugins: [appTools(), moduleFederationPlugin()],
+});
diff --git a/apps/modernjs-rsc/module-federation.config.ts b/apps/modernjs-rsc/module-federation.config.ts
new file mode 100644
index 00000000000..2db6d421faf
--- /dev/null
+++ b/apps/modernjs-rsc/module-federation.config.ts
@@ -0,0 +1,21 @@
+import { createModuleFederationConfig } from '@module-federation/modern-js-v3';
+
+export default createModuleFederationConfig({
+ name: 'modernjs_rsc',
+ manifest: {
+ filePath: 'static',
+ },
+ filename: 'static/remoteEntry.js',
+ exposes: {
+ './ServerMessage': './src/server/ServerMessage.tsx',
+ './ClientCounter': './src/client/ClientCounter.tsx',
+ },
+ shared: {
+ react: { singleton: true },
+ 'react-dom': { singleton: true },
+ },
+ experiments: {
+ asyncStartup: true,
+ rsc: true,
+ },
+});
diff --git a/apps/modernjs-rsc/package.json b/apps/modernjs-rsc/package.json
new file mode 100644
index 00000000000..81995f84530
--- /dev/null
+++ b/apps/modernjs-rsc/package.json
@@ -0,0 +1,30 @@
+{
+ "name": "modernjs-rsc",
+ "private": true,
+ "version": "0.1.0",
+ "scripts": {
+ "dev": "modern dev",
+ "build": "modern build",
+ "start": "modern start",
+ "serve": "modern serve",
+ "lint": "modern lint"
+ },
+ "engines": {
+ "node": ">=16.18.1"
+ },
+ "dependencies": {
+ "@babel/runtime": "7.28.2",
+ "@modern-js/runtime": "3.0.1",
+ "@module-federation/modern-js-v3": "workspace:*",
+ "react": "~18.3.1",
+ "react-dom": "~18.3.1"
+ },
+ "devDependencies": {
+ "@modern-js/app-tools": "3.0.1",
+ "@modern-js/tsconfig": "3.0.1",
+ "@types/node": "^20.19.5",
+ "@types/react": "~18.2.0",
+ "@types/react-dom": "~18.3.0",
+ "typescript": "~5.0.4"
+ }
+}
diff --git a/apps/modernjs-rsc/project.json b/apps/modernjs-rsc/project.json
new file mode 100644
index 00000000000..8277076bc65
--- /dev/null
+++ b/apps/modernjs-rsc/project.json
@@ -0,0 +1,44 @@
+{
+ "name": "modernjs-rsc",
+ "$schema": "../../node_modules/nx/schemas/project-schema.json",
+ "sourceRoot": "apps/modernjs-rsc/src",
+ "projectType": "application",
+ "tags": [],
+ "implicitDependencies": ["typescript"],
+ "targets": {
+ "build": {
+ "executor": "nx:run-commands",
+ "options": {
+ "dependsOn": [
+ {
+ "target": "build",
+ "dependencies": true
+ }
+ ],
+ "commands": [
+ {
+ "command": "cd apps/modernjs-rsc; pnpm run build",
+ "forwardAllArgs": true
+ }
+ ]
+ }
+ },
+ "serve": {
+ "executor": "nx:run-commands",
+ "options": {
+ "dependsOn": [
+ {
+ "target": "build",
+ "dependencies": true
+ }
+ ],
+ "commands": [
+ {
+ "command": "cd apps/modernjs-rsc; pnpm run dev",
+ "forwardAllArgs": false
+ }
+ ]
+ }
+ }
+ }
+}
diff --git a/apps/modernjs-rsc/src/client/ClientCounter.tsx b/apps/modernjs-rsc/src/client/ClientCounter.tsx
new file mode 100644
index 00000000000..97e4871f519
--- /dev/null
+++ b/apps/modernjs-rsc/src/client/ClientCounter.tsx
@@ -0,0 +1,18 @@
+'use client';
+
+import { useState } from 'react';
+
+const ClientCounter = () => {
+ const [count, setCount] = useState(0);
+
+ return (
+
+ Client Component
+
+
+ );
+};
+
+export default ClientCounter;
diff --git a/apps/modernjs-rsc/src/modern-app-env.d.ts b/apps/modernjs-rsc/src/modern-app-env.d.ts
new file mode 100644
index 00000000000..ca35b059576
--- /dev/null
+++ b/apps/modernjs-rsc/src/modern-app-env.d.ts
@@ -0,0 +1,4 @@
+///
+///
+///
+///
diff --git a/apps/modernjs-rsc/src/routes/page.tsx b/apps/modernjs-rsc/src/routes/page.tsx
new file mode 100644
index 00000000000..92154d7b644
--- /dev/null
+++ b/apps/modernjs-rsc/src/routes/page.tsx
@@ -0,0 +1,15 @@
+import ClientCounter from '../client/ClientCounter';
+import ServerMessage from '../server/ServerMessage';
+
+const Page = async () => {
+ return (
+
+ ModernJS RSC + Module Federation
+ This example exposes both server and client components.
+
+
+
+ );
+};
+
+export default Page;
diff --git a/apps/modernjs-rsc/src/server/ServerMessage.tsx b/apps/modernjs-rsc/src/server/ServerMessage.tsx
new file mode 100644
index 00000000000..7f391cc920a
--- /dev/null
+++ b/apps/modernjs-rsc/src/server/ServerMessage.tsx
@@ -0,0 +1,18 @@
+const wait = (ms: number) =>
+ new Promise((resolve) => {
+ setTimeout(resolve, ms);
+ });
+
+const ServerMessage = async () => {
+ await wait(20);
+ const renderedAt = new Date().toISOString();
+
+ return (
+
+ Server Component
+ Rendered at: {renderedAt}
+
+ );
+};
+
+export default ServerMessage;
diff --git a/apps/modernjs-rsc/tsconfig.app.json b/apps/modernjs-rsc/tsconfig.app.json
new file mode 100644
index 00000000000..c7c9676cbdd
--- /dev/null
+++ b/apps/modernjs-rsc/tsconfig.app.json
@@ -0,0 +1,17 @@
+{
+ "extends": "./tsconfig.json",
+ "compilerOptions": {
+ "outDir": "../../dist/out-tsc",
+ "types": ["node", "express"],
+ "target": "ES2015",
+ "module": "commonjs",
+ "forceConsistentCasingInFileNames": true,
+ "strict": true,
+ "noImplicitOverride": true,
+ "noPropertyAccessFromIndexSignature": true,
+ "noImplicitReturns": true,
+ "noFallthroughCasesInSwitch": true
+ },
+ "exclude": ["jest.config.ts", "src/**/*.spec.ts", "src/**/*.test.ts"],
+ "include": ["src/**/*.ts", "src/**/*.tsx"]
+}
diff --git a/apps/modernjs-rsc/tsconfig.json b/apps/modernjs-rsc/tsconfig.json
new file mode 100644
index 00000000000..8ea6df7ff72
--- /dev/null
+++ b/apps/modernjs-rsc/tsconfig.json
@@ -0,0 +1,14 @@
+{
+ "extends": "@modern-js/tsconfig/base",
+ "compilerOptions": {
+ "declaration": false,
+ "jsx": "preserve",
+ "baseUrl": "./",
+ "paths": {
+ "@/*": ["./src/*"],
+ "*": ["./@mf-types/*"]
+ }
+ },
+ "include": ["src", "config", "modern.config.ts", "./@mf-types"],
+ "exclude": ["**/node_modules"]
+}
diff --git a/packages/bridge/bridge-react/package.json b/packages/bridge/bridge-react/package.json
index 4f75042a024..5b2e4e73ce0 100644
--- a/packages/bridge/bridge-react/package.json
+++ b/packages/bridge/bridge-react/package.json
@@ -19,7 +19,8 @@
".": {
"types": "./dist/index.d.ts",
"import": "./dist/index.es.js",
- "require": "./dist/index.cjs.js"
+ "require": "./dist/index.cjs.js",
+ "default": "./dist/index.es.js"
},
"./base": {
"types": "./dist/base.d.ts",
@@ -64,17 +65,20 @@
"./lazy-utils": {
"types": "./dist/lazy-utils.d.ts",
"import": "./dist/lazy-utils.es.js",
- "require": "./dist/lazy-utils.cjs.js"
+ "require": "./dist/lazy-utils.cjs.js",
+ "default": "./dist/lazy-utils.es.js"
},
"./data-fetch-utils": {
"types": "./dist/data-fetch-utils.d.ts",
"import": "./dist/data-fetch-utils.es.js",
- "require": "./dist/data-fetch-utils.cjs.js"
+ "require": "./dist/data-fetch-utils.cjs.js",
+ "default": "./dist/data-fetch-utils.es.js"
},
"./data-fetch-server-middleware": {
"types": "./dist/data-fetch-server-middleware.d.ts",
"import": "./dist/data-fetch-server-middleware.es.js",
- "require": "./dist/data-fetch-server-middleware.cjs.js"
+ "require": "./dist/data-fetch-server-middleware.cjs.js",
+ "default": "./dist/data-fetch-server-middleware.es.js"
},
"./lazy-load-component-plugin": {
"types": "./dist/lazy-load-component-plugin.d.ts",
diff --git a/packages/dts-plugin/src/core/lib/typeScriptCompiler.ts b/packages/dts-plugin/src/core/lib/typeScriptCompiler.ts
index 6b38a49d8e2..777841c9206 100644
--- a/packages/dts-plugin/src/core/lib/typeScriptCompiler.ts
+++ b/packages/dts-plugin/src/core/lib/typeScriptCompiler.ts
@@ -1,5 +1,4 @@
-import fse from 'fs-extra';
-const { ensureDirSync, writeFileSync, existsSync } = fse;
+import fsExtra from 'fs-extra';
import crypto from 'crypto';
import { stat, readdir, writeFile, rm, readFile } from 'fs/promises';
import {
@@ -24,6 +23,7 @@ import { TsConfigJson } from '../interfaces/TsConfigJson';
import { logger } from '../../server';
const STARTS_WITH_SLASH = /^\//;
+const { ensureDirSync, writeFileSync, existsSync } = fsExtra;
const DEFINITION_FILE_EXTENSION = '.d.ts';
diff --git a/packages/enhanced/src/schemas/container/ContainerPlugin.check.ts b/packages/enhanced/src/schemas/container/ContainerPlugin.check.ts
index f41e37b89f0..0dfc1f6225e 100644
--- a/packages/enhanced/src/schemas/container/ContainerPlugin.check.ts
+++ b/packages/enhanced/src/schemas/container/ContainerPlugin.check.ts
@@ -44,6 +44,7 @@ const e = {
],
},
name: { type: 'string' },
+ layer: { type: 'string', minLength: 1 },
},
required: ['import'],
},
@@ -233,7 +234,7 @@ function a(
{
const r = l;
for (const e in t)
- if ('import' !== e && 'name' !== e)
+ if ('import' !== e && 'name' !== e && 'layer' !== e)
return (a.errors = [{ params: { additionalProperty: e } }]), !1;
if (r === l) {
if (void 0 !== t.import) {
@@ -241,7 +242,7 @@ function a(
const n = l,
m = l;
let u = !1;
- const c = l;
+ const y = l;
if (l == l)
if ('string' == typeof r) {
if (r.length < 1) {
@@ -252,7 +253,7 @@ function a(
const t = { params: { type: 'string' } };
null === i ? (i = [t]) : i.push(t), l++;
}
- var p = c === l;
+ var p = y === l;
if (((u = u || p), !u)) {
const n = l;
s(r, {
@@ -275,13 +276,25 @@ function a(
(l = m), null !== i && (m ? (i.length = m) : (i = null));
var f = n === l;
} else f = !0;
- if (f)
+ if (f) {
if (void 0 !== t.name) {
const e = l;
if ('string' != typeof t.name)
return (a.errors = [{ params: { type: 'string' } }]), !1;
f = e === l;
} else f = !0;
+ if (f)
+ if (void 0 !== t.layer) {
+ let e = t.layer;
+ const r = l;
+ if (l === r) {
+ if ('string' != typeof e)
+ return (a.errors = [{ params: { type: 'string' } }]), !1;
+ if (e.length < 1) return (a.errors = [{ params: {} }]), !1;
+ }
+ f = r === l;
+ } else f = !0;
+ }
}
}
}
@@ -306,16 +319,16 @@ function o(
let n = t[r];
const m = p,
u = p;
- let c = !1;
- const y = p;
+ let y = !1;
+ const c = p;
a(n, {
instancePath: e + '/' + r.replace(/~/g, '~0').replace(/\//g, '~1'),
parentData: t,
parentDataProperty: r,
rootData: i,
}) || ((l = null === l ? a.errors : l.concat(a.errors)), (p = l.length));
- var f = y === p;
- if (((c = c || f), !c)) {
+ var f = c === p;
+ if (((y = y || f), !y)) {
const a = p;
if (p == p)
if ('string' == typeof n) {
@@ -327,7 +340,7 @@ function o(
const t = { params: { type: 'string' } };
null === l ? (l = [t]) : l.push(t), p++;
}
- if (((f = a === p), (c = c || f), !c)) {
+ if (((f = a === p), (y = y || f), !y)) {
const a = p;
s(n, {
instancePath: e + '/' + r.replace(/~/g, '~0').replace(/\//g, '~1'),
@@ -337,10 +350,10 @@ function o(
}) ||
((l = null === l ? s.errors : l.concat(s.errors)), (p = l.length)),
(f = a === p),
- (c = c || f);
+ (y = y || f);
}
}
- if (!c) {
+ if (!y) {
const t = { params: {} };
return null === l ? (l = [t]) : l.push(t), p++, (o.errors = l), !1;
}
@@ -407,8 +420,8 @@ function i(
const t = { params: { type: 'array' } };
null === a ? (a = [t]) : a.push(t), l++;
}
- var c = m === l;
- if (((f = f || c), !f)) {
+ var y = m === l;
+ if (((f = f || y), !f)) {
const i = l;
o(t, {
instancePath: e,
@@ -416,8 +429,8 @@ function i(
parentDataProperty: n,
rootData: s,
}) || ((a = null === a ? o.errors : a.concat(o.errors)), (l = a.length)),
- (c = i === l),
- (f = f || c);
+ (y = i === l),
+ (f = f || y);
}
if (!f) {
const t = { params: {} };
@@ -674,8 +687,8 @@ function f(
const t = { params: { type: 'array' } };
null === a ? (a = [t]) : a.push(t), o++;
}
- var c = i === o;
- if (((s = s || c), !s)) {
+ var y = i === o;
+ if (((s = s || y), !s)) {
const t = o;
if (o === t)
if ('string' == typeof e) {
@@ -687,7 +700,7 @@ function f(
const t = { params: { type: 'string' } };
null === a ? (a = [t]) : a.push(t), o++;
}
- (c = t === o), (s = s || c);
+ (y = t === o), (s = s || y);
}
if (s)
(o = n), null !== a && (n ? (a.length = n) : (a = null));
@@ -868,14 +881,14 @@ function m(
const t = { params: { allowedValues: l.anyOf[0].enum } };
null === a ? (a = [t]) : a.push(t), o++;
}
- var c = p === o;
- if (((s = s || c), !s)) {
+ var y = p === o;
+ if (((s = s || y), !s)) {
const t = o;
if ('string' != typeof e) {
const t = { params: { type: 'string' } };
null === a ? (a = [t]) : a.push(t), o++;
}
- (c = t === o), (s = s || c);
+ (y = t === o), (s = s || y);
}
if (!s) {
const t = { params: {} };
@@ -919,8 +932,8 @@ function u(
} = {},
) {
let f = null,
- c = 0;
- if (0 === c) {
+ y = 0;
+ if (0 === y) {
if (!s || 'object' != typeof s || Array.isArray(s))
return (u.errors = [{ params: { type: 'object' } }]), !1;
{
@@ -931,13 +944,13 @@ function u(
)
return (u.errors = [{ params: { missingProperty: o } }]), !1;
{
- const o = c;
+ const o = y;
for (const t in s)
if (!n.call(e.properties, t))
return (u.errors = [{ params: { additionalProperty: t } }]), !1;
- if (o === c) {
+ if (o === y) {
if (void 0 !== s.exposes) {
- const t = c;
+ const t = y;
i(s.exposes, {
instancePath: a + '/exposes',
parentData: s,
@@ -945,25 +958,25 @@ function u(
rootData: p,
}) ||
((f = null === f ? i.errors : f.concat(i.errors)),
- (c = f.length));
- var y = t === c;
- } else y = !0;
- if (y) {
+ (y = f.length));
+ var c = t === y;
+ } else c = !0;
+ if (c) {
if (void 0 !== s.filename) {
let e = s.filename;
- const r = c;
- if (c === r) {
+ const r = y;
+ if (y === r) {
if ('string' != typeof e)
return (u.errors = [{ params: { type: 'string' } }]), !1;
if (e.length < 1) return (u.errors = [{ params: {} }]), !1;
if (e.includes('!') || !1 !== t.test(e))
return (u.errors = [{ params: {} }]), !1;
}
- y = r === c;
- } else y = !0;
- if (y) {
+ c = r === y;
+ } else c = !0;
+ if (c) {
if (void 0 !== s.library) {
- const t = c;
+ const t = y;
m(s.library, {
instancePath: a + '/library',
parentData: s,
@@ -971,127 +984,127 @@ function u(
rootData: p,
}) ||
((f = null === f ? m.errors : f.concat(m.errors)),
- (c = f.length)),
- (y = t === c);
- } else y = !0;
- if (y) {
+ (y = f.length)),
+ (c = t === y);
+ } else c = !0;
+ if (c) {
if (void 0 !== s.name) {
let t = s.name;
- const e = c;
- if (c === e) {
+ const e = y;
+ if (y === e) {
if ('string' != typeof t)
return (u.errors = [{ params: { type: 'string' } }]), !1;
if (t.length < 1) return (u.errors = [{ params: {} }]), !1;
}
- y = e === c;
- } else y = !0;
- if (y) {
+ c = e === y;
+ } else c = !0;
+ if (c) {
if (void 0 !== s.runtime) {
let t = s.runtime;
- const e = c,
- n = c;
+ const e = y,
+ n = y;
let a = !1;
- const o = c;
+ const o = y;
if (!1 !== t) {
const t = { params: { allowedValues: r.anyOf[0].enum } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- var g = o === c;
+ var g = o === y;
if (((a = a || g), !a)) {
- const e = c;
- if (c === e)
+ const e = y;
+ if (y === e)
if ('string' == typeof t) {
if (t.length < 1) {
const t = { params: {} };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
} else {
const t = { params: { type: 'string' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- (g = e === c), (a = a || g);
+ (g = e === y), (a = a || g);
}
if (!a) {
const t = { params: {} };
return (
null === f ? (f = [t]) : f.push(t),
- c++,
+ y++,
(u.errors = f),
!1
);
}
- (c = n),
+ (y = n),
null !== f && (n ? (f.length = n) : (f = null)),
- (y = e === c);
- } else y = !0;
- if (y) {
+ (c = e === y);
+ } else c = !0;
+ if (c) {
if (void 0 !== s.shareScope) {
let t = s.shareScope;
- const e = c,
- r = c;
+ const e = y,
+ r = y;
let n = !1;
- const a = c;
- if (c === a)
+ const a = y;
+ if (y === a)
if ('string' == typeof t) {
if (t.length < 1) {
const t = { params: {} };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
} else {
const t = { params: { type: 'string' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- var h = a === c;
+ var h = a === y;
if (((n = n || h), !n)) {
- const e = c;
- if (c === e)
+ const e = y;
+ if (y === e)
if (Array.isArray(t)) {
const e = t.length;
for (let r = 0; r < e; r++) {
let e = t[r];
- const n = c;
- if (c === n)
+ const n = y;
+ if (y === n)
if ('string' == typeof e) {
if (e.length < 1) {
const t = { params: {} };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
} else {
const t = { params: { type: 'string' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- if (n !== c) break;
+ if (n !== y) break;
}
} else {
const t = { params: { type: 'array' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- (h = e === c), (n = n || h);
+ (h = e === y), (n = n || h);
}
if (!n) {
const t = { params: {} };
return (
null === f ? (f = [t]) : f.push(t),
- c++,
+ y++,
(u.errors = f),
!1
);
}
- (c = r),
+ (y = r),
null !== f && (r ? (f.length = r) : (f = null)),
- (y = e === c);
- } else y = !0;
- if (y) {
+ (c = e === y);
+ } else c = !0;
+ if (c) {
if (void 0 !== s.experiments) {
let t = s.experiments;
- const e = c;
- if (c === e) {
+ const e = y;
+ if (y === e) {
if (!t || 'object' != typeof t || Array.isArray(t))
return (
(u.errors = [{ params: { type: 'object' } }]), !1
);
{
- const e = c;
+ const e = y;
for (const e in t)
if (
'asyncStartup' !== e &&
@@ -1104,9 +1117,9 @@ function u(
]),
!1
);
- if (e === c) {
+ if (e === y) {
if (void 0 !== t.asyncStartup) {
- const e = c;
+ const e = y;
if ('boolean' != typeof t.asyncStartup)
return (
(u.errors = [
@@ -1114,11 +1127,11 @@ function u(
]),
!1
);
- var d = e === c;
+ var d = e === y;
} else d = !0;
if (d) {
if (void 0 !== t.externalRuntime) {
- const e = c;
+ const e = y;
if ('boolean' != typeof t.externalRuntime)
return (
(u.errors = [
@@ -1126,11 +1139,11 @@ function u(
]),
!1
);
- d = e === c;
+ d = e === y;
} else d = !0;
if (d)
if (void 0 !== t.provideExternalRuntime) {
- const e = c;
+ const e = y;
if (
'boolean' !=
typeof t.provideExternalRuntime
@@ -1141,28 +1154,28 @@ function u(
]),
!1
);
- d = e === c;
+ d = e === y;
} else d = !0;
}
}
}
}
- y = e === c;
- } else y = !0;
- if (y) {
+ c = e === y;
+ } else c = !0;
+ if (c) {
if (void 0 !== s.dataPrefetch) {
- const t = c;
+ const t = y;
if ('boolean' != typeof s.dataPrefetch)
return (
(u.errors = [{ params: { type: 'boolean' } }]), !1
);
- y = t === c;
- } else y = !0;
- if (y)
+ c = t === y;
+ } else c = !0;
+ if (c)
if (void 0 !== s.runtimePlugins) {
let t = s.runtimePlugins;
- const e = c;
- if (c === e) {
+ const e = y;
+ if (y === e) {
if (!Array.isArray(t))
return (
(u.errors = [{ params: { type: 'array' } }]),
@@ -1172,31 +1185,31 @@ function u(
const e = t.length;
for (let r = 0; r < e; r++) {
let e = t[r];
- const n = c,
- s = c;
+ const n = y,
+ s = y;
let a = !1;
- const o = c;
+ const o = y;
if ('string' != typeof e) {
const t = { params: { type: 'string' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- var b = o === c;
+ var b = o === y;
if (((a = a || b), !a)) {
- const t = c;
- if (c === t)
+ const t = y;
+ if (y === t)
if (Array.isArray(e))
if (e.length > 2) {
const t = { params: { limit: 2 } };
null === f ? (f = [t]) : f.push(t),
- c++;
+ y++;
} else if (e.length < 2) {
const t = { params: { limit: 2 } };
null === f ? (f = [t]) : f.push(t),
- c++;
+ y++;
} else {
const t = e.length;
if (t > 0) {
- const t = c;
+ const t = y;
if ('string' != typeof e[0]) {
const t = {
params: { type: 'string' },
@@ -1204,13 +1217,13 @@ function u(
null === f
? (f = [t])
: f.push(t),
- c++;
+ y++;
}
- var j = t === c;
+ var j = t === y;
}
if (j && t > 1) {
let t = e[1];
- const r = c;
+ const r = y;
if (
!t ||
'object' != typeof t ||
@@ -1222,38 +1235,38 @@ function u(
null === f
? (f = [t])
: f.push(t),
- c++;
+ y++;
}
- j = r === c;
+ j = r === y;
}
}
else {
const t = { params: { type: 'array' } };
- null === f ? (f = [t]) : f.push(t), c++;
+ null === f ? (f = [t]) : f.push(t), y++;
}
- (b = t === c), (a = a || b);
+ (b = t === y), (a = a || b);
}
if (!a) {
const t = { params: {} };
return (
null === f ? (f = [t]) : f.push(t),
- c++,
+ y++,
(u.errors = f),
!1
);
}
if (
- ((c = s),
+ ((y = s),
null !== f &&
(s ? (f.length = s) : (f = null)),
- n !== c)
+ n !== y)
)
break;
}
}
}
- y = e === c;
- } else y = !0;
+ c = e === y;
+ } else c = !0;
}
}
}
@@ -1265,5 +1278,5 @@ function u(
}
}
}
- return (u.errors = f), 0 === c;
+ return (u.errors = f), 0 === y;
}
diff --git a/packages/enhanced/src/schemas/container/ContainerPlugin.json b/packages/enhanced/src/schemas/container/ContainerPlugin.json
index a5bf16d0d7b..855b73ab2e0 100644
--- a/packages/enhanced/src/schemas/container/ContainerPlugin.json
+++ b/packages/enhanced/src/schemas/container/ContainerPlugin.json
@@ -70,6 +70,11 @@
"name": {
"description": "Custom chunk name for the exposed module.",
"type": "string"
+ },
+ "layer": {
+ "description": "Layer in which the exposed module should be placed.",
+ "type": "string",
+ "minLength": 1
}
},
"required": ["import"]
diff --git a/packages/enhanced/src/schemas/container/ContainerPlugin.ts b/packages/enhanced/src/schemas/container/ContainerPlugin.ts
index 6f86e60d6e2..98fce2984ec 100644
--- a/packages/enhanced/src/schemas/container/ContainerPlugin.ts
+++ b/packages/enhanced/src/schemas/container/ContainerPlugin.ts
@@ -83,6 +83,11 @@ export default {
description: 'Custom chunk name for the exposed module.',
type: 'string',
},
+ layer: {
+ description: 'Layer in which the exposed module should be placed.',
+ type: 'string',
+ minLength: 1,
+ },
},
required: ['import'],
},
diff --git a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.check.ts b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.check.ts
index 47c62bf5dac..6fca149564e 100644
--- a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.check.ts
+++ b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.check.ts
@@ -44,6 +44,7 @@ const t = {
],
},
name: { type: 'string' },
+ layer: { type: 'string', minLength: 1 },
},
required: ['import'],
},
@@ -604,7 +605,7 @@ function i(
{
const r = l;
for (const t in e)
- if ('import' !== t && 'name' !== t)
+ if ('import' !== t && 'name' !== t && 'layer' !== t)
return (i.errors = [{ params: { additionalProperty: t } }]), !1;
if (r === l) {
if (void 0 !== e.import) {
@@ -646,13 +647,25 @@ function i(
(l = u), null !== a && (u ? (a.length = u) : (a = null));
var f = n === l;
} else f = !0;
- if (f)
+ if (f) {
if (void 0 !== e.name) {
const t = l;
if ('string' != typeof e.name)
return (i.errors = [{ params: { type: 'string' } }]), !1;
f = t === l;
} else f = !0;
+ if (f)
+ if (void 0 !== e.layer) {
+ let t = e.layer;
+ const r = l;
+ if (l === r) {
+ if ('string' != typeof t)
+ return (i.errors = [{ params: { type: 'string' } }]), !1;
+ if (t.length < 1) return (i.errors = [{ params: {} }]), !1;
+ }
+ f = r === l;
+ } else f = !0;
+ }
}
}
}
diff --git a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.json b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.json
index 4ca4c940283..0bc48dcbebb 100644
--- a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.json
+++ b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.json
@@ -70,6 +70,11 @@
"name": {
"description": "Custom chunk name for the exposed module.",
"type": "string"
+ },
+ "layer": {
+ "description": "Layer in which the exposed module should be placed.",
+ "type": "string",
+ "minLength": 1
}
},
"required": ["import"]
diff --git a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.ts b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.ts
index 4cfba3f43aa..6cfc79071e2 100644
--- a/packages/enhanced/src/schemas/container/ModuleFederationPlugin.ts
+++ b/packages/enhanced/src/schemas/container/ModuleFederationPlugin.ts
@@ -83,6 +83,11 @@ export default {
description: 'Custom chunk name for the exposed module.',
type: 'string',
},
+ layer: {
+ description: 'Layer in which the exposed module should be placed.',
+ type: 'string',
+ minLength: 1,
+ },
},
required: ['import'],
},
diff --git a/packages/error-codes/package.json b/packages/error-codes/package.json
index fc4198ef3fe..56e2302ac3b 100644
--- a/packages/error-codes/package.json
+++ b/packages/error-codes/package.json
@@ -30,14 +30,14 @@
"types": "./dist/index.d.ts",
"exports": {
".": {
+ "types": "./dist/index.d.ts",
"import": {
- "types": "./dist/index.d.mts",
"default": "./dist/index.mjs"
},
"require": {
- "types": "./dist/index.d.ts",
"default": "./dist/index.cjs"
- }
+ },
+ "default": "./dist/index.mjs"
},
"./browser": {
"import": {
diff --git a/packages/managers/src/ContainerManager.ts b/packages/managers/src/ContainerManager.ts
index 7226f395ae7..eb91edb9f6d 100644
--- a/packages/managers/src/ContainerManager.ts
+++ b/packages/managers/src/ContainerManager.ts
@@ -21,7 +21,7 @@ function normalizeExposeModuleName(exposeKey: string): string {
class ContainerManager extends BasicPluginOptionsManager {
private _manifestModuleInfos?: ManifestModuleInfos;
private _parsedOptions?: Array<
- [exposeKey: string, { import: string[]; name?: string }]
+ [exposeKey: string, { import: string[]; name?: string; layer?: string }]
>;
override get enable(): boolean {
@@ -54,10 +54,12 @@ class ContainerManager extends BasicPluginOptionsManager ({
import: Array.isArray(item) ? item : [item],
name: generateExposeFilename(key, false),
+ layer: undefined,
}),
(item, key) => ({
import: Array.isArray(item.import) ? item.import : [item.import],
name: item.name || generateExposeFilename(key, false),
+ layer: item.layer,
}),
);
@@ -97,10 +99,12 @@ class ContainerManager extends BasicPluginOptionsManager ({
import: Array.isArray(item) ? item : [item],
name: generateExposeFilename(key, false),
+ layer: undefined,
}),
(item, key) => ({
import: Array.isArray(item.import) ? item.import : [item.import],
name: item.name || generateExposeFilename(key, false),
+ layer: item.layer,
}),
);
return parsedOptions.reduce(
@@ -185,10 +189,12 @@ class ContainerManager extends BasicPluginOptionsManager ({
import: Array.isArray(item) ? item : [item],
name: undefined,
+ layer: undefined,
}),
(item) => ({
import: Array.isArray(item.import) ? item.import : [item.import],
name: undefined,
+ layer: item.layer,
}),
);
diff --git a/packages/modernjs-v3/package.json b/packages/modernjs-v3/package.json
index a4fc69af427..8f7e9180611 100644
--- a/packages/modernjs-v3/package.json
+++ b/packages/modernjs-v3/package.json
@@ -74,6 +74,16 @@
"import": "./dist/esm/cli/mfRuntimePlugins/inject-node-fetch.mjs",
"require": "./dist/cjs/cli/mfRuntimePlugins/inject-node-fetch.js"
},
+ "./rsc-bridge-runtime-plugin": {
+ "types": "./dist/types/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.d.ts",
+ "import": "./dist/esm/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.mjs",
+ "require": "./dist/cjs/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.js"
+ },
+ "./rsc-bridge-expose": {
+ "types": "./dist/types/runtime/rsc-bridge-expose.d.ts",
+ "import": "./dist/esm/runtime/rsc-bridge-expose.mjs",
+ "require": "./dist/cjs/runtime/rsc-bridge-expose.js"
+ },
"./data-fetch-server-plugin": {
"types": "./dist/types/cli/server/data-fetch-server-plugin.d.ts",
"default": "./dist/cjs/cli/server/data-fetch-server-plugin.js"
@@ -115,6 +125,12 @@
"inject-node-fetch": [
"./dist/types/cli/mfRuntimePlugins/inject-node-fetch.d.ts"
],
+ "rsc-bridge-runtime-plugin": [
+ "./dist/types/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.d.ts"
+ ],
+ "rsc-bridge-expose": [
+ "./dist/types/runtime/rsc-bridge-expose.d.ts"
+ ],
"data-fetch-server-plugin": [
"./dist/types/cli/server/data-fetch-server-plugin.d.ts"
],
@@ -151,6 +167,7 @@
"@rslib/core": "0.18.5",
"@rsbuild/core": "2.0.0-beta.2",
"@modern-js/app-tools": "3.0.1",
+ "@modern-js/server-core": "3.0.1",
"@modern-js/server-runtime": "3.0.1",
"@modern-js/module-tools": "2.70.5",
"@modern-js/runtime": "3.0.1",
@@ -161,6 +178,7 @@
"react-dom": "~18.3.1"
},
"peerDependencies": {
+ "@modern-js/server-core": ">=3.0.0",
"react": ">=17",
"react-dom": ">=17",
"typescript": "^4.9.0 || ^5.0.0",
diff --git a/packages/modernjs-v3/src/cli/configPlugin.contract.spec.ts b/packages/modernjs-v3/src/cli/configPlugin.contract.spec.ts
new file mode 100644
index 00000000000..bf2e3b1e3a6
--- /dev/null
+++ b/packages/modernjs-v3/src/cli/configPlugin.contract.spec.ts
@@ -0,0 +1,14 @@
+import fs from 'node:fs';
+import path from 'node:path';
+import { describe, expect, it } from 'vitest';
+
+describe('config plugin contracts', () => {
+ it('passes target MF config to bundler patching', () => {
+ const configPluginPath = path.resolve(__dirname, './configPlugin.ts');
+ const source = fs.readFileSync(configPluginPath, 'utf-8');
+
+ expect(source).toMatch(
+ /patchBundlerConfig\(\{\s*chain,\s*isServer:\s*!isWeb,\s*modernjsConfig,\s*mfConfig:\s*targetMFConfig,\s*enableSSR,\s*\}\);/s,
+ );
+ });
+});
diff --git a/packages/modernjs-v3/src/cli/configPlugin.spec.ts b/packages/modernjs-v3/src/cli/configPlugin.spec.ts
index a6808b6d8c5..bec54550793 100644
--- a/packages/modernjs-v3/src/cli/configPlugin.spec.ts
+++ b/packages/modernjs-v3/src/cli/configPlugin.spec.ts
@@ -80,4 +80,169 @@ describe('patchMFConfig', async () => {
},
});
});
+
+ it('patchMFConfig: rsc remotes inject runtime bridge plugin', async () => {
+ const patchedConfig = {
+ name: 'rsc-host',
+ remotes: {
+ remote: 'http://localhost:3001/remoteEntry.js',
+ },
+ exposes: {
+ './Widget': './src/widget.ts',
+ },
+ experiments: {
+ rsc: true,
+ asyncStartup: true,
+ },
+ };
+
+ patchMFConfig(patchedConfig as any, true);
+
+ expect(
+ (patchedConfig as any).runtimePlugins.some((runtimePlugin: any) =>
+ /rsc-bridge-runtime-plugin\.(t|j)s$/.test(
+ typeof runtimePlugin === 'string' ? runtimePlugin : runtimePlugin[0],
+ ),
+ ),
+ ).toBe(true);
+ expect(patchedConfig.exposes).toBeDefined();
+ const widgetExposeConfig = (patchedConfig.exposes as any)['./Widget'];
+ expect(widgetExposeConfig.import).toEqual(
+ expect.arrayContaining([
+ expect.stringMatching(/rsc-client-callback-bootstrap\.(mjs|js)$/),
+ './src/widget.ts',
+ ]),
+ );
+ expect((patchedConfig.exposes as any)['./Widget']).toMatchObject({
+ layer: 'react-server-components',
+ });
+ expect(
+ (patchedConfig.exposes as any)['./__rspack_rsc_bridge__'],
+ ).toMatchObject({
+ import: expect.stringMatching(/rsc-bridge-expose\.(t|j)s$/),
+ layer: 'react-server-components',
+ });
+ });
+
+ it('patchMFConfig: rsc client shared config avoids non-default client.browser providers', async () => {
+ const patchedConfig = {
+ name: 'rsc-host',
+ remotes: {
+ remote: 'http://localhost:3001/remoteEntry.js',
+ },
+ experiments: {
+ rsc: true,
+ asyncStartup: true,
+ },
+ shared: [
+ {
+ 'react-server-dom-rspack/client.browser': {
+ import: 'react-server-dom-rspack/client.browser',
+ shareScope: 'default',
+ },
+ },
+ {
+ 'react-server-dom-rspack/client.browser': {
+ import: 'react-server-dom-rspack/client.browser',
+ shareScope: 'ssr',
+ },
+ },
+ {
+ 'react-server-dom-rspack/client.browser': {
+ import: 'react-server-dom-rspack/client.browser',
+ shareScope: 'rsc',
+ },
+ },
+ ],
+ };
+
+ patchMFConfig(patchedConfig as any, false);
+
+ const sharedScopes = patchedConfig.shared as Array<
+ Record
+ >;
+ expect(
+ sharedScopes[0]['react-server-dom-rspack/client.browser'].import,
+ ).toBe('react-server-dom-rspack/client.browser');
+ expect(
+ sharedScopes[1]['react-server-dom-rspack/client.browser'].import,
+ ).toBe(false);
+ expect(
+ sharedScopes[2]['react-server-dom-rspack/client.browser'].import,
+ ).toBe(false);
+ });
+
+ it('patchMFConfig: rsc requires asyncStartup', async () => {
+ const patchedConfig = {
+ name: 'rsc-host',
+ remotes: {
+ remote: 'http://localhost:3001/remoteEntry.js',
+ },
+ experiments: {
+ rsc: true,
+ },
+ };
+
+ expect(() => patchMFConfig(patchedConfig as any, true)).toThrow(
+ /experiments\.rsc requires experiments\.asyncStartup = true/,
+ );
+ });
+
+ it('patchMFConfig: rsc exposes inject bridge expose + bootstrap without runtime bridge plugin', async () => {
+ const patchedConfig = {
+ name: 'rsc-remote',
+ exposes: {
+ './Widget': './src/widget.ts',
+ },
+ experiments: {
+ rsc: true,
+ asyncStartup: true,
+ },
+ };
+
+ patchMFConfig(patchedConfig as any, true);
+
+ expect(
+ (patchedConfig as any).runtimePlugins?.some((runtimePlugin: any) =>
+ /rsc-bridge-runtime-plugin\.(t|j)s$/.test(
+ typeof runtimePlugin === 'string' ? runtimePlugin : runtimePlugin[0],
+ ),
+ ),
+ ).toBe(false);
+ const widgetExposeConfig = (patchedConfig.exposes as any)['./Widget'];
+ expect(widgetExposeConfig.import).toEqual(
+ expect.arrayContaining([
+ expect.stringMatching(/rsc-client-callback-bootstrap\.(mjs|js)$/),
+ './src/widget.ts',
+ ]),
+ );
+ expect(
+ (patchedConfig.exposes as any)['./__rspack_rsc_bridge__'],
+ ).toMatchObject({
+ import: expect.stringMatching(/rsc-bridge-expose\.(t|j)s$/),
+ layer: 'react-server-components',
+ });
+ });
+
+ it('patchMFConfig: non-rsc does not inject internal bridge expose', async () => {
+ const patchedConfig = {
+ name: 'host',
+ remotes: {
+ remote: 'http://localhost:3001/remoteEntry.js',
+ },
+ exposes: {
+ './Widget': './src/widget.ts',
+ },
+ experiments: {
+ asyncStartup: true,
+ },
+ };
+
+ patchMFConfig(patchedConfig as any, true);
+
+ expect((patchedConfig.exposes as any)['./Widget']).toBe('./src/widget.ts');
+ expect(
+ (patchedConfig.exposes as any)['./__rspack_rsc_bridge__'],
+ ).toBeUndefined();
+ });
});
diff --git a/packages/modernjs-v3/src/cli/configPlugin.ts b/packages/modernjs-v3/src/cli/configPlugin.ts
index 0583cdbfadc..5f4cf1267f1 100644
--- a/packages/modernjs-v3/src/cli/configPlugin.ts
+++ b/packages/modernjs-v3/src/cli/configPlugin.ts
@@ -1,24 +1,27 @@
import fs from 'fs';
import path from 'path';
-import { getIPV4, isWebTarget, skipByTarget } from './utils';
-import { moduleFederationPlugin, encodeName } from '@module-federation/sdk';
-import { PluginOptions } from '../types';
-import { LOCALHOST, PLUGIN_IDENTIFIER } from '../constant';
import {
- autoDeleteSplitChunkCacheGroups,
addDataFetchExposes,
+ autoDeleteSplitChunkCacheGroups,
} from '@module-federation/rsbuild-plugin/utils';
+import {
+ encodeName,
+ type moduleFederationPlugin,
+} from '@module-federation/sdk';
+import { PLUGIN_IDENTIFIER } from '../constant';
import logger from '../logger';
+import type { PluginOptions } from '../types';
+import { isWebTarget, skipByTarget } from './utils';
import { isDev } from './utils';
-import type { InternalModernPluginOptions } from '../types';
import type {
AppTools,
- Rspack,
AppUserConfig,
CliPlugin,
+ Rspack,
} from '@modern-js/app-tools';
import type { BundlerChainConfig } from '../interfaces/bundler';
+import type { InternalModernPluginOptions } from '../types';
declare global {
namespace NodeJS {
@@ -30,8 +33,6 @@ declare global {
const defaultPath = path.resolve(process.cwd(), 'module-federation.config.ts');
-export type ConfigType = Rspack.Configuration;
-
type RuntimePluginEntry = NonNullable<
moduleFederationPlugin.ModuleFederationPluginOptions['runtimePlugins']
>[number];
@@ -89,6 +90,56 @@ const resolveNodeRecordRemoteHashPlugin = (): string =>
'dist/src/recordDynamicRemoteEntryHashPlugin.js',
);
+const RSC_LAYER = 'react-server-components';
+const RSC_BRIDGE_EXPOSE = './__rspack_rsc_bridge__';
+const RSC_CLIENT_BROWSER_SHARED_KEY = 'react-server-dom-rspack/client.browser';
+
+const resolveFirstExistingPath = (
+ candidatePaths: string[],
+ fallbackPath: string,
+) =>
+ candidatePaths.find((candidatePath) => fs.existsSync(candidatePath)) ||
+ fallbackPath;
+
+const RSC_BRIDGE_RUNTIME_PLUGIN = resolveFirstExistingPath(
+ [
+ path.resolve(__dirname, './mfRuntimePlugins/rsc-bridge-runtime-plugin.ts'),
+ path.resolve(__dirname, './mfRuntimePlugins/rsc-bridge-runtime-plugin.js'),
+ path.resolve(
+ __dirname,
+ '../esm/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.mjs',
+ ),
+ ],
+ require.resolve('@module-federation/modern-js-v3/rsc-bridge-runtime-plugin'),
+);
+
+const RSC_BRIDGE_EXPOSE_MODULE = resolveFirstExistingPath(
+ [
+ path.resolve(__dirname, '../runtime/rsc-bridge-expose.ts'),
+ path.resolve(__dirname, '../runtime/rsc-bridge-expose.js'),
+ path.resolve(__dirname, '../esm/runtime/rsc-bridge-expose.mjs'),
+ ],
+ require.resolve('@module-federation/modern-js-v3/rsc-bridge-expose'),
+);
+
+const RSC_CLIENT_CALLBACK_BOOTSTRAP_MODULE = resolveFirstExistingPath(
+ [
+ path.resolve(__dirname, '../runtime/rsc-client-callback-bootstrap.js'),
+ path.resolve(__dirname, '../esm/runtime/rsc-client-callback-bootstrap.mjs'),
+ path.resolve(
+ path.dirname(RSC_BRIDGE_EXPOSE_MODULE),
+ 'rsc-client-callback-bootstrap.js',
+ ),
+ path.resolve(
+ path.dirname(RSC_BRIDGE_EXPOSE_MODULE),
+ 'rsc-client-callback-bootstrap.mjs',
+ ),
+ ],
+ path.resolve(__dirname, '../runtime/rsc-client-callback-bootstrap.js'),
+);
+
+export type ConfigType = Rspack.Configuration;
+
export function setEnv(enableSSR: boolean) {
if (enableSSR) {
process.env['MF_SSR_PRJ'] = 'true';
@@ -178,12 +229,218 @@ const patchDTSConfig = (
}
};
+const hasRemotes = (
+ remotes: moduleFederationPlugin.ModuleFederationPluginOptions['remotes'],
+): boolean => {
+ if (!remotes) {
+ return false;
+ }
+ if (Array.isArray(remotes)) {
+ return remotes.length > 0;
+ }
+ if (typeof remotes === 'string') {
+ return (remotes as string).length > 0;
+ }
+ return Object.keys(remotes as Record).length > 0;
+};
+
+const hasExposes = (
+ exposes: moduleFederationPlugin.ModuleFederationPluginOptions['exposes'],
+) => {
+ if (!exposes) {
+ return false;
+ }
+ if (Array.isArray(exposes)) {
+ return exposes.length > 0;
+ }
+ return Object.keys(exposes).length > 0;
+};
+
+const isRscMfEnabled = (
+ mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
+) => Boolean((mfConfig.experiments as { rsc?: boolean } | undefined)?.rsc);
+
+const normalizeExposeConfig = (
+ exposeConfig: moduleFederationPlugin.ExposesObject[string],
+) => {
+ if (typeof exposeConfig === 'string' || Array.isArray(exposeConfig)) {
+ return {
+ import: exposeConfig,
+ };
+ }
+
+ if (
+ exposeConfig &&
+ typeof exposeConfig === 'object' &&
+ 'import' in exposeConfig
+ ) {
+ return {
+ ...(exposeConfig as unknown as Record),
+ import: (exposeConfig as { import: string | string[] }).import,
+ };
+ }
+
+ return {
+ import: exposeConfig as string,
+ };
+};
+
+const setRscExposeConfig = (
+ mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
+) => {
+ if (!mfConfig.exposes) {
+ return;
+ }
+
+ const normalizedExposes: moduleFederationPlugin.ExposesObject = {};
+
+ const appendExpose = (
+ exposeKey: string,
+ exposeConfig: moduleFederationPlugin.ExposesObject[string],
+ ) => {
+ const normalizedConfig = normalizeExposeConfig(exposeConfig);
+ const importList = Array.isArray(normalizedConfig.import)
+ ? [...normalizedConfig.import]
+ : [normalizedConfig.import];
+ const normalizedImportList =
+ exposeKey === RSC_BRIDGE_EXPOSE
+ ? importList
+ : [
+ RSC_CLIENT_CALLBACK_BOOTSTRAP_MODULE,
+ ...importList.filter(
+ (importPath) =>
+ importPath !== RSC_CLIENT_CALLBACK_BOOTSTRAP_MODULE,
+ ),
+ ];
+ const normalizedImport =
+ normalizedImportList.length === 1
+ ? normalizedImportList[0]
+ : normalizedImportList;
+ normalizedExposes[exposeKey] = {
+ ...normalizedConfig,
+ import: normalizedImport,
+ layer: RSC_LAYER,
+ } as moduleFederationPlugin.ExposesConfig;
+ };
+
+ if (Array.isArray(mfConfig.exposes)) {
+ for (const exposeItem of mfConfig.exposes) {
+ if (typeof exposeItem === 'string') {
+ appendExpose(exposeItem, exposeItem);
+ continue;
+ }
+ for (const [exposeKey, exposeConfig] of Object.entries(exposeItem)) {
+ appendExpose(exposeKey, exposeConfig);
+ }
+ }
+ } else {
+ for (const [exposeKey, exposeConfig] of Object.entries(mfConfig.exposes)) {
+ appendExpose(exposeKey, exposeConfig);
+ }
+ }
+
+ if (
+ !Object.prototype.hasOwnProperty.call(normalizedExposes, RSC_BRIDGE_EXPOSE)
+ ) {
+ normalizedExposes[RSC_BRIDGE_EXPOSE] = {
+ import: RSC_BRIDGE_EXPOSE_MODULE,
+ layer: RSC_LAYER,
+ } as moduleFederationPlugin.ExposesConfig;
+ }
+
+ mfConfig.exposes = normalizedExposes;
+};
+
+const assertRscMfConfig = ({
+ mfConfig,
+ isServer,
+ runtimePlugins,
+}: {
+ mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions;
+ isServer: boolean;
+ runtimePlugins: RuntimePluginEntry[];
+}) => {
+ if (!isRscMfEnabled(mfConfig)) {
+ return;
+ }
+
+ const asyncStartupEnabled =
+ (mfConfig.experiments as { asyncStartup?: boolean } | undefined)
+ ?.asyncStartup === true;
+ if (!asyncStartupEnabled) {
+ throw new Error(
+ `${PLUGIN_IDENTIFIER} experiments.rsc requires experiments.asyncStartup = true`,
+ );
+ }
+
+ if (!isServer) {
+ return;
+ }
+
+ const nodeRuntimePluginPath = require.resolve(
+ '@module-federation/node/runtimePlugin',
+ );
+ const hasNodeRuntimePlugin = runtimePlugins.some((runtimePlugin) => {
+ const runtimePluginPath =
+ typeof runtimePlugin === 'string' ? runtimePlugin : runtimePlugin[0];
+ return runtimePluginPath === nodeRuntimePluginPath;
+ });
+
+ if (!hasNodeRuntimePlugin) {
+ throw new Error(
+ `${PLUGIN_IDENTIFIER} experiments.rsc requires @module-federation/node/runtimePlugin in runtimePlugins`,
+ );
+ }
+};
+
+const patchRscClientBrowserSharedConfig = (
+ mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
+ isServer: boolean,
+) => {
+ if (isServer || !mfConfig.shared) {
+ return;
+ }
+
+ const patchSharedRecord = (sharedRecord: Record) => {
+ const clientBrowserShared = sharedRecord[RSC_CLIENT_BROWSER_SHARED_KEY] as
+ | Record
+ | undefined;
+ if (!clientBrowserShared || Array.isArray(clientBrowserShared)) {
+ return;
+ }
+ const shareScope = clientBrowserShared.shareScope;
+ if (typeof shareScope === 'string' && shareScope !== 'default') {
+ clientBrowserShared.import = false;
+ }
+ };
+
+ if (Array.isArray(mfConfig.shared)) {
+ for (const sharedConfig of mfConfig.shared) {
+ if (!sharedConfig || typeof sharedConfig !== 'object') {
+ continue;
+ }
+ patchSharedRecord(sharedConfig as Record);
+ }
+ return;
+ }
+
+ if (typeof mfConfig.shared === 'object') {
+ patchSharedRecord(mfConfig.shared as Record);
+ }
+};
+
export const patchMFConfig = (
mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
isServer: boolean,
) => {
+ const rscEnabled = isRscMfEnabled(mfConfig);
addDataFetchExposes(mfConfig.exposes, isServer);
+ if (rscEnabled) {
+ setRscExposeConfig(mfConfig);
+ patchRscClientBrowserSharedConfig(mfConfig, isServer);
+ }
+
if (mfConfig.remoteType === undefined) {
mfConfig.remoteType = 'script';
}
@@ -200,6 +457,9 @@ export const patchMFConfig = (
injectRuntimePlugins(resolveSharedStrategyPlugin(), runtimePlugins);
+ if (rscEnabled && hasRemotes(mfConfig.remotes)) {
+ injectRuntimePlugins(RSC_BRIDGE_RUNTIME_PLUGIN, runtimePlugins);
+ }
if (isServer) {
injectRuntimePlugins(resolveNodeRuntimePlugin(), runtimePlugins);
if (isDev()) {
@@ -223,6 +483,12 @@ export const patchMFConfig = (
}
}
+ assertRscMfConfig({
+ mfConfig,
+ isServer,
+ runtimePlugins,
+ });
+
mfConfig.runtimePlugins = runtimePlugins;
if (!isServer) {
@@ -254,6 +520,195 @@ function patchIgnoreWarning(chain: BundlerChainConfig) {
chain.ignoreWarnings(ignoreWarnings);
}
+const patchProjectNodeModulesResolution = (chain: BundlerChainConfig) => {
+ const projectNodeModulesPath = path.resolve(process.cwd(), 'node_modules');
+ if (!fs.existsSync(projectNodeModulesPath)) {
+ return;
+ }
+
+ const resolveModules = chain.resolve.modules as {
+ values?: () => string[];
+ clear: () => unknown;
+ add: (value: string) => unknown;
+ };
+ resolveModules.clear();
+ resolveModules.add(projectNodeModulesPath);
+ resolveModules.add('node_modules');
+};
+
+const patchServerOnlyAlias = (chain: BundlerChainConfig) => {
+ const serverOnlyEmptyPath = path.resolve(
+ process.cwd(),
+ 'node_modules/server-only/empty.js',
+ );
+ if (!fs.existsSync(serverOnlyEmptyPath)) {
+ return;
+ }
+
+ const aliasChain = chain.resolve.alias as {
+ has?: (key: string) => boolean;
+ set: (key: string, value: string) => unknown;
+ };
+ const hasServerOnlyAlias =
+ typeof aliasChain.has === 'function'
+ ? aliasChain.has('server-only$')
+ : false;
+ if (!hasServerOnlyAlias) {
+ aliasChain.set('server-only$', serverOnlyEmptyPath);
+ }
+};
+
+const resolveProjectDependency = (request: string) => {
+ try {
+ return require.resolve(request, { paths: [process.cwd()] });
+ } catch {
+ try {
+ return require.resolve(request);
+ } catch {
+ return undefined;
+ }
+ }
+};
+
+const getExposeImports = (
+ exposeConfig: moduleFederationPlugin.ExposesObject[string],
+): string[] => {
+ if (typeof exposeConfig === 'string') {
+ return [exposeConfig];
+ }
+ if (Array.isArray(exposeConfig)) {
+ return exposeConfig.filter(
+ (importPath): importPath is string => typeof importPath === 'string',
+ );
+ }
+ if (
+ exposeConfig &&
+ typeof exposeConfig === 'object' &&
+ 'import' in exposeConfig
+ ) {
+ const exposeImport = (exposeConfig as { import?: unknown }).import;
+ if (typeof exposeImport === 'string') {
+ return [exposeImport];
+ }
+ if (Array.isArray(exposeImport)) {
+ return exposeImport.filter(
+ (importPath): importPath is string => typeof importPath === 'string',
+ );
+ }
+ }
+ return [];
+};
+
+const collectExposeImportDirectories = (
+ exposes: moduleFederationPlugin.ModuleFederationPluginOptions['exposes'],
+) => {
+ if (!exposes) {
+ return [];
+ }
+
+ const exposeEntries = Array.isArray(exposes)
+ ? exposes.flatMap((exposeItem) =>
+ typeof exposeItem === 'string'
+ ? [[exposeItem, exposeItem] as const]
+ : (Object.entries(exposeItem || {}) as Array<
+ readonly [string, moduleFederationPlugin.ExposesObject[string]]
+ >),
+ )
+ : (Object.entries(exposes) as Array<
+ readonly [string, moduleFederationPlugin.ExposesObject[string]]
+ >);
+
+ const directories = new Set();
+ for (const [exposeKey, exposeConfig] of exposeEntries) {
+ if (exposeKey === RSC_BRIDGE_EXPOSE) {
+ continue;
+ }
+ for (const importPath of getExposeImports(exposeConfig)) {
+ if (!importPath || !importPath.startsWith('.')) {
+ continue;
+ }
+ directories.add(path.dirname(path.resolve(process.cwd(), importPath)));
+ }
+ }
+
+ return Array.from(directories);
+};
+
+const patchRscRemoteComponentLayer = (
+ chain: BundlerChainConfig,
+ mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
+) => {
+ const includeDirectories = collectExposeImportDirectories(mfConfig.exposes);
+ if (includeDirectories.length === 0) {
+ return;
+ }
+
+ const ruleChain = chain.module
+ .rule('rsc-mf-remote-components-layer')
+ .test(/\.[cm]?[jt]sx?$/);
+
+ for (const includeDirectory of includeDirectories) {
+ ruleChain.include.add(includeDirectory);
+ }
+
+ ruleChain.layer(RSC_LAYER);
+};
+
+const patchRscServerJsxRuntimeResolution = (chain: BundlerChainConfig) => {
+ const pluginId = 'rsc-mf-react-server-jsx-runtime';
+ if (chain.plugins.has(pluginId)) {
+ return;
+ }
+
+ const reactPackagePath = resolveProjectDependency('react/package.json');
+ if (!reactPackagePath) {
+ return;
+ }
+ const reactDir = path.dirname(reactPackagePath);
+ const reactJsxRuntimeServerPath = path.join(
+ reactDir,
+ 'jsx-runtime.react-server.js',
+ );
+ const reactJsxDevRuntimeServerPath = path.join(
+ reactDir,
+ 'jsx-dev-runtime.react-server.js',
+ );
+
+ if (
+ !fs.existsSync(reactJsxRuntimeServerPath) ||
+ !fs.existsSync(reactJsxDevRuntimeServerPath)
+ ) {
+ return;
+ }
+
+ const { NormalModuleReplacementPlugin } = require('@rspack/core') as {
+ NormalModuleReplacementPlugin: new (...args: unknown[]) => unknown;
+ };
+
+ chain.plugin(pluginId).use(NormalModuleReplacementPlugin, [
+ /^react\/jsx(?:-dev)?-runtime$/,
+ (resource: {
+ request?: string;
+ contextInfo?: {
+ issuerLayer?: string;
+ };
+ }) => {
+ if (resource.contextInfo?.issuerLayer !== RSC_LAYER) {
+ return;
+ }
+
+ if (resource.request === 'react/jsx-runtime') {
+ resource.request = reactJsxRuntimeServerPath;
+ } else if (resource.request === 'react/jsx-dev-runtime') {
+ resource.request = reactJsxDevRuntimeServerPath;
+ }
+ },
+ ]);
+};
+
+const normalizePublicPath = (publicPath: string) =>
+ publicPath.endsWith('/') ? publicPath.slice(0, -1) : publicPath;
+
export function addMyTypes2Ignored(
chain: BundlerChainConfig,
mfConfig: moduleFederationPlugin.ModuleFederationPluginOptions,
@@ -314,11 +769,37 @@ export function patchBundlerConfig(options: {
enableSSR: boolean;
}) {
const { chain, modernjsConfig, isServer, mfConfig, enableSSR } = options;
+ const rscMfEnabled = isRscMfEnabled(mfConfig);
chain.optimization.delete('runtimeChunk');
patchIgnoreWarning(chain);
+ if (rscMfEnabled && isServer) {
+ chain.resolve.conditionNames.add('react-server');
+ }
+
+ if (rscMfEnabled && hasExposes(mfConfig.exposes)) {
+ patchProjectNodeModulesResolution(chain);
+ patchServerOnlyAlias(chain);
+
+ const assetPrefix = modernjsConfig.output?.assetPrefix;
+ if (typeof assetPrefix === 'string' && assetPrefix.trim()) {
+ const normalizedAssetPrefix = normalizePublicPath(assetPrefix.trim());
+ chain.output.publicPath(
+ isServer
+ ? `${normalizedAssetPrefix}/bundles/`
+ : `${normalizedAssetPrefix}/`,
+ );
+ }
+ if (!isServer) {
+ chain.optimization.splitChunks(false);
+ } else {
+ patchRscRemoteComponentLayer(chain, mfConfig);
+ patchRscServerJsxRuntimeResolution(chain);
+ }
+ }
+
if (!chain.output.get('chunkLoadingGlobal')) {
chain.output.chunkLoadingGlobal(`chunk_${mfConfig.name}`);
}
@@ -398,6 +879,7 @@ export const moduleFederationConfigPlugin = (
const enableSSR = Boolean(
userConfig.userConfig?.ssr ?? Boolean(modernjsConfig?.server?.ssr),
);
+ const enableRsc = Boolean(modernjsConfig?.server?.rsc);
api.modifyBundlerChain((chain) => {
const target = chain.get('target');
@@ -414,14 +896,14 @@ export const moduleFederationConfigPlugin = (
chain,
isServer: !isWeb,
modernjsConfig,
- mfConfig,
+ mfConfig: targetMFConfig,
enableSSR,
});
if (isWeb) {
userConfig.distOutputDir =
chain.output.get('path') || path.resolve(process.cwd(), 'dist');
- } else if (enableSSR) {
+ } else if (enableSSR && !enableRsc) {
userConfig.userConfig ||= {};
userConfig.userConfig.ssr ||= {};
if (userConfig.userConfig.ssr === true) {
@@ -480,7 +962,8 @@ export const moduleFederationConfigPlugin = (
},
},
source: {
- enableAsyncEntry: modernjsConfig.source?.enableAsyncEntry ?? true,
+ enableAsyncEntry:
+ modernjsConfig.source?.enableAsyncEntry ?? !enableRsc,
},
dev: {
assetPrefix: modernjsConfig?.dev?.assetPrefix
diff --git a/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.spec.ts b/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.spec.ts
new file mode 100644
index 00000000000..e4356dec85f
--- /dev/null
+++ b/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.spec.ts
@@ -0,0 +1,490 @@
+import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest';
+import rscBridgeRuntimePlugin from './rsc-bridge-runtime-plugin';
+
+type ManifestLike = {
+ serverManifest?: Record;
+ clientManifest?: Record;
+ serverConsumerModuleMap?: Record;
+};
+
+type WebpackRequireRuntime = {
+ m?: Record void>;
+ c?: Record;
+ rscM?: ManifestLike;
+};
+
+const ACTION_REMAP_GLOBAL_KEY = '__MODERN_RSC_MF_ACTION_ID_MAP__';
+const PROXY_MODULE_PREFIX = '__modernjs_mf_rsc_action_proxy__:';
+type FederationState = {
+ [ACTION_REMAP_GLOBAL_KEY]?: Record;
+};
+
+const createWebpackRequireRuntime = (): WebpackRequireRuntime => ({
+ m: {},
+ c: {},
+ rscM: {
+ serverManifest: {},
+ clientManifest: {},
+ serverConsumerModuleMap: {},
+ },
+});
+let runtimeRequire: WebpackRequireRuntime;
+
+const getFederationState = () =>
+ global as typeof global & {
+ __FEDERATION__?: FederationState;
+ fetch?: unknown;
+ };
+
+const getActionRemapMap = () =>
+ getFederationState().__FEDERATION__?.[ACTION_REMAP_GLOBAL_KEY] || {};
+
+describe('rsc-bridge-runtime-plugin', () => {
+ beforeEach(() => {
+ vi.useFakeTimers();
+ runtimeRequire = createWebpackRequireRuntime();
+ vi.stubGlobal('__webpack_require__', runtimeRequire);
+ vi.stubGlobal('__FEDERATION__', {});
+ vi.stubGlobal('window', {
+ __MODERN_JS_ENTRY_NAME: 'server-component-root',
+ });
+ delete getFederationState().__FEDERATION__?.[ACTION_REMAP_GLOBAL_KEY];
+ });
+
+ afterEach(() => {
+ vi.clearAllTimers();
+ vi.useRealTimers();
+ vi.unstubAllGlobals();
+ delete getFederationState().fetch;
+ delete getFederationState().__FEDERATION__?.[ACTION_REMAP_GLOBAL_KEY];
+ });
+
+ it('merges remote manifest, registers action remap, and installs proxy dispatcher', async () => {
+ const executeAction = vi.fn(async (id: string, args: unknown[]) => ({
+ id,
+ args,
+ }));
+
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({
+ clientManifest: {
+ clientRef: {
+ id: '123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ serverConsumerModuleMap: {
+ '123': {
+ '*': {
+ id: '123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ },
+ serverManifest: {
+ rawActionId: {
+ async: true,
+ },
+ },
+ }),
+ executeAction,
+ }));
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemote' },
+ options: { name: 'rscHost' },
+ origin: {
+ loadRemote,
+ },
+ });
+
+ expect(loadRemote).toHaveBeenCalledTimes(1);
+ expect(loadRemote).toHaveBeenCalledWith('rscRemote/__rspack_rsc_bridge__');
+
+ const webpackRequire = runtimeRequire;
+ const hostManifest = webpackRequire.rscM!;
+
+ expect(
+ hostManifest.clientManifest?.['remote-module:rscRemote:clientRef']?.id,
+ ).toBe('remote-module:rscRemote:123');
+ expect(hostManifest.serverConsumerModuleMap).toHaveProperty(
+ 'remote-module:rscRemote:123',
+ );
+ expect(
+ hostManifest.serverConsumerModuleMap?.['remote-module:rscRemote:123']?.[
+ '*'
+ ]?.id,
+ ).toBe('remote-module:rscRemote:123');
+
+ const prefixedActionId = 'remote:rscRemote:rawActionId';
+ const proxyModuleId = `${PROXY_MODULE_PREFIX}rscRemote`;
+ expect(hostManifest.serverManifest?.[prefixedActionId]).toMatchObject({
+ id: proxyModuleId,
+ name: prefixedActionId,
+ });
+ expect(getActionRemapMap().rawActionId).toBe(prefixedActionId);
+
+ const proxyFactory = webpackRequire.m?.[proxyModuleId];
+ expect(typeof proxyFactory).toBe('function');
+
+ const proxyModule = { exports: {} as Record };
+ proxyFactory?.(proxyModule);
+ const result = await proxyModule.exports[prefixedActionId]('payload');
+
+ expect(executeAction).toHaveBeenCalledWith('rawActionId', ['payload']);
+ expect(result).toEqual({
+ id: 'rawActionId',
+ args: ['payload'],
+ });
+ });
+
+ it('awaits async bridge manifest responses before merge', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemote' },
+ options: { name: 'rscHost' },
+ origin: {
+ loadRemote: vi.fn(async () => ({
+ getManifest: async () => ({
+ serverManifest: {
+ asyncRawAction: {
+ async: true,
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ })),
+ },
+ } as any);
+
+ const webpackRequire = runtimeRequire;
+ expect(webpackRequire.rscM?.serverManifest).toHaveProperty(
+ 'remote:rscRemote:asyncRawAction',
+ );
+ expect(getActionRemapMap().asyncRawAction).toBe(
+ 'remote:rscRemote:asyncRawAction',
+ );
+ });
+
+ it('namespaces clientManifest keys per alias for same remote export key', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+
+ const loadRemote = vi.fn(async (request: string) => {
+ if (request.startsWith('rscRemoteA/')) {
+ return {
+ getManifest: () => ({
+ clientManifest: {
+ sharedClientRef: {
+ id: '123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ };
+ }
+
+ return {
+ getManifest: () => ({
+ clientManifest: {
+ sharedClientRef: {
+ id: '123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ };
+ });
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemoteA' },
+ options: { name: 'rscHost' },
+ origin: { loadRemote },
+ } as any);
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemoteB' },
+ options: { name: 'rscHost' },
+ origin: { loadRemote },
+ } as any);
+
+ const webpackRequire = runtimeRequire;
+
+ expect(webpackRequire.rscM?.clientManifest).toHaveProperty(
+ 'remote-module:rscRemoteA:sharedClientRef',
+ );
+ expect(webpackRequire.rscM?.clientManifest).toHaveProperty(
+ 'remote-module:rscRemoteB:sharedClientRef',
+ );
+ });
+
+ it('loads and merges each remote alias once', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({
+ serverManifest: {
+ one: {
+ async: true,
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ }));
+
+ const args = {
+ remote: { alias: 'rscRemote' },
+ options: { name: 'rscHost' },
+ origin: {
+ loadRemote,
+ },
+ };
+
+ await plugin.onLoad?.(args as any);
+ await plugin.onLoad?.(args as any);
+
+ expect(loadRemote).toHaveBeenCalledTimes(1);
+ });
+
+ it('falls back to federation.instance when origin is unavailable', async () => {
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({
+ serverManifest: {
+ rawActionId: {
+ async: true,
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ }));
+
+ const webpackRequire = runtimeRequire;
+ (
+ webpackRequire as WebpackRequireRuntime & {
+ federation?: {
+ instance?: { loadRemote?: (request: string) => Promise };
+ };
+ }
+ ).federation = {
+ instance: {
+ loadRemote,
+ },
+ };
+
+ const plugin = rscBridgeRuntimePlugin();
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemote' },
+ options: { name: 'rscHost' },
+ } as any);
+
+ expect(loadRemote).toHaveBeenCalledWith('rscRemote/__rspack_rsc_bridge__');
+ expect(getActionRemapMap().rawActionId).toBe(
+ 'remote:rscRemote:rawActionId',
+ );
+ });
+
+ it('throws deterministic conflict errors when manifests disagree', async () => {
+ const webpackRequire = runtimeRequire;
+ webpackRequire.rscM = {
+ serverManifest: {},
+ clientManifest: {
+ 'remote-module:rscRemote:sharedKey': {
+ id: 'remote-module:existingRemote:123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ serverConsumerModuleMap: {},
+ };
+
+ const plugin = rscBridgeRuntimePlugin();
+
+ await expect(
+ plugin.onLoad?.({
+ remote: { alias: 'rscRemote' },
+ options: { name: 'rscHost' },
+ origin: {
+ loadRemote: vi.fn(async () => ({
+ getManifest: () => ({
+ clientManifest: {
+ sharedKey: {
+ id: '123',
+ name: 'default',
+ chunks: [],
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ })),
+ },
+ } as any),
+ ).rejects.toThrow(/clientManifest conflict/);
+ });
+
+ it('marks raw action remaps as false when aliases collide', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+
+ const loadRemote = vi.fn(async (request: string) => {
+ if (request.startsWith('rscRemoteA/')) {
+ return {
+ getManifest: () => ({
+ serverManifest: {
+ sameRawId: {
+ async: true,
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ };
+ }
+
+ return {
+ getManifest: () => ({
+ serverManifest: {
+ sameRawId: {
+ async: true,
+ },
+ },
+ }),
+ executeAction: vi.fn(async () => undefined),
+ };
+ });
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemoteA' },
+ options: { name: 'rscHost' },
+ origin: { loadRemote },
+ } as any);
+
+ await plugin.onLoad?.({
+ remote: { alias: 'rscRemoteB' },
+ options: { name: 'rscHost' },
+ origin: { loadRemote },
+ } as any);
+
+ expect(getActionRemapMap().sameRawId).toBe(false);
+ });
+
+ it('normalizes missing ssrPublicPath on resolved remote snapshots', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({}),
+ executeAction: vi.fn(async () => undefined),
+ }));
+ const args: any = {
+ remote: { alias: 'rscRemote' },
+ remoteInfo: {
+ publicPath: 'http://127.0.0.1:3008/bundles/',
+ remoteEntry: {
+ name: 'static/remoteEntry.js',
+ },
+ },
+ origin: {
+ loadRemote,
+ },
+ };
+
+ await plugin.afterResolve?.(args);
+
+ expect(args.remoteInfo.ssrPublicPath).toBe(
+ 'http://127.0.0.1:3008/bundles/',
+ );
+ expect(args.remoteInfo.remoteEntry.path).toBe('');
+ });
+
+ it('rewrites node bridge loads to bundles/.js when ssr entry is missing', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({}),
+ executeAction: vi.fn(async () => undefined),
+ }));
+ const args: any = {
+ remote: { alias: 'rscRemote' },
+ remoteInfo: {
+ entry: undefined,
+ },
+ remoteSnapshot: {
+ name: 'rscRemote',
+ publicPath: 'http://127.0.0.1:3008/',
+ remoteEntry: {
+ name: 'static/remoteEntry.js',
+ },
+ },
+ origin: {
+ loadRemote,
+ },
+ };
+
+ await plugin.afterResolve?.(args);
+
+ expect(args.remoteInfo.entry).toBe(
+ 'http://127.0.0.1:3008/bundles/static/remoteEntry.js',
+ );
+ });
+
+ it('rewrites existing client remoteEntry URLs to node bundles entry', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({}),
+ executeAction: vi.fn(async () => undefined),
+ }));
+ const args: any = {
+ remote: { alias: 'rscRemote' },
+ remoteInfo: {
+ entry: 'http://127.0.0.1:3008/static/remoteEntry.js',
+ },
+ remoteSnapshot: {
+ name: 'rscRemote',
+ publicPath: 'http://127.0.0.1:3008/',
+ remoteEntry: {
+ name: 'static/remoteEntry.js',
+ },
+ },
+ origin: {
+ loadRemote,
+ },
+ };
+
+ await plugin.afterResolve?.(args);
+
+ expect(args.remoteInfo.entry).toBe(
+ 'http://127.0.0.1:3008/bundles/static/remoteEntry.js',
+ );
+ });
+
+ it('avoids duplicate bundles segment when ssr publicPath already includes bundles', async () => {
+ const plugin = rscBridgeRuntimePlugin();
+ const loadRemote = vi.fn(async () => ({
+ getManifest: () => ({}),
+ executeAction: vi.fn(async () => undefined),
+ }));
+ const args: any = {
+ remote: { alias: 'rscRemote' },
+ remoteInfo: {
+ entry: undefined,
+ },
+ remoteSnapshot: {
+ publicPath: 'http://127.0.0.1:3008/bundles/',
+ remoteEntry: {
+ name: 'static/remoteEntry.js',
+ },
+ },
+ origin: {
+ loadRemote,
+ },
+ };
+
+ await plugin.afterResolve?.(args);
+
+ expect(args.remoteInfo.entry).toBe(
+ 'http://127.0.0.1:3008/bundles/static/remoteEntry.js',
+ );
+ });
+});
diff --git a/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.ts b/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.ts
new file mode 100644
index 00000000000..c35a3a1e337
--- /dev/null
+++ b/packages/modernjs-v3/src/cli/mfRuntimePlugins/rsc-bridge-runtime-plugin.ts
@@ -0,0 +1,765 @@
+import type { ModuleFederationRuntimePlugin } from '@module-federation/enhanced/runtime';
+
+const RSC_BRIDGE_EXPOSE = '__rspack_rsc_bridge__';
+const ACTION_PREFIX = 'remote:';
+const MODULE_PREFIX = 'remote-module:';
+const ACTION_REMAP_GLOBAL_KEY = '__MODERN_RSC_MF_ACTION_ID_MAP__';
+const PROXY_MODULE_PREFIX = '__modernjs_mf_rsc_action_proxy__:';
+
+type ManifestLike = {
+ serverManifest?: Record;
+ clientManifest?: Record;
+ serverConsumerModuleMap?: Record;
+};
+
+type BridgeModule = {
+ getManifest?: () => ManifestLike;
+ executeAction?: (actionId: string, args: unknown[]) => Promise;
+};
+
+type ActionMapRecord = Record;
+type ActionRemapMap = Record;
+type FederationState = {
+ [ACTION_REMAP_GLOBAL_KEY]?: ActionRemapMap;
+};
+type WebpackRequireRuntime = {
+ m?: Record void>;
+ c?: Record;
+ rscM?: ManifestLike;
+ federation?: {
+ instance?: {
+ loadRemote?: (request: string) => Promise;
+ };
+ };
+};
+
+declare const __webpack_require__: WebpackRequireRuntime;
+declare const __FEDERATION__: FederationState | undefined;
+
+const isObject = (value: unknown): value is Record =>
+ typeof value === 'object' && value !== null;
+
+const stableStringify = (value: unknown) => {
+ try {
+ return JSON.stringify(value, (_key, current) => {
+ if (Array.isArray(current)) {
+ return current;
+ }
+ if (!isObject(current)) {
+ return current;
+ }
+ return Object.fromEntries(
+ Object.keys(current)
+ .sort()
+ .map((key) => [key, current[key]]),
+ );
+ });
+ } catch {
+ return String(value);
+ }
+};
+
+const assertNoConflict = (
+ target: Record,
+ key: string,
+ nextValue: unknown,
+ alias: string,
+ section: string,
+) => {
+ if (!Object.prototype.hasOwnProperty.call(target, key)) {
+ return;
+ }
+ if (stableStringify(target[key]) !== stableStringify(nextValue)) {
+ throw new Error(
+ `[modern-js-v3:rsc-bridge] ${section} conflict for "${key}" while merging remote "${alias}"`,
+ );
+ }
+};
+
+const getNamespacedModuleId = (alias: string, rawId: string | number) =>
+ `${MODULE_PREFIX}${alias}:${String(rawId)}`;
+
+const getNamespacedClientManifestKey = (alias: string, key: string | number) =>
+ `${MODULE_PREFIX}${alias}:${String(key)}`;
+
+const actionRemapMapFallback: ActionRemapMap = {};
+
+const getFederationState = (): FederationState | undefined => {
+ if (typeof __FEDERATION__ !== 'undefined' && isObject(__FEDERATION__)) {
+ return __FEDERATION__;
+ }
+ return undefined;
+};
+
+const getActionRemapMap = () => {
+ const federationState = getFederationState();
+ if (!federationState) {
+ return actionRemapMapFallback;
+ }
+ if (!isObject(federationState[ACTION_REMAP_GLOBAL_KEY])) {
+ federationState[ACTION_REMAP_GLOBAL_KEY] = {};
+ }
+ return federationState[ACTION_REMAP_GLOBAL_KEY] as ActionRemapMap;
+};
+
+const registerActionRemap = (rawActionId: string, prefixedActionId: string) => {
+ const remapMap = getActionRemapMap();
+ const existingValue = remapMap[rawActionId];
+ if (typeof existingValue === 'undefined') {
+ remapMap[rawActionId] = prefixedActionId;
+ return;
+ }
+ if (existingValue === prefixedActionId) {
+ return;
+ }
+ // Ambiguous mapping across remotes; skip unsafe remap.
+ remapMap[rawActionId] = false;
+};
+
+const getWebpackRequireIfAvailable = (): WebpackRequireRuntime | undefined => {
+ if (typeof __webpack_require__ !== 'undefined') {
+ return __webpack_require__;
+ }
+ return undefined;
+};
+
+const getWebpackRequire = (): WebpackRequireRuntime => {
+ const runtime = getWebpackRequireIfAvailable();
+ if (!runtime) {
+ throw new Error(
+ '[modern-js-v3:rsc-bridge] __webpack_require__ is unavailable while installing the RSC bridge runtime plugin',
+ );
+ }
+ return runtime;
+};
+
+const ensureHostManifest = () => {
+ const webpackRequire = getWebpackRequire();
+ if (!isObject(webpackRequire.rscM)) {
+ webpackRequire.rscM = {};
+ }
+ const manifest = webpackRequire.rscM as ManifestLike;
+ manifest.serverManifest = isObject(manifest.serverManifest)
+ ? manifest.serverManifest
+ : {};
+ manifest.clientManifest = isObject(manifest.clientManifest)
+ ? manifest.clientManifest
+ : {};
+ manifest.serverConsumerModuleMap = isObject(manifest.serverConsumerModuleMap)
+ ? manifest.serverConsumerModuleMap
+ : {};
+ return manifest;
+};
+
+const remapConsumerNode = (
+ alias: string,
+ value: unknown,
+ namespacedClientIds: Record,
+) => {
+ if (!isObject(value)) {
+ return value;
+ }
+ return Object.fromEntries(
+ Object.entries(value).map(([exportName, exportValue]) => {
+ const nextExportValue = isObject(exportValue)
+ ? { ...exportValue }
+ : exportValue;
+ if (isObject(nextExportValue) && nextExportValue.id != null) {
+ const rawId = String(nextExportValue.id);
+ nextExportValue.id = Object.prototype.hasOwnProperty.call(
+ namespacedClientIds,
+ rawId,
+ )
+ ? namespacedClientIds[rawId]
+ : getNamespacedModuleId(alias, rawId);
+ }
+ return [exportName, nextExportValue];
+ }),
+ );
+};
+
+const getProxyModuleId = (alias: string) => `${PROXY_MODULE_PREFIX}${alias}`;
+
+const installProxyModule = ({
+ proxyModuleId,
+ actionMap,
+ ensureBridge,
+}: {
+ proxyModuleId: string;
+ actionMap: ActionMapRecord;
+ ensureBridge: (alias: string) => Promise;
+}) => {
+ const webpackRequire = getWebpackRequire();
+ if (!isObject(webpackRequire.m)) {
+ webpackRequire.m = {};
+ }
+ if (webpackRequire.m![proxyModuleId]) {
+ return;
+ }
+
+ webpackRequire.m![proxyModuleId] = (module: { exports: any }) => {
+ module.exports = new Proxy(
+ {},
+ {
+ get(_target, property) {
+ if (property === 'then') {
+ return undefined;
+ }
+ if (typeof property !== 'string') {
+ return undefined;
+ }
+ if (!Object.prototype.hasOwnProperty.call(actionMap, property)) {
+ return undefined;
+ }
+ const mapping = actionMap[property];
+ return async (...args: unknown[]) => {
+ const bridge = await ensureBridge(mapping.alias);
+ if (typeof bridge.executeAction !== 'function') {
+ throw new Error(
+ `[modern-js-v3:rsc-bridge] Missing executeAction bridge method for remote "${mapping.alias}"`,
+ );
+ }
+ return bridge.executeAction(
+ mapping.rawActionId,
+ Array.isArray(args) ? args : [],
+ );
+ };
+ },
+ },
+ );
+ };
+};
+
+const isNodeLikeRuntime = () =>
+ typeof process !== 'undefined' &&
+ Boolean(process.versions?.node) &&
+ typeof document === 'undefined';
+
+const rscBridgeRuntimePlugin = (): ModuleFederationRuntimePlugin => {
+ const bridgePromises: Partial>> = {};
+ const aliasMergePromises: Partial>> = {};
+ const actionMap: ActionMapRecord = {};
+ const mergedRemoteAliases = new Set();
+
+ const resolveRemoteAlias = (args: any): string | undefined => {
+ const candidateAliases = [
+ args?.remote?.alias,
+ args?.pkgNameOrAlias,
+ args?.remote?.name,
+ args?.remoteInfo?.alias,
+ args?.remoteInfo?.name,
+ args?.name,
+ ];
+ for (const candidate of candidateAliases) {
+ if (typeof candidate === 'string' && candidate.trim()) {
+ return candidate;
+ }
+ }
+ return undefined;
+ };
+
+ const resolveExposeSpecifier = (args: any): string => {
+ const candidateExposes = [
+ args?.expose,
+ args?.id,
+ args?.request,
+ args?.pkgNameOrAlias,
+ args?.remote?.id,
+ args?.remote?.expose,
+ args?.remoteInfo?.id,
+ args?.remoteInfo?.expose,
+ args?.name,
+ ];
+ for (const candidate of candidateExposes) {
+ if (
+ (typeof candidate === 'string' || typeof candidate === 'number') &&
+ String(candidate).trim()
+ ) {
+ return String(candidate);
+ }
+ }
+ return '';
+ };
+
+ const isBridgeExposeRequest = (args: any) =>
+ resolveExposeSpecifier(args).includes(RSC_BRIDGE_EXPOSE);
+
+ const ensureBridge = async (alias: string, args?: any) => {
+ const existingBridgePromise = bridgePromises[alias];
+ if (existingBridgePromise) {
+ return existingBridgePromise;
+ }
+ const runtimeInstance =
+ args?.origin && typeof args.origin.loadRemote === 'function'
+ ? args.origin
+ : getWebpackRequireIfAvailable()?.federation?.instance;
+ if (!runtimeInstance || typeof runtimeInstance.loadRemote !== 'function') {
+ throw new Error(
+ '[modern-js-v3:rsc-bridge] Module Federation runtime instance is unavailable while loading the RSC bridge',
+ );
+ }
+ let resolveBridge!: (bridge: BridgeModule) => void;
+ let rejectBridge!: (error: unknown) => void;
+ const bridgePromise = new Promise((resolve, reject) => {
+ resolveBridge = resolve;
+ rejectBridge = reject;
+ });
+ bridgePromises[alias] = bridgePromise;
+
+ void Promise.resolve()
+ .then(() => runtimeInstance.loadRemote(`${alias}/${RSC_BRIDGE_EXPOSE}`))
+ .then((bridge: BridgeModule) => {
+ if (
+ !bridge ||
+ typeof bridge.getManifest !== 'function' ||
+ typeof bridge.executeAction !== 'function'
+ ) {
+ throw new Error(
+ `[modern-js-v3:rsc-bridge] Remote "${alias}" is missing the internal RSC bridge expose`,
+ );
+ }
+ resolveBridge(bridge);
+ })
+ .catch((error: unknown) => {
+ // Allow retry when bridge loading fails transiently.
+ delete bridgePromises[alias];
+ rejectBridge(error);
+ });
+
+ return bridgePromise;
+ };
+
+ const mergeRemoteManifest = (
+ alias: string,
+ remoteManifest: ManifestLike,
+ proxyModuleId: string,
+ ) => {
+ if (!isObject(remoteManifest)) {
+ return;
+ }
+
+ const hostManifest = ensureHostManifest();
+ const namespacedClientIds: Record = {};
+
+ if (isObject(remoteManifest.clientManifest)) {
+ for (const [key, value] of Object.entries(
+ remoteManifest.clientManifest,
+ )) {
+ const scopedClientManifestKey = getNamespacedClientManifestKey(
+ alias,
+ key,
+ );
+ const nextValue = isObject(value) ? { ...value } : value;
+ if (isObject(nextValue) && nextValue.id != null) {
+ const namespacedClientId = getNamespacedModuleId(alias, nextValue.id);
+ namespacedClientIds[String(nextValue.id)] = namespacedClientId;
+ nextValue.id = namespacedClientId;
+ }
+ assertNoConflict(
+ hostManifest.clientManifest as Record,
+ scopedClientManifestKey,
+ nextValue,
+ alias,
+ 'clientManifest',
+ );
+ (hostManifest.clientManifest as Record)[
+ scopedClientManifestKey
+ ] = nextValue;
+ }
+ }
+
+ if (isObject(remoteManifest.serverConsumerModuleMap)) {
+ for (const [rawModuleId, value] of Object.entries(
+ remoteManifest.serverConsumerModuleMap,
+ )) {
+ const scopedModuleId = Object.prototype.hasOwnProperty.call(
+ namespacedClientIds,
+ String(rawModuleId),
+ )
+ ? namespacedClientIds[String(rawModuleId)]
+ : getNamespacedModuleId(alias, rawModuleId);
+ const nextValue = remapConsumerNode(alias, value, namespacedClientIds);
+ assertNoConflict(
+ hostManifest.serverConsumerModuleMap as Record,
+ scopedModuleId,
+ nextValue,
+ alias,
+ 'serverConsumerModuleMap',
+ );
+ (hostManifest.serverConsumerModuleMap as Record)[
+ scopedModuleId
+ ] = nextValue;
+ }
+ }
+
+ if (!isObject(remoteManifest.serverManifest)) {
+ return;
+ }
+
+ for (const [rawActionId, actionEntry] of Object.entries(
+ remoteManifest.serverManifest,
+ )) {
+ const prefixedActionId = `${ACTION_PREFIX}${alias}:${rawActionId}`;
+ const hostActionEntry = {
+ id: proxyModuleId,
+ name: prefixedActionId,
+ chunks: [],
+ async:
+ isObject(actionEntry) && 'async' in actionEntry
+ ? (actionEntry as Record).async
+ : true,
+ };
+ assertNoConflict(
+ hostManifest.serverManifest as Record,
+ prefixedActionId,
+ hostActionEntry,
+ alias,
+ 'serverManifest',
+ );
+ (hostManifest.serverManifest as Record)[prefixedActionId] =
+ hostActionEntry;
+ actionMap[prefixedActionId] = { alias, rawActionId };
+ registerActionRemap(rawActionId, prefixedActionId);
+ }
+ };
+
+ const ensureRemoteAliasMerged = async (alias: string, args: any) => {
+ const bridgeExposeRequest = isBridgeExposeRequest(args);
+ const existingMergePromise = aliasMergePromises[alias];
+ if (existingMergePromise) {
+ if (bridgeExposeRequest) {
+ return;
+ }
+ await existingMergePromise;
+ return;
+ }
+ if (mergedRemoteAliases.has(alias) || bridgeExposeRequest) {
+ return;
+ }
+
+ const mergePromise = (async () => {
+ const proxyModuleId = getProxyModuleId(alias);
+ installProxyModule({
+ proxyModuleId,
+ actionMap,
+ ensureBridge: async (resolvedAlias) =>
+ ensureBridge(resolvedAlias, args),
+ });
+
+ const bridge = await ensureBridge(alias, args);
+ const remoteManifest =
+ typeof bridge.getManifest === 'function'
+ ? await Promise.resolve(bridge.getManifest())
+ : {};
+ mergeRemoteManifest(alias, remoteManifest || {}, proxyModuleId);
+ mergedRemoteAliases.add(alias);
+ })();
+
+ aliasMergePromises[alias] = mergePromise;
+ try {
+ await mergePromise;
+ } finally {
+ delete aliasMergePromises[alias];
+ }
+ };
+
+ const ensureTrailingSlash = (value: string) =>
+ value.endsWith('/') ? value : `${value}/`;
+
+ const isAbsoluteHttpUrl = (value: string) =>
+ value.startsWith('http://') || value.startsWith('https://');
+
+ const isBrokenRemoteEntryUrl = (value: unknown) =>
+ typeof value !== 'string' ||
+ !value.trim() ||
+ value.includes('undefined') ||
+ value.startsWith('https:undefined') ||
+ value.startsWith('http:undefined');
+
+ const isLikelyClientRemoteEntryPath = (entryPath: string) => {
+ const normalizedPath = entryPath.split('?')[0];
+ return (
+ normalizedPath.endsWith('/static/remoteEntry.js') ||
+ normalizedPath.endsWith('static/remoteEntry.js') ||
+ normalizedPath === 'remoteEntry.js' ||
+ normalizedPath.endsWith('/remoteEntry.js')
+ );
+ };
+
+ const shouldRewriteNodeClientRemoteEntryUrl = (entry: unknown) =>
+ isNodeLikeRuntime() &&
+ typeof entry === 'string' &&
+ isLikelyClientRemoteEntryPath(entry);
+
+ const resolveNodeSsrRemoteEntryPath = (entryPath: string) => {
+ if (!isNodeLikeRuntime()) {
+ return entryPath;
+ }
+
+ const normalizedEntryPath = entryPath.startsWith('/')
+ ? entryPath.slice(1)
+ : entryPath;
+ if (normalizedEntryPath.startsWith('bundles/')) {
+ return normalizedEntryPath;
+ }
+
+ if (!isLikelyClientRemoteEntryPath(normalizedEntryPath)) {
+ return entryPath;
+ }
+
+ return `bundles/${normalizedEntryPath}`;
+ };
+
+ const resolveSnapshotPublicPath = (snapshot: Record) => {
+ const metaData = isObject(snapshot.metaData)
+ ? (snapshot.metaData as Record)
+ : undefined;
+ const candidates = [
+ snapshot.ssrPublicPath,
+ snapshot.publicPath,
+ metaData?.ssrPublicPath,
+ metaData?.publicPath,
+ ];
+ const publicPath = candidates.find(
+ (candidate) => typeof candidate === 'string' && candidate.trim(),
+ ) as string | undefined;
+ if (!publicPath) {
+ return undefined;
+ }
+ return ensureTrailingSlash(publicPath.trim());
+ };
+
+ const resolveSnapshotRemoteEntryRequest = (snapshot: Record) => {
+ const remoteEntryCandidate = isObject(snapshot.ssrRemoteEntry)
+ ? (snapshot.ssrRemoteEntry as Record)
+ : (snapshot.ssrRemoteEntry ?? snapshot.remoteEntry);
+ if (!remoteEntryCandidate) {
+ return undefined;
+ }
+
+ let entryPath =
+ typeof remoteEntryCandidate === 'string'
+ ? remoteEntryCandidate
+ : (() => {
+ const pathPart =
+ typeof remoteEntryCandidate.path === 'string'
+ ? remoteEntryCandidate.path
+ : '';
+ const namePart =
+ typeof remoteEntryCandidate.name === 'string'
+ ? remoteEntryCandidate.name
+ : '';
+ return `${pathPart}${namePart}`;
+ })();
+ if (!entryPath) {
+ return undefined;
+ }
+
+ if (isAbsoluteHttpUrl(entryPath)) {
+ if (isNodeLikeRuntime() && isLikelyClientRemoteEntryPath(entryPath)) {
+ try {
+ const url = new URL(entryPath);
+ const resolvedNodeEntryPath = resolveNodeSsrRemoteEntryPath(
+ url.pathname,
+ );
+ const normalizedPathname = resolvedNodeEntryPath.startsWith('/')
+ ? resolvedNodeEntryPath
+ : `/${resolvedNodeEntryPath}`;
+ url.pathname = normalizedPathname;
+ return url.href;
+ } catch {
+ return entryPath;
+ }
+ }
+ return entryPath;
+ }
+
+ if (isNodeLikeRuntime()) {
+ const resolvedNodeEntryPath = resolveNodeSsrRemoteEntryPath(entryPath);
+ if (resolvedNodeEntryPath !== entryPath) {
+ entryPath = resolvedNodeEntryPath;
+ } else if (!snapshot.ssrRemoteEntry) {
+ const normalizedEntryPath = entryPath.startsWith('/')
+ ? entryPath.slice(1)
+ : entryPath;
+ if (!normalizedEntryPath.startsWith('bundles/')) {
+ entryPath = `bundles/${normalizedEntryPath}`;
+ }
+ }
+ }
+
+ const publicPath = resolveSnapshotPublicPath(snapshot);
+ if (!publicPath) {
+ return undefined;
+ }
+
+ const publicPathHasBundlesSegment = publicPath.includes('/bundles/');
+ if (isNodeLikeRuntime() && publicPathHasBundlesSegment) {
+ const normalizedEntryPath = entryPath.startsWith('/')
+ ? entryPath.slice(1)
+ : entryPath;
+ if (normalizedEntryPath.startsWith('bundles/')) {
+ entryPath = normalizedEntryPath.slice('bundles/'.length);
+ }
+ }
+
+ try {
+ return new URL(entryPath, publicPath).href;
+ } catch {
+ const normalizedEntry = entryPath.startsWith('/')
+ ? entryPath.slice(1)
+ : entryPath;
+ return `${publicPath}${normalizedEntry}`;
+ }
+ };
+
+ const patchRemoteInfoEntry = (
+ remoteInfo: Record | undefined,
+ snapshot: Record | undefined,
+ ) => {
+ if (!isObject(remoteInfo) || !isObject(snapshot)) {
+ return;
+ }
+ const resolvedEntry = resolveSnapshotRemoteEntryRequest(snapshot);
+ if (!resolvedEntry) {
+ return;
+ }
+
+ if (
+ shouldRewriteNodeClientRemoteEntryUrl(remoteInfo.entry) ||
+ isBrokenRemoteEntryUrl(remoteInfo.entry) ||
+ (typeof remoteInfo.entry === 'string' &&
+ remoteInfo.entry.includes('undefined'))
+ ) {
+ remoteInfo.entry = resolvedEntry;
+ }
+ };
+
+ const normalizeRemoteEntryPath = (remoteEntry: Record) => {
+ if (
+ remoteEntry.path === undefined ||
+ remoteEntry.path === null ||
+ remoteEntry.path === 'undefined'
+ ) {
+ remoteEntry.path = '';
+ }
+ };
+
+ const patchSnapshotSsrPublicPath = (snapshot: any) => {
+ if (!isObject(snapshot)) {
+ return;
+ }
+
+ const metaData = isObject(snapshot.metaData)
+ ? (snapshot.metaData as Record)
+ : undefined;
+
+ const rawPublicPathCandidates = [
+ snapshot.ssrPublicPath,
+ snapshot.publicPath,
+ metaData?.ssrPublicPath,
+ metaData?.publicPath,
+ ];
+ const publicPath = rawPublicPathCandidates.find(
+ (candidate) => typeof candidate === 'string' && candidate.trim(),
+ ) as string | undefined;
+ if (publicPath) {
+ const normalizedPublicPath = ensureTrailingSlash(publicPath.trim());
+ snapshot.ssrPublicPath = normalizedPublicPath;
+ if (metaData) {
+ metaData.ssrPublicPath = normalizedPublicPath;
+ }
+ }
+
+ const remoteEntry = isObject(snapshot.remoteEntry)
+ ? (snapshot.remoteEntry as Record)
+ : isObject(metaData?.remoteEntry)
+ ? (metaData?.remoteEntry as Record)
+ : undefined;
+ if (remoteEntry) {
+ normalizeRemoteEntryPath(remoteEntry);
+ if (!isObject(snapshot.remoteEntry)) {
+ snapshot.remoteEntry = remoteEntry;
+ }
+ if (metaData && !isObject(metaData.remoteEntry)) {
+ metaData.remoteEntry = remoteEntry;
+ }
+ }
+
+ if (
+ !isObject(snapshot.ssrRemoteEntry) &&
+ (isObject(metaData?.ssrRemoteEntry) || remoteEntry)
+ ) {
+ const source = isObject(metaData?.ssrRemoteEntry)
+ ? (metaData?.ssrRemoteEntry as Record)
+ : (remoteEntry as Record);
+ const normalizedSsrRemoteEntry = { ...source };
+ normalizeRemoteEntryPath(normalizedSsrRemoteEntry);
+ snapshot.ssrRemoteEntry = normalizedSsrRemoteEntry;
+ if (metaData) {
+ metaData.ssrRemoteEntry = { ...normalizedSsrRemoteEntry };
+ }
+ } else if (isObject(snapshot.ssrRemoteEntry)) {
+ normalizeRemoteEntryPath(snapshot.ssrRemoteEntry as Record);
+ if (metaData && !isObject(metaData.ssrRemoteEntry)) {
+ metaData.ssrRemoteEntry = snapshot.ssrRemoteEntry;
+ }
+ }
+ };
+
+ const patchRuntimeArgsSnapshots = (args: any) => {
+ patchSnapshotSsrPublicPath(args?.remoteSnapshot);
+ patchSnapshotSsrPublicPath(args?.remoteInfo);
+ patchSnapshotSsrPublicPath(args?.remote?.remoteSnapshot);
+ patchSnapshotSsrPublicPath(args?.remote?.remoteInfo);
+ patchSnapshotSsrPublicPath(args?.resolvedRemote?.remoteSnapshot);
+ patchSnapshotSsrPublicPath(args?.resolvedRemote?.remoteInfo);
+ patchRemoteInfoEntry(args?.remoteInfo, args?.remoteSnapshot);
+ patchRemoteInfoEntry(
+ args?.remote?.remoteInfo,
+ args?.remote?.remoteSnapshot,
+ );
+ patchRemoteInfoEntry(
+ args?.resolvedRemote?.remoteInfo,
+ args?.resolvedRemote?.remoteSnapshot,
+ );
+ };
+
+ return {
+ name: 'modernjs-rsc-bridge-runtime-plugin',
+ async afterResolve(args: any) {
+ patchRuntimeArgsSnapshots(args);
+ const alias = resolveRemoteAlias(args);
+ if (!alias || isBridgeExposeRequest(args)) {
+ return args;
+ }
+ await ensureRemoteAliasMerged(alias, args);
+ return args;
+ },
+ async onLoad(args: any) {
+ patchRuntimeArgsSnapshots(args);
+ const alias = resolveRemoteAlias(args);
+ if (!alias) {
+ return args;
+ }
+
+ const hasExposeContext =
+ typeof args?.expose === 'string' ||
+ typeof args?.id === 'string' ||
+ typeof args?.id === 'number';
+ if (!hasExposeContext) {
+ await ensureRemoteAliasMerged(alias, args);
+ return args;
+ }
+
+ if (mergedRemoteAliases.has(alias) || isBridgeExposeRequest(args)) {
+ return args;
+ }
+ await ensureRemoteAliasMerged(alias, args);
+
+ return args;
+ },
+ };
+};
+
+export default rscBridgeRuntimePlugin;
diff --git a/packages/modernjs-v3/src/cli/ssrPlugin.ts b/packages/modernjs-v3/src/cli/ssrPlugin.ts
index a61b7ed1a60..caf65410b01 100644
--- a/packages/modernjs-v3/src/cli/ssrPlugin.ts
+++ b/packages/modernjs-v3/src/cli/ssrPlugin.ts
@@ -32,6 +32,8 @@ export function setEnv() {
}
export const CHAIN_MF_PLUGIN_ID = 'plugin-module-federation-server';
+const isBuildCommand = () =>
+ process.argv.includes('build') || process.argv.includes('deploy');
function getManifestAssetFileNames(
manifestOption?: moduleFederationPlugin.ModuleFederationPluginOptions['manifest'],
@@ -83,52 +85,6 @@ const mfSSRRsbuildPlugin = (
let ssrEnv = '';
let csrEnv = '';
- const browserAssetFileNames =
- pluginOptions.assetFileNames.browser ||
- getManifestAssetFileNames(pluginOptions.csrConfig?.manifest);
- const nodeAssetFileNames =
- pluginOptions.assetFileNames?.node ||
- getManifestAssetFileNames(pluginOptions.ssrConfig?.manifest);
-
- const collectAssets = (
- assets: Record string | Buffer }>,
- fileNames: { statsFileName: string; manifestFileName: string },
- tag: 'browser' | 'node',
- ): StatsAssetResource | undefined => {
- const statsAsset = assets[fileNames.statsFileName];
- const manifestAsset = assets[fileNames.manifestFileName];
-
- if (!statsAsset || !manifestAsset) {
- return undefined;
- }
-
- try {
- const statsRaw = statsAsset.source();
- const manifestRaw = manifestAsset.source();
- const statsContent =
- typeof statsRaw === 'string' ? statsRaw : statsRaw.toString();
- const manifestContent =
- typeof manifestRaw === 'string'
- ? manifestRaw
- : manifestRaw.toString();
-
- return {
- stats: {
- data: JSON.parse(statsContent),
- filename: fileNames.statsFileName,
- },
- manifest: {
- data: JSON.parse(manifestContent),
- filename: fileNames.manifestFileName,
- },
- };
- } catch (err) {
- const message = err instanceof Error ? err.message : String(err);
- logger.error(`Failed to parse ${tag} manifest assets: ${message}`);
- return undefined;
- }
- };
-
api.modifyEnvironmentConfig((config, { name }) => {
const target = config.output.target;
if (skipByTarget(target)) {
@@ -166,43 +122,6 @@ const mfSSRRsbuildPlugin = (
modifySSRPublicPath(config, utils);
return config;
});
-
- api.processAssets(
- { stage: 'report' },
- ({ assets, environment: envContext }) => {
- const envName = envContext.name;
-
- if (
- pluginOptions.csrConfig?.manifest !== false &&
- csrEnv &&
- envName === csrEnv
- ) {
- const browserAssets = collectAssets(
- assets,
- browserAssetFileNames,
- 'browser',
- );
- if (browserAssets) {
- pluginOptions.assetResources.browser = browserAssets;
- }
- }
-
- if (
- pluginOptions.ssrConfig?.manifest !== false &&
- ssrEnv &&
- envName === ssrEnv
- ) {
- const nodeAssets = collectAssets(
- assets,
- nodeAssetFileNames,
- 'node',
- );
- if (nodeAssets) {
- pluginOptions.assetResources.node = nodeAssets;
- }
- }
- },
- );
},
};
};
@@ -292,6 +211,7 @@ export const moduleFederationSSRPlugin = (
if (!isWeb && !secondarySharedTreeShaking) {
chain.target('async-node');
+
if (isDev()) {
chain
.plugin('UniverseEntryChunkTrackerPlugin')
@@ -318,11 +238,33 @@ export const moduleFederationSSRPlugin = (
return;
}
try {
+ const requestPath = req.url?.split('?')[0] || '';
+ const extension = path.extname(requestPath);
+ const isJsonRequest =
+ extension === '.json' &&
+ !requestPath.includes('hot-update');
+ const isBundleJsRequest =
+ extension === '.js' && requestPath.startsWith('/bundles/');
if (
- req.url?.includes('.json') &&
- !req.url?.includes('hot-update')
+ (isJsonRequest || isBundleJsRequest) &&
+ requestPath.includes('/')
) {
- const filepath = path.join(process.cwd(), `dist${req.url}`);
+ if (!requestPath.startsWith('/')) {
+ next();
+ return;
+ }
+
+ const distRoot = path.resolve(process.cwd(), 'dist');
+ const filepath = path.resolve(distRoot, `.${requestPath}`);
+ const allowedPrefix = `${distRoot}${path.sep}`;
+ if (
+ filepath !== distRoot &&
+ !filepath.startsWith(allowedPrefix)
+ ) {
+ next();
+ return;
+ }
+
fs.statSync(filepath);
res.setHeader('Access-Control-Allow-Origin', '*');
res.setHeader(
@@ -343,14 +285,72 @@ export const moduleFederationSSRPlugin = (
},
};
});
+ const readAssetResourceFromDisk = (
+ outputDir: string,
+ fileNames: AssetFileNames,
+ tag: 'browser' | 'node',
+ ): StatsAssetResource | undefined => {
+ const statsFilePath = path.resolve(outputDir, fileNames.statsFileName);
+ const manifestFilePath = path.resolve(
+ outputDir,
+ fileNames.manifestFileName,
+ );
+ if (!fs.existsSync(statsFilePath) || !fs.existsSync(manifestFilePath)) {
+ return undefined;
+ }
+
+ try {
+ return {
+ stats: {
+ data: fs.readJSONSync(statsFilePath),
+ filename: fileNames.statsFileName,
+ },
+ manifest: {
+ data: fs.readJSONSync(manifestFilePath),
+ filename: fileNames.manifestFileName,
+ },
+ };
+ } catch (err) {
+ const message = err instanceof Error ? err.message : String(err);
+ logger.error(
+ `[module-federation-ssr] Failed to read ${tag} manifest assets from disk: ${message}`,
+ );
+ return undefined;
+ }
+ };
+
const writeMergedManifest = () => {
- const { distOutputDir, assetResources } = pluginOptions;
- const browserAssets = assetResources.browser;
- const nodeAssets = assetResources.node;
+ if (!isBuildCommand()) {
+ return;
+ }
+ const distOutputDir =
+ pluginOptions.distOutputDir || path.resolve(process.cwd(), 'dist');
+ const userSSRConfig = pluginOptions.userConfig.ssr;
+ const ssrDistOutputDir =
+ typeof userSSRConfig === 'object' && userSSRConfig.distOutputDir
+ ? userSSRConfig.distOutputDir
+ : path.resolve(distOutputDir, 'bundles');
+ const browserFileNames =
+ pluginOptions.assetFileNames.browser ||
+ getManifestAssetFileNames(pluginOptions.csrConfig?.manifest);
+ const nodeFileNames =
+ pluginOptions.assetFileNames.node ||
+ getManifestAssetFileNames(pluginOptions.ssrConfig?.manifest);
+ const browserAssets = readAssetResourceFromDisk(
+ distOutputDir,
+ browserFileNames,
+ 'browser',
+ );
+ const nodeAssets = readAssetResourceFromDisk(
+ ssrDistOutputDir,
+ nodeFileNames,
+ 'node',
+ );
- if (!distOutputDir || !browserAssets || !nodeAssets) {
+ if (!browserAssets || !nodeAssets) {
return;
}
+
try {
updateStatsAndManifest(nodeAssets, browserAssets, distOutputDir);
} catch (err) {
@@ -361,10 +361,6 @@ export const moduleFederationSSRPlugin = (
api.onAfterBuild(() => {
writeMergedManifest();
});
- api.onDevCompileDone(() => {
- // 热更后修改 manifest
- writeMergedManifest();
- });
},
});
diff --git a/packages/modernjs-v3/src/runtime/rsc-bridge-expose.spec.ts b/packages/modernjs-v3/src/runtime/rsc-bridge-expose.spec.ts
new file mode 100644
index 00000000000..c43cabd0be4
--- /dev/null
+++ b/packages/modernjs-v3/src/runtime/rsc-bridge-expose.spec.ts
@@ -0,0 +1,160 @@
+import { afterEach, describe, expect, it, vi } from 'vitest';
+
+type ManifestLike = {
+ serverManifest?: Record;
+ clientManifest?: Record;
+ serverConsumerModuleMap?: Record;
+};
+
+type ExposeModuleMap = Record Promise | unknown>;
+
+type WebpackRequireRuntime = {
+ initializeExposesData?: {
+ moduleMap?: ExposeModuleMap;
+ };
+ rscM?: ManifestLike;
+};
+
+const setWebpackRequireRuntime = (runtime: WebpackRequireRuntime) => {
+ vi.stubGlobal('__webpack_require__', runtime);
+};
+
+const loadBridgeExposeModule = async () => {
+ vi.resetModules();
+ return import('./rsc-bridge-expose');
+};
+
+afterEach(() => {
+ vi.unstubAllGlobals();
+});
+
+describe('rsc-bridge-expose', () => {
+ it('returns remote manifest through getManifest', async () => {
+ const manifest: ManifestLike = {
+ serverManifest: {
+ action: {
+ id: 'remote:raw',
+ },
+ },
+ };
+ setWebpackRequireRuntime({
+ rscM: manifest,
+ initializeExposesData: {
+ moduleMap: {},
+ },
+ });
+
+ const { getManifest } = await loadBridgeExposeModule();
+
+ expect(getManifest()).toBe(manifest);
+ });
+
+ it('scans exposes and executes action references by raw id', async () => {
+ const action = vi.fn(async (value: string) => `ok:${value}`) as {
+ (...args: unknown[]): Promise;
+ $$id?: string;
+ };
+ action.$$id = 'raw-action-id';
+
+ const getFactory = vi.fn(async () => () => ({
+ nested: {
+ action,
+ },
+ }));
+
+ setWebpackRequireRuntime({
+ initializeExposesData: {
+ moduleMap: {
+ './actions': getFactory,
+ './__rspack_rsc_bridge__': vi.fn(async () => () => ({
+ ignored: true,
+ })),
+ },
+ },
+ rscM: {},
+ });
+
+ const bridgeExpose = await loadBridgeExposeModule();
+
+ await expect(
+ bridgeExpose.executeAction('raw-action-id', ['value-a']),
+ ).resolves.toBe('ok:value-a');
+ await expect(
+ bridgeExpose.executeAction('raw-action-id', ['value-b']),
+ ).resolves.toBe('ok:value-b');
+
+ expect(getFactory).toHaveBeenCalledTimes(1);
+ expect(action).toHaveBeenNthCalledWith(1, 'value-a');
+ expect(action).toHaveBeenNthCalledWith(2, 'value-b');
+ });
+
+ it('normalizes non-array args to empty array before dispatch', async () => {
+ const action = vi.fn(async (...args: unknown[]) => args.length) as {
+ (...args: unknown[]): Promise;
+ $$id?: string;
+ };
+ action.$$id = 'raw-action-id';
+
+ setWebpackRequireRuntime({
+ initializeExposesData: {
+ moduleMap: {
+ './actions': async () => () => ({ action }),
+ },
+ },
+ rscM: {},
+ });
+
+ const bridgeExpose = await loadBridgeExposeModule();
+
+ await expect(
+ bridgeExpose.executeAction('raw-action-id', 'not-array' as any),
+ ).resolves.toBe(0);
+ expect(action).toHaveBeenCalledWith();
+ });
+
+ it('throws explicit errors when action id is unresolved', async () => {
+ setWebpackRequireRuntime({
+ initializeExposesData: {
+ moduleMap: {
+ './actions': async () => () => ({ value: 'noop' }),
+ },
+ },
+ rscM: {},
+ });
+
+ const bridgeExpose = await loadBridgeExposeModule();
+
+ await expect(
+ bridgeExpose.executeAction('missing-action-id', []),
+ ).rejects.toThrow(/Missing remote action for id "missing-action-id"/);
+ });
+
+ it('discovers action references from module cache exports', async () => {
+ const cachedAction = vi.fn(async () => 'cached') as {
+ (...args: unknown[]): Promise;
+ $$id?: string;
+ };
+ cachedAction.$$id = 'raw-action-from-cache';
+
+ setWebpackRequireRuntime({
+ initializeExposesData: {
+ moduleMap: {},
+ },
+ c: {
+ cachedModule: {
+ exports: {
+ nested: {
+ cachedAction,
+ },
+ },
+ },
+ },
+ rscM: {},
+ });
+
+ const bridgeExpose = await loadBridgeExposeModule();
+ await expect(
+ bridgeExpose.executeAction('raw-action-from-cache', []),
+ ).resolves.toBe('cached');
+ });
+});
diff --git a/packages/modernjs-v3/src/runtime/rsc-bridge-expose.ts b/packages/modernjs-v3/src/runtime/rsc-bridge-expose.ts
new file mode 100644
index 00000000000..48d155eb95c
--- /dev/null
+++ b/packages/modernjs-v3/src/runtime/rsc-bridge-expose.ts
@@ -0,0 +1,166 @@
+type ManifestLike = {
+ serverManifest?: Record;
+ clientManifest?: Record;
+ serverConsumerModuleMap?: Record;
+};
+
+type ExposeModuleMap = Record<
+ string,
+ () => Promise<(() => unknown) | unknown> | (() => unknown) | unknown
+>;
+
+type WebpackRequireRuntime = {
+ initializeExposesData?: {
+ moduleMap?: ExposeModuleMap;
+ };
+ m?: Record;
+ c?: Record;
+ rscM?: ManifestLike;
+};
+
+declare const __webpack_require__: WebpackRequireRuntime;
+
+const BRIDGE_EXPOSE_NAME = './__rspack_rsc_bridge__';
+const actionReferenceCache: Record unknown> =
+ Object.create(null);
+let scanPromise: Promise | null = null;
+let scanHadErrors = false;
+
+const isObject = (value: unknown): value is Record =>
+ typeof value === 'object' && value !== null;
+const isFunction = (value: unknown): value is (...args: unknown[]) => unknown =>
+ typeof value === 'function';
+const isWebpackRequireRuntime = (
+ value: unknown,
+): value is WebpackRequireRuntime => isObject(value) || isFunction(value);
+const runtimeRequireFromWrapper: WebpackRequireRuntime | undefined = (() => {
+ try {
+ // Access the module-wrapper require function when available.
+ // biome-ignore lint/security/noGlobalEval: The bundler module wrapper exposes `require` via arguments only.
+ const wrapperRequire = eval('arguments[2]');
+ return isWebpackRequireRuntime(wrapperRequire)
+ ? (wrapperRequire as WebpackRequireRuntime)
+ : undefined;
+ } catch {
+ return undefined;
+ }
+})();
+
+const getWebpackRequire = (): WebpackRequireRuntime => {
+ if (runtimeRequireFromWrapper) {
+ return runtimeRequireFromWrapper;
+ }
+
+ if (
+ typeof __webpack_require__ !== 'undefined' &&
+ isWebpackRequireRuntime(__webpack_require__)
+ ) {
+ return __webpack_require__;
+ }
+ throw new Error(
+ '[modern-js-v3:rsc-bridge] __webpack_require__ is unavailable while evaluating the internal bridge expose',
+ );
+};
+
+const cacheActionReferencesFromExports = (
+ exposedValue: unknown,
+ visited: WeakSet