feat: builtin react server component

Cargo.toml

@@ -43,6 +43,7 @@ dyn-clone           = { version = "1.0.17", 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.2", default-features = false }
 hashlink            = { version = "0.10.0", default-features = false }
@@ -219,6 +220,7 @@ rspack_plugin_progress                 = { version = "=0.6.3", path = "crates/rs
 rspack_plugin_real_content_hash        = { version = "=0.6.3", path = "crates/rspack_plugin_real_content_hash", default-features = false }
 rspack_plugin_remove_duplicate_modules = { version = "=0.6.3", path = "crates/rspack_plugin_remove_duplicate_modules", default-features = false }
 rspack_plugin_remove_empty_chunks      = { version = "=0.6.3", path = "crates/rspack_plugin_remove_empty_chunks", default-features = false }
+rspack_plugin_rsc                      = { version = "=0.6.3", path = "crates/rspack_plugin_rsc", default-features = false }
 rspack_plugin_rsdoctor                 = { version = "=0.6.3", path = "crates/rspack_plugin_rsdoctor", default-features = false }
 rspack_plugin_rslib                    = { version = "=0.6.3", path = "crates/rspack_plugin_rslib", default-features = false }
 rspack_plugin_rstest                   = { version = "=0.6.3", path = "crates/rspack_plugin_rstest", default-features = false }

crates/node_binding/napi-binding.d.ts

@@ -334,6 +334,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 {
@@ -602,7 +603,9 @@ export declare enum BuiltinPluginName {
   LazyCompilationPlugin = 'LazyCompilationPlugin',
   ModuleInfoHeaderPlugin = 'ModuleInfoHeaderPlugin',
   HttpUriPlugin = 'HttpUriPlugin',
-  CssChunkingPlugin = 'CssChunkingPlugin'
+  CssChunkingPlugin = 'CssChunkingPlugin',
+  ReactServerComponentsPlugin = 'ReactServerComponentsPlugin',
+  ReactClientPlugin = 'ReactClientPlugin'
 }
 
 export declare function cleanupGlobalTrace(): void
@@ -758,6 +761,10 @@ export interface JsCleanOptions {
   keep?: string | RegExp | ((path: string) => boolean)
 }
 
+export interface JsClientCompilerHandle {
+  compile: (() => Promise<undefined>)
+}
+
 export interface JsCodegenerationResult {
   sources: Record<string, string>
 }

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

@@ -202,6 +202,7 @@ 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_loader_react_refresh::ReactRefreshLoaderPlugin::new(),
       ));
@@ -409,6 +410,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::{JsClientCompilerHandle, JsReactClientPluginOptions};

crates/rspack_binding_api/src/plugins/rsc.rs

@@ -0,0 +1,84 @@
+use std::sync::Arc;
+
+use napi::{
+  Env, Status,
+  bindgen_prelude::{
+    External, ExternalRef, FromNapiValue, Function, JsObjectValue, Object, Promise, Reference,
+    WeakReference,
+  },
+  threadsafe_function::ThreadsafeFunction,
+};
+use rspack_core::CompilerId;
+use rspack_error::ToStringResultToRspackResultExt;
+use rspack_plugin_rsc::{ClientCompilerHandle, ReactClientPluginOptions};
+
+use crate::JsCompiler;
+
+#[napi(object, object_to_js = false)]
+pub struct JsClientCompilerHandle {
+  pub compile: ThreadsafeFunction<(), Promise<()>, (), Status, false, true, 0>,
+}
+
+impl From<JsClientCompilerHandle> for ClientCompilerHandle {
+  fn from(value: JsClientCompilerHandle) -> Self {
+    let ts_fn = Arc::new(value.compile);
+
+    ClientCompilerHandle::new(Box::new(move || {
+      let ts_fn = ts_fn.clone();
+      Box::pin(async move {
+        println!("Calling client compiler compile from JS");
+        let promise = ts_fn.call_async(()).await.to_rspack_result()?;
+        promise.await;
+        println!("Calling client compiler compile from JS end");
+        Ok(())
+      })
+    }))
+  }
+}
+
+type GetServerCompilerId = Box<dyn Fn() -> CompilerId + Sync + Send>;
+
+pub struct JsReactClientPluginOptions {
+  pub get_server_compiler_id:
+    ThreadsafeFunction<(), &'static External<CompilerId>, (), Status, false, true, 0>,
+}
+
+impl FromNapiValue for JsReactClientPluginOptions {
+  unsafe fn from_napi_value(
+    env: napi::sys::napi_env,
+    napi_val: napi::sys::napi_value,
+  ) -> napi::Result<Self> {
+    let obj = unsafe { Object::from_napi_value(env, napi_val)? };
+
+    let js_fn = obj.get_named_property::<Function<'static, (), &'static External<CompilerId>>>(
+      "getServerCompilerId",
+    )?;
+
+    let ts_fn = js_fn
+      .build_threadsafe_function::<()>()
+      .callee_handled::<false>()
+      .max_queue_size()
+      .weak::<true>()
+      .build()?;
+
+    Ok(Self {
+      get_server_compiler_id: ts_fn,
+    })
+  }
+}
+
+impl From<JsReactClientPluginOptions> for ReactClientPluginOptions {
+  fn from(value: JsReactClientPluginOptions) -> Self {
+    let ts_fn = Arc::new(value.get_server_compiler_id);
+
+    Self {
+      get_server_compiler_id: Box::new(move || {
+        let ts_fn = ts_fn.clone();
+        Box::pin(async move {
+          let external = ts_fn.call_async(()).await.to_rspack_result()?;
+          Ok(**external)
+        })
+      }),
+    }
+  }
+}

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

@@ -84,6 +84,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::{ReactClientPlugin, ReactServerComponentsPlugin};
 use rspack_plugin_rslib::RslibPlugin;
 use rspack_plugin_runtime::{
   ArrayPushCallbackChunkFormatPlugin, BundlerInfoPlugin, ChunkPrefetchPreloadPlugin,
@@ -126,7 +127,9 @@ use self::{
 };
 use crate::{
   options::entry::JsEntryPluginOptions,
-  plugins::{JsLoaderRspackPlugin, JsLoaderRunnerGetter},
+  plugins::{
+    JsClientCompilerHandle, JsLoaderRspackPlugin, JsLoaderRunnerGetter, JsReactClientPluginOptions,
+  },
   raw_options::{
     RawDynamicEntryPluginOptions, RawEvalDevToolModulePluginOptions, RawExternalItemWrapper,
     RawExternalsPluginOptions, RawHttpExternalsRspackPluginOptions, RawSplitChunksOptions,
@@ -236,6 +239,10 @@ pub enum BuiltinPluginName {
   ModuleInfoHeaderPlugin,
   HttpUriPlugin,
   CssChunkingPlugin,
+
+  // react server components
+  ReactServerComponentsPlugin,
+  ReactClientPlugin,
 }
 
 #[doc(hidden)]
@@ -291,7 +298,6 @@ impl<'a> BuiltinPlugin<'a> {
       }
     };
     match name {
-      // webpack also have these plugins
       BuiltinPluginName::DefinePlugin => {
         let plugin = DefinePlugin::new(
           downcast_into(self.options)
@@ -649,8 +655,6 @@ impl<'a> BuiltinPlugin<'a> {
         .boxed();
         plugins.push(plugin)
       }
-
-      // rspack specific plugins
       BuiltinPluginName::HttpExternalsRspackPlugin => {
         let plugin_options = downcast_into::<RawHttpExternalsRspackPluginOptions>(self.options)
           .map_err(|report| napi::Error::from_reason(report.to_string()))?;
@@ -833,6 +837,16 @@ impl<'a> BuiltinPlugin<'a> {
           .map_err(|report| napi::Error::from_reason(report.to_string()))?;
         plugins.push(CssChunkingPlugin::new(options.into()).boxed());
       }
+      BuiltinPluginName::ReactServerComponentsPlugin => {
+        let options = downcast_into::<JsClientCompilerHandle>(self.options)
+          .map_err(|report| napi::Error::from_reason(report.to_string()))?;
+        plugins.push(ReactServerComponentsPlugin::new(options.into()).boxed());
+      }
+      BuiltinPluginName::ReactClientPlugin => {
+        let options = downcast_into::<JsReactClientPluginOptions>(self.options)
+          .map_err(|report| napi::Error::from_reason(report.to_string()))?;
+        plugins.push(ReactClientPlugin::new(options.into()).boxed());
+      }
     }
     Ok(())
   }

crates/rspack_binding_api/src/swc.rs

@@ -1,3 +1,5 @@
+use std::sync::Arc;
+
 use napi::bindgen_prelude::within_runtime_if_available;
 use rspack_javascript_compiler::{
   JavaScriptCompiler, TransformOutput as CompilerTransformOutput, minify::JsMinifyOptions,
@@ -57,9 +59,9 @@ fn _transform(source: String, options: String) -> napi::Result<TransformOutput>
   compiler
     .transform(
       source,
-      Some(swc_core::common::FileName::Real(
+      Some(Arc::new(swc_core::common::FileName::Real(
         options.filename.clone().into(),
-      )),
+      ))),
       options,
       Some(module_source_map_kind),
       |_, _| {},

crates/rspack_cacheable/src/with/as_preset/swc.rs

@@ -1,11 +1,12 @@
 use rkyv::{
   Place,
   rancor::{Fallible, Source},
-  ser::Writer,
+  ser::{Allocator, Writer},
   string::{ArchivedString, StringResolver},
+  vec::{ArchivedVec, VecResolver},
   with::{ArchiveWith, DeserializeWith, SerializeWith},
 };
-use swc_core::ecma::atoms::Atom;
+use swc_core::{atoms::Wtf8Atom, ecma::atoms::Atom};
 
 use super::AsPreset;
 
@@ -39,3 +40,34 @@ where
     Ok(Atom::from(field.as_str()))
   }
 }
+
+impl ArchiveWith<Wtf8Atom> for AsPreset {
+  type Archived = ArchivedVec<u8>;
+  type Resolver = VecResolver;
+
+  #[inline]
+  fn resolve_with(field: &Wtf8Atom, resolver: Self::Resolver, out: Place<Self::Archived>) {
+    ArchivedVec::resolve_from_len(field.as_bytes().len(), resolver, out);
+  }
+}
+
+impl<S> SerializeWith<Wtf8Atom, S> for AsPreset
+where
+  S: Fallible + Allocator + Writer + ?Sized,
+  S::Error: Source,
+{
+  #[inline]
+  fn serialize_with(field: &Wtf8Atom, serializer: &mut S) -> Result<Self::Resolver, S::Error> {
+    ArchivedVec::serialize_from_slice(field.as_bytes(), serializer)
+  }
+}
+
+impl<D> DeserializeWith<ArchivedVec<u8>, Wtf8Atom, D> for AsPreset
+where
+  D: ?Sized + Fallible,
+{
+  #[inline]
+  fn deserialize_with(field: &ArchivedVec<u8>, _: &mut D) -> Result<Wtf8Atom, D::Error> {
+    Ok(unsafe { Wtf8Atom::from_bytes_unchecked(field) })
+  }
+}

crates/rspack_core/src/dependency/dependency_category.rs

@@ -19,6 +19,7 @@ pub enum DependencyCategory {
   Wasm,
   Worker,
   LoaderImport,
+  ClientReference,
 }
 
 impl From<&str> for DependencyCategory {
@@ -35,6 +36,7 @@ impl From<&str> for DependencyCategory {
       "loaderImport" => Self::LoaderImport,
       "worker" => Self::Worker,
       "unknown" => Self::Unknown,
+      "client-reference" => Self::Unknown,
       _ => Self::Unknown,
     }
   }
@@ -55,6 +57,7 @@ impl DependencyCategory {
       DependencyCategory::Wasm => "wasm",
       DependencyCategory::Worker => "worker",
       DependencyCategory::LoaderImport => "loaderImport",
+      DependencyCategory::ClientReference => "client-reference",
     }
   }
 }