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

static scope to instance

Browse Source
This commit is contained in:
shimon
2022-10-13 09:27:55 +03:00
parent c6a054f88d
commit e25dd11049
2 changed files with 43 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/controllers/api/syncs.php
+5 -5
View File
@@ -25,11 +25,11 @@ App::post('/v1/syncs')
$token = $request->getHeader('authorization');
$token = str_replace(["Bearer"," "], "", $token);
$jwt = new JWT(App::getEnv('_APP_OPENSSL_KEY_V1'), 'HS256', 900, 10);
// try {
// $payload = $jwt->decode($token);
// } catch (JWTException $error) {
// throw new Exception(Exception::USER_JWT_INVALID, 'Failed to verify JWT. ' . $error->getMessage());
// }
try {
$payload = $jwt->decode($token);
} catch (JWTException $error) {
throw new Exception(Exception::USER_JWT_INVALID, 'Failed to verify JWT. ' . $error->getMessage());
}
$syncIn = new SyncIn();
foreach ($keys as $key) {
app/init.php
+38 -22
View File
@@ -759,24 +759,6 @@ App::setResource('clients', function ($request, $console, $project) use ($regist
'hostname' => $request->getHostname(),
], Document::SET_TYPE_APPEND);
$register->set('syncOut', function () {
return new SyncOut();
});
cache::on(cache::EVENT_PURGE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
cache::on(cache::EVENT_SAVE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
/**
* Get All verified client URLs for both console and current projects
* + Filter for duplicated entries
@@ -945,25 +927,59 @@ App::setResource('console', function () {
]);
}, []);
App::setResource('dbForProject', function ($db, $cache, Document $project) {
$register->set('syncOut', function () {
return new SyncOut();
});
App::setResource('dbForProject', function ($db, $cache, Document $project, $register) {
$cache = new Cache(new RedisCache($cache));
$cache->attach(cache::EVENT_SAVE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
$cache->attach(cache::EVENT_PURGE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
$database = new Database(new MariaDB($db), $cache);
$database->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
$database->setNamespace("_{$project->getInternalId()}");
return $database;
}, ['db', 'cache', 'project']);
}, ['db', 'cache', 'project', 'register']);
App::setResource('dbForConsole', function ($db, $cache, $register) {
App::setResource('dbForConsole', function ($db, $cache) {
$cache = new Cache(new RedisCache($cache));
$cache->attach(cache::EVENT_SAVE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
$cache->attach(cache::EVENT_PURGE, function ($key) use ($register) {
$register
->get('syncOut')
->addKey($key)
->trigger();
});
$database = new Database(new MariaDB($db), $cache);
$database->setDefaultDatabase(App::getEnv('_APP_DB_SCHEMA', 'appwrite'));
$database->setNamespace('_console');
return $database;
}, ['db', 'cache']);
}, ['db', 'cache', 'register']);
App::setResource('deviceLocal', function () {