Appwrite/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite.git synced 2026-05-26 13:51:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

update: use helper method.

Browse Source
This commit is contained in:
Darshan
2026-01-26 17:06:52 +05:30
parent 7fb654e3a4
commit 6345802b1a
1 changed files with 38 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/Platform/Installer/HttpHandler.php
+38 -29
View File
@@ -535,35 +535,7 @@ class HttpHandler
}
$this->state->updateGlobalLock($installId, Server::STATUS_COMPLETED);
} catch (\Throwable $e) {
http_response_code(500);
if ($installId !== '') {
$details = ['trace' => $e->getTraceAsString()];
$previous = $e->getPrevious();
if ($previous instanceof \Throwable && $previous->getMessage() !== '') {
$details['output'] = $previous->getMessage();
}
$this->state->writeProgressFile($installId, [
'step' => Server::STATUS_ERROR,
'status' => Server::STATUS_ERROR,
'message' => $e->getMessage(),
'details' => $details,
'updatedAt' => time(),
]);
}
if ($installId !== '') {
$this->state->updateGlobalLock($installId, Server::STATUS_ERROR);
}
@unlink(Server::INSTALLER_CONFIG_FILE);
if ($wantsStream) {
$details = ['trace' => $e->getTraceAsString()];
$previous = $e->getPrevious();
if ($previous instanceof \Throwable && $previous->getMessage() !== '') {
$details['output'] = $previous->getMessage();
}
$this->sendSseEvent(Server::STATUS_ERROR, ['message' => $e->getMessage(), 'details' => $details]);
} else {
echo json_encode(['success' => false, 'message' => $e->getMessage()]);
}
$this->handleInstallationError($e, $installId, $wantsStream);
}
return true;
@@ -640,4 +612,41 @@ class HttpHandler
}
exit;
}
private function buildErrorDetails(\Throwable $e): array
{
$details = ['trace' => $e->getTraceAsString()];
$previous = $e->getPrevious();
if ($previous instanceof \Throwable && $previous->getMessage() !== '') {
$details['output'] = $previous->getMessage();
}
return $details;
}
private function handleInstallationError(\Throwable $e, string $installId, bool $wantsStream): void
{
http_response_code(500);
if ($installId !== '') {
$this->state->writeProgressFile($installId, [
'step' => Server::STATUS_ERROR,
'status' => Server::STATUS_ERROR,
'message' => $e->getMessage(),
'details' => $this->buildErrorDetails($e),
'updatedAt' => time(),
]);
$this->state->updateGlobalLock($installId, Server::STATUS_ERROR);
}
@unlink(Server::INSTALLER_CONFIG_FILE);
if ($wantsStream) {
$this->sendSseEvent(Server::STATUS_ERROR, [
'message' => $e->getMessage(),
'details' => $this->buildErrorDetails($e)
]);
} else {
echo json_encode(['success' => false, 'message' => $e->getMessage()]);
}
}
}