Référence des événements

type CollectedEvent = {
  key: string                        // companyId
  name: string                       // nom de l'événement — voir le catalogue ci-dessous
  url: string                        // URL de la page, ou identifiant d'écran applicatif
  tmpId: string                      // identité anonyme de l'appareil, toujours renseignée
  clientId?: string                  // identité utilisateur connue, après identification
  data: Record<string, unknown>      // ids, value, transId et labels libres
  eventId: string                    // généré côté client, unique par événement
  v: 1                               // version de l'enveloppe
  timestamp?: number                 // epoch ms — par défaut l'heure de réception
}

{
  "name": "purchase",
  "data": {
    "ids": ["SKU-12345", "SKU-67890"],
    "value": 129.9,
    "transId": "order-456",
    "locale": "EN-GB",
    "store": "FR-online"
  }
}

import { randomUUID } from 'node:crypto'

type PurchaseLine = { reference: string; amount: number }

export const trackServerSidePurchase = async (
  clientId: string,
  orderId: string,
  lines: PurchaseLine[],
): Promise<void> => {
  const response = await fetch(
    `https://collector.reelevant.com/collect/${process.env.RLVT_DATASOURCE_ID}/rlvt`,
    {
      method: 'POST',
      headers: { 'content-type': 'application/json' },
      body: JSON.stringify({
        key: process.env.RLVT_COMPANY_ID,
        name: 'purchase',
        url: 'https://shop.example.com/checkout/confirmation',
        tmpId: clientId,
        clientId,
        data: {
          ids: lines.map(line => line.reference),
          value: Number(lines.reduce((total, line) => total + line.amount, 0).toFixed(2)),
          transId: orderId,
          channel: 'backoffice',
        },
        eventId: randomUUID(),
        v: 1,
        timestamp: Date.now(),
      }),
    },
  )

  // Le collecteur répond 200 même quand des champs sont rejetés — ne réessayez que sur
  // erreur de transport ou 5xx, et consultez les logs de la Datasource pour les champs.
  if (response.status >= 500) {
    throw new Error(`Reelevant collector unavailable: ${response.status}`)
  }
}