feature: post_dpop_bytes_with_headers

crates/atproto-client/src/client.rs

···
     Ok(value)
 }
 
+
+pub async fn post_dpop_bytes_with_headers(
+    http_client: &reqwest::Client,
+    dpop_auth: &DPoPAuth,
+    url: &str,
+    payload: Bytes,
+    additional_headers: &HeaderMap,
+) -> Result<serde_json::Value> {
+    let (dpop_proof_token, dpop_proof_header, dpop_proof_claim) = request_dpop(
+        &dpop_auth.dpop_private_key_data,
+        "POST",
+        url,
+        &dpop_auth.oauth_access_token,
+    )
+    .map_err(|error| DPoPError::ProofGenerationFailed { error })?;
+
+    let dpop_retry = DpopRetry::new(
+        dpop_proof_header.clone(),
+        dpop_proof_claim.clone(),
+        dpop_auth.dpop_private_key_data.clone(),
+        true,
+    );
+
+    let dpop_retry_client = ClientBuilder::new(http_client.clone())
+        .with(ChainMiddleware::new(dpop_retry.clone()))
+        .build();
+
+    let http_response = dpop_retry_client
+        .post(url)
+        .headers(additional_headers.clone())
+        .header(
+            "Authorization",
+            &format!("DPoP {}", dpop_auth.oauth_access_token),
+        )
+        .header("DPoP", &dpop_proof_token)
+        .body(payload)
+        .send()
+        .await
+        .map_err(|error| DPoPError::HttpRequestFailed {
+            url: url.to_string(),
+            error,
+        })?;
+
+    let value = http_response
+        .json::<serde_json::Value>()
+        .await
+        .map_err(|error| DPoPError::JsonParseFailed {
+            url: url.to_string(),
+            error,
+        })?;
+
+    Ok(value)
+}
+
 /// Performs an unauthenticated HTTP POST request with JSON body and parses the response as JSON.
 ///
 /// # Arguments