Add getProxyProjectDatabase hook
This commit is contained in:
parent
a7e95588c6
commit
939aec866e
1 changed files with 8 additions and 5 deletions
|
@ -172,9 +172,14 @@ App::post('/v1/projects')
|
||||||
throw new Exception(Exception::PROJECT_ALREADY_EXISTS);
|
throw new Exception(Exception::PROJECT_ALREADY_EXISTS);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Useful for ZDT to mirror the project to destination
|
||||||
|
$dbForProject = $hooks->trigger('getProxyProjectDatabase', [ $project, $pools, $cache ]);
|
||||||
|
|
||||||
|
if(empty($dbForProject)) {
|
||||||
$dbForProject = new Database($pools->get($database)->pop()->getResource(), $cache);
|
$dbForProject = new Database($pools->get($database)->pop()->getResource(), $cache);
|
||||||
$dbForProject->setNamespace("_{$project->getInternalId()}");
|
$dbForProject->setNamespace("_{$project->getInternalId()}");
|
||||||
$dbForProject->create();
|
$dbForProject->create();
|
||||||
|
}
|
||||||
|
|
||||||
$audit = new Audit($dbForProject);
|
$audit = new Audit($dbForProject);
|
||||||
$audit->setup();
|
$audit->setup();
|
||||||
|
@ -219,8 +224,6 @@ App::post('/v1/projects')
|
||||||
$dbForProject->createCollection($key, $attributes, $indexes);
|
$dbForProject->createCollection($key, $attributes, $indexes);
|
||||||
}
|
}
|
||||||
|
|
||||||
$hooks->trigger('afterProjectCreated'); // Useful for ZDT to mirror the project to destination
|
|
||||||
|
|
||||||
$response
|
$response
|
||||||
->setStatusCode(Response::STATUS_CODE_CREATED)
|
->setStatusCode(Response::STATUS_CODE_CREATED)
|
||||||
->dynamic($project, Response::MODEL_PROJECT);
|
->dynamic($project, Response::MODEL_PROJECT);
|
||||||
|
|
Loading…
Reference in a new issue