cratefield-runtime-cloudflare 0.1.1

Cloudflare Workers runtime for the Factory Zero harness (workers-rs)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! `RateLimiter` over the Workers Rate Limiting binding. The binding does
//! not expose a retry-after, so `Decision::retry_after` is `None`.

use async_trait::async_trait;
use cratefield_core::{Decision, RateLimitError, RateLimiter};
use worker::RateLimiter as WorkerRateLimiter;

pub struct RateLimitPort(pub WorkerRateLimiter);

#[async_trait]
impl RateLimiter for RateLimitPort {
    async fn limit(&self, key: &str) -> Result<Decision, RateLimitError> {
        let outcome = self
            .0
            .limit(key.to_owned())
            .await
            .map_err(|err| RateLimitError::Transport(err.to_string()))?;
        Ok(Decision {
            ok: outcome.success,
            retry_after: None,
        })
    }
}