main.js

import {  Request, Response  } from "express"
import fetch from "node-fetch"

export const main: HttpFunction = (req: Request, res: Response) => {
  if (corsHandler(req, res)) { return }
  if (!Array.isArray(req.body)) { res.status(400).send("invalid request; no array"); return }
  // Get environment (dev, test, acc, prod, ...)
  const env = getAuth0Tenant(req)
  // Map log data onto payload data elements ~ JSON tracker protocol
  const payloads = req.body.map(e => auth0LogToPayloadDataElement(env, e.data))
  // Put payload data elements in payload_data envelope
  const envelopedPayload = envelopIgluDataPayloads(payloads)
  // Send to sp colelctor; don't actually wait for the result of the request
  fetch("https://sp.acme.com/com.snowplowanalytics.snowplow/tp2", {
    method: "post",
    body: JSON.stringify(envelopedPayload),
    headers: {
      "Content-Type": "application/json"
    }
  })
  res.send("ok")
}