chore(analytics): server composable (WIP)

Author: smarroufin

server/api/_hub/analytics/index.put.ts

@@ -0,0 +1,11 @@
+import type { AnalyticsEngineDataPoint } from '@cloudflare/workers-types/experimental'
+
+export default eventHandler(async (event) => {
+  const { data } = await readValidatedBody(event, z.object({
+    data: z.custom<AnalyticsEngineDataPoint>()
+  }).parse)
+
+  await useAnalytics().put(data)
+
+  return true
+})

server/utils/analytics.ts

@@ -0,0 +1,52 @@
+import type { AnalyticsEngineDataPoint, AnalyticsEngineDataset } from '@cloudflare/workers-types/experimental'
+import { ofetch } from 'ofetch'
+import { joinURL } from 'ufo'
+
+const _datasets: Record<string, AnalyticsEngineDataset> = {}
+
+function _useDataset() {
+  const name = 'ANALYTICS'
+  if (_datasets[name]) {
+    return _datasets[name]
+  }
+
+  // @ts-ignore
+  const binding = process.env[name] || globalThis.__env__?.[name] || globalThis[name]
+  if (binding) {
+    _datasets[name] = binding as AnalyticsEngineDataset
+    return _datasets[name]
+  }
+  throw createError(`Missing Cloudflare ${name} binding (Analytics Engine)`)
+}
+
+export function useAnalytics() {
+  if (import.meta.dev && process.env.NUXT_HUB_URL) {
+    return useProxyAnalytics(process.env.NUXT_HUB_URL, process.env.NUXT_HUB_SECRET_KEY)
+  }
+  const dataset = _useDataset()
+
+  return {
+    put(data: AnalyticsEngineDataPoint) {
+      dataset.writeDataPoint(data)
+      return true
+    }
+  }
+}
+
+export function useProxyAnalytics(projectUrl: string, secretKey?: string) {
+  const analyticsAPI = ofetch.create({
+    baseURL: joinURL(projectUrl, '/api/_hub/analytics'),
+    headers: {
+      Authorization: `Bearer ${secretKey}`
+    }
+  })
+
+  return {
+    async put(data: AnalyticsEngineDataPoint) {
+      return analyticsAPI<boolean>('/', {
+        method: 'PUT',
+        body: { data }
+      })
+    }
+  }
+}