From 45c2ef2a577382fb9d92a8c41a50424b94c75281 Mon Sep 17 00:00:00 2001 From: Alexey Polyakov Date: Tue, 10 Mar 2026 18:51:26 +0300 Subject: [PATCH] =?UTF-8?q?=D0=98=D1=81=D0=BA=D0=BB=D1=8E=D1=87=D0=B0?= =?UTF-8?q?=D0=B5=D0=BC=20=D1=82=D0=BE=D0=BB=D1=8C=D0=BA=D0=BE=20=D0=BE?= =?UTF-8?q?=D1=88=D0=B8=D0=B1=D0=BA=D1=83=20=D0=B2=D0=B0=D0=BB=D0=B8=D0=B4?= =?UTF-8?q?=D0=B0=D1=86=D0=B8=D0=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/oneme_tcp/processors.py | 47 ++++++++++++++++++++++++------------- 1 file changed, 31 insertions(+), 16 deletions(-) diff --git a/src/oneme_tcp/processors.py b/src/oneme_tcp/processors.py index 199c3ea..687595f 100644 --- a/src/oneme_tcp/processors.py +++ b/src/oneme_tcp/processors.py @@ -48,8 +48,9 @@ class Processors: # Валидируем данные пакета try: HelloPayloadModel.model_validate(payload) - except Exception as e: - await self._send_error(seq, self.proto.HELLO, self.error_types.INVALID_PAYLOAD, writer) + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") + await self._send_error(seq, self.proto.SESSION_INIT, self.error_types.INVALID_PAYLOAD, writer) return None, None # Получаем данные из пакета @@ -86,7 +87,8 @@ class Processors: # Валидируем данные пакета try: PingPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.PING, self.error_types.INVALID_PAYLOAD, writer) return @@ -115,7 +117,8 @@ class Processors: # Валидируем данные пакета try: RequestCodePayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.AUTH_REQUEST, self.error_types.INVALID_PAYLOAD, writer) return @@ -174,7 +177,8 @@ class Processors: # Валидируем данные пакета try: VerifyCodePayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.AUTH, self.error_types.INVALID_PAYLOAD, writer) return @@ -263,7 +267,8 @@ class Processors: # Валидируем данные пакета try: LoginPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.LOGIN, self.error_types.INVALID_PAYLOAD, writer) return @@ -365,7 +370,8 @@ class Processors: # Валидируем данные пакета try: AssetsPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.ASSETS_UPDATE, self.error_types.INVALID_PAYLOAD, writer) return @@ -390,7 +396,8 @@ class Processors: # Валидируем данные пакета try: GetCallHistoryPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.VIDEO_CHAT_HISTORY, self.error_types.INVALID_PAYLOAD, writer) return @@ -417,7 +424,8 @@ class Processors: # Валидируем данные пакета try: SendMessagePayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.MSG_SEND, self.error_types.INVALID_PAYLOAD, writer) return @@ -529,7 +537,8 @@ class Processors: # Валидируем данные пакета try: SyncFoldersPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.FOLDERS_GET, self.error_types.INVALID_PAYLOAD, writer) return @@ -597,7 +606,8 @@ class Processors: # Валидируем данные пакета try: SearchUsersPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.CONTACT_INFO, self.error_types.INVALID_PAYLOAD, writer) return @@ -658,7 +668,8 @@ class Processors: # Валидируем данные пакета try: SearchChatsPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.CHAT_INFO, self.error_types.INVALID_PAYLOAD, writer) return @@ -731,7 +742,8 @@ class Processors: # Валидируем данные пакета try: SearchByPhonePayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.CONTACT_INFO_BY_PHONE, self.error_types.INVALID_PAYLOAD, writer) return @@ -800,7 +812,8 @@ class Processors: # Валидируем данные пакета try: GetCallTokenPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.OK_TOKEN, self.error_types.INVALID_PAYLOAD, writer) return @@ -813,7 +826,8 @@ class Processors: # Валидируем данные пакета try: TypingPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.MSG_TYPING, self.error_types.INVALID_PAYLOAD, writer) return @@ -867,7 +881,8 @@ class Processors: # Валидируем данные пакета try: ComplainReasonsGetPayloadModel.model_validate(payload) - except Exception as e: + except pydantic.ValidationError as error: + self.logger.error(f"Возникли ошибки при валидации пакета: {error}") await self._send_error(seq, self.proto.COMPLAIN_REASONS_GET, self.error_types.INVALID_PAYLOAD, writer) return