improve connection errors

Author: lukaspijak

src/Configurator/SmsCountryConfigurator.php

@@ -57,7 +57,7 @@ public function configure(Base $message): void
         {
             [, $prefix] = $match;
 
-            $iso = PrefixMap::PREFIX_TO_ISO[$prefix] ?? null;
+            $iso = PrefixMap::PREFIX_TO_ISO[$prefix];
 
             if ($iso !== null && isset($this->profile[$iso]))
             {

src/Connection/ConnectionStream.php

@@ -3,12 +3,12 @@
 namespace BulkGate\Sdk\Connection;
 
 /**
- * @author Lukáš Piják 2022 TOPefekt s.r.o.
+ * @author Lukáš Piják 2025 TOPefekt s.r.o.
  * @link https://www.bulkgate.com/
  */
 
 use BulkGate\Sdk\{ConnectionException, Utils\Strict};
-use function implode;
+use function array_key_exists, implode, restore_error_handler, set_error_handler;
 
 class ConnectionStream implements Connection
 {
@@ -25,7 +25,13 @@ class ConnectionStream implements Connection
     private string $content_type;
 
 
-    public function __construct(int $application_id, string $application_token, string $api = 'https://portal.bulkgate.com/api/1.0/integration', string $application_product = 'php-sdk', string $content_type = 'application/json')
+    public function __construct(
+		int $application_id,
+		string $application_token,
+		string $api = 'https://portal.bulkgate.com/api/1.0/integration',
+		string $application_product = 'php-sdk',
+		string $content_type = 'application/json'
+    )
     {
         $this->application_id = $application_id;
         $this->application_token = $application_token;
@@ -40,42 +46,51 @@ public function __construct(int $application_id, string $application_token, stri
      */
     public function send(Request $request): Response
     {
-        [$content_type, $action, $data] = $request->encode($this->content_type, [
-            'application_id' => $this->application_id,
-            'application_token' => $this->application_token,
-            'application_product' => $this->application_product
-        ]);
-
-        $context = stream_context_create(['http' => [
-            'method' => 'POST',
-            'header' => [
-                "Content-type: $content_type"
-            ],
-            'content' => $data,
-            'ignore_errors' => true
-        ]]);
-
-        $connection = fopen("$this->api/$action", 'r', false, $context);
-
-        if ($connection)
-        {
-            try
-            {
-                $response = (string) stream_get_contents($connection);
-
-                $meta = stream_get_meta_data($connection);
-
-                if (isset($meta['wrapper_data']))
-                {
-                    return new Response(Helpers::parseContentType(implode("\n" , $meta['wrapper_data'])), $response);
-                }
-            }
-            finally
-            {
-                fclose($connection);
-            }
-        }
-
-        throw new ConnectionException("BulkGate server is unavailable - $this->api/$action");
+		try
+		{
+			set_error_handler(function (int $error_code, string $error_message): void { throw new ConnectionException($error_message, $error_code);	});
+
+			[$content_type, $action, $data] = $request->encode($this->content_type, [
+				'application_id' => $this->application_id,
+				'application_token' => $this->application_token,
+				'application_product' => $this->application_product
+			]);
+
+			$context = stream_context_create(['http' => [
+				'method' => 'POST',
+				'header' => [
+					"Content-type: $content_type"
+				],
+				'content' => $data,
+				'ignore_errors' => true
+			]]);
+
+			$connection = fopen("$this->api/$action", 'r', false, $context);
+
+			if ($connection)
+			{
+				try
+				{
+					$response = (string) stream_get_contents($connection);
+
+					$meta = stream_get_meta_data($connection);
+
+					if (array_key_exists('wrapper_data', $meta))
+					{
+						return new Response(Helpers::parseContentType(implode("\n" , $meta['wrapper_data'])), $response, Helpers::parseHttpCode($meta['wrapper_data'][0] ?? null));
+					}
+				}
+				finally
+				{
+					fclose($connection);
+				}
+			}
+		}
+		finally
+		{
+			restore_error_handler();
+		}
+
+	    throw new ConnectionException("BulkGate server is unavailable - $this->api/$action");
     }
 }

src/Connection/Helpers.php

@@ -3,7 +3,7 @@
 namespace BulkGate\Sdk\Connection;
 
 /**
- * @author Lukáš Piják 2022 TOPefekt s.r.o.
+ * @author Lukáš Piják 2025 TOPefekt s.r.o.
  * @link https://www.bulkgate.com/
  */
 
@@ -12,19 +12,37 @@
 
 class Helpers
 {
-    use Strict;
+	use Strict;
 
+	public static function parseContentType(string $header): ?string
+	{
+		$header = mb_strtolower($header);
 
-    public static function parseContentType(string $header): ?string
-    {
-        $header = strtolower($header);
+		if (preg_match('~content-type:\s([^\n;]+)~', mb_strtolower($header), $m))
+		{
+			[, $content_type] = $m;
 
-        if (preg_match('~content-type:\s([^\n;]+)~', mb_strtolower($header), $m))
-        {
-            [, $content_type] = $m;
+			return $content_type;
+		}
+		return null;
+	}
 
-            return $content_type;
-        }
-        return null;
-    }
+
+	public static function parseHttpCode(?string $header): ?int
+	{
+		if ($header === null)
+		{
+			return null;
+		}
+
+		$header = mb_strtolower($header);
+
+		if (preg_match('~\s(\d{3})~', mb_strtolower($header), $m))
+		{
+			[, $code] = $m;
+
+			return (int) $code;
+		}
+		return null;
+	}
 }