refactor!: remove bytes dependency

Author: brianheineman

postgresql_archive/benches/archive.rs

@@ -1,4 +1,3 @@
-use bytes::Bytes;
 use criterion::{criterion_group, criterion_main, Criterion};
 use postgresql_archive::blocking::{extract, get_archive};
 use postgresql_archive::{Result, VersionReq, DEFAULT_POSTGRESQL_URL};
@@ -22,7 +21,7 @@ fn bench_extract(criterion: &mut Criterion) -> Result<()> {
     Ok(())
 }
 
-fn extract_archive(archive: &Bytes) -> Result<()> {
+fn extract_archive(archive: &Vec<u8>) -> Result<()> {
     let out_dir = tempfile::tempdir()?.path().to_path_buf();
     create_dir_all(&out_dir)?;
     extract(archive, &out_dir)?;

postgresql_archive/src/archive.rs

@@ -101,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: Vec<u8>, 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/blocking/archive.rs

@@ -1,5 +1,4 @@
 use crate::{Version, VersionReq};
-use bytes::Bytes;
 use std::path::Path;
 use tokio::runtime::Runtime;
 
@@ -25,7 +24,7 @@ pub fn get_version(url: &str, version_req: &VersionReq) -> crate::Result<Version
 /// # Errors
 /// * If the archive is not found.
 /// * If the archive cannot be downloaded.
-pub fn get_archive(url: &str, version_req: &VersionReq) -> crate::Result<(Version, Bytes)> {
+pub fn get_archive(url: &str, version_req: &VersionReq) -> crate::Result<(Version, Vec<u8>)> {
     RUNTIME
         .handle()
         .block_on(async move { crate::get_archive(url, version_req).await })
@@ -35,7 +34,7 @@ pub fn get_archive(url: &str, version_req: &VersionReq) -> crate::Result<(Versio
 ///
 /// # Errors
 /// Returns an error if the extraction fails.
-pub fn extract(bytes: &Bytes, out_dir: &Path) -> crate::Result<()> {
+pub fn extract(bytes: &Vec<u8>, out_dir: &Path) -> crate::Result<()> {
     RUNTIME
         .handle()
         .block_on(async move { crate::extract(bytes, out_dir).await })

postgresql_embedded/src/postgresql.rs

@@ -157,7 +157,7 @@ impl PostgreSQL {
             debug!("Using bundled installation archive");
             (
                 self.settings.version.clone(),
-                bytes::Bytes::copy_from_slice(crate::settings::ARCHIVE),
+                crate::settings::ARCHIVE.to_vec(),
             )
         } else {
             let (version, bytes) =