release-time in sitemap is not nullable so we don't have to handle NULL

Author: syphar

.sqlx/query-33fd4ac8d3abdd7d240187e6a834ab8f2384521b036e24ba01501eb7d499e65d.json renamed to .sqlx/query-65b0ead56880b369931c3a5ec324910dde51096de4ee2ad868cc5025161ab466.json

@@ -1,8 +1,8 @@
 use crate::{
-    db::Pool,
     impl_axum_webpage,
     web::{
         error::{AxumNope, AxumResult},
+        extractors::DbConnection,
         file::File,
         MetaData,
     },
@@ -40,14 +40,12 @@ impl_axum_webpage! {
 
 pub(crate) async fn build_details_handler(
     Path((name, version, id)): Path<(String, String, String)>,
-    Extension(pool): Extension<Pool>,
+    mut conn: DbConnection,
     Extension(config): Extension<Arc<Config>>,
     Extension(storage): Extension<Arc<AsyncStorage>>,
 ) -> AxumResult<impl IntoResponse> {
     let id: i32 = id.parse().map_err(|_| AxumNope::BuildNotFound)?;
 
-    let mut conn = pool.get_async().await?;
-
     let row = sqlx::query!(
         "SELECT
              builds.rustc_version,

src/web/build_details.rs

@@ -618,14 +618,7 @@ impl_axum_webpage! {
     ReleaseActivity = "releases/activity.html",
 }
 
-pub(crate) async fn activity_handler(
-    Extension(pool): Extension<Pool>,
-) -> AxumResult<impl IntoResponse> {
-    let mut conn = pool
-        .get_async()
-        .await
-        .context("can't get pool connection")?;
-
+pub(crate) async fn activity_handler(mut conn: DbConnection) -> AxumResult<impl IntoResponse> {
     let rows: Vec<_> = sqlx::query!(
         r#"WITH dates AS (
                -- we need this series so that days in the statistic that don't have any releases are included

src/web/releases.rs

@@ -5,6 +5,7 @@ use crate::{
     utils::{get_config, spawn_blocking, ConfigName},
     web::{
         error::{AxumNope, AxumResult},
+        extractors::DbConnection,
         AxumErrorPage,
     },
     Config,
@@ -56,7 +57,7 @@ impl_axum_webpage! {
 
 pub(crate) async fn sitemap_handler(
     Path(letter): Path<String>,
-    Extension(pool): Extension<Pool>,
+    mut conn: DbConnection,
 ) -> AxumResult<impl IntoResponse> {
     if letter.len() != 1 {
         return Err(AxumNope::ResourceNotFound);
@@ -66,19 +67,17 @@ pub(crate) async fn sitemap_handler(
         }
     }
 
-    let mut conn = pool.get_async().await?;
-
     let releases: Vec<_> = sqlx::query!(
-        "SELECT crates.name,
+        r#"SELECT crates.name,
                 releases.target_name,
-                MAX(releases.release_time) as release_time
+                MAX(releases.release_time) as "release_time!"
          FROM crates
          INNER JOIN releases ON releases.crate_id = crates.id
          WHERE
             rustdoc_status = true AND
             crates.name ILIKE $1
          GROUP BY crates.name, releases.target_name
-         ",
+         "#,
         format!("{letter}%"),
     )
     .fetch(&mut *conn)
@@ -87,15 +86,11 @@ pub(crate) async fn sitemap_handler(
         target_name: row.target_name,
         last_modified: row
             .release_time
-            .map(|release_time| {
-                // On Aug 27 2022 we added `<link rel="canonical">` to all pages,
-                // so they should all get recrawled if they haven't been since then.
-                release_time
-                    .max(Utc.with_ymd_and_hms(2022, 8, 28, 0, 0, 0).unwrap())
-                    .format("%+")
-                    .to_string()
-            })
-            .unwrap_or_default(),
+            // On Aug 27 2022 we added `<link rel="canonical">` to all pages,
+            // so they should all get recrawled if they haven't been since then.
+            .max(Utc.with_ymd_and_hms(2022, 8, 28, 0, 0, 0).unwrap())
+            .format("%+")
+            .to_string(),
     })
     .try_collect()
     .await?;