Commit ab8c457
Changed files (1)
src
messages
src/messages/database.py
@@ -122,8 +122,6 @@ async def copy_messages_from_db(
type_order = {"media_group": 0, "video": 1, "photo": 2, "audio": 3, "document": 4, "text": 5}
return (type_order.get(item["type"], 999), item["mid"])
- if kwargs:
- logger.debug(f"kwargs: {kwargs}")
target_chat = kwargs["target_chat"] if kwargs.get("target_chat") else message.chat.id
reply_msg_id = kwargs.get("reply_msg_id", message.id)
if to_int(reply_msg_id) == 0:
@@ -143,7 +141,6 @@ async def copy_messages_from_db(
if isinstance(data, str):
data = json.loads(data)
logger.debug(f"Sending {len(data)} messages from {DB.ENGINE}: {data}")
- await modify_progress(text=f"💾在{DB.ENGINE}中查到缓存, 正在转发{len(data)}条消息...", **kwargs)
results: list[Message] = []
try:
for idx, item in enumerate(sorted(data, key=custom_sort)):