mirror of
https://github.com/openmax-server/server.git
synced 2026-07-25 15:06:09 +03:00
Compare commits
15 Commits
c5721f3f9e
..
master
| Author | SHA1 | Date | |
|---|---|---|---|
 Inception Time
|
880275eacb | ||
|
Alexey Polyakov
|
fc6ec5eec5 | ||
|
WowInceptionGood
|
c53c3cd195 | ||
|
Alexey Polyakov
|
77da4a1b61 | ||
|
WowInceptionGood
|
f9b6b2c75e | ||
|
WowInceptionGood
|
930a95453f | ||
|
relyay
|
2776051b17 | ||
|
WowInceptionGood
|
1d4cb2d248 | ||
|
WowInceptionGood
|
ba6191d7e3 | ||
|
Alexey Polyakov
|
48c74153ec | ||
|
Alexey Polyakov
|
ea9e4761bc | ||
|
Anatoliy Esherkin
|
e6d693efbd | ||
|
Anatoliy Esherkin
|
dae26f02a8 | ||
|
Anatoliy Esherkin
|
ca652aab03 | ||
|
artemchik12
|
2ce4ac64e2 |
@@ -1 +0,0 @@
|
||||
Проект OpenMAX не принимает правки, написанные с использованием искусственного интеллекта и нейросетевых технологий
|
||||
@@ -0,0 +1,8 @@
|
||||
# Патч MAX для IOS
|
||||
|
||||
1) Распаковываете IPA
|
||||
2) Находите файл MAX в Payload/Max.app
|
||||
3) Открываете hex-редактор и находите api.oneme.ru и меняете на свой
|
||||
При желании можете поменять другие URL
|
||||
URL не должен привышать количество символов которое было у изначального URL!
|
||||
4) Открываете IPA как архив и добавляете патченный файл MAX в Payload/Max.app
|
||||
+3
-2
@@ -1,7 +1,8 @@
|
||||
# Навигация по faq
|
||||
|
||||
## Работа с сервером
|
||||
[Установка сервера](install.md)
|
||||
- [Установка сервера](install.md)
|
||||
|
||||
## Патчинг клиентов
|
||||
[Патч apk](patch_apk.md)
|
||||
- [Патч мобильного клиента для Android](patch_apk.md)
|
||||
- [Патч мобильного клиента для IOS](patch_ipa.md)
|
||||
|
||||
@@ -0,0 +1,11 @@
|
||||
> [!Caution]
|
||||
>
|
||||
> На данной странице представлены инстансы от сторонних разработчиков.
|
||||
>
|
||||
> Используйте на свой страх и риск
|
||||
>
|
||||
|
||||
# Открытые сервера
|
||||
|
||||
* [JustMAX](https://t.me/justmax_official)
|
||||
* [mox.nyako.tk](https://t.me/opengrame/296), порт 443 (регистрация по реальному номеру)
|
||||
@@ -1,6 +1,6 @@
|
||||
> [!Caution]
|
||||
>
|
||||
> Проект находится на ранней стадии разработки и вероятно полон багов.
|
||||
> Проект находится на ранней стадии разработки и, вероятно, полон багов.
|
||||
>
|
||||
> Использование в профессиональных средах не рекомендовано.
|
||||
|
||||
@@ -13,7 +13,7 @@ https://t.me/openmax_alerts
|
||||
# Требования
|
||||
|
||||
- Python 3.12+ (поддержка версий ниже не гарантирована)
|
||||
- MariaDB, MySQL или SQLite
|
||||
- MariaDB, MySQL или SQLite (использование последнего не рекомендуется, так как поддержка ещё в разработке)
|
||||
- Уметь патчить клиент MAX или собирать Komet из исходного кода (естественно с заменой сервера)
|
||||
- Сертификат и приватный ключ X.509 (для тестирования сервера можно сгенерировать самоподписанный: ```openssl req -x509 -newkey rsa:2048 -nodes -keyout key.pem -out cert.pem -days 365```)
|
||||
|
||||
@@ -22,4 +22,6 @@ https://t.me/openmax_alerts
|
||||
Клиент может быть практически любым, главное условие - чтобы он был совместим с официальным сервером (`api.oneme.ru` / `api.tamtam.chat`).
|
||||
|
||||
# Дополнительная информация
|
||||
[Faq](faq/readme.md)
|
||||
- [FAQ](faq/readme.md)
|
||||
- [Документация проекта](https://github.com/openmax-server/docs)
|
||||
- [Публичные сервера](faq/servers.md)
|
||||
|
||||
@@ -49,6 +49,9 @@ class SQLiteConnectionCompat:
|
||||
async def __aexit__(self, exc_type, exc, tb):
|
||||
return False
|
||||
|
||||
async def commit(self):
|
||||
await self.connection.commit()
|
||||
|
||||
def cursor(self):
|
||||
return SQLiteCursorCompat(self.connection)
|
||||
|
||||
|
||||
+23
-19
@@ -39,17 +39,17 @@ class Tools:
|
||||
|
||||
def generate_profile(
|
||||
self,
|
||||
id=1,
|
||||
phone=70000000000,
|
||||
id=None,
|
||||
phone=None,
|
||||
avatarUrl=None,
|
||||
photoId=None,
|
||||
updateTime=0,
|
||||
firstName="Test",
|
||||
lastName="Account",
|
||||
options=[],
|
||||
updateTime=None,
|
||||
firstName=None,
|
||||
lastName=None,
|
||||
options=None,
|
||||
description=None,
|
||||
accountStatus=0,
|
||||
profileOptions=[],
|
||||
accountStatus=None,
|
||||
profileOptions=None,
|
||||
includeProfileOptions=True,
|
||||
username=None,
|
||||
|
||||
@@ -108,31 +108,32 @@ class Tools:
|
||||
|
||||
def generate_profile_tt(
|
||||
self,
|
||||
id=1,
|
||||
phone=70000000000,
|
||||
id=None,
|
||||
phone=None,
|
||||
avatarUrl=None,
|
||||
photoId=None,
|
||||
updateTime=0,
|
||||
firstName="Test",
|
||||
lastName="Account",
|
||||
options=[],
|
||||
updateTime=None,
|
||||
firstName=None,
|
||||
lastName=None,
|
||||
options=None,
|
||||
description=None,
|
||||
username=None,
|
||||
custom_firstname=None,
|
||||
custom_lastname=None
|
||||
custom_lastname=None,
|
||||
blocked=None
|
||||
):
|
||||
# Так как TT не поддерживает фамилию, и если нам ее не передали в функцию
|
||||
# то используем только имя, чтобы избежать None в фамилии
|
||||
if firstName and lastName:
|
||||
name = f"{firstName} {lastName}",
|
||||
name = f"{firstName} {lastName}"
|
||||
else:
|
||||
name = firstName
|
||||
|
||||
# Используем такой же костыль, как и выше
|
||||
if custom_firstname:
|
||||
custom_name = custom_firstname
|
||||
elif custom_firstname and custom_lastname:
|
||||
if custom_firstname and custom_lastname:
|
||||
custom_name = f"{custom_firstname} {custom_lastname}"
|
||||
elif custom_firstname:
|
||||
custom_name = custom_firstname
|
||||
else:
|
||||
custom_name = None
|
||||
|
||||
@@ -163,6 +164,9 @@ class Tools:
|
||||
{"name": custom_name, "type": "CUSTOM"}
|
||||
)
|
||||
|
||||
if blocked:
|
||||
contact["status"] = "BLOCKED"
|
||||
|
||||
return contact
|
||||
|
||||
def generate_chat(
|
||||
|
||||
@@ -22,6 +22,7 @@ class OnemeController(ControllerBase):
|
||||
|
||||
# Выбираем протокол в зависимости от типа подключения
|
||||
proto = self.proto_web if is_web else self.proto_tcp
|
||||
packet = None
|
||||
|
||||
# Не отправляем событие самому себе
|
||||
if writer == eventData.get("writer"):
|
||||
@@ -94,7 +95,9 @@ class OnemeController(ControllerBase):
|
||||
cmd=0, seq=1, opcode=self.opcodes.NOTIF_PRESENCE, payload=payload
|
||||
)
|
||||
|
||||
# Отправляем пакет
|
||||
if not packet:
|
||||
return
|
||||
|
||||
if is_web:
|
||||
await writer.send(packet)
|
||||
else:
|
||||
|
||||
@@ -297,7 +297,7 @@ class AuthProcessors(BaseProcessor):
|
||||
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
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + str(photoId)
|
||||
description = (
|
||||
None if not account.get("description") else account.get("description")
|
||||
)
|
||||
@@ -521,7 +521,7 @@ class AuthProcessors(BaseProcessor):
|
||||
await self._send_error(
|
||||
seq, self.opcodes.LOGIN, self.error_types.INVALID_PAYLOAD, writer
|
||||
)
|
||||
return
|
||||
return None, None, None
|
||||
|
||||
# Чаты, где состоит пользователь
|
||||
chats = []
|
||||
@@ -545,7 +545,7 @@ class AuthProcessors(BaseProcessor):
|
||||
await self._send_error(
|
||||
seq, self.opcodes.LOGIN, self.error_types.INVALID_TOKEN, writer
|
||||
)
|
||||
return
|
||||
return None, None, None
|
||||
|
||||
# Ищем аккаунт пользователя в бд
|
||||
await cursor.execute(
|
||||
@@ -563,7 +563,7 @@ class AuthProcessors(BaseProcessor):
|
||||
# Ищем все чаты, где состоит пользователь
|
||||
await cursor.execute(
|
||||
"SELECT * FROM chat_participants WHERE user_id = %s",
|
||||
(user.get("id")),
|
||||
(user.get("id"),),
|
||||
)
|
||||
user_chats = await cursor.fetchall()
|
||||
|
||||
@@ -578,7 +578,7 @@ class AuthProcessors(BaseProcessor):
|
||||
|
||||
# Аватарка с биографией
|
||||
photoId = None if not user.get("avatar_id") else int(user.get("avatar_id"))
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + photoId
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + str(photoId)
|
||||
description = None if not user.get("description") else user.get("description")
|
||||
|
||||
if self._check_legacy_version(appVersion):
|
||||
|
||||
@@ -153,7 +153,7 @@ class MainProcessors(BaseProcessor):
|
||||
|
||||
# Аватарка с биографией
|
||||
photoId = None if not user.get("avatar_id") else int(user.get("avatar_id"))
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + photoId
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + str(photoId)
|
||||
description = None if not user.get("description") else user.get("description")
|
||||
|
||||
# Генерируем профиль
|
||||
|
||||
@@ -36,7 +36,7 @@ class SearchProcessors(BaseProcessor):
|
||||
if user:
|
||||
# Аватарка с биографией
|
||||
photoId = None if not user.get("avatar_id") else int(user.get("avatar_id"))
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + photoId
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + str(photoId)
|
||||
description = None if not user.get("description") else user.get("description")
|
||||
|
||||
# Получаем данные контакта
|
||||
@@ -129,7 +129,7 @@ class SearchProcessors(BaseProcessor):
|
||||
|
||||
# Аватарка с биографией
|
||||
photoId = None if not user.get("avatar_id") else int(user.get("avatar_id"))
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + photoId
|
||||
avatar_url = None if not photoId else self.config.avatar_base_url + str(photoId)
|
||||
description = None if not user.get("description") else user.get("description")
|
||||
|
||||
# Получаем данные контакта
|
||||
|
||||
@@ -22,6 +22,7 @@ class TTController(ControllerBase):
|
||||
|
||||
# Выбираем протокол в зависимости от типа подключения
|
||||
proto = self.proto_web if is_web else self.proto_tcp
|
||||
packet = None
|
||||
|
||||
# Не отправляем событие самому себе
|
||||
if writer == eventData.get("writer"):
|
||||
@@ -94,7 +95,9 @@ class TTController(ControllerBase):
|
||||
cmd=0, seq=1, opcode=self.opcodes.NOTIF_PRESENCE, payload=payload
|
||||
)
|
||||
|
||||
# Отправляем пакет
|
||||
if not packet:
|
||||
return
|
||||
|
||||
if is_web:
|
||||
await writer.send(packet)
|
||||
else:
|
||||
|
||||
@@ -443,7 +443,7 @@ class AuthProcessors(BaseProcessor):
|
||||
self.logger.error(f"Возникли ошибки при валидации пакета: {e}")
|
||||
await self._send_error(seq, self.opcodes.LOGIN,
|
||||
self.error_types.INVALID_PAYLOAD, writer)
|
||||
return
|
||||
return None, None, None
|
||||
|
||||
# Чаты, где состоит пользователь
|
||||
chats = []
|
||||
@@ -464,7 +464,7 @@ class AuthProcessors(BaseProcessor):
|
||||
if token_data is None:
|
||||
await self._send_error(seq, self.opcodes.LOGIN,
|
||||
self.error_types.INVALID_TOKEN, writer)
|
||||
return
|
||||
return None, None, None
|
||||
|
||||
# Ищем аккаунт пользователя в бд
|
||||
await cursor.execute("SELECT * FROM users WHERE phone = %s", (token_data.get("phone"),))
|
||||
@@ -477,7 +477,7 @@ class AuthProcessors(BaseProcessor):
|
||||
# Ищем все чаты, где состоит пользователь
|
||||
await cursor.execute(
|
||||
"SELECT * FROM chat_participants WHERE user_id = %s",
|
||||
(user.get('id'))
|
||||
(user.get('id'),)
|
||||
)
|
||||
user_chats = await cursor.fetchall()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user