Segment

async function onTrack(event, settings) {
  const endpoint = "https://ingest.hyperline.co/v1/events";

  // https://docs.hyperline.co/api-reference/endpoints/billable-events/create-billable-event
  const event = {
    customer_id: event.userId,
    event_type: event.event,
    timestamp: event.timestamp,
    record: {
      id: event.messageId,
      my_property: event.properties.customProperty,
      // add any custom properties you want to ingest in Hyperline
    },
  };

  try {
    // Post request
    const response = await fetch(endpoint, {
      method: "POST",
      headers: {
        Authorization: `Bearer ${settings.apiKey}`,
        "Content-Type": "application/json",
      },
      body: JSON.stringify(event),
    });

    // Retry on 5xx (server errors) and 429s (rate limits)
    if (response.status >= 500 || response.status === 429) {
      throw new RetryError(`Failed with ${response.status}`);
    }

    return response.json();
  } catch (error) {
    // Retry on connection error
    throw new RetryError(error.message);
  }
}