chore: reuse app context's http client in conductor obj

src/conductor.rs

@@ -30,11 +30,13 @@ pub struct Conductor {
 }
 
 impl Conductor {
-    pub fn new(settings: Settings) -> Self {
-        Self {
-            client: Client::new(),
-            settings,
-        }
+    pub fn new(settings: Settings, client: Option<Client>) -> Self {
+        let client = if let Some(client) = client {
+            client
+        } else {
+            Client::new()
+        };
+        Self { client, settings }
     }
     async fn tx(&self, e: &EventType) -> ServiceResult<()> {
         for c in self.settings.conductors.iter() {
@@ -79,7 +81,7 @@ mod tests {
     #[actix_rt::test]
     pub async fn test_conductor() {
         let settings = Settings::new().unwrap();
-        let c = Conductor::new(settings.clone());
+        let c = Conductor::new(settings.clone(), None);
         c.delete_site("example.org".into()).await.unwrap();
         let page = Page {
             secret: "foo".into(),

src/ctx/mod.rs

@@ -20,6 +20,7 @@ use std::thread;
 use crate::db::*;
 use crate::settings::Settings;
 use argon2_creds::{Config as ArgonConfig, ConfigBuilder as ArgonConfigBuilder, PasswordPolicy};
+use reqwest::Client;
 use tracing::info;
 
 pub mod api;
@@ -35,6 +36,7 @@ pub struct Ctx {
     pub conductor: Conductor,
     /// credential-procession policy
     pub creds: ArgonConfig,
+    client: Client,
 }
 
 impl Ctx {
@@ -52,7 +54,8 @@ impl Ctx {
     pub async fn new(settings: Settings) -> Arc<Self> {
         let creds = Self::get_creds();
         let c = creds.clone();
-        let conductor = Conductor::new(settings.clone());
+        let client = Client::default();
+        let conductor = Conductor::new(settings.clone(), Some(client.clone()));
 
         #[allow(unused_variables)]
         let init = thread::spawn(move || {
@@ -67,6 +70,7 @@ impl Ctx {
 
         Arc::new(Self {
             settings,
+            client,
             db,
             creds,
             conductor,