refactor(clicks): write the click row and the counter in one transaction

There were two tracking implementations. clicks.ts was the one in use, while
clickTracking.ts had no importer anywhere in the repo, and the dead one was the
better of the two: it wrote the row and the counter together instead of leaving
links.click_count and COUNT(*) over clicks free to drift apart, and it dropped
an unparsable referrer instead of keeping it raw, query string included.

clicks.ts now does both inside one transaction and keeps what the active
version did better: the bot filter up front, no re-throw so tracking can never
break a redirect, and a failing UA parser that leaves the columns empty rather
than skipping the row. clickTracking.ts is gone.

Because the counter moved into trackClick, the separate incrementClickCount
calls had to go, otherwise every click would count twice. That function has no
callers left and is removed with them. One behaviour change follows from this:
in the password flow the counter used to be incremented even for bots while the
clicks row was already filtered, now the filter covers both.

Author: Musiker15

app/[code]/page.tsx

@@ -2,7 +2,7 @@ import { redirect, notFound } from 'next/navigation'
 import { headers } from 'next/headers'
 import Link from 'next/link'
 import { getTranslations } from 'next-intl/server'
-import { getLinkByCode, incrementClickCount, isLinkExpired } from '@/lib/links'
+import { getLinkByCode, isLinkExpired } from '@/lib/links'
 import { trackClick } from '@/lib/clicks'
 import { getClientIp } from '@/lib/rateLimit'
 import { isBot } from '@/lib/botDetection'
@@ -51,18 +51,14 @@ export default async function RedirectPage({ params }: PageProps) {
   const userAgent   = headersList.get('user-agent')
   const referrer    = headersList.get('referer')
 
+  // trackClick schreibt Zeile und Zähler in einer Transaktion und filtert Bots
+  // selbst. Bewusst ohne await, damit die Weiterleitung nicht auf die DB wartet.
   if (!isBot(userAgent)) {
-    const clientIp = getClientIp(headersList)
-
-    incrementClickCount(link.id).catch((err) => {
-      console.error('[Redirect] Counter-Error:', err)
-    })
-
     trackClick({
       linkId:    link.id,
       userAgent,
       referrer,
-      clientIp,
+      clientIp:  getClientIp(headersList),
     }).catch(() => { /* bereits intern geloggt */ })
   }
 

app/api/verify/route.ts

@@ -1,6 +1,6 @@
 import { NextRequest, NextResponse } from 'next/server'
 import { verifyPasswordSchema } from '@/lib/validation'
-import { verifyLinkPassword, incrementClickCount } from '@/lib/links'
+import { verifyLinkPassword } from '@/lib/links'
 import { trackClick } from '@/lib/clicks'
 import { getClientIp, hashIp, checkRateLimit } from '@/lib/rateLimit'
 import type { ApiError } from '@/types'
@@ -57,17 +57,11 @@ export async function POST(request: NextRequest) {
     }
 
     // ─── Click tracken (fire-and-forget) ───────────────────────────
-    const userAgent = request.headers.get('user-agent')
-    const referrer  = request.headers.get('referer')
-
-    incrementClickCount(link.id).catch((err) => {
-      console.error('[Verify] Counter-Error:', err)
-    })
-
+    // Zeile und Zähler schreibt trackClick in einer Transaktion.
     trackClick({
       linkId:    link.id,
-      userAgent,
-      referrer,
+      userAgent: request.headers.get('user-agent'),
+      referrer:  request.headers.get('referer'),
       clientIp,
     }).catch(() => { /* bereits intern geloggt */ })
 

src/lib/clickTracking.ts

@@ -1,5 +1,5 @@
 import { UAParser } from 'ua-parser-js'
-import { execute } from './db'
+import { getPool } from './db'
 import { hashIp } from './rateLimit'
 import { isBot } from './botDetection'
 import type { DeviceType } from '@/types'
@@ -12,70 +12,102 @@ interface TrackClickOptions {
 }
 
 /**
- * Trackt einen Click in der `clicks`-Tabelle.
- * Bots werden ignoriert. Fire-and-forget – wirft keinen Fehler.
+ * Trackt einen Click: Insert in `clicks` und Increment von `links.click_count`
+ * in EINER Transaktion. Damit können Zähler und Tabelle nicht auseinanderlaufen.
  *
- * Der Aufrufer sollte das Promise nicht awaiten,
- * damit Redirects nicht durch DB-Latenz verzögert werden.
+ * Bots werden ignoriert, dann passiert gar nichts – weder Zeile noch Zähler.
+ *
+ * Fire-and-forget: Fehler werden geloggt, aber nicht geworfen. Der Aufrufer
+ * soll das Promise nicht awaiten, damit Redirects nicht durch DB-Latenz
+ * verzögert werden.
  */
 export async function trackClick(opts: TrackClickOptions): Promise<void> {
   const { linkId, userAgent, referrer, clientIp } = opts
 
   // Bots überspringen
   if (isBot(userAgent)) return
 
-  try {
-    // ─── User-Agent parsen ─────────────────────────────────────────
-    const parser = new UAParser(userAgent ?? '')
-    const result = parser.getResult()
+  // ─── User-Agent parsen ───────────────────────────────────────────
+  // Ein kaputter UA darf das Tracking nicht verhindern, die Felder bleiben
+  // dann einfach leer.
+  let browser: string | null = null
+  let os:      string | null = null
+  let device:  DeviceType    = 'desktop'
+
+  if (userAgent) {
+    try {
+      const result = new UAParser(userAgent).getResult()
+      browser = result.browser.name ?? null
+      os      = result.os.name      ?? null
+      device  = mapDeviceType(result.device.type)
+    } catch {
+      // Stiller Fehlschlag – wir tracken trotzdem
+    }
+  }
+
+  const cleanRef = sanitizeReferrer(referrer)
 
-    const browser = result.browser.name ?? null
-    const os      = result.os.name      ?? null
-    const device  = mapDeviceType(result.device.type)
+  // ─── Transaktion: Insert Click + Update Zähler ───────────────────
+  let conn
+  try {
+    conn = await getPool().getConnection()
+  } catch (err) {
+    console.error('[trackClick] Keine DB-Verbindung:', err)
+    return
+  }
 
-    // ─── Referrer normalisieren (max. 500 Zeichen, ohne Querystring-Spam) ───
-    const cleanRef = referrer ? sanitizeReferrer(referrer) : null
+  try {
+    await conn.beginTransaction()
 
-    // ─── In DB schreiben ──────────────────────────────────────────
-    await execute(
+    await conn.execute(
       `INSERT INTO clicks
          (link_id, ip_hash, referrer, browser, os, device_type)
        VALUES (?, ?, ?, ?, ?, ?)`,
-      [
-        linkId,
-        hashIp(clientIp),
-        cleanRef,
-        browser,
-        os,
-        device,
-      ]
+      [linkId, hashIp(clientIp), cleanRef, browser, os, device]
     )
+
+    await conn.execute(
+      'UPDATE links SET click_count = click_count + 1 WHERE id = ?',
+      [linkId]
+    )
+
+    await conn.commit()
   } catch (err) {
     console.error('[trackClick] Fehler beim Tracking:', err)
     // Bewusst kein Re-throw – Tracking darf den Redirect nicht stören
+    try {
+      await conn.rollback()
+    } catch (rollbackErr) {
+      console.error('[trackClick] Rollback fehlgeschlagen:', rollbackErr)
+    }
+  } finally {
+    conn.release()
   }
 }
 
 /**
  * Mappt ua-parser-js Device-Types auf unsere DeviceType-Werte.
+ * ua-parser-js v2 kennt zusätzlich 'xr' (VR/AR-Headsets), das zählt als mobile.
  */
 function mapDeviceType(type: string | undefined): DeviceType {
-  if (!type) return 'desktop'
   if (type === 'mobile') return 'mobile'
   if (type === 'tablet') return 'tablet'
+  if (type === 'xr')     return 'mobile'
   return 'desktop'
 }
 
 /**
  * Bereinigt Referrer-URLs:
- * - Schneidet auf 500 Zeichen
- * - Entfernt Query-Strings (Privacy)
+ * - Nur Origin + Pfad behalten, Query-Strings können Tokens enthalten
+ * - Auf 500 Zeichen kürzen (Spaltenbreite)
+ * - Nicht parsbare Werte verwerfen, statt sie roh zu übernehmen
  */
-function sanitizeReferrer(ref: string): string | null {
+function sanitizeReferrer(referrer: string | null): string | null {
+  if (!referrer) return null
   try {
-    const url = new URL(ref)
-    return `${url.protocol}//${url.host}${url.pathname}`.slice(0, 500)
+    const url = new URL(referrer)
+    return `${url.origin}${url.pathname}`.slice(0, 500)
   } catch {
-    return ref.slice(0, 500)
+    return null
   }
 }

src/lib/clicks.ts

@@ -122,16 +122,6 @@ export async function verifyLinkPassword(
   return valid ? link : null
 }
 
-/**
- * Erhöht den Click-Counter atomar.
- */
-export async function incrementClickCount(linkId: number): Promise<void> {
-  await execute(
-    'UPDATE links SET click_count = click_count + 1 WHERE id = ?',
-    [linkId]
-  )
-}
-
 /**
  * Löscht einen Link anhand seines Delete-Tokens.
  * Gibt true zurück bei Erfolg, false wenn Token ungültig.