Merge pull request #126 from theseus-rs/split-axum-progress-examples

docs: split axum and progress bar examples

Author: brianheineman

Cargo.lock

@@ -8,11 +8,9 @@ version.workspace = true
 [dependencies]
 anyhow = { workspace = true }
 axum = { workspace = true }
-indicatif = { workspace = true }
 postgresql_embedded = { path = "../../postgresql_embedded" }
 postgresql_extensions = { path = "../../postgresql_extensions" }
 sqlx = { workspace = true, features = ["runtime-tokio"] }
 tracing = { workspace = true }
-tracing-indicatif = { workspace = true }
 tracing-subscriber = { workspace = true }
 tokio = { workspace = true, features = ["full"] }

examples/axum_embedded/Cargo.toml

@@ -4,29 +4,18 @@
 use anyhow::Result;
 use axum::extract::State;
 use axum::{http::StatusCode, routing::get, Json, Router};
-use indicatif::ProgressStyle;
 use postgresql_embedded::{PostgreSQL, Settings, VersionReq};
 use sqlx::postgres::PgPoolOptions;
 use sqlx::PgPool;
 use std::env;
 use std::time::Duration;
 use tokio::net::TcpListener;
 use tracing::info;
-use tracing_indicatif::IndicatifLayer;
-use tracing_subscriber::filter::LevelFilter;
-use tracing_subscriber::prelude::*;
-use tracing_subscriber::{fmt, Registry};
 
 /// Example of how to use postgresql embedded with axum.
 #[tokio::main]
 async fn main() -> Result<()> {
-    let progress_style = ProgressStyle::with_template("{span_child_prefix}{spinner} {span_name} [{elapsed_precise}] [{wide_bar:.green.bold}] {bytes}/{total_bytes} ({bytes_per_sec}, {eta})")?
-        .progress_chars("=> ");
-    let indicatif_layer = IndicatifLayer::new().with_progress_style(progress_style);
-    let subscriber = Registry::default()
-        .with(fmt::Layer::default().with_filter(LevelFilter::INFO))
-        .with(indicatif_layer);
-    subscriber.init();
+    tracing_subscriber::fmt().compact().init();
 
     let db_url =
         env::var("DATABASE_URL").unwrap_or_else(|_| "postgresql://postgres@localhost".to_string());

examples/axum_embedded/src/main.rs

@@ -0,0 +1,16 @@
+[package]
+edition.workspace = true
+name = "download_progress_bar"
+publish = false
+license.workspace = true
+version.workspace = true
+
+[dependencies]
+anyhow = { workspace = true }
+indicatif = { workspace = true }
+postgresql_embedded = { path = "../../postgresql_embedded" }
+postgresql_extensions = { path = "../../postgresql_extensions" }
+tracing = { workspace = true }
+tracing-indicatif = { workspace = true }
+tracing-subscriber = { workspace = true }
+tokio = { workspace = true, features = ["full"] }

examples/download_progress_bar/Cargo.toml

@@ -0,0 +1,48 @@
+#![forbid(unsafe_code)]
+#![deny(clippy::pedantic)]
+
+use anyhow::Result;
+use indicatif::ProgressStyle;
+use postgresql_embedded::{PostgreSQL, Settings, VersionReq};
+use tracing_indicatif::IndicatifLayer;
+use tracing_subscriber::filter::LevelFilter;
+use tracing_subscriber::prelude::*;
+use tracing_subscriber::{fmt, Registry};
+
+/// Example of how to display a progress bar for the postgresql embedded archive download
+#[tokio::main]
+async fn main() -> Result<()> {
+    let progress_style = ProgressStyle::with_template("{span_child_prefix}{spinner} {span_name} [{elapsed_precise}] [{wide_bar:.green.bold}] {bytes}/{total_bytes} ({bytes_per_sec}, {eta})")?
+        .progress_chars("=> ");
+    let indicatif_layer = IndicatifLayer::new().with_progress_style(progress_style);
+    let subscriber = Registry::default()
+        .with(fmt::Layer::default().with_filter(LevelFilter::INFO))
+        .with(indicatif_layer);
+    subscriber.init();
+
+    let settings = Settings {
+        version: VersionReq::parse("=16.4.0")?,
+        ..Default::default()
+    };
+    let mut postgresql = PostgreSQL::new(settings);
+    postgresql.setup().await?;
+    postgresql.start().await?;
+
+    let database_name = "test";
+    postgresql.create_database(database_name).await?;
+    postgresql.database_exists(database_name).await?;
+    postgresql.drop_database(database_name).await?;
+
+    postgresql.stop().await?;
+    Ok(())
+}
+
+#[cfg(test)]
+mod test {
+    use super::*;
+
+    #[test]
+    fn test_main() -> Result<()> {
+        main()
+    }
+}