merged all code from AbstractGeocoder into Geocoder

Author: mtmail

demo/geocode.php

@@ -1,6 +1,5 @@
 <?php
 
-include(dirname(__DIR__) . '/src/AbstractGeocoder.php');
 include(dirname(__DIR__) . '/src/Geocoder.php');
 
 // use OpenCage\Geocoder;

src/AbstractGeocoder.php

@@ -2,10 +2,69 @@
 
 namespace OpenCage\Geocoder;
 
-use OpenCage\Geocoder\AbstractGeocoder;
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\ConnectException;
 
-class Geocoder extends AbstractGeocoder
+class Geocoder
 {
+    public const VERSION  = '3.4.0';  // if changing this => remember to match everything with the git tag
+
+    public const TIMEOUT = 10;
+    public const URL = 'https://api.opencagedata.com/geocode/v1/json/?';
+    public const PROXY = null;
+
+    protected $key;
+    protected $timeout;
+    protected $url;
+    protected $proxy;
+    protected $user_agent;
+    protected $client;
+
+    public function __construct($key = null)
+    {
+        if (isset($key) && !empty($key)) {
+            $this->setKey($key);
+        }
+        $this->setTimeout(self::TIMEOUT);
+        $this->url = self::URL;
+        $this->user_agent = 'opencage-php/' . self::VERSION . ' (PHP ' . phpversion() . '; ' . php_uname('s') . ' ' . php_uname('r') . ')';
+    }
+
+    public function setKey($key)
+    {
+        $this->key = $key;
+    }
+
+    public function setTimeout($timeout)
+    {
+        $this->timeout = $timeout;
+        $this->client = null;
+    }
+
+    public function setProxy($proxy)
+    {
+        $parsed = parse_url($proxy);
+        if (
+            $parsed === false
+            || !isset($parsed['scheme'])
+            || !in_array($parsed['scheme'], ['http', 'https', 'socks5'], true)
+            || !isset($parsed['host'])
+        ) {
+            throw new \Exception('Invalid proxy URL: must include a valid scheme (http, https, or socks5) and host');
+        }
+        $this->proxy = $proxy;
+        $this->client = null;
+    }
+
+    public function setHost($host)
+    {
+        if (!$this->isValidHost($host)) {
+            throw new \Exception('Invalid host: must be localhost or an opencagedata.com subdomain');
+        }
+        $this->url = str_replace('api.opencagedata.com', $host, self::URL);
+        $this->client = null;
+    }
+
     public function geocode($query, $optParams = [])
     {
         $url = $this->url . 'q=' . urlencode($query);
@@ -24,4 +83,67 @@ public function geocode($query, $optParams = [])
         $ret = json_decode($this->getJSON($url), true);
         return $ret;
     }
+
+    protected function isValidHost($host)
+    {
+        if (in_array($host, ['localhost', '127.0.0.1', '0.0.0.0', '::1'], true)) {
+            return true;
+        }
+
+        // localhost with port
+        if (preg_match('/^(localhost|127\.0\.0\.1|0\.0\.0\.0)\:\d+$/', $host)) {
+            return true;
+        }
+
+        // opencagedata.com or any subdomain
+        if (preg_match('/^([a-zA-Z0-9-]+\.)*opencagedata\.com$/', $host)) {
+            return true;
+        }
+
+        return false;
+    }
+
+    protected function buildClient()
+    {
+        $config = [
+            'timeout' => $this->timeout,
+            'verify' => true,
+            'headers' => [
+                'User-Agent' => $this->user_agent,
+            ],
+        ];
+
+        if ($this->proxy) {
+            $config['proxy'] = $this->proxy;
+        }
+
+        return new Client($config);
+    }
+
+    protected function getJSON($query)
+    {
+        if ($this->client === null) {
+            $this->client = $this->buildClient();
+        }
+
+        try {
+            $response = $this->client->get($query, ['http_errors' => false]);
+            return (string) $response->getBody();
+        } catch (ConnectException $e) {
+            return $this->generateErrorJSON(498, 'network issue ' . $e->getMessage());
+        }
+    }
+
+    protected function generateErrorJSON($code, $message)
+    {
+        $response = [
+                        'results' => [],
+                        'total_results' => 0,
+                        'status' => [
+                            'code' => $code,
+                            'message' => $message
+                        ]
+                    ];
+        return json_encode($response);
+    }
 }