from __future__ import annotations

import hiro

from flask_limiter import RateLimitExceeded


def test_static_limit(extension_factory):
    app, limiter = extension_factory()

    @app.route("/t1")
    def t1():
        with limiter.limit("1/second"):
            resp = "ok"
        try:
            with limiter.limit("1/day"):
                resp += "maybe"
        except RateLimitExceeded:
            pass
        return resp

    with hiro.Timeline().freeze() as timeline:
        with app.test_client() as cli:
            response = cli.get("/t1")
            assert 200 == response.status_code
            assert "okmaybe" == response.text
            assert 429 == cli.get("/t1").status_code
            timeline.forward(1)
            response = cli.get("/t1")
            assert 200 == response.status_code
            assert "ok" == response.text


def test_dynamic_limits(extension_factory):
    app, limiter = extension_factory()

    @app.route("/t1")
    def t1():
        with limiter.limit(lambda: "1/second"):
            return "test"

    with hiro.Timeline().freeze():
        with app.test_client() as cli:
            assert 200 == cli.get("/t1").status_code
            assert 429 == cli.get("/t1").status_code


def test_scoped_context_manager(extension_factory):
    app, limiter = extension_factory()

    @app.route("/t1/<int:param>")
    def t1(param: int):
        with limiter.limit("1/second", scope=param):
            return "p1"

    with hiro.Timeline().freeze():
        with app.test_client() as cli:
            assert 200 == cli.get("/t1/1").status_code
            assert 429 == cli.get("/t1/1").status_code
            assert 200 == cli.get("/t1/2").status_code
            assert 429 == cli.get("/t1/2").status_code