matrix-sdk-indexeddb 0.17.0

Web's IndexedDB Storage backend for matrix-sdk
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

// Copyright 2025 The Matrix.org Foundation C.I.C.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License

use std::{rc::Rc, sync::Arc};

use matrix_sdk_base::media::store::MediaService;
use matrix_sdk_store_encryption::StoreCipher;

use crate::{
    media_store::{
        IndexeddbMediaStore, error::IndexeddbMediaStoreError, migrations::open_and_upgrade_db,
    },
    serializer::{indexed_type::IndexedTypeSerializer, safe_encode::types::SafeEncodeSerializer},
};

/// A type for conveniently building an [`IndexeddbMediaStore`]
pub struct IndexeddbMediaStoreBuilder {
    // The name of the IndexedDB database which will be opened
    database_name: String,
    // The store cipher, if any, to use when encrypting data
    // before it is persisted to the IndexedDB database
    store_cipher: Option<Arc<StoreCipher>>,
}

impl Default for IndexeddbMediaStoreBuilder {
    fn default() -> Self {
        Self { database_name: Self::DEFAULT_DATABASE_NAME.to_owned(), store_cipher: None }
    }
}

impl IndexeddbMediaStoreBuilder {
    /// The default name of the IndexedDB database used to back the
    /// [`IndexeddbMediaStore`]
    pub const DEFAULT_DATABASE_NAME: &'static str = "media";

    /// Create a new [`IndexeddbMediaStoreBuilder`] where the database name is
    /// constructed by joining the given prefix with
    /// [`Self::DEFAULT_DATABASE_NAME`] and separated by `::`.
    pub fn with_prefix(prefix: &str) -> Self {
        Self {
            database_name: format!("{}::{}", prefix, Self::DEFAULT_DATABASE_NAME),
            store_cipher: None,
        }
    }

    /// Sets the name of the IndexedDB database which will be opened. This
    /// defaults to [`Self::DEFAULT_DATABASE_NAME`].
    pub fn database_name(mut self, name: String) -> Self {
        self.database_name = name;
        self
    }

    /// Sets the store cipher to use when encrypting data before it is persisted
    /// to the IndexedDB database. By default, no store cipher is used -
    /// i.e., data is not encrypted before it is persisted.
    pub fn store_cipher(mut self, store_cipher: Arc<StoreCipher>) -> Self {
        self.store_cipher = Some(store_cipher);
        self
    }

    /// Opens the IndexedDB database with the provided name. If successfully
    /// opened, builds the [`IndexeddbMediaStore`] with that database
    /// and the provided store cipher.
    pub async fn build(self) -> Result<IndexeddbMediaStore, IndexeddbMediaStoreError> {
        Ok(IndexeddbMediaStore {
            inner: Rc::new(open_and_upgrade_db(&self.database_name).await?),
            serializer: IndexedTypeSerializer::new(SafeEncodeSerializer::new(self.store_cipher)),
            media_service: MediaService::new(),
        })
    }
}