1 files changed, 96 insertions, 0 deletions
diff --git a/src/backup/mod.rs b/src/backup/mod.rs
new file mode 100644
index 0000000..16d60a3
--- /dev/null
+++ b/src/backup/mod.rs
@@ -0,0 +1,96 @@
+use std::{sync::Arc, time::Duration};
+
+use deploy::BackupDeployment;
+use futures::StreamExt;
+use kube::{
+    runtime::{controller::Action, watcher::Config, Controller},
+    Api, Client, Resource, ResourceExt,
+};
+use restic_crd::Backup;
+use tracing::{error, info};
+
+use crate::{
+    context::ContextData,
+    deploy::{Deployable, Labels},
+    finalizer::{self, FINALIZER},
+    Error,
+};
+
+mod deploy;
+mod job;
+
+pub async fn run_controller(client: Client) {
+    let crd_api: Api<Backup> = Api::all(client.clone());
+    let context: Arc<ContextData> = Arc::new(ContextData::new(client));
+
+    Controller::new(crd_api, Config::default())
+        .run(reconcile, on_error, context)
+        .for_each(|reconciliation_result| async move {
+            match reconciliation_result {
+                Ok(echo_resource) => {
+                    info!("Reconciliation successful. Resource: {:?}", echo_resource);
+                }
+                Err(reconciliation_err) => {
+                    error!(%reconciliation_err, "Reconciliation error")
+                }
+            }
+        })
+        .await;
+}
+
+async fn reconcile(backup: Arc<Backup>, context: Arc<ContextData>) -> Result<Action, Error> {
+    let client = context.client.clone();
+
+    let ns = backup.namespace().ok_or(Error::MissingNamespace)?;
+    let name = backup.name_any();
+
+    match determine_action(&backup) {
+        BackupAction::Create => {
+            finalizer::add(&Api::<Backup>::namespaced(client.clone(), &ns), &name).await?;
+
+            let deployment = BackupDeployment::new(ns, &backup);
+            let labels = Labels::new(name);
+            deployment.create(client, &*backup, labels).await?;
+            Ok(Action::requeue(Duration::from_secs(10)))
+        }
+        BackupAction::Delete => {
+            let deployment = BackupDeployment::new(ns.clone(), &backup);
+            deployment.delete(client.clone()).await?;
+
+            finalizer::remove(&Api::<Backup>::namespaced(client, &ns), &name).await?;
+
+            Ok(Action::await_change())
+        }
+        BackupAction::Noop => Ok(Action::requeue(Duration::from_secs(10))),
+    }
+}
+
+fn determine_action(backup: &Backup) -> BackupAction {
+    if backup.meta().deletion_timestamp.is_some() {
+        BackupAction::Delete
+    } else if backup
+        .meta()
+        .finalizers
+        .as_ref()
+        .map_or(true, |f| !f.iter().any(|x| x == FINALIZER))
+    {
+        BackupAction::Create
+    } else {
+        BackupAction::Noop
+    }
+}
+
+fn on_error(backup: Arc<Backup>, error: &Error, _context: Arc<ContextData>) -> Action {
+    error!("Reconciliation error:\n{:?}.\n{:?}", error, backup);
+    Action::requeue(Duration::from_secs(5))
+}
+
+/// Possible actions to take on a [`Backup`] resource
+enum BackupAction {
+    /// Create the sub-resources for the backup
+    Create,
+    /// Delete the sub-resources for the backup
+    Delete,
+    /// No operation required. Update the status if needed.
+    Noop,
+}