eventstore 2.1.1

Official EventStoreDB gRPC client
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
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150

#![allow(unused_attributes)]
#![allow(unused_imports)]
#![allow(unused_results)]
#![allow(unused_variables)]

use eventstore::{
    AppendToStreamOptions, Client, Credentials, EventData, ExpectedRevision, ReadStreamOptions,
    StreamPosition,
};
use futures::TryStreamExt;
use serde::{Deserialize, Serialize};
use std::error::Error;
use uuid::Uuid;

#[derive(Serialize, Deserialize)]
struct TestEvent {
    pub id: String,
    pub important_data: String,
}

type Result<A> = std::result::Result<A, Box<dyn Error>>;

pub async fn append_to_stream(client: &Client) -> Result<()> {
    // region append-to-stream
    let data = TestEvent {
        id: "1".to_string(),
        important_data: "some value".to_string(),
    };

    let event = EventData::json("some-event", &data)?.id(Uuid::new_v4());
    let options = AppendToStreamOptions::default().expected_revision(ExpectedRevision::NoStream);

    let _ = client
        .append_to_stream("some-stream", &options, event)
        .await?;
    // endregion append-to-stream

    Ok(())
}

pub async fn append_with_same_id(client: &Client) -> Result<()> {
    // region append-duplicate-event
    let data = TestEvent {
        id: "1".to_string(),
        important_data: "some value".to_string(),
    };

    let event = EventData::json("some-event", &data)?.id(Uuid::new_v4());
    let options = AppendToStreamOptions::default();

    let _ = client
        .append_to_stream("same-event-stream", &options, event.clone())
        .await?;

    let _ = client
        .append_to_stream("same-event-stream", &options, event)
        .await?;
    // endregion append-duplicate-event

    Ok(())
}

pub async fn append_with_no_stream(client: &Client) -> Result<()> {
    // region append-with-no-stream
    let data = TestEvent {
        id: "1".to_string(),
        important_data: "some value".to_string(),
    };

    let event = EventData::json("some-event", &data)?.id(Uuid::new_v4());
    let options = AppendToStreamOptions::default().expected_revision(ExpectedRevision::NoStream);

    let _ = client
        .append_to_stream("same-event-stream", &options, event)
        .await?;

    let data = TestEvent {
        id: "2".to_string(),
        important_data: "some other value".to_string(),
    };

    let event = EventData::json("some-event", &data)?.id(Uuid::new_v4());

    let _ = client
        .append_to_stream("same-event-stream", &options, event)
        .await?;
    // endregion append-with-no-stream

    Ok(())
}

pub async fn append_with_concurrency_check(client: Client) -> Result<()> {
    // region append-with-concurrency-check
    let options = ReadStreamOptions::default().position(StreamPosition::End);

    let last_event = client
        .read_stream("concurrency-stream", &options)
        .await?
        .next()
        .await?
        .expect("the stream to at least exist.");

    let data = TestEvent {
        id: "1".to_string(),
        important_data: "clientOne".to_string(),
    };

    let event = EventData::json("some-event", data)?.id(Uuid::new_v4());
    let options = AppendToStreamOptions::default().expected_revision(ExpectedRevision::Exact(
        last_event.get_original_event().revision,
    ));

    let _ = client
        .append_to_stream("concurrency-stream", &options, event)
        .await?;

    let data = TestEvent {
        id: "2".to_string(),
        important_data: "clientTwo".to_string(),
    };

    let event = EventData::json("some-event", &data)?.id(Uuid::new_v4());

    let _ = client
        .append_to_stream("concurrency-stream", &options, event)
        .await?;
    // endregion append-with-concurrency-check

    Ok(())
}

pub async fn append_overriding_user_credentials(client: &Client) -> Result<()> {
    let data = TestEvent {
        id: "1".to_string(),
        important_data: "clientOne".to_string(),
    };

    let event = EventData::json("some-event", data)?.id(Uuid::new_v4());

    // region overriding-user-credentials
    let options =
        AppendToStreamOptions::default().authenticated(Credentials::new("admin", "changeit"));

    let _ = client
        .append_to_stream("some-stream", &options, event)
        .await?;
    // endregion overriding-user-credentials

    Ok(())
}