Added description saving for user

app/blueprints/api/tasks/tasks.py

@@ -20,9 +20,44 @@ async def sending_message(session, task, task_self):
     async with PaperParser(session.name) as parser:
         await parser.send_messages(task.collection.users, task.message, task.file, task_self)
 
-async def parse_users(session, task):
+async def parse_users(session, task, db, collection):
     async with PaperParser(session.name) as parser:
-        return await parser.get_participants(task.url)
+        users = await parser.get_participants(task.url)
+
+        filtered_users = filter(filter_users, users)
+
+        for user in filtered_users:
+            if not User.exist(user.username, collection):
+                full = await parser.get_full_info()
+                bio = full.full_user.about if full.full_user else None
+
+                db.session.add(
+                    User(
+                        first_name=user.first_name,
+                        last_name=user.last_name,
+                        username=user.username,
+                        phone=user.phone,
+                        description=bio,
+                        collection=collection,
+                    )
+                )
+        
+                db.session.commit()
+
+def filter_users(user):
+    if not user.username or user.bot:
+        return False
+    
+    is_active = False
+    if isinstance(user.status, UserStatusOffline):
+        was_online = user.status.was_online.replace(tzinfo=datetime.timezone.utc)
+        today = datetime.datetime.today().replace(tzinfo=datetime.timezone.utc)
+        is_active = was_online + datetime.timedelta(days=5) >= today
+    
+    if isinstance(user.status, UserStatusOnline) or isinstance(user.status, UserStatusRecently):
+        is_active = True
+        
+    return is_active
 
 @shared_task(bind=True)
 def add_to_group_task(self, task_id: int):
@@ -32,8 +67,6 @@ def add_to_group_task(self, task_id: int):
 
         session = task.session
 
-        time.sleep(10)
-
         asyncio.run(
             add_to_group(session, task, self)
         )
@@ -45,44 +78,27 @@ def add_to_group_task(self, task_id: int):
     else:
         success_state(task_id)
 
+
 @shared_task(bind=True)
 def parse_users_task(self, task_id: int):
-    task: Task = Task.query.get_or_404(task_id)
+    try:
-    session = task.session
+        task: Task = Task.query.get_or_404(task_id)
-    collection = task.collection
+        session = task.session
+        collection = task.collection
 
-    users = asyncio.run(
+        run_state(self.request.id, task_id)
-        parse_users(session, task)
-    )
 
-    for user in users:
+        asyncio.run(
-        if not user.username or user.bot:
+            parse_users(session, task, db, collection)
-            continue
+        )
     
-        is_active = False
+    except Exception as e:
-        if isinstance(user.status, UserStatusOffline):
+        logger.exception(e)
-            was_online = user.status.was_online.replace(tzinfo=datetime.timezone.utc)
+        failure_state(task_id, e)
-            today = datetime.datetime.today().replace(tzinfo=datetime.timezone.utc)
-            is_active = was_online + datetime.timedelta(days=5) >= today
     
-        if isinstance(user.status, UserStatusOnline) or isinstance(user.status, UserStatusRecently):
+    else:
-            is_active = True
+        success_state(task_id)
 
-        if not is_active:
-            continue
-        
-        if not User.exist(user.username, collection):
-            db.session.add(
-                User(
-                    first_name=user.first_name,
-                    last_name=user.last_name,
-                    username=user.username,
-                    phone=user.phone,
-                    collection=collection,
-                )
-            )
-    
-    db.session.commit()
 
 @shared_task(bind=True)
 def send_messages_task(self, task_id: int):

app/models/user.py

@@ -14,6 +14,7 @@ class User(db.Model):
 
     phone: Mapped[str] = mapped_column(nullable=True)
     username: Mapped[str] = mapped_column(nullable=True)
+    description: Mapped[str] = mapped_column(nullable=True)
 
     delete: Mapped[bool] = mapped_column(default="false")
     
@@ -30,4 +31,5 @@ class User(db.Model):
             'last_name': self.last_name,
             'phone': self.phone,
             'username': self.username,
+            'description': self.description
         }

migrations/versions/d4a19a758c83_added_desc_field_to_user.py

@@ -0,0 +1,32 @@
+"""Added desc field to user
+
+Revision ID: d4a19a758c83
+Revises: 65ccd5b1039b
+Create Date: 2024-04-12 16:53:20.758855
+
+"""
+from alembic import op
+import sqlalchemy as sa
+
+
+# revision identifiers, used by Alembic.
+revision = 'd4a19a758c83'
+down_revision = '65ccd5b1039b'
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.add_column(sa.Column('description', sa.String(), nullable=True))
+
+    # ### end Alembic commands ###
+
+
+def downgrade():
+    # ### commands auto generated by Alembic - please adjust! ###
+    with op.batch_alter_table('user', schema=None) as batch_op:
+        batch_op.drop_column('description')
+
+    # ### end Alembic commands ###

paper/client.py

@@ -5,6 +5,7 @@ from opentele.api import API
 
 from telethon.tl.functions.channels import InviteToChannelRequest, JoinChannelRequest
 from telethon.tl.functions.messages import AddChatUserRequest
+from telethon.tl.functions.users import GetFullUserRequest
 
 # Types
 from telethon.hints import (Entity, EntityLike, MessageLike)
@@ -105,3 +106,6 @@ class PaperClient(TelegramClient):
             return entity  # type: ignore
         except UsernameInvalidError as e:
             raise IgnoreException(e)
+        
+    async def get_full_info(self, user):
+        return await self(GetFullUserRequest(user))

paper/parser.py

@@ -68,6 +68,10 @@ class PaperParser:
 
         return await self.client.get_participants(group)
     
+    async def get_full_info(self, user):
+        return await self.client.get_full_info(user)
+
+
     async def sign_in(self, phone: str, password: str | None = None, code: str | None = None, phone_hash: str | None = None, **kwargs):
         if not await self.client.is_user_authorized():
             try: