chore: big reformatting

Author: d-biehl

robotcode/debugger/__main__.py

@@ -26,7 +26,6 @@
     __file__ = __file__[:-1]
 
 if __name__ == "__main__" and __package__ is None or __package__ == "":
-
     file = Path(__file__).resolve()
     parent, top = file.parent, file.parents[2]
 
@@ -114,7 +113,6 @@ async def start_debugpy_async(
         global config_done_callback
 
         def connect_debugpy(server: "DebugAdapterServer") -> None:
-
             server.protocol.send_event(Event(event="debugpyStarted", body={"port": port, "addresses": addresses}))
 
             if wait_for_debugpy_client:
@@ -206,7 +204,6 @@ async def run_robot(
 
         exit_code = -1
         try:
-
             exit_code = robot.run_cli(args, False)
         finally:
             if server.protocol.connected:

robotcode/debugger/debugger.py

@@ -424,7 +424,6 @@ def set_breakpoints(
         lines: Optional[List[int]] = None,
         source_modified: Optional[bool] = None,
     ) -> List[Breakpoint]:
-
         if self.is_windows_path(source.path or ""):
             path: pathlib.PurePath = pathlib.PureWindowsPath(source.path or "")
         else:
@@ -930,7 +929,6 @@ def map_path_to_client(self, path: Union[os.PathLike[str], str]) -> pathlib.Pure
             return path
 
         for mapping in self.path_mappings:
-
             remote_root_path = Path(mapping.remote_root or ".").absolute()
 
             if (

robotcode/debugger/launcher/__main__.py

@@ -12,7 +12,6 @@
     __file__ = __file__[:-1]
 
 if __name__ == "__main__" and __package__ is None or __package__ == "":
-
     file = Path(__file__).resolve()
     parent, top = file.parent, file.parents[3]
 

robotcode/debugger/listeners.py

@@ -41,7 +41,6 @@ def start_suite(self, name: str, attributes: Dict[str, Any]) -> None:
         Debugger.instance().start_suite(name, attributes)
 
     def end_suite(self, name: str, attributes: Dict[str, Any]) -> None:
-
         Debugger.instance().end_suite(name, attributes)
 
         Debugger.instance().end_output_group(name, attributes, "SUITE")

robotcode/debugger/protocol.py

@@ -75,7 +75,6 @@ def __init__(
 
 
 class DebugAdapterProtocol(JsonRPCProtocolBase):
-
     _logger = LoggingDescriptor()
 
     def __init__(self) -> None:
@@ -301,7 +300,6 @@ def send_request(
         request: Request,
         return_type: Optional[Type[TResult]] = None,
     ) -> asyncio.Future[TResult]:
-
         result: asyncio.Future[TResult] = asyncio.get_event_loop().create_future()
 
         with self._sended_request_lock:

robotcode/debugger/server.py

@@ -233,7 +233,6 @@ async def _terminate(self, arguments: Optional[TerminateArguments] = None, *args
 
     @rpc_method(name="disconnect", param_type=DisconnectArguments)
     async def _disconnect(self, arguments: Optional[DisconnectArguments] = None, *args: Any, **kwargs: Any) -> None:
-
         if (
             (not (await self.exited) or not (await self.terminated))
             and arguments is not None
@@ -264,7 +263,6 @@ async def _configuration_done(
         self._received_configuration_done_event.set()
 
         if self.received_configuration_done_callback is not None:
-
             self.received_configuration_done_callback()
 
     @_logger.call

robotcode/jsonrpc2/protocol.py

@@ -180,7 +180,6 @@ def rpc_method(
     cancelable: bool = True,
 ) -> Callable[[_F], _F]:
     def _decorator(func: _F) -> Callable[[_F], _F]:
-
         if inspect.isclass(_func):
             raise TypeError(f"Not supported type {type(func)}.")
 
@@ -270,7 +269,6 @@ def get_methods(obj: Any) -> Dict[str, RpcMethodEntry]:
             }
 
         if not self.__initialized:
-
             if inspect.isclass(self.__owner):
                 self.__methods = get_methods(self.__owner)
 
@@ -342,7 +340,6 @@ class ReceivedRequestEntry(NamedTuple):
 
 
 class JsonRPCProtocolBase(asyncio.Protocol, ABC):
-
     _logger = LoggingDescriptor()
     registry: ClassVar = RpcRegistry()
 
@@ -547,7 +544,6 @@ def send_request(
         params: Optional[Any] = None,
         return_type_or_converter: Optional[Type[_TResult]] = None,
     ) -> asyncio.Future[Optional[_TResult]]:
-
         with self._sended_request_lock:
             result: asyncio.Future[Optional[_TResult]] = create_sub_future()
             self._sended_request_count += 1
@@ -566,7 +562,6 @@ async def send_request_async(
         params: Optional[Any] = None,
         return_type: Optional[Type[_TResult]] = None,
     ) -> Optional[_TResult]:
-
         return await self.send_request(method, params, return_type)
 
     @_logger.call
@@ -613,7 +608,6 @@ def set_result(f: asyncio.Future[Any], r: Any, ev: threading.Event) -> None:
 
                         start = time.monotonic()
                         while not done.is_set():
-
                             if time.monotonic() - start > 120:
                                 raise TimeoutError("Can't set future result.")
 

robotcode/language_server/__main__.py

@@ -13,7 +13,6 @@
     __file__ = __file__[:-1]
 
 if __name__ == "__main__" and __package__ is None or __package__ == "":
-
     file = Path(__file__).resolve()
     parent, top = file.parent, file.parents[2]
 

robotcode/language_server/common/parts/code_action.py

@@ -28,7 +28,6 @@
 
 
 class CodeActionProtocolPart(LanguageServerProtocolPart, HasExtendCapabilities):
-
     _logger = LoggingDescriptor()
 
     def __init__(self, parent: LanguageServerProtocol) -> None:
@@ -71,7 +70,6 @@ async def _text_document_code_action(
         *args: Any,
         **kwargs: Any,
     ) -> Optional[List[Union[Command, CodeAction]]]:
-
         results: List[Union[Command, CodeAction]] = []
 
         document = await self.parent.documents.get(text_document.uri)
@@ -105,7 +103,6 @@ async def _text_document_code_action_resolve(
         *args: Any,
         **kwargs: Any,
     ) -> CodeAction:
-
         results: List[CodeAction] = []
 
         for result in await self.resolve(self, params):

robotcode/language_server/common/parts/code_lens.py

@@ -25,7 +25,6 @@
 
 
 class CodeLensProtocolPart(LanguageServerProtocolPart, HasExtendCapabilities):
-
     _logger = LoggingDescriptor()
 
     def __init__(self, parent: LanguageServerProtocol) -> None:
@@ -49,7 +48,6 @@ def extend_capabilities(self, capabilities: ServerCapabilities) -> None:
     async def _text_document_code_lens(
         self, text_document: TextDocumentIdentifier, *args: Any, **kwargs: Any
     ) -> Optional[List[CodeLens]]:
-
         results: List[CodeLens] = []
         document = await self.parent.documents.get(text_document.uri)
         if document is None:
@@ -71,7 +69,6 @@ async def _text_document_code_lens(
     @rpc_method(name="codeLens/resolve", param_type=CodeLens)
     @threaded()
     async def _code_lens_resolve(self, params: CodeLens, *args: Any, **kwargs: Any) -> CodeLens:
-
         results: List[CodeLens] = []
 
         for result in await self.resolve(self, params):