persistence.rs 843 B

12345678910111213141516171819202122232425262728293031
  1. #![allow(clippy::all)]
  2. #![allow(dead_code)]
  3. #![allow(unused_variables)]
  4. use crate::{RevisionSnapshotDiskCache, RevisionSnapshotInfo};
  5. use flowy_database::ConnectionPool;
  6. use flowy_error::FlowyResult;
  7. use std::sync::Arc;
  8. pub struct SQLiteRevisionSnapshotPersistence {
  9. object_id: String,
  10. pool: Arc<ConnectionPool>,
  11. }
  12. impl SQLiteRevisionSnapshotPersistence {
  13. pub fn new(object_id: &str, pool: Arc<ConnectionPool>) -> Self {
  14. Self {
  15. object_id: object_id.to_string(),
  16. pool,
  17. }
  18. }
  19. }
  20. impl RevisionSnapshotDiskCache for SQLiteRevisionSnapshotPersistence {
  21. fn write_snapshot(&self, object_id: &str, rev_id: i64, data: Vec<u8>) -> FlowyResult<()> {
  22. todo!()
  23. }
  24. fn read_snapshot(&self, object_id: &str, rev_id: i64) -> FlowyResult<RevisionSnapshotInfo> {
  25. todo!()
  26. }
  27. }