holochain_data 0.7.0-rc.1

Database abstraction layer for Holochain using sqlx
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

//! `DbRead<Dht>` / `DbWrite<Dht>` API for the `SliceHash` table.

use super::super::inner::slice_hash;
use crate::handles::{DbRead, DbWrite};
use crate::kind::Dht;
use crate::models::dht::SliceHashIndexedRow;

impl DbWrite<Dht> {
    /// Insert or replace the slice hash for `(arc_start, arc_end, slice_index)`.
    pub async fn insert_slice_hash(
        &self,
        arc_start: u32,
        arc_end: u32,
        slice_index: u64,
        hash: &[u8],
    ) -> sqlx::Result<()> {
        slice_hash::insert_slice_hash(self.pool(), arc_start, arc_end, slice_index, hash).await
    }
}

impl DbRead<Dht> {
    /// Number of stored slices for the arc, or 0 if none.
    pub async fn slice_hash_count(&self, arc_start: u32, arc_end: u32) -> sqlx::Result<u64> {
        let mut conn = self.timed_conn().await?;
        slice_hash::slice_hash_count(&mut *conn, arc_start, arc_end).await
    }

    /// Single slice hash, if any.
    pub async fn get_slice_hash(
        &self,
        arc_start: u32,
        arc_end: u32,
        slice_index: u64,
    ) -> sqlx::Result<Option<Vec<u8>>> {
        let mut conn = self.timed_conn().await?;
        slice_hash::get_slice_hash(&mut *conn, arc_start, arc_end, slice_index).await
    }

    /// Every `(slice_index, hash)` pair stored for the arc.
    pub async fn get_slice_hashes(
        &self,
        arc_start: u32,
        arc_end: u32,
    ) -> sqlx::Result<Vec<SliceHashIndexedRow>> {
        let mut conn = self.timed_conn().await?;
        slice_hash::get_slice_hashes(&mut *conn, arc_start, arc_end).await
    }
}