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

Fix Swoole adapter all() to work directly with GQLPromise objects

Browse Source 
Instead of extracting adopted promises and delegating to SwoolePromise::all(),
implement the batch handling logic directly to properly work with GQLPromise
wrappers. Uses Swoole Channel for synchronization.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Jake Barnby
2026-01-21 18:55:20 +13:00
parent a70d67810e
commit b671bfb1c7
1 changed files with 50 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/Appwrite/GraphQL/Promises/Adapter/Swoole.php
+50 -8
View File
@@ -5,6 +5,7 @@ namespace Appwrite\GraphQL\Promises\Adapter;
use Appwrite\GraphQL\Promises\Adapter;
use Appwrite\Promises\Swoole as SwoolePromise;
use GraphQL\Executor\Promise\Promise as GQLPromise;
use Swoole\Coroutine\Channel;
class Swoole extends Adapter
{
@@ -37,14 +38,55 @@ class Swoole extends Adapter
public function all(iterable $promisesOrValues): GQLPromise
{
$swoolePromises = [];
foreach ($promisesOrValues as $promise) {
if ($promise instanceof GQLPromise) {
$swoolePromises[] = $promise->adoptedPromise;
} else {
$swoolePromises[] = $promise;
$promisesOrValues = \is_array($promisesOrValues) ? $promisesOrValues : \iterator_to_array($promisesOrValues);
return $this->create(function (callable $resolve, callable $reject) use ($promisesOrValues) {
$total = \count($promisesOrValues);
if ($total === 0) {
$resolve([]);
return;
}
}
return new GQLPromise(SwoolePromise::all($swoolePromises), $this);
$result = [];
$completed = 0;
$rejected = false;
$channel = new Channel($total);
foreach ($promisesOrValues as $index => $promiseOrValue) {
if ($promiseOrValue instanceof GQLPromise) {
$result[$index] = null;
$promiseOrValue->then(
function ($value) use ($index, &$result, &$completed, $channel) {
$result[$index] = $value;
$completed++;
$channel->push(true);
return $value;
},
function ($error) use (&$rejected, $channel, $reject) {
if (!$rejected) {
$rejected = true;
$reject($error);
}
$channel->push(false);
}
);
} else {
$result[$index] = $promiseOrValue;
$completed++;
$channel->push(true);
}
}
// Wait for all promises to complete
for ($i = 0; $i < $total; $i++) {
$channel->pop();
}
$channel->close();
if (!$rejected) {
\ksort($result);
$resolve($result);
}
});
}
}