wip pyo3 migration

Author: VishnuSanal

src/server.rs

@@ -106,14 +106,14 @@ impl Server {
 
         let asyncio = py.import("asyncio")?;
         let event_loop = asyncio.call_method0("new_event_loop")?;
-        asyncio.call_method1("set_event_loop", (event_loop,))?;
+        asyncio.call_method1("set_event_loop", (event_loop.clone(),))?;
 
         let startup_handler = self.startup_handler.clone();
         let shutdown_handler = self.shutdown_handler.clone();
 
         let excluded_response_headers_paths = self.excluded_response_headers_paths.clone();
 
-        let task_locals = pyo3_async_runtimes::TaskLocals::new(event_loop).copy_context(py)?;
+        let task_locals = pyo3_async_runtimes::TaskLocals::new(event_loop.clone()).copy_context(py)?;
         let task_locals_copy = task_locals.clone_ref(py);
 
         let max_payload_size = env::var(MAX_PAYLOAD_SIZE)
@@ -136,7 +136,7 @@ impl Server {
                 HttpServer::new(move || {
                     let mut app = App::new();
 
-                    let task_locals = task_locals_copy.clone_ref(py);
+                    let task_locals = task_locals_copy.clone();
                     let directories = directories.read().unwrap();
 
                     // this loop matches three types of directory serving
@@ -174,7 +174,7 @@ impl Server {
                     for (elem, value) in (web_socket_map.read()).iter() {
                         let endpoint = elem.clone();
                         let path_params = value.clone();
-                        let task_locals = task_locals.clone_ref(py);
+                        let task_locals = task_locals.clone();
                         app = app.route(
                             &endpoint.clone(),
                             web::get().to(move |stream: web::Payload, req: HttpRequest| {
@@ -183,7 +183,7 @@ impl Server {
                                     req,
                                     stream,
                                     path_params.clone(),
-                                    task_locals.clone_ref(py),
+                                    task_locals.clone(),
                                     endpoint_copy,
                                 )
                             }),
@@ -202,7 +202,7 @@ impl Server {
                                   global_response_headers,
                                   response_headers_exclude_paths,
                                   req| {
-                                pyo3_async_runtimes::tokio::scope_local(task_locals.clone_ref(py), async move {
+                                pyo3_async_runtimes::tokio::scope_local(task_locals.clone(), async move {
                                     index(
                                         router,
                                         payload,