Formatting

src/idempotency/persistance.rs

@@ -23,14 +23,14 @@ pub async fn get_saved_response(
 ) -> Result<Option<Response>, anyhow::Error> {
     let saved_response = sqlx::query!(
         r#"
-            SELECT
+        SELECT
-                response_status_code as "response_status_code!",
+            response_status_code as "response_status_code!",
-                response_headers as "response_headers!: Vec<HeaderPairRecord>",
+            response_headers as "response_headers!: Vec<HeaderPairRecord>",
-                response_body as "response_body!"
+            response_body as "response_body!"
-            FROM idempotency
+        FROM idempotency
-            WHERE
+        WHERE
-                user_id = $1
+            user_id = $1
-                AND idempotency_key = $2
+            AND idempotency_key = $2
         "#,
         user_id,
         idempotency_key.as_ref()
@@ -73,15 +73,15 @@ pub async fn save_response(
 
     let query = sqlx::query_unchecked!(
         r#"
-            UPDATE idempotency
+        UPDATE idempotency
-            SET
+        SET
-                response_status_code = $3,
+            response_status_code = $3,
-                response_headers = $4,
+            response_headers = $4,
-                response_body = $5
+            response_body = $5
-            WHERE
+        WHERE
-                user_id = $1
+            user_id = $1
-                AND idempotency_key = $2
+            AND idempotency_key = $2
-            "#,
+        "#,
         user_id,
         idempotency_key.as_ref(),
         status_code,
@@ -109,10 +109,10 @@ pub async fn try_processing(
     let mut transaction = connection_pool.begin().await?;
     let query = sqlx::query!(
         r#"
-            INSERT INTO idempotency (user_id, idempotency_key, created_at)
+        INSERT INTO idempotency (user_id, idempotency_key, created_at)
-            VALUES ($1, $2, now())
+        VALUES ($1, $2, now())
-            ON CONFLICT DO NOTHING
+        ON CONFLICT DO NOTHING
-            "#,
+        "#,
         user_id,
         idempotency_key.as_ref()
     );