Merge branch 'master' into fix-openapi-example

.github/workflows/ci.yml

@@ -61,7 +61,7 @@ jobs:
       - name: Cache Rust
         uses: Swatinem/rust-cache@v2
       - name: Install Protoc
-        if: matrix.package.name == 'poem-grpc'
+        if: matrix.package.name == 'poem-grpc' || matrix.package.name == 'poem-openapi'
         uses: arduino/setup-protoc@v1
 
       # Do tests

.github/workflows/release.yml

@@ -43,7 +43,7 @@ jobs:
       - name: Checkout
         uses: actions/checkout@v3
       - name: Install Protoc
-        if: matrix.package.name == 'poem-grpc'
+        if: matrix.package.name == 'poem-grpc' || matrix.package.name == 'poem-openapi'
         uses: arduino/setup-protoc@v1
       - name: Get Version
         working-directory: ${{ matrix.package.path }}

Cargo.toml

@@ -36,7 +36,7 @@ thiserror = "1.0.30"
 regex = "1.5.5"
 mime = "0.3.16"
 tracing = "0.1.36"
-chrono = { version = "0.4.19", default-features = false }
+chrono = { version = "0.4.31", default-features = false }
 bytes = "1.1.0"
 futures-util = "0.3.17"
 tokio-stream = "0.1.8"

examples/Cargo.toml

@@ -1,4 +1,5 @@
 [workspace]
+resolver = "2"
 members = ["poem/*", "openapi/*", "grpc/*"]
 
 [workspace.package]
@@ -14,7 +15,7 @@ poem-lambda = { path = "../poem-lambda" }
 poem-grpc-build = { path = "../poem-grpc-build" }
 
 tokio = "1.17.0"
-tracing-subscriber = { version ="0.3.9", features = ["env-filter"] }
+tracing-subscriber = { version = "0.3.9", features = ["env-filter"] }
 serde_json = "1.0.68"
 serde = { version = "1.0.140", features = ["derive"] }
 mime = "0.3.16"

examples/grpc/helloworld/src/main.rs

@@ -21,7 +21,7 @@ impl Greeter for GreeterService {
 #[tokio::main]
 async fn main() -> Result<(), std::io::Error> {
     let route = RouteGrpc::new().add_service(GreeterServer::new(GreeterService));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(route)
         .await
 }

examples/grpc/jsoncodec/src/main.rs

@@ -25,7 +25,7 @@ async fn main() -> Result<(), std::io::Error> {
     }
     tracing_subscriber::fmt::init();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             RouteGrpc::new()
                 .add_service(GreeterServer::new(GreeterService))

examples/grpc/middleware/src/main.rs

@@ -22,7 +22,7 @@ impl Greeter for GreeterService {
 
 #[tokio::main]
 async fn main() -> Result<(), std::io::Error> {
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(RouteGrpc::new().add_service(GreeterServer::new(GreeterService)))
         .await
 }

examples/grpc/reflection/src/main.rs

@@ -26,7 +26,7 @@ async fn main() -> Result<(), std::io::Error> {
     }
     tracing_subscriber::fmt::init();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             RouteGrpc::new()
                 .add_service(

examples/grpc/routeguide/src/main.rs

@@ -148,7 +148,7 @@ async fn main() -> Result<(), std::io::Error> {
     }
     tracing_subscriber::fmt::init();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             RouteGrpc::new()
                 .add_service(RouteGuideServer::new(RouteGuideService {

examples/openapi/auth-apikey/src/main.rs

@@ -84,7 +84,7 @@ async fn main() -> Result<(), std::io::Error> {
         .nest("/", ui)
         .data(server_key);
 
-    poem::Server::new(TcpListener::bind("127.0.0.1:3000"))
+    poem::Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/openapi/auth-basic/src/main.rs

@@ -33,7 +33,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Authorization Demo", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    poem::Server::new(TcpListener::bind("127.0.0.1:3000"))
+    poem::Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/auth-github/src/main.rs

@@ -91,7 +91,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Authorization Demo", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             Route::new()
                 .at("/proxy", oauth_token_url_proxy)

examples/openapi/auth-multiple/src/main.rs

@@ -99,7 +99,7 @@ async fn main() -> Result<(), std::io::Error> {
         .nest("/", ui)
         .data(server_key);
 
-    poem::Server::new(TcpListener::bind("127.0.0.1:3000"))
+    poem::Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/openapi/combined-apis/src/main.rs

@@ -42,7 +42,7 @@ async fn main() -> Result<(), std::io::Error> {
         .server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/content-type-accept/src/main.rs

@@ -142,7 +142,7 @@ async fn main() -> Result<(), std::io::Error> {
     let ui = api_service.swagger_ui();
     let yaml = api_service.spec_endpoint();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             Route::new()
                 .nest("/api", api_service)

examples/openapi/custom-payload/src/main.rs

@@ -32,7 +32,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Hello World", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/generics/src/main.rs

@@ -36,7 +36,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Hello World", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/hello-world/src/main.rs

@@ -25,7 +25,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Hello World", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/log-with-operation-id/src/main.rs

@@ -35,7 +35,7 @@ async fn main() -> Result<(), std::io::Error> {
             Ok(resp)
         });
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/openapi/poem-extractor/src/main.rs

@@ -22,7 +22,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Poem Extractor", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             Route::new()
                 .nest("/api", api_service.data(100i32))

examples/openapi/poem-middleware/src/main.rs

@@ -26,7 +26,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Poem Middleware", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    poem::Server::new(TcpListener::bind("127.0.0.1:3000"))
+    poem::Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/sse/src/main.rs

@@ -37,7 +37,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api, "Hello World", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/todos/src/main.rs

@@ -158,7 +158,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         .with(Cors::new())
         .data(pool);
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(route)
         .await?;
     Ok(())

examples/openapi/uniform-response/src/main.rs

@@ -104,7 +104,7 @@ async fn main() -> Result<(), std::io::Error> {
     .server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/union/src/main.rs

@@ -41,7 +41,7 @@ async fn main() -> Result<(), std::io::Error> {
     let spec = api_service.spec_endpoint();
     let spec_yaml = api_service.spec_endpoint_yaml();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(
             Route::new()
                 .nest("/api", api_service)

examples/openapi/upload/src/main.rs

@@ -101,7 +101,7 @@ async fn main() -> Result<(), std::io::Error> {
     .server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/openapi/users-crud/src/main.rs

@@ -143,7 +143,7 @@ async fn main() -> Result<(), std::io::Error> {
         OpenApiService::new(Api::default(), "Users", "1.0").server("http://localhost:3000/api");
     let ui = api_service.swagger_ui();
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(Route::new().nest("/api", api_service).nest("/", ui))
         .await
 }

examples/poem/async-graphql/src/main.rs

@@ -39,7 +39,7 @@ async fn main() -> Result<(), std::io::Error> {
 
     println!("Playground: http://localhost:3000");
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/auth/src/main.rs

@@ -105,7 +105,7 @@ async fn main() -> Result<(), std::io::Error> {
         .at("/signin", get(signin_ui).post(signin))
         .at("/logout", get(logout))
         .with(CookieSession::new(CookieConfig::new()));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/basic-auth/src/main.rs

@@ -62,7 +62,7 @@ async fn main() -> Result<(), std::io::Error> {
         username: "test".to_string(),
         password: "123456".to_string(),
     });
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/catch-panic/src/main.rs

@@ -21,7 +21,7 @@ async fn main() -> Result<(), std::io::Error> {
         .at("/", index)
         .with(Tracing)
         .with(CatchPanic::new());
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .name("hello-world")
         .run(app)
         .await

examples/poem/combined-listeners/src/main.rs

@@ -17,8 +17,8 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/", get(hello));
-    let listener = TcpListener::bind("127.0.0.1:3000")
-        .combine(TcpListener::bind("127.0.0.1:3001"))
-        .combine(TcpListener::bind("127.0.0.1:3002"));
+    let listener = TcpListener::bind("0.0.0.0:3000")
+        .combine(TcpListener::bind("0.0.0.0:3001"))
+        .combine(TcpListener::bind("0.0.0.0:3002"));
     Server::new(listener).run(app).await
 }

examples/poem/cookie-session/src/main.rs

@@ -22,7 +22,7 @@ async fn main() -> Result<(), std::io::Error> {
     let app = Route::new()
         .at("/", get(count))
         .with(CookieSession::new(CookieConfig::default().secure(false)));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/csrf/src/main.rs

@@ -60,7 +60,7 @@ async fn main() -> Result<(), std::io::Error> {
     let app = Route::new()
         .at("/", get(login_ui).post(login))
         .with(Csrf::new());
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/custom-error/src/main.rs

@@ -31,7 +31,7 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/", get(hello));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/custom-extractor/src/main.rs

@@ -31,7 +31,7 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/", get(index));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/embed-files/src/main.rs

@@ -19,7 +19,7 @@ async fn main() -> Result<(), std::io::Error> {
     let app = Route::new()
         .at("/", EmbeddedFileEndpoint::<Files>::new("index.html"))
         .nest("/files", EmbeddedFilesEndpoint::<Files>::new());
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/graceful-shutdown/src/main.rs

@@ -45,7 +45,7 @@ async fn main() -> Result<(), std::io::Error> {
 
     let app = Route::new().at("/", get(index)).at("/event", get(event));
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run_with_graceful_shutdown(
             app,
             async move {

examples/poem/handling-404/src/main.rs

@@ -24,7 +24,7 @@ async fn main() -> Result<(), std::io::Error> {
                     .body("haha")
             });
 
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/hello-world/src/main.rs

@@ -15,7 +15,7 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/hello/:name", get(hello)).with(Tracing);
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .name("hello-world")
         .run(app)
         .await

examples/poem/i18n/src/main.rs

@@ -51,7 +51,7 @@ async fn main() -> Result<(), std::io::Error> {
         .at("/welcome_hashmap/:name", get(welcome_hashmap))
         .with(Tracing)
         .data(resources);
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .name("hello-world")
         .run(app)
         .await

examples/poem/json/src/main.rs

@@ -22,7 +22,7 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/hello", post(hello));
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }

examples/poem/middleware/src/main.rs

@@ -50,7 +50,7 @@ async fn main() -> Result<(), std::io::Error> {
     tracing_subscriber::fmt::init();
 
     let app = Route::new().at("/", get(index)).with(Log);
-    Server::new(TcpListener::bind("127.0.0.1:3000"))
+    Server::new(TcpListener::bind("0.0.0.0:3000"))
         .run(app)
         .await
 }