Start9/patch-db
2
0
Fork 0
mirror of https://github.com/Start9Labs/patch-db.git synced 2026-03-26 02:11:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

dump type

Browse Source
This commit is contained in:
Aiden McClelland
2021-06-15 14:39:41 -06:00
committed by Aiden McClelland
parent b5cf9f28ba
commit 8bc6a3a1a5
2 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
patch-db/src/patch.rs
View File

@@ -14,6 +14,13 @@ pub struct Revision {
pub expire_id: Option<String>, pub expire_id: Option<String>,
} }
#[derive(Debug, Clone, Deserialize, Serialize)]
#[serde(rename_all = "kebab-case")]
pub struct Dump {
pub id: u64,
pub value: Value,
}
#[derive(Debug, Clone, Deserialize, Serialize)] #[derive(Debug, Clone, Deserialize, Serialize)]
pub struct DiffPatch(Patch); pub struct DiffPatch(Patch);
impl DiffPatch { impl DiffPatch {

11
patch-db/src/store.rs
View File

@@ -15,7 +15,7 @@ use tokio::fs::File;
use tokio::sync::broadcast::{Receiver, Sender}; use tokio::sync::broadcast::{Receiver, Sender};
use tokio::sync::{Mutex, RwLock, RwLockWriteGuard}; use tokio::sync::{Mutex, RwLock, RwLockWriteGuard};
use crate::patch::{diff, DiffPatch, Revision}; use crate::patch::{diff, DiffPatch, Dump, Revision};
use crate::Error; use crate::Error;
use crate::{locker::Locker, PatchDbHandle}; use crate::{locker::Locker, PatchDbHandle};
@@ -146,8 +146,11 @@ impl Store {
ptr.get(self.get_data()?).unwrap_or(&Value::Null).clone(), ptr.get(self.get_data()?).unwrap_or(&Value::Null).clone(),
)?) )?)
} }
pub(crate) fn dump(&self) -> Value { pub(crate) fn dump(&self) -> Dump {
self.get_data().unwrap().clone() Dump {
id: self.revision,
value: self.get_data().unwrap().clone(),
}
} }
pub(crate) async fn put<T: Serialize + ?Sized, S: AsRef<str>, V: SegList>( pub(crate) async fn put<T: Serialize + ?Sized, S: AsRef<str>, V: SegList>(
&mut self, &mut self,
@@ -214,7 +217,7 @@ impl PatchDb {
subscriber: Arc::new(subscriber), subscriber: Arc::new(subscriber),
}) })
} }
pub async fn dump(&self) -> Value { pub async fn dump(&self) -> Dump {
self.store.read().await.dump() self.store.read().await.dump()
} }
pub async fn exists<S: AsRef<str>, V: SegList>( pub async fn exists<S: AsRef<str>, V: SegList>(