Dashboard SaaS Analytics

1// Sync multi-source — CRM + Stripe + Notion
2async function syncDashboardData(workspaceId: string) {
3  const [crmData, revenueData, pipelineData] = await Promise.all([
4    fetchCRMLeads(workspaceId, { since: lastSync }),
5    stripe.metrics.retrieve({ expand: ['mrr', 'churn'] }),
6    notion.databases.query({ filter: { status: 'active' } }),
7  ])
8
9  // Merge & deduplicate across sources
10  const unified = mergeDataSources([crmData, revenueData, pipelineData])
11
12  // Trigger real-time alert if threshold crossed
13  if (unified.conversionRate < ALERT_THRESHOLD) {
14    await sendAlert({ type: 'conversion_drop', workspace: workspaceId })
15  }
16
17  await db.dashboardSnapshots.upsert({ workspaceId, data: unified })
18}

1// Configurable alert rules — evaluated on every sync
2interface AlertRule {
3  metric: keyof DashboardSnapshot
4  operator: 'lt' | 'gt' | 'delta_pct'
5  threshold: number
6  channels: ('email' | 'slack')[]
7}
8
9async function evaluateAlerts(
10  snapshot: DashboardSnapshot,
11  rules: AlertRule[]
12): Promise<void> {
13  for (const rule of rules) {
14    const value = snapshot[rule.metric]
15    const prev  = await db.snapshots.getPrevious(snapshot.workspaceId)
16    const triggered =
17      rule.operator === 'lt'        ? value < rule.threshold :
18      rule.operator === 'gt'        ? value > rule.threshold :
19      /* delta_pct */                 Math.abs((value - prev[rule.metric]) / prev[rule.metric]) > rule.threshold
20
21    if (triggered) {
22      await notify(rule.channels, { rule, value, snapshot })
23    }
24  }
25}