fix: remove disabled chat

main.py

@@ -203,7 +203,15 @@ async def send_notification(
         text: str,
         parse_mode: str | DefaultValue[None] = DEFAULT_NONE,
     ) -> None:
-        await self.bot.send_message(chat_id=chat_id, text=text, parse_mode=parse_mode)
+        try:
+            await self.bot.send_message(
+                chat_id=chat_id, text=text, parse_mode=parse_mode
+            )
+        except telegram.error.Forbidden as e:
+            if e.message == "Forbidden: user is deactivated":
+                await self.pg.disable_chat(chat_id)
+                await self.read_from_db()
+            raise
 
     async def get_chats(self, user_id: int) -> set[int] | None:
         async with self.__lock.reader:

pg.py

@@ -4,7 +4,6 @@
 from collections import defaultdict
 
 import asyncpg
-from asyncpg import Record
 
 from lib import config
 
@@ -25,10 +24,10 @@ async def create_pg_client() -> PG:
 
 
 class PG:
-    __pool: asyncpg.Pool[Record]
+    __pool: asyncpg.Pool
 
-    def __init__(self, pool: asyncpg.Pool[Record]):
-        self.__pool = pool
+    def __init__(self, pool: asyncpg.Pool):
+        self.__pool: asyncpg.Pool = pool
 
     async def init(self) -> None:
         await self.__pool.execute(
@@ -74,3 +73,9 @@ async def get_watched_users(self) -> dict[int, set[int]]:
                 d[user_id].add(chat_id)
             return d
         return {}
+
+    async def disable_chat(self, chat_id: int) -> None:
+        await self.__pool.execute(
+            "update telegram_notify_chat set disabled = 1 and disabled = 0 where chat_id = $1",
+            chat_id,
+        )