fix tests

tests/projects/balancer_app/pages/different_datacenter.py

@@ -7,14 +7,15 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 
 if TYPE_CHECKING:
     from frontik.app import FrontikApplication
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         free_server = get_server(self, 'free')
         free_server.datacenter = 'dc1'
@@ -37,6 +38,7 @@ async def get_page(self):
 
         self.text = result.data
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/different_datacenter_async.py

@@ -3,11 +3,12 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         free_server = get_server(self, 'free')
         free_server.datacenter = 'dc1'
@@ -30,6 +31,7 @@ async def get_page(self):
 
         self.text = result.data
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_available_backend.py

@@ -2,10 +2,12 @@
 from http_client.request_response import NoAvailableServerException
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(Upstream('no_available_backend', {}, []))
 
@@ -20,6 +22,7 @@ async def request_with_processing() -> None:
         self.run_task(request_with_processing())
         check_all_requests_done(self, 'no_available_backend')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_available_backend_async.py

@@ -2,10 +2,12 @@
 from http_client.request_response import NoAvailableServerException
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(Upstream('no_available_backend', {}, []))
 
@@ -22,6 +24,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'no_available_backend')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_retry_error.py

@@ -1,11 +1,13 @@
 from http_client.balancing import Upstream
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(Upstream('no_retry_error', {}, [get_server(self, 'broken')]))
 
@@ -17,6 +19,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'no_retry_error')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_retry_error_async.py

@@ -1,11 +1,13 @@
 from http_client.balancing import Upstream
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('no_retry_error_async', {}, [get_server(self, 'broken')]),
@@ -20,6 +22,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'no_retry_error_async')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_retry_timeout.py

@@ -3,11 +3,13 @@
 from http_client.balancing import Upstream
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('no_retry_timeout', {}, [get_server(self, 'broken')]),
@@ -21,6 +23,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'no_retry_timeout')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/no_retry_timeout_async.py

@@ -3,11 +3,13 @@
 from http_client.balancing import Upstream, UpstreamConfig
 
 from frontik import handler, media_types
+from frontik.handler import router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done
 
 
 class Page(handler.PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.upstreams['no_retry_timeout_async'] = Upstream(
             'no_retry_timeout_async',
@@ -33,6 +35,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'no_retry_timeout_async')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/profile_with_retry.py

@@ -2,11 +2,12 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         servers = [get_server(self, 'broken'), get_server(self, 'normal')]
         upstream_config = {
@@ -27,6 +28,7 @@ async def get_page(self):
 
         self.text = result.data
 
+    @router.put()
     async def put_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/profile_without_retry.py

@@ -1,11 +1,12 @@
 from http_client.balancing import Upstream, UpstreamConfig
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         servers = [get_server(self, 'broken'), get_server(self, 'normal')]
         upstream_config = {
@@ -26,6 +27,7 @@ async def get_page(self):
 
         self.text = result.data
 
+    @router.put()
     async def put_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/requests_count.py

@@ -3,12 +3,13 @@
 from http_client.balancing import Upstream
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done, check_all_servers_were_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(Upstream('requests_count', {}, [get_server(self, 'normal')]))
         self.text = ''
@@ -28,6 +29,7 @@ async def request_with_processing() -> None:
         await asyncio.sleep(0.1)
         check_all_servers_were_occupied(self, 'requests_count')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = str(self.application.upstream_manager.upstreams['requests_count'].servers[0].stat_requests)

tests/projects/balancer_app/pages/requests_count_async.py

@@ -3,12 +3,13 @@
 from http_client.balancing import Upstream
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_requests_done, check_all_servers_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('requests_count_async', {}, [get_server(self, 'normal')]),
@@ -32,6 +33,7 @@ async def get_page(self):
 
         check_all_requests_done(self, 'requests_count_async')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         servers = self.application.upstream_manager.upstreams['requests_count_async'].servers

tests/projects/balancer_app/pages/retry_connect.py

@@ -2,13 +2,14 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from frontik.util import gather_list
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_servers_were_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('retry_connect', {}, [get_server(self, 'free'), get_server(self, 'normal')]),
@@ -30,6 +31,7 @@ async def get_page(self):
 
             self.text = self.text + result.data
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/retry_connect_async.py

@@ -4,12 +4,13 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_servers_were_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('retry_connect_async', {}, [get_server(self, 'free'), get_server(self, 'normal')]),
@@ -36,6 +37,7 @@ async def make_request() -> None:
 
         check_all_servers_were_occupied(self, 'retry_connect_async')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/retry_connect_timeout.py

@@ -2,13 +2,14 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from frontik.util import gather_list
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_servers_were_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('retry_connect_timeout', {}, [get_server(self, 'normal')]),
@@ -30,6 +31,7 @@ async def get_page(self):
 
             self.text = self.text + result.data
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/retry_connect_timeout_async.py

@@ -4,12 +4,13 @@
 from tornado.web import HTTPError
 
 from frontik import media_types
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.projects.balancer_app import get_server
 from tests.projects.balancer_app.pages import check_all_servers_were_occupied
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         self.application.upstream_manager.update_upstream(
             Upstream('retry_connect_timeout', {}, [get_server(self, 'normal')]),
@@ -36,6 +37,7 @@ async def make_request() -> None:
 
         check_all_servers_were_occupied(self, 'retry_connect_timeout')
 
+    @router.post()
     async def post_page(self):
         self.add_header('Content-Type', media_types.TEXT_PLAIN)
         self.text = 'result'

tests/projects/balancer_app/pages/retry_count_limit.py

@@ -1,11 +1,12 @@
 from http_client.balancing import Upstream, UpstreamConfig
 
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.instances import find_free_port
 from tests.projects.balancer_app import get_server_with_port
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         upstream = Upstream(
             'retry_count_limit',

tests/projects/balancer_app/pages/retry_count_limit_async.py

@@ -1,11 +1,12 @@
 from http_client.balancing import Upstream, UpstreamConfig
 
-from frontik.handler import PageHandler
+from frontik.handler import PageHandler, router
 from tests.instances import find_free_port
 from tests.projects.balancer_app import get_server_with_port
 
 
 class Page(PageHandler):
+    @router.get()
     async def get_page(self):
         upstream = Upstream(
             'retry_count_limit_async',