This is it

Squashed commit of all the exploration history. Development starts here.

Signed-off-by: Kim Altintop <kim@eagain.io>

1 files changed, 114 insertions, 0 deletions

diff --git a/src/bundle.rs b/src/bundle.rs
new file mode 100644
index 0000000..25eafd0
--- /dev/null
+++ b/src/bundle.rs
@@ -0,0 +1,114 @@
+// Copyright © 2022 Kim Altintop <kim@eagain.io>
+// SPDX-License-Identifier: GPL-2.0-only WITH openvpn-openssl-exception
+
+use std::io;
+
+use log::info;
+use sha2::{
+    Digest,
+    Sha256,
+};
+use url::Url;
+
+use crate::io::{
+    HashWriter,
+    LenWriter,
+};
+
+pub mod error;
+
+mod fetch;
+pub use fetch::{
+    Fetched,
+    Fetcher,
+};
+
+mod header;
+pub use header::{
+    Hash,
+    Header,
+    ObjectFormat,
+    ObjectId,
+    Version,
+};
+
+pub mod list;
+pub use list::{
+    List,
+    Location,
+    Uri,
+};
+
+pub const FILE_EXTENSION: &str = "bundle";
+pub const DOT_FILE_EXTENSION: &str = ".bundle";
+
+#[derive(Clone, Debug, serde::Serialize, serde::Deserialize)]
+pub struct Info {
+    pub len: u64,
+    pub hash: Hash,
+    #[serde(with = "hex::serde")]
+    pub checksum: [u8; 32],
+    #[serde(default, skip_serializing_if = "Vec::is_empty")]
+    pub uris: Vec<Url>,
+}
+
+#[derive(Clone, Copy)]
+pub struct Expect<'a> {
+    pub len: u64,
+    pub hash: &'a Hash,
+    pub checksum: Option<&'a [u8]>,
+}
+
+impl<'a> From<&'a Info> for Expect<'a> {
+    fn from(
+        Info {
+            len,
+            hash,
+            checksum,
+            ..
+        }: &'a Info,
+    ) -> Self {
+        Self {
+            len: *len,
+            hash,
+            checksum: Some(checksum),
+        }
+    }
+}
+
+pub fn create<W>(mut out: W, repo: &git2::Repository, header: &Header) -> crate::Result<Info>
+where
+    W: io::Write,
+{
+    let mut hasher = HashWriter::new(Sha256::new(), &mut out);
+    let mut writer = LenWriter::new(&mut hasher);
+    let mut pack = {
+        let mut pack = repo.packbuilder()?;
+        let mut walk = repo.revwalk()?;
+        for pre in &header.prerequisites {
+            walk.hide(pre.try_into()?)?;
+        }
+        for inc in header.references.values() {
+            walk.push(inc.try_into()?)?;
+        }
+        pack.insert_walk(&mut walk)?;
+        pack
+    };
+    header.to_writer(&mut writer)?;
+
+    info!("Packing objects...");
+    pack.foreach(|chunk| io::Write::write_all(&mut writer, chunk).is_ok())?;
+
+    let len = writer.bytes_written();
+    let hash = header.hash();
+    let checksum = hasher.hash().into();
+
+    info!("Created patch bundle {hash}");
+
+    Ok(Info {
+        len,
+        hash,
+        checksum,
+        uris: vec![],
+    })
+}