Apply async to tokio task

src/adapter/feed.rs

@@ -25,7 +25,7 @@ pub async fn create(
     }
 
     let proxy = &config.producer.proxy;
-    let html_content = fetch_content(&arg.link, proxy).unwrap();
+    let html_content = fetch_content(&arg.link, proxy).await.unwrap();
     let is_feed = html_content.parse::<SyndicationFeed>().is_ok();
 
     let link = if is_feed {
@@ -36,7 +36,7 @@ pub async fn create(
         return (StatusCode::BAD_REQUEST, Json(false));
     };
 
-    let title = match fetch_feed_title(&link, proxy) {
+    let title = match fetch_feed_title(&link, proxy).await {
         Ok(title) => title,
         Err(_) => return (StatusCode::INTERNAL_SERVER_ERROR, Json(false)),
     };
@@ -49,7 +49,7 @@ pub async fn create(
 
     match feed::create(conn, &arg) {
         Ok(_) => {
-            let _ = create_new_items(conn, proxy);
+            let _ = create_new_items(conn, proxy).await;
             (StatusCode::OK, Json(true))
         }
         Err(_) => (StatusCode::INTERNAL_SERVER_ERROR, Json(false)),

src/serve.rs

@@ -51,20 +51,20 @@ pub async fn serve(app_state: Arc<AppState>, addr: &str) {
         .nest("/", protected)
         .with_state(app_state.clone());
 
-    let listener = tokio::net::TcpListener::bind(addr).await.unwrap();
-    axum::serve(listener, app).await.unwrap();
-
     tokio::spawn(async move {
         let AppState { conn, config, .. } = &*app_state;
 
         loop {
-            let _ = create_new_items(conn, &config.producer.proxy);
+            let _ = create_new_items(conn, &config.producer.proxy).await;
             tokio::time::sleep(std::time::Duration::from_secs(
                 config.producer.polling_frequency,
             ))
             .await;
         }
     });
+
+    let listener = tokio::net::TcpListener::bind(addr).await.unwrap();
+    axum::serve(listener, app).await.unwrap();
 }
 
 async fn authenticate(