style: remove some unused code and comments

Author: d-biehl

packages/core/src/robotcode/core/async_tools.py

@@ -5,7 +5,6 @@
 import concurrent.futures
 import contextvars
 import functools
-import inspect
 import threading
 import time
 import warnings
@@ -15,14 +14,9 @@
 from types import TracebackType
 from typing import (
     Any,
-    AsyncIterator,
     Callable,
     Coroutine,
     Deque,
-    Generic,
-    Iterator,
-    List,
-    MutableSet,
     Optional,
     Set,
     Type,
@@ -31,235 +25,8 @@
     cast,
 )
 
-from .concurrent import is_threaded_callable
-from .utils.inspect import ensure_coroutine
-
 _T = TypeVar("_T")
 
-# TODO try to use new ParamSpec feature in Python 3.10
-
-_TResult = TypeVar("_TResult")
-_TCallable = TypeVar("_TCallable", bound=Callable[..., Any])
-
-
-class AsyncEventResultIteratorBase(Generic[_TCallable, _TResult]):
-    def __init__(self) -> None:
-        self._lock = threading.RLock()
-
-        self._listeners: MutableSet[weakref.ref[Any]] = set()
-        self._loop = asyncio.get_event_loop()
-
-    def add(self, callback: _TCallable) -> None:
-        def remove_listener(ref: Any) -> None:
-            with self._lock:
-                self._listeners.remove(ref)
-
-        with self._lock:
-            if inspect.ismethod(callback):
-                self._listeners.add(weakref.WeakMethod(callback, remove_listener))
-            else:
-                self._listeners.add(weakref.ref(callback, remove_listener))
-
-    def remove(self, callback: _TCallable) -> None:
-        with self._lock:
-            try:
-                if inspect.ismethod(callback):
-                    self._listeners.remove(weakref.WeakMethod(callback))
-                else:
-                    self._listeners.remove(weakref.ref(callback))
-            except KeyError:
-                pass
-
-    def __contains__(self, obj: Any) -> bool:
-        if inspect.ismethod(obj):
-            return weakref.WeakMethod(obj) in self._listeners
-
-        return weakref.ref(obj) in self._listeners
-
-    def __len__(self) -> int:
-        return len(self._listeners)
-
-    def __iter__(self) -> Iterator[_TCallable]:
-        for r in self._listeners:
-            c = r()
-            if c is not None:
-                yield c
-
-    async def __aiter__(self) -> AsyncIterator[_TCallable]:
-        for r in self.__iter__():
-            yield r
-
-    async def _notify(
-        self,
-        *args: Any,
-        callback_filter: Optional[Callable[[_TCallable], bool]] = None,
-        **kwargs: Any,
-    ) -> AsyncIterator[_TResult]:
-        for method in filter(
-            lambda x: callback_filter(x) if callback_filter is not None else True,
-            set(self),
-        ):
-            result = method(*args, **kwargs)
-            if inspect.isawaitable(result):
-                result = await result
-
-            yield result
-
-
-class AsyncEventIterator(AsyncEventResultIteratorBase[_TCallable, _TResult]):
-    def __call__(self, *args: Any, **kwargs: Any) -> AsyncIterator[_TResult]:
-        return self._notify(*args, **kwargs)
-
-
-class AsyncEvent(AsyncEventResultIteratorBase[_TCallable, _TResult]):
-    async def __call__(self, *args: Any, **kwargs: Any) -> List[_TResult]:
-        return [a async for a in self._notify(*args, **kwargs)]
-
-
-_TEvent = TypeVar("_TEvent")
-
-
-class AsyncEventDescriptorBase(Generic[_TCallable, _TResult, _TEvent]):
-    def __init__(
-        self,
-        _func: _TCallable,
-        factory: Callable[..., _TEvent],
-        *factory_args: Any,
-        **factory_kwargs: Any,
-    ) -> None:
-        self._func = _func
-        self.__factory = factory
-        self.__factory_args = factory_args
-        self.__factory_kwargs = factory_kwargs
-        self._owner: Optional[Any] = None
-        self._owner_name: Optional[str] = None
-
-    def __set_name__(self, owner: Any, name: str) -> None:
-        self._owner = owner
-        self._owner_name = name
-
-    def __get__(self, obj: Any, objtype: Type[Any]) -> _TEvent:
-        if obj is None:
-            return self  # type: ignore
-
-        name = f"__async_event_{self._func.__name__}__"
-        if not hasattr(obj, name):
-            setattr(
-                obj,
-                name,
-                self.__factory(*self.__factory_args, **self.__factory_kwargs),
-            )
-
-        return cast("_TEvent", getattr(obj, name))
-
-
-class async_event_iterator(  # noqa: N801
-    AsyncEventDescriptorBase[_TCallable, Any, AsyncEventIterator[_TCallable, Any]]
-):
-    def __init__(self, _func: _TCallable) -> None:
-        super().__init__(_func, AsyncEventIterator[_TCallable, Any])
-
-
-class async_event(AsyncEventDescriptorBase[_TCallable, Any, AsyncEvent[_TCallable, Any]]):  # noqa: N801
-    def __init__(self, _func: _TCallable) -> None:
-        super().__init__(_func, AsyncEvent[_TCallable, Any])
-
-
-class AsyncTaskingEventResultIteratorBase(AsyncEventResultIteratorBase[_TCallable, _TResult]):
-    def __init__(self, *, task_name_prefix: Optional[str] = None) -> None:
-        super().__init__()
-        self._task_name_prefix = task_name_prefix or type(self).__qualname__
-
-    async def _notify(  # type: ignore
-        self,
-        *args: Any,
-        result_callback: Optional[Callable[[Optional[_TResult], Optional[BaseException]], Any]] = None,
-        return_exceptions: Optional[bool] = True,
-        callback_filter: Optional[Callable[[_TCallable], bool]] = None,
-        threaded: Optional[bool] = True,
-        **kwargs: Any,
-    ) -> AsyncIterator[Union[_TResult, BaseException]]:
-        def _done(f: asyncio.Future[_TResult]) -> None:
-            if result_callback is not None:
-                try:
-                    result_callback(f.result(), f.exception())
-                except (SystemExit, KeyboardInterrupt):
-                    raise
-                except BaseException as e:
-                    result_callback(None, e)
-
-        awaitables: List[asyncio.Future[_TResult]] = []
-        for method in filter(
-            lambda x: callback_filter(x) if callback_filter is not None else True,
-            set(self),
-        ):
-            if method is not None:
-                if threaded and is_threaded_callable(method):
-                    future = run_coroutine_in_thread(ensure_coroutine(method), *args, **kwargs)
-                else:
-                    future = create_sub_task(ensure_coroutine(method)(*args, **kwargs))
-                awaitables.append(future)
-
-                if result_callback is not None:
-                    future.add_done_callback(_done)
-
-        for a in asyncio.as_completed(awaitables):
-            try:
-                yield await a
-
-            except (SystemExit, KeyboardInterrupt):
-                raise
-            except BaseException as e:
-                if return_exceptions:
-                    yield e
-                else:
-                    raise
-
-
-class AsyncTaskingEventIterator(AsyncTaskingEventResultIteratorBase[_TCallable, _TResult]):
-    def __call__(self, *args: Any, **kwargs: Any) -> AsyncIterator[Union[_TResult, BaseException]]:
-        return self._notify(*args, **kwargs)
-
-
-def _get_name_prefix(
-    descriptor: AsyncEventDescriptorBase[Any, Any, Any],
-) -> str:
-    if descriptor._owner is None:
-        return type(descriptor).__qualname__
-
-    return f"{descriptor._owner.__qualname__}.{descriptor._owner_name}"
-
-
-class AsyncTaskingEvent(AsyncTaskingEventResultIteratorBase[_TCallable, _TResult]):
-    async def __call__(self, *args: Any, **kwargs: Any) -> List[Union[_TResult, BaseException]]:
-        return [a async for a in self._notify(*args, **kwargs)]
-
-
-class async_tasking_event_iterator(  # noqa: N801
-    AsyncEventDescriptorBase[_TCallable, Any, AsyncTaskingEventIterator[_TCallable, Any]]
-):
-    def __init__(self, _func: _TCallable) -> None:
-        super().__init__(
-            _func,
-            AsyncTaskingEventIterator[_TCallable, Any],
-            task_name_prefix=lambda: _get_name_prefix(self),
-        )
-
-
-class async_tasking_event(AsyncEventDescriptorBase[_TCallable, Any, AsyncTaskingEvent[_TCallable, Any]]):  # noqa: N801
-    def __init__(self, _func: _TCallable) -> None:
-        super().__init__(
-            _func,
-            AsyncTaskingEvent[_TCallable, Any],
-            task_name_prefix=lambda: _get_name_prefix(self),
-        )
-
-
-async def check_canceled() -> bool:
-    await asyncio.sleep(0)
-
-    return True
-
 
 def check_canceled_sync() -> bool:
     info = get_current_future_info()

packages/debugger/src/robotcode/debugger/debugger.py

@@ -312,7 +312,6 @@ def __init__(self) -> None:
         self.stop_on_entry = False
         self._debug = True
         self.terminated = False
-        self.terminated_requested = False
         self.attached = False
         self.path_mappings: List[PathMapping] = []
         self.server_loop: Optional[asyncio.AbstractEventLoop] = None
@@ -383,9 +382,6 @@ def robot_output_file(self) -> Optional[str]:
     def robot_output_file(self, value: Optional[str]) -> None:
         self._robot_output_file = value
 
-    def terminate_requested(self) -> None:
-        self.terminated_requested = True
-
     def terminate(self) -> None:
         self.terminated = True
 
@@ -504,7 +500,7 @@ def step_out(self, thread_id: int, granularity: Optional[SteppingGranularity] =
             self.condition.notify_all()
 
     @event
-    def send_event(sender: Any, event: Event) -> None:  # NOSONAR
+    def send_event(sender: Any, event: Event) -> None:
         ...
 
     def set_breakpoints(

packages/language_server/src/robotcode/language_server/common/parts/code_action.py

@@ -41,12 +41,12 @@ def collect(
         sender,
         document: TextDocument,
         range: Range,
-        context: CodeActionContext,  # NOSONAR
+        context: CodeActionContext,
     ) -> Optional[List[Union[Command, CodeAction]]]:
         ...
 
     @event
-    def resolve(sender, code_action: CodeAction) -> Optional[CodeAction]:  # NOSONAR
+    def resolve(sender, code_action: CodeAction) -> Optional[CodeAction]:
         ...
 
     def extend_capabilities(self, capabilities: ServerCapabilities) -> None:

packages/language_server/src/robotcode/language_server/common/parts/code_lens.py

@@ -30,11 +30,11 @@ def __init__(self, parent: "LanguageServerProtocol") -> None:
         self._refresh_timeout = 5
 
     @event
-    def collect(sender, document: TextDocument) -> Optional[List[CodeLens]]:  # NOSONAR
+    def collect(sender, document: TextDocument) -> Optional[List[CodeLens]]:
         ...
 
     @event
-    def resolve(sender, code_lens: CodeLens) -> Optional[CodeLens]:  # NOSONAR
+    def resolve(sender, code_lens: CodeLens) -> Optional[CodeLens]:
         ...
 
     def extend_capabilities(self, capabilities: ServerCapabilities) -> None:

packages/language_server/src/robotcode/language_server/common/parts/completion.py

@@ -47,12 +47,12 @@ def collect(
         sender,
         document: TextDocument,
         position: Position,
-        context: Optional[CompletionContext],  # NOSONAR
+        context: Optional[CompletionContext],
     ) -> Union[List[CompletionItem], CompletionList, None]:
         ...
 
     @event
-    def resolve(sender, completion_item: CompletionItem) -> Optional[CompletionItem]:  # NOSONAR
+    def resolve(sender, completion_item: CompletionItem) -> Optional[CompletionItem]:
         ...
 
     def extend_capabilities(self, capabilities: ServerCapabilities) -> None:

packages/language_server/src/robotcode/language_server/common/parts/declaration.py

@@ -34,7 +34,7 @@ def __init__(self, parent: "LanguageServerProtocol") -> None:
     def collect(
         sender,
         document: TextDocument,
-        position: Position,  # NOSONAR
+        position: Position,
     ) -> Union[Location, List[Location], List[LocationLink], None]:
         ...
 

packages/language_server/src/robotcode/language_server/common/parts/definition.py

@@ -34,7 +34,7 @@ def __init__(self, parent: "LanguageServerProtocol") -> None:
     def collect(
         sender,
         document: TextDocument,
-        position: Position,  # NOSONAR
+        position: Position,
     ) -> Union[Location, List[Location], List[LocationLink], None]:
         ...
 

packages/language_server/src/robotcode/language_server/common/parts/diagnostics.py

@@ -132,25 +132,25 @@ def extend_capabilities(self, capabilities: ServerCapabilities) -> None:
             self.client_supports_pull = True
 
     @event
-    def collect(sender, document: TextDocument) -> Optional[DiagnosticsResult]:  # NOSONAR
+    def collect(sender, document: TextDocument) -> Optional[DiagnosticsResult]:
         ...
 
     @event
     def load_workspace_documents(
         sender,
-    ) -> Optional[List[WorkspaceDocumentsResult]]:  # NOSONAR
+    ) -> Optional[List[WorkspaceDocumentsResult]]:
         ...
 
     @event
-    def on_workspace_loaded(sender) -> None:  # NOSONAR
+    def on_workspace_loaded(sender) -> None:
         ...
 
     @event
-    def on_get_analysis_progress_mode(sender, uri: Uri) -> Optional[AnalysisProgressMode]:  # NOSONAR
+    def on_get_analysis_progress_mode(sender, uri: Uri) -> Optional[AnalysisProgressMode]:
         ...
 
     @event
-    def on_get_diagnostics_mode(sender, uri: Uri) -> Optional[DiagnosticsMode]:  # NOSONAR
+    def on_get_diagnostics_mode(sender, uri: Uri) -> Optional[DiagnosticsMode]:
         ...
 
     def ensure_workspace_loaded(self) -> None:

packages/language_server/src/robotcode/language_server/common/parts/document_highlight.py

@@ -34,7 +34,7 @@ def extend_capabilities(self, capabilities: ServerCapabilities) -> None:
             capabilities.document_highlight_provider = DocumentHighlightOptions(work_done_progress=True)
 
     @event
-    def collect(sender, document: TextDocument, position: Position) -> Optional[List[DocumentHighlight]]:  # NOSONAR
+    def collect(sender, document: TextDocument, position: Position) -> Optional[List[DocumentHighlight]]:
         ...
 
     @rpc_method(name="textDocument/documentHighlight", param_type=DocumentHighlightParams, threaded=True)

packages/language_server/src/robotcode/language_server/common/parts/document_symbols.py

@@ -66,7 +66,7 @@ def __init__(self, parent: "LanguageServerProtocol") -> None:
     @event
     def collect(
         sender,
-        document: TextDocument,  # NOSONAR
+        document: TextDocument,
     ) -> Optional[Union[List[DocumentSymbol], List[SymbolInformation], None]]:
         ...