- Gunakan URL Incoming Webhook dari Mattermost untuk mengirim broadcast PO baru secara
- otomatis.
+ Atur integrasi Mattermost. Bagian atas untuk Notifikasi Personal (DM) ke Kreator, sedangkan bagian bawah untuk fitur Share (Broadcast) PO menggunakan Webhook.
+
+
handleChange('MATTERMOST_NOTIF_ENABLED', checked ? 'true' : 'false')}
+ />
+
+
+ Aktifkan DM Kreator saat Update Pesanan (Menggunakan Bot API)
+
+
+ Kirim notifikasi otomatis ke channel/DM kreator PO tiap ada update pesanan. (Membutuhkan Bot Token).
+
+
+ {settings.MATTERMOST_NOTIF_ENABLED === 'true' && (
+
+ )}
+
+
+
+
Broadcast via Incoming Webhook
Webhook URL
= {}
+ settings.forEach((s: any) => { config[s.key] = s.value })
+ return { success: true, config }
+ } catch (e: any) {
+ return { success: false, error: e.message }
+ }
+}
+
+export async function updateSystemSettings(key: string, value: string) {
+ try {
+ await prisma.setting.upsert({
+ where: { key },
+ update: { value },
+ create: { key, value }
+ })
+ return { success: true }
+ } catch (e: any) {
+ return { success: false, error: e.message }
+ }
+}
+
+// === USER NOTIFICATION CONFIG ACTIONS ===
+export async function getUserNotificationConfig(userId: string) {
+ try {
+ const config = await prisma.userNotificationConfig.findUnique({
+ where: { user_id: userId }
+ })
+ return { success: true, config }
+ } catch (e: any) {
+ return { success: false, error: e.message }
+ }
+}
+
+export async function updateUserNotificationConfig(userId: string, data: { mattermost_channel_id?: string, is_active?: boolean }) {
+ try {
+ const config = await prisma.userNotificationConfig.upsert({
+ where: { user_id: userId },
+ update: data,
+ create: { user_id: userId, ...data }
+ })
+ return { success: true, config }
+ } catch (e: any) {
+ return { success: false, error: e.message }
+ }
+}
+
+export async function notifyCreatorOnSubmission(orderId: string, submittorId: string, actionType: 'create' | 'update' | 'delete' = 'update') {
+ try {
+ const settings = await getSettings()
+ if (!settings || settings.MATTERMOST_NOTIF_ENABLED !== 'true') return
+
+ const order = await prisma.order.findUnique({
+ where: { id: orderId },
+ include: {
+ creator: {
+ include: { notification_config: true }
+ },
+ submissions: {
+ include: { user: true, items: true }
+ }
+ }
+ })
+
+ if (!order) return
+ const config = order.creator.notification_config
+ if (!config?.is_active || !config?.mattermost_channel_id) return
+
+ const submittor = await prisma.user.findUnique({ where: { id: submittorId } })
+ if (!submittor) return
+
+ const actionText = actionType === 'delete' ? 'membatalkan pesanan' : actionType === 'create' ? 'menambahkan pesanan baru' : 'merubah pesanan'
+ const headerMessage = `Ada yang ${actionText} dari **${submittor.name}** di PO **${order.title}**!`
+
+ let summaryByPerson = `**Rekap per Orang:**\n\`\`\`text\n${order.title}\n`
+ const itemCounts: Record = {}
+
+ order.submissions?.forEach((sub: any) => {
+ const itemStrings = sub.items.map(
+ (i: any) => `${i.name} ${i.qty}x${i.note ? ` (${i.note})` : ''}`
+ )
+ summaryByPerson += `- ${sub.user?.name || 'Unknown'} : ${itemStrings.join(', ')}\n`
+
+ sub.items.forEach((i: any) => {
+ const key = i.note ? `${i.name} (${i.note})` : i.name
+ itemCounts[key] = (itemCounts[key] || 0) + i.qty
+ })
+ })
+ summaryByPerson += `\`\`\``
+
+ let summaryByItem = `**Rekap per Item (Akumulasi):**\n\`\`\`text\n${order.title}\n`
+ Object.entries(itemCounts).forEach(([name, qty]) => {
+ summaryByItem += `- ${name} : ${qty} pcs\n`
+ })
+ summaryByItem += `\`\`\``
+
+ const finalMessage = `${headerMessage}\n\n${summaryByPerson}\n\n${summaryByItem}`
+
+ await sendMattermostNotification(
+ config.mattermost_channel_id,
+ finalMessage,
+ settings.MATTERMOST_BOT_TOKEN,
+ settings.MATTERMOST_API_URL
+ )
+
+ } catch (error) {
+ console.error('Failed to notify creator:', error)
+ }
+}
diff --git a/src/lib/mattermost.ts b/src/lib/mattermost.ts
new file mode 100644
index 0000000..5a153a8
--- /dev/null
+++ b/src/lib/mattermost.ts
@@ -0,0 +1,77 @@
+export async function sendMattermostNotification(targetIdentifier: string, message: string, botToken?: string, apiUrl?: string) {
+ try {
+ const token = botToken || process.env.MATTERMOST_BOT_TOKEN || '5zubexudb38uuradfa36qy98ca'
+ // Ensure we get the base URL by stripping '/posts' if it exists in the configured URL
+ let baseUrl = apiUrl || process.env.MATTERMOST_API_URL || 'https://mattermost.eigen.co.id/api/v4/posts'
+ if (baseUrl.endsWith('/posts')) {
+ baseUrl = baseUrl.replace('/posts', '')
+ }
+
+ const headers = {
+ 'Content-Type': 'application/json',
+ Authorization: `Bearer ${token}`,
+ }
+
+ let finalChannelId = targetIdentifier
+ let targetUserId = targetIdentifier
+
+ // 1. If it's a username (starts with @ or doesn't look like a 26-char ID), look up the User ID
+ if (targetIdentifier.startsWith('@') || targetIdentifier.length !== 26) {
+ const username = targetIdentifier.replace('@', '').trim()
+ const userRes = await fetch(`${baseUrl}/users/usernames`, {
+ method: 'POST',
+ headers,
+ body: JSON.stringify([username]),
+ })
+ if (userRes.ok) {
+ const users = await userRes.json()
+ if (users && users.length > 0) {
+ targetUserId = users[0].id
+ }
+ }
+ }
+
+ // 2. Try to create a DM channel if we have a valid 26-char User ID
+ if (targetUserId.length === 26) {
+ // Fetch Bot's own User ID
+ const meRes = await fetch(`${baseUrl}/users/me`, { headers })
+ if (meRes.ok) {
+ const me = await meRes.json()
+ const botId = me.id
+
+ // Create Direct Message channel between Bot and Target User
+ const dmRes = await fetch(`${baseUrl}/channels/direct`, {
+ method: 'POST',
+ headers,
+ body: JSON.stringify([botId, targetUserId]),
+ })
+ if (dmRes.ok) {
+ const dmChannel = await dmRes.json()
+ finalChannelId = dmChannel.id
+ }
+ }
+ }
+
+ // 3. Post the message to the final resolved channel ID
+ const res = await fetch(`${baseUrl}/posts`, {
+ method: 'POST',
+ headers,
+ body: JSON.stringify({
+ channel_id: finalChannelId,
+ message,
+ }),
+ })
+
+ if (!res.ok) {
+ const errorText = await res.text()
+ console.error(`[Mattermost Error] Failed to send message to ${targetIdentifier}:`, errorText)
+ return { success: false, error: errorText }
+ }
+
+ return { success: true }
+ } catch (error: any) {
+ console.error(`[Mattermost Exception] Failed to send message to ${targetIdentifier}:`, error.message)
+ return { success: false, error: error.message }
+ }
+}
+