* database response model * database collection config * new database scopes * database service update * database execption codes * remove read write permission from database model * updating tests and fixing some bugs * server side tests are now passing * databases api * tests for database endpoint * composer update * fix error * formatting * formatting fixes * get database test * more updates to events and usage * more usage updates * fix delete type * fix test * delete database * more fixes * databaseId in attributes and indexes * more fixes * fix issues * fix index subquery * fix console scope and index query * updating tests as required * fix phpcs errors and warnings * updates to review suggestions * UI progress * ui updates and cleaning up * fix type * rework database events * update tests * update types * event generation fixed * events config updated * updating context to support multiple * realtime updates * fix ids * update context * validator updates * fix naming conflict * fix tests * fix lint errors * fix wprler and realtime tests * fix webhooks test * fix event validator and other tests * formatting fixes * removing leftover var_dumps * remove leftover comment * update usage params * usage metrics updates * update database usage * fix usage * specs update * updates to usage * fix UI and usage * fix lints * internal id fixes * fixes for internal Id * renaming services and related files * rename tests * rename doc link * rename readme * fix test name * tests: fixes for 0.15.x sync Co-authored-by: Torsten Dittmann <torsten.dittmann@googlemail.com>
174 lines
7 KiB
PHP
174 lines
7 KiB
PHP
<?php
|
|
|
|
namespace Appwrite\Tests;
|
|
|
|
use Appwrite\Event\Event;
|
|
use InvalidArgumentException;
|
|
use PHPUnit\Framework\TestCase;
|
|
use Utopia\App;
|
|
|
|
class EventTest extends TestCase
|
|
{
|
|
/**
|
|
* @var Event
|
|
*/
|
|
protected $object = null;
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
protected $queue = '';
|
|
|
|
public function setUp(): void
|
|
{
|
|
$redisHost = App::getEnv('_APP_REDIS_HOST', '');
|
|
$redisPort = App::getEnv('_APP_REDIS_PORT', '');
|
|
\Resque::setBackend($redisHost . ':' . $redisPort);
|
|
|
|
$this->queue = 'v1-tests' . uniqid();
|
|
$this->object = new Event($this->queue, 'TestsV1');
|
|
}
|
|
|
|
public function tearDown(): void
|
|
{
|
|
}
|
|
|
|
public function testQueue()
|
|
{
|
|
$this->assertEquals($this->queue, $this->object->getQueue());
|
|
|
|
$this->object->setQueue('demo');
|
|
|
|
$this->assertEquals('demo', $this->object->getQueue());
|
|
|
|
$this->object->setQueue($this->queue);
|
|
}
|
|
|
|
public function testClass()
|
|
{
|
|
$this->assertEquals('TestsV1', $this->object->getClass());
|
|
|
|
$this->object->setClass('TestsV2');
|
|
|
|
$this->assertEquals('TestsV2', $this->object->getClass());
|
|
|
|
$this->object->setClass('TestsV1');
|
|
}
|
|
|
|
public function testParams()
|
|
{
|
|
$this->object
|
|
->setParam('eventKey1', 'eventValue1')
|
|
->setParam('eventKey2', 'eventValue2');
|
|
|
|
$this->object->trigger();
|
|
|
|
$this->assertEquals('eventValue1', $this->object->getParam('eventKey1'));
|
|
$this->assertEquals('eventValue2', $this->object->getParam('eventKey2'));
|
|
$this->assertEquals(null, $this->object->getParam('eventKey3'));
|
|
$this->assertEquals(\Resque::size($this->queue), 1);
|
|
}
|
|
|
|
public function testReset()
|
|
{
|
|
$this->object
|
|
->setParam('eventKey1', 'eventValue1')
|
|
->setParam('eventKey2', 'eventValue2');
|
|
|
|
$this->assertEquals('eventValue1', $this->object->getParam('eventKey1'));
|
|
$this->assertEquals('eventValue2', $this->object->getParam('eventKey2'));
|
|
|
|
$this->object->reset();
|
|
|
|
$this->assertEquals(null, $this->object->getParam('eventKey1'));
|
|
$this->assertEquals(null, $this->object->getParam('eventKey2'));
|
|
$this->assertEquals(null, $this->object->getParam('eventKey3'));
|
|
}
|
|
|
|
public function testGenerateEvents()
|
|
{
|
|
$event = Event::generateEvents('users.[userId].create', [
|
|
'userId' => 'torsten'
|
|
]);
|
|
$this->assertCount(4, $event);
|
|
$this->assertContains('users.torsten.create', $event);
|
|
$this->assertContains('users.torsten', $event);
|
|
$this->assertContains('users.*.create', $event);
|
|
$this->assertContains('users.*', $event);
|
|
|
|
$event = Event::generateEvents('users.[userId].update.email', [
|
|
'userId' => 'torsten'
|
|
]);
|
|
$this->assertCount(6, $event);
|
|
$this->assertContains('users.torsten.update.email', $event);
|
|
$this->assertContains('users.torsten.update', $event);
|
|
$this->assertContains('users.torsten', $event);
|
|
$this->assertContains('users.*.update.email', $event);
|
|
$this->assertContains('users.*.update', $event);
|
|
$this->assertContains('users.*', $event);
|
|
|
|
$event = Event::generateEvents('collections.[collectionId].documents.[documentId].create', [
|
|
'collectionId' => 'chapters',
|
|
'documentId' => 'prolog',
|
|
]);
|
|
$this->assertCount(10, $event);
|
|
|
|
$this->assertContains('collections.chapters.documents.prolog.create', $event);
|
|
$this->assertContains('collections.chapters.documents.prolog', $event);
|
|
$this->assertContains('collections.chapters.documents.*.create', $event);
|
|
$this->assertContains('collections.chapters.documents.*', $event);
|
|
$this->assertContains('collections.chapters', $event);
|
|
$this->assertContains('collections.*.documents.prolog.create', $event);
|
|
$this->assertContains('collections.*.documents.prolog', $event);
|
|
$this->assertContains('collections.*.documents.*.create', $event);
|
|
$this->assertContains('collections.*.documents.*', $event);
|
|
$this->assertContains('collections.*', $event);
|
|
|
|
$event = Event::generateEvents('databases.[databaseId].collections.[collectionId].documents.[documentId].create', [
|
|
'databaseId' => 'chaptersDB',
|
|
'collectionId' => 'chapters',
|
|
'documentId' => 'prolog',
|
|
]);
|
|
|
|
$this->assertCount(22, $event);
|
|
$this->assertContains('databases.chaptersDB.collections.chapters.documents.prolog.create', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.chapters.documents.prolog', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.chapters.documents.*.create', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.chapters.documents.*', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.chapters', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.*.documents.prolog.create', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.*.documents.prolog', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.*', $event);
|
|
$this->assertContains('databases.chaptersDB', $event);
|
|
$this->assertContains('databases.*.collections.chapters.documents.prolog.create', $event);
|
|
$this->assertContains('databases.*.collections.chapters.documents.prolog', $event);
|
|
$this->assertContains('databases.*.collections.chapters', $event);
|
|
$this->assertContains('databases.*.collections.*.documents.*.create', $event);
|
|
$this->assertContains('databases.*.collections.*.documents.*', $event);
|
|
$this->assertContains('databases.*.collections.*', $event);
|
|
$this->assertContains('databases.*', $event);
|
|
$this->assertContains('databases.*.collections.*.documents.prolog', $event);
|
|
$this->assertContains('databases.*.collections.*.documents.prolog.create', $event);
|
|
$this->assertContains('databases.*.collections.chapters.documents.*', $event);
|
|
$this->assertContains('databases.*.collections.chapters.documents.*.create', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.*.documents.*', $event);
|
|
$this->assertContains('databases.chaptersDB.collections.*.documents.*.create', $event);
|
|
|
|
|
|
try {
|
|
$event = Event::generateEvents('collections.[collectionId].documents.[documentId].create', [
|
|
'collectionId' => 'chapters'
|
|
]);
|
|
$this->fail();
|
|
} catch (\Throwable $th) {
|
|
$this->assertInstanceOf(InvalidArgumentException::class, $th, 'An invalid exception was thrown');
|
|
}
|
|
|
|
try {
|
|
$event = Event::generateEvents('collections.[collectionId].documents.[documentId].create');
|
|
$this->fail();
|
|
} catch (\Throwable $th) {
|
|
$this->assertInstanceOf(InvalidArgumentException::class, $th, 'An invalid exception was thrown');
|
|
}
|
|
}
|
|
}
|