refactor!: remove bytes dependency

Author: brianheineman

Cargo.lock

@@ -25,7 +25,6 @@ version = "0.12.0"
 anyhow = "1.0.86"
 async-trait = "0.1.80"
 blake2 = "0.10.6"
-bytes = "1.6.0"
 criterion = "0.5.1"
 flate2 = "1.0.30"
 hex = "0.4.3"

Cargo.toml

@@ -13,7 +13,6 @@ version.workspace = true
 anyhow = { workspace = true }
 async-trait = { workspace = true }
 blake2 = { workspace = true }
-bytes = { workspace = true }
 flate2 = { workspace = true }
 hex = { workspace = true }
 http = { workspace = true }

postgresql_archive/Cargo.toml

@@ -4,7 +4,6 @@
 use crate::error::Error::Unexpected;
 use crate::error::Result;
 use crate::repository;
-use bytes::Bytes;
 use flate2::bufread::GzDecoder;
 use human_bytes::human_bytes;
 use num_format::{Locale, ToFormattedString};
@@ -39,12 +38,11 @@ pub async fn get_version(url: &str, version_req: &VersionReq) -> Result<Version>
 /// * If the archive is not found.
 /// * If the archive cannot be downloaded.
 #[instrument]
-pub async fn get_archive(url: &str, version_req: &VersionReq) -> Result<(Version, Bytes)> {
+pub async fn get_archive(url: &str, version_req: &VersionReq) -> Result<(Version, Vec<u8>)> {
     let repository = repository::registry::get(url)?;
     let archive = repository.get_archive(version_req).await?;
     let version = archive.version().clone();
-    let archive_bytes = archive.bytes().to_vec();
-    let bytes = Bytes::from(archive_bytes.clone());
+    let bytes = archive.bytes().to_vec();
     Ok((version, bytes))
 }
 
@@ -103,7 +101,7 @@ fn acquire_lock(out_dir: &Path) -> Result<PathBuf> {
 /// Returns an error if the extraction fails.
 #[allow(clippy::cast_precision_loss)]
 #[instrument(skip(bytes))]
-pub async fn extract(bytes: &Bytes, out_dir: &Path) -> Result<()> {
+pub async fn extract(bytes: Vec<u8>, out_dir: &Path) -> Result<()> {
     let input = BufReader::new(Cursor::new(bytes));
     let decoder = GzDecoder::new(input);
     let mut archive = Archive::new(decoder);

postgresql_archive/src/archive.rs

@@ -7,7 +7,6 @@ use crate::Error::{
 };
 use crate::{hasher, matcher, Result};
 use async_trait::async_trait;
-use bytes::Bytes;
 use http::{header, Extensions};
 use human_bytes::human_bytes;
 use regex::Regex;
@@ -237,7 +236,7 @@ impl Repository for GitHub {
         debug!("Downloading archive {}", asset.browser_download_url);
         let request = client.get(&asset.browser_download_url);
         let response = request.send().await?.error_for_status()?;
-        let archive: Bytes = response.bytes().await?;
+        let archive = response.bytes().await?;
         let bytes = archive.to_vec();
         debug!(
             "Archive {} downloaded: {}",

postgresql_archive/src/repository/github/repository.rs

@@ -18,7 +18,6 @@ tokio = { workspace = true, features = ["full"] }
 
 [dependencies]
 anyhow = { workspace = true }
-bytes = { workspace = true }
 home = { workspace = true }
 lazy_static = { workspace = true }
 postgresql_archive = { path = "../postgresql_archive", version = "0.12.0", default-features = false }