chore: add testcontainer to examples

Author: dotKuro

examples/event_types.rs

@@ -1,11 +1,11 @@
-use eventsourcingdb::client::Client;
+use eventsourcingdb::{client::Client, container::Container};
 use futures::StreamExt;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client.list_event_types().await;

examples/listing_subjects.rs

@@ -1,11 +1,11 @@
-use eventsourcingdb::client::Client;
+use eventsourcingdb::{client::Client, container::Container};
 use futures::StreamExt;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client.list_subjects(Some("/")).await;

examples/observing_events.rs

@@ -1,11 +1,14 @@
-use eventsourcingdb::client::{Client, request_options::ObserveEventsRequestOptions};
+use eventsourcingdb::{
+    client::{Client, request_options::ObserveEventsRequestOptions},
+    container::Container,
+};
 use futures::StreamExt;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client

examples/ping.rs

@@ -1,10 +1,10 @@
-use eventsourcingdb::client::Client;
-use url::Url;
+use eventsourcingdb::{client::Client, container::Container};
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client.ping().await;

examples/reading_events.rs

@@ -1,11 +1,14 @@
-use eventsourcingdb::client::{Client, request_options::ReadEventsRequestOptions};
+use eventsourcingdb::{
+    client::{Client, request_options::ReadEventsRequestOptions},
+    container::Container,
+};
 use futures::StreamExt;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client

examples/registering_event_schema.rs

@@ -1,11 +1,11 @@
-use eventsourcingdb::client::Client;
+use eventsourcingdb::{client::Client, container::Container};
 use serde_json::json;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client

examples/running_eventql.rs

@@ -1,11 +1,11 @@
-use eventsourcingdb::client::Client;
+use eventsourcingdb::{client::Client, container::Container};
 use futures::StreamExt;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client

examples/verify_api_token.rs

@@ -1,10 +1,10 @@
-use eventsourcingdb::client::Client;
-use url::Url;
+use eventsourcingdb::{client::Client, container::Container};
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let result = client.verify_api_token().await;

examples/write_events.rs

@@ -1,11 +1,11 @@
-use eventsourcingdb::{client::Client, event::EventCandidate};
+use eventsourcingdb::{client::Client, container::Container, event::EventCandidate};
 use serde_json::json;
-use url::Url;
 
 #[tokio::main]
 async fn main() {
-    let base_url: Url = "localhost:3000".parse().unwrap();
-    let api_token = "secret";
+    let db = Container::start_default().await.unwrap();
+    let base_url = db.get_base_url().await.unwrap();
+    let api_token = db.get_api_token();
     let client = Client::new(base_url, api_token);
 
     let event = EventCandidate::builder()