CodeMirror/appwrite
1
0
Fork 0
mirror of synced 2024-09-30 17:26:48 +13:00
Code Issues Projects Releases Wiki Activity

feat: added deleteDeployment to executor

Browse source
This commit is contained in:
Christy Jacob 2022-01-28 05:40:53 +04:00
parent f4616a6832
commit 3418c06bc8
1 changed files with 31 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
app/executor.php
View file

@ -962,7 +962,7 @@ App::delete('/v1/functions/:functionId')
->send();
}
Console::info("Deleting $results count");
Console::info("Deleting " . count($results) . " deployments");
// Delete the containers of all deployments
// TODO : @christy Delete all build containers as well. Not just the latest one,
@ -991,7 +991,7 @@ App::delete('/v1/functions/:functionId')
$orchestration->remove('appwrite-function-' . $deployment['$id'], true);
Console::info('Removed container for deployment ' . $deployment['$id']);
} catch (Throwable $th) {
} catch (\Throwable $th) {
// Do nothing, we don't care that much if it fails
Console::error($th->getMessage());
} finally {
@ -1041,12 +1041,10 @@ App::post('/v1/functions/:functionId/deployments/:deploymentId/runtime')
App::delete('/v1/deployments/:deploymentId')
->desc('Delete a deployment')
->param('deploymentId', '', new UID(), 'Deployment unique ID.')
->inject('projectId')
->inject('response')
->inject('dbForProject')
->action(function (string $deploymentId, Response $response, Database $dbForProject) use ($orchestrationPool) {
try {
/** @var Orchestration $orchestration */
$orchestration = $orchestrationPool->get();
->action(function (string $deploymentId, string $projectId, Response $response, Database $dbForProject) use ($orchestrationPool) {
// Get deployment document
$deployment = $dbForProject->getDocument('deployments', $deploymentId);
@ -1056,7 +1054,17 @@ App::delete('/v1/deployments/:deploymentId')
throw new Exception('Deployment not found', 404);
}
global $register;
go(function () use ($projectId, $orchestrationPool, $register, $deployment) {
try {
$db = $register->get('dbPool')->get();
$redis = $register->get('redisPool')->get();
$cache = new Cache(new RedisCache($redis));
$dbForProject = new Database(new MariaDB($db), $cache);
$dbForProject->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
$dbForProject->setNamespace('_project_' . $projectId);
$orchestration = $orchestrationPool->get();
// Remove any ongoing builds
if ($deployment->getAttribute('buildId')) {
$build = $dbForProject->getDocument('builds', $deployment->getAttribute('buildId'));
@ -1071,18 +1079,18 @@ App::delete('/v1/deployments/:deploymentId')
// Remove the container of the deployment
$orchestration->remove('appwrite-function-' . $deployment['$id'], true);
Console::info('Removed container for deployment ' . $deployment['$id']);
} catch (Exception $e) {
} catch (\Throwable $th) {
// Do nothing, we don't care that much if it fails
}
} catch (Exception $e) {
logError($e, "cleanupFunction");
Console::error($th->getMessage());
} finally {
$orchestrationPool->put($orchestration);
return $response->json(['error' => $e->getMessage()]);
}
$orchestrationPool->put($orchestration);
return $response->json(['success' => true]);
});
$response
->setStatusCode(Response::STATUS_CODE_OK)
->send();
});
App::post('/v1/functions/:functionId/deployments/:deploymentId/builds/:buildId')