Multiple release stores

This patch adds the ability to have more than one release store.

With this patch, a user can (has to) configure release store names in the
configuration file, and can then specify one of the configured names to release
the artifacts to.

This way, different release "channels" can be served, for example a stable
channel and a rolling release channel (although "channel" is not in our wording).

The code was adapted to be able to fetch releases from multiple release
directories, in the crate::db::find_artifact implementation, so that re-using
artifacts works across all release directories.

Signed-off-by: Matthias Beyer <matthias.beyer@atos.net>

1 files changed, 19 insertions, 15 deletions

diff --git a/src/commands/build.rs b/src/commands/build.rs
index 05fb0d6..1044896 100644
--- a/src/commands/build.rs
+++ b/src/commands/build.rs
@@ -151,20 +151,24 @@ pub async fn build(
         .get(0)
         .ok_or_else(|| anyhow!("Found no package."))?;
 
-    let release_dir = {
-        let bar_release_loading = progressbars.bar();
-        bar_release_loading.set_length(max_packages);
-
-        let p = config.releases_directory();
-        debug!("Loading release directory: {}", p.display());
-        let r = ReleaseStore::load(StoreRoot::new(p.clone())?, bar_release_loading.clone());
-        if r.is_ok() {
-            bar_release_loading.finish_with_message("Loaded releases successfully");
-        } else {
-            bar_release_loading.finish_with_message("Failed to load releases");
-        }
-        r.map(RwLock::new).map(Arc::new)?
-    };
+    let release_stores = config
+        .release_stores()
+        .iter()
+        .map(|storename| {
+            let bar_release_loading = progressbars.bar();
+            bar_release_loading.set_length(max_packages);
+
+            let p = config.releases_directory().join(storename);
+            debug!("Loading release directory: {}", p.display());
+            let r = ReleaseStore::load(StoreRoot::new(p)?, bar_release_loading.clone());
+            if r.is_ok() {
+                bar_release_loading.finish_with_message("Loaded releases successfully");
+            } else {
+                bar_release_loading.finish_with_message("Failed to load releases");
+            }
+            r.map(Arc::new)
+        })
+        .collect::<Result<Vec<_>>>()?;
 
     let (staging_store, staging_dir, submit_id) = {
         let bar_staging_loading = progressbars.bar();
@@ -325,7 +329,7 @@ pub async fn build(
         .progress_generator(progressbars)
         .endpoint_config(endpoint_configurations)
         .staging_store(staging_store)
-        .release_store(release_dir)
+        .release_stores(release_stores)
         .database(database_connection.clone())
         .source_cache(source_cache)
         .submit(submit)