omnilance.php

<?php
namespace Bitrix\Mail\Registrar;
 
use \Bitrix\Main\Text\Encoding;
 
class Omnilance extends Registrar
{
    const BASE_ENDPOINT = 'https://api.omnilance.com/v3/';
 
    private $apiKey;
 
    private $secretKey;
 
    private $http;
 
    public function __construct(string $apiKey, string $secretKey)
    {
        $this->apiKey = $apiKey;
        $this->secretKey = $secretKey;
        $this->http = new \Bitrix\Main\Web\HttpClient;
        $this->http->setTimeout(5);
    }
 
    private function setHeaders(string $endPoint, ?string $payLoad = null): void
    {
        if (!$payLoad)
        {
            $payLoad = '';
        }
 
        $signature = hash_hmac('sha256', $this->apiKey . $endPoint . $payLoad, $this->secretKey);
        $this->http->setHeader('X-OMNI-APIKEY', $this->apiKey);
        $this->http->setHeader('X-OMNI-SIGNATURE', $signature);
        $this->http->setHeader('content-type', 'application/json');
    }
 
    private function sendPostCommand(string $endPoint, string $payLoad): string
    {
        $endPoint = $this::BASE_ENDPOINT . $endPoint;
        $this->setHeaders($endPoint, $payLoad);
        $this->http->post($endPoint, $payLoad);
        return $this->http->getResult();
    }
 
    private function sendGetCommand(string $endPoint): string
    {
        $endPoint = $this::BASE_ENDPOINT . $endPoint;
        $this->setHeaders($endPoint);
        $this->http->get($endPoint);
        return $this->http->getResult();
    }
 
    public static function checkDomain(string $user, string $password, string $domain, ?string &$error): ?bool
    {
        $domain = mb_strtolower($domain);
        $domain = Encoding::convertEncoding($domain, SITE_CHARSET, 'UTF-8');
 
        $omnilance = new self($user, $password);
 
        $payLoad = json_encode([
            'domainNames' => [
                $domain
            ]
        ]);
        $res = $omnilance->sendPostCommand('domains/checkAvailability', $payLoad);
        $res = json_decode($res, true);
 
        if (isset($res['error']))
        {
            $error = $res['message'] ?? $res['error'];
            return null;
        }
 
        if (isset($res['results']) && is_array($res['results']))
        {
            foreach ($res['results'] as $item)
            {
                if ($item['domainName'] == $domain)
                {
                    if ($item['status'] == 'registered')
                    {
                        return true;
                    }
                    break;
                }
            }
        }
 
        return false;
    }
 
    public static function suggestDomain(string $user, string $password, string $word1, string $word2, array $tlds, ?string &$error): ?array
    {
        // method is not allowed by provider
        return null;
    }
 
    public static function createDomain(string $user, string $password, string $domain, array $params, ?string &$error): ?bool
    {
        $domain = mb_strtolower($domain);
        $domain = Encoding::convertEncoding($domain, SITE_CHARSET, 'UTF-8');
 
        $payLoad = json_encode([
            'domain' => [
                'domainName' => $domain,
                'privacyEnabled' => true
            ],
            'years' => 1
        ]);
 
        $omnilance = new self($user, $password);
        $res = $omnilance->sendPostCommand('domains/createDomain', $payLoad);
        $res = json_decode($res, true);
 
        if (isset($res['error']))
        {
            $error = $res['message'] ?? $res['error'];
            return null;
        }
 
        return true;
    }
 
    public static function renewDomain(string $user, string $password, string $domain, ?string &$error): ?bool
    {
        $domain = mb_strtolower($domain);
        $domain = Encoding::convertEncoding($domain, SITE_CHARSET, 'UTF-8');
 
        $payLoad = json_encode([
            'domain' => [
                'domainName' => $domain
            ],
            'years' => 1
        ]);
 
        $omnilance = new self($user, $password);
        $res = $omnilance->sendPostCommand('domains/renewDomain/'.$domain, $payLoad);
        $res = json_decode($res, true);
 
        if (isset($res['error']))
        {
            $error = $res['message'] ?? $res['error'];
            return null;
        }
 
        return true;
    }
 
    public static function updateDns(string $user, string $password, string $domain, array $params, ?string &$error): ?bool
    {
        $error = null;
        $domain = mb_strtolower($domain);
        $domain = Encoding::convertEncoding($domain, SITE_CHARSET, 'UTF-8');
        $params = Encoding::convertEncoding($params, SITE_CHARSET, 'UTF-8');
 
        $first = true;
        foreach ($params as $dns)
        {
            $payLoad = [
                'type' => (isset($dns['type']) && is_string($dns['type'])) ? strtoupper($dns['type']) : null,
                'name' => (isset($dns['name']) && is_string($dns['name'])) ? $dns['name'] : '',
                'value' => isset($dns['value']) ? [$dns['value']] : [],
                'ttl' => 3600
            ];
            $payLoad = json_encode($payLoad);
 
            $omnilance = new self($user, $password);
 
            if ($first)
            {
                $res = $omnilance->sendPostCommand('domains/createZoneRecord/'.$domain, $payLoad);
            }
            else
            {
                $res = $omnilance->sendPostCommand('domains/createDnsRecord/'.$domain, $payLoad);
            }
 
            $res = json_decode($res, true);
 
            if (isset($res['error']))
            {
                $error = $res['message'] ?? $res['error'];
            }
            $first = false;
        }
 
        return $error === null;
    }
 
    public static function getDomainsList(string $user, string  $password, ?string &$error): ?array
    {
        $list = [];
        $currentPage = 1;
        $omnilance = new self($user, $password);
 
        do
        {
            $res = $omnilance->sendGetCommand('domains/100/' . $currentPage);
            $res = json_decode($res, true);
 
            if (isset($res['error']))
            {
                $error = $res['message'] ?? $res['error'];
                return null;
            }
 
            if (!isset($res['domains']) || !isset($res['lastPage']))
            {
                $error = 'Unknown error';
                return null;
            }
 
            foreach ($res['domains'] as $domain)
            {
                $list[$domain['domainName']] = [
                    'domain_name' => $domain['domainName'],
                    'creation_date' => $domain['createDate'],
                    'expiration_date' => $domain['expireDate'],
                    'status' => null
                ];
            }
 
            $currentPage++;
 
        } while ($currentPage <= $res['lastPage']);
 
        return $list;
    }
}