pkgxdev / pkgx / 12768583963

pub fn should(config: &Config) -> bool {

    if !config.pantry_dir.join("projects").is_dir() {

        true

    } else if !config

        .is_file()

        true

        false

pub async fn replace(config: &Config, conn: &mut Connection) -> Result<(), Box<dyn Error>> {

    let url = env!("PKGX_PANTRY_TARBALL_URL");

    let dest = &config.pantry_dir;

    std::fs::create_dir_all(dest.clone())?;

    let dir = OpenOptions::new()

        .open(dest)?;

    dir.lock_exclusive()?;

    download_and_extract_pantry(url, dest).await?;

    pantry_db::cache(config, conn)?;

    FileExt::unlock(&dir)?;

    Ok(())

async fn download_and_extract_pantry(url: &str, dest: &PathBuf) -> Result<(), Box<dyn Error>> {

    let rsp = reqwest::get(url).await?.error_for_status()?;

    let stream = rsp.bytes_stream();

    let stream = stream

        .map_err(|e| futures::io::Error::new(futures::io::ErrorKind::Other, e))

    let stream = stream.compat();

    let decoder = GzipDecoder::new(stream);

    let mut archive = Archive::new(decoder);

    archive.unpack(dest).await?;

    Ok(())