wip

mbtiles/src/bin/mbtiles.rs

@@ -48,6 +48,15 @@ enum Commands {
         /// Value to set, or nothing if the key should be deleted.
         value: Option<String>,
     },
+    #[command(name = "diff")]
+    Diff{
+        /// MBTiles file to read from
+        src_file: PathBuf,
+        /// MBTiles file to write to
+        dst_file: PathBuf,
+        /// MBTiles file to write diff to
+        diff_file: PathBuf,
+    },
     /// Copy tiles from one mbtiles file to another.
     #[command(name = "copy", alias = "cp")]
     Copy(MbtilesCopier),
@@ -138,6 +147,10 @@ async fn main_int() -> anyhow::Result<()> {
             println!("MBTiles file summary for {mbt}");
             println!("{}", mbt.summary(&mut conn).await?);
         }
+        Commands::Diff { src_file, dst_file, diff_file } => {
+            let src = Mbtiles::new(src_file)?;
+            src.diff(dst_file, diff_file).await?;
+        },
     }
 
     Ok(())

mbtiles/src/diff.rs

@@ -0,0 +1,29 @@
+use std::{path::PathBuf, str::FromStr};
+
+use crate::{Mbtiles, MbtError, MbtResult, is_empty_database};
+
+impl Mbtiles {
+    pub async fn diff(&self, dst_path: PathBuf, diff_path: PathBuf) -> MbtResult<()>{
+        let src_path = PathBuf::from_str(self.filepath()).unwrap();
+
+        if src_path == dst_path {
+            return Err(MbtError::SameSourceAndDestination(dst_path.clone()));
+        }
+        if src_path == diff_path || dst_path == diff_path {
+            return Err(MbtError::SameDiffAndSourceOrDestination(diff_path.clone()));
+        }
+
+        let dst_mbt = Mbtiles::new(&dst_path)?;
+
+        let mut dst_conn = dst_mbt.open_or_new().await?;
+
+        let is_empty_db = is_empty_database(&mut dst_conn).await?;
+        if !is_empty_db {
+            return Err(MbtError::NonEmptyTargetFile(dst_path.clone()));
+        }
+
+        self.attach_to(&mut dst_conn, "sourceDb").await?;
+
+        todo!()
+    }
+}

mbtiles/src/lib.rs

@@ -4,6 +4,7 @@
 pub use sqlx;
 
 mod copier;
+mod diff;
 pub use copier::{CopyDuplicateMode, MbtilesCopier};
 
 mod errors;