Elgato_dark/appwrite
1
0
Fork 0
mirror of https://github.com/appwrite/appwrite synced 2026-05-23 17:08:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Update query list for db collection

Browse source
This commit is contained in:
Jake Barnby 2022-05-03 17:40:26 +12:00
parent 4b216fccb9
commit f31080f52c
No known key found for this signature in database
GPG key ID: A4674EBC0E404657
1 changed files with 43 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
src/Appwrite/GraphQL/Builder.php
View file

@ -489,16 +489,55 @@ class Builder
);
}
private static function queryList(string $collectionId, Database $dbForProject): callable
private static function queryList(
App $utopia,
Request $request,
Response $response,
Database $dbForProject,
string $collectionId
): callable
{
return fn($type, $args, $context, $info) => new CoroutinePromise(
function (callable $resolve, callable $reject) use ($collectionId, $type, $args, $dbForProject) {
function (callable $resolve, callable $reject) use ($utopia, $request, $response, $dbForProject, $collectionId, $type, $args) {
$swooleRq = $request->getSwoole();
$swooleRq->post = [
'collectionId' => $collectionId,
'limit' => $args['limit'],
'offset' => $args['offset'],
'cursor' => $args['cursor'],
'cursorDirection' => $args['cursorDirection'],
'orderAttributes' => $args['orderAttributes'],
'orderType' => $args['orderType'],
];
// Drop json content type so post args are used directly
if (\array_key_exists('content-type', $swooleRq->header)
&& $swooleRq->header['content-type'] === 'application/json') {
unset($swooleRq->header['content-type']);
}
$url = '/v1/database/collections/:collectionId/documents';
$route = $utopia->getRoutes()['GET'][$url];
$request = new Request($swooleRq);
$response = new Response($response->getSwoole());
$utopia->setResource('request', fn() => $request);
$utopia->setResource('response', fn() => $response);
$response->setContentType(Response::CONTENT_TYPE_NULL);
try {
$list = $dbForProject->find($collectionId);
$resolve($list);
$utopia->setRoute($route)->execute($route, $request);
} catch (\Throwable $e) {
$reject($e);
}
$result = \array_map(
fn($value) => $value['data'],
$response->getPayload()['documents']
);
$resolve($result);
}
);
}