Skip to content

Commit c26b5dd

Browse files
dotKurodotKuro
authored
chore: Prepare for release (#21)
* chore: Add release * fix: Remove self dependecy for release * fix: fix indendation * fix: rename creates token
1 parent 176e176 commit c26b5dd

File tree

15 files changed

+66
-51
lines changed

15 files changed

+66
-51
lines changed

‎.github/workflows/release.yml‎

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,5 +27,22 @@ jobs:
2727
- name: Create new version
2828
if: ${{ steps.get_next_version.outputs.hasNextVersion == 'true' }}
2929
run: |
30+
cargo install cargo-edit
31+
cargo set-version ${{ steps.get_next_version.outputs.version }}
32+
git config --global user.email "[email protected]"
33+
git config --global user.name "${{ github.actor }}"
34+
git add .
35+
git commit -m 'chore: Bump version to ${{ steps.get_next_version.outputs.version }}. [skip ci]'
36+
git push
3037
git tag v${{steps.get_next_version.outputs.version}}
3138
git push origin v${{steps.get_next_version.outputs.version}}
39+
- name: Build artifacts
40+
if: ${{ steps.get_next_version.outputs.hasNextVersion == 'true' }}
41+
run: |
42+
cargo build
43+
- name: Publish new version
44+
if: ${{ steps.get_next_version.outputs.hasNextVersion == 'true' }}
45+
run: |
46+
echo "${{ secrets.TOKEN_GITHUB_TO_CRATES_RW }}" | cargo login
47+
cargo package
48+
cargo publish

‎Cargo.lock‎

Lines changed: 1 addition & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎Cargo.toml‎

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
[package]
2-
name = "eventsourcingdb-client-rust"
2+
name = "eventsourcingdb"
33
version = "0.1.0"
44
edition = "2024"
55
description = "A client library for the EventsourcingDB by the native web."
@@ -33,7 +33,6 @@ typed-builder = "0.21.0"
3333
url = "2.5.4"
3434

3535
[dev-dependencies]
36-
eventsourcingdb-client-rust = { path = ".", features = ["testcontainer"] }
3736
testcontainers = { version = "0.24.0", features = ["http_wait"] }
3837
tokio = { version = "1.45.1", features = ["full"] }
3938
tokio-test = "0.4.4"

‎Makefile‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ analyze:
66
@cargo doc --all-features --no-deps --document-private-items
77

88
test:
9-
@cargo test
9+
@cargo test --features testcontainer
1010

1111
format:
1212
@cargo fmt

‎README.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
# eventsourcingdb-client-rust
1+
# eventsourcingdb
22

33
The official Rust client SDK for [EventSourcingDB](https://www.eventsourcingdb.io/).
44

‎src/client.rs‎

Lines changed: 32 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
//! To use the client, create it with the base URL and API token of your [EventsourcingDB](https://www.eventsourcingdb.io/) instance.
44
//! ```
55
//! # tokio_test::block_on(async {
6-
//! # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
6+
//! # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
77
//! let db_url = "http://localhost:3000/";
88
//! let api_token = "secrettoken";
99
//! # let db_url = container.get_base_url().await.unwrap();
1010
//! # let api_token = container.get_api_token();
11-
//! let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
11+
//! let client = eventsourcingdb::client::Client::new(db_url, api_token);
1212
//! client.ping().await.expect("Failed to ping");
1313
//! client.verify_api_token().await.expect("Failed to verify API token");
1414
//! # })
@@ -57,7 +57,7 @@ impl Client {
5757
/// Get the base URL of the client to use for API calls
5858
/// ```
5959
/// # use url::Url;
60-
/// # use eventsourcingdb_client_rust::client::Client;
60+
/// # use eventsourcingdb::client::Client;
6161
/// # let client = Client::new("http://localhost:8080/".parse().unwrap(), "token");
6262
/// let base_url = client.get_base_url();
6363
/// # assert_eq!(base_url.as_str(), "http://localhost:8080/");
@@ -69,7 +69,7 @@ impl Client {
6969

7070
/// Get the API token of the client to use for API calls
7171
/// ```
72-
/// # use eventsourcingdb_client_rust::client::Client;
72+
/// # use eventsourcingdb::client::Client;
7373
/// # use url::Url;
7474
/// # let client = Client::new("http://localhost:8080/".parse().unwrap(), "secrettoken");
7575
/// let api_token = client.get_api_token();
@@ -161,12 +161,12 @@ impl Client {
161161
///
162162
/// ```
163163
/// # tokio_test::block_on(async {
164-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
164+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
165165
/// let db_url = "http://localhost:3000/";
166166
/// let api_token = "secrettoken";
167167
/// # let db_url = container.get_base_url().await.unwrap();
168168
/// # let api_token = container.get_api_token();
169-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
169+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
170170
/// client.ping().await.expect("Failed to ping");
171171
/// # })
172172
/// ```
@@ -181,16 +181,16 @@ impl Client {
181181
/// Reads events from the DB instance.
182182
///
183183
/// ```
184-
/// use eventsourcingdb_client_rust::event::EventCandidate;
184+
/// use eventsourcingdb::event::EventCandidate;
185185
/// use futures::StreamExt;
186186
/// # use serde_json::json;
187187
/// # tokio_test::block_on(async {
188-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
188+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
189189
/// let db_url = "http://localhost:3000/";
190190
/// let api_token = "secrettoken";
191191
/// # let db_url = container.get_base_url().await.unwrap();
192192
/// # let api_token = container.get_api_token();
193-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
193+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
194194
/// let mut event_stream = client.read_events("/", None).await.expect("Failed to read events");
195195
/// while let Some(event) = event_stream.next().await {
196196
/// println!("Found Type {:?}", event.expect("Error while reading events"));
@@ -214,16 +214,16 @@ impl Client {
214214
/// Observe events from the DB instance.
215215
///
216216
/// ```
217-
/// use eventsourcingdb_client_rust::event::EventCandidate;
217+
/// use eventsourcingdb::event::EventCandidate;
218218
/// use futures::StreamExt;
219219
/// # use serde_json::json;
220220
/// # tokio_test::block_on(async {
221-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
221+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
222222
/// let db_url = "http://localhost:3000/";
223223
/// let api_token = "secrettoken";
224224
/// # let db_url = container.get_base_url().await.unwrap();
225225
/// # let api_token = container.get_api_token();
226-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
226+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
227227
/// # client.write_events(
228228
/// # vec![
229229
/// # EventCandidate::builder()
@@ -261,12 +261,12 @@ impl Client {
261261
///
262262
/// ```
263263
/// # tokio_test::block_on(async {
264-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
264+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
265265
/// let db_url = "http://localhost:3000/";
266266
/// let api_token = "secrettoken";
267267
/// # let db_url = container.get_base_url().await.unwrap();
268268
/// # let api_token = container.get_api_token();
269-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
269+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
270270
/// client.verify_api_token().await.expect("Failed to ping");
271271
/// # })
272272
/// ```
@@ -281,16 +281,16 @@ impl Client {
281281
/// Registers an event schema with the DB instance.
282282
///
283283
/// ```
284-
/// use eventsourcingdb_client_rust::event::EventCandidate;
284+
/// use eventsourcingdb::event::EventCandidate;
285285
/// use futures::StreamExt;
286286
/// # use serde_json::json;
287287
/// # tokio_test::block_on(async {
288-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
288+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
289289
/// let db_url = "http://localhost:3000/";
290290
/// let api_token = "secrettoken";
291291
/// # let db_url = container.get_base_url().await.unwrap();
292292
/// # let api_token = container.get_api_token();
293-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
293+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
294294
/// let event_type = "io.eventsourcingdb.test";
295295
/// let schema = json!({
296296
/// "type": "object",
@@ -323,16 +323,16 @@ impl Client {
323323
///
324324
/// To get all subjects in the DB, just pass `None` as the `base_subject`.
325325
/// ```
326-
/// use eventsourcingdb_client_rust::event::EventCandidate;
326+
/// use eventsourcingdb::event::EventCandidate;
327327
/// use futures::StreamExt;
328328
/// # use serde_json::json;
329329
/// # tokio_test::block_on(async {
330-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
330+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
331331
/// let db_url = "http://localhost:3000/";
332332
/// let api_token = "secrettoken";
333333
/// # let db_url = container.get_base_url().await.unwrap();
334334
/// # let api_token = container.get_api_token();
335-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
335+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
336336
/// let mut subject_stream = client.list_subjects(None).await.expect("Failed to list event types");
337337
/// while let Some(subject) = subject_stream.next().await {
338338
/// println!("Found Type {}", subject.expect("Error while reading types"));
@@ -342,16 +342,16 @@ impl Client {
342342
///
343343
/// To get all subjects under /test in the DB, just pass `Some("/test")` as the `base_subject`.
344344
/// ```
345-
/// use eventsourcingdb_client_rust::event::EventCandidate;
345+
/// use eventsourcingdb::event::EventCandidate;
346346
/// use futures::StreamExt;
347347
/// # use serde_json::json;
348348
/// # tokio_test::block_on(async {
349-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
349+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
350350
/// let db_url = "http://localhost:3000/";
351351
/// let api_token = "secrettoken";
352352
/// # let db_url = container.get_base_url().await.unwrap();
353353
/// # let api_token = container.get_api_token();
354-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
354+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
355355
/// let mut subject_stream = client.list_subjects(Some("/test")).await.expect("Failed to list event types");
356356
/// while let Some(subject) = subject_stream.next().await {
357357
/// println!("Found Type {}", subject.expect("Error while reading types"));
@@ -376,16 +376,16 @@ impl Client {
376376
/// List all event types in the DB instance.
377377
///
378378
/// ```
379-
/// use eventsourcingdb_client_rust::event::EventCandidate;
379+
/// use eventsourcingdb::event::EventCandidate;
380380
/// use futures::StreamExt;
381381
/// # use serde_json::json;
382382
/// # tokio_test::block_on(async {
383-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
383+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
384384
/// let db_url = "http://localhost:3000/";
385385
/// let api_token = "secrettoken";
386386
/// # let db_url = container.get_base_url().await.unwrap();
387387
/// # let api_token = container.get_api_token();
388-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
388+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
389389
/// let mut type_stream = client.list_event_types().await.expect("Failed to list event types");
390390
/// while let Some(ty) = type_stream.next().await {
391391
/// println!("Found Type {}", ty.expect("Error while reading types").name);
@@ -405,15 +405,15 @@ impl Client {
405405
/// Writes events to the DB instance.
406406
///
407407
/// ```
408-
/// use eventsourcingdb_client_rust::event::EventCandidate;
408+
/// use eventsourcingdb::event::EventCandidate;
409409
/// # use serde_json::json;
410410
/// # tokio_test::block_on(async {
411-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
411+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
412412
/// let db_url = "http://localhost:3000/";
413413
/// let api_token = "secrettoken";
414414
/// # let db_url = container.get_base_url().await.unwrap();
415415
/// # let api_token = container.get_api_token();
416-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
416+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
417417
/// let candidates = vec![
418418
/// EventCandidate::builder()
419419
/// .source("https://www.eventsourcingdb.io".to_string())
@@ -443,16 +443,16 @@ impl Client {
443443
/// Run an eventql query against the DB.
444444
///
445445
/// ```
446-
/// use eventsourcingdb_client_rust::event::EventCandidate;
446+
/// use eventsourcingdb::event::EventCandidate;
447447
/// use futures::StreamExt;
448448
/// # use serde_json::json;
449449
/// # tokio_test::block_on(async {
450-
/// # let container = eventsourcingdb_client_rust::container::Container::start_default().await.unwrap();
450+
/// # let container = eventsourcingdb::container::Container::start_default().await.unwrap();
451451
/// let db_url = "http://localhost:3000/";
452452
/// let api_token = "secrettoken";
453453
/// # let db_url = container.get_base_url().await.unwrap();
454454
/// # let api_token = container.get_api_token();
455-
/// let client = eventsourcingdb_client_rust::client::Client::new(db_url, api_token);
455+
/// let client = eventsourcingdb::client::Client::new(db_url, api_token);
456456
/// let query = "FROM e IN events ORDER BY e.time DESC TOP 100 PROJECT INTO e";
457457
/// let mut row_stream = client.run_eventql_query(query).await.expect("Failed to list event types");
458458
/// while let Some(row) = row_stream.next().await {

‎src/container.rs‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
//! ## Shortcut suitable for most use cases
1010
//! This starts a container with the default settings which is most likely what you want.
1111
//! ```
12-
//! # use eventsourcingdb_client_rust::container::Container;
12+
//! # use eventsourcingdb::container::Container;
1313
//! # tokio_test::block_on(async {
1414
//! let container = Container::start_default().await;
1515
//! // let client = container.get_client().await;
@@ -19,7 +19,7 @@
1919
//! ## Custom configuration
2020
//! This allows you to configure the container to your needs.
2121
//! ```
22-
//! # use eventsourcingdb_client_rust::container::Container;
22+
//! # use eventsourcingdb::container::Container;
2323
//! # tokio_test::block_on(async {
2424
//! let container = Container::builder()
2525
//! .with_image_tag("v1.0.0")
@@ -48,7 +48,7 @@ use crate::{client::Client, error::ContainerError};
4848
///
4949
/// By default this container is the same as running this:
5050
/// ```
51-
/// # use eventsourcingdb_client_rust::container::Container;
51+
/// # use eventsourcingdb::container::Container;
5252
/// # tokio_test::block_on(async {
5353
/// let builder = Container::builder()
5454
/// .with_image_tag("latest")
@@ -144,7 +144,7 @@ impl ContainerBuilder {
144144
/// You'll most likely want to use the [`Container::start_default`] method to create a new container instance for your tests.
145145
/// For more details, see the [`crate::container`] module documentation.
146146
/// ```
147-
/// # use eventsourcingdb_client_rust::container::Container;
147+
/// # use eventsourcingdb::container::Container;
148148
/// # tokio_test::block_on(async {
149149
/// let container = Container::start_default().await;
150150
/// // let client = container.get_client().await;

‎tests/essentials.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use eventsourcingdb_client_rust::{client::Client, container::Container};
1+
use eventsourcingdb::{client::Client, container::Container};
22

33
#[tokio::test]
44
async fn ping() {

‎tests/metadata_and_discovery.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
use eventsourcingdb_client_rust::container::Container;
1+
use eventsourcingdb::container::Container;
22
use futures::StreamExt;
33
use serde_json::json;
44

‎tests/observe_events.rs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
mod utils;
22

3-
use eventsourcingdb_client_rust::container::Container;
3+
use eventsourcingdb::container::Container;
44
use futures::stream::StreamExt;
55
use serde_json::json;
66
use utils::create_test_eventcandidate;

0 commit comments

Comments
 (0)