update ohkami to v0.17 (#8942)

* update ohkami v0.16 -> v0.17 & refactor some

* Fix: dockerfile

Author: kanarus

frameworks/Rust/ohkami/Cargo.lock

@@ -1,13 +1,13 @@
 [package]
 name    = "ohkami_framework_benchmarks"
-version = "0.15.0"
+version = "0.17.1"
 edition = "2021"
 authors = ["kanarus <[email protected]>"]
 
 [dependencies]
-ohkami       = { version = "=0.16.0", features = ["rt_tokio"] }
+ohkami       = { version = "=0.17.1", features = ["rt_tokio"] }
 tokio        = { version = "1.37.0" , features = ["full"] }
 rand         = { version = "0.8.5"  , features = ["small_rng"] }
 sqlx         = { version = "0.7.4"  , features = ["postgres", "macros", "runtime-tokio-native-tls"] }
 yarte        = { version = "0.15.7" }
-futures-util = { version = "0.3.30" }
+futures-util = { version = "0.3.30" }

frameworks/Rust/ohkami/Cargo.toml

@@ -4,7 +4,7 @@
 
 > Build web app in intuitive and declarative code
 > - *macro-less and type-safe* APIs for intuitive and declarative code
-> - *multi runtime* support：`tokio`, `async-std`
+> - *multi runtime* support：`tokio`, `async-std`, `worker` (Cloudflare Workers)
 
 - [User Guide](https://docs.rs/ohkami/latest/ohkami/)
 - [API Documentation](https://docs.rs/ohkami/latest/ohkami/)

frameworks/Rust/ohkami/README.md

@@ -1,12 +1,11 @@
-FROM rust:1.76-slim-buster
+FROM rust:1.77-slim-buster
 WORKDIR /ohkami_framework_benchmarks
 
 ENV DATABASE_URL=postgres://benchmarkdbuser:benchmarkdbpass@tfb-database/hello_world
 ENV MAX_CONNECTIONS=56
 ENV MIN_CONNECTIONS=56
 
 COPY ./src        ./src
-COPY ./templates  ./templates
 COPY ./Cargo.toml ./Cargo.toml
 COPY ./Cargo.lock ./Cargo.lock
 
@@ -16,4 +15,4 @@ RUN apt update && apt install -y --no-install-recommends \
 
 RUN RUSTFLAGS="-C target-cpu=native" cargo build --release
 EXPOSE 8000
-CMD ./target/release/ohkami_framework_benchmarks
+CMD ./target/release/ohkami_framework_benchmarks

frameworks/Rust/ohkami/ohkami.dockerfile

@@ -0,0 +1,96 @@
+use ohkami::prelude::*;
+use crate::Postgres;
+
+
+#[derive(Clone)]
+pub struct SetServer;
+impl FangAction for SetServer {
+    #[inline(always)]
+    async fn back<'a>(&'a self, res: &'a mut ohkami::Response) {
+        res.headers.set().Server("ohkami");
+    }
+}
+
+#[derive(Clone)]
+pub struct UsePostgres(
+    Postgres
+);
+impl UsePostgres {
+    pub async fn init() -> Self {
+        macro_rules! load_env {
+            ($($name:ident as $t:ty)*) => {$(
+                #[allow(non_snake_case)]
+                let $name = ::std::env::var(stringify!($name))
+                    .expect(concat!(
+                        "Failed to load environment variable ",
+                        "`", stringify!($name), "`"
+                    ))
+                    .parse::<$t>()
+                    .unwrap();
+            )*};
+        } load_env! {
+            MAX_CONNECTIONS as u32
+            MIN_CONNECTIONS as u32
+            DATABASE_URL    as String
+        }
+
+        let pool = sqlx::postgres::PgPoolOptions::new()
+            .max_connections(MAX_CONNECTIONS)
+            .min_connections(MIN_CONNECTIONS)
+            .connect(&DATABASE_URL).await
+            .unwrap();
+
+        Self(pool.into())
+    }
+}
+impl FangAction for UsePostgres {
+    #[inline(always)]
+    async fn fore<'a>(&'a self, req: &'a mut Request) -> Result<(), Response> {
+        Ok(req.memorize(self.0.clone()))
+    }
+}
+
+
+/*
+impl Postgres {
+    pub async fn init() -> impl FangAction {
+        #[derive(Clone)]
+        pub struct UsePostgres(Postgres);
+
+        impl FangAction for UsePostgres {
+            #[inline(always)]
+            async fn fore<'a>(&'a self, req: &'a mut Request) -> Result<(), Response> {
+                req.memorize(self.0.clone());
+                Ok(())
+            }
+        }
+
+        macro_rules! load_env {
+            ($($name:ident as $t:ty)*) => {
+                $(
+                    #[allow(non_snake_case)]
+                    let $name = ::std::env::var(stringify!($name))
+                        .expect(concat!(
+                            "Failed to load environment variable ",
+                            "`", stringify!($name), "`"
+                        ))
+                        .parse::<$t>()
+                        .unwrap();
+                )*
+            };
+        } load_env! {
+            MAX_CONNECTIONS as u32
+            MIN_CONNECTIONS as u32
+            DATABASE_URL    as String
+        }
+
+        UsePostgres(Self(
+            sqlx::postgres::PgPoolOptions::new()
+                .max_connections(MAX_CONNECTIONS)
+                .min_connections(MIN_CONNECTIONS)
+                .connect(&DATABASE_URL).await
+                .unwrap()
+        ))
+    }
+}
+*/