Compare commits

..

No commits in common. "cab75a58f877ac778597f6d065189d974f12666d" and "1984e018eedd15e16a62a6dd0f52902cd6e9ea45" have entirely different histories.

6 changed files with 39 additions and 53 deletions

View File

@ -1 +0,0 @@
TODO

View File

@ -1,10 +1,3 @@
> [!Caution]
>
> Проект находится на ранней стадии разработки и вероятно полон багов.
>
> Использование в профессиональных средах не рекомендовано.
# OpenMAX # OpenMAX
Эмулятор сервера MAX и ТамТам Эмулятор сервера MAX и ТамТам
@ -22,8 +15,6 @@ https://t.me/openmax_alerts
Клиент может быть практически любым, главное условие - чтобы он был совместим с официальным сервером (`api.oneme.ru` / `api.tamtam.chat`). Клиент может быть практически любым, главное условие - чтобы он был совместим с официальным сервером (`api.oneme.ru` / `api.tamtam.chat`).
На данный момент с сервером может работать последняя версия MAX (26.7.1), однако все тесты проходят на версии 26.5.0.
# Установка # Установка
1. Склонируйте репозиторий 1. Склонируйте репозиторий

View File

@ -109,15 +109,7 @@ class Static:
### Причины для жалоб ### Причины для жалоб
COMPLAIN_REASONS = [ COMPLAIN_REASONS = [
"Порнография или эротика", # TODO: Было бы очень замечательно заполнить этот лист причинами для жалоб
"Экстремизм или терроризм",
"Фейк",
"Мошенничество",
"Нарушение авторского права",
"Шокирующий контент",
"Персональные данные",
"Незаконная услуга",
"Это законно, но надо удалить"
] ]
### Заглушка для папок ### Заглушка для папок
@ -168,4 +160,4 @@ class Static:
"SAFE_MODE": False, "SAFE_MODE": False,
"M_CALL_PUSH_NOTIFICATION": "ON", "M_CALL_PUSH_NOTIFICATION": "ON",
"QUICK_REPLY": False "QUICK_REPLY": False
} }

View File

@ -102,14 +102,20 @@ class Tools:
# Выносим результат в лист # Выносим результат в лист
chats.append( chats.append(
self.generate_chat( {
row.get("id"), "id": row.get("id"),
row.get("owner"), "type": row.get("type"),
row.get("type"), "status": "ACTIVE",
participants, "owner": row.get("owner"),
message, "participants": participants,
messageTime "lastMessage": message,
) "lastEventTime": messageTime,
"lastDelayedUpdateTime": 0,
"lastFireDelayedErrorTime": 0,
"created": 1,
"joinTime": 1,
"modified": messageTime
}
) )
# Получаем последнее сообщение из избранного # Получаем последнее сообщение из избранного
@ -117,19 +123,24 @@ class Tools:
senderId, db_pool senderId, db_pool
) )
# ID избранного
chatId = senderId ^ senderId
# Хардкодим в лист чатов избранное # Хардкодим в лист чатов избранное
chats.append( chats.append(
self.generate_chat( {
chatId, "id": 0,
senderId, "type": "DIALOG",
"DIALOG", "status": "ACTIVE",
[senderId], "owner": senderId,
message, "participants": {
messageTime str(senderId): 0 # if not messageTime else messageTime
) },
"lastMessage": message,
"lastEventTime": messageTime,
"lastDelayedUpdateTime": 0,
"lastFireDelayedErrorTime": 0,
"created": 1,
"joinTime": 1,
"modified": messageTime
}
) )
return chats return chats
@ -174,11 +185,9 @@ class Tools:
"time": int(row.get("time")), "time": int(row.get("time")),
"type": row.get("type"), "type": row.get("type"),
"sender": row.get("sender"), "sender": row.get("sender"),
"cid": int(row.get("cid")),
"text": row.get("text"), "text": row.get("text"),
"attaches": json.loads(row.get("attaches")), "attaches": json.loads(row.get("attaches")),
"elements": json.loads(row.get("elements")), # "reactionInfo": {}
"reactionInfo": {}
} }
# Возвращаем # Возвращаем

View File

@ -445,7 +445,7 @@ class Processors:
chatId = userId ^ senderId chatId = userId ^ senderId
# Если клиент хочет отправить сообщение в избранное, # Если клиент хочет отправить сообщение в избранное,
# то выставляем в качестве ID чата ID отправителя # то выставляем ID чата 0
# (А ещё используем это, если клиент вообще ничего не указал) # (А ещё используем это, если клиент вообще ничего не указал)
if chatId == 0 or not chatId: if chatId == 0 or not chatId:
chatId = senderId chatId = senderId
@ -491,8 +491,7 @@ class Processors:
"sender": senderId, "sender": senderId,
"cid": cid, "cid": cid,
"text": text, "text": text,
"attaches": attaches, "attaches": attaches
"elements": elements
} }
# Отправляем событие всем участникам чата # Отправляем событие всем участникам чата
@ -701,9 +700,6 @@ class Processors:
senderId, self.db_pool senderId, self.db_pool
) )
# ID избранного
chatId = senderId ^ senderId
# Добавляем чат в список # Добавляем чат в список
chats.append( chats.append(
self.tools.generate_chat( self.tools.generate_chat(

View File

@ -1,5 +1,4 @@
import hashlib, secrets, random, time, logging, json # PEP-8 по приколу сделан >_< import hashlib, secrets, random, time, logging, json
import re
from common.static import Static from common.static import Static
from common.tools import Tools from common.tools import Tools
from tamtam_tcp.proto import Proto from tamtam_tcp.proto import Proto
@ -77,17 +76,17 @@ class Processors:
return return
# Извлекаем телефон из пакета # Извлекаем телефон из пакета
phone = re.sub(r'\D', '', payload.get("phone", "")) # Не хардкодим, через регулярки phone = payload.get("phone").replace("+", "").replace(" ", "").replace("-", "")
# Генерируем токен с кодом # Генерируем токен с кодом
code = f"{secrets.randbelow(1_000_000):06d}" # Старая версия ненадежна, могла отбросить ведущие нули или вообще интерпритировать как систему счисления с основанием 8 code = str(random.randint(000000, 999999))
token = secrets.token_urlsafe(128) token = secrets.token_urlsafe(128)
# Хешируем # Хешируем
code_hash = hashlib.sha256(code.encode()).hexdigest() code_hash = hashlib.sha256(code.encode()).hexdigest()
token_hash = hashlib.sha256(token.encode()).hexdigest() token_hash = hashlib.sha256(token.encode()).hexdigest()
# Срок жизни токена (5 минут) # Время истечения токена
expires = int(time.time()) + 300 expires = int(time.time()) + 300
# Ищем пользователя, и если он существует, сохраняем токен # Ищем пользователя, и если он существует, сохраняем токен