All files / web/src/app/api/admin/notifications route.ts

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
import { eq } from 'drizzle-orm'
import { NextResponse } from 'next/server'
import { db } from '@/db'
import { appSettings, type NotificationChannelsConfig } from '@/db/schema/app-settings'
import { withAuth } from '@/lib/auth/withAuth'

const DEFAULT_CONFIG: NotificationChannelsConfig = {
  webPush: { enabled: false },
  email: { enabled: false },
  inApp: { enabled: false },
}

export interface ChannelStatus {
  operational: boolean
  reason?: string
}

function getChannelStatuses(): Record<string, ChannelStatus> {
  const hasVapidPublic = !!process.env.VAPID_PUBLIC_KEY
  const hasVapidPrivate = !!process.env.VAPID_PRIVATE_KEY
  const hasEmailServer = !!process.env.EMAIL_SERVER

  return {
    webPush:
      hasVapidPublic && hasVapidPrivate
        ? { operational: true }
        : {
            operational: false,
            reason: `Missing env: ${[!hasVapidPublic && 'VAPID_PUBLIC_KEY', !hasVapidPrivate && 'VAPID_PRIVATE_KEY'].filter(Boolean).join(', ')}`,
          },
    email: hasEmailServer
      ? { operational: true }
      : { operational: false, reason: 'Missing env: EMAIL_SERVER' },
    inApp: { operational: true },
  }
}

/**
 * GET /api/admin/notifications
 *
 * Returns the current notification channels config + operational status.
 */
export const GET = withAuth(
  async () => {
    try {
      const [settings] = await db
        .select({ notificationChannels: appSettings.notificationChannels })
        .from(appSettings)
        .where(eq(appSettings.id, 'default'))
        .limit(1)

      let config = DEFAULT_CONFIG
      if (settings?.notificationChannels) {
        try {
          config = JSON.parse(settings.notificationChannels) as NotificationChannelsConfig
        } catch {
          // use default
        }
      }

      return NextResponse.json({
        config,
        status: getChannelStatuses(),
        vapidPublicKey: process.env.VAPID_PUBLIC_KEY ?? null,
      })
    } catch (error) {
      console.error('[admin/notifications] Error fetching config:', error)
      return NextResponse.json({ error: 'Failed to fetch notification config' }, { status: 500 })
    }
  },
  { role: 'admin' }
)

/**
 * PATCH /api/admin/notifications
 *
 * Update notification channels config.
 * Body: NotificationChannelsConfig shape.
 */
export const PATCH = withAuth(
  async (request) => {
    try {
      const body = await request.json()
      const config = body as NotificationChannelsConfig

      // Validate shape
      if (!config || typeof config !== 'object') {
        return NextResponse.json({ error: 'Invalid config shape' }, { status: 400 })
      }

      for (const key of ['webPush', 'email', 'inApp'] as const) {
        if (!config[key] || typeof config[key].enabled !== 'boolean') {
          return NextResponse.json({ error: `${key}.enabled must be a boolean` }, { status: 400 })
        }
      }

      const configJson = JSON.stringify(config)

      // Ensure default row exists
      const existing = await db
        .select({ id: appSettings.id })
        .from(appSettings)
        .where(eq(appSettings.id, 'default'))
        .limit(1)

      if (existing.length === 0) {
        await db.insert(appSettings).values({
          id: 'default',
          notificationChannels: configJson,
        })
      } else {
        await db
          .update(appSettings)
          .set({ notificationChannels: configJson })
          .where(eq(appSettings.id, 'default'))
      }

      return NextResponse.json(config)
    } catch (error) {
      console.error('[admin/notifications] Error updating config:', error)
      return NextResponse.json({ error: 'Failed to update notification config' }, { status: 500 })
    }
  },
  { role: 'admin' }
)