Move reqwest middle into its own folder

src/transport/http.rs

@@ -1,11 +1,8 @@
-use async_trait::async_trait;
+use middleware::DefaultHeaderMiddleware;
-use reqwest::{Request, Response};
 use reqwest_middleware::{ClientBuilder, ClientWithMiddleware};
-use reqwest_middleware::{Middleware, Next, Result};
 use reqwest_retry::{policies::ExponentialBackoff, RetryTransientMiddleware};
 use reqwest_tracing::TracingMiddleware;
-
+use crate::transport::middleware;
-pub const USER_AGENT: &str = "osrs-prometheus-exporter";
 
 pub fn new() -> ClientWithMiddleware {
     let retry_policy = ExponentialBackoff::builder().build_with_max_retries(3);
@@ -19,25 +16,3 @@ pub fn new() -> ClientWithMiddleware {
         .with(RetryTransientMiddleware::new_with_policy(retry_policy))
         .build()
 }
-
-struct DefaultHeaderMiddleware {}
-
-impl DefaultHeaderMiddleware {
-    fn new() -> Self {
-        DefaultHeaderMiddleware {}
-    }
-}
-
-#[async_trait]
-impl Middleware for DefaultHeaderMiddleware {
-    async fn handle(
-        &self,
-        mut req: Request,
-        extensions: &mut task_local_extensions::Extensions,
-        next: Next<'_>,
-    ) -> Result<Response> {
-        req.headers_mut()
-            .insert("User-Agent", USER_AGENT.parse().unwrap());
-        next.run(req, extensions).await
-    }
-}

src/transport/middleware/headers.rs

@@ -0,0 +1,28 @@
+use async_trait::async_trait;
+use reqwest::{Request, Response};
+use reqwest_middleware::{Middleware, Next, Result};
+
+pub const USER_AGENT: &str = "osrs-prometheus-exporter";
+
+pub struct DefaultHeaderMiddleware {}
+
+impl DefaultHeaderMiddleware {
+    pub fn new() -> Self {
+        DefaultHeaderMiddleware {}
+    }
+}
+
+#[async_trait]
+impl Middleware for DefaultHeaderMiddleware {
+    async fn handle(
+        &self,
+        mut req: Request,
+        extensions: &mut task_local_extensions::Extensions,
+        next: Next<'_>,
+    ) -> Result<Response> {
+        req.headers_mut()
+            .insert("User-Agent", USER_AGENT.parse().unwrap());
+
+        next.run(req, extensions).await
+    }
+}

src/transport/middleware/mod.rs

@@ -0,0 +1,3 @@
+mod headers;
+
+pub use headers::DefaultHeaderMiddleware;

src/transport/mod.rs

@@ -1 +1,2 @@
+mod middleware;
 pub mod http;