1 Commits

Author SHA1 Message Date
Первов Артем
fc8bfb6691 БУР-68 Добавил обработку ECONNREFUSED и сохранение сервиса живым 2026-07-07 01:27:07 +03:00
2 changed files with 58 additions and 0 deletions

View File

@@ -1,3 +1,4 @@
import './process-errors.js'
import './handlers/index.js' import './handlers/index.js'
import './http/server.js' import './http/server.js'
import './mqtt.js' import './mqtt.js'

57
app/src/process-errors.ts Normal file
View File

@@ -0,0 +1,57 @@
type ErrorWithCause = Error & {
cause?: unknown
}
type NodeError = Error & {
code?: string
address?: string
port?: number
}
// Undici кладёт системную ошибку соединения внутрь error.cause.
function getFetchCause(error: unknown): NodeError | null {
if (!(error instanceof Error)) {
return null
}
const cause = (error as ErrorWithCause).cause
return cause instanceof Error ? (cause as NodeError) : null
}
// Обрабатываем только подсвеченный кейс: backend отказал в TCP-соединении.
function isFetchConnectionRefused(error: unknown): boolean {
if (!(error instanceof Error)) {
return false
}
const cause = getFetchCause(error)
return error.message === 'fetch failed' && cause?.code === 'ECONNREFUSED'
}
// Логируем короткую диагностическую форму без огромного stack trace.
function formatFetchError(error: unknown): object {
if (!(error instanceof Error)) {
return { message: String(error) }
}
const cause = getFetchCause(error)
return {
message: error.message,
cause: cause?.message,
code: cause?.code,
address: cause?.address,
port: cause?.port,
}
}
// Последний рубеж защиты для fire-and-forget fetch-запросов.
// Если backend недоступен, Node.js 22 может превратить незахваченный
// fetch failed / ECONNREFUSED в падение всего процесса mqtt-worker.
process.on('unhandledRejection', (error) => {
if (isFetchConnectionRefused(error)) {
console.error('process.unhandled_fetch_refused', formatFetchError(error))
return
}
console.error('process.unhandled_rejection', error)
})