mirror/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-01-05 20:50:22 -06:00
Code Issues Packages Projects Releases Wiki Activity

dev(puterfs): move quick_check to extension

Browse Source
This commit is contained in:
KernelDeimos
2025-11-05 16:31:42 -05:00
committed by Eric Dubé
parent f2ad7ddfb5
commit acb9c4660c
2 changed files with 47 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

45
extensions/puterfs/main.js
View File

@@ -23,6 +23,7 @@ const svc_trace = extension.import('service:traceService');
// TODO: these services ought to be part of this extension
const svc_size = extension.import('service:sizeService');
const svc_fsEntry = extension.import('service:fsEntryService');
const svc_fsEntryFetcher = extension.import('service:fsEntryFetcher');
// TODO: depending on mountpoint service will not be necessary
// once the storage provider is moved to this extension
@@ -47,7 +48,51 @@ const {
TYPE_DIRECTORY,
} = extension.import('core').fs;
const {
NodeChildSelector,
NodeUIDSelector,
NodeInternalIDSelector,
} = extension.import('core').fs.selectors;
class PuterFSProvider {
/**
* Check if a given node exists.
*
* @param {Object} param
* @param {NodeSelector} param.selector - The selector used for checking.
* @returns {Promise<boolean>} - True if the node exists, false otherwise.
*/
async quick_check ({
selector,
}) {
// shortcut: has full path
if ( selector?.path ) {
const entry = await svc_fsEntryFetcher.findByPath(selector.path);
return Boolean(entry);
}
// shortcut: has uid
if ( selector?.uid ) {
const entry = await svc_fsEntryFetcher.findByUID(selector.uid);
return Boolean(entry);
}
// shortcut: parent uid + child name
if ( selector instanceof NodeChildSelector && selector.parent instanceof NodeUIDSelector ) {
return await svc_fsEntryFetcher.nameExistsUnderParent(selector.parent.uid,
selector.name);
}
// shortcut: parent id + child name
if ( selector instanceof NodeChildSelector && selector.parent instanceof NodeInternalIDSelector ) {
return await svc_fsEntryFetcher.nameExistsUnderParentID(selector.parent.id,
selector.name);
}
return false;
}
async unlink ({ context, node, options = {} }) {
if ( await node.get('type') === TYPE_DIRECTORY ) {
throw new APIError(409, 'Cannot unlink a directory.');

32
src/backend/src/modules/puterfs/lib/PuterFSProvider.js
View File

@@ -89,36 +89,8 @@ class PuterFSProvider extends putility.AdvancedBase {
async quick_check ({
selector,
}) {
// a wrapper that access underlying database directly
const fsEntryFetcher = this.#services.get('fsEntryFetcher');
// shortcut: has full path
if ( selector?.path ) {
const entry = await fsEntryFetcher.findByPath(selector.path);
return Boolean(entry);
}
// shortcut: has uid
if ( selector?.uid ) {
const entry = await fsEntryFetcher.findByUID(selector.uid);
return Boolean(entry);
}
// shortcut: parent uid + child name
if ( selector instanceof NodeChildSelector && selector.parent instanceof NodeUIDSelector ) {
return await fsEntryFetcher.nameExistsUnderParent(selector.parent.uid,
selector.name);
}
// shortcut: parent id + child name
if ( selector instanceof NodeChildSelector && selector.parent instanceof NodeInternalIDSelector ) {
return await fsEntryFetcher.nameExistsUnderParentID(selector.parent.id,
selector.name);
}
// TODO (xiaochen): we should fallback to stat but we cannot at this moment
// since stat requires a valid `FSNodeContext` argument.
return false;
console.error('This .quick_check should not be called!');
process.exit(1);
}
async stat ({