Function createCustomPersister

src/persisters/common/create.ts:100–392

(
  store: PersistedStore<Persist>,
  getPersisted: () => Promise<PersistedContent<Persist> | undefined>,
  setPersisted: (
    getContent: () => PersistedContent<Persist>,
    changes?: PersistedChanges<
      Persist,
      IsSynchronizer extends 1 ? false : true
    >,
  ) => Promise<void>,
  addPersisterListener: (
    listener: PersisterListener<Persist>,
  ) => ListenerHandle | Promise<ListenerHandle>,
  delPersisterListener: (
    listenerHandle: ListenerHandle,
  ) => void | Promise<void>,
  onIgnoredError?: (error: any) => void,
  persist?: Persist,
  // undocumented:
  extra: {[methodName: string]: (...params: any[]) => any} = {},
  isSynchronizer: IsSynchronizer = 0 as IsSynchronizer,
  scheduleId = [],
)

      : errorNew('Store type not supported by this Persister');

export const createCustomPersister = <
  ListenerHandle,
  Persist extends PersistsEnum = PersistsEnum.StoreOnly,
  IsSynchronizer extends 0 | 1 = 0,
>(
  store: PersistedStore<Persist>,
  getPersisted: () => Promise<PersistedContent<Persist> | undefined>,
  setPersisted: (
    getContent: () => PersistedContent<Persist>,
    changes?: PersistedChanges<
      Persist,
      IsSynchronizer extends 1 ? false : true
    >,
  ) => Promise<void>,
  addPersisterListener: (
    listener: PersisterListener<Persist>,
  ) => ListenerHandle | Promise<ListenerHandle>,
  delPersisterListener: (
    listenerHandle: ListenerHandle,
  ) => void | Promise<void>,
  onIgnoredError?: (error: any) => void,
  persist?: Persist,
  // undocumented:
  extra: {[methodName: string]: (...params: any[]) => any} = {},
  isSynchronizer: IsSynchronizer = 0 as IsSynchronizer,
  scheduleId = [],
): Persister<Persist> => {
  let status: StatusValues = StatusValues.Idle;
  let loads = 0;
  let saves = 0;
  let action;
  let autoLoadHandle: ListenerHandle | undefined;
  let autoSaveListenerId: Id | undefined;

  mapEnsure(scheduleRunning, scheduleId, () => 0);
  mapEnsure(scheduleActions, scheduleId, () => []);

  const statusListeners: IdSet2 = mapNew();

  const [
    isMergeableStore,
    getContent,
    getChanges,
    hasChanges,
    setDefaultContent,
  ] = getStoreFunctions(persist, store, isSynchronizer);

  const [addListener, callListeners, delListenerImpl] = getListenerFunctions(
    () => persister,
  );

  const setStatus = (newStatus: StatusValues): void => {
    if (newStatus != status) {
      status = newStatus;
      callListeners(statusListeners, undefined, status);
    }
  };