feat: onBug()

telefunc/client/server.ts

@@ -4,7 +4,7 @@ export const getContext = err('getContext')
 export const provideTelefuncContext = err('provideTelefuncContext')
 export const Abort = err('Abort')
 export const shield = err('shield')
-export const onTelefuncServerError = err('onTelefuncServerError')
+export const onBug = err('onBug')
 
 import { assertUsage } from './utils'
 

telefunc/node/server/index.ts

@@ -3,7 +3,7 @@ export { telefuncConfig } from './telefuncConfig'
 export { getContext, provideTelefuncContext } from './getContext'
 export { Abort } from './Abort'
 export { shield } from './shield'
-export { onTelefuncServerError } from './runTelefunc/onTelefuncServerError'
+export { onBug } from './runTelefunc/onBug'
 
 // In order to allow users to override `Telefunc.Context`, we need to export `Telefunc` (even if the user never imports `Telefunc`)
 export type { Telefunc } from './getContext/TelefuncNamespace'

telefunc/node/server/runTelefunc.ts

@@ -9,7 +9,7 @@ import { getTelefunctions } from './runTelefunc/getTelefunctions'
 import { executeTelefunction } from './runTelefunc/executeTelefunction'
 import { serializeTelefunctionResult } from './runTelefunc/serializeTelefunctionResult'
 import { handleError } from './runTelefunc/handleError'
-import { executeServerErrorListeners } from './runTelefunc/onTelefuncServerError'
+import { callBugListeners } from './runTelefunc/onBug'
 import { applyShield } from './runTelefunc/applyShield'
 import { findTelefunction } from './runTelefunc/findTelefunction'
 import { globalContext } from './globalContext'
@@ -39,7 +39,7 @@ async function runTelefunc(runContext: Parameters<typeof runTelefunc_>[0]) {
   try {
     return await runTelefunc_(runContext)
   } catch (err: unknown) {
-    executeServerErrorListeners(err)
+    callBugListeners(err)
     handleError(err, globalContext.viteDevServer || null)
     return serverError
   }

telefunc/node/server/runTelefunc/onBug.ts

@@ -0,0 +1,14 @@
+export { onBug }
+export { callBugListeners }
+
+const bugListeners: ((err: unknown) => void)[] = []
+
+function onBug(listener: (err: unknown) => void) {
+  bugListeners.push(listener)
+}
+
+function callBugListeners(err: unknown) {
+  bugListeners.forEach((listener) => {
+    listener(err)
+  })
+}