mirror of
https://github.com/appwrite/appwrite.git
synced 2026-05-26 13:51:13 +00:00
add unit tests
This commit is contained in:
Torsten Dittmann
@@ -0,0 +1,310 @@
|
||||
<?php
|
||||
|
||||
namespace Appwrite\Tests;
|
||||
|
||||
use Appwrite\Database\Document;
|
||||
use Appwrite\Realtime\Realtime;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
|
||||
class RealtimeChannelsTest extends TestCase
|
||||
{
|
||||
/**
|
||||
* Configures how many Connections the Test should Mock.
|
||||
*/
|
||||
public $connectionsPerChannel = 10;
|
||||
|
||||
public $connections = [];
|
||||
public $subscriptions = [];
|
||||
public $connectionsCount = 0;
|
||||
public $connectionsAuthenticated = 0;
|
||||
public $connectionsGuest = 0;
|
||||
public $connectionsTotal = 0;
|
||||
public $allChannels = [
|
||||
'files',
|
||||
'files.1',
|
||||
'collections',
|
||||
'collections.1',
|
||||
'collections.1.documents',
|
||||
'collections.2',
|
||||
'collections.2.documents',
|
||||
'documents',
|
||||
'documents.1',
|
||||
'documents.2',
|
||||
];
|
||||
|
||||
|
||||
|
||||
public function setUp(): void
|
||||
{
|
||||
/**
|
||||
* Setup global Counts
|
||||
*/
|
||||
$this->connectionsAuthenticated = count($this->allChannels) * $this->connectionsPerChannel;
|
||||
$this->connectionsGuest = count($this->allChannels) * $this->connectionsPerChannel;
|
||||
$this->connectionsTotal = $this->connectionsAuthenticated + $this->connectionsGuest;
|
||||
|
||||
/**
|
||||
* Add 100 Authenticated Clients
|
||||
*/
|
||||
for ($i = 0; $i < $this->connectionsPerChannel; $i++) {
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
Realtime::setUser(new Document([
|
||||
'$id' => 'user' . $this->connectionsCount,
|
||||
'memberships' => [
|
||||
[
|
||||
'teamId' => 'team' . $i,
|
||||
'roles' => [
|
||||
empty($index % 2) ? 'admin' : 'member'
|
||||
]
|
||||
]
|
||||
]
|
||||
]));
|
||||
|
||||
Realtime::addSubscription(
|
||||
'1',
|
||||
$this->connectionsCount,
|
||||
$this->subscriptions,
|
||||
$this->connections,
|
||||
Realtime::getRoles(),
|
||||
Realtime::parseChannels([0 => $channel])
|
||||
);
|
||||
|
||||
$this->connectionsCount++;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Add 100 Guest Clients
|
||||
*/
|
||||
for ($i = 0; $i < $this->connectionsPerChannel; $i++) {
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
Realtime::setUser(new Document([
|
||||
'$id' => ''
|
||||
]));
|
||||
|
||||
Realtime::addSubscription(
|
||||
'1',
|
||||
$this->connectionsCount,
|
||||
$this->subscriptions,
|
||||
$this->connections,
|
||||
Realtime::getRoles(),
|
||||
Realtime::parseChannels([0 => $channel])
|
||||
);
|
||||
|
||||
$this->connectionsCount++;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public function tearDown(): void
|
||||
{
|
||||
$this->connections = [];
|
||||
$this->subscriptions = [];
|
||||
$this->connectionsCount = 0;
|
||||
}
|
||||
|
||||
public function testSubscriptions()
|
||||
{
|
||||
/**
|
||||
* Check for 1 project.
|
||||
*/
|
||||
$this->assertCount(1, $this->subscriptions);
|
||||
|
||||
/**
|
||||
* Check for 133 subscriptions:
|
||||
* - XXX users
|
||||
* - 1 *
|
||||
* - 1 role:guest
|
||||
* - 1 role:member
|
||||
* - 10 teams
|
||||
* - 20 team roles (2 roles per team)
|
||||
*/
|
||||
$this->assertCount(($this->connectionsAuthenticated + (3 * $this->connectionsPerChannel) + 3), $this->subscriptions['1']);
|
||||
|
||||
/**
|
||||
* Check for 200 connections
|
||||
* - 100 Authenticated
|
||||
* - 100 Guests
|
||||
*/
|
||||
$this->assertCount($this->connectionsTotal, $this->connections);
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests Wildcard (*) Permissions on every channel.
|
||||
*/
|
||||
public function testWildcardPermission()
|
||||
{
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => ['*'],
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => $channel,
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
/**
|
||||
* Every Client subscribed to the Wildcard should receive this event.
|
||||
*/
|
||||
$this->assertCount($this->connectionsTotal / count($this->allChannels), $receivers, $channel);
|
||||
|
||||
foreach ($receivers as $receiver) {
|
||||
/**
|
||||
* Making sure the right clients receive the event.
|
||||
*/
|
||||
$this->assertStringEndsWith($index, $receiver);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public function testRolePermissions()
|
||||
{
|
||||
$roles = ['role:guest', 'role:member'];
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
foreach ($roles as $role) {
|
||||
$permissions = [$role];
|
||||
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => $permissions,
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => $channel,
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
/**
|
||||
* Every Role subscribed to a Channel should receive this event.
|
||||
*/
|
||||
$this->assertCount($this->connectionsPerChannel, $receivers, $channel);
|
||||
|
||||
foreach ($receivers as $receiver) {
|
||||
/**
|
||||
* Making sure the right clients receive the event.
|
||||
*/
|
||||
$this->assertStringEndsWith($index, $receiver);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public function testUserPermissions()
|
||||
{
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
$permissions = [];
|
||||
for ($i = 0; $i < $this->connectionsPerChannel; $i++) {
|
||||
$permissions[] = 'user:user' . (!empty($i) ? $i : '') . $index;
|
||||
}
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => $permissions,
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => $channel,
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
/**
|
||||
* Every Client subscribed to a Channel should receive this event.
|
||||
*/
|
||||
$this->assertCount($this->connectionsAuthenticated / count($this->allChannels), $receivers, $channel);
|
||||
|
||||
foreach ($receivers as $receiver) {
|
||||
/**
|
||||
* Making sure the right clients receive the event.
|
||||
*/
|
||||
$this->assertStringEndsWith($index, $receiver);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
public function testTeamPermissions()
|
||||
{
|
||||
foreach ($this->allChannels as $index => $channel) {
|
||||
$permissions = [];
|
||||
|
||||
for ($i = 0; $i < $this->connectionsPerChannel; $i++) {
|
||||
$permissions[] = 'team:team' . $i;
|
||||
}
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => $permissions,
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => $channel,
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
/**
|
||||
* Every Team Member should receive this event.
|
||||
*/
|
||||
$this->assertCount($this->connectionsAuthenticated / count($this->allChannels), $receivers, $channel);
|
||||
|
||||
foreach ($receivers as $receiver) {
|
||||
/**
|
||||
* Making sure the right clients receive the event.
|
||||
*/
|
||||
$this->assertStringEndsWith($index, $receiver);
|
||||
}
|
||||
|
||||
$permissions = ['team:team' . $index . '/' . (empty($index % 2) ? 'admin' : 'member')];
|
||||
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => $permissions,
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => $channel,
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
/**
|
||||
* Only 1 Team Member of a role should have access to a specific channel.
|
||||
*/
|
||||
$this->assertCount(1, $receivers, $channel);
|
||||
|
||||
foreach ($receivers as $receiver) {
|
||||
/**
|
||||
* Making sure the right clients receive the event.
|
||||
*/
|
||||
$this->assertStringEndsWith($index, $receiver);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,205 @@
|
||||
<?php
|
||||
|
||||
namespace Appwrite\Tests;
|
||||
|
||||
use Appwrite\Database\Document;
|
||||
use Appwrite\Realtime\Realtime;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
|
||||
class RealtimeGuestTest extends TestCase
|
||||
{
|
||||
public $connections = [];
|
||||
public $subscriptions = [];
|
||||
|
||||
public function setUp(): void
|
||||
{
|
||||
}
|
||||
|
||||
public function tearDown(): void
|
||||
{
|
||||
}
|
||||
|
||||
public function testGuest()
|
||||
{
|
||||
Realtime::setUser(new Document([
|
||||
'$id' => ''
|
||||
]));
|
||||
|
||||
$roles = Realtime::getRoles();
|
||||
$this->assertCount(2, $roles);
|
||||
$this->assertContains('*', $roles);
|
||||
$this->assertContains('role:guest', $roles);
|
||||
|
||||
$channels = [
|
||||
0 => 'files',
|
||||
1 => 'documents',
|
||||
2 => 'documents.789',
|
||||
3 => 'account',
|
||||
4 => 'account.456'
|
||||
];
|
||||
|
||||
$channels = Realtime::parseChannels($channels);
|
||||
$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);
|
||||
|
||||
Realtime::addSubscription('1', 1, $this->subscriptions, $this->connections, $roles, $channels);
|
||||
|
||||
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => ['*'],
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => 'documents',
|
||||
1 => 'documents',
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['role:guest'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['role:member'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['user:123'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:abc'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:abc/administrator'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:abc/god'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:def'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:def/guest'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['user:456'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:def/member'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['*'];
|
||||
$event['data']['channels'] = ['documents.123'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['data']['channels'] = ['documents.789'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['project'] = '2';
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,223 @@
|
||||
<?php
|
||||
|
||||
namespace Appwrite\Tests;
|
||||
|
||||
use Appwrite\Database\Document;
|
||||
use Appwrite\Realtime\Realtime;
|
||||
use PHPUnit\Framework\TestCase;
|
||||
|
||||
class RealtimeTest extends TestCase
|
||||
{
|
||||
public $connections = [];
|
||||
public $subscriptions = [];
|
||||
|
||||
public function setUp(): void
|
||||
{
|
||||
}
|
||||
|
||||
public function tearDown(): void
|
||||
{
|
||||
}
|
||||
|
||||
public function testUser()
|
||||
{
|
||||
Realtime::setUser(new Document([
|
||||
'$id' => '123',
|
||||
'memberships' => [
|
||||
[
|
||||
'teamId' => 'abc',
|
||||
'roles' => [
|
||||
'administrator',
|
||||
'god'
|
||||
]
|
||||
],
|
||||
[
|
||||
'teamId' => 'def',
|
||||
'roles' => [
|
||||
'guest'
|
||||
]
|
||||
]
|
||||
]
|
||||
]));
|
||||
|
||||
$roles = Realtime::getRoles();
|
||||
|
||||
$this->assertCount(8, $roles);
|
||||
$this->assertContains('*', $roles);
|
||||
$this->assertContains('user:123', $roles);
|
||||
$this->assertContains('role:member', $roles);
|
||||
$this->assertContains('team:abc', $roles);
|
||||
$this->assertContains('team:abc/administrator', $roles);
|
||||
$this->assertContains('team:abc/god', $roles);
|
||||
$this->assertContains('team:def', $roles);
|
||||
$this->assertContains('team:def/guest', $roles);
|
||||
|
||||
$channels = [
|
||||
0 => 'files',
|
||||
1 => 'documents',
|
||||
2 => 'documents.789',
|
||||
3 => 'account',
|
||||
4 => 'account.456'
|
||||
];
|
||||
|
||||
$channels = Realtime::parseChannels($channels);
|
||||
|
||||
$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);
|
||||
|
||||
Realtime::addSubscription('1', 1, $this->subscriptions, $this->connections, $roles, $channels);
|
||||
|
||||
$event = [
|
||||
'project' => '1',
|
||||
'permissions' => ['*'],
|
||||
'data' => [
|
||||
'channels' => [
|
||||
0 => 'account.123',
|
||||
]
|
||||
]
|
||||
];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['role:member'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['user:123'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['team:abc'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['team:abc/administrator'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['team:abc/god'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['team:def'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['team:def/guest'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['permissions'] = ['user:456'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['team:def/member'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['permissions'] = ['*'];
|
||||
$event['data']['channels'] = ['documents.123'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
|
||||
$event['data']['channels'] = ['documents.789'];
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertCount(1, $receivers);
|
||||
$this->assertEquals(1, $receivers[0]);
|
||||
|
||||
$event['project'] = '2';
|
||||
|
||||
$receivers = Realtime::identifyReceivers(
|
||||
$event,
|
||||
$this->connections,
|
||||
$this->subscriptions
|
||||
);
|
||||
|
||||
$this->assertEmpty($receivers);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user