First commit

Author: alperensert

.github/workflows/publish.yml

@@ -0,0 +1,32 @@
+name: Publish Python Package 🐍
+
+on:
+  release:
+    types: [published]
+
+jobs:
+  deploy:
+
+    runs-on: ubuntu-latest
+
+    steps:
+    - uses: actions/checkout@v2
+    - name: Set up Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: "3.7"
+
+    - name: Install setup dependencies
+      run: make setup_dependencies
+
+    - name: Install dependencies
+      run: make build
+
+    - name: Build package
+      run: python -m build
+
+    - name: Publish package to PYPI
+      uses: pypa/gh-action-pypi-publish@27b31702a0e7fc50959f5ad993c78deac1bdfc29
+      with:
+        user: __token__
+        password: ${{ secrets.PYPI_TOKEN }}

.gitignore

@@ -0,0 +1,2 @@
+**/__pycache__
+**/.vscode

LICENSE

@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2022
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

Makefile

@@ -0,0 +1,18 @@
+build:
+	python -m pip install --upgrade pip
+	pip install build
+
+install: install_test install_pkg
+
+install_test:
+	pip install .[test]
+
+install_pkg:
+	python -m pip install --upgrade pip wheel
+	pip install .
+
+test:
+	python -m unittest -v tests/test_tasks.py
+
+setup_dependencies:
+	pip install setuptools_scm wheel

README.md

@@ -0,0 +1,78 @@
+CapSolver.com package for Python
+=
+![PyPI - Wheel](https://img.shields.io/pypi/wheel/capsolver_python?style=plastic) ![PyPI - Python Version](https://img.shields.io/pypi/pyversions/capsolver_python?style=flat) ![GitHub last commit](https://img.shields.io/github/last-commit/alperensert/capsolver_python?style=flat) ![GitHub release (latest by date)](https://img.shields.io/github/v/release/alperensert/capsolver_python?style=flat) ![PyPI - Downloads](https://img.shields.io/pypi/dm/capsolver_python?style=flat) ![GitHub code size in bytes](https://img.shields.io/github/languages/code-size/alperensert/capsolver_python?style=flat) ![GitHub Repo stars](https://img.shields.io/github/stars/alperensert/capsolver_python?style=social) 
+
+[CapSolver.com](https://capsolver.com) package for Python3
+
+Register now from [here](https://dashboard.capsolver.com/passport/register?inviteCode=kXa8cbNF-b2l).
+
+If you have any problem with usage, [read the documentation](https://github.com/alperensert/capsolver_python/wiki) or [create an issue](https://github.com/alperensert/capsolver_python/issues/new)
+
+### Installation
+```
+pip install capsolver_python
+```
+
+### Supported captcha types
+- Image to Text
+- Recaptcha V2
+- Recaptcha V2 Enterprise
+- Recaptcha V3
+- FunCaptcha
+- HCaptcha
+- GeeTest
+- AntiAkamaiBMP
+- HCaptcha Classification
+- DataDome Slider
+- FunCaptcha Classification
+
+Usage examples
+-
+
+#### ImageToText
+
+```python
+from capsolver_python import ImageToTextTask
+
+capsolver = ImageToTextTask("API_KEY")
+task_id = capsolver.create_task(image_path="img.png")
+result = capsolver.join_task_result(task_id)
+print(result.get("text"))
+```
+
+#### Recaptcha v2
+
+```python
+from capsolver_python import RecaptchaV2Task
+
+capsolver = RecaptchaV2Task("API_KEY")
+task_id = capsolver.create_task("website_url", "website_key")
+result = capsolver.join_task_result(task_id)
+print(result.get("gRecaptchaResponse"))
+```
+
+#### Recaptcha v2 enterprise
+
+```python
+from capsolver_python import RecaptchaV2EnterpriseTask
+
+capsolver = RecaptchaV2EnterpriseTask("API_KEY")
+task_id = capsolver.create_task("website_url", "website_key", {"s": "payload value"}, "api_domain")
+result = capsolver.join_task_result(task_id)
+print(result.get("gRecaptchaResponse"))
+```
+
+#### GeeTest
+
+```python
+from capsolver_python import GeeTestTask
+
+capsolver = GeeTestTask("API_KEY")
+task_id = capsolver.create_task("website_url", "gt", "challenge")
+result= capsolver.join_task_result(task_id)
+print(result.get("challenge"))
+print(result.get("seccode"))
+print(result.get("validate"))
+```
+
+For other examples and api documentation please visit [wiki](https://captchaai.atlassian.net/wiki/spaces/CAPTCHAAI/overview)

capsolver_python/__init__.py

@@ -0,0 +1,13 @@
+from .antiakamai_bmp import AntiAkamaiBMPTask
+from .antikasada import AntiKasadaTask
+from .datadome_slider import DataDomeSliderTask
+from .recaptcha_v2 import RecaptchaV2Task
+from .recaptcha_v2_enterprise import RecaptchaV2EnterpriseTask
+from .fun_captcha import FunCaptchaTask
+from .funcaptcha_classification import FunCaptchaClassificationTask
+from .hcaptcha_classification import HCaptchaClassificationTask
+from .image_to_text import ImageToTextTask
+from .gee_test import GeeTestTask
+from .h_captcha import HCaptchaTask
+from .recaptcha_v3 import RecaptchaV3Task
+from .utils import CapSolverException

capsolver_python/antiakamai_bmp.py

@@ -0,0 +1,31 @@
+from .capsolver import CapSolver
+from .request_type import RequestType
+
+
+class AntiAkamaiBMPTask(CapSolver):
+    '''
+    Class to solve AntiAkamaiBMP tasks.
+
+    Only IOS sensor is supported, and you'll need to implement the tls by yourself
+    '''
+    def __init__(self, client_key: str, beta: bool = False) -> None:
+        super(AntiAkamaiBMPTask, self).__init__(client_key, beta)
+
+    def create_task(self, package_name: str, version: str = None, device_id: str = None,
+                    device_name: str = None, count: int =  None) -> str:
+        data = {
+            "clientKey": self.client_key,
+            "task": {
+                "type": "AntiAkamaiBMPTask",
+                "packageName": package_name
+            }
+        }
+        if version is not None:
+            data["task"]["version"] = version
+        if device_id is not None:
+            data["task"]["deviceId"] = device_id
+        if device_name is not None:
+            data["task"]["deviceName"] = device_name
+        if count is not None:
+            data["task"]["count"] = count
+        return self._make_request(RequestType.CreateTaskAntiAkamai, data).get("taskId")

capsolver_python/antikasada.py

@@ -0,0 +1,28 @@
+from .proxy import Proxy
+from .useragent import UserAgent
+from .request_type import RequestType
+
+
+class AntiKasadaTask(UserAgent, Proxy):
+    '''
+    Class to solve AntiKasada tasks.
+
+    This task type AntiKasadaTask require that you send us your proxies.
+
+    We support the following proxy types: SOCKS4, SOCKS5, HTTP, HTTPS with authentication by IP address or login and password. 
+
+    If you want to use proxies by authentication by IP address, please add into the whitelist this ip: 47.253.53.46
+    '''
+    def __init__(self, client_key: str, beta: bool = False) -> None:
+        super(AntiKasadaTask, self).__init__(client_key, beta)
+
+    def create_task(self, page_url: str, only_cd: str = None) -> str:
+        data = {
+            "clientKey": self.client_key,
+            "task": {
+                "pageURL": page_url
+            }
+        }
+        if only_cd is not None:
+            data["task"]["onlyCD"] = only_cd
+        return self._make_request(RequestType.CreateTaskKasada, data).get("taskId")

capsolver_python/capsolver.py

@@ -0,0 +1,100 @@
+import asyncio
+import requests
+from time import sleep
+from .request_type import RequestType
+from .utils import CapSolverException
+
+class CapSolver:
+    _HOST_URL = "https://api.capsolver.com"
+    _BETA_HOST_URL = "https://api-beta.capsolver.com"
+
+    def __init__(self, client_key: str, beta: bool = False) -> None:
+        self.client_key = client_key
+        self.beta = beta
+    
+    def get_balance(self) -> float:
+        '''
+        Returns balance for API key.
+        '''
+        data = {"clientKey": self.client_key}
+        return self._make_request(RequestType.GetBalance, data).get("balance")
+    
+    def get_packages(self) -> list:
+        '''
+        Returns a list of monthly packages.
+        '''
+        data = {"clientKey": self.client_key}
+        return self._make_request(RequestType.GetBalance, data).get("packages")
+
+    def get_task_result(self, task_id: str):
+        data = {
+            "clientKey": self.client_key,
+            "taskId": task_id
+        }
+        task_result = self._make_request(RequestType.GetTaskResult, data)
+        return self._is_ready(task_result)
+    
+    def join_task_result(self, task_id: str, maximum_time: int = 90):
+        for i in range(0, maximum_time + 1, 1):
+            result = self.get_task_result(task_id)
+            if result is not False and result is not None:
+                return result
+            elif result is False:
+                i += 1
+                sleep(1)
+        raise CapSolverException(61, "ERROR_MAXIMUM_TIME_EXCEED", "Maximum time is exceed.")
+
+    async def join_task_result_async(self, task_id: str, maximum_time: int = 90):
+        for i in range(0, maximum_time + 1, 1):
+            result = self.get_task_result(task_id)
+            if result is not False and result is not None:
+                return result
+            elif result is False:
+                i += 1
+                await asyncio.sleep(1)
+        raise CapSolverException(61, "ERROR_MAXIMUM_TIME_EXCEED", "Maximum time is exceed.")
+
+    # TODO: Get a soft id for this one
+    def _make_request(self, method: RequestType, data: dict):
+        if method == RequestType.CreateTask or method == RequestType.CreateTaskAntiAkamai or method == RequestType.CreateTaskKasada:
+            data["appId"] = "0C39FC4D-C1FB-4F4E-975B-89E93B78A97A"
+        try:
+            response = requests.post("{}{}".format(self._BETA_HOST_URL if self.beta else self._HOST_URL, method), json=data).json()
+        except Exception as err:
+            raise CapSolverException(-1, type(err).__name__, str(err))
+        return response
+
+    @staticmethod
+    def _is_ready(response: dict):
+        status = response.get("status")
+        if status == "ready" or status == "processing":
+            return False if status == "processing" else response.get("solution")
+        else:
+            raise CapSolverException(response.get("errorId"), response.get("errorCode"), response.get("errorDescription"))
+    
+    @staticmethod
+    def _add_cookies(cookies, data):
+        if cookies is None:
+            return data
+        str_cookies = ""
+        if type(cookies) == dict:
+            for key, value in cookies.items():
+                if value == list(cookies.items())[-1][1]:
+                    str_cookies += "{}={}".format(key, value)
+                else:
+                    str_cookies += "{}={};".format(key, value)
+        elif type(cookies) == list:
+            for i in cookies:
+                if not len(cookies) % 2 == 0:
+                    raise AttributeError("List cookies length must be even numbers")
+                if cookies.index(i) % 2 == 0:
+                    str_cookies += "{}=".format(i)
+                elif cookies[cookies.index(i)] == cookies[-1]:
+                    str_cookies += "{}".format(i)
+                elif cookies.index(i) % 2 == 1:
+                    str_cookies += "{};".format(i)
+        elif type(cookies) == str:
+            data["task"]["cookies"] = cookies
+            return data
+        data["task"]["cookies"] = str_cookies
+        return data

capsolver_python/datadome_slider.py

@@ -0,0 +1,28 @@
+from .proxy import Proxy
+from .useragent import UserAgent
+from .request_type import RequestType
+
+
+class DataDomeSliderTask(UserAgent, Proxy):
+    '''
+    Class to solve Data dome slider tasks.
+
+    This task type DatadomeSliderTask require that you send us your proxies.
+
+    We support the following proxy types: SOCKS4, SOCKS5, HTTP, HTTPS with authentication by IP address or login and password. 
+
+    If you want to use proxies by authentication by IP address, please add into the whitelist this ip: 47.253.53.46
+    '''
+    def __init__(self, client_key: str, beta: bool = False) -> None:
+        super(DataDomeSliderTask, self).__init__(client_key, beta)
+
+    def create_task(self, website_url: str, captcha_url: str) -> str:
+        data = {
+            "clientKey": self.client_key,
+            "task": {
+                "type": "DatadomeSliderTask",
+                "websiteURL": website_url,
+                "captchaUrl": captcha_url
+            }
+        }
+        return self._make_request(RequestType.CreateTask, data).get("taskId")