cory/tildefriends
4
5
Fork 1
Code Issues 29 Pull Requests 1 Actions Releases 26 Wiki Activity

Enumerate apps without walking all DB keys.

Browse Source 
git-svn-id: https://www.unprompted.com/svn/projects/tildefriends/trunk@3768 ed5197a5-7fde-0310-b194-c3ffbd925b24
This commit is contained in:
Cory McWilliams 2022-01-15 21:48:04 +00:00
parent 1ae9aaf752
commit 4637509b3d
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
core/core.js
View File

@ -193,12 +193,17 @@ async function getProcessBlob(blobId, key, options) {
'getUser': getUser.bind(null, process, process), 'getUser': getUser.bind(null, process, process),
'user': getUser(process, process), 'user': getUser(process, process),
'apps': function() { 'apps': function() {
var apps = process.credentials && if (process.credentials &&
process.credentials.session && process.credentials.session &&
process.credentials.session.name ? process.credentials.session.name) {
new Database(process.credentials.session.name).getLike('path:%') : var db = new Database(process.credentials.session.name);
{}; try {
return Object.fromEntries(Object.keys(apps).map(key => [key.substring(5), apps[key]])); var names = JSON.parse(db.get('apps'));
return Object.fromEntries(names.map(name => [name, db.get('path:' + name)]));
} catch {
}
}
return {};
}, },
} }
}; };
@ -478,7 +483,16 @@ async function blobHandler(request, response, blobId, uri) {
return; return;
} }
var database = new Database(user); var database = new Database(user);
await database.set('path:' + app, newBlobId); var apps = new Set();
try {
apps = new Set(JSON.parse(database.get('apps')));
} catch {
}
if (!apps.has(app)) {
apps.add(app);
database.set('apps', JSON.stringify([...apps]));
}
database.set('path:' + app, newBlobId);
} }
response.writeHead(200, {"Content-Type": "text/plain; charset=utf-8"}); response.writeHead(200, {"Content-Type": "text/plain; charset=utf-8"});