ayb 0.1.12-rc.7

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

use crate::ayb_db::db_interfaces::AybDb;
use crate::ayb_db::models::{DBType, Database, InstantiatedEntity, PublicSharingLevel};
use std::str::FromStr;

use crate::error::AybError;

use crate::hosted_db::daemon_registry::DaemonRegistry;
use crate::hosted_db::paths::{
    instantiated_new_database_path, pathbuf_to_parent, set_current_database_and_clean_up,
};
use crate::http::structs::{Database as APIDatabase, EntityDatabasePath};
use crate::server::config::AybConfig;
use crate::server::permissions::can_create_database;
use crate::server::utils::{get_required_header, unwrap_authenticated_entity};
use actix_web::{post, web, HttpRequest, HttpResponse};

#[post("/{entity}/{database}/create")]
async fn create_database(
    path: web::Path<EntityDatabasePath>,
    req: HttpRequest,
    ayb_db: web::Data<Box<dyn AybDb>>,
    ayb_config: web::Data<AybConfig>,
    daemon_registry: web::Data<DaemonRegistry>,
    authenticated_entity: Option<web::ReqData<InstantiatedEntity>>,
) -> Result<HttpResponse, AybError> {
    let entity_slug = &path.entity;

    let entity = ayb_db.get_entity_by_slug(entity_slug).await?;
    let db_type = get_required_header(&req, "db-type")?;
    let public_sharing_level = get_required_header(&req, "public-sharing-level")?;
    let database = Database {
        entity_id: entity.id,
        slug: path.database.clone(),
        db_type: DBType::from_str(&db_type)? as i16,
        public_sharing_level: PublicSharingLevel::from_str(&public_sharing_level)? as i16,
    };
    let authenticated_entity = unwrap_authenticated_entity(&authenticated_entity)?;
    if can_create_database(&authenticated_entity, &entity) {
        let created_database = ayb_db.create_database(&database).await?;
        // Create the database file at the appropriate path
        let db_path =
            instantiated_new_database_path(entity_slug, &path.database, &ayb_config.data_path)?;
        set_current_database_and_clean_up(&pathbuf_to_parent(&db_path)?, &daemon_registry).await?;
        Ok(HttpResponse::Created().json(APIDatabase::from_persisted(&entity, &created_database)))
    } else {
        Err(AybError::Other {
            message: format!(
                "Authenticated entity {} can't create a database for entity {}",
                authenticated_entity.slug, entity_slug
            ),
        })
    }
}