mirror of
https://github.com/HeyPuter/puter
synced 2024-11-15 06:15:47 +00:00
Move error-conversion functions into PosixError
Specifically, this makes the Puter->PosixError conversion available to the in-progress git client.
This commit is contained in:
Sam Atkins
parent
e43b21387c
commit
8098dc9dcc
@ -22,29 +22,6 @@ import path_ from 'path';
|
|||||||
import modeString from 'fs-mode-to-string';
|
import modeString from 'fs-mode-to-string';
|
||||||
import { ErrorCodes, PosixError } from '@heyputer/puter-js-common/src/PosixError.js';
|
import { ErrorCodes, PosixError } from '@heyputer/puter-js-common/src/PosixError.js';
|
||||||
|
|
||||||
function convertNodeError(e) {
|
|
||||||
switch (e.code) {
|
|
||||||
case 'EACCES': return new PosixError(ErrorCodes.EACCES, e.message);
|
|
||||||
case 'EADDRINUSE': return new PosixError(ErrorCodes.EADDRINUSE, e.message);
|
|
||||||
case 'ECONNREFUSED': return new PosixError(ErrorCodes.ECONNREFUSED, e.message);
|
|
||||||
case 'ECONNRESET': return new PosixError(ErrorCodes.ECONNRESET, e.message);
|
|
||||||
case 'EEXIST': return new PosixError(ErrorCodes.EEXIST, e.message);
|
|
||||||
case 'EIO': return new PosixError(ErrorCodes.EIO, e.message);
|
|
||||||
case 'EISDIR': return new PosixError(ErrorCodes.EISDIR, e.message);
|
|
||||||
case 'EMFILE': return new PosixError(ErrorCodes.EMFILE, e.message);
|
|
||||||
case 'ENOENT': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'ENOTDIR': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
|
||||||
case 'ENOTEMPTY': return new PosixError(ErrorCodes.ENOTEMPTY, e.message);
|
|
||||||
// ENOTFOUND is Node-specific. ECONNREFUSED is similar enough.
|
|
||||||
case 'ENOTFOUND': return new PosixError(ErrorCodes.ECONNREFUSED, e.message);
|
|
||||||
case 'EPERM': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'EPIPE': return new PosixError(ErrorCodes.EPIPE, e.message);
|
|
||||||
case 'ETIMEDOUT': return new PosixError(ErrorCodes.ETIMEDOUT, e.message);
|
|
||||||
}
|
|
||||||
// Some other kind of error
|
|
||||||
return e;
|
|
||||||
}
|
|
||||||
|
|
||||||
// DRY: Almost the same as puter/filesystem.js
|
// DRY: Almost the same as puter/filesystem.js
|
||||||
function wrapAPIs(apis) {
|
function wrapAPIs(apis) {
|
||||||
for (const method in apis) {
|
for (const method in apis) {
|
||||||
@ -56,7 +33,7 @@ function wrapAPIs(apis) {
|
|||||||
try {
|
try {
|
||||||
return await original(...args);
|
return await original(...args);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
throw convertNodeError(e);
|
throw PosixError.fromNodeJSError(e);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@ -18,106 +18,6 @@
|
|||||||
*/
|
*/
|
||||||
import { ErrorCodes, PosixError } from '@heyputer/puter-js-common/src/PosixError.js';
|
import { ErrorCodes, PosixError } from '@heyputer/puter-js-common/src/PosixError.js';
|
||||||
|
|
||||||
function convertPuterError(e) {
|
|
||||||
// Handle Puter SDK errors
|
|
||||||
switch (e.code) {
|
|
||||||
case 'item_with_same_name_exists': return new PosixError(ErrorCodes.EEXIST, e.message);
|
|
||||||
case 'cannot_move_item_into_itself': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'cannot_copy_item_into_itself': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'cannot_move_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
|
||||||
case 'cannot_copy_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
|
||||||
case 'cannot_write_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
|
||||||
case 'cannot_overwrite_a_directory': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'cannot_read_a_directory': return new PosixError(ErrorCodes.EISDIR, e.message);
|
|
||||||
case 'source_and_dest_are_the_same': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'dest_is_not_a_directory': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
|
||||||
case 'dest_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'source_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'subject_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'shortcut_target_not_found': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'shortcut_target_is_a_directory': return new PosixError(ErrorCodes.EISDIR, e.message);
|
|
||||||
case 'shortcut_target_is_a_file': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
|
||||||
case 'forbidden': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
case 'immutable': return new PosixError(ErrorCodes.EACCES, e.message);
|
|
||||||
case 'field_empty': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_missing': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'xor_field_missing': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_only_valid_with_other_field': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'invalid_id': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_invalid': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_immutable': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_too_long': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'field_too_short': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'already_in_use': return new PosixError(ErrorCodes.EINVAL, e.message); // Not sure what this one is
|
|
||||||
case 'invalid_file_name': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'storage_limit_reached': return new PosixError(ErrorCodes.ENOSPC, e.message);
|
|
||||||
case 'internal_error': return new PosixError(ErrorCodes.ECONNRESET, e.message); // This isn't quite right
|
|
||||||
case 'response_timeout': return new PosixError(ErrorCodes.ETIMEDOUT, e.message);
|
|
||||||
case 'file_too_large': return new PosixError(ErrorCodes.EFBIG, e.message);
|
|
||||||
case 'thumbnail_too_large': return new PosixError(ErrorCodes.EFBIG, e.message);
|
|
||||||
case 'upload_failed': return new PosixError(ErrorCodes.ECONNRESET, e.message); // This isn't quite right
|
|
||||||
case 'missing_expected_metadata': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'overwrite_and_dedupe_exclusive': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'not_empty': return new PosixError(ErrorCodes.ENOTEMPTY, e.message);
|
|
||||||
|
|
||||||
// Write
|
|
||||||
case 'offset_without_existing_file': return new PosixError(ErrorCodes.ENOENT, e.message);
|
|
||||||
case 'offset_requires_overwrite': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'offset_requires_stream': return new PosixError(ErrorCodes.EPERM, e.message);
|
|
||||||
|
|
||||||
// Batch
|
|
||||||
case 'batch_too_many_files': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
case 'batch_missing_file': return new PosixError(ErrorCodes.EINVAL, e.message);
|
|
||||||
|
|
||||||
// Open
|
|
||||||
case 'no_suitable_app': break;
|
|
||||||
case 'app_does_not_exist': break;
|
|
||||||
|
|
||||||
// Apps
|
|
||||||
case 'app_name_already_in_use': break;
|
|
||||||
|
|
||||||
// Subdomains
|
|
||||||
case 'subdomain_limit_reached': break;
|
|
||||||
case 'subdomain_reserved': break;
|
|
||||||
|
|
||||||
// Users
|
|
||||||
case 'email_already_in_use': break;
|
|
||||||
case 'username_already_in_use': break;
|
|
||||||
case 'too_many_username_changes': break;
|
|
||||||
case 'token_invalid': break;
|
|
||||||
|
|
||||||
// drivers
|
|
||||||
case 'interface_not_found': break;
|
|
||||||
case 'no_implementation_available': break;
|
|
||||||
case 'method_not_found': break;
|
|
||||||
case 'missing_required_argument': break;
|
|
||||||
case 'argument_consolidation_failed': break;
|
|
||||||
|
|
||||||
// SLA
|
|
||||||
case 'rate_limit_exceeded': break;
|
|
||||||
case 'monthly_limit_exceeded': break;
|
|
||||||
case 'server_rate_exceeded': break;
|
|
||||||
|
|
||||||
// auth
|
|
||||||
case 'token_missing': break;
|
|
||||||
case 'token_auth_failed': break;
|
|
||||||
case 'token_unsupported': break;
|
|
||||||
case 'account_suspended': break;
|
|
||||||
case 'permission_denied': break;
|
|
||||||
case 'access_token_empty_permissions': break;
|
|
||||||
|
|
||||||
// Object Mapping
|
|
||||||
case 'field_not_allowed_for_create': break;
|
|
||||||
case 'field_required_for_update': break;
|
|
||||||
case 'entity_not_found': break;
|
|
||||||
|
|
||||||
// Chat
|
|
||||||
case 'max_tokens_exceeded': break;
|
|
||||||
}
|
|
||||||
// Some other kind of error
|
|
||||||
return e;
|
|
||||||
}
|
|
||||||
|
|
||||||
// DRY: Almost the same as node/filesystem.js
|
// DRY: Almost the same as node/filesystem.js
|
||||||
function wrapAPIs(apis) {
|
function wrapAPIs(apis) {
|
||||||
for (const method in apis) {
|
for (const method in apis) {
|
||||||
@ -129,7 +29,7 @@ function wrapAPIs(apis) {
|
|||||||
try {
|
try {
|
||||||
return await original(...args);
|
return await original(...args);
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
throw convertPuterError(e);
|
throw PosixError.fromPuterAPIError(e);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|||||||
@ -100,7 +100,8 @@ export const runErrnoTests = () => {
|
|||||||
'EADDRINUSE 98 Address already in use\n' +
|
'EADDRINUSE 98 Address already in use\n' +
|
||||||
'ECONNRESET 104 Connection reset\n' +
|
'ECONNRESET 104 Connection reset\n' +
|
||||||
'ETIMEDOUT 110 Connection timed out\n' +
|
'ETIMEDOUT 110 Connection timed out\n' +
|
||||||
'ECONNREFUSED 111 Connection refused\n',
|
'ECONNREFUSED 111 Connection refused\n' +
|
||||||
|
'EUNKNOWN -1 Unknown error\n',
|
||||||
expectedStderr: '',
|
expectedStderr: '',
|
||||||
expectedFail: false,
|
expectedFail: false,
|
||||||
},
|
},
|
||||||
|
|||||||
@ -34,6 +34,9 @@ const ErrorCodes = {
|
|||||||
EPERM: Symbol.for('EPERM'),
|
EPERM: Symbol.for('EPERM'),
|
||||||
EPIPE: Symbol.for('EPIPE'),
|
EPIPE: Symbol.for('EPIPE'),
|
||||||
ETIMEDOUT: Symbol.for('ETIMEDOUT'),
|
ETIMEDOUT: Symbol.for('ETIMEDOUT'),
|
||||||
|
|
||||||
|
// For when we need to convert errors that we don't recognise
|
||||||
|
EUNKNOWN: Symbol.for('EUNKNOWN'),
|
||||||
};
|
};
|
||||||
|
|
||||||
// Codes taken from `errno` on Linux.
|
// Codes taken from `errno` on Linux.
|
||||||
@ -55,6 +58,8 @@ const ErrorMetadata = new Map([
|
|||||||
[ErrorCodes.ECONNRESET, { code: 104, description: 'Connection reset'}],
|
[ErrorCodes.ECONNRESET, { code: 104, description: 'Connection reset'}],
|
||||||
[ErrorCodes.ETIMEDOUT, { code: 110, description: 'Connection timed out' }],
|
[ErrorCodes.ETIMEDOUT, { code: 110, description: 'Connection timed out' }],
|
||||||
[ErrorCodes.ECONNREFUSED, { code: 111, description: 'Connection refused' }],
|
[ErrorCodes.ECONNREFUSED, { code: 111, description: 'Connection refused' }],
|
||||||
|
|
||||||
|
[ErrorCodes.EUNKNOWN, { code: -1, description: 'Unknown error' }],
|
||||||
]);
|
]);
|
||||||
|
|
||||||
const errorFromIntegerCode = (code) => {
|
const errorFromIntegerCode = (code) => {
|
||||||
@ -86,6 +91,131 @@ class PosixError extends Error {
|
|||||||
this.posixCode = posixCode;
|
this.posixCode = posixCode;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static fromNodeJSError(e) {
|
||||||
|
switch (e.code) {
|
||||||
|
case 'EACCES': return new PosixError(ErrorCodes.EACCES, e.message);
|
||||||
|
case 'EADDRINUSE': return new PosixError(ErrorCodes.EADDRINUSE, e.message);
|
||||||
|
case 'ECONNREFUSED': return new PosixError(ErrorCodes.ECONNREFUSED, e.message);
|
||||||
|
case 'ECONNRESET': return new PosixError(ErrorCodes.ECONNRESET, e.message);
|
||||||
|
case 'EEXIST': return new PosixError(ErrorCodes.EEXIST, e.message);
|
||||||
|
case 'EIO': return new PosixError(ErrorCodes.EIO, e.message);
|
||||||
|
case 'EISDIR': return new PosixError(ErrorCodes.EISDIR, e.message);
|
||||||
|
case 'EMFILE': return new PosixError(ErrorCodes.EMFILE, e.message);
|
||||||
|
case 'ENOENT': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'ENOTDIR': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
||||||
|
case 'ENOTEMPTY': return new PosixError(ErrorCodes.ENOTEMPTY, e.message);
|
||||||
|
// ENOTFOUND is Node-specific. ECONNREFUSED is similar enough.
|
||||||
|
case 'ENOTFOUND': return new PosixError(ErrorCodes.ECONNREFUSED, e.message);
|
||||||
|
case 'EPERM': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'EPIPE': return new PosixError(ErrorCodes.EPIPE, e.message);
|
||||||
|
case 'ETIMEDOUT': return new PosixError(ErrorCodes.ETIMEDOUT, e.message);
|
||||||
|
}
|
||||||
|
// Some other kind of error
|
||||||
|
return new PosixError(ErrorCodes.EUNKNOWN, e.message);
|
||||||
|
}
|
||||||
|
|
||||||
|
static fromPuterAPIError(e) {
|
||||||
|
// Handle Puter SDK errors
|
||||||
|
switch (e.code) {
|
||||||
|
case 'item_with_same_name_exists': return new PosixError(ErrorCodes.EEXIST, e.message);
|
||||||
|
case 'cannot_move_item_into_itself': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'cannot_copy_item_into_itself': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'cannot_move_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
||||||
|
case 'cannot_copy_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
||||||
|
case 'cannot_write_to_root': return new PosixError(ErrorCodes.EACCES, e.message);
|
||||||
|
case 'cannot_overwrite_a_directory': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'cannot_read_a_directory': return new PosixError(ErrorCodes.EISDIR, e.message);
|
||||||
|
case 'source_and_dest_are_the_same': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'dest_is_not_a_directory': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
||||||
|
case 'dest_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'source_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'subject_does_not_exist': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'shortcut_target_not_found': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'shortcut_target_is_a_directory': return new PosixError(ErrorCodes.EISDIR, e.message);
|
||||||
|
case 'shortcut_target_is_a_file': return new PosixError(ErrorCodes.ENOTDIR, e.message);
|
||||||
|
case 'forbidden': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
case 'immutable': return new PosixError(ErrorCodes.EACCES, e.message);
|
||||||
|
case 'field_empty': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_missing': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'xor_field_missing': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_only_valid_with_other_field': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'invalid_id': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_invalid': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_immutable': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_too_long': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'field_too_short': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'already_in_use': return new PosixError(ErrorCodes.EINVAL, e.message); // Not sure what this one is
|
||||||
|
case 'invalid_file_name': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'storage_limit_reached': return new PosixError(ErrorCodes.ENOSPC, e.message);
|
||||||
|
case 'internal_error': return new PosixError(ErrorCodes.ECONNRESET, e.message); // This isn't quite right
|
||||||
|
case 'response_timeout': return new PosixError(ErrorCodes.ETIMEDOUT, e.message);
|
||||||
|
case 'file_too_large': return new PosixError(ErrorCodes.EFBIG, e.message);
|
||||||
|
case 'thumbnail_too_large': return new PosixError(ErrorCodes.EFBIG, e.message);
|
||||||
|
case 'upload_failed': return new PosixError(ErrorCodes.ECONNRESET, e.message); // This isn't quite right
|
||||||
|
case 'missing_expected_metadata': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'overwrite_and_dedupe_exclusive': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'not_empty': return new PosixError(ErrorCodes.ENOTEMPTY, e.message);
|
||||||
|
|
||||||
|
// Write
|
||||||
|
case 'offset_without_existing_file': return new PosixError(ErrorCodes.ENOENT, e.message);
|
||||||
|
case 'offset_requires_overwrite': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'offset_requires_stream': return new PosixError(ErrorCodes.EPERM, e.message);
|
||||||
|
|
||||||
|
// Batch
|
||||||
|
case 'batch_too_many_files': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
case 'batch_missing_file': return new PosixError(ErrorCodes.EINVAL, e.message);
|
||||||
|
|
||||||
|
// TODO: Associate more of these with posix error codes
|
||||||
|
|
||||||
|
// Open
|
||||||
|
case 'no_suitable_app': break;
|
||||||
|
case 'app_does_not_exist': break;
|
||||||
|
|
||||||
|
// Apps
|
||||||
|
case 'app_name_already_in_use': break;
|
||||||
|
|
||||||
|
// Subdomains
|
||||||
|
case 'subdomain_limit_reached': break;
|
||||||
|
case 'subdomain_reserved': break;
|
||||||
|
|
||||||
|
// Users
|
||||||
|
case 'email_already_in_use': break;
|
||||||
|
case 'username_already_in_use': break;
|
||||||
|
case 'too_many_username_changes': break;
|
||||||
|
case 'token_invalid': break;
|
||||||
|
|
||||||
|
// drivers
|
||||||
|
case 'interface_not_found': break;
|
||||||
|
case 'no_implementation_available': break;
|
||||||
|
case 'method_not_found': break;
|
||||||
|
case 'missing_required_argument': break;
|
||||||
|
case 'argument_consolidation_failed': break;
|
||||||
|
|
||||||
|
// SLA
|
||||||
|
case 'rate_limit_exceeded': break;
|
||||||
|
case 'monthly_limit_exceeded': break;
|
||||||
|
case 'server_rate_exceeded': break;
|
||||||
|
|
||||||
|
// auth
|
||||||
|
case 'token_missing': break;
|
||||||
|
case 'token_auth_failed': break;
|
||||||
|
case 'token_unsupported': break;
|
||||||
|
case 'account_suspended': break;
|
||||||
|
case 'permission_denied': break;
|
||||||
|
case 'access_token_empty_permissions': break;
|
||||||
|
|
||||||
|
// Object Mapping
|
||||||
|
case 'field_not_allowed_for_create': break;
|
||||||
|
case 'field_required_for_update': break;
|
||||||
|
case 'entity_not_found': break;
|
||||||
|
|
||||||
|
// Chat
|
||||||
|
case 'max_tokens_exceeded': break;
|
||||||
|
}
|
||||||
|
// Some other kind of error
|
||||||
|
return new PosixError(ErrorCodes.EUNKNOWN, e.message);
|
||||||
|
}
|
||||||
|
|
||||||
//
|
//
|
||||||
// Helpers for constructing a PosixError when you don't already have an error message.
|
// Helpers for constructing a PosixError when you don't already have an error message.
|
||||||
//
|
//
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user