4 files changed, 92 insertions, 4 deletions

diff --git a/src/cmd/backup.rs b/src/cmd/backup.rs
index dae9811..6983de4 100644
--- a/src/cmd/backup.rs
+++ b/src/cmd/backup.rs
@@ -3,9 +3,10 @@
 use crate::backup_run::BackupRun;
 use crate::client::BackupClient;
 use crate::config::ClientConfig;
-use crate::dbgen::FileId;
+use crate::dbgen::{schema_version, FileId, DEFAULT_SCHEMA_MAJOR};
 use crate::error::ObnamError;
 use crate::generation::GenId;
+use crate::schema::VersionComponent;
 
 use log::info;
 use std::time::SystemTime;
@@ -15,7 +16,11 @@ use tokio::runtime::Runtime;
 
 /// Make a backup.
 #[derive(Debug, StructOpt)]
-pub struct Backup {}
+pub struct Backup {
+    /// Backup schema major version.
+    #[structopt(long)]
+    backup_version: Option<VersionComponent>,
+}
 
 impl Backup {
     /// Run the command.
@@ -27,6 +32,10 @@ impl Backup {
     async fn run_async(&self, config: &ClientConfig) -> Result<(), ObnamError> {
         let runtime = SystemTime::now();
 
+        let major = self.backup_version.or(Some(DEFAULT_SCHEMA_MAJOR)).unwrap();
+        let schema = schema_version(major)?;
+        eprintln!("backup: schema: {}", schema);
+
         let client = BackupClient::new(config)?;
         let genlist = client.list_generations().await?;
 
@@ -39,13 +48,19 @@ impl Backup {
                 info!("fresh backup without a previous generation");
                 let mut run = BackupRun::initial(config, &client)?;
                 let old = run.start(None, &oldtemp).await?;
-                (false, run.backup_roots(config, &old, &newtemp).await?)
+                (
+                    false,
+                    run.backup_roots(config, &old, &newtemp, schema).await?,
+                )
             }
             Ok(old_id) => {
                 info!("incremental backup based on {}", old_id);
                 let mut run = BackupRun::incremental(config, &client)?;
                 let old = run.start(Some(&old_id), &oldtemp).await?;
-                (true, run.backup_roots(config, &old, &newtemp).await?)
+                (
+                    true,
+                    run.backup_roots(config, &old, &newtemp, schema).await?,
+                )
             }
         };
 
diff --git a/src/cmd/inspect.rs b/src/cmd/inspect.rs
new file mode 100644
index 0000000..d5a75c6
--- /dev/null
+++ b/src/cmd/inspect.rs
@@ -0,0 +1,40 @@
+//! The `inspect` subcommand.
+
+use crate::client::BackupClient;
+use crate::config::ClientConfig;
+use crate::error::ObnamError;
+
+use log::info;
+use structopt::StructOpt;
+use tempfile::NamedTempFile;
+use tokio::runtime::Runtime;
+
+/// Make a backup.
+#[derive(Debug, StructOpt)]
+pub struct Inspect {
+    /// Reference to generation to inspect.
+    #[structopt()]
+    gen_id: String,
+}
+
+impl Inspect {
+    /// Run the command.
+    pub fn run(&self, config: &ClientConfig) -> Result<(), ObnamError> {
+        let rt = Runtime::new()?;
+        rt.block_on(self.run_async(config))
+    }
+
+    async fn run_async(&self, config: &ClientConfig) -> Result<(), ObnamError> {
+        let temp = NamedTempFile::new()?;
+        let client = BackupClient::new(config)?;
+        let genlist = client.list_generations().await?;
+        let gen_id = genlist.resolve(&self.gen_id)?;
+        info!("generation id is {}", gen_id.as_chunk_id());
+
+        let gen = client.fetch_generation(&gen_id, temp.path()).await?;
+        let meta = gen.meta()?;
+        println!("schema_version: {}", meta.schema_version());
+
+        Ok(())
+    }
+}
diff --git a/src/cmd/list_backup_versions.rs b/src/cmd/list_backup_versions.rs
new file mode 100644
index 0000000..859d91c
--- /dev/null
+++ b/src/cmd/list_backup_versions.rs
@@ -0,0 +1,31 @@
+//! The `backup` subcommand.
+
+use crate::config::ClientConfig;
+use crate::dbgen::{schema_version, DEFAULT_SCHEMA_MAJOR, SCHEMA_MAJORS};
+use crate::error::ObnamError;
+
+use structopt::StructOpt;
+
+/// List supported backup schema versions.
+#[derive(Debug, StructOpt)]
+pub struct ListSchemaVersions {
+    /// List only the default version.
+    #[structopt(long)]
+    default_only: bool,
+}
+
+impl ListSchemaVersions {
+    /// Run the command.
+    pub fn run(&self, _config: &ClientConfig) -> Result<(), ObnamError> {
+        if self.default_only {
+            let schema = schema_version(DEFAULT_SCHEMA_MAJOR)?;
+            println!("{}", schema);
+        } else {
+            for major in SCHEMA_MAJORS {
+                let schema = schema_version(*major)?;
+                println!("{}", schema);
+            }
+        }
+        Ok(())
+    }
+}
diff --git a/src/cmd/mod.rs b/src/cmd/mod.rs
index 5e5226f..af7457b 100644
--- a/src/cmd/mod.rs
+++ b/src/cmd/mod.rs
@@ -6,7 +6,9 @@ pub mod chunkify;
 pub mod gen_info;
 pub mod get_chunk;
 pub mod init;
+pub mod inspect;
 pub mod list;
+pub mod list_backup_versions;
 pub mod list_files;
 pub mod resolve;
 pub mod restore;