Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
ray / purelib / ray / serve / tests / test_http_prefix_matching.py
Size: Mime:
import pytest

from ray.serve._private.common import EndpointInfo
from ray.serve._private.http_proxy import LongestPrefixRouter


@pytest.fixture
def mock_longest_prefix_router() -> LongestPrefixRouter:
    def mock_get_handle(name, *args, **kwargs):
        return name

    yield LongestPrefixRouter(mock_get_handle)


def test_no_match(mock_longest_prefix_router):
    router = mock_longest_prefix_router
    router.update_routes({"endpoint": EndpointInfo(route="/hello")})
    route, handle = router.match_route("/nonexistent")
    assert route is None and handle is None


def test_default_route(mock_longest_prefix_router):
    router = mock_longest_prefix_router
    router.update_routes({"endpoint": EndpointInfo(route="/endpoint")})

    route, handle = router.match_route("/nonexistent")
    assert route is None and handle is None

    route, handle = router.match_route("/endpoint")
    assert route == "/endpoint" and handle == "endpoint"


def test_trailing_slash(mock_longest_prefix_router):
    router = mock_longest_prefix_router
    router.update_routes(
        {
            "endpoint": EndpointInfo(route="/test"),
        }
    )

    route, handle = router.match_route("/test/")
    assert route == "/test" and handle == "endpoint"

    router.update_routes(
        {
            "endpoint": EndpointInfo(route="/test/"),
        }
    )

    route, handle = router.match_route("/test")
    assert route is None and handle is None


def test_prefix_match(mock_longest_prefix_router):
    router = mock_longest_prefix_router
    router.update_routes(
        {
            "endpoint1": EndpointInfo(route="/test/test2"),
            "endpoint2": EndpointInfo(route="/test"),
            "endpoint3": EndpointInfo(route="/"),
        }
    )

    route, handle = router.match_route("/test/test2/subpath")
    assert route == "/test/test2" and handle == "endpoint1"
    route, handle = router.match_route("/test/test2/")
    assert route == "/test/test2" and handle == "endpoint1"
    route, handle = router.match_route("/test/test2")
    assert route == "/test/test2" and handle == "endpoint1"

    route, handle = router.match_route("/test/subpath")
    assert route == "/test" and handle == "endpoint2"
    route, handle = router.match_route("/test/")
    assert route == "/test" and handle == "endpoint2"
    route, handle = router.match_route("/test")
    assert route == "/test" and handle == "endpoint2"

    route, handle = router.match_route("/test2")
    assert route == "/" and handle == "endpoint3"
    route, handle = router.match_route("/")
    assert route == "/" and handle == "endpoint3"


def test_update_routes(mock_longest_prefix_router):
    router = mock_longest_prefix_router
    router.update_routes({"endpoint": EndpointInfo(route="/endpoint")})

    route, handle = router.match_route("/endpoint")
    assert route == "/endpoint" and handle == "endpoint"

    router.update_routes({"endpoint2": EndpointInfo(route="/endpoint2")})

    route, handle = router.match_route("/endpoint")
    assert route is None and handle is None

    route, handle = router.match_route("/endpoint2")
    assert route == "/endpoint2" and handle == "endpoint2"


if __name__ == "__main__":
    import sys

    sys.exit(pytest.main(["-v", "-s", __file__]))