fix: throw exception if we're unable to connect to php-fpm

Author: carlalexander

src/FastCgi/PhpFpmProcess.php

@@ -13,6 +13,7 @@
 
 namespace Ymir\Runtime\FastCgi;
 
+use hollodotme\FastCGI\Exceptions\ConnectException;
 use hollodotme\FastCGI\Exceptions\ReadFailedException;
 use hollodotme\FastCGI\Exceptions\TimedoutException;
 use hollodotme\FastCGI\Interfaces\ProvidesRequestData;
@@ -99,6 +100,8 @@ public function handle(ProvidesRequestData $request, int $timeoutMs): ProvidesRe
     {
         try {
             $response = $this->client->handle($request, $timeoutMs);
+        } catch (ConnectException $exception) {
+            throw new PhpFpmProcessException('Unable to connect to PHP-FPM FastCGI socket');
         } catch (ReadFailedException $exception) {
             throw new PhpFpmProcessException('PHP-FPM process crashed unexpectedly');
         } catch (TimedoutException $exception) {

tests/Unit/FastCgi/PhpFpmProcessTest.php

@@ -13,6 +13,7 @@
 
 namespace Ymir\Runtime\Tests\Unit\FastCgi;
 
+use hollodotme\FastCGI\Exceptions\ConnectException;
 use PHPUnit\Framework\TestCase;
 use Ymir\Runtime\Exception\PhpFpm\PhpFpmProcessException;
 use Ymir\Runtime\Exception\PhpFpm\PhpFpmTimeoutException;
@@ -78,6 +79,26 @@ public function testHandle(): void
         $this->assertSame($response, $phpFpmProcess->handle($request, 1000));
     }
 
+    public function testHandleWithConnectException(): void
+    {
+        $this->expectException(PhpFpmProcessException::class);
+        $this->expectExceptionMessage('Unable to connect to PHP-FPM FastCGI socket');
+
+        $client = $this->getFastCgiServerClientMock();
+        $logger = $this->getLoggerMock();
+        $process = $this->getProcessMock();
+        $request = $this->getProvidesRequestDataMock();
+
+        $client->expects($this->once())
+               ->method('handle')
+               ->with($this->identicalTo($request), 1000)
+               ->willThrowException(new ConnectException('connection refused'));
+
+        $phpFpmProcess = new PhpFpmProcess($client, $logger, $process);
+
+        $phpFpmProcess->handle($request, 1000);
+    }
+
     public function testHandleWithProcessStopped(): void
     {
         $this->expectException(PhpFpmProcessException::class);