Actor and REST interface for LEDB

The LEDB is an attempt to implement simple but efficient, lightweight but powerful document storage.

The abbreviation LEDB may be treated as an Lightweight Embedded DB, also Low End DB, also Literium Engine DB, also LitE DB, and so on.

Links

• ledb-actix Crate on crates.io
• ledb-actix API Docs on docs.rs
• ledb Crate on crates.io
• ledb API Docs on docs.rs

REST-interface

LEDB HTTP interface 0.1.0

Storage API

get database info

GET /info

get database statistics

GET /stats

Collection API

get list of collections

GET /collection

create new empty collection

POST /collection?name=$collectionname_

drop collection with all documents

DELETE /collection/$collectionname_

Index API

get indexes of collection

GET /collection/$collectionname_/index

create new index for collection

POST /collection/$collectionname/index?name=$fieldname&kind=$indexkind&type=$keytype

drop index of collection

DELETE /collection/$collectionname/document/$indexname

Document API

find documents using query

GET /collection/$collectionname/document?filter=$query&order=$ordering&offset=$skip&length=$take_

GET /collection/$collectionname?filter=$query&order=$ordering&offset=$skip&length=$take_

modify documents using query

PUT /collection/$collectionname/document?filter=$query&modify=$modifications_

PATCH /collection/$collectionname?filter=$query&modify=$modifications_

remove documents using query

DELETE /collection/$collectionname/document?filter=$query_

PUT /collection/$collectionname?filter=$query_

insert new document

POST /collection/$collectionname_/document

POST /collection/$collectionname_

get document by id

GET /collection/$collectionname/document/$documentid

GET /collection/$collectionname/$documentid

replace document

PUT /collection/$collectionname/document/$documentid

PUT /collection/$collectionname/$documentid

remove document

DELETE /collection/$collectionname/document/$documentid

DELETE /collection/$collectionname/$documentid

Supported index kinds

• uni -- Unique key
• dup -- Duplicated keys

Supported key types

• int -- 64-bit signed integer
• float -- 64-bit floating point number
• bool -- boolean value
• string -- UTF-8 string
• binary -- binary data

Actor

Usage example

```rust extern crate actix; extern crate futures; extern crate tokio;

[macro_use]

extern crate serde_derive;

[macro_use]

extern crate serde_json;

[macro_use]

extern crate ledb;

[macro_use]

extern crate ledb_actix;

[macro_use]

extern crate log; extern crate prettyenvlogger;

use actix::System; use futures::Future; use ledbactix::{Storage, StorageAddrExt}; use serdejson::from_value; use std::env; use tokio::spawn;

[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]

struct BlogPost { pub title: String, pub tags: Vec, pub content: String, }

fn main() { env::setvar("RUSTLOG", "info"); prettyenvlogger::init().unwrap();

let _ = std::fs::remove_dir_all("example_db");

System::run(|| {
    let addr = Storage::new("example_db").unwrap().start(1);

    spawn(
        addr.clone().send_query(query!(
            insert into blog {
                "title": "Absurd",
                "tags": ["absurd", "psychology"],
                "content": "Still nothing..."
            }
        )).and_then({ let addr = addr.clone(); move |id| {
            info!("Inserted document id: {}", id);
            assert_eq!(id, 1);

            addr.send_query(query!(
                insert into blog {
                    "title": "Lorem ipsum",
                    "tags": ["lorem", "ipsum"],
                    "content": "Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed do eiusmod tempor incididunt ut labore et dolore magna aliqua. Ut enim ad minim veniam, quis nostrud exercitation ullamco laboris nisi ut aliquip ex ea commodo consequat. Duis aute irure dolor in reprehenderit in voluptate velit esse cillum dolore eu fugiat nulla pariatur. Excepteur sint occaecat cupidatat non proident, sunt in culpa qui officia deserunt mollit anim id est laborum."
                }
            ))
        } }).and_then({ let addr = addr.clone(); move |id| {
            info!("Inserted document id: {}", id);
            assert_eq!(id, 2);

            addr.send_query(query!(
                index for blog tags string
            ))
        } }).and_then({ let addr = addr.clone(); move |_| {
            info!("Indexing is ok");

            addr.send_query(query!(
                find BlogPost in blog
                where tags == "psychology"
                    order asc
            ))
        } }).map(|mut docs| {
            info!("Number of found documents: {}", docs.size_hint().0);

            assert_eq!(docs.size_hint(), (1, Some(1)));

            let doc = docs.next().unwrap().unwrap();

            info!("Found document: {:?}", doc);

            let doc_data: BlogPost = from_value(json!({
                "title": "Absurd",
                "tags": ["absurd", "psychology"],
                "content": "Still nothing..."
            })).unwrap();

            assert_eq!(doc.get_data(), &doc_data);
            assert!(docs.next().is_none());

            System::current().stop();
        }).map_err(|err| {
            error!("Error: {:?}", err);
        })
    );
});

} ```