nostrdb 0.9.0

An unfairly fast embedded nostr database backed by lmdb
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
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use crate::bindings;
use crate::error::Error;
use crate::ndb::Ndb;
use crate::result::Result;

/// A `nostrdb` transaction. Only one is allowed to be active per thread.
#[derive(Debug)]
pub struct Transaction {
    txn: bindings::ndb_txn,
}

impl Transaction {
    /// Create a new `nostrdb` transaction. These are reference counted
    pub fn new(ndb: &Ndb) -> Result<Self> {
        // Initialize your transaction here
        let mut txn = bindings::ndb_txn::new();
        let res = unsafe { bindings::ndb_begin_query(ndb.as_ptr(), &mut txn) };

        if res == 0 {
            return Err(Error::TransactionFailed);
        }

        Ok(Transaction { txn })
    }

    pub fn as_ptr(&self) -> *const bindings::ndb_txn {
        &self.txn
    }

    pub fn as_mut_ptr(&self) -> *mut bindings::ndb_txn {
        self.as_ptr() as *mut bindings::ndb_txn
    }
}

impl Drop for Transaction {
    fn drop(&mut self) {
        // End the transaction
        unsafe {
            // Replace with your actual function
            bindings::ndb_end_query(&mut self.txn);
        }
    }
}

impl bindings::ndb_txn {
    fn new() -> Self {
        // just create something uninitialized. ndb_begin_query will initialize it for us
        let lmdb: *mut bindings::ndb_lmdb = std::ptr::null_mut();
        let mdb_txn: *mut ::std::os::raw::c_void = std::ptr::null_mut();
        bindings::ndb_txn { lmdb, mdb_txn }
    }
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::config::Config;
    use crate::ndb::Ndb;
    use crate::test_util;

    #[test]
    fn transaction_inheritence_fails() {
        let db = "target/testdbs/txn_inheritence_fails";
        // Initialize ndb
        {
            let cfg = Config::new();
            let ndb = Ndb::new(db, &cfg).expect("ndb open failed");

            {
                let _txn = Transaction::new(&ndb).expect("txn1 failed");
                let txn2 = Transaction::new(&ndb).expect_err("tx2");
                assert!(matches!(txn2, Error::TransactionFailed));
            }

            {
                let _txn = Transaction::new(&ndb).expect("txn1 failed");
            }
        }

        test_util::cleanup_db(db);
    }
}