velvox
/
litecord
mirror of https://gitlab.com/litecord/litecord.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

run: add support for x-ratelimit-precision header

This commit is contained in:
Luna 2019-08-13 12:24:03 -03:00
parent b8a4125482
commit c10806e0de
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
run.py
View File

@ -194,6 +194,21 @@ async def app_after_request(resp):
return resp return resp
def _set_rtl_reset(bucket, resp):
reset = bucket._window + bucket.second
precision = request.headers.get('x-ratelimit-precision', 'second')
if precision == 'second':
resp.headers['X-RateLimit-Reset'] = str(round(reset))
elif precision == 'millisecond':
resp.headers['X-RateLimit-Reset'] = str(reset)
else:
resp.headers['X-RateLimit-Reset'] = (
'Invalid X-RateLimit-Precision, '
'valid options are (second, millisecond)'
)
@app.after_request @app.after_request
async def app_set_ratelimit_headers(resp): async def app_set_ratelimit_headers(resp):
"""Set the specific ratelimit headers.""" """Set the specific ratelimit headers."""
@ -205,9 +220,8 @@ async def app_set_ratelimit_headers(resp):
resp.headers['X-RateLimit-Limit'] = str(bucket.requests) resp.headers['X-RateLimit-Limit'] = str(bucket.requests)
resp.headers['X-RateLimit-Remaining'] = str(bucket._tokens) resp.headers['X-RateLimit-Remaining'] = str(bucket._tokens)
resp.headers['X-RateLimit-Reset'] = str(bucket._window + bucket.second)
resp.headers['X-RateLimit-Global'] = str(request.bucket_global).lower() resp.headers['X-RateLimit-Global'] = str(request.bucket_global).lower()
_set_rtl_reset(bucket, resp)
# only add Retry-After if we actually hit a ratelimit # only add Retry-After if we actually hit a ratelimit
retry_after = request.retry_after retry_after = request.retry_after