1use super::*;
2
3pub fn has_build_mode_flag(wasm_pack_args: &[String]) -> bool {
16 wasm_pack_args
17 .iter()
18 .any(|arg: &String| arg == DEV_FLAG || arg == RELEASE_FLAG || arg == PROFILING_FLAG)
19}
20
21pub fn filter_euv_args(wasm_pack_args: &[String]) -> Vec<String> {
36 let raw_args: &[String] = if let Some(position) = wasm_pack_args
37 .iter()
38 .rposition(|arg: &String| arg == DOUBLE_DASH)
39 {
40 &wasm_pack_args[position + 1..]
41 } else {
42 wasm_pack_args
43 };
44 let mut filtered: Vec<String> = Vec::new();
45 let mut skip_next: bool = false;
46 for arg in raw_args {
47 if skip_next {
48 skip_next = false;
49 continue;
50 }
51 let name: &str = arg.split('=').next().unwrap_or(arg.as_str());
57 if EUV_ARGS.contains(&name) {
58 if arg.contains('=') || name == NO_GITIGNORE_ARG {
59 continue;
63 }
64 skip_next = true;
65 continue;
66 }
67 filtered.push(arg.clone());
68 }
69 filtered
70}
71
72pub fn reconcile_args(args: &mut ModeArgs) {
87 let wasm_pack_args: Vec<String> = args.get_wasm_pack_args().clone();
88 let mut crate_path: Option<PathBuf> = None;
89 let mut port: Option<u16> = None;
90 let mut www_dir: Option<String> = None;
91 let mut index_html: Option<Option<PathBuf>> = None;
92 let mut no_gitignore: Option<bool> = None;
93 let mut dev: Option<bool> = None;
94 let mut release: Option<bool> = None;
95 let mut profiling: Option<bool> = None;
96 let mut iter: Iter<String> = wasm_pack_args.iter();
97 while let Some(arg) = iter.next() {
98 match arg.as_str() {
99 CRATE_PATH_ARG | CRATE_PATH_ARG_SHORT => {
100 if let Some(value) = iter.next() {
101 crate_path = Some(PathBuf::from(value));
102 }
103 }
104 PORT_ARG | PORT_ARG_SHORT => {
105 if let Some(value) = iter.next()
106 && let Ok(parsed_port) = value.parse::<u16>()
107 {
108 port = Some(parsed_port);
109 }
110 }
111 WWW_DIR_ARG => {
112 if let Some(value) = iter.next() {
113 www_dir = Some(value.clone());
114 }
115 }
116 INDEX_HTML_ARG => {
117 if let Some(value) = iter.next() {
118 index_html = Some(Some(PathBuf::from(value)));
119 }
120 }
121 NO_GITIGNORE_ARG => {
122 no_gitignore = Some(true);
123 }
124 DEV_FLAG => {
125 dev = Some(true);
126 }
127 RELEASE_FLAG => {
128 release = Some(true);
129 }
130 PROFILING_FLAG => {
131 profiling = Some(true);
132 }
133 other => {
134 if let Some(value) = other.strip_prefix(&format!("{CRATE_PATH_ARG}=")) {
135 crate_path = Some(PathBuf::from(value));
136 } else if let Some(value) = other.strip_prefix(&format!("{PORT_ARG}=")) {
137 if let Ok(parsed_port) = value.parse::<u16>() {
138 port = Some(parsed_port);
139 }
140 } else if let Some(value) = other.strip_prefix(&format!("{WWW_DIR_ARG}=")) {
141 www_dir = Some(value.to_string());
142 } else if let Some(value) = other.strip_prefix(&format!("{INDEX_HTML_ARG}=")) {
143 index_html = Some(Some(PathBuf::from(value)));
144 }
145 }
146 }
147 }
148 if let Some(value) = crate_path {
149 args.set_crate_path(value);
150 }
151 if let Some(value) = port {
152 args.set_port(value);
153 }
154 if let Some(value) = www_dir {
155 args.set_www_dir(value);
156 }
157 if let Some(value) = index_html {
158 args.set_index_html(value);
159 }
160 if let Some(value) = no_gitignore {
161 args.set_no_gitignore(value);
162 }
163 if let Some(value) = dev {
164 args.set_dev(value);
165 }
166 if let Some(value) = release {
167 args.set_release(value);
168 }
169 if let Some(value) = profiling {
170 args.set_profiling(value);
171 }
172}
173
174pub fn resolve_build_mode(args: &ModeArgs) -> BuildMode {
189 if args.get_profiling() {
190 BuildMode::Profiling
191 } else if args.get_release() {
192 BuildMode::Release
193 } else if args.get_dev() {
194 BuildMode::Dev
195 } else if args
196 .get_wasm_pack_args()
197 .iter()
198 .any(|arg: &String| arg == PROFILING_FLAG)
199 {
200 BuildMode::Profiling
201 } else if args
202 .get_wasm_pack_args()
203 .iter()
204 .any(|arg: &String| arg == RELEASE_FLAG)
205 {
206 BuildMode::Release
207 } else {
208 BuildMode::Dev
209 }
210}
211
212pub fn build_mode_to_flag(build_mode: BuildMode) -> &'static str {
222 match build_mode {
223 BuildMode::Dev => DEV_FLAG,
224 BuildMode::Release => RELEASE_FLAG,
225 BuildMode::Profiling => PROFILING_FLAG,
226 }
227}
228
229async fn build_gitignore(root: &PathBuf) -> Gitignore {
239 let gitignore_path: PathBuf = root.join(GITIGNORE_FILE_NAME);
240 let mut builder: GitignoreBuilder = GitignoreBuilder::new(root);
241 let gitignore_exists: bool = metadata(&gitignore_path).await.is_ok();
242 if gitignore_exists && let Some(error) = builder.add(&gitignore_path) {
243 log::warn!("Failed to load .gitignore: {error}");
244 }
245 match builder.build() {
246 Ok(gitignore) => {
247 if gitignore_exists {
248 log::info!("Loaded .gitignore to filter file change events");
249 }
250 gitignore
251 }
252 Err(error) => {
253 log::warn!("Failed to build gitignore matcher: {error}");
254 GitignoreBuilder::new(root)
255 .build()
256 .unwrap_or_else(|_error: ignore::Error| Gitignore::empty())
257 }
258 }
259}
260
261fn extract_out_name(wasm_pack_args: &[String]) -> Option<String> {
273 let mut iter: Iter<'_, String> = wasm_pack_args.iter();
274 while let Some(arg) = iter.next() {
275 if arg == OUT_NAME_ARG {
276 return iter.next().cloned();
277 }
278 if let Some(value) = arg.strip_prefix(&format!("{OUT_NAME_ARG}=")) {
279 return Some(value.to_string());
280 }
281 }
282 None
283}
284
285fn extract_out_dir(wasm_pack_args: &[String]) -> Option<String> {
297 let mut iter: Iter<'_, String> = wasm_pack_args.iter();
298 while let Some(arg) = iter.next() {
299 if arg == OUT_DIR_ARG {
300 return iter.next().cloned();
301 }
302 if let Some(value) = arg.strip_prefix(&format!("{OUT_DIR_ARG}=")) {
303 return Some(value.to_string());
304 }
305 }
306 None
307}
308
309pub fn resolve_out_name(args: &ModeArgs) -> String {
324 let name: String = if let Some(out_name) = extract_out_name(args.get_wasm_pack_args()) {
325 out_name.replace(STR_HYPHEN, STR_UNDERSCORE)
326 } else {
327 let cargo_toml_path: PathBuf = args.get_crate_path().join(CARGO_TOML_FILE_NAME);
328 read_crate_name_from_toml(&cargo_toml_path)
329 .unwrap_or_else(|| {
330 args.get_crate_path()
331 .file_name()
332 .unwrap_or_default()
333 .to_string_lossy()
334 .to_string()
335 })
336 .replace(STR_HYPHEN, STR_UNDERSCORE)
337 };
338 format!("{name}{JS_EXTENSION}")
339}
340
341fn read_crate_name_from_toml(path: &Path) -> Option<String> {
353 let content: String = sync_read_to_string(path).ok()?;
354 let mut in_package: bool = false;
355 for line in content.lines() {
356 let trimmed: &str = line.trim();
357 if trimmed.starts_with('[') {
358 in_package = trimmed == "[package]";
359 continue;
360 }
361 if in_package
362 && trimmed.starts_with("name")
363 && let Some(value) = trimmed.strip_prefix("name")
364 {
365 let value: &str = value.trim().strip_prefix('=')?.trim();
366 let value: &str = value.strip_prefix('"')?.strip_suffix('"')?;
367 return Some(value.to_string());
368 }
369 }
370 None
371}
372
373fn compute_relative_path(base: &Path, target: &Path) -> PathBuf {
387 let base_components: Vec<Component> = base.components().collect();
388 let target_components: Vec<Component> = target.components().collect();
389 let common_len: usize = base_components
390 .iter()
391 .zip(target_components.iter())
392 .take_while(
393 |(base_component, target_component): &(&Component, &Component)| {
394 base_component == target_component
395 },
396 )
397 .count();
398 let mut result: PathBuf = PathBuf::new();
399 for _ in &base_components[common_len..] {
400 result.push("..");
401 }
402 for component in &target_components[common_len..] {
403 if let Component::Normal(os_str) = component {
404 result.push(os_str);
405 }
406 }
407 result
408}
409
410pub async fn resolve_serving_root(args: &ModeArgs) -> PathBuf {
424 let www_absolute: PathBuf = args.get_crate_path().join(args.get_www_dir());
425 let out_dir_absolute: PathBuf = resolve_out_dir(args);
426 if out_dir_absolute.strip_prefix(&www_absolute).is_ok() {
427 resolve_www_dir(&www_absolute).await
428 } else {
429 out_dir_absolute
430 .parent()
431 .map(|p: &Path| p.to_path_buf())
432 .unwrap_or_else(|| www_absolute)
433 }
434}
435
436pub fn resolve_serving_route_prefix(args: &ModeArgs) -> String {
449 let www_absolute: PathBuf = args.get_crate_path().join(args.get_www_dir());
450 let out_dir_absolute: PathBuf = resolve_out_dir(args);
451 let serving_root: PathBuf = if out_dir_absolute.strip_prefix(&www_absolute).is_ok() {
452 www_absolute
453 } else {
454 out_dir_absolute
455 .parent()
456 .map(|p: &Path| p.to_path_buf())
457 .unwrap_or_else(|| www_absolute)
458 };
459 serving_root
460 .strip_prefix(args.get_crate_path())
461 .map(|rel: &Path| {
462 rel.to_string_lossy()
463 .replace(CHAR_SLASH_BACK, STR_SLASH_FORWARD)
464 })
465 .unwrap_or_else(|_| {
466 serving_root
467 .file_name()
468 .and_then(|name: &ffi::OsStr| name.to_str())
469 .unwrap_or_default()
470 .to_string()
471 })
472}
473
474pub fn resolve_import_path(args: &ModeArgs) -> String {
488 let out_name: String = resolve_out_name(args);
489 let www_absolute: PathBuf = args.get_crate_path().join(args.get_www_dir());
490 let out_dir_absolute: PathBuf = resolve_out_dir(args);
491 let serving_root: PathBuf = if out_dir_absolute.strip_prefix(&www_absolute).is_ok() {
492 www_absolute
493 } else {
494 out_dir_absolute
495 .parent()
496 .map(|p: &Path| p.to_path_buf())
497 .unwrap_or_else(|| www_absolute)
498 };
499 let relative: PathBuf = compute_relative_path(&serving_root, &out_dir_absolute);
500 let mut components: Vec<String> = relative
501 .components()
502 .filter_map(|component: Component| match component {
503 Component::Normal(os_str) => os_str.to_str().map(|text: &str| text.to_string()),
504 Component::ParentDir => Some(PARENT_DIR.to_string()),
505 _ => None,
506 })
507 .collect();
508 components.push(out_name);
509 format!("{RELATIVE_PATH_PREFIX}{}", components.join(PATH_SEPARATOR))
510}
511
512pub fn resolve_out_dir(args: &ModeArgs) -> PathBuf {
527 let out_dir_path: PathBuf = PathBuf::from(
528 extract_out_dir(args.get_wasm_pack_args())
529 .unwrap_or_else(|| format!("{}/{PKG_DIR_NAME}", args.get_www_dir())),
530 );
531 if out_dir_path.is_absolute() {
532 out_dir_path
533 } else {
534 args.get_crate_path().join(&out_dir_path)
535 }
536}
537
538pub async fn run_build_only_pipeline(args: &ModeArgs) -> Result<(), EuvError> {
553 let src_path: PathBuf = args.get_crate_path().join(SRC_DIR_NAME);
554 if let Err(error) = format_dir(&src_path, FmtMode::Write).await {
555 log::warn!("euv fmt error: {error}");
556 }
557 build_wasm(args).await?;
558 log::info!("WASM build completed successfully");
559 finalize_html_output(args, false).await?;
560 Ok(())
561}
562
563pub(crate) async fn finalize_html_output(
579 args: &ModeArgs,
580 is_dev_server: bool,
581) -> Result<String, EuvError> {
582 let html_config: HtmlConfig = HtmlConfig::new(
583 resolve_serving_root(args).await,
584 resolve_import_path(args),
585 resolve_build_mode(args) == BuildMode::Release,
586 args.try_get_index_html().clone(),
587 is_dev_server.then(|| resolve_serving_route_prefix(args)),
588 );
589 let html: String = generate_html(&html_config).await?;
590 let pkg_dir: PathBuf = resolve_out_dir(args);
591 let removed: Vec<PathBuf> = remove_generated_js(&pkg_dir).await?;
592 if !removed.is_empty() {
593 log::info!(
594 "Inlined {} generated JavaScript file(s) into {} and removed them from {}",
595 removed.len(),
596 INDEX_HTML_FILE_NAME,
597 pkg_dir.display()
598 );
599 }
600 assert_no_js_artifacts(&pkg_dir).await?;
601 Ok(html)
602}
603
604async fn assert_no_js_artifacts(pkg_dir: &Path) -> Result<(), EuvError> {
619 let mut pending: Vec<PathBuf> = vec![pkg_dir.to_path_buf()];
620 while let Some(dir) = pending.pop() {
621 let mut entries: ReadDir =
622 read_dir(&dir)
623 .await
624 .map_err(|error: io::Error| EuvError::IoPath {
625 message: String::from("Failed to inspect finalized WASM output"),
626 path: dir.clone(),
627 error,
628 })?;
629 while let Some(entry) =
630 entries
631 .next_entry()
632 .await
633 .map_err(|error: io::Error| EuvError::IoPath {
634 message: String::from("Failed to inspect an entry of finalized WASM output"),
635 path: dir.clone(),
636 error,
637 })?
638 {
639 let path: PathBuf = entry.path();
640 let file_type: FileType =
641 entry
642 .file_type()
643 .await
644 .map_err(|error: io::Error| EuvError::IoPath {
645 message: String::from("Failed to inspect a finalized WASM output file"),
646 path: path.clone(),
647 error,
648 })?;
649 if file_type.is_dir() {
650 pending.push(path);
651 continue;
652 }
653 if is_generated_js_artifact(&path) {
654 return Err(EuvError::Message(format!(
655 "{} survived the cleanup, so this build would deploy JavaScript; \
656 the page no longer imports it, and it cannot be served",
657 path.display()
658 )));
659 }
660 }
661 }
662 Ok(())
663}
664
665pub async fn clean_out_dir(out_dir: &Path) {
675 let mut entries: ReadDir = match read_dir(out_dir).await {
676 Ok(dir) => dir,
677 Err(_) => return,
678 };
679 while let Ok(Some(entry)) = entries.next_entry().await {
680 let path: PathBuf = entry.path();
681 if path.is_dir() {
682 if let Err(error) = remove_dir_all(&path).await {
683 log::warn!("Failed to remove directory '{}': {error}", path.display());
684 }
685 } else if let Err(error) = remove_file(&path).await {
686 log::warn!("Failed to remove file '{}': {error}", path.display());
687 }
688 }
689}
690
691pub async fn run_build_pipeline(
708 args: &ModeArgs,
709 reload_tx: Option<&broadcast::Sender<ReloadEvent>>,
710) -> Result<String, EuvError> {
711 let src_path: PathBuf = args.get_crate_path().join(SRC_DIR_NAME);
712 if let Err(error) = format_dir(&src_path, FmtMode::Write).await {
713 log::warn!("euv fmt error: {error}");
714 }
715 if let Err(error) = build_wasm(args).await {
716 log::error!("WASM build failed: {error}");
717 notify_reload(reload_tx, Err(error.to_string()));
718 return Err(error);
719 }
720 log::info!("WASM build completed successfully");
721 let html: String = match finalize_html_output(args, true).await {
722 Ok(html) => html,
723 Err(error) => {
724 log::error!("Page generation failed: {error}");
725 notify_reload(reload_tx, Err(error.to_string()));
726 return Err(error);
727 }
728 };
729 notify_reload(reload_tx, Ok(()));
730 Ok(html)
731}
732
733fn notify_reload(reload_tx: Option<&broadcast::Sender<ReloadEvent>>, outcome: Result<(), String>) {
741 let Some(sender) = reload_tx else {
742 return;
743 };
744 let event: ReloadEvent = match outcome {
745 Ok(()) => ReloadEvent::Reload,
746 Err(message) => ReloadEvent::Error(message),
747 };
748 let _: Result<usize, tokio::sync::broadcast::error::SendError<ReloadEvent>> =
749 sender.send(event);
750}
751
752pub(crate) async fn watch_and_build(state: Arc<AppState>) -> Result<(), EuvError> {
762 let crate_path: PathBuf = state.get_args().get_crate_path().clone();
763 let src_path: PathBuf = crate_path.join(SRC_DIR_NAME);
764 let gitignore: Gitignore = build_gitignore(&crate_path).await;
765 let (tx, mut rx): (Sender<Event>, Receiver<Event>) = channel(32);
766 let mut watcher: RecommendedWatcher = RecommendedWatcher::new(
767 move |result: Result<Event, notify::Error>| {
768 if let Ok(event) = result {
769 let _: Result<(), tokio::sync::mpsc::error::SendError<Event>> =
770 tx.blocking_send(event);
771 }
772 },
773 Config::default(),
774 )?;
775 watcher.watch(&src_path, RecursiveMode::Recursive)?;
776 log::info!("Watching {} for changes...", src_path.display());
777 let mut debounce: Interval = interval(Duration::from_millis(500));
778 debounce.tick().await;
779 while let Some(event) = rx.recv().await {
780 let filtered_paths: Vec<String> = event
781 .paths
782 .iter()
783 .filter(|path: &&PathBuf| !gitignore.matched(*path, path.is_dir()).is_ignore())
784 .map(|path: &PathBuf| path.display().to_string())
785 .collect();
786 if filtered_paths.is_empty() {
787 continue;
788 }
789 log::warn!("File change detected: {}", filtered_paths.join(", "));
790 debounce.reset();
791 sleep(Duration::from_millis(300)).await;
792 let mut building: RwLockWriteGuard<bool> = state.get_is_building().write().await;
793 if *building {
794 continue;
795 }
796 *building = true;
797 drop(building);
798 let state_for_build: Arc<AppState> = Arc::clone(&state);
799 spawn(async move {
800 let args: ModeArgs = state_for_build.get_args().clone();
801 let reload_tx: broadcast::Sender<ReloadEvent> = state_for_build.get_reload_tx().clone();
802 match run_build_pipeline(&args, Some(&reload_tx)).await {
803 Ok(html) => {
804 let mut content: RwLockWriteGuard<String> =
805 state_for_build.get_html_content().write().await;
806 *content = html;
807 }
808 Err(error) => {
809 log::error!("Build pipeline error: {error}");
810 }
811 }
812 let mut building: RwLockWriteGuard<bool> =
813 state_for_build.get_is_building().write().await;
814 *building = false;
815 });
816 }
817 Ok(())
818}
819
820pub async fn build_wasm(args: &ModeArgs) -> Result<(), EuvError> {
835 let build_mode: BuildMode = resolve_build_mode(args);
836 let build_mode_flag: &str = build_mode_to_flag(build_mode);
837 let filtered_args: Vec<String> = filter_euv_args(args.get_wasm_pack_args());
838 let has_existing_build_mode: bool = has_build_mode_flag(&filtered_args);
839 let default_out_dir: String = format!("{}/{PKG_DIR_NAME}", args.get_www_dir());
840 let mut command: Command = Command::new(WASM_PACK_COMMAND);
841 command.arg(WASM_PACK_BUILD_SUBCOMMAND);
842 if !has_existing_build_mode {
843 command.arg(build_mode_flag);
844 }
845 command
846 .args(&filtered_args)
847 .env(RUST_MIN_STACK_ENV, RUST_MIN_STACK_VALUE);
848 let has_out_dir: bool = extract_out_dir(&filtered_args).is_some();
849 if !has_out_dir {
850 command.arg(OUT_DIR_ARG).arg(&default_out_dir);
851 }
852 let has_target: bool = filtered_args
853 .iter()
854 .any(|arg: &String| arg == TARGET_ARG || arg.starts_with(&format!("{TARGET_ARG}=")));
855 if !has_target {
856 command.arg(TARGET_ARG).arg(TARGET_WEB);
857 }
858 command.current_dir(args.get_crate_path());
859 command.stdout(Stdio::piped()).stderr(Stdio::piped());
860 let display_args: Vec<String> = (if has_existing_build_mode {
861 filtered_args.to_vec()
862 } else {
863 once(build_mode_flag.to_string())
864 .chain(filtered_args.iter().cloned())
865 .collect::<Vec<String>>()
866 })
867 .into_iter()
868 .chain(if has_out_dir {
869 Vec::new()
870 } else {
871 vec![OUT_DIR_ARG.to_string(), default_out_dir.clone()]
872 })
873 .chain(if has_target {
874 Vec::new()
875 } else {
876 vec![TARGET_ARG.to_string(), TARGET_WEB.to_string()]
877 })
878 .collect();
879 let out_dir_absolute: PathBuf = resolve_out_dir(args);
880 create_dir_all(&out_dir_absolute)
881 .await
882 .map_err(|error: io::Error| EuvError::IoPath {
883 message: String::from("Failed to create output directory"),
884 path: out_dir_absolute.clone(),
885 error,
886 })?;
887 log::info!(
888 "Running: {WASM_PACK_COMMAND} {WASM_PACK_BUILD_SUBCOMMAND} {} ...",
889 display_args.join(" ")
890 );
891 let output: Output = command
892 .output()
893 .await
894 .map_err(|error: io::Error| EuvError::Io {
895 message: String::from("Failed to execute wasm-pack"),
896 error,
897 })?;
898 let stdout: String = String::from_utf8_lossy(&output.stdout).to_string();
899 let stderr: String = String::from_utf8_lossy(&output.stderr).to_string();
900 if args.get_no_gitignore() {
901 let gitignore_path: PathBuf = out_dir_absolute.join(GITIGNORE_FILE_NAME);
902 if gitignore_path.exists()
903 && let Err(error) = remove_file(&gitignore_path).await
904 {
905 log::warn!("Failed to remove '{}': {error}", gitignore_path.display());
906 }
907 }
908 for line in stdout.lines().filter(|line: &&str| !line.is_empty()) {
909 log::info!("{line}");
910 }
911 if output.status.success() {
912 for line in stderr.lines().filter(|line: &&str| !line.is_empty()) {
913 log::info!("{line}");
914 }
915 } else {
916 for line in stderr.lines().filter(|line: &&str| !line.is_empty()) {
917 log::error!("{line}");
918 }
919 return Err(EuvError::Message(String::from("wasm-pack build failed")));
920 }
921 Ok(())
922}
923
924pub fn print_banner(action: Action) {
930 let version: &str = env!("CARGO_PKG_VERSION");
931 if version.is_empty() {
932 log::warn!("Failed to parse version from root Cargo.toml");
933 } else {
934 log::info!("euv v{version}");
935 }
936 let action_name: &str = match action {
937 Action::Run => ACTION_RUN,
938 Action::Build => ACTION_BUILD,
939 };
940 log::info!("Mode: {action_name}");
941 log::info!(
942 "Use .gitignore to filter file change events; pass --no-gitignore to remove .gitignore from output"
943 );
944}
945
946pub(crate) fn print_server_urls(config: &ServerUrlConfig) {
958 let port: u16 = config.get_port();
959 let route_prefix: &str = config.get_route_prefix();
960 let index_html_file_name: &str = config.get_index_html_file_name();
961 let mut addresses: Vec<IpAddr> = Vec::new();
962 match if_addrs::get_if_addrs() {
963 Ok(interfaces) => {
964 for interface in interfaces {
965 let ip: IpAddr = interface.addr.ip();
966 if !addresses.contains(&ip) {
967 addresses.push(ip);
968 }
969 }
970 }
971 Err(error) => {
972 log::warn!("Failed to enumerate network interfaces: {error}");
973 }
974 }
975 if addresses.is_empty() {
976 addresses.push(IpAddr::V4(Ipv4Addr::LOCALHOST));
977 }
978 for ip in addresses {
979 let host: String = match ip {
980 IpAddr::V6(_) => format!("[{ip}]"),
981 IpAddr::V4(_) => format!("{ip}"),
982 };
983 let url: String =
984 format!("{HTTP_SCHEME}://{host}:{port}/{route_prefix}/{index_html_file_name}");
985 log::info!("Server: {url}");
986 match QrCode::new(url.as_str()) {
987 Ok(code) => {
988 let string: String = code.render::<Dense1x2>().quiet_zone(false).build();
989 for line in string.lines() {
990 log::info!("{line}");
991 }
992 }
993 Err(error) => {
994 log::warn!("Failed to generate QR code: {error}");
995 }
996 }
997 }
998}
999
1000pub(crate) async fn build_inline_bridge(
1026 pkg_dir: &Path,
1027 js_name: &str,
1028 wasm_url: &str,
1029) -> Result<String, EuvError> {
1030 let js_path: PathBuf = pkg_dir.join(js_name);
1031 let bridge_source: String =
1032 read_to_string(&js_path)
1033 .await
1034 .map_err(|error: io::Error| EuvError::IoPath {
1035 message: String::from("Failed to read wasm-bindgen JS bridge"),
1036 path: js_path.clone(),
1037 error,
1038 })?;
1039 let inlined: String = inline_module_graph(&bridge_source, pkg_dir).await?;
1040 let js_only: String = strip_trailing_module_exports(&inlined);
1041 if !js_only.contains("function main(") {
1042 return Err(EuvError::Message(format!(
1043 "wasm-bindgen bridge '{js_name}' declares no main() for the bootstrap to call"
1044 )));
1045 }
1046 if !js_only.contains("__wbg_get_imports") {
1047 return Err(EuvError::Message(format!(
1048 "wasm-bindgen bridge '{js_name}' declares no __wbg_get_imports() \
1049 for the bootstrap to instantiate the module with"
1050 )));
1051 }
1052 let wasm_url_json: String = encode_js_string(wasm_url);
1053 Ok(format!(
1054 "(function() {{\n\
1055 {js_only}\n\
1056 var __euv_wasm_url = {wasm_url_json};\n\
1057 var __euv_base = (document.querySelector('base[href]') && document.baseURI) || location.href;\n\
1058 var __euv_url = new URL(__euv_wasm_url, __euv_base).toString();\n\
1059 function __euv_main() {{ if (typeof main === 'function') {{ main(); }} }}\n\
1060 if (typeof __wbg_init === 'function') {{\n\
1061 __wbg_init(__euv_url).then(__euv_main).catch(function(e) {{\n\
1062 console.error('[euv] inline bridge init failed:', e);\n\
1063 }});\n\
1064 }} else if (typeof initSync === 'function') {{\n\
1065 fetch(__euv_url).then(function(response) {{ return response.arrayBuffer(); }})\n\
1066 .then(function(bytes) {{ initSync({{ module: bytes }}); __euv_main(); }})\n\
1067 .catch(function(e) {{ console.error('[euv] inline bridge init failed:', e); }});\n\
1068 }} else {{\n\
1069 console.error('[euv] inline bridge: no __wbg_init or initSync to instantiate the module');\n\
1070 }}\n\
1071 }})();\n"
1072 ))
1073}
1074
1075async fn inline_module_graph(bridge_source: &str, pkg_dir: &Path) -> Result<String, EuvError> {
1094 let mut snippets: Vec<(PathBuf, String)> = Vec::new();
1095 let mut namespace_clauses: Vec<NamespaceImport> = Vec::new();
1096 for line in bridge_source.lines() {
1097 let trimmed: &str = line.trim();
1098 if !trimmed.starts_with("import ") {
1099 continue;
1100 }
1101 let rest: &str = trimmed.strip_prefix("import ").unwrap_or_default();
1102 let clause: ImportClause<'_> = parse_import_clause(rest)?;
1103 if clause.default_binding.is_some() || !clause.named.is_empty() {
1104 return Err(EuvError::Message(format!(
1105 "wasm-bindgen bridge imports a default or named binding from '{}', \
1106 which a self-contained bootstrap cannot reproduce",
1107 clause.spec
1108 )));
1109 }
1110 if !(clause.spec.starts_with("./") || clause.spec.starts_with("../")) {
1111 return Err(EuvError::Message(format!(
1112 "wasm-bindgen bridge imports the bare module '{}', which a \
1113 self-contained bootstrap cannot fetch",
1114 clause.spec
1115 )));
1116 }
1117 if let Some(alias) = clause.namespace {
1118 namespace_clauses.push(NamespaceImport {
1119 alias: alias.to_string(),
1120 spec: clause.spec.to_string(),
1121 });
1122 }
1123 let snippet_path: PathBuf = resolve_snippet_path(pkg_dir, clause.spec).await?;
1124 if snippets
1125 .iter()
1126 .any(|(path, _): &(PathBuf, String)| path == &snippet_path)
1127 {
1128 continue;
1129 }
1130 let raw: String = read_to_string(&snippet_path)
1131 .await
1132 .map_err(|error: io::Error| EuvError::IoPath {
1133 message: String::from("Failed to read wasm-pack snippet module"),
1134 path: snippet_path.clone(),
1135 error,
1136 })?;
1137 snippets.push((snippet_path, raw));
1138 }
1139 let mut out: String = String::new();
1140 for (snippet_path, raw) in &snippets {
1141 let body: String = strip_module_exports(raw).map_err(|error: EuvError| match error {
1142 EuvError::Message(message) => EuvError::Message(format!(
1143 "{} in snippet module '{}'",
1144 message,
1145 snippet_path.display()
1146 )),
1147 other => other,
1148 })?;
1149 if body.trim().is_empty() {
1150 return Err(EuvError::Message(format!(
1151 "snippet module '{}' has no inlinable body",
1152 snippet_path.display()
1153 )));
1154 }
1155 out.push_str(&body);
1156 out.push('\n');
1157 }
1158 for clause in &namespace_clauses {
1159 let snippet_path: PathBuf = resolve_snippet_path(pkg_dir, &clause.spec).await?;
1160 let raw: String = snippets
1161 .iter()
1162 .find(|(path, _): &&(PathBuf, String)| *path == snippet_path)
1163 .map(|(_, raw): &(PathBuf, String)| raw.clone())
1164 .unwrap_or_default();
1165 let names: Vec<String> = extract_exported_names(&raw);
1166 if names.is_empty() {
1167 return Err(EuvError::Message(format!(
1168 "snippet module '{}' exports nothing the namespace binding '{}' \
1169 could reference",
1170 clause.spec, clause.alias
1171 )));
1172 }
1173 out.push_str(&render_namespace_object(&clause.alias, &names));
1174 }
1175 for line in bridge_source.lines() {
1176 let trimmed: &str = line.trim();
1177 if trimmed.starts_with("import ") {
1178 continue;
1179 }
1180 if trimmed.contains(IMPORT_META_URL_MARKER) {
1181 continue;
1182 }
1183 out.push_str(line);
1184 out.push('\n');
1185 }
1186 Ok(out)
1187}
1188
1189pub fn parse_import_clause(rest: &str) -> Result<ImportClause<'_>, EuvError> {
1199 let rest: &str = rest.trim().trim_end_matches(';').trim();
1200 let from_idx: usize = rest.find(" from ").ok_or_else(|| {
1201 EuvError::Message(format!(
1202 "bridge import '{rest}' is not a static `from` clause, which a \
1203 self-contained bootstrap cannot reproduce"
1204 ))
1205 })?;
1206 let head: &str = rest[..from_idx].trim();
1207 let quoted: &str = rest[from_idx + " from ".len()..].trim();
1208 let quote: char = match quoted.chars().next() {
1209 Some(quote @ ('\'' | '"')) => quote,
1210 _ => {
1211 return Err(EuvError::Message(format!(
1212 "bridge import specifier '{quoted}' is not a quoted string"
1213 )));
1214 }
1215 };
1216 let after: &str = "ed[quote.len_utf8()..];
1217 let spec: &str = after.split(quote).next().unwrap_or_default();
1218 if spec.is_empty() {
1219 return Err(EuvError::Message(format!(
1220 "bridge import '{rest}' names an empty specifier"
1221 )));
1222 }
1223 if head.starts_with('*') {
1224 let alias: &str = head
1225 .strip_prefix('*')
1226 .map(|value: &str| value.trim())
1227 .and_then(|value: &str| value.strip_prefix("as "))
1228 .map(|value: &str| value.trim())
1229 .unwrap_or_default();
1230 if alias.is_empty() {
1231 return Err(EuvError::Message(format!(
1232 "bridge import '{rest}' is a namespace import without a binding"
1233 )));
1234 }
1235 return Ok(ImportClause {
1236 spec,
1237 namespace: Some(alias),
1238 default_binding: None,
1239 named: Vec::new(),
1240 });
1241 }
1242 if let Some(inner) = head.strip_prefix('{') {
1243 let inner: &str = inner.strip_suffix('}').ok_or_else(|| {
1244 EuvError::Message(format!(
1245 "bridge import '{rest}' has an unbalanced `{{` clause"
1246 ))
1247 })?;
1248 return Ok(ImportClause {
1249 spec,
1250 namespace: None,
1251 default_binding: None,
1252 named: inner
1253 .split(',')
1254 .map(|entry: &str| entry.trim())
1255 .filter(|entry: &&str| !entry.is_empty())
1256 .collect(),
1257 });
1258 }
1259 Ok(ImportClause {
1260 spec,
1261 namespace: None,
1262 default_binding: Some(head),
1263 named: Vec::new(),
1264 })
1265}
1266
1267fn render_namespace_object(alias: &str, names: &[String]) -> String {
1279 let mut out: String = format!("var {alias} = {{");
1280 for (index, name) in names.iter().enumerate() {
1281 if index > 0 {
1282 out.push(',');
1283 }
1284 out.push_str(name);
1285 out.push(':');
1286 out.push_str(name);
1287 }
1288 out.push_str("};\n");
1289 out
1290}
1291
1292fn strip_module_exports(source: &str) -> Result<String, EuvError> {
1304 let mut out: String = String::with_capacity(source.len());
1305 for line in source.lines() {
1306 let trimmed: &str = line.trim();
1307 let Some(rest) = trimmed.strip_prefix("export ") else {
1308 out.push_str(line);
1309 out.push('\n');
1310 continue;
1311 };
1312 match classify_export(rest) {
1313 ExportForm::Aliases(clause) => {
1314 out.push_str(&render_export_aliases(clause)?);
1315 }
1316 ExportForm::Declaration(declaration) => {
1317 out.push_str(declaration);
1318 out.push('\n');
1319 }
1320 ExportForm::Unsupported => {
1321 return Err(EuvError::Message(format!(
1322 "snippet exports '{rest}', a form a self-contained \
1323 bootstrap cannot reproduce"
1324 )));
1325 }
1326 }
1327 }
1328 Ok(out)
1329}
1330
1331fn classify_export(rest: &str) -> ExportForm<'_> {
1341 let trimmed: &str = rest.trim_end().trim_end_matches(';');
1342 if let Some(inner) = trimmed.strip_prefix('{')
1343 && inner.trim_end().ends_with('}')
1344 {
1345 return ExportForm::Aliases(inner.trim_end().trim_end_matches('}'));
1346 }
1347 if EXPORT_DECLARATION_KEYWORDS
1348 .iter()
1349 .any(|keyword: &&str| trimmed.starts_with(keyword))
1350 {
1351 return ExportForm::Declaration(trimmed);
1352 }
1353 ExportForm::Unsupported
1354}
1355
1356fn render_export_aliases(clause: &str) -> Result<String, EuvError> {
1373 let mut out: String = String::new();
1374 for entry in clause.split(',') {
1375 let entry: &str = entry.trim();
1376 if entry.is_empty() {
1377 continue;
1378 }
1379 let (original, exported): (&str, &str) = match entry.split_once(" as ") {
1380 Some((original, exported)) => (original.trim(), exported.trim()),
1381 None => (entry, entry),
1382 };
1383 if !is_identifier(original) || !is_identifier(exported) {
1384 return Err(EuvError::Message(format!(
1385 "snippet exports the non-identifier entry '{entry}'"
1386 )));
1387 }
1388 if original == exported || exported == "default" || original == "wasm" {
1389 continue;
1390 }
1391 out.push_str(exported);
1392 out.push_str(" = ");
1393 out.push_str(original);
1394 out.push_str(";\n");
1395 }
1396 Ok(out)
1397}
1398
1399fn is_identifier(value: &str) -> bool {
1409 !value.is_empty()
1410 && !value.starts_with(|c: char| c.is_ascii_digit())
1411 && value
1412 .chars()
1413 .all(|c: char| c.is_ascii_alphanumeric() || c == '_' || c == '$')
1414}
1415
1416pub fn extract_exported_names(source: &str) -> Vec<String> {
1428 let mut names: Vec<String> = Vec::new();
1429 for line in source.lines() {
1430 let trimmed: &str = line.trim();
1431 let Some(rest) = trimmed.strip_prefix("export ") else {
1432 continue;
1433 };
1434 let declaration: Option<&str> = EXPORT_DECLARATION_KEYWORDS
1435 .iter()
1436 .find_map(|keyword: &&str| rest.strip_prefix(keyword));
1437 if let Some(name) = declaration.and_then(leading_identifier)
1438 && !names.iter().any(|existing: &String| existing == name)
1439 {
1440 names.push(name.to_string());
1441 }
1442 }
1443 names
1444}
1445
1446fn leading_identifier(value: &str) -> Option<&str> {
1457 let end: usize = value
1458 .find(|c: char| !c.is_alphanumeric() && c != '_' && c != '$')
1459 .unwrap_or(value.len());
1460 if end == 0 { None } else { Some(&value[..end]) }
1461}
1462
1463async fn resolve_snippet_path(pkg_dir: &Path, spec: &str) -> Result<PathBuf, EuvError> {
1475 let base: &str = spec.strip_prefix("./").unwrap_or(spec);
1476 let mut path: PathBuf = pkg_dir.to_path_buf();
1477 for segment in base.split('/') {
1478 if segment.is_empty() || segment == "." {
1479 continue;
1480 }
1481 if segment == ".." {
1482 return Err(EuvError::Message(String::from(
1483 "Snippet import spec escapes pkg directory",
1484 )));
1485 }
1486 path.push(segment);
1487 }
1488 let root: PathBuf =
1489 canonicalize(pkg_dir)
1490 .await
1491 .map_err(|error: io::Error| EuvError::IoPath {
1492 message: String::from("Failed to resolve the WASM output directory"),
1493 path: pkg_dir.to_path_buf(),
1494 error,
1495 })?;
1496 let resolved: PathBuf =
1497 canonicalize(&path)
1498 .await
1499 .map_err(|error: io::Error| EuvError::IoPath {
1500 message: String::from("Failed to resolve the imported snippet"),
1501 path: path.clone(),
1502 error,
1503 })?;
1504 if !resolved.starts_with(root) {
1505 return Err(EuvError::Message(format!(
1506 "Snippet import '{spec}' resolves outside the WASM output directory",
1507 )));
1508 }
1509 Ok(resolved)
1510}
1511
1512fn strip_trailing_module_exports(source: &str) -> String {
1525 let mut out: String = String::with_capacity(source.len());
1526 for line in source.lines() {
1527 let trimmed: &str = line.trim();
1528 let Some(rest) = trimmed.strip_prefix("export ") else {
1529 out.push_str(line);
1530 out.push('\n');
1531 continue;
1532 };
1533 match classify_export(rest) {
1534 ExportForm::Aliases(clause) => {
1535 if let Ok(aliases) = render_export_aliases(clause) {
1536 out.push_str(&aliases);
1537 }
1538 }
1539 ExportForm::Declaration(declaration) => {
1540 out.push_str(declaration);
1541 out.push('\n');
1542 }
1543 ExportForm::Unsupported => {
1544 out.push_str(line);
1545 out.push('\n');
1546 }
1547 }
1548 }
1549 out
1550}
1551
1552pub(crate) fn encode_js_string(value: &str) -> String {
1565 let mut out: String = String::with_capacity(value.len() + 2);
1566 out.push('"');
1567 for ch in value.chars() {
1568 match ch {
1569 '"' => out.push_str("\\\""),
1570 '\\' => out.push_str("\\\\"),
1571 '\n' => out.push_str("\\n"),
1572 '\r' => out.push_str("\\r"),
1573 '\t' => out.push_str("\\t"),
1574 '\u{08}' => out.push_str("\\b"),
1575 '\u{0C}' => out.push_str("\\f"),
1576 '<' => out.push_str("\\u003c"),
1577 '>' => out.push_str("\\u003e"),
1578 '&' => out.push_str("\\u0026"),
1579 '\u{2028}' => out.push_str("\\u2028"),
1580 '\u{2029}' => out.push_str("\\u2029"),
1581 c if (c as u32) < 0x20 => out.push_str(&format!("\\u{:04x}", c as u32)),
1582 c => out.push(c),
1583 }
1584 }
1585 out.push('"');
1586 out
1587}
1588
1589pub(crate) async fn remove_generated_js(pkg_dir: &Path) -> Result<Vec<PathBuf>, EuvError> {
1616 let root: PathBuf = match canonicalize(pkg_dir).await {
1617 Ok(root) => root,
1618 Err(error) if error.kind() == io::ErrorKind::NotFound => {
1619 return Ok(Vec::new());
1620 }
1621 Err(error) => {
1622 return Err(EuvError::IoPath {
1623 message: String::from("Failed to resolve the wasm-pack output directory"),
1624 path: pkg_dir.to_path_buf(),
1625 error,
1626 });
1627 }
1628 };
1629 let mut removed: Vec<PathBuf> = Vec::new();
1630 let mut generated_dirs: Vec<PathBuf> = Vec::new();
1631 let mut pending: Vec<PathBuf> = vec![root.clone()];
1632 while let Some(dir) = pending.pop() {
1633 let mut entries: ReadDir = read_dir(&dir).await.map_err(|error: io::Error| {
1634 EuvError::IoPath {
1635 message: String::from(
1636 "Failed to list the wasm-pack output directory while removing inlined JavaScript",
1637 ),
1638 path: dir.clone(),
1639 error,
1640 }
1641 })?;
1642 loop {
1643 let entry: DirEntry = match entries.next_entry().await {
1644 Ok(Some(entry)) => entry,
1645 Ok(None) => break,
1646 Err(error) => {
1647 return Err(EuvError::IoPath {
1648 message: String::from(
1649 "Failed to read an entry of the wasm-pack output directory while \
1650 removing inlined JavaScript",
1651 ),
1652 path: dir.clone(),
1653 error,
1654 });
1655 }
1656 };
1657 let path: PathBuf = entry.path();
1658 let file_type: FileType =
1659 entry
1660 .file_type()
1661 .await
1662 .map_err(|error: io::Error| EuvError::IoPath {
1663 message: String::from(
1664 "Failed to stat an entry of the wasm-pack output directory while \
1665 removing inlined JavaScript",
1666 ),
1667 path: path.clone(),
1668 error,
1669 })?;
1670 if file_type.is_symlink() {
1671 log::warn!(
1674 "Leaving '{}' in place: it is a symlink, and the cleanup never follows one",
1675 path.display()
1676 );
1677 continue;
1678 }
1679 if file_type.is_dir() {
1680 if path.starts_with(root.join(SNIPPET_DIR_NAME)) {
1681 generated_dirs.push(path.clone());
1682 }
1683 pending.push(path);
1684 continue;
1685 }
1686 let canonical: PathBuf =
1687 canonicalize(&path)
1688 .await
1689 .map_err(|error: io::Error| EuvError::IoPath {
1690 message: String::from(
1691 "Failed to resolve an entry of the wasm-pack output directory before \
1692 deleting it",
1693 ),
1694 path: path.clone(),
1695 error,
1696 })?;
1697 if !canonical.starts_with(&root) {
1698 log::warn!(
1699 "Leaving '{}' in place: it resolves outside the wasm-pack output",
1700 path.display()
1701 );
1702 continue;
1703 }
1704 if !is_generated_js_artifact(&path) {
1705 continue;
1706 }
1707 remove_file(&path)
1708 .await
1709 .map_err(|error: io::Error| EuvError::IoPath {
1710 message: String::from(
1711 "Failed to remove a generated JavaScript file after inlining it",
1712 ),
1713 path: path.clone(),
1714 error,
1715 })?;
1716 removed.push(path);
1717 }
1718 }
1719 for dir in generated_dirs.iter().rev() {
1720 match remove_dir(dir).await {
1721 Ok(()) => {}
1722 Err(error) if error.kind() == io::ErrorKind::DirectoryNotEmpty => {}
1723 Err(error) => {
1724 return Err(EuvError::IoPath {
1725 message: String::from("Failed to remove an emptied snippet directory"),
1726 path: dir.clone(),
1727 error,
1728 });
1729 }
1730 }
1731 }
1732 log::debug!(
1733 "Removed {} generated JavaScript file(s) and {} empty generated directory(ies)",
1734 removed.len(),
1735 generated_dirs.len()
1736 );
1737 Ok(removed)
1738}
1739
1740fn is_generated_js_artifact(path: &Path) -> bool {
1751 let name: String = path
1752 .file_name()
1753 .and_then(|name: &ffi::OsStr| name.to_str())
1754 .unwrap_or_default()
1755 .to_ascii_lowercase();
1756 GENERATED_JS_SUFFIXES
1757 .iter()
1758 .any(|suffix: &&str| name.ends_with(suffix))
1759}