diff --git a/src/python3_anticaptcha/GeeTestTaskProxyless.py b/src/python3_anticaptcha/GeeTestTaskProxyless.py deleted file mode 100644 index 284edfc..0000000 --- a/src/python3_anticaptcha/GeeTestTaskProxyless.py +++ /dev/null @@ -1,153 +0,0 @@ -import time -import asyncio - -import aiohttp -import requests - -from python3_anticaptcha import app_key, create_task_url, get_sync_result, get_async_result - - -class GeeTestTaskProxyless: - def __init__( - self, - anticaptcha_key: str, - websiteURL: str, - gt: str, - sleep_time: int = 10, - callbackUrl: str = None, - ): - """ - Модуль отвечает за решение GeeTestTaskProxyless - :param anticaptcha_key: Ключ от АнтиКапчи - :param websiteURL: Адрес страницы на которой решается капча - :param gt: Ключ-индентификатор капчи на целевой странице - :param sleep_time: Время ожидания решения - :param callbackUrl: URL для решения капчи с ответом через callback - """ - if sleep_time < 10: - raise ValueError(f"Param `sleep_time` must be greater than 10. U set - {sleep_time}") - self.sleep_time = sleep_time - - # Пайлоад для создания задачи - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "GeeTestTaskProxyless", "websiteURL": websiteURL, "gt": gt}, - "softId": app_key, - } - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # пайлоад для получения ответа сервиса - self.result_payload = {"clientKey": anticaptcha_key} - - def __enter__(self): - return self - - def __exit__(self, exc_type, exc_value, traceback): - if exc_type: - return False - return True - - # Работа с капчёй - def captcha_handler(self, challenge: str, **kwargs) -> dict: - """ - Метод получает ссылку изображение для задания - :param challenge: Переменный токен который необходимо обновлять каждый раз перед созданием задачи - :param kwargs: Дополнительные параметры для `requests.post(....)`. - :return: Возвращает ответ сервера в виде JSON(ответ так же можно глянуть в документации антикапчи) - """ - self.task_payload["task"].update({"challenge": challenge}) - # Отправляем на антикапча параметры фанкапич, - # в результате получаем JSON ответ содержащий номер решаемой капчи - captcha_id = requests.post(create_task_url, json=self.task_payload, verify=False, **kwargs).json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - # обновляем пайлоад на получение решения капчи - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ждем решения капчи - time.sleep(self.sleep_time) - return get_sync_result(result_payload=self.result_payload, sleep_time=self.sleep_time) - - -class aioGeeTestTaskProxyless: - def __init__( - self, - anticaptcha_key: str, - websiteURL: str, - gt: str, - sleep_time: int = 10, - callbackUrl: str = None, - ): - """ - Модуль отвечает за решение GeeTestTaskProxyless - :param anticaptcha_key: Ключ от АнтиКапчи - :param websiteURL: Адрес страницы на которой решается капча - :param gt: Ключ-индентификатор капчи на целевой странице - :param sleep_time: Время ожидания решения - :param callbackUrl: URL для решения капчи с ответом через callback - """ - if sleep_time < 10: - raise ValueError(f"Param `sleep_time` must be greater than 10. U set - {sleep_time}") - self.sleep_time = sleep_time - - # Пайлоад для создания задачи - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "GeeTestTaskProxyless", "websiteURL": websiteURL, "gt": gt}, - "softId": app_key, - } - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # пайлоад для получения ответа сервиса - self.result_payload = {"clientKey": anticaptcha_key} - - def __enter__(self): - return self - - def __exit__(self, exc_type, exc_value, traceback): - if exc_type: - return False - return True - - # Работа с капчёй - async def captcha_handler(self, challenge: str) -> dict: - """ - Метод получает ссылку изображение для задания - :param challenge: Переменный токен который необходимо обновлять каждый раз перед созданием задачи - :return: Возвращает ответ сервера в виде JSON(ответ так же можно глянуть в документации антикапчи) - """ - self.task_payload["task"].update({"challenge": challenge}) - # Отправляем на антикапча параметры фанкапич, - # в результате получаем JSON ответ содержащий номер решаемой капчи - async with aiohttp.ClientSession() as session: - async with session.post(create_task_url, json=self.task_payload) as resp: - captcha_id = await resp.json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - # обновляем пайлоад на получение решения капчи - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ждем решения капчи - await asyncio.sleep(self.sleep_time) - return await get_async_result(result_payload=self.result_payload, sleep_time=self.sleep_time) diff --git a/src/python3_anticaptcha/HCaptchaTaskProxyless.py b/src/python3_anticaptcha/HCaptchaTaskProxyless.py deleted file mode 100644 index 571edef..0000000 --- a/src/python3_anticaptcha/HCaptchaTaskProxyless.py +++ /dev/null @@ -1,130 +0,0 @@ -import time -import asyncio - -import aiohttp -import requests - -from python3_anticaptcha import app_key, create_task_url, get_sync_result, get_async_result - - -class HCaptchaTaskProxyless: - def __init__(self, anticaptcha_key: str, sleep_time: int = 5, callbackUrl: str = None): - """ - Модуль отвечает за решение HCaptcha Proxyless - :param anticaptcha_key: Ключ от АнтиКапчи - :param sleep_time: Время ожидания решения - :param callbackUrl: URL для решения капчи с ответом через callback - """ - if sleep_time < 5: - raise ValueError(f"Param `sleep_time` must be greater than 5. U set - {sleep_time}") - self.sleep_time = sleep_time - - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "HCaptchaTaskProxyless"}, - "softId": app_key, - } - - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # пайлоад для получения ответа сервиса - self.result_payload = {"clientKey": anticaptcha_key} - - def __enter__(self): - return self - - def __exit__(self, exc_type, exc_value, traceback): - if exc_type: - return False - return True - - def captcha_handler(self, websiteURL: str, websiteKey: str, **kwargs) -> dict: - """ - Метод получает ссылку на страницу на которпой расположена капча и ключ капчи - :param websiteURL: Адрес страницы на которой решается капча - :param websiteKey: Ключ-индентификатор капчи на целевой странице. - :param kwargs: Дополнительные параметры для `requests.post(....)`. - :return: Возвращает ответ сервера в виде JSON(ответ так же можно глянуть в документации антикапчи) - """ - self.task_payload["task"].update({"websiteURL": websiteURL, "websiteKey": websiteKey}) - # Отправляем на антикапча параметры фанкапич, - # в результате получаем JSON ответ содержащий номер решаемой капчи - captcha_id = requests.post(create_task_url, json=self.task_payload, verify=False, **kwargs).json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, - # иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - # обновляем пайлоад на получение решения капчи - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ждем решения капчи - time.sleep(self.sleep_time) - return get_sync_result(result_payload=self.result_payload, sleep_time=self.sleep_time) - - -class aioHCaptchaTaskProxyless: - def __init__(self, anticaptcha_key: str, sleep_time: int = 5, callbackUrl: str = None): - """ - Модуль отвечает за решение HCaptcha Proxyless - :param anticaptcha_key: Ключ от АнтиКапчи - :param sleep_time: Время ожидания решения - :param callbackUrl: URL для решения капчи с ответом через callback - """ - if sleep_time < 5: - raise ValueError(f"Param `sleep_time` must be greater than 5. U set - {sleep_time}") - self.sleep_time = sleep_time - - # Пайлоад для создания задачи - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "HCaptchaTaskProxyless"}, - "softId": app_key, - } - - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # пайлоад для получения ответа сервиса - self.result_payload = {"clientKey": anticaptcha_key} - - async def captcha_handler(self, websiteURL: str, websiteKey: str) -> dict: - """ - Метод получает ссылку на страницу на которпой расположена капча и ключ капчи - :param websiteURL: Адрес страницы на которой решается капча - :param websiteKey: Ключ-индентификатор капчи на целевой странице. - :return: Возвращает ответ сервера в виде JSON(ответ так же можно глянуть в документации антикапчи) - """ - self.task_payload["task"].update({"websiteURL": websiteURL, "websiteKey": websiteKey}) - # Отправляем на антикапча параметры фанкапич, - # в результате получаем JSON ответ содержащий номер решаемой капчи - async with aiohttp.ClientSession() as session: - async with session.post(create_task_url, json=self.task_payload) as resp: - captcha_id = await resp.json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, - # иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - # обновляем пайлоад на получение решения капчи - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ждем решения капчи - await asyncio.sleep(self.sleep_time) - return await get_async_result(result_payload=self.result_payload, sleep_time=self.sleep_time) diff --git a/src/python3_anticaptcha/NoCaptchaTaskProxyless.py b/src/python3_anticaptcha/NoCaptchaTaskProxyless.py deleted file mode 100644 index 368e67b..0000000 --- a/src/python3_anticaptcha/NoCaptchaTaskProxyless.py +++ /dev/null @@ -1,173 +0,0 @@ -import time -import asyncio - -import aiohttp -import requests - -from python3_anticaptcha import app_key, create_task_url, get_sync_result, get_async_result - - -class NoCaptchaTaskProxyless: - def __init__(self, anticaptcha_key: str, sleep_time: int = 5, callbackUrl: str = None, **kwargs): - """ - Модуль отвечает за решение ReCaptcha без прокси - :param anticaptcha_key: Ключ антикапчи - :param sleep_time: Время ожидания решения капчи - :param callbackUrl: URL для решения капчи с ответом через callback - :param kwargs: Другие необязательные параметры из документации - """ - if sleep_time < 5: - raise ValueError(f"Param `sleep_time` must be greater than 5. U set - {sleep_time}") - self.sleep_time = sleep_time - - # Пайлоад для создания задачи - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "NoCaptchaTaskProxyless"}, - "softId": app_key, - } - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # Пайлоад для получения результата - self.result_payload = {"clientKey": anticaptcha_key} - - # Если переданы ещё параметры - вносим их в payload - if kwargs: - for key in kwargs: - self.task_payload["task"].update({key: kwargs[key]}) - - def __enter__(self): - return self - - def __exit__(self, exc_type, exc_value, traceback): - if exc_type: - return False - return True - - # Работа с капчёй - def captcha_handler(self, websiteURL: str, websiteKey: str, recaptchaDataSValue: str = "", **kwargs) -> dict: - """ - Метод решения ReCaptcha - :param websiteURL: Ссылка на страницу с капчёй - :param websiteKey: Ключ капчи сайта(как получить - написано в документации) - :param recaptchaDataSValue: Некоторые реализации виджета рекапчи могут содержать - дополнительный параметр "data-s" в div'е рекапчи, - который является одноразовым токеном и - должен собираться каждый раз при решении рекапчи. - :param kwargs: Дополнительные параметры для `requests.post(....)`. - :return: Возвращает ответ сервера в виде JSON-строки - """ - - # вставляем в пайлоад адрес страницы и ключ-индентификатор рекапчи - self.task_payload["task"].update( - { - "websiteURL": websiteURL, - "websiteKey": websiteKey, - "recaptchaDataSValue": recaptchaDataSValue, - } - ) - # Отправляем на антикапчу пайлоад - # в результате получаем JSON ответ содержащий номер решаемой капчи - captcha_id = requests.post(create_task_url, json=self.task_payload, verify=False, **kwargs).json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ожидаем решения капчи - time.sleep(self.sleep_time) - return get_sync_result(result_payload=self.result_payload, sleep_time=self.sleep_time) - - -class aioNoCaptchaTaskProxyless: - def __init__(self, anticaptcha_key: str, sleep_time: int = 5, callbackUrl: str = None, **kwargs): - """ - Модуль отвечает за решение ReCaptcha без прокси - :param anticaptcha_key: Ключ антикапчи - :param sleep_time: Время ожидания решения капчи - :param callbackUrl: URL для решения капчи с ответом через callback - :param kwargs: Другие необязательные параметры из документации - """ - if sleep_time < 5: - raise ValueError(f"Param `sleep_time` must be greater than 5. U set - {sleep_time}") - self.sleep_time = sleep_time - - # Пайлоад для создания задачи - self.task_payload = { - "clientKey": anticaptcha_key, - "task": {"type": "NoCaptchaTaskProxyless"}, - "softId": app_key, - } - - # задаём callbackUrl если передан - if callbackUrl: - self.task_payload.update({"callbackUrl": callbackUrl}) - - # Пайлоад для получения результата - self.result_payload = {"clientKey": anticaptcha_key} - - # Если переданы ещё параметры - вносим их в payload - if kwargs: - for key in kwargs: - self.task_payload["task"].update({key: kwargs[key]}) - - def __enter__(self): - return self - - def __exit__(self, exc_type, exc_value, traceback): - if exc_type: - return False - return True - - # Работа с капчёй - async def captcha_handler(self, websiteURL: str, websiteKey: str, recaptchaDataSValue: str = "") -> dict: - """ - Метод решения ReCaptcha - :param websiteURL: Ссылка на страницу с капчёй - :param websiteKey: Ключ капчи сайта(как получить - написано в документации) - :param recaptchaDataSValue: Некоторые реализации виджета рекапчи могут содержать - дополнительный параметр "data-s" в div'е рекапчи, - который является одноразовым токеном и - должен собираться каждый раз при решении рекапчи. - :return: Возвращает ответ сервера в виде JSON-строки - """ - - # вставляем в пайлоад адрес страницы и ключ-индентификатор рекапчи - self.task_payload["task"].update( - { - "websiteURL": websiteURL, - "websiteKey": websiteKey, - "recaptchaDataSValue": recaptchaDataSValue, - } - ) - # Отправляем на антикапчу пайлоад - # в результате получаем JSON ответ содержащий номер решаемой капчи - async with aiohttp.ClientSession() as session: - async with session.post(create_task_url, json=self.task_payload) as resp: - captcha_id = await resp.json() - - # Проверка статуса создания задачи, если создано без ошибок - извлекаем ID задачи, иначе возвращаем ответ сервера - if captcha_id["errorId"] == 0: - captcha_id = captcha_id["taskId"] - self.result_payload.update({"taskId": captcha_id}) - else: - return captcha_id - - # если передан параметр `callbackUrl` - не ждём решения капчи а возвращаем незаполненный ответ - if self.task_payload.get("callbackUrl"): - return self.result_payload - - else: - # Ждем решения капчи - await asyncio.sleep(self.sleep_time) - return await get_async_result(result_payload=self.result_payload, sleep_time=self.sleep_time)