lee/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-09-15 09:45:54 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

More precise cache invalidation in case of item rename
Docker Image CI / build-and-push-image (push) Has been cancelled
Details
Maintain Release Merge PR / update-release-pr (push) Has been cancelled
Details
release-please / release-please (push) Has been cancelled
Details
test / test (20.x) (push) Has been cancelled
Details
test / test (22.x) (push) Has been cancelled
Details
test / api-test (22.x) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
jelveh
2025-09-28 23:43:36 -07:00
parent fe022cff1d
commit a69072b31b
3 changed files with 25 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/puter-js/src/modules/FileSystem/index.js
+22 -3
View File
@@ -1,5 +1,6 @@
import io from '../../lib/socket.io/socket.io.esm.min.js';
import * as utils from '../../lib/utils.js';
import path from '../../lib/path.js';
// Constants
//
@@ -122,9 +123,27 @@ export class PuterJSFileSystemModule extends AdvancedBase {
// });
this.socket.on('item.renamed', (item) => {
// check original_client_socket_id and if it matches this.socket.id, don't invalidate cache
puter._cache.flushall();
console.log('Flushed cache for item.renamed');
// delete old item from cache
puter._cache.del('item:' + item.old_path);
// if a directory
if(item.is_dir){
// delete readdir
puter._cache.del('readdir:' + item.old_path);
// descendants items
const descendants = puter._cache.keys('item:' + item.old_path + '/*');
for(const descendant of descendants){
console.log('Deleting cache for:', descendant);
puter._cache.del(descendant);
}
// descendants readdirs
const descendants_readdir = puter._cache.keys('readdir:' + item.old_path + '/*');
for(const descendant of descendants_readdir){
console.log('Deleting cache for:', descendant);
puter._cache.del(descendant);
}
}
// parent readdir
puter._cache.del('readdir:' + path.dirname(item.old_path));
});
this.socket.on('item.removed', (item) => {
src/puter-js/src/modules/FileSystem/operations/readdir.js
+2 -2
View File
@@ -66,12 +66,12 @@ const readdir = async function (...args) {
if(resultSize <= MAX_CACHE_SIZE){
// UPSERT the cache
await puter._cache.set(cacheKey, result);
puter._cache.set(cacheKey, result);
}
// set each individual item's cache
for(const item of result){
await puter._cache.set('item:' + item.path, item);
puter._cache.set('item:' + item.path, item);
}
resolve(result);
src/puter-js/src/modules/FileSystem/operations/stat.js
+1 -4
View File
@@ -39,8 +39,6 @@ const stat = async function (...args) {
let cacheKey;
if(options.path){
cacheKey = 'item:' + options.path;
}else if(options.uid){
cacheKey = 'item:' + options.uid;
}
if(options.consistency === 'eventual' && !options.returnSubdomains && !options.returnPermissions && !options.returnVersions && !options.returnSize){
@@ -65,8 +63,7 @@ const stat = async function (...args) {
if(resultSize <= MAX_CACHE_SIZE){
// UPSERT the cache
await puter._cache.set('item:' + result.path, result);
await puter._cache.set('item:' + result.uid, result);
puter._cache.set(cacheKey, result);
}
resolve(result);