Segment

// US: https://api.novu.co | EU: https://eu.api.novu.co
const NOVU_API_BASE_URL = 'https://api.novu.co';

/**
 * Posts to the Novu API. Retries on 5xx and 429. Fails fast on other 4xx responses.
 */
async function novuRequest(path, apiKey, body) {
  if (!apiKey) throw new Error('Novu API key is missing in settings');

  let response;
  try {
    response = await fetch(`${NOVU_API_BASE_URL}${path}`, {
      method: 'POST',
      headers: {
        'Authorization': `ApiKey ${apiKey}`,
        'Content-Type': 'application/json'
      },
      body: JSON.stringify(body)
    });
  } catch (error) {
    throw new RetryError(error.message);
  }

  const responseBody = await response.json().catch(() => ({}));
  if (!response.ok) {
    if (response.status >= 500 || response.status === 429) {
      throw new RetryError(`Server error: ${response.status}`);
    }
    throw new Error(`API error: ${response.status} - ${responseBody.message || 'Unknown error'}`);
  }
}

/**
 * Handles identify events: Creates or updates a subscriber in Novu
 * @param {SegmentIdentifyEvent} event - The Segment identify event
 * @param {FunctionSettings} settings - Function settings including API key
 */
async function onIdentify(event, settings) {
  if (!event.userId) throw new Error('userId is required in identify event');

  await novuRequest('/v2/subscribers', settings.apiKey, {
    subscriberId: event.userId,
    firstName: event.traits?.firstName,
    lastName: event.traits?.lastName,
    email: event.traits?.email,
    phone: event.traits?.phone,
    avatar: event.traits?.avatar,
  });
}

// Mapping of Segment track events to Novu workflows
const EVENT_TO_WORKFLOW_MAPPINGS = {
  'User Registered': 'welcome',
  // Add more mappings: 'Event Name': 'novu-workflow-name'
};

/**
 * Handles track events: Triggers a notification workflow in Novu
 * @param {SegmentTrackEvent} event - The Segment track event
 * @param {FunctionSettings} settings - Function settings including API key
 */
async function onTrack(event, settings) {
  if (!event.userId) throw new Error('userId is required in track event');

  const workflow = EVENT_TO_WORKFLOW_MAPPINGS[event.event];
  if (!workflow) throw new Error(`No workflow mapped for event: ${event.event}`);

  await novuRequest('/v1/events/trigger', settings.apiKey, {
    name: workflow,
    to: { subscriberId: event.userId },
    payload: event.properties || {}
  });
}