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

feat: GraphQL DI

Browse Source
This commit is contained in:
Binyamin Yawitz
2024-06-21 17:22:58 -04:00
parent ca0e44620a
commit 4ef09b680f
3 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/GraphQL/Resolvers.php
+10 -8
View File
@@ -30,8 +30,10 @@ class Resolvers
UtopiaHttpResponse $response,
Container $container,
): callable {
$resolver = $this;
return fn ($type, $args, $context, $info) => new Swoole(
function (callable $resolve, callable $reject) use ($http, $route, $args, $context, $container, $info, $request, $response) {
function (callable $resolve, callable $reject) use ($http, $route, $args, $context, $container, $info, $request, $response, $resolver) {
$path = $route->getPath();
foreach ($args as $key => $value) {
if (\str_contains($path, '/:' . $key)) {
@@ -50,7 +52,7 @@ class Resolvers
$request->setPayload($args);
break;
}
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject);
}
);
}
@@ -101,7 +103,7 @@ class Resolvers
$request->setMethod('GET');
$request->setURI($url($databaseId, $collectionId, $args));
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject);
}
);
}
@@ -137,7 +139,7 @@ class Resolvers
return $payload['documents'];
};
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject, $beforeResolve);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject, $beforeResolve);
}
);
}
@@ -169,7 +171,7 @@ class Resolvers
$request->setURI($url($databaseId, $collectionId, $args));
$request->setPayload($params($databaseId, $collectionId, $args));
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject);
}
);
}
@@ -201,7 +203,7 @@ class Resolvers
$request->setURI($url($databaseId, $collectionId, $args));
$request->setPayload($params($databaseId, $collectionId, $args));
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject);
}
);
}
@@ -230,7 +232,7 @@ class Resolvers
$request->setMethod('DELETE');
$request->setURI($url($databaseId, $collectionId, $args));
Resolvers::resolve($http, $request, $response, $container, $resolve, $reject);
$resolver->resolve($http, $request, $response, $container, $resolve, $reject);
}
);
}
@@ -246,7 +248,7 @@ class Resolvers
* @return void
* @throws Exception
*/
private static function resolve(
private function resolve(
Http $http,
Request $request,
Response $response,
src/Appwrite/Promises/Swoole.php
+5 -7
View File
@@ -11,13 +11,11 @@ class Swoole extends Promise
callable $resolve,
callable $reject
): void {
\go(function () use ($executor, $resolve, $reject) {
try {
$executor($resolve, $reject);
} catch (\Throwable $exception) {
$reject($exception);
}
});
try {
$executor($resolve, $reject);
} catch (\Throwable $exception) {
$reject($exception);
}
}
/**
tests/e2e/Services/GraphQL/Base.php
+1 -1
View File
@@ -2498,6 +2498,6 @@ trait Base
protected function packageCode($folder): void
{
Console::execute('cd ' . realpath(__DIR__ . "/../../../resources/functions") . "/$folder && tar --exclude code.tar.gz -czf code.tar.gz .", '', $this->stdout, $this->stderr);
Console::execute('cd ' . realpath(__DIR__ . "/../../../resources/functions") . "/$folder && tar --exclude code.tar.gz -czf code.tar.gz .", '', $this->stdout);
}
}