Library/Fn/SWC/
Watch.rs

1//! SWC-compatible file watching module (using OXC backend)
2//!
3//! This module provides file watching functionality for the compiler.
4
5pub mod Compile;
6
7#[tracing::instrument]
8pub async fn Fn(path:std::path::PathBuf, options:crate::Struct::SWC::Option) -> anyhow::Result<()> {
9	let (tx, mut rx) = tokio::sync::mpsc::unbounded_channel();
10
11	let mut watcher = notify::RecommendedWatcher::new(
12		move |res| {
13			let _ = futures::executor::block_on(async {
14				tx.send(res).unwrap();
15			});
16		},
17		notify::Config::default(),
18	)?;
19
20	use notify::Watcher; // trait import
21
22	watcher.watch(path.as_ref(), notify::RecursiveMode::Recursive)?;
23
24	while let Some(result) = rx.recv().await {
25		match result {
26			Ok(event) => {
27				if let notify::Event {
28					kind: notify::EventKind::Modify(notify::event::ModifyKind::Data(_)),
29
30					paths,
31					..
32				} = event
33				{
34					for path in paths {
35						if path.extension().map_or(false, |ext| ext == "ts") {
36							let options = options.clone();
37
38							tokio::task::spawn_blocking(move || {
39								let rt = tokio::runtime::Handle::current();
40
41								rt.block_on(async {
42									if let Err(e) = Compile::Fn(crate::Struct::SWC::Option {
43										entry:vec![vec![path.to_string_lossy().to_string()]],
44										..options
45									})
46									.await
47									{
48										error!("Compilation error: {}", e);
49									}
50								})
51							});
52						}
53					}
54				}
55			},
56
57			Err(e) => error!("Watch error: {:?}", e),
58		}
59	}
60
61	Ok(())
62}
63
64use tracing::error;
Library/Fn/SWC/Watch.rs

Library/Fn/SWC/
Watch.rs
