ci: Add build for pheanstalk compatibility

Author: vincent4vx

.github/workflows/php.yml

@@ -40,6 +40,42 @@ jobs:
     - name: Run test suite
       run: composer run-script tests
 
+  pheanstalk_compatibility:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+          pheanstalk-versions: ['3.2.1']
+    name: Pheanstalk ${{ matrix.pheanstalk-versions }}
+
+    steps:
+    - uses: actions/checkout@v2
+
+    - name: Set Timezone
+      uses: szenius/set-timezone@v1.0
+      with:
+        timezoneLinux: "Europe/Paris"
+
+    - name: Install PHP
+      uses: shivammathur/setup-php@v2
+      with:
+        php-version: 8.4
+        extensions: json
+        ini-values: date.timezone=Europe/Paris
+
+    - name: Install & run Beanstalkd
+      run: | 
+        sudo apt-get install -y beanstalkd
+        sudo service beanstalkd start
+
+    - name: Install dependencies
+      run: composer install --prefer-dist --no-progress
+
+    - name: Require Pheanstalk version
+      run: composer require --dev "pda/pheanstalk:~${{ matrix.pheanstalk-versions }}"
+
+    - name: Run test suite
+      run: composer run-script tests
+
   analysis:
     name: Analysis
     runs-on: ubuntu-latest

composer.json

@@ -37,7 +37,7 @@
     "enqueue/fs": "~0.9",
     "league/container": "~3.0",
     "monolog/monolog": "~2.0",
-    "pda/pheanstalk": "^3.1@dev",
+    "pda/pheanstalk": "~3.2",
     "php-amqplib/php-amqplib": "~3.0",
     "phpbench/phpbench": "~0.0|~1.0",
     "phpunit/phpunit": "~9.6",

tests/Connection/Pheanstalk/PheanstalkFunctionalTest.php

@@ -0,0 +1,97 @@
+<?php
+
+namespace Connection\Pheanstalk;
+
+use Bdf\Queue\Connection\Pheanstalk\PheanstalkConnection;
+use Bdf\Queue\Message\Message;
+use Bdf\Queue\Message\QueueEnvelope;
+use Bdf\Queue\Message\TopicEnvelope;
+use Bdf\Queue\Serializer\JsonSerializer;
+use PHPUnit\Framework\TestCase;
+
+use function pcntl_fork;
+use function usleep;
+
+class PheanstalkFunctionalTest extends TestCase
+{
+    private PheanstalkConnection $connection;
+
+    protected function setUp(): void
+    {
+        $host = getenv('PHEANSTALK_HOST') ?: '127.0.0.1';
+        $port = getenv('PHEANSTALK_PORT') ?: 11300;
+
+        if (!@fsockopen($host, $port, $errno, $errstr, 1)) {
+            $this->markTestSkipped('Pheanstalk server is not available');
+        }
+
+        $this->connection = new PheanstalkConnection('test', new JsonSerializer());
+        $this->connection->setConfig([
+            'host' => $host,
+            'port' => $port,
+        ]);
+    }
+
+    public function test_queuePushPop()
+    {
+        $queue = $this->connection->queue();
+        $queue->push(
+            (new Message(['foo' => 'bar']))
+                ->setQueue('test')
+        );
+
+        $message = $queue->pop('test');
+        $this->assertEquals('test', $message->message()->destination());
+        $this->assertSame(['foo' => 'bar'], $message->message()->data());
+        $this->assertFalse($message->isRejected());
+        $this->assertFalse($message->isDeleted());
+
+        $message->acknowledge();
+
+        $this->assertNull($queue->pop('test'));
+    }
+
+    public function test_queueRelease()
+    {
+        $queue = $this->connection->queue();
+        $queue->push(
+            (new Message(['foo' => 'bar']))
+                ->setQueue('test')
+        );
+
+        $message = $queue->pop('test');
+        $this->assertSame(['foo' => 'bar'], $message->message()->data());
+        $this->assertFalse($message->isRejected());
+        $this->assertFalse($message->isDeleted());
+
+        $queue->release($message->message());
+        $this->assertEquals($message, $queue->pop('test'));
+        $this->assertFalse($message->isRejected());
+        $this->assertFalse($message->isDeleted());
+
+        $message->acknowledge();
+    }
+
+    public function test_topic()
+    {
+        $messages = [];
+
+        $topic = $this->connection->topic();
+        $topic->subscribe(['topic.test'], function (QueueEnvelope $envelope) use (&$messages) {
+            $messages[] = $envelope->message()->data();
+            $envelope->acknowledge();
+        });
+
+        if (pcntl_fork() === 0) {
+            usleep(50000);
+            $topic->publish(
+                (new Message(['foo' => 'bar']))
+                    ->setTopic('topic.test')
+            );
+            exit;
+        }
+
+        $topic->consume(2);
+        $this->assertEquals([['foo' => 'bar']], $messages);
+    }
+}