LaravelAnticaptcha\Anticaptcha\Anticaptcha

Complexity

Total Complexity

27

Size/Duplication

Total Lines	214
Duplicated Lines	0 %

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	jsonPostRequest()	0	32	3
A	setVerboseMode()	0	2	1
A	createTask()	0	19	3
A	getBalance()	0	12	3
B	waitForResult()	0	39	6
A	setTaskId()	0	2	1
A	setHost()	0	2	1
A	getErrorMessage()	0	2	1
A	setKey()	0	2	1
A	setScheme()	0	2	1
A	debout()	0	19	4
A	setErrorMessage()	0	2	1
A	getTaskId()	0	2	1

<?php
namespace LaravelAnticaptcha\Anticaptcha;

use LaravelAnticaptcha\Anticaptcha\Exceptions\AnticaptchaException;


class Anticaptcha {

    private $host = "api.anti-captcha.com";
    private $scheme = "https";
    private $clientKey;
    private $verboseMode = false;
    private $errorMessage;
    private $taskId;
    public $taskInfo;
    
    /**
     * Submit new task and receive tracking ID
     * @return bool
     * @throws AnticaptchaException
     */
    public function createTask() {
        
        $postData = array(
            "clientKey" =>  $this->clientKey,
            "task"      =>  $this->getPostData()

The method getPostData() does not exist on LaravelAnticaptcha\Anticaptcha\Anticaptcha. Maybe you want to declare this class abstract?

        );
        $submitResult = $this->jsonPostRequest("createTask", $postData);
        
        if ($submitResult == false) {
            throw new AnticaptchaException('API error');
        }
        
        if ($submitResult->errorId == 0) {
            $this->taskId = $submitResult->taskId;
            $this->debout("created task with ID {$this->taskId}", "yellow");
            return true;
        } else {
            $this->setErrorMessage($submitResult->errorDescription);
            throw new AnticaptchaException("API error {$submitResult->errorCode} : {$submitResult->errorDescription}");
        }
        
    }

    /**
     * @param int $maxSeconds
     * @param int $currentSecond
     *
     * @return bool
     * @throws AnticaptchaException
     */
    public function waitForResult($maxSeconds = 300, $currentSecond = 0) {
        $postData = array(
            "clientKey" =>  $this->clientKey,
            "taskId"    =>  $this->taskId
        );
        if ($currentSecond == 0) {
            $this->debout("waiting 5 seconds..");
            sleep(3);
        } else {
            sleep(1);
        }
        $this->debout("requesting task status");
        $postResult = $this->jsonPostRequest("getTaskResult", $postData);
        
        if ($postResult == false) {
            throw new AnticaptchaException('API error');
        }
        
        $this->taskInfo = $postResult;
        
        
        if ($this->taskInfo->errorId == 0) {
            if ($this->taskInfo->status == "processing") {
                
                $this->debout("task is still processing");
                //repeating attempt
                return $this->waitForResult($maxSeconds, $currentSecond+1);
                
            }
            if ($this->taskInfo->status == "ready") {
                $this->debout("task is complete", "green");
                return true;
            }
            $this->setErrorMessage("unknown API status, update your software");
            throw new AnticaptchaException("unknown API status, update your software");

        } else {
            $this->setErrorMessage($this->taskInfo->errorDescription);
            throw new AnticaptchaException("API error {$this->taskInfo->errorCode} : {$this->taskInfo->errorDescription}");
        }
    }

    /**
     * @return bool
     * @throws AnticaptchaException
     */
    public function getBalance() {
        $postData = array(
            "clientKey" =>  $this->clientKey
        );
        $result = $this->jsonPostRequest("getBalance", $postData);
        if ($result == false) {
            throw new AnticaptchaException('API error');
        }
        if ($result->errorId == 0) {
            return $result->balance;
        } else {
            return false;
        }
    }

    /**
     * @param $methodName
     * @param $postData
     *
     * @return mixed
     * @throws AnticaptchaException
     */
    public function jsonPostRequest($methodName, $postData) {
        
        
        if ($this->verboseMode) {
            echo "making request to {$this->scheme}://{$this->host}/$methodName with following payload:\n";
            print_r($postData);
        }
        
        
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, "{$this->scheme}://{$this->host}/$methodName");
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_ENCODING, "gzip,deflate");
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");   
        $postDataEncoded = json_encode($postData);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $postDataEncoded);
        curl_setopt($ch, CURLOPT_HTTPHEADER, array(
            'Content-Type: application/json; charset=utf-8',     
            'Accept: application/json',     
            'Content-Length: '.strlen($postDataEncoded) 
        ));
        curl_setopt($ch, CURLOPT_TIMEOUT, 30);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
        $result = curl_exec($ch);
        $curlError = curl_error($ch);
        
        if ($curlError != "") {
            $this->debout("Network error: $curlError");
            throw new AnticaptchaException("Network error: $curlError");
        }
        curl_close($ch);
        return json_decode($result);
    }
    
    public function setVerboseMode($mode) {
        $this->verboseMode = $mode;
    }
    
    public function debout($message, $color = "white") {
        if (!$this->verboseMode) {
            return false;
        }
        if ($color != "white" and $color != "") {
            $CLIcolors = array(
                "cyan" => "0;36",
                "green" => "0;32",
                "blue"  => "0;34",
                "red"   => "0;31",
                "yellow" => "1;33"
            );
            
            $CLIMsg  = "\033[".$CLIcolors[$color]."m$message\033[0m";
            
        } else {
            $CLIMsg  = $message;
        }
        echo $CLIMsg."\n";
    }

    /**
     * @param $message
     */
    public function setErrorMessage($message) {
        $this->errorMessage = $message;
    }

    /**
     * @return mixed
     */
    public function getErrorMessage() {
        return $this->errorMessage;
    }

    /**
     * @return mixed
     */
    public function getTaskId() {
        return $this->taskId;
    }

    /**
     * @param $taskId
     */
    public function setTaskId($taskId) {
        $this->taskId = $taskId;
    }
    
    public function setHost($host) {
        $this->host = $host;
    }
    
    public function setScheme($scheme) {
        $this->scheme = $scheme;
    }
    
    /**
     * Set client access key, must be 32 bytes long
     * @param string $key
     */
    public function setKey($key) {
        $this->clientKey = $key;
    }

}