From a3ef312a6ad961c5e857a51e9f406563074aa0d3 Mon Sep 17 00:00:00 2001 From: Alphonse Paix Date: Wed, 17 Sep 2025 14:24:45 +0200 Subject: [PATCH] Formatting --- src/idempotency/persistance.rs | 42 +++++++++++++++++----------------- 1 file changed, 21 insertions(+), 21 deletions(-) diff --git a/src/idempotency/persistance.rs b/src/idempotency/persistance.rs index c9701bf..facb520 100644 --- a/src/idempotency/persistance.rs +++ b/src/idempotency/persistance.rs @@ -23,14 +23,14 @@ pub async fn get_saved_response( ) -> Result, anyhow::Error> { let saved_response = sqlx::query!( r#" - SELECT - response_status_code as "response_status_code!", - response_headers as "response_headers!: Vec", - response_body as "response_body!" - FROM idempotency - WHERE - user_id = $1 - AND idempotency_key = $2 + SELECT + response_status_code as "response_status_code!", + response_headers as "response_headers!: Vec", + response_body as "response_body!" + FROM idempotency + WHERE + user_id = $1 + 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 - SET - response_status_code = $3, - response_headers = $4, - response_body = $5 - WHERE - user_id = $1 - AND idempotency_key = $2 - "#, + UPDATE idempotency + SET + response_status_code = $3, + response_headers = $4, + response_body = $5 + WHERE + user_id = $1 + 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) - VALUES ($1, $2, now()) - ON CONFLICT DO NOTHING - "#, + INSERT INTO idempotency (user_id, idempotency_key, created_at) + VALUES ($1, $2, now()) + ON CONFLICT DO NOTHING + "#, user_id, idempotency_key.as_ref() );