Skip to content

Dev/1.2.3 #33

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ink-developer merged 8 commits into from
Dec 24, 2025
Merged

Dev/1.2.3 #33

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
4dad9c1
фикс типов
ink-developer Dec 22, 2025
1834b41
фикс типов 2
ink-developer Dec 22, 2025
bae4476
Добавил загрузку фото профиля
ink-developer Dec 22, 2025
c6ab809
Добавил метод для получении информации о чате по ссылке
ink-developer Dec 23, 2025
de05a5e
Добавил класс ContactAttach для обработки контактов и обновил Message…
ink-developer Dec 23, 2025
6995648
Сделал нормальные примеры
ink-developer Dec 24, 2025
46d269b
Добавил список контактов
ink-developer Dec 24, 2025
b519264
Бамп версии
ink-developer Dec 24, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
236 changes: 21 additions & 215 deletions examples/example.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,13 +5,14 @@
from typing import Any

import pymax
from pymax import MaxClient, Message, ReactionInfo, SocketMaxClient
from pymax.files import File, Video
from pymax import MaxClient, Message, ReactionInfo, SocketMaxClient, filters
from pymax.files import File, Photo, Video
from pymax.filters import Filters
from pymax.payloads import UserAgentPayload
from pymax.static.enum import AttachType, Opcode
from pymax.types import Chat

phone = "+7903223111"
phone = "+79991234567"
headers = UserAgentPayload(device_type="WEB")

client = MaxClient(
Expand All @@ -24,115 +25,36 @@
client.logger.setLevel(logging.INFO)


@client.on_raw_receive
async def handle_raw_receive(data: dict[str, Any]) -> None:
print(f"Raw data received: {data}")


@client.task(seconds=10)
async def periodic_task() -> None:
# print(f"Periodic task executed at {datetime.datetime.now()}")
...


@client.on_start
async def handle_start() -> None:
print(f"Client started as {client.me.names[0].first_name}!")

chat_id = -1
max_messages = 1000
messages = []
from_time = int(time() * 1000)
while len(messages) < max_messages:
r = await client.fetch_history(chat_id=chat_id, from_time=from_time, backward=30)
if not r:
break
from_time = r[0].time
messages.extend(r)
print(f"First message time: {from_time}, id: {r[0].id}, text: {r[0].text}")
print(f"Last message time: {from_time}, id: {r[-1].id}, text: {r[-1].text}")
print(f"Loaded {len(messages)}/{max_messages} messages...")
# channel = await client.resolve_channel_by_name("fm92")
# if channel:
# print(f"Resolved channel by name: {channel.title}, ID: {channel.id}")
# else:
# print("Channel not found by name.")

# channel = await client.join_channel(link)
# if channel:
# print(f"Joined channel: {channel.title}, ID: {channel.id}")
# else:
# print("Failed to join channel.")
# await client.send_message(
# "Hello! The client has started successfully.",
# chat_id=2265456546456,
# notify=True,
# )
# folder_update = await client.create_folder(
# title="My Folder",
# chat_include=[0],
# )
# print(f"Folder created: {folder_update.folder.title}")
# video_path = "tests2/test.mp4"
# video_file = Video(path=video_path)

# await client.send_message(
# text="Here is the video you requested.",
# chat_id=0,
# attachment=video_file,
# notify=True,
# )
# chat_id = -6970655
# for chat in client.chats:
# if chat.id == chat_id:
# print(f"Found chat: {chat.title}, ID: {chat.id}")
# members_count = chat.participants_count
# marker = 0
# member_list = []
# while len(member_list) < members_count:
# await asyncio.sleep(10)
# r = await client.load_members(
# chat_id=chat_id,
# marker=marker,
# count=200,
# )
# members, marker = r
# member_list.extend(members)
# print(f"Loaded {len(member_list)}/{members_count} members...")
# for member in member_list:
# print(
# f"Member {member.contact.names[0].first_name}, ID: {member.contact.id}"
# )
# r = await client.load_members(chat_id=chat_id, count=50)
# print(f"Loaded {len(r)} members from chat {chat_id}")
# member_list, marker = r
# for member in member_list:
# print(f"Member {member.contact.names[0].first_name}, ID: {member.contact.id}")
@client.on_raw_receive
async def handle_raw_receive(data: dict[str, Any]) -> None:
print(f"Raw data received: {data}")


# @client.on_reaction_change
# async def handle_reaction_change(
# message_id: str, chat_id: int, reaction_info: ReactionInfo
# ) -> None:
# print(
# f"Reaction changed on message {message_id} in chat {chat_id}: "
# f"Total count: {reaction_info.total_count}, "
# f"Your reaction: {reaction_info.your_reaction}, "
# f"Counters: {reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
# )
@client.on_reaction_change
async def handle_reaction_change(
message_id: str, chat_id: int, reaction_info: ReactionInfo
) -> None:
print(
f"Reaction changed on message {message_id} in chat {chat_id}: "
f"Total count: {reaction_info.total_count}, "
f"Your reaction: {reaction_info.your_reaction}, "
f"Counters: {reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
)
Comment on lines +38 to +47
Copy link
Contributor

@coderabbitai coderabbitai bot Dec 24, 2025

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟡 Minor

Potential IndexError when accessing counters[0].

Line 46 accesses reaction_info.counters[0] without verifying that the counters list is non-empty. If a reaction change event arrives with an empty counters list, this will raise an IndexError.

Since this is example code, consider adding a guard or a comment noting this assumption.

🔎 Suggested fix 
 @client.on_reaction_change
 async def handle_reaction_change(
     message_id: str, chat_id: int, reaction_info: ReactionInfo
 ) -> None:
+    counters_info = (
+        f"{reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
+        if reaction_info.counters
+        else "none"
+    )
     print(
         f"Reaction changed on message {message_id} in chat {chat_id}: "
         f"Total count: {reaction_info.total_count}, "
         f"Your reaction: {reaction_info.your_reaction}, "
-        f"Counters: {reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
+        f"Counters: {counters_info}"
     )
📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change
@client.on_reaction_change
async def handle_reaction_change(
message_id: str, chat_id: int, reaction_info: ReactionInfo
) -> None:
print(
f"Reaction changed on message {message_id} in chat {chat_id}: "
f"Total count: {reaction_info.total_count}, "
f"Your reaction: {reaction_info.your_reaction}, "
f"Counters: {reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
)
@client.on_reaction_change
async def handle_reaction_change(
message_id: str, chat_id: int, reaction_info: ReactionInfo
) -> None:
counters_info = (
f"{reaction_info.counters[0].reaction}={reaction_info.counters[0].count}"
if reaction_info.counters
else "none"
)
print(
f"Reaction changed on message {message_id} in chat {chat_id}: "
f"Total count: {reaction_info.total_count}, "
f"Your reaction: {reaction_info.your_reaction}, "
f"Counters: {counters_info}"
)
🤖 Prompt for AI Agents 
In examples/example.py around lines 38 to 47, the example prints
reaction_info.counters[0] without checking that reaction_info.counters is
non-empty which can raise IndexError; update the handler to guard against an
empty counters list (e.g., check len(reaction_info.counters) > 0 before
accessing index 0 or select a safe default when empty) or add a brief comment
explaining the assumption so the example is safe and clear.



# @client.on_chat_update
# async def handle_chat_update(chat: Chat) -> None:
# print(f"Chat updated: {chat.id}, new title: {chat.title}")
@client.on_chat_update
async def handle_chat_update(chat: Chat) -> None:
print(f"Chat updated: {chat.id}, new title: {chat.title}")


@client.on_message()
@client.on_message(Filters.chat(0) & Filters.text("hello"))
async def handle_message(message: Message) -> None:
print(f"New message in chat {message.chat_id} from {message.sender}: {message.text}")
# if message.link and message.link.message.attaches:
# for attach in message.link.message.attaches:
# print(f"Link attach type: {attach.type}")


@client.on_message_edit()
Expand All @@ -145,122 +67,6 @@ async def handle_deleted_message(message: Message) -> None:
print(f"Deleted message in chat {message.chat_id}: {message.id}")


# async def login_flow_test():
# await client.connect()
# temp_token = await client.request_code(phone)
# code = input("Введите код: ").strip()
# await client.login_with_code(temp_token, code)


# asyncio.run(login_flow_test())

# @client.on_message(filter=Filter(chat_id=0))
# async def handle_message(message: Message) -> None:
# print(str(message.sender) + ": " + message.text)


# @client.on_message_edit()
# async def handle_edited_message(message: Message) -> None:
# print(f"Edited message in chat {message.chat_id}: {message.text}")


# @client.on_message_delete()
# async def handle_deleted_message(message: Message) -> None:
# print(f"Deleted message in chat {message.chat_id}: {message.id}")


# @client.on_start
# async def handle_start() -> None:
# print(f"Client started successfully at {datetime.datetime.now()}!")
# print(client.me.id)

# await client.send_message(
# "Hello, this is a test message sent upon client start!",
# chat_id=23424,
# notify=True,
# )
# file_path = "ruff.toml"
# file = File(path=file_path)
# msg = await client.send_message(
# text="Here is the file you requested.",
# chat_id=0,
# attachment=file,
# notify=True,
# )
# if msg:
# print(f"File sent successfully in message ID: {msg.id}")
# history = await client.fetch_history(chat_id=0)
# if history:
# for message in history:
# if message.attaches:
# for attach in message.attaches:
# if attach.type == AttachType.AUDIO:
# print(attach.url)
# chat = await client.rework_invite_link(chat_id=0)
# print(chat.link)
# text = """
# **123**
# *123*
# __123__
# ~~123~~
# """
# message = await client.send_message(text, chat_id=0, notify=True)
# react_info = await client.add_reaction(
# chat_id=0, message_id="115368067020359151", reaction="👍"
# )
# if react_info:
# print("Reaction added!")
# print(react_info.total_count)
# react_info = await client.get_reactions(
# chat_id=0, message_ids=["115368067020359151"]
# )
# if react_info:
# print("Reactions fetched!")
# for msg_id, info in react_info.items():
# print(f"Message ID: {msg_id}, Total Reactions: {info.total_count}")
# react_info = await client.remove_reaction(
# chat_id=0, message_id="115368067020359151"
# )
# if react_info:
# print("Reaction removed!")
# print(react_info.total_count)
# print(client.dialogs)

# if history:
# for message in history:
# if message.link:
# print(message.link.chat_id)
# print(message.link.message.text)
# for attach in message.attaches:
# if attach.type == AttachType.CONTROL:
# print(attach.event)
# print(attach.extra)
# if attach.type == AttachType.VIDEO:
# print(message)
# vid = await client.get_video_by_id(
# chat_id=0,
# video_id=attach.video_id,
# message_id=message.id,
# )
# print(vid.url)
# elif attach.type == AttachType.FILE:
# file = await client.get_file_by_id(
# chat_id=0,
# file_id=attach.file_id,
# message_id=message.id,
# )
# print(file.url)
# print(client.me.names[0].first_name)
# user = await client.get_user(client.me.id)

# photo1 = Photo(path="tests/test.jpeg")
# photo2 = Photo(path="tests/test.jpg")

# await client.send_message(
# "Hello with photo!", chat_id=0, photos=[photo1, photo2], notify=True
# )


if __name__ == "__main__":
try:
asyncio.run(client.start())
Expand Down
51 changes: 0 additions & 51 deletions examples/flt_test.py
View file
Open in desktop

This file was deleted.

51 changes: 0 additions & 51 deletions examples/large_file_upload.py
View file
Open in desktop

This file was deleted.

Loading