packages/notify/
├── src/
│   ├── types.ts              # Zod schemas for OrderNotification, AppointmentNotification, WebPush
│   ├── formatters.ts         # formatOrderNotificationHtml, formatAppointmentNotificationHtml, escapeHtml
│   ├── telegram.ts           # TelegramNotifier, createTelegramNotifier
│   ├── webpush.ts            # WebPushNotifier, createWebPushNotifier, generateVAPIDKeys
│   ├── scheduler.ts          # HybridNotificationScheduler, InMemoryZSetStore, createValkeyZSetAdapter
│   ├── ops-alert-bridge/     # Multi-Platform Alert Forwarder
│   │   ├── channels.ts       # TelegramChannel, DiscordChannel, SlackChannel
│   │   ├── transformer.ts    # AlertTransformer, detectAlertSource
│   │   ├── server.ts         # createAlertBridgeHandler (Hono / Express webhook receiver)
│   │   └── index.ts          # Ops Alert Bridge Barrel
│   └── index.ts              # SSoT Unified Barrel

import {
  HybridNotificationScheduler,
  InMemoryZSetStore,
  TelegramNotifier,
  formatOrderNotificationHtml,
  AlertTransformer,
  TelegramChannel,
  DiscordChannel,
  type OrderNotificationPayload,
} from '@kido/notify';

// 1. Initialize Hybrid Timing Wheel Scheduler
const zsetStore = new InMemoryZSetStore();
const scheduler = new HybridNotificationScheduler({
  store: zsetStore,
  onTrigger: async (job) => {
    console.log(`[Timer Fired] Executing scheduled job: ${job.id} (Channel: ${job.channel})`);
    if (job.channel === 'TELEGRAM') {
      await telegram.sendMessage(job.payload.chatId, job.payload.text);
    }
  },
});

await scheduler.start();

// 2. Schedule an Appointment Reminder 30 Days in the Future (Survives 24.8d overflow!)
const futureDate = new Date(Date.now() + 30 * 24 * 60 * 60 * 1000);
await scheduler.schedule({
  id: 'job-reminder-30d',
  channel: 'TELEGRAM',
  scheduledAt: futureDate,
  payload: {
    chatId: '-1001234567890',
    text: '🔔 Nhắc lịch hẹn bảo dưỡng định kỳ 1 tháng!',
  },
});
console.log('Successfully scheduled job 30 days into the future.');

// 3. Format and Send Real-Time Order Notification to Telegram
const telegram = new TelegramNotifier({
  botToken: process.env.TELEGRAM_BOT_TOKEN || 'mock-bot-token',
  defaultChatId: '-1001234567890',
});

const orderPayload: OrderNotificationPayload = {
  orderId: 'ORD-VN-88219',
  customerName: 'Hoàng Anh Tuấn',
  phone: '0905112233',
  deliveryAddress: '456 Lê Duẩn, Thanh Khê, Đà Nẵng',
  items: [
    { name: 'Gà Rán Giòn Cay (2 miếng)', quantity: 2, price: 75_000 },
    { name: 'Trà Đào Cam Sả', quantity: 2, price: 35_000 },
  ],
  totalAmount: 220_000,
  paymentMethod: 'VIETQR',
  paymentStatus: 'PAID',
  note: 'Giao trước 12h trưa',
};

const orderHtml = formatOrderNotificationHtml(orderPayload);
console.log('Formatted Telegram HTML Notification:\n' + orderHtml);

// 4. Incident Response: Fan Out Critical P0 Alert to Telegram & Discord
const opsBridge = [
  new TelegramChannel({ botToken: 'mock-bot-token', chatId: '-100-OPS-ALERT' }),
  new DiscordChannel({ webhookUrl: 'https://discord.com/api/webhooks/mock-url' }),
];

const incidentAlert = AlertTransformer.transformCustom({
  title: 'PostgreSQL Primary Replication Lag Critical',
  message: 'Replication lag exceeded 500MB on replica node-02. Fallback to cold standby triggered.',
  severity: 'CRITICAL',
  service: 'core-database',
  metadata: {
    lsnLagBytes: 524288000,
    replicaHost: 'replica-db-02.internal',
  },
});

for (const channel of opsBridge) {
  await channel.send(incidentAlert);
}
console.log('Dispatched incident alert across all Ops channels.');