api.php

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

<?php
 
namespace Bitrix\Location\Source\Osm\Api;
 
use Bitrix\Location\Exception\RuntimeException;
use Bitrix\Location\Source\Osm\OsmSource;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\Web\HttpClient;
use Bitrix\Main\Web\Json;

final class Api
{
    private const HTTP_VERSION = HttpClient::HTTP_1_1;
    private const HTTP_SOCKET_TIMEOUT = 10;
    private const HTTP_STREAM_TIMEOUT = 10;

    private const API_SEARCH_LIMIT = 10;
 
    private const API_AUTOCOMPLETE_LIMIT = 7;

    private $source;

    public function __construct(OsmSource $source)
    {
        $this->source = $source;
    }
 
    public function search(array $options): array
    {
        $client = $this->makeHttpClient();
 
        $body = $client->get(
            $this->buildUrl(
                'location',
                'search',
                $this->wrapQueryData(
                    [
                        'q' =>  $options['q'],
                        'addressdetails' => isset($options['addressdetails']) ? (int)$options['addressdetails'] : 0,
                        'limit' => isset($options['limit']) ? (int)$options['limit'] : self::API_SEARCH_LIMIT,
                        'accept-language' => $options['accept-language'] ?? '',
                        'format' => 'json',
                    ]
                )
            )
        );
 
        return $this->getResponse($client, $body);
    }
 
    public function autocomplete(array $options): array
    {
        $client = $this->makeHttpClient();
 
        $queryData = [
            'q' =>  $options['q'],
            'limit' => isset($options['limit']) ? (int)$options['limit'] : self::API_AUTOCOMPLETE_LIMIT,
            'lang' => $options['lang'] ?? '',
            'version' => 2,
        ];
        if (isset($options['lat']) && isset($options['lon']))
        {
            $queryData['lat'] = $options['lat'];
            $queryData['lon'] = $options['lon'];
        }
 
        $body = $client->get(
            $this->buildUrl(
                'autocomplete',
                'autocomplete',
                $this->wrapQueryData(
                    $queryData
                )
            )
        );
 
        return $this->getResponse($client, $body);
    }
 
    public function lookup(array $options): array
    {
        $client = $this->makeHttpClient();
 
        $body = $client->get(
            $this->buildUrl(
                'location',
                'lookup',
                $this->wrapQueryData(
                    [
                        'osm_ids' => $options['osm_ids'] ?? '',
                        'addressdetails' => isset($options['addressdetails']) ? (int)$options['addressdetails'] : 0,
                        'accept-language' => $options['accept-language'] ?? '',
                        'format' => 'json',
                    ]
                )
            )
        );
 
        return $this->getResponse($client, $body);
    }
 
    public function details(array $options): array
    {
        $client = $this->makeHttpClient();
 
        $body = $client->get(
            $this->buildUrl(
                'location',
                'details',
                $this->wrapQueryData(
                    [
                        'osmtype' => $options['osm_type'] ?? '',
                        'osmid' => $options['osm_id'] ?? '',
                        'format' => 'json',
                        'addressdetails' => isset($options['addressdetails']) ? (int)$options['addressdetails'] : 0,
                        'linkedplaces' => isset($options['linkedplaces']) ? (int)$options['linkedplaces'] : 0,
                        'hierarchy' => isset($options['hierarchy']) ? (int)$options['hierarchy'] : 0,
                        'accept-language' => $options['accept-language'] ?? '',
                    ]
                )
            )
        );
 
        return $this->getResponse($client, $body);
    }
 
    public function reverse(array $options): array
    {
        $client = $this->makeHttpClient();
 
        $body = $client->get(
            $this->buildUrl(
                'location',
                'reverse',
                $this->wrapQueryData(
                    [
                        'lat' => isset($options['lat']) ? (float)$options['lat'] : null,
                        'lon' => isset($options['lng']) ? (float)$options['lng'] : null,
                        'zoom' => isset($options['zoom']) ? (int)$options['zoom'] : null,
                        'format' => 'json',
                        'addressdetails' => isset($options['addressdetails']) ? (int)$options['addressdetails'] : 0,
                        'accept-language' => $options['accept-language'] ?? '',
                    ]
                )
            )
        );
 
        return $this->getResponse($client, $body);
    }
 
    public function getStaticMap(
        float $latitude,
        float $longitude,
        int $zoom,
        int $width,
        int $height,
    ): array
    {
        $client = $this->makeHttpClient();
 
        $body = $client->get(
            $this->buildUrl(
                'staticmap',
                'get',
                [
                    'latitude' => $latitude,
                    'longitude' => $longitude,
                    'zoom' => $zoom,
                    'width' => $width,
                    'height' => $height,
                ],
            )
        );
 
        $response = $this->getResponse($client, $body);
 
        $response['data'] = isset($response['data']) ? base64_decode($response['data']) : null;
 
        return $response;
    }
 
    private function getResponse(HttpClient $client, string $body): array
    {
        $status = $client->getStatus();
 
        if ($body === false)
        {
            return [];
        }
 
        if ($status != 200)
        {
            return [];
        }
 
        try
        {
            $response = Json::decode($body);
        }
        catch (ArgumentException $e)
        {
            return [];
        }
 
        return is_array($response) ? $response : [];
    }
 
    private function makeHttpClient(): HttpClient
    {
        $token = $this->source->getOsmToken();
 
        $result = new HttpClient(
            [
                'version' => self::HTTP_VERSION,
                'socketTimeout' => self::HTTP_SOCKET_TIMEOUT,
                'streamTimeout' => self::HTTP_STREAM_TIMEOUT,
            ]
        );
 
        $result->setHeader(
            'Authorization',
            sprintf('Bearer %s', ($token ? $token->getToken() : ''))
        );
 
        $result->setHeader('Bx-Location-Osm-Host', $this->source->getOsmHostName());
 
        return $result;
    }
 
    private function buildUrl(string $controller, string $action, array $queryData): string
    {
        $serviceUrl = $this->source->getOsmApiUrl();
 
        if (!$serviceUrl)
        {
            throw new RuntimeException('Service url is not specified');
        }
 
        return sprintf(
            '%s/?%s',
            $serviceUrl,
            http_build_query(
                array_merge(
                    $queryData,
                    [
                        'action' => sprintf('osmgateway.%s.%s', $controller, $action)
                    ]
                )
            )
        );
    }
 
    private function wrapQueryData(array $queryData): array
    {
        return [
            'params' => $queryData
        ];
    }
}