feat: 优化异常信息展示

package.json

@@ -23,6 +23,7 @@
   },
   "homepage": "https://github.com/bangbang93/openbmclapi#readme",
   "dependencies": {
+    "@bangbang93/service-errors": "^1.1.1",
     "@bangbang93/utils": "^6.9.1",
     "@mongodb-js/zstd": "^1.2.0",
     "@xmcl/nat-api": "^0.4.3",

src/cluster.ts

@@ -30,6 +30,7 @@ import {FileListSchema} from './constants.js'
 import {validateFile} from './file.js'
 import {Keepalive} from './keepalive.js'
 import {logger} from './logger.js'
+import {beforeError} from './modules/got-hooks.js'
 import {AuthRouteFactory} from './routes/auth.route.js'
 import MeasureRouteFactory from './routes/measure.route.js'
 import {getStorage, type IStorage} from './storage/base.storage.js'
@@ -117,6 +118,7 @@ export class Cluster {
             }
           },
         ],
+        beforeError,
       },
     })
     this.storage = getStorage(config)

src/modules/got-hooks.ts

@@ -0,0 +1,16 @@
+import {ServiceError} from '@bangbang93/service-errors'
+import {BeforeErrorHook, HTTPError, RequestError} from 'got'
+
+export const beforeError: BeforeErrorHook[] = [catchServiceError]
+
+export function catchServiceError(error: RequestError): RequestError {
+  if (error instanceof HTTPError) {
+    if (error.response.headers['content-type']?.includes('application/json')) {
+      const body = JSON.parse(error.response.body.toString())
+      if (ServiceError.isServiceError(body)) {
+        throw ServiceError.fromJSON(body as unknown as Record<string, unknown>)
+      }
+    }
+  }
+  return error
+}

src/token.ts

@@ -2,6 +2,7 @@ import got, {type Got} from 'got'
 import ms from 'ms'
 import {createHmac} from 'node:crypto'
 import {logger} from './logger.js'
+import {beforeError} from './modules/got-hooks.js'
 
 export class TokenManager {
   private token: string | undefined
@@ -22,6 +23,9 @@ export class TokenManager {
       timeout: {
         request: ms('5m'),
       },
+      hooks: {
+        beforeError,
+      },
     })
   }