#![doc = doc_self!()]
use std::sync::LazyLock;
use async_trait::async_trait;
use futures::prelude::*;
use indoc::indoc;
use tap::prelude::*;
use super::{Pm, PmHelper, PromptStrategy, Strategy};
use crate::{config::Config, error::Result, exec::Cmd};
macro_rules! doc_self {
() => {
indoc! {"
The [Conda Package Manager](https://conda.io/).
"}
};
}
use doc_self;
#[doc = doc_self!()]
#[derive(Debug)]
pub struct Conda {
cfg: Config,
}
static STRAT_PROMPT: LazyLock<Strategy> = LazyLock::new(|| Strategy {
prompt: PromptStrategy::native_no_confirm(["-y"]),
..Strategy::default()
});
impl Conda {
#[must_use]
#[allow(missing_docs)]
pub const fn new(cfg: Config) -> Self {
Self { cfg }
}
}
#[async_trait]
impl Pm for Conda {
fn name(&self) -> &'static str {
"conda"
}
fn cfg(&self) -> &Config {
&self.cfg
}
async fn q(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
if kws.is_empty() {
self.run(Cmd::new(["conda", "list"]).flags(flags)).await
} else {
self.qs(kws, flags).await
}
}
async fn qo(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "package", "--which"])
.kws(kws)
.flags(flags)
.pipe(|cmd| self.run(cmd))
.await
}
async fn qs(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
self.search_regex(Cmd::new(["conda", "list"]).flags(flags), kws)
.await
}
async fn r(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "remove"])
.kws(kws)
.flags(flags)
.pipe(|cmd| self.run_with(cmd, self.default_mode(), &STRAT_PROMPT))
.await
}
async fn s(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "install"])
.kws(kws)
.flags(flags)
.pipe(|cmd| self.run_with(cmd, self.default_mode(), &STRAT_PROMPT))
.await
}
async fn sc(&self, _kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "clean", "--all"])
.flags(flags)
.pipe(|cmd| self.run_with(cmd, self.default_mode(), &STRAT_PROMPT))
.await
}
async fn si(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "search", "--info"])
.kws(kws)
.flags(flags)
.pipe(|cmd| self.run(cmd))
.await
}
async fn ss(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
stream::iter(kws)
.map(|s| Ok(format!("*{s}*")))
.try_for_each(|kw| self.run(Cmd::new(["conda", "search"]).kws([kw]).flags(flags)))
.await
}
async fn su(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
Cmd::new(["conda", "update", "--all"])
.kws(kws)
.flags(flags)
.pipe(|cmd| self.run_with(cmd, self.default_mode(), &STRAT_PROMPT))
.await
}
async fn suy(&self, kws: &[&str], flags: &[&str]) -> Result<()> {
self.su(kws, flags).await
}
}