iota-sdk 2.0.0-beta.1

The IOTA SDK provides developers with a seamless experience to develop on IOTA by providing account abstractions and clients to interact with node APIs.
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

// Copyright 2021 IOTA Stiftung
// SPDX-License-Identifier: Apache-2.0

use std::{path::Path, sync::Arc};

use rocksdb::{DBCompressionType, Options, DB};
use tokio::sync::Mutex;

use crate::{client::storage::StorageAdapter, wallet::WalletError};

/// Key value storage adapter.
#[derive(Clone, Debug)]
pub struct RocksdbStorageAdapter {
    pub(crate) db: Arc<Mutex<DB>>,
}

impl RocksdbStorageAdapter {
    /// Initialises the storage adapter.
    pub fn new(path: impl AsRef<Path>) -> Result<Self, WalletError> {
        let mut opts = Options::default();
        opts.set_compression_type(DBCompressionType::Lz4);
        opts.create_if_missing(true);
        opts.create_missing_column_families(true);
        let db = DB::open(&opts, path)?;
        Ok(Self {
            db: Arc::new(Mutex::new(db)),
        })
    }
}

#[async_trait::async_trait]
impl StorageAdapter for RocksdbStorageAdapter {
    type Error = WalletError;

    async fn get_bytes(&self, key: &str) -> Result<Option<Vec<u8>>, WalletError> {
        Ok(self.db.lock().await.get(key)?)
    }

    async fn set_bytes(&self, key: &str, record: &[u8]) -> Result<(), WalletError> {
        self.db.lock().await.put(key, record)?;
        Ok(())
    }

    async fn delete(&self, key: &str) -> Result<(), WalletError> {
        self.db.lock().await.delete(key)?;
        Ok(())
    }
}