symfony
diff --git a/‎src/Symfony/Bridge/Doctrine/Messenger/DoctrinePingConnectionMiddleware.php
Copy file name to clipboard
+64Lines changed: 64 additions & 0 deletions b/‎src/Symfony/Bridge/Doctrine/Messenger/DoctrinePingConnectionMiddleware.php
Copy file name to clipboard
+64Lines changed: 64 additions & 0 deletions
diff --git a/‎src/Symfony/Bridge/Doctrine/Tests/Messenger/DoctrinePingConnectionMiddlewareTest.php
Copy file name to clipboard
+98Lines changed: 98 additions & 0 deletions b/‎src/Symfony/Bridge/Doctrine/Tests/Messenger/DoctrinePingConnectionMiddlewareTest.php
Copy file name to clipboard
+98Lines changed: 98 additions & 0 deletions
@@ -0,0 +1,64 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Bridge\Doctrine\Messenger;
+
+use Doctrine\Common\Persistence\ManagerRegistry;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
+use Symfony\Component\Messenger\Middleware\StackInterface;
+
+class DoctrinePingConnectionMiddleware implements MiddlewareInterface
+{
+    private $managerRegistry;
+    private $entityManagerName;
+    private $forceCloseConnection = false;
+
+    public function __construct(ManagerRegistry $managerRegistry, bool $forceCloseConnection = false, string $entityManagerName = null)
+    {
+        $this->managerRegistry = $managerRegistry;
+        $this->forceCloseConnection = $forceCloseConnection;
+        $this->entityManagerName = $entityManagerName;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function handle(Envelope $envelope, StackInterface $stack): Envelope
+    {
+        $entityManager = $this->managerRegistry->getManager($this->entityManagerName);
+
+        if (!$entityManager instanceof EntityManagerInterface) {
+            throw new \InvalidArgumentException(sprintf('The ObjectManager with name "%s" must be an instance of EntityManagerInterface', $this->entityManagerName));
+        }
+
+        $connection = $entityManager->getConnection();
+        try {
+            if (!$connection->ping()) {
+                $connection->close();
+                $connection->connect();
+            }
+
+            $envelope = $stack->next()->handle($envelope, $stack);
+
+            if (!$entityManager->isOpen()) {
+                $this->managerRegistry->resetManager($this->entityManagerName);
+            }
+
+            return $envelope;
+        } finally {
+            if ($this->forceCloseConnection) {
+                $connection->close();
+            }
+        }
+    }
+}
@@ -0,0 +1,98 @@
+<?php
+
+/*
+ * This file is part of the Symfony package.
+ *
+ * (c) Fabien Potencier <fabien@symfony.com>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace Symfony\Bridge\Doctrine\Tests\Messenger;
+
+use Doctrine\Common\Persistence\ManagerRegistry;
+use Doctrine\DBAL\Connection;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Bridge\Doctrine\Messenger\DoctrinePingConnectionMiddleware;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Test\Middleware\MiddlewareTestCase;
+
+class DoctrinePingConnectionMiddlewareTest extends MiddlewareTestCase
+{
+    private $connection;
+    private $entityManager;
+    private $managerRegistry;
+    private $middleware;
+    private $middlewareForceCloseConnection;
+    private $entityManagerName = 'default';
+
+    protected function setUp()
+    {
+        $this->connection = $this->createMock(Connection::class);
+
+        $this->entityManager = $this->createMock(EntityManagerInterface::class);
+        $this->entityManager->method('getConnection')->willReturn($this->connection);
+
+        $this->managerRegistry = $this->createMock(ManagerRegistry::class);
+        $this->managerRegistry->method('getManager')->willReturn($this->entityManager);
+
+        $this->middleware = new DoctrinePingConnectionMiddleware(
+            $this->managerRegistry,
+            false,
+            $this->entityManagerName
+        );
+
+        $this->middlewareForceCloseConnection = new DoctrinePingConnectionMiddleware(
+            $this->managerRegistry,
+            true,
+            $this->entityManagerName
+        );
+    }
+
+    public function testMiddlewarePingOk()
+    {
+        $this->connection->expects($this->once())
+            ->method('ping')
+            ->willReturn(false);
+
+        $this->connection->expects($this->once())
+            ->method('close')
+        ;
+        $this->connection->expects($this->once())
+            ->method('connect')
+        ;
+
+        $this->middleware->handle(new Envelope(new \stdClass()), $this->getStackMock());
+    }
+
+    public function testMiddlewarePingResetEntityManager()
+    {
+        $this->entityManager->expects($this->once())
+            ->method('isOpen')
+            ->willReturn(false)
+        ;
+        $this->managerRegistry->expects($this->once())
+            ->method('resetManager')
+            ->with($this->entityManagerName)
+            ;
+
+        $this->middleware->handle(new Envelope(new \stdClass()), $this->getStackMock());
+    }
+
+    public function testMiddlewarePingForceCloseConnection()
+    {
+        $this->connection->expects($this->once())
+            ->method('ping')
+            ->willReturn(true);
+
+        $this->connection->expects($this->never())
+            ->method('connect')
+        ;
+        $this->connection->expects($this->once())
+            ->method('close')
+        ;
+
+        $this->middlewareForceCloseConnection->handle(new Envelope(new \stdClass()), $this->getStackMock());
+    }
+}