mirror of
https://github.com/appwrite/appwrite.git
synced 2026-05-26 13:51:13 +00:00
setup to use database listeners
This commit is contained in:
@@ -16,6 +16,7 @@ use Utopia\Abuse\Abuse;
|
||||
use Utopia\Abuse\Adapters\TimeLimit;
|
||||
use Utopia\Cache\Adapter\Filesystem;
|
||||
use Utopia\Cache\Cache;
|
||||
use Utopia\CLI\Console;
|
||||
use Utopia\Database\Database;
|
||||
use Utopia\Database\DateTime;
|
||||
use Utopia\Database\Document;
|
||||
@@ -159,6 +160,38 @@ App::init()
|
||||
$deletes->setProject($project);
|
||||
$database->setProject($project);
|
||||
|
||||
$dbForProject->on(Database::EVENT_DOCUMENT_CREATE, function($event, Document $document) {
|
||||
$collection = $document->getCollection();
|
||||
Console::info('collection: ' . $collection);
|
||||
switch($collection)
|
||||
{
|
||||
case 'users':
|
||||
Console::info('user created');
|
||||
break;
|
||||
case 'databases':
|
||||
Console::info('Database created');
|
||||
break;
|
||||
case 'buckets':
|
||||
Console::info('bucket created');
|
||||
break;
|
||||
case 'functions':
|
||||
Console::info('function created');
|
||||
break;
|
||||
default:
|
||||
if(strpos($collection, 'buckets_') === 0) {
|
||||
// created file for a bucket
|
||||
Console::info('file created');
|
||||
} else if (strpos($collection, 'database_') === 0) {
|
||||
if(strpos($collection, '_collection_') != false) {
|
||||
Console::info('document created');
|
||||
} else {
|
||||
Console::info('Collection created');
|
||||
}
|
||||
}
|
||||
break;
|
||||
}
|
||||
});
|
||||
|
||||
$useCache = $route->getLabel('cache', false);
|
||||
|
||||
if ($useCache) {
|
||||
|
||||
Reference in New Issue
Block a user