notedthat-write 0.12.1

Shared write path (commit, patch, replace) for NotedThat HTTP API and WebDAV surfaces
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

use notedthat_core::ConditionalHeaders;
use notedthat_indexer::IndexEvent;
use tokio::sync::mpsc;

use super::TestStorage;
use crate::replace::{ReplaceRequest, replace};

pub(in crate::replace::tests) struct ReplaceArgs<'a> {
    pub(in crate::replace::tests) old: &'a str,
    pub(in crate::replace::tests) new: &'a str,
    pub(in crate::replace::tests) replace_all: bool,
}

impl<'a> ReplaceArgs<'a> {
    pub(in crate::replace::tests) fn one(old: &'a str, new: &'a str) -> Self {
        Self {
            old,
            new,
            replace_all: false,
        }
    }

    pub(in crate::replace::tests) fn all(old: &'a str, new: &'a str) -> Self {
        Self {
            old,
            new,
            replace_all: true,
        }
    }
}

pub(in crate::replace::tests) async fn run_replace(
    storage: &TestStorage,
    args: ReplaceArgs<'_>,
) -> Result<crate::ReplaceOutcome, crate::WriteError> {
    run_replace_with(storage, args, conditionals(Some("etag1")), 1024, None).await
}

pub(in crate::replace::tests) async fn run_replace_with(
    storage: &TestStorage,
    args: ReplaceArgs<'_>,
    caller_conditionals: ConditionalHeaders,
    max_patchable_size: u64,
    supplied_indexer_tx: Option<mpsc::Sender<IndexEvent>>,
) -> Result<crate::ReplaceOutcome, crate::WriteError> {
    let (indexer_tx, _rx) = mpsc::channel::<IndexEvent>(8);
    let indexer_tx = supplied_indexer_tx.unwrap_or(indexer_tx);
    let kb = kb();
    let path = path();
    replace(
        storage,
        &crate::WriteSinks::indexer_only(&indexer_tx),
        ReplaceRequest {
            kb: &kb,
            path: &path,
            old_string: args.old,
            new_string: args.new,
            replace_all: args.replace_all,
            caller_conditionals,
            max_patchable_size,
            caller_content_type: None,
        },
    )
    .await
}

pub(in crate::replace::tests) fn expect_replace_err(
    result: Result<crate::ReplaceOutcome, crate::WriteError>,
) -> crate::WriteError {
    match result {
        Ok(_) => panic!("replace should fail"),
        Err(err) => err,
    }
}

pub(in crate::replace::tests) fn conditionals(etag: Option<&str>) -> ConditionalHeaders {
    super::make_conditionals(etag)
}

pub(in crate::replace::tests) fn kb() -> notedthat_core::KbSlug {
    super::make_kb()
}

pub(in crate::replace::tests) fn path() -> notedthat_core::ObjectPath {
    super::make_path()
}