summaryrefslogtreecommitdiff
path: root/cli/worker.rs
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-02-04 20:24:33 +0100
committerGitHub <noreply@github.com>2020-02-04 20:24:33 +0100
commit184be99f5b6e85a6041e72dfdd0afda46e5f8619 (patch)
treed438f3ab106d4a515cf05a296a31db206c266d80 /cli/worker.rs
parent2ab49a80a62f00e5540907d6d85cf15a9cce070e (diff)
refactor: CLI subcommands and argv (#3886)
Diffstat (limited to 'cli/worker.rs')
-rw-r--r--cli/worker.rs59
1 files changed, 21 insertions, 38 deletions
diff --git a/cli/worker.rs b/cli/worker.rs
index 07a96af16..b81a77a9e 100644
--- a/cli/worker.rs
+++ b/cli/worker.rs
@@ -230,22 +230,13 @@ mod tests {
.join("cli/tests/esm_imports_a.js");
let module_specifier =
ModuleSpecifier::resolve_url_or_path(&p.to_string_lossy()).unwrap();
- let global_state = ThreadSafeGlobalState::new(
- flags::DenoFlags {
- argv: vec![String::from("./deno"), module_specifier.to_string()],
- ..flags::DenoFlags::default()
- },
- Progress::new(),
- )
- .unwrap();
+ let global_state =
+ ThreadSafeGlobalState::new(flags::DenoFlags::default(), Progress::new())
+ .unwrap();
let (int, ext) = ThreadSafeState::create_channels();
- let state = ThreadSafeState::new(
- global_state,
- None,
- Some(module_specifier.clone()),
- int,
- )
- .unwrap();
+ let state =
+ ThreadSafeState::new(global_state, None, module_specifier.clone(), int)
+ .unwrap();
let state_ = state.clone();
tokio_util::run_basic(async move {
let mut worker =
@@ -275,22 +266,13 @@ mod tests {
.join("tests/circular1.ts");
let module_specifier =
ModuleSpecifier::resolve_url_or_path(&p.to_string_lossy()).unwrap();
- let global_state = ThreadSafeGlobalState::new(
- flags::DenoFlags {
- argv: vec![String::from("deno"), module_specifier.to_string()],
- ..flags::DenoFlags::default()
- },
- Progress::new(),
- )
- .unwrap();
+ let global_state =
+ ThreadSafeGlobalState::new(flags::DenoFlags::default(), Progress::new())
+ .unwrap();
let (int, ext) = ThreadSafeState::create_channels();
- let state = ThreadSafeState::new(
- global_state,
- None,
- Some(module_specifier.clone()),
- int,
- )
- .unwrap();
+ let state =
+ ThreadSafeState::new(global_state, None, module_specifier.clone(), int)
+ .unwrap();
let state_ = state.clone();
tokio_util::run_basic(async move {
let mut worker =
@@ -321,16 +303,20 @@ mod tests {
.join("cli/tests/006_url_imports.ts");
let module_specifier =
ModuleSpecifier::resolve_url_or_path(&p.to_string_lossy()).unwrap();
- let mut flags = flags::DenoFlags::default();
- flags.argv = vec![String::from("deno"), module_specifier.to_string()];
- flags.reload = true;
+ let flags = flags::DenoFlags {
+ subcommand: flags::DenoSubcommand::Run {
+ script: module_specifier.to_string(),
+ },
+ reload: true,
+ ..flags::DenoFlags::default()
+ };
let global_state =
ThreadSafeGlobalState::new(flags, Progress::new()).unwrap();
let (int, ext) = ThreadSafeState::create_channels();
let state = ThreadSafeState::new(
global_state.clone(),
None,
- Some(module_specifier.clone()),
+ module_specifier.clone(),
int,
)
.unwrap();
@@ -361,10 +347,7 @@ mod tests {
fn create_test_worker() -> MainWorker {
let (int, ext) = ThreadSafeState::create_channels();
- let state = ThreadSafeState::mock(
- vec![String::from("./deno"), String::from("hello.js")],
- int,
- );
+ let state = ThreadSafeState::mock("./hello.js", int);
let mut worker = MainWorker::new(
"TEST".to_string(),
startup_data::deno_isolate_init(),