diff --git a/robyn/__init__.py b/robyn/__init__.py index b80716ed..9c564db0 100644 --- a/robyn/__init__.py +++ b/robyn/__init__.py @@ -70,7 +70,7 @@ def __init__( self.web_socket_router = WebSocketRouter() self.request_headers: Headers = Headers({}) self.response_headers: Headers = Headers({}) - self.header_exclude_paths: Optional[List[str]] = None + self.excluded_response_header_paths: Optional[List[str]] = None self.directories: List[Directory] = [] self.event_handlers = {} self.exception_handler: Optional[Callable] = None @@ -201,12 +201,12 @@ def set_request_header(self, key: str, value: str) -> None: def set_response_header(self, key: str, value: str) -> None: self.response_headers.set(key, value) - def exclude_response_headers_for(self, excluded_paths: Optional[List[str]]): + def exclude_response_headers_for(self, excluded_response_header_paths: Optional[List[str]]): """ To exclude response headers from certain routes @param exclude_paths: the paths to exclude response headers from """ - self.excluded_response_header_paths = exclude_paths + self.excluded_response_header_paths = excluded_response_header_paths def add_web_socket(self, endpoint: str, ws: WebSocket) -> None: self.web_socket_router.add_route(endpoint, ws) @@ -293,7 +293,7 @@ def start(self, host: str = "127.0.0.1", port: int = 8080, _check_port: bool = T self.config.workers, self.config.processes, self.response_headers, - self.header_exclude_paths, + self.excluded_response_header_paths, open_browser, ) diff --git a/robyn/processpool.py b/robyn/processpool.py index 9fc9af8c..f09387a7 100644 --- a/robyn/processpool.py +++ b/robyn/processpool.py @@ -27,7 +27,7 @@ def run_processes( workers: int, processes: int, response_headers: Headers, - response_header_exclude_paths: Optional[List[str]], + excluded_response_header_paths: Optional[List[str]], open_browser: bool, ) -> List[Process]: socket = SocketHeld(url, port) @@ -44,7 +44,7 @@ def run_processes( workers, processes, response_headers, - response_header_exclude_paths, + excluded_response_header_paths, ) def terminating_signal_handler(_sig, _frame): @@ -78,7 +78,7 @@ def init_processpool( workers: int, processes: int, response_headers: Headers, - response_header_exclude_paths: Optional[List[str]], + excluded_response_header_paths: Optional[List[str]], ) -> List[Process]: process_pool = [] if sys.platform.startswith("win32") or processes == 1: @@ -149,7 +149,7 @@ def spawn_process( socket: SocketHeld, workers: int, response_headers: Headers, - response_header_exclude_paths: Optional[List[str]], + excluded_response_header_paths: Optional[List[str]], ): """ This function is called by the main process handler to create a server runtime. diff --git a/src/server.rs b/src/server.rs index cf4a8e94..d1cb9a9d 100644 --- a/src/server.rs +++ b/src/server.rs @@ -73,7 +73,7 @@ impl Server { directories: Arc::new(RwLock::new(Vec::new())), startup_handler: None, shutdown_handler: None, - response_header_exclude_paths: None, + excluded_response_header_paths: None, } } @@ -110,7 +110,7 @@ impl Server { let startup_handler = self.startup_handler.clone(); let shutdown_handler = self.shutdown_handler.clone(); - let response_header_exclude_paths = self.response_header_exclude_paths.clone(); + let excluded_response_header_paths = self.excluded_response_header_paths.clone(); let task_locals = pyo3_asyncio::TaskLocals::new(event_loop).copy_context(py)?; let task_locals_copy = task_locals.clone(); @@ -167,7 +167,7 @@ impl Server { .app_data(web::Data::new(middleware_router.clone())) .app_data(web::Data::new(global_request_headers.clone())) .app_data(web::Data::new(global_response_headers.clone())) - .app_data(web::Data::new(response_header_exclude_paths.clone())); + .app_data(web::Data::new(excluded_response_header_paths.clone())); let web_socket_map = web_socket_router.get_web_socket_map(); for (elem, value) in (web_socket_map.read()).iter() { @@ -308,7 +308,7 @@ impl Server { &mut self, excluded_response_header_paths: Option>, ) { - self.response_header_exclude_paths = response_header_exclude_paths; + self.excluded_response_header_paths = excluded_response_header_paths; } /// Add a new route to the routing tables @@ -428,7 +428,7 @@ async fn index( const_router: web::Data>, middleware_router: web::Data>, global_request_response_headers: (web::Data>, web::Data>), - response_header_exclude_paths: web::Data>>, + excluded_response_header_paths: web::Data>>, req: HttpRequest, ) -> impl Responder { let mut request = Request::from_actix_request(&req, payload, &global_request_response_headers.0).await;