OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	05/19/2025 10:07:17 AM	rwxr-xr-x
📄 PostmarkAdminClientDataRemovalTest.php	1.22 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkAdminClientDomainTest.php	3.9 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkAdminClientSenderSignatureTest.php	4.12 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkAdminClientServersTest.php	2.88 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClickClientStatisticsTest.php	1.52 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientBaseTest.php	597 bytes	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientBounceTest.php	4.03 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientEmailTest.php	8.78 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientInboundMessageTest.php	1.07 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientMessageStreamsTest.php	6.73 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientOutboundMessageTest.php	1.52 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientRuleTriggerTest.php	1.07 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientServerTest.php	1.02 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientStatisticsTest.php	4.54 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientSuppressionsTest.php	5.37 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientTemplatesTest.php	11.22 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 PostmarkClientWebhooksTest.php	9.72 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 TestingKeys.php	2.32 KB	05/19/2025 10:07:17 AM	rw-r--r--
📄 postmark-logo.png	4.18 KB	03/05/2025 10:53:47 AM	rw-r--r--

Editing: PostmarkClientMessageStreamsTest.php

<?php

namespace Postmark\Tests;

require_once __DIR__ . '/PostmarkClientBaseTest.php';

use Postmark\PostmarkAdminClient;
use Postmark\PostmarkClient;

/**
 * @internal
 *
 * @coversNothing
 */
class PostmarkClientMessageStreamsTest extends PostmarkClientBaseTest
{
    public static function tearDownAfterClass(): void
    {
        $tk = parent::$testKeys;
        $client = new PostmarkAdminClient($tk->WRITE_ACCOUNT_TOKEN, $tk->TEST_TIMEOUT);

$servers = $client->listServers();

foreach ($servers->getServers() as $key => $value) {
            if (preg_match('/^test-php-streams.+/', $value->getName()) > 0 && !empty($value->getID())) {
                $client->deleteServer($value->getID());
            }
        }
    }

// create message stream
    public function testClientCanCreateMessageStream()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$id = 'test-stream';
        $messageStreamType = 'Broadcasts';
        $name = 'Test Stream Name';
        $description = 'Test Stream Description';

$createdStream = $client->createMessageStream($id, $messageStreamType, $name, $description);

$this->assertEquals($id, $createdStream->getID());
        $this->assertEquals($server->getID(), $createdStream->getServerId());
        $this->assertEquals($messageStreamType, $createdStream->getMessageStreamType());
        $this->assertEquals($name, $createdStream->getName());
        $this->assertEquals($description, $createdStream->getDescription());
        $this->assertNotNull($createdStream->getCreatedAt());
        $this->assertNull($createdStream->getUpdatedAt());
        $this->assertNull($createdStream->getArchivedAt());
    }

// edit message stream
    public function testClientCanEditMessageStream()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$id = 'test-stream';
        $messageStreamType = 'Broadcasts';
        $name = 'Test Stream Name';
        $description = 'Test Stream Description';

$client->createMessageStream($id, $messageStreamType, $name, $description);

$updatedName = 'New Name';
        $updatedDescription = 'New Description';

$updatedStream = $client->editMessageStream($id, $updatedName, $updatedDescription);

$this->assertEquals($id, $updatedStream->getID());
        $this->assertEquals($updatedName, $updatedStream->getName());
        $this->assertEquals($updatedDescription, $updatedStream->getDescription());
        $this->assertNotNull($updatedStream->getUpdatedAt());
    }

// get message stream
    public function testClientCanGetMessageStream()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$id = 'test-stream';
        $messageStreamType = 'Broadcasts';
        $name = 'Test Stream Name';
        $description = 'Test Stream Description';

$client->createMessageStream($id, $messageStreamType, $name, $description);

$fetchedStream = $client->getMessageStream($id);

$this->assertEquals($id, $fetchedStream->getID());
        $this->assertEquals($messageStreamType, $fetchedStream->getMessageStreamType());
        $this->assertEquals($name, $fetchedStream->getName());
        $this->assertEquals($description, $fetchedStream->getDescription());
    }

// list message streams
    public function testClientCanListMessageStreams()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$broadcastsStream = $client->createMessageStream('test-stream', 'Broadcasts', 'Test Stream Name');

$this->assertEquals(4, $client->listMessageStreams()->getTotalCount()); // Includes 3 default streams

$filteredStreams = $client->listMessageStreams('Broadcasts');

$this->assertEquals(2, $filteredStreams->getTotalCount()); // Filter only our Broadcasts streams
    }

// list archived message streams
    public function testClientCanListArchivedStreams()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$newStream = $client->createMessageStream('test-stream', 'Broadcasts', 'Test Stream Name');

// 2 broadcast streams, including the default one
        $this->assertEquals(2, $client->listMessageStreams('Broadcasts')->getTotalCount());

$client->archiveMessageStream($newStream->getID());

// Filtering out archived streams by default
        $this->assertEquals(1, $client->listMessageStreams('Broadcasts')->getTotalCount());

// Allowing archived streams in the result
        $this->assertEquals(2, $client->listMessageStreams('Broadcasts', 'true')->getTotalCount());
    }

// archive message streams
    public function testClientCanArchiveStreams()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$newStream = $client->createMessageStream('test-stream', 'Broadcasts', 'Test Stream Name');
        $archivedStream = $client->archiveMessageStream($newStream->getID());

$this->assertEquals($newStream->getID(), $archivedStream->getID());
        $this->assertEquals($newStream->getServerId(), $archivedStream->getServerId());
        $this->assertNotNull($archivedStream->getExpectedPurgeDate());

$fetchedStream = $client->getMessageStream($archivedStream->getID());
        $this->assertNotNull($fetchedStream->getArchivedAt());
    }

// unarchive message streams
    public function testClientCanUnarchiveStreams()
    {
        $tk = parent::$testKeys;
        $server = self::getNewServer();
        $client = new PostmarkClient($server->ApiTokens[0], $tk->TEST_TIMEOUT);

$newStream = $client->createMessageStream('test-stream', 'Broadcasts', 'Test Stream Name');
        $client->archiveMessageStream($newStream->getID());

$unarchivedStream = $client->unArchiveMessageStream($newStream->getID());

$this->assertNull($unarchivedStream->getArchivedAt());
    }

private static function getNewServer()
    {
        $tk = parent::$testKeys;
        $client = new PostmarkAdminClient($tk->WRITE_ACCOUNT_TOKEN, $tk->TEST_TIMEOUT);

return $client->createServer('test-php-streams-' . uniqid());
    }
}