added Python stub files generated by MyPy (+ some hand made / adjusted). helps IDEs handle typing in modules that use local imports.

Author: Someguy123

privex_stubs/privex/__init__.pyi

@@ -0,0 +1,4 @@
+
+__path__ = __import__('pkgutil').extend_path(__path__, __name__)
+
+from .helpers import *

privex_stubs/privex/db

@@ -0,0 +1 @@
+/Users/chris/.local/share/virtualenvs/helpers-IG0UDhHY/lib/python3.8/site-packages/privex/db

privex_stubs/privex/helpers/__init__.pyi

@@ -0,0 +1,24 @@
+from .common import *
+from .collections import *
+from .decorators import *
+from .net import *
+from .exceptions import *
+from .plugin import *
+from .cache.asyncx import *
+from .asyncx import *
+from .extras import *
+from .converters import *
+from .geoip import *
+from .thread import *
+from . import plugin as plugin
+from .cache import CacheAdapter as CacheAdapter, CacheNotFound as CacheNotFound, CacheWrapper as CacheWrapper, MemoryCache as MemoryCache, cached as cached
+from .cache.RedisCache import RedisCache as RedisCache
+from .crypto import EncryptHelper as EncryptHelper, Format as Format, KeyManager as KeyManager, auto_b64decode as auto_b64decode, is_base64 as is_base64
+from .setuppy.bump import bump_version as bump_version, get_current_ver as get_current_ver
+from .setuppy.commands import BumpCommand as BumpCommand, ExtrasCommand as ExtrasCommand
+from .setuppy.common import extras_require as extras_require, reqs as reqs
+from typing import Any
+
+log: Any
+name: str
+VERSION: str

privex_stubs/privex/helpers/asyncx.pyi

@@ -0,0 +1,31 @@
+import queue
+import threading
+from privex.helpers.types import STRBYTES, T
+from typing import Any, Awaitable, Callable, Coroutine, List, Optional, Tuple, Type, Union
+
+def coro_thread_func(func: callable, *t_args: Any, _output_queue: Optional[Union[queue.Queue, str]]=..., **t_kwargs: Any) -> Any: ...
+def run_coro_thread_base(func: callable, *args: Any, _daemon_thread: Any=..., **kwargs: Any) -> threading.Thread: ...
+def run_coro_thread(func: callable, *args: Any, **kwargs: Any) -> Any: ...
+async def run_coro_thread_async(func: callable, *args: Any, _queue_timeout: Any=..., _queue_sleep: Any=..., **kwargs: Any) -> Any: ...
+def run_sync(func: Any, *args: Any, **kwargs: Any): ...
+def loop_run(coro: Union[Coroutine, Type[Coroutine], Callable], *args: Any, _loop: Any=..., **kwargs: Any) -> Any: ...
+def async_sync(f: Any): ...
+async def call_sys_async(proc: Any, *args: Any, write: STRBYTES=..., **kwargs: Any) -> Tuple[bytes, bytes]: ...
+async def await_if_needed(func: Union[callable, Coroutine, Awaitable, Any], *args: Any, **kwargs: Any) -> Any: ...
+def get_async_type(obj: Any) -> str: ...
+
+AWAITABLE_BLACKLIST_FUNCS: List[str]
+AWAITABLE_BLACKLIST_MODS: List[str]
+AWAITABLE_BLACKLIST: List[str]
+
+def is_async_context() -> bool: ...
+
+class AwaitableMixin:
+    def __getattribute__(self, item: Any): ...
+
+def awaitable_class(cls: Type[T]) -> Type[T]: ...
+def awaitable(func: Callable) -> Callable: ...
+
+class aobject:
+    __new__: Any = ...
+    __init__: Any = ...

privex_stubs/privex/helpers/cache/CacheAdapter.pyi

@@ -0,0 +1,34 @@
+import abc
+from abc import ABC, abstractmethod
+from privex.helpers.asyncx import await_if_needed as await_if_needed
+from privex.helpers.common import empty_if as empty_if
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound
+from privex.helpers.settings import DEFAULT_CACHE_TIMEOUT as DEFAULT_CACHE_TIMEOUT
+from privex.helpers.types import VAL_FUNC_CORO as VAL_FUNC_CORO
+from typing import Any, Optional, Union
+
+class CacheAdapter(ABC, metaclass=abc.ABCMeta):
+    adapter_enter_reconnect: bool = ...
+    adapter_exit_close: bool = ...
+    ins_enter_reconnect: bool
+    ins_exit_close: bool
+    def __init__(self, *args: Any, enter_reconnect: Optional[bool]=..., exit_close: Optional[bool]=..., **kwargs: Any) -> None: ...
+    @abstractmethod
+    def get(self, key: str, default: Any=..., fail: bool=...) -> Any: ...
+    @abstractmethod
+    def set(self, key: str, value: Any, timeout: Optional[int]=...) -> Any: ...
+    @abstractmethod
+    def remove(self, *key: str) -> bool: ...
+    @abstractmethod
+    def update_timeout(self, key: str, timeout: int=...) -> Any: ...
+    def get_or_set(self, key: str, value: Union[Any, callable], timeout: int=...) -> Any: ...
+    async def get_or_set_async(self, key: str, value: VAL_FUNC_CORO, timeout: int=...) -> Any: ...
+    def close(self, *args: Any, **kwargs: Any) -> Any: ...
+    def connect(self, *args: Any, **kwargs: Any) -> Any: ...
+    def reconnect(self, *args: Any, **kwargs: Any) -> Any: ...
+    def __getitem__(self, item: Any): ...
+    def __setitem__(self, key: Any, value: Any): ...
+    async def __aenter__(self): ...
+    async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None: ...
+    def __enter__(self): ...
+    def __exit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None: ...

privex_stubs/privex/helpers/cache/MemoryCache.pyi

@@ -0,0 +1,13 @@
+from privex.helpers.cache.CacheAdapter import CacheAdapter as CacheAdapter
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound
+from privex.helpers.settings import DEFAULT_CACHE_TIMEOUT as DEFAULT_CACHE_TIMEOUT
+from typing import Any, Optional, Union
+
+log: Any
+
+class MemoryCache(CacheAdapter):
+    def get(self, key: str, default: Any=..., fail: bool=...) -> Any: ...
+    def set(self, key: str, value: Any, timeout: Optional[int]=...) -> Any: ...
+    def get_or_set(self, key: str, value: Union[Any, callable], timeout: int=...) -> Any: ...
+    def remove(self, *key: str) -> bool: ...
+    def update_timeout(self, key: str, timeout: int=...) -> Any: ...

privex_stubs/privex/helpers/cache/RedisCache.pyi

@@ -0,0 +1,23 @@
+from privex.helpers import plugin as plugin
+from privex.helpers.cache.CacheAdapter import CacheAdapter as CacheAdapter
+from privex.helpers.common import empty as empty
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound
+from privex.helpers.plugin import close_redis as close_redis, get_redis as get_redis
+from privex.helpers.settings import DEFAULT_CACHE_TIMEOUT as DEFAULT_CACHE_TIMEOUT
+from redis import Redis
+from typing import Any, Optional
+
+log: Any
+
+class RedisCache(CacheAdapter):
+    pickle_default: bool = ...
+    use_pickle: bool
+    def __init__(self, use_pickle: bool=..., redis_instance: Redis=..., *args: Any, **kwargs: Any) -> None: ...
+    @property
+    def redis(self) -> Redis: ...
+    def get(self, key: str, default: Any=..., fail: bool=...) -> Any: ...
+    def set(self, key: str, value: Any, timeout: Optional[int]=...) -> Any: ...
+    def remove(self, *key: str) -> bool: ...
+    def update_timeout(self, key: str, timeout: int=...) -> Any: ...
+    def connect(self, *args: Any, **kwargs: Any) -> Redis: ...
+    def close(self): ...

privex_stubs/privex/helpers/cache/SqliteCache.pyi

@@ -0,0 +1,40 @@
+from privex.helpers import settings as settings
+from privex.helpers.cache.CacheAdapter import CacheAdapter as CacheAdapter
+from privex.helpers.common import empty as empty, empty_if as empty_if, is_true as is_true
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound
+from typing import Any, Optional
+
+from privex.helpers.cache.post_deps import SqliteCacheManager, SqliteCacheResult
+
+log: Any
+
+
+def _cache_result_expired(res: SqliteCacheResult, _auto_purge=True) -> bool: ...
+
+
+class SqliteCache(CacheAdapter):
+    pickle_default: bool = ...
+    use_pickle: bool
+    last_purged_expired: Optional[int] = ...
+    db_file: Any = ...
+    db_folder: Any = ...
+    connection_kwargs: Any = ...
+    memory_persist: Any = ...
+    purge_every: Any = ...
+    _wrapper: Optional[SqliteCacheManager] = ...
+    
+    def __init__(self, db_file: str=..., memory_persist: Any=..., use_pickle: bool=..., connection_kwargs: dict=..., *args: Any, **kwargs: Any) -> None: ...
+    
+    @property
+    def purge_due(self) -> bool: ...
+    
+    @property
+    def wrapper(self) -> SqliteCacheManager: ...
+    
+    def purge_expired(self, force: Any=...) -> Optional[int]: ...
+    def get(self, key: str, default: Any=..., fail: bool=..., _auto_purge: Any=...) -> Any: ...
+    def set(self, key: str, value: Any, timeout: Optional[int]=..., _auto_purge: Any=...) -> Any: ...
+    def remove(self, *key: str) -> bool: ...
+    def update_timeout(self, key: str, timeout: int=...) -> Any: ...
+    def connect(self, db: Any=..., *args: Any, connection_kwargs: Any=..., memory_persist: Any=..., **kwargs: Any) -> SqliteCacheManager: ...
+    def close(self) -> None: ...

privex_stubs/privex/helpers/cache/__init__.pyi

@@ -0,0 +1,72 @@
+from .asyncx import *
+from privex.helpers import plugin as plugin
+from privex.helpers.asyncx import await_if_needed as await_if_needed, awaitable as awaitable, loop_run as loop_run
+from .CacheAdapter import CacheAdapter as CacheAdapter
+from .MemoryCache import MemoryCache as MemoryCache
+from .RedisCache import RedisCache as RedisCache
+from .SqliteCache import SqliteCache as SqliteCache
+from privex.helpers.common import LayeredContext as LayeredContext, empty_if as empty_if
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound, NotConfigured as NotConfigured
+from privex.helpers.settings import DEFAULT_CACHE_TIMEOUT as DEFAULT_CACHE_TIMEOUT
+from typing import Any, Optional, Type, Union
+
+log: Any
+CLSCacheAdapter = Union[Type[CacheAdapter], Type[AsyncCacheAdapter]]
+INSCacheAdapter = Union[CacheAdapter, AsyncCacheAdapter]
+ANYCacheAdapter = Union[CLSCacheAdapter, INSCacheAdapter]
+
+class CacheWrapper:
+    cache_instance: Optional[INSCacheAdapter] = ...
+    default_adapter: Type[CLSCacheAdapter] = ...
+    instance_args: Any = ...
+    instance_kwargs: Any = ...
+    max_context_layers: int = ...
+    @classmethod
+    def get_context_tracker(cls: Any, reset: bool=...) -> LayeredContext: ...
+    @classmethod
+    def reset_context_tracker(cls: Any) -> LayeredContext: ...
+    @classmethod
+    def get_adapter(cls: Any, default: CLSCacheAdapter=..., *args: Any, **kwargs: Any) -> INSCacheAdapter: ...
+    @classmethod
+    def set_adapter(cls: Any, adapter: ANYCacheAdapter, *args: Any, **kwargs: Any) -> INSCacheAdapter: ...
+    @classmethod
+    def reset_adapter(cls: Any, default: CLSCacheAdapter=..., *args: Any, **kwargs: Any) -> INSCacheAdapter: ...
+    def __getattr__(self, item: Any): ...
+    def __getitem__(self, item: Any): ...
+    def __setitem__(self, key: Any, value: Any): ...
+    async def __aenter__(self): ...
+    async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any): ...
+    def __enter__(self): ...
+    def __exit__(self, exc_type: Any, exc_val: Any, exc_tb: Any): ...
+
+cached: Union[CacheAdapter, CacheWrapper]
+
+class AsyncCacheWrapper(CacheWrapper):
+    cache_instance: AsyncCacheAdapter = ...
+    instance_args: Any = ...
+    instance_kwargs: Any = ...
+    default_adapter: Type[AsyncCacheAdapter] = ...
+    max_context_layers: int = ...
+    @classmethod
+    def get_adapter(cls: Any, default: Type[AsyncCacheAdapter]=..., *args: Any, **kwargs: Any) -> AsyncCacheAdapter: ...
+    @classmethod
+    def set_adapter(cls: Any, adapter: AsyncCacheAdapter, *args: Any, **kwargs: Any) -> AsyncCacheAdapter: ...
+    @classmethod
+    def reset_adapter(cls: Any, default: Type[AsyncCacheAdapter]=..., *args: Any, **kwargs: Any) -> AsyncCacheAdapter: ...
+    def __getattr__(self, item: Any): ...
+    def __getitem__(self, item: Any): ...
+    def __setitem__(self, key: Any, value: Any): ...
+    def __enter__(self): ...
+    def __exit__(self, exc_type: Any, exc_val: Any, exc_tb: Any): ...
+
+async_cached: Union[AsyncCacheAdapter, AsyncCacheWrapper]
+
+def async_adapter_set(adapter: AsyncCacheAdapter) -> AsyncCacheAdapter: ...
+def async_adapter_get(default: Type[AsyncCacheAdapter]=...) -> AsyncCacheAdapter: ...
+def adapter_set(adapter: CacheAdapter) -> Any: ...
+def adapter_get(default: Type[CacheAdapter]=...) -> CacheAdapter: ...
+def get(key: str, default: Any=..., fail: bool=...) -> Any: ...
+def set(key: str, value: Any, timeout: Optional[int]=...) -> Any: ...
+def get_or_set(key: str, value: Union[Any, callable], timeout: int=...) -> Any: ...
+def remove(*key: str) -> bool: ...
+def update_timeout(key: str, timeout: int=...) -> Any: ...

privex_stubs/privex/helpers/cache/asyncx/AsyncMemcachedCache.pyi

@@ -0,0 +1,23 @@
+import aiomcache
+from privex.helpers.cache.asyncx.base import AsyncCacheAdapter as AsyncCacheAdapter
+from privex.helpers.common import byteify as byteify, empty as empty
+from privex.helpers.exceptions import CacheNotFound as CacheNotFound
+from privex.helpers.plugin import close_memcached_async as close_memcached_async, get_memcached_async as get_memcached_async
+from privex.helpers.settings import DEFAULT_CACHE_TIMEOUT as DEFAULT_CACHE_TIMEOUT
+from typing import Any, Optional, Union
+
+log: Any
+
+class AsyncMemcachedCache(AsyncCacheAdapter):
+    pickle_default: bool = ...
+    use_pickle: bool
+    adapter_enter_reconnect: bool = ...
+    adapter_exit_close: bool = ...
+    def __init__(self, use_pickle: bool=..., mcache_instance: aiomcache.Client=..., *args: Any, **kwargs: Any) -> None: ...
+    async def mcache(self) -> aiomcache.Client: ...
+    async def get(self, key: Union[bytes, str], default: Any=..., fail: bool=...) -> Any: ...
+    async def set(self, key: Union[bytes, str], value: Any, timeout: Optional[int]=...) -> Any: ...
+    async def remove(self, *key: Union[bytes, str]) -> bool: ...
+    async def update_timeout(self, key: str, timeout: int=...) -> Any: ...
+    async def connect(self, *args: Any, new_connection: Any=..., **kwargs: Any) -> aiomcache.Client: ...
+    async def close(self): ...