Merge pull request #36 from Leibniz-HBI/35-python38-compatibility

[fix] python3.8 compatibility

.github/workflows/main.yml

@@ -10,7 +10,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        python-version: ["3.9", "3.10"] # "3.7", "3.8", "
+        python-version: ["3.8", "3.9", "3.10"] # "3.7", "3.8", "
 
     steps:
       - uses: actions/checkout@v3

pyproject.toml

@@ -14,7 +14,7 @@ classifiers = [
 ]
 
 [tool.poetry.dependencies]
-python = "^3.9"
+python = "^3.8"
 Telethon = "^1.24.0"
 ujson = "^5.4.0"
 click = "^8.1.3"

tegracli/dispatch.py

@@ -1,11 +1,10 @@
-"""dispatch functions that dispatch requests to Telethon and MTProto
-"""
+"""Dispatch functions that request data from Telethon and MTProto."""
 import datetime
 import time
 from functools import partial
 from io import TextIOWrapper
 from pathlib import Path
-from typing import Dict, Optional
+from typing import Dict, List, Optional
 
 import telethon
 import ujson
@@ -20,19 +19,19 @@
 async def dispatch_iter_messages(
     client: TelegramClient, params: Dict, callback: MessageHandler
 ) -> None:
-    """dispatch a a TG-method with callback
+    """Dispatch a a TG-method with callback.
 
     Parameters:
         client : TelegramClient
         params : Dict
-        callback : Callable
+        callback : MessageHandler
     """
     async for message in client.iter_messages(wait_time=10, **params):
         await callback(message)
 
 
 async def dispatch_get(users, client: TelegramClient, params: Dict):
-    """get the message history of a specified set of users."""
+    """Get the message history of a specified set of users."""
 
     for user in users:
         done = False
@@ -62,8 +61,8 @@ async def dispatch_get(users, client: TelegramClient, params: Dict):
             done = True
 
 
-async def dispatch_search(queries: list[str], client: TelegramClient):
-    """dispatch a global search"""
+async def dispatch_search(queries: List[str], client: TelegramClient):
+    """Dispatch a global search."""
     local_account = await client.get_me()
     log.info(f"Using telegram accout of {local_account.username}")
     for query in queries:
@@ -83,7 +82,7 @@ async def dispatch_search(queries: list[str], client: TelegramClient):
 async def handle_message(
     message: telethon.types.Message, file: TextIOWrapper, injects: Optional[Dict]
 ):
-    """Accept incoming messages and log them to disk
+    """Accept incoming messages and log them to disk.
 
     Parameters
     ----------
@@ -109,7 +108,7 @@ async def handle_message(
 async def get_input_entity(
     client: TelegramClient, member_id: int
 ) -> Optional[telethon.types.TypeInputPeer]:
-    """wraps the client.get_input_entity function
+    """Wraps the client.get_input_entity function.
 
     Parameters
     ----------
@@ -127,7 +126,7 @@ async def get_input_entity(
 async def get_profile(
     client: TelegramClient, member: str, group_name: str
 ) -> Optional[Dict[str, str]]:
-    """Returns a Dict from the requested entity
+    """Returns a Dict from the requested entity.
 
     Parameters
     ----------

tegracli/main.py

@@ -108,7 +108,7 @@ def get(  # pylint: disable=too-many-arguments
     from_user: str,
     reverse: bool,
     reply_to: int,
-    channels: list[str],
+    channels: List[str],
 ) -> None:
     """Get messages for the specified channels by either ID or username."""
     client = get_client(ctx.obj["credentials"])
@@ -337,7 +337,7 @@ def _guarded_group_load(cwd: Path, _name: str) -> Group:
 @cli.command()
 @click.argument("queries", nargs=-1)
 @click.pass_context
-def search(ctx: click.Context, queries: list[str]):
+def search(ctx: click.Context, queries: List[str]):
     """Searches Telegram content that is available to your account."""
     client = get_client(ctx.obj["credentials"])
 

tests/test_dispatchers.py

@@ -10,7 +10,7 @@
 # pylint: disable=wrong-import-position
 
 from pathlib import Path
-from typing import Dict
+from typing import Dict, List
 
 import pytest
 import yaml
@@ -36,7 +36,7 @@ def client():
 
 @pytest.mark.api
 @pytest.mark.enable_socket
-def test_search(queries: list[str], client: TelegramClient):
+def test_search(queries: List[str], client: TelegramClient):
     """Should run a search on the specified queries
 
     Asserts
@@ -59,7 +59,7 @@ def test_search(queries: list[str], client: TelegramClient):
     [{"limit": 1}, {"limit": 2, "reverse": True}, {"offset_id": 5, "limit": 1}],
 )
 @pytest.mark.parametrize("queries", [["channelnotfound123"], ["channel", "1446651076"]])
-def test_get(queries: list[str], client: TelegramClient, params: Dict):
+def test_get(queries: List[str], client: TelegramClient, params: Dict):
     """Should get message for existing channels
 
     Asserts