upgrade symfony/doctrine-messenger (#4365)

Author: vitek-rostislav

composer.json

@@ -97,7 +97,7 @@
         "symfony/amqp-messenger": "^6.4",
         "symfony/clock": "^6.4",
         "symfony/css-selector": "^6.4",
-        "symfony/doctrine-messenger": "^6.4",
+        "symfony/doctrine-messenger": "^6.4.31",
         "symfony/dom-crawler": "^6.4",
         "symfony/error-handler": "^6.4",
         "symfony/event-dispatcher": "^6.4",

src/Migrations/Version20241223020557.php

@@ -0,0 +1,49 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Shopsys\FrameworkBundle\Migrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Override;
+use Shopsys\MigrationBundle\Component\Doctrine\Migrations\AbstractMigration;
+
+class Version20241223020557 extends AbstractMigration
+{
+    /**
+     * @param \Doctrine\DBAL\Schema\Schema $schema
+     */
+    #[Override]
+    public function up(Schema $schema): void
+    {
+        if ($this->isAppMigrationNotInstalledRemoveIfExists('Version20231227143511')) {
+            $this->sql('
+            CREATE TABLE messenger_messages (
+                id BIGSERIAL NOT NULL,
+                body TEXT NOT NULL,
+                headers TEXT NOT NULL,
+                queue_name VARCHAR(190) NOT NULL,
+                created_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL,
+                available_at TIMESTAMP(0) WITHOUT TIME ZONE NOT NULL,
+                delivered_at TIMESTAMP(0) WITHOUT TIME ZONE DEFAULT NULL,
+                PRIMARY KEY(id)
+            )');
+            $this->sql('CREATE INDEX IDX_75EA56E0FB7336F0 ON messenger_messages (queue_name)');
+            $this->sql('CREATE INDEX IDX_75EA56E0E3BD61CE ON messenger_messages (available_at)');
+            $this->sql('CREATE INDEX IDX_75EA56E016BA31DB ON messenger_messages (delivered_at)');
+            $this->sql('
+            CREATE
+            OR REPLACE FUNCTION notify_messenger_messages() RETURNS TRIGGER AS $$ BEGIN PERFORM pg_notify(
+                \'messenger_messages\', NEW.queue_name :: text
+            ); RETURN NEW; END; $$ LANGUAGE plpgsql;');
+            $this->sql('DROP TRIGGER IF EXISTS notify_trigger ON messenger_messages;');
+            $this->sql('
+            CREATE TRIGGER notify_trigger
+            AFTER
+                INSERT
+                OR
+            UPDATE
+                ON messenger_messages FOR EACH ROW EXECUTE PROCEDURE notify_messenger_messages();');
+        }
+    }
+}

src/Migrations/Version20251231124034.php

@@ -0,0 +1,28 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Shopsys\FrameworkBundle\Migrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Override;
+use Shopsys\MigrationBundle\Component\Doctrine\Migrations\AbstractMigration;
+
+class Version20251231124034 extends AbstractMigration
+{
+    /**
+     * @param \Doctrine\DBAL\Schema\Schema $schema
+     */
+    #[Override]
+    public function up(Schema $schema): void
+    {
+        $this->sql('
+            CREATE INDEX IDX_75EA56E0FB7336F0E3BD61CE16BA31DBBF396750 ON messenger_messages (
+                queue_name, available_at, delivered_at,
+                id
+            )');
+        $this->sql('DROP INDEX IF EXISTS IDX_75EA56E016BA31DB');
+        $this->sql('DROP INDEX IF EXISTS IDX_75EA56E0E3BD61CE');
+        $this->sql('DROP INDEX IF EXISTS IDX_75EA56E0FB7336F0');
+    }
+}