diff --git a/src/pages/app/[app].vue b/src/pages/app/[app].vue
index 91a649f218..bafd4eb068 100644
--- a/src/pages/app/[app].vue
+++ b/src/pages/app/[app].vue
@@ -202,6 +202,15 @@ watchEffect(async () => {
:force-demo="appNotFound"
class="col-span-full sm:col-span-6 xl:col-span-4"
/>
+
+ metaCounts?: Array
+ metaCountValues?: Array
+}
+
+function toNonNegativeInt(value: number | null | undefined): number {
+ if (typeof value !== 'number' || !Number.isFinite(value))
+ return 0
+ return Math.max(0, Math.round(value))
+}
+
+function getCountSeries(dataset: ChartDatasetLike): Array {
+ if (Array.isArray(dataset.metaCountValues) && dataset.metaCountValues.length > 0)
+ return dataset.metaCountValues
+ if (Array.isArray(dataset.metaCounts) && dataset.metaCounts.length > 0)
+ return dataset.metaCounts
+ return []
+}
+
+function findLatestIndex(datasets: ChartDatasetLike[]): number {
+ let lastIndex = -1
+
+ for (const dataset of datasets) {
+ const counts = getCountSeries(dataset)
+
+ for (let index = counts.length - 1; index >= 0; index--) {
+ if (toNonNegativeInt(counts[index]) > 0) {
+ lastIndex = Math.max(lastIndex, index)
+ break
+ }
+ }
+ }
+
+ return lastIndex
+}
+
+function percentFromShare(count: number, total: number): number {
+ if (total > 0)
+ return Math.round((count / total) * 1000) / 10
+ return 0
+}
+
+/**
+ * Latest-day unique-device share for a specific bundle, or the leading bundle
+ * when no version name is given. Counts come from daily check-in stats.
+ */
+export function getLatestDayVersionAdoption(
+ datasets: ChartDatasetLike[],
+ versionName?: string,
+): VersionAdoption | null {
+ if (!datasets.length)
+ return null
+
+ const lastIndex = findLatestIndex(datasets)
+ if (lastIndex < 0) {
+ if (!versionName)
+ return null
+ return {
+ versionName,
+ count: 0,
+ total: 0,
+ percent: 0,
+ }
+ }
+
+ const total = datasets.reduce((sum, dataset) => {
+ return sum + toNonNegativeInt(getCountSeries(dataset)[lastIndex])
+ }, 0)
+
+ const namedDataset = versionName
+ ? datasets.find(dataset => dataset.label === versionName)
+ : undefined
+
+ if (versionName && !namedDataset) {
+ return {
+ versionName,
+ count: 0,
+ total,
+ percent: 0,
+ }
+ }
+
+ const target = namedDataset ?? datasets.reduce((current, dataset) => {
+ const count = toNonNegativeInt(getCountSeries(dataset)[lastIndex])
+ if (!current)
+ return dataset
+ const currentCount = toNonNegativeInt(getCountSeries(current)[lastIndex])
+ return count > currentCount ? dataset : current
+ }, null)
+
+ if (!target)
+ return null
+
+ const count = toNonNegativeInt(getCountSeries(target)[lastIndex])
+ return {
+ versionName: target.label,
+ count,
+ total,
+ percent: percentFromShare(count, total),
+ }
+}
diff --git a/supabase/functions/_backend/triggers/cron_email.ts b/supabase/functions/_backend/triggers/cron_email.ts
index 3414542da8..1bc05c84dd 100644
--- a/supabase/functions/_backend/triggers/cron_email.ts
+++ b/supabase/functions/_backend/triggers/cron_email.ts
@@ -7,13 +7,14 @@ import {
getPreviousMonthUtcRange,
shouldRetryDeployInstallStats,
shouldSendDeployInstallStatsEmail,
+ summarizeDeviceVersionAdoption,
sumVersionInstalls,
} from '../utils/cron_email_stats.ts'
import { BRES, middlewareAPISecret, parseBody, simpleError } from '../utils/hono.ts'
import { cloudlog, cloudlogErr } from '../utils/logging.ts'
import { sendEmailToOrgMembers } from '../utils/org_email_notifications.ts'
import { findBestPlan } from '../utils/plans.ts'
-import { readStatsVersion } from '../utils/stats.ts'
+import { readDeviceVersionCounts, readStatsVersion } from '../utils/stats.ts'
import { getCurrentPlanNameOrg, supabaseAdmin } from '../utils/supabase.ts'
export const app = new Hono()
@@ -207,6 +208,28 @@ async function handleMonthlyCreateStats(c: Context, appId: string) {
return c.json(BRES)
}
+async function loadDeployVersionAdoption(
+ c: Context,
+ appId: string,
+ versionName?: string,
+ versionId?: number,
+ channelName?: string,
+) {
+ try {
+ const deviceCounts = await readDeviceVersionCounts(c, appId, channelName)
+ return summarizeDeviceVersionAdoption(deviceCounts, versionName, versionId)
+ }
+ catch (error) {
+ cloudlogErr({
+ requestId: c.get('requestId'),
+ message: 'Failed to read device version counts for deploy stats email',
+ error,
+ metadata: { appId, versionName, versionId, channelName },
+ })
+ return summarizeDeviceVersionAdoption({}, versionName, versionId)
+ }
+}
+
async function handleDeployInstallStats(
c: Context,
payload: {
@@ -266,22 +289,25 @@ async function handleDeployInstallStats(
// Coerce installs with Number() — Analytics Engine sum() can arrive as stringy Float64.
const installs = sumVersionInstalls(versionStats, versionName, versionId)
- const metadata = {
- app_id: appId,
- app_name: appName ?? '',
- deploy_id: deployId?.toString(),
- version_id: versionId?.toString(),
- version_name: versionName ?? '',
- channel_id: channelId?.toString(),
- channel_name: channelName ?? '',
- platform: platform ?? '',
- deployed_at: windowStart,
- install_count_24h: installs.toString(),
- window_hours: '24',
- }
-
if (shouldSendDeployInstallStatsEmail(installs)) {
- await sendEmailToOrgMembers(c, 'bundle:install_stats_24h', 'deploy_stats_24h', metadata, orgId ?? await getOrgIdForApp(c, appId))
+ const adoption = await loadDeployVersionAdoption(c, appId, versionName, versionId, channelName)
+
+ await sendEmailToOrgMembers(c, 'bundle:install_stats_24h', 'deploy_stats_24h', {
+ app_id: appId,
+ app_name: appName ?? '',
+ deploy_id: deployId?.toString(),
+ version_id: versionId?.toString(),
+ version_name: versionName ?? '',
+ channel_id: channelId?.toString(),
+ channel_name: channelName ?? '',
+ platform: platform ?? '',
+ deployed_at: windowStart,
+ install_count_24h: installs.toString(),
+ window_hours: '24',
+ device_count: adoption.device_count.toString(),
+ total_devices: adoption.total_devices.toString(),
+ adoption_percent: adoption.adoption_percent,
+ }, orgId ?? await getOrgIdForApp(c, appId))
return c.json(BRES)
}
diff --git a/supabase/functions/_backend/utils/cron_email_stats.ts b/supabase/functions/_backend/utils/cron_email_stats.ts
index 8b556ad309..ed1b973f5c 100644
--- a/supabase/functions/_backend/utils/cron_email_stats.ts
+++ b/supabase/functions/_backend/utils/cron_email_stats.ts
@@ -215,3 +215,32 @@ export function shouldRetryDeployInstallStats(deployedAt: Date, now: Date = new
export function shouldSendDeployInstallStatsEmail(installs: number): boolean {
return installs > 1
}
+
+export interface DeviceVersionAdoptionSummary {
+ device_count: number
+ total_devices: number
+ adoption_percent: string
+}
+
+/** Live unique-device reach for a deployed bundle from version_name counts. */
+export function summarizeDeviceVersionAdoption(
+ counts: Record,
+ versionName?: string | null,
+ versionId?: number | null,
+): DeviceVersionAdoptionSummary {
+ const totalDevices = Object.values(counts).reduce((sum, value) => {
+ return sum + Math.max(0, Math.round(toStatNumber(value)))
+ }, 0)
+ const namedCount = versionName ? counts[versionName] : undefined
+ const idCount = versionId != null ? counts[String(versionId)] : undefined
+ const deviceCount = Math.max(0, Math.round(toStatNumber(namedCount ?? idCount ?? 0)))
+ const adoptionPercent = totalDevices > 0
+ ? (Math.round((deviceCount / totalDevices) * 1000) / 10).toFixed(1)
+ : '0.0'
+
+ return {
+ device_count: deviceCount,
+ total_devices: totalDevices,
+ adoption_percent: adoptionPercent,
+ }
+}
diff --git a/tests/bundle-adoption.unit.test.ts b/tests/bundle-adoption.unit.test.ts
new file mode 100644
index 0000000000..1024d58f48
--- /dev/null
+++ b/tests/bundle-adoption.unit.test.ts
@@ -0,0 +1,87 @@
+import { describe, expect, it } from 'vitest'
+import { getLatestDayVersionAdoption } from '~/services/bundleAdoption'
+
+describe('getLatestDayVersionAdoption', () => {
+ it.concurrent('returns the named bundle share on the latest day with counts', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCountValues: [80, 60, 20], data: [80, 60, 20] },
+ { label: '1.1.0', metaCountValues: [20, 40, 80], data: [20, 40, 80] },
+ ], '1.1.0')
+
+ expect(adoption).toEqual({
+ versionName: '1.1.0',
+ count: 80,
+ total: 100,
+ percent: 80,
+ })
+ })
+
+ it.concurrent('returns zero for a bundle that has not been reported yet', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCounts: [100], data: [100] },
+ ], '1.2.0')
+
+ expect(adoption).toEqual({
+ versionName: '1.2.0',
+ count: 0,
+ total: 100,
+ percent: 0,
+ })
+ })
+
+ it.concurrent('picks the leading bundle when no version is given', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCountValues: [10, 30] },
+ { label: '1.1.0', metaCountValues: [90, 70] },
+ ])
+
+ expect(adoption).toEqual({
+ versionName: '1.1.0',
+ count: 70,
+ total: 100,
+ percent: 70,
+ })
+ })
+
+ it.concurrent('skips trailing empty days', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCountValues: [40, 0], data: [40, 0] },
+ { label: '1.1.0', metaCountValues: [60, 0], data: [60, 0] },
+ ], '1.1.0')
+
+ expect(adoption).toEqual({
+ versionName: '1.1.0',
+ count: 60,
+ total: 100,
+ percent: 60,
+ })
+ })
+
+ it.concurrent('ignores percent-only days that have no device counts', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCountValues: [40, 0], data: [40, 80] },
+ { label: '1.1.0', metaCountValues: [60, 0], data: [60, 20] },
+ ], '1.1.0')
+
+ expect(adoption).toEqual({
+ versionName: '1.1.0',
+ count: 60,
+ total: 100,
+ percent: 60,
+ })
+ })
+
+ it.concurrent('keeps one-decimal rounding for fractional shares', () => {
+ const adoption = getLatestDayVersionAdoption([
+ { label: '1.0.0', metaCountValues: [77] },
+ { label: '1.1.0', metaCountValues: [56] },
+ ], '1.1.0')
+
+ expect(adoption).toEqual({
+ versionName: '1.1.0',
+ count: 56,
+ total: 133,
+ percent: 42.1,
+ })
+ })
+})
diff --git a/tests/cron-email-stats.unit.test.ts b/tests/cron-email-stats.unit.test.ts
index 42b2fb796b..e2ad9222f7 100644
--- a/tests/cron-email-stats.unit.test.ts
+++ b/tests/cron-email-stats.unit.test.ts
@@ -7,6 +7,7 @@ import {
getPreviousMonthUtcRange,
shouldRetryDeployInstallStats,
shouldSendDeployInstallStatsEmail,
+ summarizeDeviceVersionAdoption,
sumVersionInstalls,
toStatNumber,
} from '../supabase/functions/_backend/utils/cron_email_stats.ts'
@@ -198,3 +199,46 @@ describe('shouldRetryDeployInstallStats', () => {
expect(shouldRetryDeployInstallStats(deployedAt, now)).toBe(false)
})
})
+
+describe('summarizeDeviceVersionAdoption', () => {
+ it.concurrent('computes live device reach for a deployed bundle', () => {
+ expect(summarizeDeviceVersionAdoption({
+ '1.0.0': 20,
+ '1.1.0': 80,
+ }, '1.1.0')).toEqual({
+ device_count: 80,
+ total_devices: 100,
+ adoption_percent: '80.0',
+ })
+ })
+
+ it.concurrent('returns zeros when no devices have reported', () => {
+ expect(summarizeDeviceVersionAdoption({}, '1.1.0')).toEqual({
+ device_count: 0,
+ total_devices: 0,
+ adoption_percent: '0.0',
+ })
+ })
+
+ it.concurrent('falls back to version_id string keys used by legacy device counts', () => {
+ expect(summarizeDeviceVersionAdoption({
+ 9601: 40,
+ 9602: 60,
+ }, '1.1.0', 9602)).toEqual({
+ device_count: 60,
+ total_devices: 100,
+ adoption_percent: '60.0',
+ })
+ })
+
+ it.concurrent('keeps one-decimal rounding for fractional shares', () => {
+ expect(summarizeDeviceVersionAdoption({
+ '1.0.0': 77,
+ '1.1.0': 56,
+ }, '1.1.0')).toEqual({
+ device_count: 56,
+ total_devices: 133,
+ adoption_percent: '42.1',
+ })
+ })
+})