ontime/apps/server/src/services/integration-service/HttpIntegration.ts

import got from 'got';

import { HttpSettings, HttpSubscription, LogOrigin } from 'ontime-types';

import IIntegration, { TimerLifeCycleKey } from './IIntegration.js';
import { parseTemplateNested } from './integrationUtils.js';
import { logger } from '../../classes/Logger.js';

/**
 * @description Class contains logic towards outgoing HTTP communications
 * @class
 */
export class HttpIntegration implements IIntegration<HttpSubscription, HttpSettings> {
  subscriptions: HttpSubscription[];
  enabled: boolean;

  constructor() {
    this.subscriptions = [];
    this.enabled = false;
  }

  /**
   * Initializes httpClient
   */
  init(config: HttpSettings) {
    const { subscriptions, enabledOut } = config;
    this.initSubscriptions(subscriptions);
    this.enabled = enabledOut;
  }

  initSubscriptions(subscriptions: HttpSubscription[]) {
    this.subscriptions = subscriptions;
  }

  dispatch(action: TimerLifeCycleKey, state?: object) {
    // noop
    if (!this.enabled) {
      return;
    }

    for (let i = 0; i < this.subscriptions.length; i++) {
      const { cycle, message, enabled } = this.subscriptions[i];
      if (cycle !== action || !enabled || !message) {
        continue;
      }

      const parsedMessage = parseTemplateNested(message, state || {});
      this.emit(parsedMessage);
    }
  }

  emit(path: string) {
    got.get(path, { retry: { limit: 0 } }).catch((err) => {
      logger.warning(LogOrigin.Tx, `HTTP Integration: ${err.message}`);

      if (err.code === 'ECONNREFUSED') {
        logger.warning(LogOrigin.Tx, `HTTP Integration: '${err.code}' The server refused the connection`);
        return;
      }

      if (err.code === 'ENOTFOUND') {
        logger.warning(LogOrigin.Tx, `HTTP Integration: '${err.code}' DNS lookup failed`);
        return;
      }

      if (err.code === 'ETIMEDOUT') {
        logger.warning(LogOrigin.Tx, `HTTP Integration: '${err.code}' The connection timed out`);
        return;
      }

      logger.warning(LogOrigin.Tx, `HTTP Integration: ${err.code}`);
    });
  }

  shutdown() {
    /** shutdown is a no-op here*/
  }
}

export const httpIntegration = new HttpIntegration();