cloud_monitor_request.php

См. документацию.

<?

class CSecurityCloudMonitorRequest
{
    const BITRIX_CHECKER_URL_PATH = "/bitrix/site_checker.php";
    const REMOTE_STATUS_OK = "ok";
    const REMOTE_STATUS_ERROR = "error";
    const REMOTE_STATUS_FATAL_ERROR = "fatal_error";
    const TIMEOUT = 10;
 
    private static $validActions = array("check", "get_results");
    protected $response = array();
    protected $checkingToken = "";
    protected $protocolVersion = 2;
 
    public function __construct($action, $protocolVersion, $token = "")
    {
        if(!in_array($action, self::$validActions))
            return null;
 
        $this->checkingToken = $token;
        $this->response = $this->receiveData($action);
        $this->protocolVersion = $protocolVersion;
    }

    public function setCheckingToken($checkingToken)
    {
        $this->checkingToken = $checkingToken;
 
        return $this;
    }

    public function getCheckingToken()
    {
        return $this->checkingToken;
    }

    public function receiveData($action)
    {
        $payload = $this->getPayload($action, false);
        if(!$payload)
            return false;
 
        $response = self::sendRequest($payload);
        if(!$response)
        {
            $response = array();
        }
 
        if(!isset($response["status"]))
        {
            $response["status"] = self::REMOTE_STATUS_FATAL_ERROR;
            $response["error_text"] = GetMessage("SECURITY_SITE_CHECKER_CONNECTION_ERROR");
        }
 
        return $response;
    }

    public function isOk()
    {
        return  $this->checkStatus(self::REMOTE_STATUS_OK);
    }

    public function isFatalError()
    {
        return  $this->checkStatus(self::REMOTE_STATUS_FATAL_ERROR);
    }

    public function isError()
    {
        return  $this->checkStatus(self::REMOTE_STATUS_ERROR);
    }

    public function isSuccess()
    {
        return  (isset($this->response["status"]));
    }

    public function getValue($key)
    {
        if(isset($this->response[$key]))
        {
            return $this->response[$key];
        }
        else
        {
            return "";
        }
    }

    protected function checkStatus($status)
    {
        return  (isset($this->response["status"]) && $this->response["status"] === $status);
    }

    protected function getPayload($action = "check", $collectInformation = true)
    {
        if(!in_array($action, self::$validActions))
            return false;
 
        $payload = array(
                "action" => $action,
                "host"   => self::getHostName(),
                "lang"   => LANGUAGE_ID,
                "license_key" => self::getLicenseKey(),
                "testing_token" => $this->checkingToken,
                "version" => $this->protocolVersion
            );
 
        if($collectInformation || $action === "check")
        {
            $payload["system_information"] = base64_encode(serialize(self::getSystemInformation()));
            $payload["additional_information"] = base64_encode(serialize(self::getAdditionalInformation()));
        }
 
        return $payload;
    }
 

    protected static function decodeResponse($response)
    {
        $result = json_decode($response, true);
 
        return $result;
    }

    protected static function sendRequest(array $payload)
    {
        $license = \Bitrix\Main\Application::getInstance()->getLicense();
        $targetHost = $license->getDomainStoreLicense() . self::BITRIX_CHECKER_URL_PATH;
 
        $httpClient = new \Bitrix\Main\Web\HttpClient(array(
            'streamTimeout' => static::TIMEOUT
        ));
 
        $response = $httpClient->post($targetHost, $payload);
        if ($response && $httpClient->getStatus() == 200)
        {
            return self::decodeResponse($response);
        }
 
        return false;
    }

    protected static function getLicenseKey()
    {
        if (defined("LICENSE_KEY"))
        {
            $licenseKey = LICENSE_KEY;
        }
        else
        {
            $licenseKey = "DEMO";
        }
        return md5($licenseKey);
    }

    protected static function getSystemInformation()
    {
        return CSecuritySystemInformation::getSystemInformation();
    }

    protected static function getAdditionalInformation()
    {
        return CSecuritySystemInformation::getAdditionalInformation();
    }

    protected function getHostName()
    {
        $sheme = (CMain::IsHTTPS() ? "https" : "http")."://";
        $serverPort = self::getServerPort();
        $url = self::getDomainName();
        $url .= ($serverPort && mb_strpos($url, ":") === false) ? ":".$serverPort : "";
        return $sheme.$url;
    }

    protected static function getServerPort()
    {
        if($_SERVER["SERVER_PORT"] && !in_array($_SERVER["SERVER_PORT"], array(80, 443)))
            return $_SERVER["SERVER_PORT"];
        else
            return false;
    }

    protected static function getDomainName()
    {
        return CSecuritySystemInformation::getCurrentHost();
    }
}