ыввы

server/src/index.js

@@ -141,10 +141,24 @@ await registerUserNotificationRoutes(fastify)
 await registerOAuthSocialRoutes(fastify)
 await registerYookassaWebhookRoute(fastify)
 await registerApiRoutes(fastify)
-await ensureAdminUser()
-await getOrCreateUnspecifiedCategory()
 
-await notificationQueue.flushPendingOnStartup()
+try {
+  await ensureAdminUser()
+} catch (err) {
+  fastify.log.error({ err }, 'ensureAdminUser failed — continuing startup')
+}
+
+try {
+  await getOrCreateUnspecifiedCategory()
+} catch (err) {
+  fastify.log.error({ err }, 'getOrCreateUnspecifiedCategory failed — continuing startup')
+}
+
+try {
+  await notificationQueue.flushPendingOnStartup()
+} catch (err) {
+  fastify.log.error({ err }, 'notificationQueue.flushPendingOnStartup failed')
+}
 notificationQueue.start()
 
 const {
@@ -158,9 +172,40 @@ const {
 } = NOTIFICATION_EVENTS
 
 async function dispatchNotification(eventType, payload) {
-  if (eventType === AUTH_CODE_REQUESTED) {
-    const targets = await resolveAuthCodeTargets(eventType, payload)
-    for (const target of targets.filter((t) => t.channel === 'telegram')) {
+  try {
+    if (eventType === AUTH_CODE_REQUESTED) {
+      const targets = await resolveAuthCodeTargets(eventType, payload)
+      for (const target of targets.filter((t) => t.channel === 'telegram')) {
+        const log = await prisma.notificationLog.create({
+          data: {
+            eventType,
+            channel: target.channel,
+            status: 'pending',
+            payload: JSON.stringify(payload),
+          },
+        })
+        notificationQueue.enqueue({ ...target, eventType, payload, logId: log.id })
+      }
+      return
+    }
+
+    const userTargets = await resolveUserNotificationTargets(eventType, payload)
+    for (const target of userTargets) {
+      const log = await prisma.notificationLog.create({
+        data: {
+          userId: payload.userId,
+          eventType,
+          channel: target.channel,
+          status: 'pending',
+          payload: JSON.stringify(payload),
+        },
+      })
+      notificationQueue.enqueue({ ...target, eventType, payload, logId: log.id })
+    }
+
+    const adminEventType = eventType === 'order:created:admin' ? ORDER_CREATED : eventType
+    const adminTargets = await resolveAdminNotificationTargets(adminEventType, payload)
+    for (const target of adminTargets) {
       const log = await prisma.notificationLog.create({
         data: {
           eventType,
@@ -171,35 +216,8 @@ async function dispatchNotification(eventType, payload) {
       })
       notificationQueue.enqueue({ ...target, eventType, payload, logId: log.id })
     }
-    return
-  }
-
-  const userTargets = await resolveUserNotificationTargets(eventType, payload)
-  for (const target of userTargets) {
-    const log = await prisma.notificationLog.create({
-      data: {
-        userId: payload.userId,
-        eventType,
-        channel: target.channel,
-        status: 'pending',
-        payload: JSON.stringify(payload),
-      },
-    })
-    notificationQueue.enqueue({ ...target, eventType, payload, logId: log.id })
-  }
-
-  const adminEventType = eventType === 'order:created:admin' ? ORDER_CREATED : eventType
-  const adminTargets = await resolveAdminNotificationTargets(adminEventType, payload)
-  for (const target of adminTargets) {
-    const log = await prisma.notificationLog.create({
-      data: {
-        eventType,
-        channel: target.channel,
-        status: 'pending',
-        payload: JSON.stringify(payload),
-      },
-    })
-    notificationQueue.enqueue({ ...target, eventType, payload, logId: log.id })
+  } catch (err) {
+    console.error(`[notification] Error dispatching ${eventType}:`, err.message)
   }
 }
 
@@ -221,6 +239,10 @@ async function shutdown() {
 process.on('SIGINT', shutdown)
 process.on('SIGTERM', shutdown)
 
+process.on('unhandledRejection', (reason) => {
+  console.error('[process] Unhandled rejection:', reason?.message || reason)
+})
+
 try {
   await fastify.listen({ port, host: '0.0.0.0' })
 } catch (err) {