refactor: remove absolute imports (#107)

README.md

@@ -18,10 +18,10 @@ Using this library, you can host your application and query against it with requ
 Then decode the responses, and assert what is returned.
 
 ```rust
-  use ::axum::Router;
-  use ::axum::routing::get;
+  use axum::Router;
+  use axum::routing::get;
 
-  use ::axum_test::TestServer;
+  use axum_test::TestServer;
 
   async fn get_ping() -> &'static str {
       "pong!"

examples/example-shuttle/main.rs

@@ -16,29 +16,29 @@
 //! At the bottom of this file are a series of tests for these endpoints.
 //!
 
-use ::anyhow::anyhow;
-use ::anyhow::Result;
-use ::axum::extract::Json;
-use ::axum::extract::State;
-use ::axum::routing::get;
-use ::axum::routing::post;
-use ::axum::routing::put;
-use ::axum::Router;
-use ::axum_extra::extract::cookie::Cookie;
-use ::axum_extra::extract::cookie::CookieJar;
-use ::http::StatusCode;
-use ::serde::Deserialize;
-use ::serde::Serialize;
-use ::serde_email::Email;
-use ::std::collections::HashMap;
-use ::std::result::Result as StdResult;
-use ::std::sync::Arc;
-use ::std::sync::RwLock;
+use anyhow::anyhow;
+use anyhow::Result;
+use axum::extract::Json;
+use axum::extract::State;
+use axum::routing::get;
+use axum::routing::post;
+use axum::routing::put;
+use axum::Router;
+use axum_extra::extract::cookie::Cookie;
+use axum_extra::extract::cookie::CookieJar;
+use http::StatusCode;
+use serde::Deserialize;
+use serde::Serialize;
+use serde_email::Email;
+use std::collections::HashMap;
+use std::result::Result as StdResult;
+use std::sync::Arc;
+use std::sync::RwLock;
 
 #[cfg(test)]
-use ::axum_test::TestServer;
+use axum_test::TestServer;
 #[cfg(test)]
-use ::axum_test::TestServerConfig;
+use axum_test::TestServerConfig;
 
 /// Main to start Shuttle application
 #[shuttle_runtime::main]
@@ -166,7 +166,7 @@ pub async fn route_get_user_todos(
 mod test_post_login {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_create_session_on_login() {
@@ -205,7 +205,7 @@ mod test_post_login {
 mod test_route_put_user_todos {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_not_store_todos_without_login() {
@@ -260,7 +260,7 @@ mod test_route_put_user_todos {
 mod test_route_get_user_todos {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_not_return_todos_if_logged_out() {

examples/example-todo/main.rs

@@ -15,34 +15,34 @@
 //! At the bottom of this file are a series of tests for these endpoints.
 //!
 
-use ::anyhow::anyhow;
-use ::anyhow::Result;
-use ::axum::extract::Json;
-use ::axum::extract::State;
-use ::axum::routing::get;
-use ::axum::routing::post;
-use ::axum::routing::put;
-use ::axum::serve::serve;
-use ::axum::Router;
-use ::axum_extra::extract::cookie::Cookie;
-use ::axum_extra::extract::cookie::CookieJar;
-use ::http::StatusCode;
-use ::serde::Deserialize;
-use ::serde::Serialize;
-use ::serde_email::Email;
-use ::std::collections::HashMap;
-use ::std::net::IpAddr;
-use ::std::net::Ipv4Addr;
-use ::std::net::SocketAddr;
-use ::std::result::Result as StdResult;
-use ::std::sync::Arc;
-use ::std::sync::RwLock;
-use ::tokio::net::TcpListener;
+use anyhow::anyhow;
+use anyhow::Result;
+use axum::extract::Json;
+use axum::extract::State;
+use axum::routing::get;
+use axum::routing::post;
+use axum::routing::put;
+use axum::serve::serve;
+use axum::Router;
+use axum_extra::extract::cookie::Cookie;
+use axum_extra::extract::cookie::CookieJar;
+use http::StatusCode;
+use serde::Deserialize;
+use serde::Serialize;
+use serde_email::Email;
+use std::collections::HashMap;
+use std::net::IpAddr;
+use std::net::Ipv4Addr;
+use std::net::SocketAddr;
+use std::result::Result as StdResult;
+use std::sync::Arc;
+use std::sync::RwLock;
+use tokio::net::TcpListener;
 
 #[cfg(test)]
-use ::axum_test::TestServer;
+use axum_test::TestServer;
 #[cfg(test)]
-use ::axum_test::TestServerConfig;
+use axum_test::TestServerConfig;
 
 const PORT: u16 = 8080;
 const USER_ID_COOKIE_NAME: &'static str = &"example-todo-user-id";
@@ -182,7 +182,7 @@ fn new_test_app() -> TestServer {
 mod test_post_login {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_create_session_on_login() {
@@ -221,7 +221,7 @@ mod test_post_login {
 mod test_route_put_user_todos {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_not_store_todos_without_login() {
@@ -276,7 +276,7 @@ mod test_route_put_user_todos {
 mod test_route_get_user_todos {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_not_return_todos_if_logged_out() {

examples/example-websocket-chat/main.rs

@@ -9,33 +9,33 @@
 //! ```
 //!
 
-use ::anyhow::Result;
-use ::axum::extract::ws::Message;
-use ::axum::extract::ws::WebSocket;
-use ::axum::extract::Path;
-use ::axum::extract::State;
-use ::axum::extract::WebSocketUpgrade;
-use ::axum::response::Response;
-use ::axum::routing::get;
-use ::axum::serve::serve;
-use ::axum::Router;
-use ::futures_util::SinkExt;
-use ::futures_util::StreamExt;
-use ::serde::Deserialize;
-use ::serde::Serialize;
-use ::std::collections::HashMap;
-use ::std::net::IpAddr;
-use ::std::net::Ipv4Addr;
-use ::std::net::SocketAddr;
-use ::std::sync::Arc;
-use ::std::time::Duration;
-use ::tokio::net::TcpListener;
-use ::tokio::sync::RwLock;
+use anyhow::Result;
+use axum::extract::ws::Message;
+use axum::extract::ws::WebSocket;
+use axum::extract::Path;
+use axum::extract::State;
+use axum::extract::WebSocketUpgrade;
+use axum::response::Response;
+use axum::routing::get;
+use axum::serve::serve;
+use axum::Router;
+use futures_util::SinkExt;
+use futures_util::StreamExt;
+use serde::Deserialize;
+use serde::Serialize;
+use std::collections::HashMap;
+use std::net::IpAddr;
+use std::net::Ipv4Addr;
+use std::net::SocketAddr;
+use std::sync::Arc;
+use std::time::Duration;
+use tokio::net::TcpListener;
+use tokio::sync::RwLock;
 
 #[cfg(test)]
-use ::axum_test::TestServer;
+use axum_test::TestServer;
 #[cfg(test)]
-use ::axum_test::TestServerConfig;
+use axum_test::TestServerConfig;
 
 const PORT: u16 = 8080;
 

examples/example-websocket-ping-pong/main.rs

@@ -10,22 +10,22 @@
 //! ```
 //!
 
-use ::anyhow::Result;
-use ::axum::extract::ws::WebSocket;
-use ::axum::extract::WebSocketUpgrade;
-use ::axum::response::Response;
-use ::axum::routing::get;
-use ::axum::serve::serve;
-use ::axum::Router;
-use ::std::net::IpAddr;
-use ::std::net::Ipv4Addr;
-use ::std::net::SocketAddr;
-use ::tokio::net::TcpListener;
+use anyhow::Result;
+use axum::extract::ws::WebSocket;
+use axum::extract::WebSocketUpgrade;
+use axum::response::Response;
+use axum::routing::get;
+use axum::serve::serve;
+use axum::Router;
+use std::net::IpAddr;
+use std::net::Ipv4Addr;
+use std::net::SocketAddr;
+use tokio::net::TcpListener;
 
 #[cfg(test)]
-use ::axum_test::TestServer;
+use axum_test::TestServer;
 #[cfg(test)]
-use ::axum_test::TestServerConfig;
+use axum_test::TestServerConfig;
 
 const PORT: u16 = 8080;
 
@@ -86,7 +86,7 @@ fn new_test_app() -> TestServer {
 mod test_websockets_ping_pong {
     use super::*;
 
-    use ::serde_json::json;
+    use serde_json::json;
 
     #[tokio::test]
     async fn it_should_start_a_websocket_connection() {

src/internals/query_params_store.rs

@@ -1,9 +1,9 @@
-use ::anyhow::Result;
-use ::serde::Serialize;
-use ::smallvec::SmallVec;
-use ::std::fmt::Display;
-use ::std::fmt::Formatter;
-use ::std::fmt::Result as FmtResult;
+use anyhow::Result;
+use serde::Serialize;
+use smallvec::SmallVec;
+use std::fmt::Display;
+use std::fmt::Formatter;
+use std::fmt::Result as FmtResult;
 
 #[derive(Clone, Debug, PartialEq)]
 pub struct QueryParamsStore {

src/internals/request_path_formatter.rs

@@ -1,5 +1,5 @@
-use ::http::Method;
-use ::std::fmt;
+use http::Method;
+use std::fmt;
 
 use crate::internals::QueryParamsStore;
 

src/internals/starting_tcp_setup.rs

@@ -1,11 +1,11 @@
-use ::anyhow::Context;
-use ::anyhow::Result;
-use ::reserve_port::ReservedPort;
-use ::std::net::IpAddr;
-use ::std::net::Ipv4Addr;
-use ::std::net::SocketAddr;
-use ::std::net::TcpListener as StdTcpListener;
-use ::tokio::net::TcpListener as TokioTcpListener;
+use anyhow::Context;
+use anyhow::Result;
+use reserve_port::ReservedPort;
+use std::net::IpAddr;
+use std::net::Ipv4Addr;
+use std::net::SocketAddr;
+use std::net::TcpListener as StdTcpListener;
+use tokio::net::TcpListener as TokioTcpListener;
 
 pub const DEFAULT_IP_ADDRESS: IpAddr = IpAddr::V4(Ipv4Addr::LOCALHOST);
 
@@ -56,8 +56,8 @@ impl StartingTcpSetup {
 #[cfg(test)]
 mod test_new {
     use super::*;
-    use ::regex::Regex;
-    use ::std::net::Ipv4Addr;
+    use regex::Regex;
+    use std::net::Ipv4Addr;
 
     #[tokio::test]
     async fn it_should_create_default_ip_with_random_port_when_none() {

src/internals/status_code_formatter.rs

@@ -1,5 +1,5 @@
-use ::http::StatusCode;
-use ::std::fmt;
+use http::StatusCode;
+use std::fmt;
 
 #[derive(Debug, Copy, Clone, PartialEq)]
 pub struct StatusCodeFormatter(pub StatusCode);

src/internals/transport_layer/http_transport_layer.rs

@@ -1,12 +1,12 @@
-use ::anyhow::Result;
-use ::axum::body::Body;
-use ::http::Request;
-use ::http::Response;
-use ::hyper_util::client::legacy::Client;
-use ::reserve_port::ReservedPort;
-use ::std::future::Future;
-use ::std::pin::Pin;
-use ::url::Url;
+use anyhow::Result;
+use axum::body::Body;
+use http::Request;
+use http::Response;
+use hyper_util::client::legacy::Client;
+use reserve_port::ReservedPort;
+use std::future::Future;
+use std::pin::Pin;
+use url::Url;
 
 use crate::transport_layer::TransportLayer;
 use crate::transport_layer::TransportLayerType;

src/internals/transport_layer/mock_transport_layer.rs

@@ -1,15 +1,15 @@
-use ::anyhow::Error as AnyhowError;
-use ::anyhow::Result;
-use ::axum::body::Body;
-use ::axum::response::Response as AxumResponse;
-use ::bytes::Bytes;
-use ::http::Request;
-use ::http::Response;
-use ::std::fmt::Debug;
-use ::std::future::Future;
-use ::std::pin::Pin;
-use ::tower::util::ServiceExt;
-use ::tower::Service;
+use anyhow::Error as AnyhowError;
+use anyhow::Result;
+use axum::body::Body;
+use axum::response::Response as AxumResponse;
+use bytes::Bytes;
+use http::Request;
+use http::Response;
+use std::fmt::Debug;
+use std::future::Future;
+use std::pin::Pin;
+use tower::util::ServiceExt;
+use tower::Service;
 
 use crate::transport_layer::TransportLayer;
 use crate::transport_layer::TransportLayerType;

src/internals/websockets/test_response_websocket.rs

@@ -1,4 +1,4 @@
-use ::hyper::upgrade::OnUpgrade;
+use hyper::upgrade::OnUpgrade;
 
 use crate::transport_layer::TransportLayerType;