lee/puter
1
0
Fork 0
mirror of https://github.com/HeyPuter/puter.git synced 2026-05-26 19:32:46 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix: error handling in ThreadService
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 (18.x) (push) Has been cancelled
Details
test / test (20.x) (push) Has been cancelled
Details
test / test (22.x) (push) Has been cancelled
Details

Browse Source
This commit is contained in:
KernelDeimos
2025-04-07 19:02:52 -04:00
parent fc11eba070
commit 95ddfe3909
1 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/backend/src/services/ThreadService.js
+17 -4
View File
@@ -19,6 +19,16 @@ class ThreadService extends BaseService {
this.db = this.services.get('database').get(DB_WRITE, 'service:thread');
this.thread_body_max_size = 4 * 1024; // 4KiB
const svc_apiError = this.services.get('api-error');
svc_apiError.register({
'thread_not_found': {
status: 400,
message: ({ uid }) => {
return `Thread with UID ${uid} was not found`;
}
},
});
const svc_permission = this.services.get('permission');
svc_permission.register_implicator(PermissionImplicator.create({
@@ -183,6 +193,8 @@ class ThreadService extends BaseService {
}
install_threads_endpoints_ ({ router }) {
const svc_apiError = this.services.get('api-error');
Endpoint({
route: '/create',
methods: ['POST'],
@@ -223,7 +235,7 @@ class ThreadService extends BaseService {
{
const parent_thread = await this.get_thread({ uid: parent_uid });
if ( !parent_thread ) {
throw APIError.create('thread_not_found', null, {
throw svc_apiError.create('thread_not_found', {
uid: parent_uid,
});
}
@@ -311,7 +323,7 @@ class ThreadService extends BaseService {
// Get existing thread
const thread = await this.get_thread({ uid });
if ( !thread ) {
throw APIError.create('thread_not_found', null, {
throw svc_apiError.create('thread_not_found', {
uid,
});
}
@@ -372,7 +384,7 @@ class ThreadService extends BaseService {
// Get existing thread
const thread = await this.get_thread({ uid });
if ( !thread ) {
throw APIError.create('thread_not_found', null, {
throw svc_apiError.create('thread_not_found', {
uid,
});
}
@@ -539,7 +551,8 @@ class ThreadService extends BaseService {
);
if ( !thread ) {
throw APIError.create('thread_not_found', null, {
const svc_apiError = this.services.get('api-error');
throw svc_apiError.create('thread_not_found', {
uid,
});
}