ayb 0.1.12

ayb makes it easy to create, host, and share embedded databases like SQLite and DuckDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

use crate::http::structs::EntityDatabasePath;
use crate::server::config::AybConfig;
use crate::server::ui_endpoints::auth::init_ayb_client;
use crate::server::ui_endpoints::templates::{error_snippet, render, success_snippet};
use actix_web::{get, post, web, HttpRequest, HttpResponse, Result};
use serde::Deserialize;

#[derive(Deserialize)]
pub struct RestoreSnapshotRequest {
    snapshot_id: String,
}

#[get("/{entity}/{database}/snapshots")]
pub async fn database_snapshots(
    req: HttpRequest,
    path: web::Path<EntityDatabasePath>,
    ayb_config: web::Data<AybConfig>,
) -> Result<HttpResponse> {
    let entity_slug = &path.entity.to_lowercase();
    let database_slug = &path.database.to_lowercase();

    let client = init_ayb_client(&ayb_config, &req);

    match client.list_snapshots(entity_slug, database_slug).await {
        Ok(snapshot_list) => {
            let mut context = tera::Context::new();
            context.insert("snapshots", &snapshot_list.snapshots);

            let html = render("database_snapshots.html", &context);
            Ok(HttpResponse::Ok().content_type("text/html").body(html))
        }
        Err(err) => error_snippet("Error loading snapshots", &format!("{err}")),
    }
}

#[post("/{entity}/{database}/restore_snapshot")]
pub async fn restore_snapshot(
    req: HttpRequest,
    path: web::Path<EntityDatabasePath>,
    form: web::Form<RestoreSnapshotRequest>,
    ayb_config: web::Data<AybConfig>,
) -> Result<HttpResponse> {
    let entity_slug = &path.entity.to_lowercase();
    let database_slug = &path.database.to_lowercase();
    let snapshot_id = &form.snapshot_id.trim();

    if snapshot_id.is_empty() {
        return error_snippet("Missing snapshot ID", "Please provide a valid snapshot ID.");
    }

    let client = init_ayb_client(&ayb_config, &req);

    match client
        .restore_snapshot(entity_slug, database_slug, snapshot_id)
        .await
    {
        Ok(_) => success_snippet(&format!(
            "Database successfully restored from snapshot '{snapshot_id}'."
        )),
        Err(err) => error_snippet("Error restoring snapshot", &format!("{err}")),
    }
}