1
0
Fork 0
mirror of synced 2024-06-17 10:14:50 +12:00
appwrite/tests/unit/Messaging/MessagingTest.php

199 lines
5.3 KiB
PHP
Raw Normal View History

2021-06-30 01:11:14 +12:00
<?php
namespace Appwrite\Tests;
2021-06-30 23:36:58 +12:00
use Appwrite\Database\Document;
2021-06-30 01:11:14 +12:00
use Appwrite\Messaging\Adapter\Realtime;
use PHPUnit\Framework\TestCase;
class MessagingTest extends TestCase
{
public function setUp(): void
{
}
public function tearDown(): void
{
}
public function testUser()
{
$realtime = new Realtime();
$realtime->subscribe(
'1',
1,
['user:123', 'role:member', 'team:abc', 'team:abc/administrator', 'team:abc/moderator', 'team:def', 'team:def/guest'],
['files' => 0, 'documents' => 0, 'documents.789' => 0, 'account.123' => 0]
);
$event = [
'project' => '1',
2021-07-14 03:18:02 +12:00
'roles' => ['*'],
2021-06-30 01:11:14 +12:00
'data' => [
'channels' => [
0 => 'account.123',
]
]
];
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['role:member'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['user:123'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:abc'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:abc/administrator'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:abc/moderator'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:def'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:def/guest'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['user:456'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertEmpty($receivers);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['team:def/member'];
2021-06-30 01:11:14 +12:00
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertEmpty($receivers);
2021-07-14 03:18:02 +12:00
$event['roles'] = ['*'];
2021-06-30 01:11:14 +12:00
$event['data']['channels'] = ['documents.123'];
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertEmpty($receivers);
$event['data']['channels'] = ['documents.789'];
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertCount(1, $receivers);
$this->assertEquals(1, $receivers[0]);
$event['project'] = '2';
2021-07-14 03:18:02 +12:00
$receivers = $realtime->getSubscribers($event);
2021-06-30 01:11:14 +12:00
$this->assertEmpty($receivers);
$realtime->unsubscribe(2);
$this->assertCount(1, $realtime->connections);
$this->assertCount(7, $realtime->subscriptions['1']);
$realtime->unsubscribe(1);
$this->assertEmpty($realtime->connections);
$this->assertEmpty($realtime->subscriptions);
}
2021-06-30 23:36:58 +12:00
public function testConvertChannelsGuest()
{
$user = new Document([
'$id' => ''
]);
$channels = [
0 => 'files',
1 => 'documents',
2 => 'documents.789',
3 => 'account',
4 => 'account.456'
];
2021-07-14 03:18:02 +12:00
$channels = Realtime::convertChannels($channels, $user->getId());
2021-06-30 23:36:58 +12:00
$this->assertCount(3, $channels);
$this->assertArrayHasKey('files', $channels);
$this->assertArrayHasKey('documents', $channels);
$this->assertArrayHasKey('documents.789', $channels);
$this->assertArrayNotHasKey('account', $channels);
$this->assertArrayNotHasKey('account.456', $channels);
}
public function testConvertChannelsUser()
{
$user = new Document([
'$id' => '123',
'memberships' => [
[
'teamId' => 'abc',
'roles' => [
'administrator',
'moderator'
]
],
[
'teamId' => 'def',
'roles' => [
'guest'
]
]
]
]);
$channels = [
0 => 'files',
1 => 'documents',
2 => 'documents.789',
3 => 'account',
4 => 'account.456'
];
2021-07-14 03:18:02 +12:00
$channels = Realtime::convertChannels($channels, $user->getId());
2021-06-30 23:36:58 +12:00
$this->assertCount(4, $channels);
$this->assertArrayHasKey('files', $channels);
$this->assertArrayHasKey('documents', $channels);
$this->assertArrayHasKey('documents.789', $channels);
$this->assertArrayHasKey('account.123', $channels);
$this->assertArrayNotHasKey('account', $channels);
$this->assertArrayNotHasKey('account.456', $channels);
}
2021-06-30 01:11:14 +12:00
}