Notification Channels

Authorization: Bearer your-secret-token
X-Api-Key: your-api-key

import { Hono } from 'hono'

const app = new Hono()

// Validasi token sederhana via header
const EXPECTED_TOKEN = process.env.WEBHOOK_SECRET ?? 'change-me'

app.post('/webhook/lenz', async (c) => {
  // Validasi Authorization header
  const authHeader = c.req.header('Authorization')
  if (authHeader !== `Bearer ${EXPECTED_TOKEN}`) {
    return c.json({ ok: false, message: 'Unauthorized' }, 401)
  }

  const payload = await c.req.json()

  console.log('Alert diterima:', {
    severity: payload.severity,
    stream: payload.stream_name,
    label: payload.label,
    time: payload.timestamp,
    rule: payload.alert_rule,
  })

  // Proses alert sesuai kebutuhan Anda di sini
  // Contoh: simpan ke database, kirim ke Slack, dll.

  return c.json({ ok: true, message: 'received' })
})

export default {
  port: 3000,
  fetch: app.fetch,
}

bun run webhook-receiver.ts

const express = require('express')
const app = express()

app.use(express.json())

const EXPECTED_TOKEN = process.env.WEBHOOK_SECRET || 'change-me'

app.post('/webhook/lenz', (req, res) => {
  // Validasi Authorization header
  const authHeader = req.headers['authorization']
  if (authHeader !== `Bearer ${EXPECTED_TOKEN}`) {
    return res.status(401).json({ ok: false, message: 'Unauthorized' })
  }

  const payload = req.body

  console.log('Alert diterima:', {
    severity: payload.severity,
    stream: payload.stream_name,
    label: payload.label,
    time: payload.timestamp,
    rule: payload.alert_rule,
  })

  // Proses alert sesuai kebutuhan Anda di sini
  // Contoh: simpan ke database, kirim ke Slack, dll.

  res.json({ ok: true, message: 'received' })
})

app.listen(3000, () => {
  console.log('Webhook receiver berjalan di port 3000')
})

node webhook-receiver.js