moltendb-server 0.2.0-beta.1

MoltenDB HTTP server — Axum routing, TLS, auth, rate limiting, CORS.
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

use serde_json::{Value, json};
use crate::validation;
use moltendb_core::engine;

/// Handle a DELETE request.
///
/// Three modes:
///   - Single key:  { "collection": "users", "keys": "u1" }
///   - Batch keys:  { "collection": "users", "keys": ["u1", "u2"] }
///   - Drop all:    { "collection": "users", "drop": true }
pub fn process_delete(db: &engine::Db, payload: &Value, max_body_size: usize) -> (u16, Value) {
    if let Err(e) = validation::validate_request(payload, max_body_size) {
        return (400, json!({ "error": e.to_string(), "statusCode": 400 }));
    }
    // Only "collection", "keys", and "drop" are valid for a delete request.
    const DELETE_ALLOWED: &[&str] = &["collection", "keys", "drop"];
    if let Err(e) = validation::validate_allowed_properties(payload, DELETE_ALLOWED) {
        return (400, json!({ "error": e.to_string(), "statusCode": 400 }));
    }

    let col = payload["collection"].as_str().unwrap_or("default");

    // Check for drop: true — this removes the entire collection.
    if payload["drop"].as_bool().unwrap_or(false) {
        return match db.delete_collection(col) {
            Ok(_)  => (200, json!({ "status": "ok", "dropped": true })),
            Err(e) => (500, json!({ "error": "Failed to drop collection", "details": e.to_string(), "statusCode": 500 }))
        };
    }

    match payload.get("keys") {
        // Single key delete.
        Some(Value::String(k)) => {
            match db.delete(col, k) {
                Ok(_)  => (200, json!({ "status": "ok", "deleted": 1 })),
                Err(e) => (500, json!({ "error": "Failed to delete key", "details": e.to_string(), "statusCode": 500 }))
            }
        },

        // Batch key delete — collect all keys then delete in one call.
        Some(Value::Array(arr)) => {
            let mut keys = Vec::new();
            for k in arr {
                if let Some(s) = k.as_str() { keys.push(s.to_string()); }
            }
            let count = keys.len();
            match db.delete_batch(col, keys) {
                Ok(_)  => (200, json!({ "status": "ok", "deleted": count })),
                Err(e) => (500, json!({ "error": "Failed to delete batch", "details": e.to_string(), "statusCode": 500 }))
            }
        },
        // Neither keys nor drop:true — invalid request.
        _ => (400, json!({ "error": "Missing 'keys' (string or array) or 'drop': true", "statusCode": 400 }))
    }
}