systemprompt_models/config/
rate_limits.rs

1//! Rate limit configuration.
2
3use crate::auth::RateLimitTier;
4use crate::profile::{RateLimitsConfig, TierMultipliers};
5
6#[derive(Debug, Clone, Copy)]
7pub struct RateLimitConfig {
8    pub oauth_public_per_second: u64,
9    pub oauth_auth_per_second: u64,
10    pub contexts_per_second: u64,
11    pub tasks_per_second: u64,
12    pub artifacts_per_second: u64,
13    pub agent_registry_per_second: u64,
14    pub agents_per_second: u64,
15    pub mcp_registry_per_second: u64,
16    pub mcp_per_second: u64,
17    pub stream_per_second: u64,
18    pub content_per_second: u64,
19    pub burst_multiplier: u64,
20    pub disabled: bool,
21    pub tier_multipliers: TierMultipliers,
22}
23
24impl Default for RateLimitConfig {
25    fn default() -> Self {
26        Self {
27            oauth_public_per_second: 10,
28            oauth_auth_per_second: 10,
29            contexts_per_second: 100,
30            tasks_per_second: 50,
31            artifacts_per_second: 50,
32            agent_registry_per_second: 50,
33            agents_per_second: 20,
34            mcp_registry_per_second: 50,
35            mcp_per_second: 200,
36            stream_per_second: 100,
37            content_per_second: 50,
38            burst_multiplier: 3,
39            disabled: false,
40            tier_multipliers: TierMultipliers::default(),
41        }
42    }
43}
44
45impl RateLimitConfig {
46    pub fn production() -> Self {
47        Self::default()
48    }
49
50    pub fn testing() -> Self {
51        Self {
52            oauth_public_per_second: 10000,
53            oauth_auth_per_second: 10000,
54            contexts_per_second: 10000,
55            tasks_per_second: 10000,
56            artifacts_per_second: 10000,
57            agent_registry_per_second: 10000,
58            agents_per_second: 10000,
59            mcp_registry_per_second: 10000,
60            mcp_per_second: 10000,
61            stream_per_second: 10000,
62            content_per_second: 10000,
63            burst_multiplier: 100,
64            disabled: false,
65            tier_multipliers: TierMultipliers::default(),
66        }
67    }
68
69    pub fn disabled() -> Self {
70        let mut config = Self::testing();
71        config.disabled = true;
72        config
73    }
74
75    #[allow(clippy::cast_possible_truncation, clippy::cast_sign_loss)]
76    pub fn effective_limit(&self, base_rate: u64, tier: RateLimitTier) -> u64 {
77        let multiplier = self.tier_multiplier(tier);
78        let effective = (base_rate as f64 * multiplier) as u64;
79        effective.max(1)
80    }
81
82    pub const fn tier_multiplier(&self, tier: RateLimitTier) -> f64 {
83        match tier {
84            RateLimitTier::Admin => self.tier_multipliers.admin,
85            RateLimitTier::User => self.tier_multipliers.user,
86            RateLimitTier::A2a => self.tier_multipliers.a2a,
87            RateLimitTier::Mcp => self.tier_multipliers.mcp,
88            RateLimitTier::Service => self.tier_multipliers.service,
89            RateLimitTier::Anon => self.tier_multipliers.anon,
90        }
91    }
92}
93
94impl From<&RateLimitsConfig> for RateLimitConfig {
95    fn from(config: &RateLimitsConfig) -> Self {
96        Self {
97            oauth_public_per_second: config.oauth_public_per_second,
98            oauth_auth_per_second: config.oauth_auth_per_second,
99            contexts_per_second: config.contexts_per_second,
100            tasks_per_second: config.tasks_per_second,
101            artifacts_per_second: config.artifacts_per_second,
102            agent_registry_per_second: config.agent_registry_per_second,
103            agents_per_second: config.agents_per_second,
104            mcp_registry_per_second: config.mcp_registry_per_second,
105            mcp_per_second: config.mcp_per_second,
106            stream_per_second: config.stream_per_second,
107            content_per_second: config.content_per_second,
108            burst_multiplier: config.burst_multiplier,
109            disabled: config.disabled,
110            tier_multipliers: config.tier_multipliers,
111        }
112    }
113}
systemprompt_models/config/rate_limits.rs

systemprompt_models/config/
rate_limits.rs
