aboutsummaryrefslogtreecommitdiffhomepage
path: root/crates/mozart/src/commands.rs
diff options
context:
space:
mode:
authornsfisis <nsfisis@gmail.com>2026-02-22 11:07:42 +0900
committernsfisis <nsfisis@gmail.com>2026-02-22 11:15:29 +0900
commit9f0d210021c54f63c9984446862b6ec68834bc63 (patch)
treed1522b8047c60bc7ee7a9d832178dd24e1b07636 /crates/mozart/src/commands.rs
parent2c243a3cb814939bbe40fda1608781825ab0d77d (diff)
downloadphp-mozart-9f0d210021c54f63c9984446862b6ec68834bc63.tar.gz
php-mozart-9f0d210021c54f63c9984446862b6ec68834bc63.tar.zst
php-mozart-9f0d210021c54f63c9984446862b6ec68834bc63.zip
refactor(async): migrate from blocking HTTP to async/await with tokio
Replace reqwest::blocking with async reqwest across the entire codebase. All command execute functions, registry API calls (packagist, downloader, resolver, lockfile), and the main entry point now use async/await with the tokio runtime. The pubgrub resolver runs on spawn_blocking since its DependencyProvider trait is synchronous, using Handle::block_on for async I/O within that context. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Diffstat (limited to 'crates/mozart/src/commands.rs')
-rw-r--r--crates/mozart/src/commands.rs70
1 files changed, 36 insertions, 34 deletions
diff --git a/crates/mozart/src/commands.rs b/crates/mozart/src/commands.rs
index 7b94f4d..cf3300f 100644
--- a/crates/mozart/src/commands.rs
+++ b/crates/mozart/src/commands.rs
@@ -238,7 +238,7 @@ impl Commands {
}
#[tracing::instrument(skip(cli), fields(command = cli.command.name()))]
-pub fn execute(cli: &Cli) -> anyhow::Result<()> {
+pub async fn execute(cli: &Cli) -> anyhow::Result<()> {
let console = mozart_core::console::Console::new(
cli.verbose,
cli.quiet,
@@ -247,38 +247,40 @@ pub fn execute(cli: &Cli) -> anyhow::Result<()> {
cli.no_interaction,
);
match &cli.command {
- Commands::About(args) => about::execute(args, cli, &console),
- Commands::Archive(args) => archive::execute(args, cli, &console),
- Commands::Audit(args) => audit::execute(args, cli, &console),
- Commands::Browse(args) => browse::execute(args, cli, &console),
- Commands::Bump(args) => bump::execute(args, cli, &console),
- Commands::CheckPlatformReqs(args) => check_platform_reqs::execute(args, cli, &console),
- Commands::ClearCache(args) => clear_cache::execute(args, cli, &console),
- Commands::Completion(args) => completion::execute(args, cli, &console),
- Commands::Config(args) => config::execute(args, cli, &console),
- Commands::CreateProject(args) => create_project::execute(args, cli, &console),
- Commands::Depends(args) => depends::execute(args, cli, &console),
- Commands::Diagnose(args) => diagnose::execute(args, cli, &console),
- Commands::DumpAutoload(args) => dump_autoload::execute(args, cli, &console),
- Commands::Exec(args) => exec::execute(args, cli, &console),
- Commands::Fund(args) => fund::execute(args, cli, &console),
- Commands::Global(args) => global::execute(args, cli, &console),
- Commands::Init(args) => init::execute(args, cli, &console),
- Commands::Install(args) => install::execute(args, cli, &console),
- Commands::Licenses(args) => licenses::execute(args, cli, &console),
- Commands::Outdated(args) => outdated::execute(args, cli, &console),
- Commands::Prohibits(args) => prohibits::execute(args, cli, &console),
- Commands::Reinstall(args) => reinstall::execute(args, cli, &console),
- Commands::Remove(args) => remove::execute(args, cli, &console),
- Commands::Repository(args) => repository::execute(args, cli, &console),
- Commands::Require(args) => require::execute(args, cli, &console),
- Commands::RunScript(args) => run_script::execute(args, cli, &console),
- Commands::Search(args) => search::execute(args, cli, &console),
- Commands::SelfUpdate(args) => self_update::execute(args, cli, &console),
- Commands::Show(args) => show::execute(args, cli, &console),
- Commands::Status(args) => status::execute(args, cli, &console),
- Commands::Suggests(args) => suggests::execute(args, cli, &console),
- Commands::Update(args) => update::execute(args, cli, &console),
- Commands::Validate(args) => validate::execute(args, cli, &console),
+ Commands::About(args) => about::execute(args, cli, &console).await,
+ Commands::Archive(args) => archive::execute(args, cli, &console).await,
+ Commands::Audit(args) => audit::execute(args, cli, &console).await,
+ Commands::Browse(args) => browse::execute(args, cli, &console).await,
+ Commands::Bump(args) => bump::execute(args, cli, &console).await,
+ Commands::CheckPlatformReqs(args) => {
+ check_platform_reqs::execute(args, cli, &console).await
+ }
+ Commands::ClearCache(args) => clear_cache::execute(args, cli, &console).await,
+ Commands::Completion(args) => completion::execute(args, cli, &console).await,
+ Commands::Config(args) => config::execute(args, cli, &console).await,
+ Commands::CreateProject(args) => create_project::execute(args, cli, &console).await,
+ Commands::Depends(args) => depends::execute(args, cli, &console).await,
+ Commands::Diagnose(args) => diagnose::execute(args, cli, &console).await,
+ Commands::DumpAutoload(args) => dump_autoload::execute(args, cli, &console).await,
+ Commands::Exec(args) => exec::execute(args, cli, &console).await,
+ Commands::Fund(args) => fund::execute(args, cli, &console).await,
+ Commands::Global(args) => global::execute(args, cli, &console).await,
+ Commands::Init(args) => init::execute(args, cli, &console).await,
+ Commands::Install(args) => install::execute(args, cli, &console).await,
+ Commands::Licenses(args) => licenses::execute(args, cli, &console).await,
+ Commands::Outdated(args) => outdated::execute(args, cli, &console).await,
+ Commands::Prohibits(args) => prohibits::execute(args, cli, &console).await,
+ Commands::Reinstall(args) => reinstall::execute(args, cli, &console).await,
+ Commands::Remove(args) => remove::execute(args, cli, &console).await,
+ Commands::Repository(args) => repository::execute(args, cli, &console).await,
+ Commands::Require(args) => require::execute(args, cli, &console).await,
+ Commands::RunScript(args) => run_script::execute(args, cli, &console).await,
+ Commands::Search(args) => search::execute(args, cli, &console).await,
+ Commands::SelfUpdate(args) => self_update::execute(args, cli, &console).await,
+ Commands::Show(args) => show::execute(args, cli, &console).await,
+ Commands::Status(args) => status::execute(args, cli, &console).await,
+ Commands::Suggests(args) => suggests::execute(args, cli, &console).await,
+ Commands::Update(args) => update::execute(args, cli, &console).await,
+ Commands::Validate(args) => validate::execute(args, cli, &console).await,
}
}