lb-rs 26.4.13

The rust library for interacting with your lockbook.
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

use super::errors::{DiffError, LbErrKind, LbResult};
use super::meta::Meta;
use super::server_meta::{IntoServerMeta, ServerMeta};
use super::signed_meta::SignedMeta;
use crate::model::clock::get_time;
use crate::model::file_like::FileLike;
use crate::model::file_metadata::FileDiff;
use crate::model::lazy::{LazyStaged1, LazyTree};
use crate::model::server_tree::ServerTree;
use crate::model::signed_file::SignedFile;
use crate::model::tree_like::TreeLike;

type LazyServerStaged1<'a> = LazyStaged1<ServerTree<'a>, Vec<ServerMeta>>;

impl<'a> LazyTree<ServerTree<'a>> {
    /// Validates a diff prior to staging it. Performs individual validations, then validations that
    /// require a tree
    pub fn stage_diff(self, changes: Vec<FileDiff<SignedFile>>) -> LbResult<LazyServerStaged1<'a>> {
        let mut changes_meta: Vec<FileDiff<SignedMeta>> = vec![];
        for change in changes {
            let mut new_meta: SignedMeta = change.new.into();
            let mut old_meta = change.old.map(SignedMeta::from);
            if let Some(old) = &mut old_meta {
                let current_size = *self
                    .maybe_find(old.id())
                    .ok_or(LbErrKind::Diff(DiffError::OldFileNotFound))?
                    .file
                    .timestamped_value
                    .value
                    .doc_size();

                match &mut old.timestamped_value.value {
                    Meta::V1 { doc_size, .. } => {
                        *doc_size = current_size;
                    }
                };

                match &mut new_meta.timestamped_value.value {
                    Meta::V1 { doc_size, .. } => {
                        *doc_size = current_size;
                    }
                };
            }

            changes_meta.push(FileDiff { old: old_meta, new: new_meta });
        }

        self.stage_diff_v2(changes_meta)
    }

    pub fn stage_diff_v2(
        self, mut changes: Vec<FileDiff<SignedMeta>>,
    ) -> LbResult<LazyServerStaged1<'a>> {
        // Check new.id == old.id
        for change in &changes {
            if let Some(old) = &change.old {
                if old.id() != change.new.id() {
                    return Err(LbErrKind::Diff(DiffError::DiffMalformed))?;
                }
            }
        }

        // Check for changes to digest
        for change in &changes {
            match &change.old {
                Some(old) => {
                    if old.timestamped_value.value.document_hmac()
                        != change.new.timestamped_value.value.document_hmac()
                    {
                        return Err(LbErrKind::Diff(DiffError::HmacModificationInvalid))?;
                    }

                    if old.timestamped_value.value.doc_size()
                        != change.new.timestamped_value.value.doc_size()
                    {
                        return Err(LbErrKind::Diff(DiffError::SizeModificationInvalid))?;
                    }
                }
                None => {
                    if change.new.timestamped_value.value.doc_size().is_some() {
                        return Err(LbErrKind::Diff(DiffError::SizeModificationInvalid))?;
                    }
                    if change.new.timestamped_value.value.document_hmac().is_some() {
                        return Err(LbErrKind::Diff(DiffError::HmacModificationInvalid))?;
                    }
                }
            }
        }

        // Check for race conditions and populate prior size
        for change in &mut changes {
            match &change.old {
                Some(old) => {
                    let current = &self
                        .maybe_find(old.id())
                        .ok_or(LbErrKind::Diff(DiffError::OldFileNotFound))?
                        .file;

                    if current != old {
                        return Err(LbErrKind::Diff(DiffError::OldVersionIncorrect))?;
                    }
                }
                None => {
                    // if you're claiming this file is new, it must be globally unique
                    if self.tree.files.maybe_find(change.new.id()).is_some() {
                        return Err(LbErrKind::Diff(DiffError::OldVersionRequired))?;
                    }
                }
            }
        }

        let now = get_time().0 as u64;
        let changes = changes
            .into_iter()
            .map(|change| change.new.add_time(now))
            .collect();

        Ok(self.stage(changes))
    }
}