mirror of
https://github.com/appwrite/appwrite.git
synced 2026-05-26 13:51:13 +00:00
71 lines
2.3 KiB
PHP
71 lines
2.3 KiB
PHP
<?php
|
|
|
|
use Ahc\Jwt\JWT;
|
|
use Ahc\Jwt\JWTException;
|
|
use Appwrite\DSN\DSN;
|
|
use Appwrite\Extend\Exception;
|
|
use Appwrite\URL\URL as AppwriteURL;
|
|
use Appwrite\Utopia\Request;
|
|
use Appwrite\Utopia\Response;
|
|
use Utopia\App;
|
|
use Utopia\Database\Document;
|
|
use Utopia\Queue\Client as SyncIn;
|
|
use Utopia\Queue\Connection\Redis as QueueRedis;
|
|
use Utopia\Validator\ArrayList;
|
|
use Utopia\Validator\Text;
|
|
|
|
App::init()
|
|
->groups(['edge'])
|
|
->inject('request')
|
|
->action(function (Request $request) {
|
|
|
|
$token = $request->getHeader('authorization');
|
|
$token = str_replace(["Bearer"," "], "", $token);
|
|
$jwt = new JWT(App::getEnv('_APP_OPENSSL_KEY_V1'), 'HS256', 600, 10);
|
|
try {
|
|
$payload = $jwt->decode($token);
|
|
} catch (JWTException $error) {
|
|
throw new Exception(Exception::USER_JWT_INVALID, 'Failed to verify JWT. ' . $error->getMessage());
|
|
}
|
|
});
|
|
|
|
App::post('/v1/edge/sync')
|
|
->desc('Purge cache keys')
|
|
->groups(['edge'])
|
|
->label('scope', 'public')
|
|
->param('keys', '', new ArrayList(new Text(100), 1000), 'Cache keys. an array containing alphanumerical cache keys')
|
|
->inject('request')
|
|
->inject('response')
|
|
->action(function (array $keys, Request $request, Response $response) {
|
|
|
|
if (empty($keys)) {
|
|
throw new Exception(Exception::KEY_NOT_FOUND);
|
|
}
|
|
|
|
$fallbackForRedis = AppwriteURL::unparse([
|
|
'scheme' => 'redis',
|
|
'host' => App::getEnv('_APP_REDIS_HOST', 'redis'),
|
|
'port' => App::getEnv('_APP_REDIS_PORT', '6379'),
|
|
'user' => App::getEnv('_APP_REDIS_USER', ''),
|
|
'pass' => App::getEnv('_APP_REDIS_PASS', ''),
|
|
]);
|
|
|
|
$connection = App::getEnv('_APP_CONNECTIONS_QUEUE', $fallbackForRedis);
|
|
$dsns = explode(',', $connection ?? '');
|
|
|
|
if (empty($dsns)) {
|
|
throw new Exception(Exception::GENERAL_SERVER_ERROR);
|
|
}
|
|
|
|
$dsn = explode('=', $dsns[0]);
|
|
$dsn = $dsn[1] ?? '';
|
|
$dsn = new DSN($dsn);
|
|
$client = new SyncIn('syncIn', new QueueRedis($dsn->getHost(), $dsn->getPort()));
|
|
|
|
$client->enqueue(['value' => ['keys' => $keys]]);
|
|
|
|
$response->dynamic(new Document([
|
|
'keys' => $keys
|
|
]), Response::MODEL_EDGE_SYNC);
|
|
});
|