From 32a88e8b0553ead5edf07870aee5e511729b561b Mon Sep 17 00:00:00 2001 From: WowInceptionGood <143893762+WowInceptionGood@users.noreply.github.com> Date: Tue, 10 Mar 2026 13:55:50 +0000 Subject: [PATCH 1/8] Update README --- docs/proto/oneme_tcp.md | 1 + readme.md | 7 +++++++ 2 files changed, 8 insertions(+) create mode 100644 docs/proto/oneme_tcp.md diff --git a/docs/proto/oneme_tcp.md b/docs/proto/oneme_tcp.md new file mode 100644 index 0000000..30404ce --- /dev/null +++ b/docs/proto/oneme_tcp.md @@ -0,0 +1 @@ +TODO \ No newline at end of file diff --git a/readme.md b/readme.md index e3788d7..a98d6ce 100644 --- a/readme.md +++ b/readme.md @@ -1,3 +1,10 @@ +> [!Caution] +> +> Проект находится на ранней стадии разработки и вероятно полон багов. +> +> Использование в профессиональных средах не рекомендовано. + + # OpenMAX Эмулятор сервера MAX и ТамТам From 4bd632e6df3b90bb0cd99cb998e8a6a97bce49f4 Mon Sep 17 00:00:00 2001 From: Alexey Polyakov Date: Tue, 10 Mar 2026 18:21:59 +0300 Subject: [PATCH 2/8] =?UTF-8?q?=D0=9C=D0=B5=D0=BB=D0=BA=D0=B8=D0=B5=20?= =?UTF-8?q?=D0=BF=D1=80=D0=B0=D0=B2=D0=BA=D0=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- readme.md | 2 ++ src/common/tools.py | 53 +++++++++++++++---------------------- src/oneme_tcp/processors.py | 8 ++++-- 3 files changed, 30 insertions(+), 33 deletions(-) diff --git a/readme.md b/readme.md index a98d6ce..5165f10 100644 --- a/readme.md +++ b/readme.md @@ -22,6 +22,8 @@ https://t.me/openmax_alerts Клиент может быть практически любым, главное условие - чтобы он был совместим с официальным сервером (`api.oneme.ru` / `api.tamtam.chat`). +На данный момент с сервером может работать последняя версия MAX (26.7.1), однако все тесты проходят на версии 26.5.0. + # Установка 1. Склонируйте репозиторий diff --git a/src/common/tools.py b/src/common/tools.py index 5a04102..70843c4 100644 --- a/src/common/tools.py +++ b/src/common/tools.py @@ -102,20 +102,14 @@ class Tools: # Выносим результат в лист chats.append( - { - "id": row.get("id"), - "type": row.get("type"), - "status": "ACTIVE", - "owner": row.get("owner"), - "participants": participants, - "lastMessage": message, - "lastEventTime": messageTime, - "lastDelayedUpdateTime": 0, - "lastFireDelayedErrorTime": 0, - "created": 1, - "joinTime": 1, - "modified": messageTime - } + self.generate_chat( + row.get("id"), + row.get("owner"), + row.get("type"), + participants, + message, + messageTime + ) ) # Получаем последнее сообщение из избранного @@ -123,24 +117,19 @@ class Tools: senderId, db_pool ) + # ID избранного + chatId = senderId ^ senderId + # Хардкодим в лист чатов избранное chats.append( - { - "id": 0, - "type": "DIALOG", - "status": "ACTIVE", - "owner": senderId, - "participants": { - str(senderId): 0 # if not messageTime else messageTime - }, - "lastMessage": message, - "lastEventTime": messageTime, - "lastDelayedUpdateTime": 0, - "lastFireDelayedErrorTime": 0, - "created": 1, - "joinTime": 1, - "modified": messageTime - } + self.generate_chat( + chatId, + senderId, + "DIALOG", + [senderId], + message, + messageTime + ) ) return chats @@ -185,9 +174,11 @@ class Tools: "time": int(row.get("time")), "type": row.get("type"), "sender": row.get("sender"), + "cid": int(row.get("cid")), "text": row.get("text"), "attaches": json.loads(row.get("attaches")), - # "reactionInfo": {} + "elements": json.loads(row.get("elements")), + "reactionInfo": {} } # Возвращаем diff --git a/src/oneme_tcp/processors.py b/src/oneme_tcp/processors.py index e3f0a4f..199c3ea 100644 --- a/src/oneme_tcp/processors.py +++ b/src/oneme_tcp/processors.py @@ -445,7 +445,7 @@ class Processors: chatId = userId ^ senderId # Если клиент хочет отправить сообщение в избранное, - # то выставляем ID чата 0 + # то выставляем в качестве ID чата ID отправителя # (А ещё используем это, если клиент вообще ничего не указал) if chatId == 0 or not chatId: chatId = senderId @@ -491,7 +491,8 @@ class Processors: "sender": senderId, "cid": cid, "text": text, - "attaches": attaches + "attaches": attaches, + "elements": elements } # Отправляем событие всем участникам чата @@ -700,6 +701,9 @@ class Processors: senderId, self.db_pool ) + # ID избранного + chatId = senderId ^ senderId + # Добавляем чат в список chats.append( self.tools.generate_chat( From cab75a58f877ac778597f6d065189d974f12666d Mon Sep 17 00:00:00 2001 From: relyay Date: Tue, 10 Mar 2026 21:19:54 +0300 Subject: [PATCH 3/8] Merge pull request #9 from relyay/fix Some fixes --- src/tamtam_tcp/processors.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/tamtam_tcp/processors.py b/src/tamtam_tcp/processors.py index 5faa5e7..c13aba1 100644 --- a/src/tamtam_tcp/processors.py +++ b/src/tamtam_tcp/processors.py @@ -1,4 +1,5 @@ -import hashlib, secrets, random, time, logging, json +import hashlib, secrets, random, time, logging, json # PEP-8 по приколу сделан >_< +import re from common.static import Static from common.tools import Tools from tamtam_tcp.proto import Proto @@ -76,17 +77,17 @@ class Processors: return # Извлекаем телефон из пакета - phone = payload.get("phone").replace("+", "").replace(" ", "").replace("-", "") + phone = re.sub(r'\D', '', payload.get("phone", "")) # Не хардкодим, через регулярки # Генерируем токен с кодом - code = str(random.randint(000000, 999999)) + code = f"{secrets.randbelow(1_000_000):06d}" # Старая версия ненадежна, могла отбросить ведущие нули или вообще интерпритировать как систему счисления с основанием 8 token = secrets.token_urlsafe(128) # Хешируем code_hash = hashlib.sha256(code.encode()).hexdigest() token_hash = hashlib.sha256(token.encode()).hexdigest() - # Время истечения токена + # Срок жизни токена (5 минут) expires = int(time.time()) + 300 # Ищем пользователя, и если он существует, сохраняем токен From 917db804605750679af0f2a3b5e9dabfaf179589 Mon Sep 17 00:00:00 2001 From: devreal95 Date: Tue, 10 Mar 2026 21:42:11 +0300 Subject: [PATCH 4/8] Update config.py (#10) --- src/oneme_tcp/config.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/oneme_tcp/config.py b/src/oneme_tcp/config.py index 39195db..c9ff193 100644 --- a/src/oneme_tcp/config.py +++ b/src/oneme_tcp/config.py @@ -179,7 +179,7 @@ class OnemeConfig: "moscow-theme-enabled": True, "msg-get-reactions-page-size": 40, "music-files-enabled": False, - "mytracker-enabled": True, + "mytracker-enabled": False, "net-client-dns-enabled": True, "net-session-suppress-bad-disconnected-state": True, "net-stat-config": [ From 4d82f55b798857073f155d376b1b876ea2e47a05 Mon Sep 17 00:00:00 2001 From: relyay Date: Tue, 10 Mar 2026 21:59:44 +0300 Subject: [PATCH 5/8] Fix (#11) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * Улучшена генерация кода, пояснения в некоторых участках, очистка номера телефона через регулярные выражения :> * Именовать переменные snake_case стоит везде, даже если ты достаешь заголовки в такомСтиле if not object использовать предпочтительнее, т.к. он обрабатывает более широкие случаи, когда достать данные не получилось --- src/tamtam_tcp/processors.py | 67 +++++++++++++++++++++--------------- 1 file changed, 40 insertions(+), 27 deletions(-) diff --git a/src/tamtam_tcp/processors.py b/src/tamtam_tcp/processors.py index c13aba1..0f7977b 100644 --- a/src/tamtam_tcp/processors.py +++ b/src/tamtam_tcp/processors.py @@ -1,12 +1,19 @@ -import hashlib, secrets, random, time, logging, json # PEP-8 по приколу сделан >_< +import hashlib +import secrets +import time +import logging +import json import re from common.static import Static from common.tools import Tools from tamtam_tcp.proto import Proto from tamtam_tcp.models import * + class Processors: - def __init__(self, db_pool=None, clients={}, send_event=None): + def __init__(self, db_pool=None, clients=None, send_event=None): + if clients is None: + clients = {} # Более правильная логика self.static = Static() self.proto = Proto() self.tools = Tools() @@ -28,11 +35,11 @@ class Processors: "message": "Unknown error", "title": "Неизвестная ошибка" }) - + packet = self.proto.pack_packet( cmd=self.proto.CMD_ERR, seq=seq, opcode=opcode, payload=payload ) - + await self._send(writer, packet) async def process_hello(self, payload, seq, writer): @@ -43,10 +50,10 @@ class Processors: except Exception as e: await self._send_error(seq, self.proto.HELLO, self.error_types.INVALID_PAYLOAD, writer) return None, None - + # Получаем данные из пакета - deviceType = payload.get("userAgent").get("deviceType") - deviceName = payload.get("userAgent").get("deviceName") + device_type = payload.get("userAgent").get("deviceType") + device_name = payload.get("userAgent").get("deviceName") # Данные пакета payload = { @@ -65,8 +72,8 @@ class Processors: # Отправляем await self._send(writer, packet) - return deviceType, deviceName - + return device_type, device_name + async def process_request_code(self, payload, seq, writer): """Обработчик запроса кода""" # Валидируем данные пакета @@ -77,10 +84,10 @@ class Processors: return # Извлекаем телефон из пакета - phone = re.sub(r'\D', '', payload.get("phone", "")) # Не хардкодим, через регулярки + phone = re.sub(r'\D', '', payload.get("phone", "")) # Не хардкодим, через регулярки # Генерируем токен с кодом - code = f"{secrets.randbelow(1_000_000):06d}" # Старая версия ненадежна, могла отбросить ведущие нули или вообще интерпритировать как систему счисления с основанием 8 + code = f"{secrets.randbelow(1_000_000):06d}" # Старая версия ненадежна, могла отбросить ведущие нули или вообще интерпритировать как систему счисления с основанием 8 token = secrets.token_urlsafe(128) # Хешируем @@ -96,12 +103,14 @@ class Processors: await cursor.execute("SELECT * FROM users WHERE phone = %s", (phone,)) user = await cursor.fetchone() - if user is None: + if not user: await self._send_error(seq, self.proto.REQUEST_CODE, self.error_types.USER_NOT_FOUND, writer) return # Сохраняем токен - await cursor.execute("INSERT INTO auth_tokens (phone, token_hash, code_hash, expires, state) VALUES (%s, %s, %s, %s, %s)", (phone, token_hash, code_hash, expires, "started",)) + await cursor.execute( + "INSERT INTO auth_tokens (phone, token_hash, code_hash, expires, state) VALUES (%s, %s, %s, %s, %s)", + (phone, token_hash, code_hash, expires, "started",)) # Данные пакета payload = { @@ -144,10 +153,11 @@ class Processors: async with self.db_pool.acquire() as conn: async with conn.cursor() as cursor: # Ищем токен - await cursor.execute("SELECT * FROM auth_tokens WHERE token_hash = %s AND expires > UNIX_TIMESTAMP()", (hashed_token,)) + await cursor.execute("SELECT * FROM auth_tokens WHERE token_hash = %s AND expires > UNIX_TIMESTAMP()", + (hashed_token,)) stored_token = await cursor.fetchone() - if stored_token is None: + if not stored_token: await self._send_error(seq, self.proto.VERIFY_CODE, self.error_types.CODE_EXPIRED, writer) return @@ -155,13 +165,14 @@ class Processors: if stored_token.get("code_hash") != hashed_code: await self._send_error(seq, self.proto.VERIFY_CODE, self.error_types.INVALID_CODE, writer) return - + # Ищем аккаунт await cursor.execute("SELECT * FROM users WHERE phone = %s", (stored_token.get("phone"),)) account = await cursor.fetchone() # Обновляем состояние токена - await cursor.execute("UPDATE auth_tokens set state = %s WHERE token_hash = %s", ("verified", hashed_token,)) + await cursor.execute("UPDATE auth_tokens set state = %s WHERE token_hash = %s", + ("verified", hashed_token,)) # # Создаем сессию # await cursor.execute( @@ -171,9 +182,9 @@ class Processors: # Генерируем профиль # Аватарка с биографией - photoId = None if not account.get("avatar_id") else int(account.get("avatar_id")) - avatar_url = None if not photoId else self.config.avatar_base_url + photoId - description = None if not account.get("description") else account.get("description") + photo_id = int(account["avatar_id"]) if account.get("avatar_id") else None + avatar_url = f"{self.config.avatar_base_url}{photo_id}" if photo_id else None + description = account.get("description") # Собираем данные пакета payload = { @@ -181,7 +192,7 @@ class Processors: id=account.get("id"), phone=int(account.get("phone")), avatarUrl=avatar_url, - photoId=photoId, + photoId=photo_id, updateTime=int(account.get("updatetime")), firstName=account.get("firstname"), lastName=account.get("lastname"), @@ -235,7 +246,8 @@ class Processors: async with self.db_pool.acquire() as conn: async with conn.cursor() as cursor: # Ищем токен - await cursor.execute("SELECT * FROM auth_tokens WHERE token_hash = %s AND expires > UNIX_TIMESTAMP()", (hashed_token,)) + await cursor.execute("SELECT * FROM auth_tokens WHERE token_hash = %s AND expires > UNIX_TIMESTAMP()", + (hashed_token,)) stored_token = await cursor.fetchone() if stored_token is None: @@ -256,12 +268,13 @@ class Processors: # Создаем сессию await cursor.execute( "INSERT INTO tokens (phone, token_hash, device_type, device_name, location, time) VALUES (%s, %s, %s, %s, %s, %s)", - (stored_token.get("phone"), hashed_login, deviceType, deviceName, "Epstein Island", int(time.time()),) + (stored_token.get("phone"), hashed_login, deviceType, deviceName, "Epstein Island", + int(time.time()),) ) # Аватарка с биографией - photoId = None if not account.get("avatar_id") else int(account.get("avatar_id")) - avatar_url = None if not photoId else self.config.avatar_base_url + photoId + photo_id = None if not account.get("avatar_id") else int(account.get("avatar_id")) + avatar_url = None if not photo_id else self.config.avatar_base_url + photo_id description = None if not account.get("description") else account.get("description") # Собираем данные пакета @@ -271,7 +284,7 @@ class Processors: id=account.get("id"), phone=int(account.get("phone")), avatarUrl=avatar_url, - photoId=photoId, + photoId=photo_id, updateTime=int(account.get("updatetime")), firstName=account.get("firstname"), lastName=account.get("lastname"), @@ -291,4 +304,4 @@ class Processors: cmd=self.proto.CMD_OK, seq=seq, opcode=self.proto.FINAL_AUTH, payload=payload ) - await self._send(writer, packet) \ No newline at end of file + await self._send(writer, packet) From 573825e195bd71f7090aa09c773608cc80614661 Mon Sep 17 00:00:00 2001 From: WowInceptionGood <143893762+WowInceptionGood@users.noreply.github.com> Date: Tue, 10 Mar 2026 21:40:49 +0000 Subject: [PATCH 6/8] =?UTF-8?q?=D0=9D=D0=B0=D1=87=D0=B0=D0=BB=20=D0=BF?= =?UTF-8?q?=D0=B8=D1=81=D0=B0=D1=82=D1=8C=20=D0=B4=D0=BE=D0=BA=D1=83=D0=BC?= =?UTF-8?q?=D0=B5=D0=BD=D1=82=D0=B0=D1=86=D0=B8=D1=8E=20=D0=BF=D1=80=D0=BE?= =?UTF-8?q?=D1=82=D0=BE=20=D0=A2=D0=B0=D0=BC=D0=A2=D0=B0=D0=BC=D0=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/proto/tamtam_ws.md | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 docs/proto/tamtam_ws.md diff --git a/docs/proto/tamtam_ws.md b/docs/proto/tamtam_ws.md new file mode 100644 index 0000000..42910e6 --- /dev/null +++ b/docs/proto/tamtam_ws.md @@ -0,0 +1,29 @@ +# Описание протокола TamTam по Websocket + +## Основная информация +В веб версии мессенджера ТамТам используется протокол, работающий поверх Websocket. + +Пакеты в этом протоколе являются JSON данными, закодированными в текст (UTF-8). + +Структура пакета: +```json +{ + ver: int, + cmd: int, + seq: int, + opcode: int, + payload: {} +} +``` + +ver - версия протокола +cmd - определяет, от кого отправлен пакет. клиент - 0, сервер - 1 +seq - порядковый номер пакета (сервер дублирует его из запроса клиента) +opcode - команда +payload - полезная нагрузка команды + +## Команды протокола + +### PING (1) +Клиент отправляет пакет с командой PING и пустой нагрузкой серверу раз в x секунд. +Сервер отвечает ему тем же. \ No newline at end of file From fbb451cd39db807677da6d1f5c9abd3307685c21 Mon Sep 17 00:00:00 2001 From: WowInceptionGood <143893762+WowInceptionGood@users.noreply.github.com> Date: Tue, 10 Mar 2026 21:41:57 +0000 Subject: [PATCH 7/8] =?UTF-8?q?=D0=98=D1=81=D0=BF=D1=80=D0=B0=D0=B2=D0=BB?= =?UTF-8?q?=D0=B5=D0=BD=D0=B8=D0=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/proto/tamtam_ws.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/proto/tamtam_ws.md b/docs/proto/tamtam_ws.md index 42910e6..8f62dfe 100644 --- a/docs/proto/tamtam_ws.md +++ b/docs/proto/tamtam_ws.md @@ -3,10 +3,10 @@ ## Основная информация В веб версии мессенджера ТамТам используется протокол, работающий поверх Websocket. -Пакеты в этом протоколе являются JSON данными, закодированными в текст (UTF-8). +Пакеты в этом протоколе являются JSON данными, закодированными в текст. Структура пакета: -```json +``` { ver: int, cmd: int, From fb46d06aabadb96fc4a4ec31c7b6252dd0108a81 Mon Sep 17 00:00:00 2001 From: WowInceptionGood <143893762+WowInceptionGood@users.noreply.github.com> Date: Tue, 10 Mar 2026 21:43:25 +0000 Subject: [PATCH 8/8] =?UTF-8?q?=D0=9B=D0=B0=D0=B4=D0=BD=D0=BE=20=D0=BF?= =?UTF-8?q?=D0=BE=D1=81=D0=BB=D0=B5=D0=B4=D0=BD=D0=B5=D0=B5=20=D0=B8=D1=81?= =?UTF-8?q?=D0=BF=D1=80=D0=B0=D0=B2=D0=BB=D0=B5=D0=BD=D0=B8=D0=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docs/proto/tamtam_ws.md | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/docs/proto/tamtam_ws.md b/docs/proto/tamtam_ws.md index 8f62dfe..bd4e712 100644 --- a/docs/proto/tamtam_ws.md +++ b/docs/proto/tamtam_ws.md @@ -3,7 +3,7 @@ ## Основная информация В веб версии мессенджера ТамТам используется протокол, работающий поверх Websocket. -Пакеты в этом протоколе являются JSON данными, закодированными в текст. +Пакеты в этом протоколе являются текстовыми JSON данными. Структура пакета: ``` @@ -16,14 +16,14 @@ } ``` -ver - версия протокола -cmd - определяет, от кого отправлен пакет. клиент - 0, сервер - 1 -seq - порядковый номер пакета (сервер дублирует его из запроса клиента) -opcode - команда -payload - полезная нагрузка команды +* ver - версия протокола +* cmd - определяет, от кого отправлен пакет. клиент - 0, сервер - 1 +* seq - порядковый номер пакета (сервер дублирует его из запроса клиента) +* opcode - команда +* payload - полезная нагрузка команды ## Команды протокола ### PING (1) -Клиент отправляет пакет с командой PING и пустой нагрузкой серверу раз в x секунд. +Клиент периодически отправляет пакет с командой PING и пустой нагрузкой серверу. Сервер отвечает ему тем же. \ No newline at end of file