mirror of
https://github.com/servo/servo.git
synced 2025-09-30 00:29:14 +01:00
0089e652c5
Sanitization of object store names brought some problems because of replacing special characters and making it impossible to have certain object store names that are allowed by the spec. These changes make sure deterministic UUIDs are used for file paths plus object store names are inserted into SQLite without sanitization. Testing: Covered by existing tests and new unit tests were added. Fixes: #37569 --------- Signed-off-by: Rodion Borovyk <rodion.borovyk@gmail.com>
63 lines
1.9 KiB
Rust
63 lines
1.9 KiB
Rust
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at https://mozilla.org/MPL/2.0/. */
|
|
|
|
use std::collections::VecDeque;
|
|
|
|
use net_traits::indexeddb_thread::{AsyncOperation, CreateObjectResult, IndexedDBTxnMode, KeyPath};
|
|
use tokio::sync::oneshot;
|
|
|
|
pub use self::sqlite::SqliteEngine;
|
|
|
|
mod sqlite;
|
|
|
|
pub struct KvsOperation {
|
|
pub store_name: String,
|
|
pub operation: AsyncOperation,
|
|
}
|
|
|
|
pub struct KvsTransaction {
|
|
// Mode could be used by a more optimal implementation of transactions
|
|
// that has different allocated threadpools for reading and writing
|
|
#[allow(unused)]
|
|
pub mode: IndexedDBTxnMode,
|
|
pub requests: VecDeque<KvsOperation>,
|
|
}
|
|
|
|
pub trait KvsEngine {
|
|
type Error: std::error::Error;
|
|
|
|
fn create_store(
|
|
&self,
|
|
store_name: &str,
|
|
key_path: Option<KeyPath>,
|
|
auto_increment: bool,
|
|
) -> Result<CreateObjectResult, Self::Error>;
|
|
|
|
fn delete_store(&self, store_name: &str) -> Result<(), Self::Error>;
|
|
|
|
fn close_store(&self, store_name: &str) -> Result<(), Self::Error>;
|
|
|
|
fn delete_database(self) -> Result<(), Self::Error>;
|
|
|
|
fn process_transaction(
|
|
&self,
|
|
transaction: KvsTransaction,
|
|
) -> oneshot::Receiver<Option<Vec<u8>>>;
|
|
|
|
fn has_key_generator(&self, store_name: &str) -> bool;
|
|
fn key_path(&self, store_name: &str) -> Option<KeyPath>;
|
|
|
|
fn create_index(
|
|
&self,
|
|
store_name: &str,
|
|
index_name: String,
|
|
key_path: KeyPath,
|
|
unique: bool,
|
|
multi_entry: bool,
|
|
) -> Result<CreateObjectResult, Self::Error>;
|
|
fn delete_index(&self, store_name: &str, index_name: String) -> Result<(), Self::Error>;
|
|
|
|
fn version(&self) -> Result<u64, Self::Error>;
|
|
fn set_version(&self, version: u64) -> Result<(), Self::Error>;
|
|
}
|