diff options
Diffstat (limited to 'cli/factory.rs')
-rw-r--r-- | cli/factory.rs | 70 |
1 files changed, 2 insertions, 68 deletions
diff --git a/cli/factory.rs b/cli/factory.rs index a95f0facf..8055a2582 100644 --- a/cli/factory.rs +++ b/cli/factory.rs @@ -17,6 +17,7 @@ use crate::cache::NodeAnalysisCache; use crate::cache::ParsedSourceCache; use crate::emit::Emitter; use crate::file_fetcher::FileFetcher; +use crate::graph_util::FileWatcherReporter; use crate::graph_util::ModuleGraphBuilder; use crate::graph_util::ModuleGraphContainer; use crate::http_util::HttpClient; @@ -39,8 +40,6 @@ use crate::standalone::DenoCompileBinaryWriter; use crate::tools::check::TypeChecker; use crate::util::progress_bar::ProgressBar; use crate::util::progress_bar::ProgressBarStyle; -use crate::watcher::FileWatcher; -use crate::watcher::FileWatcherReporter; use crate::worker::CliMainWorkerFactory; use crate::worker::CliMainWorkerOptions; use crate::worker::HasNodeSpecifierChecker; @@ -148,7 +147,6 @@ struct CliFactoryServices { blob_store: Deferred<BlobStore>, parsed_source_cache: Deferred<Arc<ParsedSourceCache>>, resolver: Deferred<Arc<CliGraphResolver>>, - file_watcher: Deferred<Arc<FileWatcher>>, maybe_file_watcher_reporter: Deferred<Option<FileWatcherReporter>>, module_graph_builder: Deferred<Arc<ModuleGraphBuilder>>, module_load_preparer: Deferred<Arc<ModuleLoadPreparer>>, @@ -412,20 +410,6 @@ impl CliFactory { .await } - pub fn file_watcher(&self) -> Result<&Arc<FileWatcher>, AnyError> { - self.services.file_watcher.get_or_try_init(|| { - let watcher = FileWatcher::new( - self.options.clone(), - self.cjs_resolutions().clone(), - self.graph_container().clone(), - self.maybe_file_watcher_reporter().clone(), - self.parsed_source_cache()?.clone(), - ); - watcher.init_watcher(); - Ok(Arc::new(watcher)) - }) - } - pub fn maybe_file_watcher_reporter(&self) -> &Option<FileWatcherReporter> { let maybe_sender = self.maybe_sender.borrow_mut().take(); self @@ -531,6 +515,7 @@ impl CliFactory { self.npm_resolver().await?.clone(), self.parsed_source_cache()?.clone(), self.maybe_lockfile().clone(), + self.maybe_file_watcher_reporter().clone(), self.emit_cache()?.clone(), self.file_fetcher()?.clone(), self.type_checker().await?.clone(), @@ -600,57 +585,6 @@ impl CliFactory { )) } - /// Gets a function that can be used to create a CliMainWorkerFactory - /// for a file watcher. - pub async fn create_cli_main_worker_factory_func( - &self, - ) -> Result<Arc<dyn Fn() -> CliMainWorkerFactory>, AnyError> { - let emitter = self.emitter()?.clone(); - let graph_container = self.graph_container().clone(); - let module_load_preparer = self.module_load_preparer().await?.clone(); - let parsed_source_cache = self.parsed_source_cache()?.clone(); - let resolver = self.resolver().await?.clone(); - let blob_store = self.blob_store().clone(); - let cjs_resolutions = self.cjs_resolutions().clone(); - let node_code_translator = self.node_code_translator().await?.clone(); - let options = self.cli_options().clone(); - let main_worker_options = self.create_cli_main_worker_options()?; - let fs = self.fs().clone(); - let root_cert_store_provider = self.root_cert_store_provider().clone(); - let node_resolver = self.node_resolver().await?.clone(); - let npm_resolver = self.npm_resolver().await?.clone(); - let maybe_inspector_server = self.maybe_inspector_server().clone(); - let maybe_lockfile = self.maybe_lockfile().clone(); - Ok(Arc::new(move || { - CliMainWorkerFactory::new( - StorageKeyResolver::from_options(&options), - npm_resolver.clone(), - node_resolver.clone(), - Box::new(CliHasNodeSpecifierChecker(graph_container.clone())), - blob_store.clone(), - Box::new(CliModuleLoaderFactory::new( - &options, - emitter.clone(), - graph_container.clone(), - module_load_preparer.clone(), - parsed_source_cache.clone(), - resolver.clone(), - NpmModuleLoader::new( - cjs_resolutions.clone(), - node_code_translator.clone(), - fs.clone(), - node_resolver.clone(), - ), - )), - root_cert_store_provider.clone(), - fs.clone(), - maybe_inspector_server.clone(), - maybe_lockfile.clone(), - main_worker_options.clone(), - ) - })) - } - pub async fn create_cli_main_worker_factory( &self, ) -> Result<CliMainWorkerFactory, AnyError> { |