rouchdb 0.3.2

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

//! Attachment tests: put/get text and binary data via HTTP adapter.

mod common;

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

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

    let r1 = db
        .put("doc1", serde_json::json!({"name": "test"}))
        .await
        .unwrap();
    let rev = r1.rev.unwrap();

    let data = b"Hello, CouchDB attachments!".to_vec();
    let result = db
        .adapter()
        .put_attachment("doc1", "greeting.txt", &rev, data.clone(), "text/plain")
        .await
        .unwrap();
    assert!(result.ok);

    let retrieved = db
        .adapter()
        .get_attachment("doc1", "greeting.txt", GetAttachmentOptions::default())
        .await
        .unwrap();
    assert_eq!(retrieved, data);

    let doc = db.get("doc1").await.unwrap();
    assert_eq!(doc.data["name"], "test");

    delete_remote_db(&url).await;
}

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

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

    let binary_data: Vec<u8> = (0..=255).collect();
    let result = db
        .adapter()
        .put_attachment(
            "doc1",
            "bytes.bin",
            &rev,
            binary_data.clone(),
            "application/octet-stream",
        )
        .await
        .unwrap();
    assert!(result.ok);

    let retrieved = db
        .adapter()
        .get_attachment("doc1", "bytes.bin", GetAttachmentOptions::default())
        .await
        .unwrap();
    assert_eq!(retrieved, binary_data);

    delete_remote_db(&url).await;
}