submitterManager.ts

import { eventsSubmitterFactory } from './eventsSubmitter';
import { impressionsSubmitterFactory } from './impressionsSubmitter';
import { impressionCountsSubmitterFactory } from './impressionCountsSubmitter';
import { telemetrySubmitterFactory } from './telemetrySubmitter';
import { ISdkFactoryContextSync } from '../../sdkFactory/types';
import { ISubmitterManager } from './types';
import { uniqueKeysSubmitterFactory } from './uniqueKeysSubmitter';

export function submitterManagerFactory(params: ISdkFactoryContextSync): ISubmitterManager {

  const submitters = [
    impressionsSubmitterFactory(params),
    eventsSubmitterFactory(params),
    impressionCountsSubmitterFactory(params),
    uniqueKeysSubmitterFactory(params)
  ];

  const telemetrySubmitter = telemetrySubmitterFactory(params);

  return {
    // `onlyTelemetry` true if SDK is created with userConsent not GRANTED
    start(onlyTelemetry?: boolean) {
      if (!onlyTelemetry) submitters.forEach(submitter => submitter.start());
      if (telemetrySubmitter) telemetrySubmitter.start();
    },

    // `allExceptTelemetry` true if userConsent is changed to DECLINED
    stop(allExceptTelemetry?: boolean) {
      submitters.forEach(submitter => submitter.stop());
      if (!allExceptTelemetry && telemetrySubmitter) telemetrySubmitter.stop();
    },

    isRunning() {
      return submitters.some(submitter => submitter.isRunning());
    },

    // Flush data. Called with `onlyTelemetry` true if SDK is destroyed with userConsent not GRANTED
    execute(onlyTelemetry?: boolean) {
      const promises = onlyTelemetry ? [] : submitters.map(submitter => submitter.execute());
      if (telemetrySubmitter) promises.push(telemetrySubmitter.execute());
      return Promise.all(promises).then(() => { });
    },

    isExecuting() {
      return submitters.some(submitter => submitter.isExecuting());
    }
  };
}