fix(elysia): prevent DB hangs during saves (#643)

* feat(api): refactor error handling to use status responses and dynamic import for ESM compatibility

* feat(deps): update @elysiajs/swagger to v1.3.1 and add @sinclair/typebox v0.34.41

* fix(api): add explicit return type for '/tree' route handler

* feat(api): regenerate

Author: antonreshetov

package.json

@@ -41,8 +41,9 @@
   "dependencies": {
     "@dagrejs/dagre": "^1.1.5",
     "@elysiajs/cors": "^1.2.0",
-    "@elysiajs/node": "^1.2.5",
-    "@elysiajs/swagger": "^1.2.2",
+    "@elysiajs/node": "^1.4.2",
+    "@elysiajs/swagger": "^1.3.1",
+    "@sinclair/typebox": "^0.34.41",
     "@vue-flow/background": "^1.3.2",
     "@vue-flow/controls": "^1.1.3",
     "@vue-flow/core": "^1.46.5",
@@ -60,7 +61,7 @@
     "date-fns": "^4.1.0",
     "dom-to-image": "^2.6.0",
     "electron-store": "^8.2.0",
-    "elysia": "^1.2.15",
+    "elysia": "^1.4.16",
     "fs-extra": "^11.3.0",
     "i18next": "^24.2.2",
     "i18next-fs-backend": "^2.6.0",

pnpm-lock.yaml

@@ -1,14 +1,18 @@
 import { cors } from '@elysiajs/cors'
-import { node } from '@elysiajs/node'
 import { swagger } from '@elysiajs/swagger'
 import { app as electronApp } from 'electron'
 import { Elysia } from 'elysia'
 import { store } from '../store'
+import { importEsm } from '../utils'
 import folders from './routes/folders'
 import snippets from './routes/snippets'
 import tags from './routes/tags'
 
-export function initApi() {
+export async function initApi() {
+  // поскольку @elysiajs/node использует crossws, который работает только в ESM среде,
+  // то делаем хак с динамическим импортом
+  const { node } = await importEsm('@elysiajs/node')
+
   const app = new Elysia({ adapter: node() })
   const port = store.preferences.get('apiPort')
 

src/main/api/index.ts

@@ -42,7 +42,7 @@ app
   // Получение папок в виде древовидной структуры
   .get(
     '/tree',
-    () => {
+    (): any => {
       const db = useDB()
       const allFolders = db
         .prepare(
@@ -141,7 +141,7 @@ app
   // Обновление папки
   .patch(
     '/:id',
-    ({ params, body, error }) => {
+    ({ params, body, status }) => {
       const db = useDB()
       const { id } = params
       const now = Date.now()
@@ -187,7 +187,7 @@ app
       }
 
       if (updateFields.length === 0) {
-        return error(400, { message: 'Need at least one field to update' })
+        return status(400, { message: 'Need at least one field to update' })
       }
 
       updateFields.push('updatedAt = ?')
@@ -204,7 +204,7 @@ app
           | undefined
 
         if (!folder) {
-          return error(404, { message: 'Folder not found' })
+          return status(404, { message: 'Folder not found' })
         }
 
         // Обновляем порядок, только если изменился родитель или индекс
@@ -301,7 +301,7 @@ app
   // Удаление папки
   .delete(
     '/:id',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const { id } = params
 
@@ -314,7 +314,7 @@ app
         .get(id)
 
       if (!folder) {
-        return error(404, { message: 'Folder not found' })
+        return status(404, { message: 'Folder not found' })
       }
 
       const transaction = db.transaction(() => {

src/main/api/routes/folders.ts

@@ -231,7 +231,7 @@ app
   // Обновление сниппета
   .patch(
     '/:id',
-    ({ params, body, error }) => {
+    ({ params, body, status }) => {
       const db = useDB()
       const { id } = params
 
@@ -264,7 +264,7 @@ app
       }
 
       if (updateFields.length === 0) {
-        return error(400, { message: 'Need at least one field to update' })
+        return status(400, { message: 'Need at least one field to update' })
       }
 
       updateFields.push('updatedAt = ?')
@@ -283,7 +283,7 @@ app
       const result = stmt.run(...updateParams)
 
       if (!result.changes) {
-        return error(404, { message: 'Snippet not found' })
+        return status(404, { message: 'Snippet not found' })
       }
 
       return { message: 'Snippet updated' }
@@ -298,7 +298,7 @@ app
   // Обновление содержимого сниппета
   .patch(
     '/:id/contents/:contentId',
-    ({ params, body, error }) => {
+    ({ params, body, status }) => {
       const db = useDB()
       const { id, contentId } = params
 
@@ -321,7 +321,7 @@ app
       }
 
       if (updateFields.length === 0) {
-        return error(400, { message: 'Need at least one field to update' })
+        return status(400, { message: 'Need at least one field to update' })
       }
 
       updateParams.push(contentId)
@@ -335,7 +335,7 @@ app
       const contentsResult = contentsStmt.run(...updateParams)
 
       if (!contentsResult.changes) {
-        return error(404, { message: 'Snippet content not found' })
+        return status(404, { message: 'Snippet content not found' })
       }
 
       // Обновляем дату сниппета только если были реальные изменения в данных
@@ -348,7 +348,7 @@ app
         const snippetResult = snippetsStmt.run(now, id)
 
         if (!snippetResult.changes) {
-          return error(404, { message: 'Snippet not found' })
+          return status(404, { message: 'Snippet not found' })
         }
       }
 
@@ -364,7 +364,7 @@ app
   // Добавление тега к сниппету
   .post(
     '/:id/tags/:tagId',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const { id, tagId } = params
 
@@ -378,7 +378,7 @@ app
         .get(id)
 
       if (!snippet) {
-        return error(404, { message: 'Snippet not found' })
+        return status(404, { message: 'Snippet not found' })
       }
 
       // Проверяем, существует ли тег
@@ -391,7 +391,7 @@ app
         .get(tagId)
 
       if (!tag) {
-        return error(404, { message: 'Tag not found' })
+        return status(404, { message: 'Tag not found' })
       }
 
       // Добавляем связь между сниппетом и тегом
@@ -415,7 +415,7 @@ app
   // Удаление тега из сниппета
   .delete(
     '/:id/tags/:tagId',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const { id, tagId } = params
 
@@ -429,7 +429,7 @@ app
         .get(id)
 
       if (!snippet) {
-        return error(404, { message: 'Snippet not found' })
+        return status(404, { message: 'Snippet not found' })
       }
 
       // Проверяем, существует ли тег
@@ -442,7 +442,7 @@ app
         .get(tagId)
 
       if (!tag) {
-        return error(404, { message: 'Tag not found' })
+        return status(404, { message: 'Tag not found' })
       }
 
       // Удаляем связь между сниппетом и тегом
@@ -456,7 +456,7 @@ app
       const result = stmt.run(id, tagId)
 
       if (!result.changes) {
-        return error(404, {
+        return status(404, {
           message: 'Tag is not associated with this snippet',
         })
       }
@@ -472,7 +472,7 @@ app
   // Удаление сниппета
   .delete(
     '/:id',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const { id } = params
 
@@ -485,7 +485,7 @@ app
         .get(id)
 
       if (!snippet) {
-        return error(404, { message: 'Snippet not found' })
+        return status(404, { message: 'Snippet not found' })
       }
 
       const transaction = db.transaction(() => {
@@ -524,7 +524,7 @@ app
   // Удаление всех сниппетов в корзине
   .delete(
     '/trash',
-    ({ error }) => {
+    ({ status }) => {
       const db = useDB()
       const deletedSnippets = db
         .prepare(
@@ -535,7 +535,7 @@ app
         .all() as { id: number }[]
 
       if (deletedSnippets.length === 0) {
-        return error(404, { message: 'No snippets in trash' })
+        return status(404, { message: 'No snippets in trash' })
       }
 
       const transaction = db.transaction(() => {
@@ -582,7 +582,7 @@ app
   // Удаление содержимого сниппета
   .delete(
     '/:id/contents/:contentId',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const { contentId } = params
 
@@ -595,7 +595,7 @@ app
         .run(contentId)
 
       if (!result.changes) {
-        return error(404, { message: 'Snippet content not found' })
+        return status(404, { message: 'Snippet content not found' })
       }
 
       return { message: 'Snippet content deleted' }

src/main/api/routes/snippets.ts

@@ -49,7 +49,7 @@ app
   // Удаление тега и удаление его из всех сниппетов
   .delete(
     '/:id',
-    ({ params, error }) => {
+    ({ params, status }) => {
       const db = useDB()
       const tag = db
         .prepare(
@@ -60,7 +60,7 @@ app
         .get(params.id)
 
       if (!tag) {
-        return error(404, { message: 'Tag not found' })
+        return status(404, { message: 'Tag not found' })
       }
 
       const transaction = db.transaction(() => {

src/main/api/routes/tags.ts

@@ -90,7 +90,7 @@ else {
     }
 
     try {
-      initApi()
+      await initApi()
     }
     catch (error) {
       log('Error initializing API', error)

src/main/index.ts

@@ -12,3 +12,8 @@ export function log(context: string, error: unknown): void {
     stack,
   })
 }
+
+export function importEsm(specifier: string) {
+  // eslint-disable-next-line no-new-func
+  return new Function('s', 'return import(s)')(specifier) as Promise<any>
+}