mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2024-11-30 05:13:45 +03:00
70 lines
1.8 KiB
Python
70 lines
1.8 KiB
Python
import urllib.request
|
|
import re
|
|
from threading import Thread
|
|
|
|
from .common import (
|
|
ReadCancelledError, InvalidParameterError, TypeNotFoundError,
|
|
InvalidChecksumError, BrokenAuthKeyError, SecurityError,
|
|
CdnFileTamperedError
|
|
)
|
|
|
|
from .rpc_errors import (
|
|
RPCError, InvalidDCError, BadRequestError, UnauthorizedError,
|
|
ForbiddenError, NotFoundError, FloodError, ServerError, BadMessageError
|
|
)
|
|
|
|
from .rpc_errors_303 import *
|
|
from .rpc_errors_400 import *
|
|
from .rpc_errors_401 import *
|
|
from .rpc_errors_420 import *
|
|
|
|
|
|
def report_error(code, message, report_method):
|
|
try:
|
|
# Ensure it's signed
|
|
report_method = int.from_bytes(
|
|
report_method.to_bytes(4, 'big'), 'big', signed=True
|
|
)
|
|
url = urllib.request.urlopen(
|
|
'https://rpc.pwrtelegram.xyz?code={}&error={}&method={}'
|
|
.format(code, message, report_method),
|
|
timeout=5
|
|
)
|
|
url.read()
|
|
url.close()
|
|
except:
|
|
"We really don't want to crash when just reporting an error"
|
|
|
|
|
|
def rpc_message_to_error(code, message, report_method=None):
|
|
if report_method is not None:
|
|
Thread(
|
|
target=report_error,
|
|
args=(code, message, report_method)
|
|
).start()
|
|
|
|
errors = {
|
|
303: rpc_errors_303_all,
|
|
400: rpc_errors_400_all,
|
|
401: rpc_errors_401_all,
|
|
420: rpc_errors_420_all
|
|
}.get(code, None)
|
|
|
|
if errors is not None:
|
|
for msg, cls in errors.items():
|
|
m = re.match(msg, message)
|
|
if m:
|
|
extra = int(m.group(1)) if m.groups() else None
|
|
return cls(extra=extra)
|
|
|
|
elif code == 403:
|
|
return ForbiddenError(message)
|
|
|
|
elif code == 404:
|
|
return NotFoundError(message)
|
|
|
|
elif code == 500:
|
|
return ServerError(message)
|
|
|
|
return RPCError('{} (code {})'.format(message, code))
|