feat: builtin react server component

Cargo.toml

@@ -44,6 +44,7 @@ dyn-clone           = { version = "1.0.20", default-features = false }
 either              = { version = "1.15.0", default-features = false }
 enum-tag            = { version = "0.3.0", default-features = false }
 fast-glob           = { version = "1.0.0", default-features = false }
+form_urlencoded     = { version = "1.2.2", default-features = false }
 futures             = { version = "0.3.31", default-features = false, features = ["std"] }
 glob                = { version = "0.3.3", default-features = false }
 hashlink            = { version = "0.10.0", default-features = false }
@@ -224,6 +225,7 @@ rspack_plugin_progress                 = { version = "=0.100.0-alpha.0", path =
 rspack_plugin_real_content_hash        = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_real_content_hash", default-features = false }
 rspack_plugin_remove_duplicate_modules = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_remove_duplicate_modules", default-features = false }
 rspack_plugin_remove_empty_chunks      = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_remove_empty_chunks", default-features = false }
+rspack_plugin_rsc                      = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_rsc", default-features = false }
 rspack_plugin_rsdoctor                 = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_rsdoctor", default-features = false }
 rspack_plugin_rslib                    = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_rslib", default-features = false }
 rspack_plugin_rstest                   = { version = "=0.100.0-alpha.0", path = "crates/rspack_plugin_rstest", default-features = false }

crates/node_binding/napi-binding.d.ts

@@ -95,6 +95,8 @@ export interface JsSource {
 	source: string | Buffer
 	map?: string
 }
+
+export type CompilerId = void;
 /* -- banner.d.ts end -- */
 
 /* -- napi-rs generated below -- */
@@ -334,6 +336,7 @@ export declare class JsCompiler {
   rebuild(changed_files: string[], removed_files: string[], callback: (err: null | Error) => void): void
   close(): Promise<void>
   getVirtualFileStore(): VirtualFileStore | null
+  getCompilerId(): ExternalObject<CompilerId>
 }
 
 export declare class JsContextModuleFactoryAfterResolveData {
@@ -361,6 +364,10 @@ export declare class JsContextModuleFactoryBeforeResolveData {
   set recursive(recursive: boolean)
 }
 
+export declare class JsCoordinator {
+  constructor(getServerCompilerIdJsFn: () => ExternalObject<CompilerId>)
+}
+
 export declare class JsDependencies {
   get fileDependencies(): Array<string>
   get addedFileDependencies(): Array<string>
@@ -602,7 +609,9 @@ export declare enum BuiltinPluginName {
   LazyCompilationPlugin = 'LazyCompilationPlugin',
   ModuleInfoHeaderPlugin = 'ModuleInfoHeaderPlugin',
   HttpUriPlugin = 'HttpUriPlugin',
-  CssChunkingPlugin = 'CssChunkingPlugin'
+  CssChunkingPlugin = 'CssChunkingPlugin',
+  RscServerPlugin = 'RscServerPlugin',
+  RscClientPlugin = 'RscClientPlugin'
 }
 
 export declare function cleanupGlobalTrace(): void
@@ -1028,6 +1037,15 @@ export interface JsResourceData {
   descriptionFilePath?: string
 }
 
+export interface JsRscClientPluginOptions {
+  coordinator: JsCoordinator
+}
+
+export interface JsRscServerPluginOptions {
+  coordinator: JsCoordinator
+  onServerComponentChanges?: (() => void) | undefined | null
+}
+
 export interface JsRsdoctorAsset {
   ukey: number
   path: string

crates/node_binding/rspack.wasi-browser.js

@@ -85,6 +85,7 @@ export const JsCompilation = __napiModule.exports.JsCompilation
 export const JsCompiler = __napiModule.exports.JsCompiler
 export const JsContextModuleFactoryAfterResolveData = __napiModule.exports.JsContextModuleFactoryAfterResolveData
 export const JsContextModuleFactoryBeforeResolveData = __napiModule.exports.JsContextModuleFactoryBeforeResolveData
+export const JsCoordinator = __napiModule.exports.JsCoordinator
 export const JsDependencies = __napiModule.exports.JsDependencies
 export const JsEntries = __napiModule.exports.JsEntries
 export const JsExportsInfo = __napiModule.exports.JsExportsInfo

crates/node_binding/rspack.wasi.cjs

@@ -130,6 +130,7 @@ module.exports.JsCompilation = __napiModule.exports.JsCompilation
 module.exports.JsCompiler = __napiModule.exports.JsCompiler
 module.exports.JsContextModuleFactoryAfterResolveData = __napiModule.exports.JsContextModuleFactoryAfterResolveData
 module.exports.JsContextModuleFactoryBeforeResolveData = __napiModule.exports.JsContextModuleFactoryBeforeResolveData
+module.exports.JsCoordinator = __napiModule.exports.JsCoordinator
 module.exports.JsDependencies = __napiModule.exports.JsDependencies
 module.exports.JsEntries = __napiModule.exports.JsEntries
 module.exports.JsExportsInfo = __napiModule.exports.JsExportsInfo

crates/node_binding/scripts/banner.d.ts

@@ -95,6 +95,8 @@ export interface JsSource {
 	source: string | Buffer
 	map?: string
 }
+
+export type CompilerId = void;
 /* -- banner.d.ts end -- */
 
 /* -- napi-rs generated below -- */

crates/rspack_binding_api/Cargo.toml

@@ -40,6 +40,7 @@ rspack_paths              = { workspace = true }
 rspack_plugin_esm_library = { workspace = true }
 rspack_plugin_html        = { workspace = true }
 rspack_plugin_javascript  = { workspace = true }
+rspack_plugin_rsc         = { workspace = true }
 rspack_plugin_rsdoctor    = { workspace = true }
 rspack_plugin_rslib       = { workspace = true }
 rspack_plugin_rstest      = { workspace = true }

crates/rspack_binding_api/src/lib.rs

@@ -206,6 +206,8 @@ impl JsCompiler {
         rspack_loader_lightningcss::LightningcssLoaderPlugin::new(),
       ));
       plugins.push(Box::new(rspack_loader_swc::SwcLoaderPlugin::new()));
+      plugins.push(Box::new(rspack_plugin_rsc::ClientEntryLoaderPlugin::new()));
+      plugins.push(Box::new(rspack_plugin_rsc::ActionEntryLoaderPlugin::new()));
       plugins.push(Box::new(
         rspack_loader_react_refresh::ReactRefreshLoaderPlugin::new(),
       ));
@@ -416,6 +418,11 @@ impl JsCompiler {
       .as_ref()
       .map(|store| JsVirtualFileStore::new(store.clone()))
   }
+
+  #[napi]
+  pub fn get_compiler_id(&self) -> External<CompilerId> {
+    External::new(self.compiler.id())
+  }
 }
 
 struct RunGuard {

crates/rspack_binding_api/src/plugins/mod.rs

@@ -2,9 +2,11 @@ mod interceptor;
 mod js_cleanup_plugin;
 mod js_hooks_plugin;
 mod js_loader;
+mod rsc;
 
 pub use js_cleanup_plugin::*;
 pub use js_hooks_plugin::*;
 pub(super) use js_loader::{JsLoaderItem, JsLoaderRspackPlugin, JsLoaderRunnerGetter};
 pub mod buildtime_plugins;
 pub use interceptor::*;
+pub use rsc::{JsCoordinator, JsRscClientPluginOptions, JsRscServerPluginOptions};

crates/rspack_binding_api/src/plugins/rsc.rs

@@ -0,0 +1,114 @@
+use std::sync::Arc;
+
+use futures::future::BoxFuture;
+use napi::{
+  Env, Status,
+  bindgen_prelude::{
+    ClassInstance, Either3, External, ExternalRef, FromNapiValue, Function, JsObjectValue, Null,
+    Object, Promise, Reference, Undefined, WeakReference,
+  },
+  threadsafe_function::ThreadsafeFunction,
+};
+use once_cell::unsync::OnceCell;
+use rspack_core::{Compiler, CompilerId};
+use rspack_error::ToStringResultToRspackResultExt;
+use rspack_plugin_rsc::{Coordinator, RscClientPluginOptions, RscServerPluginOptions};
+
+use crate::JsCompiler;
+
+type InvalidateTsFn = Arc<ThreadsafeFunction<(), (), (), Status, false, true, 0>>;
+
+#[napi]
+pub struct JsCoordinator {
+  i: Arc<Coordinator>,
+}
+
+#[napi]
+impl JsCoordinator {
+  #[napi(constructor)]
+  pub fn new(
+    get_server_compiler_id_js_fn: Function<'static, (), &'static External<CompilerId>>,
+  ) -> napi::Result<Self> {
+    let get_server_compiler_id = {
+      let ts_fn = Arc::new(
+        get_server_compiler_id_js_fn
+          .build_threadsafe_function::<()>()
+          .callee_handled::<false>()
+          .max_queue_size::<0>()
+          .weak::<true>()
+          .build()?,
+      );
+      Box::new(
+        move || -> BoxFuture<'static, rspack_error::Result<CompilerId>> {
+          let ts_fn = ts_fn.clone();
+          Box::pin(async move {
+            let external = ts_fn.call_async(()).await.to_rspack_result()?;
+            Ok(**external)
+          })
+        },
+      )
+    };
+
+    Ok(Self {
+      i: Arc::new(Coordinator::new(get_server_compiler_id)),
+    })
+  }
+}
+
+impl From<&JsCoordinator> for Arc<Coordinator> {
+  fn from(value: &JsCoordinator) -> Self {
+    value.i.clone()
+  }
+}
+
+#[napi(object, object_to_js = false)]
+pub struct JsRscClientPluginOptions<'a> {
+  pub coordinator: ClassInstance<'a, JsCoordinator>,
+}
+
+impl From<&JsRscClientPluginOptions<'_>> for RscClientPluginOptions {
+  fn from(value: &JsRscClientPluginOptions) -> Self {
+    Self {
+      coordinator: value.coordinator.i.clone(),
+    }
+  }
+}
+
+#[napi(object, object_to_js = false)]
+pub struct JsRscServerPluginOptions<'a> {
+  pub coordinator: ClassInstance<'a, JsCoordinator>,
+  pub on_server_component_changes: Option<Either3<Function<'static, (), ()>, Undefined, Null>>,
+}
+
+impl TryFrom<&JsRscServerPluginOptions<'_>> for RscServerPluginOptions {
+  type Error = napi::Error;
+
+  fn try_from(value: &JsRscServerPluginOptions) -> napi::Result<Self> {
+    let on_server_component_changes: Option<
+      Box<dyn Fn() -> BoxFuture<'static, rspack_error::Result<()>> + Sync + Send>,
+    > = match value.on_server_component_changes {
+      Some(Either3::A(js_fn)) => {
+        let ts_fn = Arc::new(
+          js_fn
+            .build_threadsafe_function::<()>()
+            .callee_handled::<false>()
+            .max_queue_size::<0>()
+            .weak::<true>()
+            .build()?,
+        );
+        Some(Box::new(
+          move || -> BoxFuture<'static, rspack_error::Result<()>> {
+            let ts_fn = ts_fn.clone();
+            Box::pin(async move { ts_fn.call_async(()).await.to_rspack_result() })
+          },
+        ))
+      }
+      _ => None,
+    };
+
+    Ok(Self {
+      coordinator: value.coordinator.i.clone(),
+      on_server_component_changes,
+    })
+  }
+}

crates/rspack_binding_api/src/raw_options/raw_builtins/mod.rs

@@ -26,7 +26,7 @@ use std::cell::RefCell;
 
 use napi::{
   Either, Env, Unknown,
-  bindgen_prelude::{FromNapiValue, JsObjectValue, Object},
+  bindgen_prelude::{ClassInstance, FromNapiValue, JsObjectValue, Object},
 };
 use napi_derive::napi;
 use raw_dll::{RawDllReferenceAgencyPluginOptions, RawFlagAllModulesAsUsedPluginOptions};
@@ -85,6 +85,7 @@ use rspack_plugin_no_emit_on_errors::NoEmitOnErrorsPlugin;
 use rspack_plugin_real_content_hash::RealContentHashPlugin;
 use rspack_plugin_remove_duplicate_modules::RemoveDuplicateModulesPlugin;
 use rspack_plugin_remove_empty_chunks::RemoveEmptyChunksPlugin;
+use rspack_plugin_rsc::{RscClientPlugin, RscServerPlugin};
 use rspack_plugin_rslib::RslibPlugin;
 use rspack_plugin_runtime::{
   ArrayPushCallbackChunkFormatPlugin, BundlerInfoPlugin, ChunkPrefetchPreloadPlugin,
@@ -126,7 +127,10 @@ use self::{
 };
 use crate::{
   options::entry::JsEntryPluginOptions,
-  plugins::{JsLoaderRspackPlugin, JsLoaderRunnerGetter},
+  plugins::{
+    JsCoordinator, JsLoaderRspackPlugin, JsLoaderRunnerGetter, JsRscClientPluginOptions,
+    JsRscServerPluginOptions,
+  },
   raw_options::{
     RawDynamicEntryPluginOptions, RawEvalDevToolModulePluginOptions, RawExternalItemWrapper,
     RawExternalsPluginOptions, RawHttpExternalsRspackPluginOptions, RawSplitChunksOptions,
@@ -236,6 +240,10 @@ pub enum BuiltinPluginName {
   ModuleInfoHeaderPlugin,
   HttpUriPlugin,
   CssChunkingPlugin,
+
+  // react server components
+  RscServerPlugin,
+  RscClientPlugin,
 }
 
 #[doc(hidden)]
@@ -839,6 +847,16 @@ impl<'a> BuiltinPlugin<'a> {
           .map_err(|report| napi::Error::from_reason(report.to_string()))?;
         plugins.push(CssChunkingPlugin::new(options.into()).boxed());
       }
+      BuiltinPluginName::RscServerPlugin => {
+        let options = &downcast_into::<JsRscServerPluginOptions>(self.options)
+          .map_err(|report| napi::Error::from_reason(report.to_string()))?;
+        plugins.push(RscServerPlugin::new(options.try_into()?).boxed());
+      }
+      BuiltinPluginName::RscClientPlugin => {
+        let options = &downcast_into::<JsRscClientPluginOptions>(self.options)
+          .map_err(|report| napi::Error::from_reason(report.to_string()))?;
+        plugins.push(RscClientPlugin::new(options.into()).boxed());
+      }
     }
     Ok(())
   }