fromObjectSyncTask.ts

import { forOwn } from '../../../utils/lang';
import { IReadinessManager } from '../../../readiness/types';
import { IStorageSync } from '../../../storages/types';
import { ISplitsParser } from '../splitsParser/types';
import { ISplit, ISplitPartial } from '../../../dtos/types';
import { syncTaskFactory } from '../../syncTask';
import { ISyncTask } from '../../types';
import { ISettings } from '../../../types';
import { CONTROL } from '../../../utils/constants';
import { SDK_SPLITS_ARRIVED, SDK_SEGMENTS_ARRIVED, SDK_SPLITS_CACHE_LOADED } from '../../../readiness/constants';
import { SYNC_OFFLINE_DATA, ERROR_SYNC_OFFLINE_LOADING } from '../../../logger/constants';

/**
 * Offline equivalent of `splitChangesUpdaterFactory`
 */
export function fromObjectUpdaterFactory(
  splitsParser: ISplitsParser,
  storage: Pick<IStorageSync, 'splits' | 'validateCache'>,
  readiness: IReadinessManager,
  settings: ISettings,
): () => Promise<boolean> {

  const log = settings.log, splitsCache = storage.splits;
  let startingUp = true;

  return function objectUpdater() {
    const splits: ISplit[] = [];
    let loadError = null;
    let splitsMock: false | Record<string, ISplitPartial> = {};
    try {
      splitsMock = splitsParser(settings);
    } catch (err) {
      loadError = err;
      log.error(ERROR_SYNC_OFFLINE_LOADING, [err]);
    }

    if (!loadError && splitsMock) {
      log.debug(SYNC_OFFLINE_DATA, [JSON.stringify(splitsMock)]);

      forOwn(splitsMock, (val, name) => {
        // @ts-ignore Split changeNumber and seed is undefined in localhost mode
        splits.push({
          name,
          status: 'ACTIVE',
          killed: false,
          trafficAllocation: 100,
          defaultTreatment: CONTROL,
          conditions: val.conditions || [],
          configurations: val.configurations,
          trafficTypeName: val.trafficTypeName
        });
      });

      return Promise.all([
        splitsCache.clear(), // required to sync removed splits from mock
        splitsCache.update(splits, [], Date.now())
      ]).then(() => {
        readiness.splits.emit(SDK_SPLITS_ARRIVED);

        if (startingUp) {
          startingUp = false;
          Promise.resolve(storage.validateCache ? storage.validateCache() : false).then((isCacheLoaded) => {
            // Emits SDK_READY_FROM_CACHE
            if (isCacheLoaded) readiness.splits.emit(SDK_SPLITS_CACHE_LOADED);
            // Emits SDK_READY
            readiness.segments.emit(SDK_SEGMENTS_ARRIVED);
          });
        }
        return true;
      });
    } else {
      return Promise.resolve(true);
    }
  };
}

/**
 * PollingManager in Offline mode
 */
export function fromObjectSyncTaskFactory(
  splitsParser: ISplitsParser,
  storage: Pick<IStorageSync, 'splits' | 'validateCache'>,
  readiness: IReadinessManager,
  settings: ISettings
): ISyncTask<[], boolean> {
  return syncTaskFactory(
    settings.log,
    fromObjectUpdaterFactory(
      splitsParser,
      storage,
      readiness,
      settings,
    ),
    settings.scheduler.offlineRefreshRate,
    'offlineUpdater',
  );
}