import { Arr, Optional } from '@ephox/katamari';

import * as Compare from '../api/dom/Compare';
import type { SugarElement } from '../api/node/SugarElement';

export interface Polling {
  element: SugarElement<Node>;
  unbind: () => void;
}

/*
  Used to monitor elements and ensure that only one monitor is running at a time per element. It also
  guarantees that the unbind function will be called when monitoring is ended.

  This list is shared across the entire page, so be wary of memory leaks when using it.
 */
const polls: Polling[] = [];

const poll = (element: SugarElement<Node>, unbind: () => void): Polling => ({ element, unbind });

const findPoller = (element: SugarElement<Node>): number =>
  Arr.findIndex(polls, (p) => Compare.eq(p.element, element)).getOr(-1);

const begin = (element: SugarElement<Node>, f: () => (() => void)): void => {
  const index = findPoller(element);
  if (index === -1) {
    const unbind = f();
    polls.push(poll(element, unbind));
  }
};

const query = (element: SugarElement<Node>): Optional<Polling> => {
  // Used in tests to determine whether an element is still being monitored
  const index = findPoller(element);
  return index === -1 ? Optional.none<Polling>() : Optional.some(polls[index]);
};

const end = (element: SugarElement<Node>): void => {
  const index = findPoller(element);

  // This function is called speculatively, so just do nothing if there is no monitor for the element
  if (index === -1) {
    return;
  }

  const poller = polls[index];
  polls.splice(index, 1);
  poller.unbind();
};

export { begin, query, end };