rouchdb 0.4.0

Local-first document database with CouchDB replication protocol support
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

//! Error condition tests: nonexistent docs, wrong revisions, conflicts.

mod common;

use common::{delete_remote_db, fresh_remote_db};
use rouchdb::{Database, RouchError};

#[tokio::test]
#[ignore]
async fn error_get_nonexistent_doc() {
    let url = fresh_remote_db("err_noexist").await;
    let db = Database::http(&url);

    let result = db.get("does_not_exist").await;
    assert!(matches!(result, Err(RouchError::NotFound(_))));

    delete_remote_db(&url).await;
}

#[tokio::test]
#[ignore]
async fn error_update_wrong_rev() {
    let url = fresh_remote_db("err_wrongrev").await;
    let db = Database::http(&url);

    db.put("doc1", serde_json::json!({"v": 1})).await.unwrap();

    let result = db
        .update("doc1", "1-bogusrevisionhash", serde_json::json!({"v": 2}))
        .await;
    assert!(result.is_err() || !result.unwrap().ok);

    delete_remote_db(&url).await;
}

#[tokio::test]
#[ignore]
async fn error_delete_wrong_rev() {
    let url = fresh_remote_db("err_delrev").await;
    let db = Database::http(&url);

    db.put("doc1", serde_json::json!({"v": 1})).await.unwrap();

    let result = db.remove("doc1", "1-bogusrevisionhash").await;
    assert!(result.is_err() || !result.unwrap().ok);

    delete_remote_db(&url).await;
}

#[tokio::test]
#[ignore]
async fn error_put_existing_without_rev() {
    let url = fresh_remote_db("err_dup").await;
    let db = Database::http(&url);

    db.put("doc1", serde_json::json!({"v": 1})).await.unwrap();

    let result = db.put("doc1", serde_json::json!({"v": 2})).await;
    assert!(result.is_err() || !result.unwrap().ok);

    delete_remote_db(&url).await;
}

#[tokio::test]
#[ignore]
async fn error_get_deleted_doc() {
    let url = fresh_remote_db("err_deleted").await;
    let db = Database::http(&url);

    let r1 = db.put("doc1", serde_json::json!({"v": 1})).await.unwrap();
    db.remove("doc1", &r1.rev.unwrap()).await.unwrap();

    let result = db.get("doc1").await;
    assert!(matches!(result, Err(RouchError::NotFound(_))));

    delete_remote_db(&url).await;
}