use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use super::cachekitio::{reqwest_err_sanitized, CachekitIO};
use super::LockableBackend;
use crate::error::BackendError;
#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
struct LockAcquireRequest {
timeout_ms: u64,
}
#[derive(Deserialize)]
#[serde(rename_all = "camelCase", deny_unknown_fields)]
struct LockAcquireResponse {
lock_id: Option<String>,
}
#[cfg(not(target_arch = "wasm32"))]
#[cfg_attr(not(feature = "unsync"), async_trait)]
#[cfg_attr(feature = "unsync", async_trait(?Send))]
impl LockableBackend for CachekitIO {
async fn acquire_lock(
&self,
key: &str,
timeout_ms: u64,
) -> Result<Option<String>, BackendError> {
let url = format!(
"{}/v1/cache/{}/lock",
self.api_url(),
urlencoding::encode(key)
);
let body = serde_json::to_vec(&LockAcquireRequest { timeout_ms }).map_err(|e| {
BackendError::permanent(format!("failed to serialize lock request: {e}"))
})?;
let req = self.with_standard_headers(
self.client()
.post(&url)
.bearer_auth(self.api_key_str())
.header("Content-Type", "application/json")
.body(body),
);
let resp = req
.send()
.await
.map_err(|e| reqwest_err_sanitized(e, self.api_key_str()))?;
if !resp.status().is_success() {
return Err(self.error_from_response(resp).await);
}
let response: LockAcquireResponse = resp
.json()
.await
.map_err(|e| BackendError::transient(format!("failed to parse lock response: {e}")))?;
Ok(response.lock_id)
}
async fn release_lock(&self, key: &str, lock_id: &str) -> Result<bool, BackendError> {
let url = format!(
"{}/v1/cache/{}/lock?lock_id={}",
self.api_url(),
urlencoding::encode(key),
urlencoding::encode(lock_id),
);
let req =
self.with_standard_headers(self.client().delete(&url).bearer_auth(self.api_key_str()));
let resp = req
.send()
.await
.map_err(|e| reqwest_err_sanitized(e, self.api_key_str()))?;
match resp.status().as_u16() {
200 | 204 => Ok(true),
404 => Ok(false),
_ => Err(self.error_from_response(resp).await),
}
}
}
#[cfg(test)]
mod tests {
use super::*;
fn _assert_lockable(_b: &dyn LockableBackend) {}
#[test]
fn cachekitio_is_lockable() {
fn _check(backend: &CachekitIO) {
_assert_lockable(backend);
}
}
}