feat: support modify resource in after resolve hook

Author: LingyuCoder

crates/node_binding/binding.d.ts

@@ -123,13 +123,20 @@ export function __chunk_inner_is_only_initial(jsChunkUkey: number, compilation:
 
 export function __entrypoint_inner_get_runtime_chunk(ukey: number, compilation: JsCompilation): JsChunk
 
+export interface AfterResolveCreateData {
+  request: string
+  userRequest: string
+  resource: string
+}
+
 export interface AfterResolveData {
   request: string
   context: string
   fileDependencies: Array<string>
   contextDependencies: Array<string>
   missingDependencies: Array<string>
   factoryMeta: FactoryMeta
+  createData?: AfterResolveCreateData
 }
 
 export interface BeforeResolveData {
@@ -348,7 +355,7 @@ export interface JsHooks {
   buildModule: (module: JsModule) => void
   chunkAsset: (asset: JsChunkAssetArgs) => void
   beforeResolve: (data: BeforeResolveData) => Promise<(boolean | void | BeforeResolveData)[]>
-  afterResolve: (data: AfterResolveData) => Promise<boolean | void>
+  afterResolve: (data: AfterResolveData) => Promise<(boolean | void | AfterResolveCreateData)[]>
   contextModuleFactoryBeforeResolve: (data: BeforeResolveData) => Promise<boolean | void>
   contextModuleFactoryAfterResolve: (data: AfterResolveData) => Promise<boolean | void>
   normalModuleFactoryCreateModule: (data: CreateModuleData) => void

crates/node_binding/src/plugins/mod.rs

@@ -16,7 +16,7 @@ use rspack_binding_values::{
 use rspack_core::rspack_sources::Source;
 use rspack_core::{
   ApplyContext, BuildTimeExecutionOption, Chunk, ChunkAssetArgs, CompilerOptions, ModuleIdentifier,
-  NormalModuleAfterResolveArgs, PluginContext, RuntimeModule,
+  NormalModuleAfterResolveArgs, NormalModuleAfterResolveCreateData, PluginContext, RuntimeModule,
 };
 use rspack_core::{NormalModuleBeforeResolveArgs, PluginNormalModuleFactoryAfterResolveOutput};
 use rspack_core::{
@@ -140,7 +140,36 @@ impl rspack_core::Plugin for JsHooksAdapterPlugin {
     if self.is_hook_disabled(&Hook::AfterResolve) {
       return Ok(None);
     }
-    self.hooks.after_resolve.call((&*args).into()).await
+
+    match self.hooks.after_resolve.call((&*args).into()).await {
+      Ok((ret, resolve_data)) => {
+        if let (Some(resolve_data), Some(create_data)) = (resolve_data, &args.create_data) {
+          fn override_resource(origin_data: &ResourceData, new_resource: String) -> ResourceData {
+            let mut resource_data = origin_data.clone();
+            let origin_resource_path = origin_data.resource_path.to_string_lossy().to_string();
+            resource_data.resource_path = new_resource.clone().into();
+            resource_data.resource = resource_data
+              .resource
+              .replace(&origin_resource_path, &new_resource);
+
+            resource_data
+          }
+
+          let request = resolve_data.request;
+          let user_request = resolve_data.user_request;
+          let resource = override_resource(&create_data.resource, resolve_data.resource);
+
+          args.create_data = Some(NormalModuleAfterResolveCreateData {
+            request,
+            user_request,
+            resource,
+          });
+        }
+
+        Ok(ret)
+      }
+      Err(err) => Err(err),
+    }
   }
 
   async fn context_module_before_resolve(

crates/rspack_binding_values/src/hooks.rs

@@ -2,9 +2,9 @@ use napi_derive::napi;
 use rspack_napi_shared::new_tsfn::ThreadsafeFunction;
 
 use crate::{
-  AfterResolveData, BeforeResolveData, CreateModuleData, JsAssetEmittedArgs, JsChunkAssetArgs,
-  JsCompilation, JsExecuteModuleArg, JsModule, JsResolveForSchemeInput, JsResolveForSchemeResult,
-  JsRuntimeModule, JsRuntimeModuleArg,
+  AfterResolveCreateData, AfterResolveData, BeforeResolveData, CreateModuleData,
+  JsAssetEmittedArgs, JsChunkAssetArgs, JsCompilation, JsExecuteModuleArg, JsModule,
+  JsResolveForSchemeInput, JsResolveForSchemeResult, JsRuntimeModule, JsRuntimeModuleArg,
 };
 
 #[napi(object, object_to_js = false)]
@@ -43,8 +43,11 @@ pub struct JsHooks {
   pub chunk_asset: ThreadsafeFunction<JsChunkAssetArgs, ()>,
   #[napi(ts_type = "(data: BeforeResolveData) => Promise<(boolean | void | BeforeResolveData)[]>")]
   pub before_resolve: ThreadsafeFunction<BeforeResolveData, (Option<bool>, BeforeResolveData)>,
-  #[napi(ts_type = "(data: AfterResolveData) => Promise<boolean | void>")]
-  pub after_resolve: ThreadsafeFunction<AfterResolveData, Option<bool>>,
+  #[napi(
+    ts_type = "(data: AfterResolveData) => Promise<(boolean | void | AfterResolveCreateData)[]>"
+  )]
+  pub after_resolve:
+    ThreadsafeFunction<AfterResolveData, (Option<bool>, Option<AfterResolveCreateData>)>,
   #[napi(ts_type = "(data: BeforeResolveData) => Promise<boolean | void>")]
   pub context_module_factory_before_resolve: ThreadsafeFunction<BeforeResolveData, Option<bool>>,
   #[napi(ts_type = "(data: AfterResolveData) => Promise<boolean | void>")]

crates/rspack_binding_values/src/normal_module_factory.rs

@@ -1,6 +1,7 @@
 use napi_derive::napi;
 use rspack_core::{
-  NormalModuleAfterResolveArgs, NormalModuleBeforeResolveArgs, NormalModuleCreateData, ResourceData,
+  NormalModuleAfterResolveArgs, NormalModuleAfterResolveCreateData, NormalModuleBeforeResolveArgs,
+  NormalModuleCreateData, ResourceData,
 };
 
 #[napi(object)]
@@ -21,6 +22,13 @@ pub struct BeforeResolveData {
   pub context: String,
 }
 
+#[napi(object)]
+pub struct AfterResolveCreateData {
+  pub request: String,
+  pub user_request: String,
+  pub resource: String,
+}
+
 #[napi(object)]
 pub struct AfterResolveData {
   pub request: String,
@@ -29,6 +37,7 @@ pub struct AfterResolveData {
   pub context_dependencies: Vec<String>,
   pub missing_dependencies: Vec<String>,
   pub factory_meta: FactoryMeta,
+  pub create_data: Option<AfterResolveCreateData>,
 }
 
 #[napi(object)]
@@ -122,6 +131,17 @@ impl From<&NormalModuleAfterResolveArgs<'_>> for AfterResolveData {
       factory_meta: FactoryMeta {
         side_effect_free: value.factory_meta.side_effect_free,
       },
+      create_data: value.create_data.as_ref().map(AfterResolveCreateData::from),
+    }
+  }
+}
+
+impl From<&NormalModuleAfterResolveCreateData> for AfterResolveCreateData {
+  fn from(value: &NormalModuleAfterResolveCreateData) -> Self {
+    Self {
+      request: value.request.to_owned(),
+      user_request: value.user_request.to_owned(),
+      resource: value.resource.resource_path.to_string_lossy().to_string(),
     }
   }
 }

crates/rspack_core/src/context_module_factory.rs

@@ -234,6 +234,7 @@ impl ContextModuleFactory {
         missing_dependencies: &data.missing_dependencies,
         diagnostics: &mut data.diagnostics,
         factory_meta: &factory_result.factory_meta,
+        create_data: None,
       })
       .await
   }

crates/rspack_core/src/normal_module_factory.rs

@@ -17,9 +17,9 @@ use crate::{
   FuncUseCtx, GeneratorOptions, ModuleExt, ModuleFactory, ModuleFactoryCreateData,
   ModuleFactoryResult, ModuleIdentifier, ModuleRule, ModuleRuleEnforce, ModuleRuleUse,
   ModuleRuleUseLoader, ModuleType, NormalModule, NormalModuleAfterResolveArgs,
-  NormalModuleBeforeResolveArgs, NormalModuleCreateData, ParserOptions, RawModule, Resolve,
-  ResolveArgs, ResolveOptionsWithDependencyType, ResolveResult, Resolver, ResolverFactory,
-  ResourceData, ResourceParsedData, SharedPluginDriver,
+  NormalModuleAfterResolveCreateData, NormalModuleBeforeResolveArgs, NormalModuleCreateData,
+  ParserOptions, RawModule, Resolve, ResolveArgs, ResolveOptionsWithDependencyType, ResolveResult,
+  Resolver, ResolverFactory, ResourceData, ResourceParsedData, SharedPluginDriver,
 };
 
 #[derive(Debug, Default)]
@@ -43,9 +43,6 @@ impl ModuleFactory for NormalModuleFactory {
       return Ok(before_resolve_data);
     }
     let factory_result = self.factorize(data).await?;
-    if let Ok(Some(after_resolve_data)) = self.after_resolve(data, &factory_result).await {
-      return Ok(after_resolve_data);
-    }
 
     Ok(factory_result)
   }
@@ -105,35 +102,6 @@ impl NormalModuleFactory {
     Ok(None)
   }
 
-  async fn after_resolve(
-    &self,
-    data: &mut ModuleFactoryCreateData,
-    factory_result: &ModuleFactoryResult,
-  ) -> Result<Option<ModuleFactoryResult>> {
-    let dependency = data
-      .dependency
-      .as_module_dependency()
-      .expect("should be module dependency");
-    if let Ok(Some(false)) = self
-      .plugin_driver
-      .after_resolve(&mut NormalModuleAfterResolveArgs {
-        request: dependency.request(),
-        context: data.context.as_ref(),
-        file_dependencies: &data.file_dependencies,
-        context_dependencies: &data.context_dependencies,
-        missing_dependencies: &data.missing_dependencies,
-        factory_meta: &factory_result.factory_meta,
-        diagnostics: &mut data.diagnostics,
-      })
-      .await
-    {
-      // ignored
-      // See https://github.com/webpack/webpack/blob/6be4065ade1e252c1d8dcba4af0f43e32af1bdc1/lib/NormalModuleFactory.js#L301
-      return Ok(Some(ModuleFactoryResult::default()));
-    }
-    Ok(None)
-  }
-
   fn get_loader_resolver(&self) -> Arc<Resolver> {
     self
       .loader_resolver_factory
@@ -575,10 +543,43 @@ impl NormalModuleFactory {
         )
       })?();
 
+    let after_resolve_create_data = {
+      let mut after_resolve_args = NormalModuleAfterResolveArgs {
+        request: dependency.request(),
+        context: data.context.as_ref(),
+        file_dependencies: &data.file_dependencies,
+        context_dependencies: &data.context_dependencies,
+        missing_dependencies: &data.missing_dependencies,
+        factory_meta: &factory_meta,
+        diagnostics: &mut data.diagnostics,
+        create_data: Some(NormalModuleAfterResolveCreateData {
+          request,
+          user_request,
+          resource: resource_data,
+        }),
+      };
+
+      if let Some(plugin_result) = self
+        .plugin_driver
+        .after_resolve(&mut after_resolve_args)
+        .await?
+      {
+        if !plugin_result {
+          // ignored
+          // See https://github.com/webpack/webpack/blob/6be4065ade1e252c1d8dcba4af0f43e32af1bdc1/lib/NormalModuleFactory.js#L301
+          return Ok(Some(ModuleFactoryResult::default()));
+        }
+      }
+
+      after_resolve_args
+        .create_data
+        .unwrap_or_else(|| unreachable!())
+    };
+
     let mut create_data = NormalModuleCreateData {
       dependency_type: data.dependency.dependency_type().clone(),
       resolve_data_request: dependency.request(),
-      resource_resolve_data: resource_data.clone(),
+      resource_resolve_data: after_resolve_create_data.resource.clone(),
       context: data.context.clone(),
       diagnostics: &mut data.diagnostics,
     };
@@ -590,15 +591,15 @@ impl NormalModuleFactory {
       module
     } else {
       let normal_module = NormalModule::new(
-        request,
-        user_request,
+        after_resolve_create_data.request,
+        after_resolve_create_data.user_request,
         dependency.request().to_owned(),
         resolved_module_type,
         resolved_parser_and_generator,
         resolved_parser_options,
         resolved_generator_options,
         match_resource_data,
-        resource_data,
+        after_resolve_create_data.resource,
         resolved_resolve_options,
         loaders,
         contains_inline,

crates/rspack_core/src/plugin/args.rs

@@ -82,6 +82,13 @@ pub struct NormalModuleCreateData<'a> {
   pub diagnostics: &'a mut Vec<Diagnostic>,
 }
 
+#[derive(Debug)]
+pub struct NormalModuleAfterResolveCreateData {
+  pub request: String,
+  pub user_request: String,
+  pub resource: ResourceData,
+}
+
 #[derive(Debug, Clone)]
 pub struct NormalModuleBeforeResolveArgs {
   pub request: String,
@@ -96,6 +103,7 @@ pub struct NormalModuleAfterResolveArgs<'a> {
   pub missing_dependencies: &'a HashSet<PathBuf>,
   pub factory_meta: &'a FactoryMeta,
   pub diagnostics: &'a mut Vec<Diagnostic>,
+  pub create_data: Option<NormalModuleAfterResolveCreateData>,
 }
 
 #[derive(Debug)]

packages/rspack/src/Compiler.ts

@@ -532,8 +532,8 @@ class Compiler {
 				(hook.taps
 					? !hook.isUsed()
 					: hook._map
-					? /* hook map */ hook._map.size === 0
-					: false)
+						? /* hook map */ hook._map.size === 0
+						: false)
 			) {
 				disabledHooks.push(name);
 			}
@@ -616,7 +616,7 @@ class Compiler {
 			}
 		);
 		this.#updateDisabledHooks();
-		return res;
+		return [res, resolveData.createData];
 	}
 
 	async #contextModuleFactoryBeforeResolve(

packages/rspack/tests/configCases/hooks/after-resolve-resource/a.js

@@ -0,0 +1 @@
+module.exports = "a"

packages/rspack/tests/configCases/hooks/after-resolve-resource/b.js

@@ -0,0 +1 @@
+module.exports = "b"

packages/rspack/tests/configCases/hooks/after-resolve-resource/c.js

@@ -0,0 +1 @@
+module.exports = "c"

packages/rspack/tests/configCases/hooks/after-resolve-resource/duplicate.js

@@ -0,0 +1,14 @@
+import a from "./a";
+import b from "./b"; // b.js will be transform to c.js
+import c from "./c";
+import fs from "fs";
+
+it("should remove duplicate request modules generate by after resolve hook", () => {
+  expect(a).toBe("a");
+  expect(b).toBe("c");
+  expect(c).toBe("c");
+  const ext = ".js";
+  expect(fs.readFileSync(__filename, "utf-8")).not.toContain("./b" + ext);
+  expect(fs.readFileSync(__filename, "utf-8")).toContain("./c" + ext);
+  expect(fs.readFileSync(__filename, "utf-8").split("./c" + ext).length - 1).toBe(2);
+});

packages/rspack/tests/configCases/hooks/after-resolve-resource/request.js

@@ -0,0 +1,10 @@
+import a from "./a";
+import b from "./b";
+import fs from "fs";
+
+it("should modify request by after resolve hook", () => {
+  expect(a).toBe("a");
+  expect(b).toBe("b");
+  const ext = ".js";
+  expect(fs.readFileSync(__filename, "utf-8")).toContain("./c" + ext);
+});

packages/rspack/tests/configCases/hooks/after-resolve-resource/resource.js

@@ -0,0 +1,10 @@
+import a from "./a";
+import b from "./b";
+import fs from "fs";
+
+it("should modify resource by after resolve hook", () => {
+  expect(a).toBe("a")
+  expect(b).toBe("c")
+  const ext = ".js";
+  expect(fs.readFileSync(__filename, "utf-8")).toContain("./b" + ext);
+});

packages/rspack/tests/configCases/hooks/after-resolve-resource/test.config.js

@@ -0,0 +1,9 @@
+module.exports = {
+  findBundle(index) {
+    switch (index) {
+      case 0: return ['resource.js'];
+      case 1: return ['request.js'];
+      case 2: return ['duplicate.js'];
+    }
+  }
+};