mirrors/discord.py
1
0
Fork 0
mirror of https://github.com/Rapptz/discord.py.git synced 2025-04-16 06:03:11 +00:00
Code Issues Projects Releases Wiki Activity

[commands] Allow subtracting multiple tokens from cooldown

Browse Source
This commit is contained in:
Florian Spieß 2022-04-21 18:23:20 +02:00 committed by GitHub
parent 832d2c0542
commit 0e5c4c391d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
discord/app_commands/checks.py
View File

@ -112,7 +112,8 @@ class Cooldown:
if not current:
current = time.time()
tokens = self._tokens
# the calculated tokens should be non-negative
tokens = max(self._tokens, 0)
if current > self._window + self.per:
tokens = self.rate
@ -140,7 +141,7 @@ class Cooldown:
return 0.0
def update_rate_limit(self, current: Optional[float] = None) -> Optional[float]:
def update_rate_limit(self, current: Optional[float] = None, *, tokens: int = 1) -> Optional[float]:
"""Updates the cooldown rate limit.
Parameters
@ -148,6 +149,8 @@ class Cooldown:
current: Optional[:class:`float`]
The time in seconds since Unix epoch to update the rate limit at.
If not supplied, then :func:`time.time()` is used.
tokens: :class:`int`
The amount of tokens to deduct from the rate limit.
Returns
-------
@ -163,12 +166,12 @@ class Cooldown:
if self._tokens == self.rate:
self._window = current
# check if we are rate limited
if self._tokens == 0:
return self.per - (current - self._window)
# decrement tokens by specified number
self._tokens -= tokens
# we're not so decrement our tokens
self._tokens -= 1
# check if we are rate limited and return retry-after
if self._tokens < 0:
return self.per - (current - self._window)
def reset(self) -> None:
"""Reset the cooldown to its initial state."""

4
discord/ext/commands/cooldowns.py
View File

@ -140,9 +140,9 @@ class CooldownMapping:
return bucket
def update_rate_limit(self, message: Message, current: Optional[float] = None) -> Optional[float]:
def update_rate_limit(self, message: Message, current: Optional[float] = None, tokens: int = 1) -> Optional[float]:
bucket = self.get_bucket(message, current)
return bucket.update_rate_limit(current)
return bucket.update_rate_limit(current, tokens=tokens)
class DynamicCooldownMapping(CooldownMapping):