From 887e1e72c398fcf7ab80e1a5713448bf97f0624d Mon Sep 17 00:00:00 2001
From: Mathieu Ledru <matyo91@gmail.com>
Date: Wed, 18 Sep 2024 00:34:26 +0200
Subject: [PATCH] :white_check_mark: Fix ci

---
 .../Receiver/CollectionReceiverTest.php       | 192 ------------------
 .../Transport/Sender/CollectionSenderTest.php |  39 ----
 2 files changed, 231 deletions(-)
 delete mode 100644 tests/Examples/Transport/Receiver/CollectionReceiverTest.php
 delete mode 100644 tests/Examples/Transport/Sender/CollectionSenderTest.php

diff --git a/tests/Examples/Transport/Receiver/CollectionReceiverTest.php b/tests/Examples/Transport/Receiver/CollectionReceiverTest.php
deleted file mode 100644
index 23111da7..00000000
--- a/tests/Examples/Transport/Receiver/CollectionReceiverTest.php
+++ /dev/null
@@ -1,192 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Flow\Test\Examples\Transport\Receiver;
-
-use ArrayObject;
-use Flow\Examples\Transport\Receiver\CollectionReceiver;
-use PHPUnit\Framework\TestCase;
-use SplObjectStorage;
-use stdClass;
-use Symfony\Component\Messenger\Envelope;
-use Symfony\Component\Messenger\Stamp\TransportMessageIdStamp;
-use Symfony\Component\Messenger\Transport\Receiver\ReceiverInterface;
-
-use function is_array;
-
-class CollectionReceiverTest extends TestCase
-{
-    /**
-     * @param array<ReceiverInterface>                             $receivers
-     * @param SplObjectStorage<ReceiverInterface, array<Envelope>> $expectedReceiversIps
-     *
-     * @dataProvider receiverProvider
-     */
-    public function testGet($receivers, $expectedReceiversIps): void
-    {
-        $collectionReceiver = new CollectionReceiver($receivers);
-        $envelopes = $collectionReceiver->get();
-
-        $expectedIpIds = [];
-        foreach ($expectedReceiversIps as $receiver) {
-            $expectedIps = $expectedReceiversIps[$receiver];
-            foreach ($expectedIps as $envelope) {
-                $expectedIpIds[] = $this->getTransportMessageId($envelope);
-            }
-        }
-        $envelopeIds = array_map(function (Envelope $envelope) {
-            return $this->getTransportMessageId($envelope);
-        }, iterator_to_array($envelopes));
-
-        $this->assertArraySimilar($expectedIpIds, $envelopeIds);
-    }
-
-    /**
-     * @param array<ReceiverInterface>                             $receivers
-     * @param SplObjectStorage<ReceiverInterface, array<Envelope>> $expectedReceiversIps
-     * @param array<mixed, ReceiverInterface>                      $expectedAckIpsReceivers
-     * @param array<mixed, ReceiverInterface>                      $expectedRejectIpsReceivers
-     *
-     * @dataProvider receiverProvider
-     */
-    public function testAckAndReject($receivers, $expectedReceiversIps, $expectedAckIpsReceivers, $expectedRejectIpsReceivers): void
-    {
-        $collectionReceiver = new CollectionReceiver($receivers);
-
-        $envelopes = $collectionReceiver->get();
-        foreach ($envelopes as $envelope) {
-            $envelopeId = $this->getTransportMessageId($envelope);
-            $expectedReceiver = null;
-            foreach ($expectedReceiversIps as $receiver) {
-                $expectedIps = $expectedReceiversIps[$receiver];
-                foreach ($expectedIps as $expectedIp) {
-                    $expectedIpId = $this->getTransportMessageId($expectedIp);
-                    if ($envelopeId === $expectedIpId) {
-                        $expectedReceiver = $receiver;
-
-                        break 2;
-                    }
-                }
-            }
-            self::assertNotNull($expectedReceiver);
-
-            if (1 === random_int(0, 1)) {
-                $collectionReceiver->ack($envelope);
-                self::assertArrayHasKey($envelopeId, $expectedAckIpsReceivers);
-                self::assertSame($expectedReceiver, $expectedAckIpsReceivers[$envelopeId]);
-            } else {
-                $collectionReceiver->reject($envelope);
-                self::assertArrayHasKey($envelopeId, $expectedRejectIpsReceivers);
-                self::assertSame($expectedReceiver, $expectedRejectIpsReceivers[$envelopeId]);
-            }
-        }
-    }
-
-    /**
-     * @return array<array<mixed>>
-     */
-    public static function receiverProvider(): iterable
-    {
-        $expectedReceiversIps = new SplObjectStorage();
-        /** @var array<mixed, ReceiverInterface> $expectedAckIpsReceivers */
-        $expectedAckIpsReceivers = new ArrayObject();
-        /** @var array<mixed, ReceiverInterface> $expectedRejectIpsReceivers */
-        $expectedRejectIpsReceivers = new ArrayObject();
-        $receivers = [];
-        for ($i = 0; $i < 10; $i++) {
-            $envelopes = [];
-            for ($j = 0; $j < 3; $j++) {
-                $envelopes[] = Envelope::wrap(new stdClass(), [new TransportMessageIdStamp(uniqid('envelope_', true))]);
-            }
-
-            $receiver = new class($envelopes, $expectedAckIpsReceivers, $expectedRejectIpsReceivers) implements ReceiverInterface {
-                /**
-                 * @param array<Envelope>                 $envelopes
-                 * @param array<mixed, ReceiverInterface> $expectedAckIpsReceivers
-                 * @param array<mixed, ReceiverInterface> $expectedRejectIpsReceivers
-                 */
-                public function __construct(private $envelopes, private $expectedAckIpsReceivers, private $expectedRejectIpsReceivers) {}
-
-                public function get(): iterable
-                {
-                    foreach ($this->envelopes as $envelope) {
-                        yield $envelope;
-                    }
-                }
-
-                /**
-                 * @return array<mixed, ReceiverInterface>
-                 */
-                public function getExpectedAckIpsReceivers()
-                {
-                    return $this->expectedAckIpsReceivers;
-                }
-
-                /**
-                 * @return array<mixed, ReceiverInterface>
-                 */
-                public function getExpectedRejectIpsReceivers()
-                {
-                    return $this->expectedRejectIpsReceivers;
-                }
-
-                public function ack(Envelope $envelope): void
-                {
-                    $id = $this->getTransportMessageId($envelope);
-                    $this->expectedAckIpsReceivers[$id] = $this;
-                }
-
-                public function reject(Envelope $envelope): void
-                {
-                    $id = $this->getTransportMessageId($envelope);
-                    $this->expectedRejectIpsReceivers[$id] = $this;
-                }
-
-                private function getTransportMessageId(Envelope $envelope): string
-                {
-                    /** @var null|TransportMessageIdStamp $stamp */
-                    $stamp = $envelope->last(TransportMessageIdStamp::class);
-
-                    return $stamp ? $stamp->getId() : '';
-                }
-            };
-            $expectedReceiversIps->offsetSet($receiver, $envelopes);
-            $receivers[] = $receiver;
-        }
-
-        return [
-            [$receivers, $expectedReceiversIps, $expectedAckIpsReceivers, $expectedRejectIpsReceivers],
-        ];
-    }
-
-    /**
-     * Asserts that two associative arrays are similar.
-     *
-     * Both arrays must have the same indexes with identical values
-     * without respect to key ordering
-     *
-     * @param array<mixed, mixed> $expected
-     * @param array<mixed, mixed> $array
-     */
-    protected function assertArraySimilar(array $expected, array $array): void
-    {
-        self::assertSame([], array_diff_key($array, $expected));
-
-        foreach ($expected as $key => $value) {
-            if (is_array($value)) {
-                self::assertArraySimilar($value, $array[$key]);
-            } else {
-                self::assertContains($value, $array);
-            }
-        }
-    }
-
-    private function getTransportMessageId(Envelope $envelope): string
-    {
-        /** @var null|TransportMessageIdStamp $stamp */
-        $stamp = $envelope->last(TransportMessageIdStamp::class);
-
-        return $stamp ? $stamp->getId() : '';
-    }
-}
diff --git a/tests/Examples/Transport/Sender/CollectionSenderTest.php b/tests/Examples/Transport/Sender/CollectionSenderTest.php
deleted file mode 100644
index cd465e5c..00000000
--- a/tests/Examples/Transport/Sender/CollectionSenderTest.php
+++ /dev/null
@@ -1,39 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace Flow\Test\Examples\Transport\Sender;
-
-use ArrayObject;
-use Flow\Examples\Transport\Sender\CollectionSender;
-use PHPUnit\Framework\TestCase;
-use stdClass;
-use Symfony\Component\Messenger\Envelope;
-use Symfony\Component\Messenger\Transport\Sender\SenderInterface;
-
-class CollectionSenderTest extends TestCase
-{
-    public function testSend(): void
-    {
-        $counter = new ArrayObject(['send' => 0]);
-        $senders = array_map(function () use ($counter) {
-            return new class($counter) implements SenderInterface {
-                /**
-                 * @param ArrayObject<string, int> $counter
-                 */
-                public function __construct(private ArrayObject $counter) {}
-
-                public function send(Envelope $envelope): Envelope
-                {
-                    $this->counter['send']++;
-
-                    return $envelope;
-                }
-            };
-        }, array_fill(0, 10, 0));
-        $collectionSender = new CollectionSender($senders);
-        $collectionSender->send(new Envelope(new stdClass()));
-
-        self::assertSame(10, $counter['send']);
-    }
-}