webhookEvents.js

'use strict';

const POOL_EVENTS = Object.freeze([
  'pool.created',
  'pool.assets_locked',
  'pool.assets_unlocked',
  'pool.rewards_distributed',
  'pool.closed',
]);

const PRICE_EVENTS = Object.freeze(['price.alert']);

// Only 'airdrop.failed' is registered here — it's the one event this
// codebase actually dispatches today (the expiry reconciliation job, #88).
// The README also documents airdrop.created/executing/completed, but
// nothing in the codebase dispatches those yet; registering unused event
// names here would let a client subscribe to something that can never
// fire, so they're left out until whatever feature actually dispatches
// them lands.
const AIRDROP_EVENTS = Object.freeze(['airdrop.failed']);

const ALL_EVENTS = Object.freeze([...POOL_EVENTS, ...PRICE_EVENTS, ...AIRDROP_EVENTS]);
const EVENT_SET = new Set(ALL_EVENTS);

const WILDCARD = '*';

function isKnownEvent(eventType) {
  return typeof eventType === 'string' && EVENT_SET.has(eventType);
}

function isValidSubscription(events) {
  if (!Array.isArray(events) || events.length === 0) return false;
  return events.every((e) => e === WILDCARD || EVENT_SET.has(e));
}

function matchesSubscription(subscribedEvents, eventType) {
  if (!Array.isArray(subscribedEvents) || subscribedEvents.length === 0) return false;
  if (subscribedEvents.includes(WILDCARD)) return true;
  return subscribedEvents.includes(eventType);
}

module.exports = {
  POOL_EVENTS,
  PRICE_EVENTS,
  AIRDROP_EVENTS,
  ALL_EVENTS,
  WILDCARD,
  isKnownEvent,
  isValidSubscription,
  matchesSubscription,
};