cleanup and add new test

Author: SergioBenitez

core/lib/tests/drop-in-async-context.rs

@@ -1,45 +1,41 @@
 #[macro_use]
 extern crate rocket;
 
-use rocket::figment::{providers::{Format as _, Toml}, Figment};
-use rocket::{custom, fairing::AdHoc, Build, Orbit, Rocket};
+use rocket::{Build, Config, Rocket};
+use rocket::fairing::AdHoc;
+use rocket::figment::Figment;
 
 struct AsyncDropInAsync;
 
 impl Drop for AsyncDropInAsync {
     fn drop(&mut self) {
-        // Attempt to fetch the current runtime while dropping
-        // Pools in rocket_sync_db_pools (and maybe rocket_db_pools)
-        // do use this capability. They spawn tasks to asyncronously
-        // complete shutdown of the pool, which triggers the same panic.
+        // Ensure that managed state is dropped inside of an async context by
+        // ensuring that we do not panic when fetching the current runtime.
+        //
+        // Crates like rocket_sync_db_pools spawn tasks to asynchronously
+        // complete pool shutdown which must be done in an async context or else
+        // the spawn will panic. We want to ensure that does not happen.
         let _ = rocket::tokio::runtime::Handle::current();
     }
 }
 
 fn rocket() -> Rocket<Build> {
-    let mut config = rocket::Config::default();
-    #[cfg(feature = "secrets")]
-    { config.secret_key = rocket::config::SecretKey::generate().unwrap(); }
-    let figment = Figment::from(config).merge(Toml::string(r#"
-[default]
-address = "tcp:127.0.0.1:0"
-port = 0
-"#).nested());
-    custom(figment).manage(AsyncDropInAsync).attach(AdHoc::on_liftoff(
-        "Shutdown immediately",
-        |rocket: &Rocket<Orbit>| {
-            Box::pin(async {
-                rocket.shutdown().notify();
-            })
-        },
-    ))
+    let figment = Figment::from(Config::debug_default())
+        .merge(("address", "tcp:127.0.0.1:0"));
+
+    rocket::custom(figment)
+        .manage(AsyncDropInAsync)
+        .attach(AdHoc::on_liftoff("Shutdown", |rocket| Box::pin(async {
+            rocket.shutdown().notify();
+        })))
 }
 
 mod launch {
     #[launch]
     fn launch() -> _ {
         super::rocket()
     }
+
     #[test]
     fn test_launch() {
         main();
@@ -49,22 +45,25 @@ mod launch {
 mod main {
     #[rocket::main]
     async fn main() {
-        super::rocket()
-            .launch()
-            .await
-            .unwrap();
+        super::rocket().launch().await.unwrap();
     }
+
     #[test]
     fn test_main() {
         main();
     }
+
     #[test]
     fn test_execute() {
         rocket::execute(async {
-            super::rocket()
-                .launch()
-                .await
-                .unwrap();
+            super::rocket().launch().await.unwrap();
+        });
+    }
+
+    #[test]
+    fn test_execute_directly() {
+        rocket::execute(async {
+            rocket::execute(super::rocket().launch()).unwrap();
         });
     }
 }