Function createTabularPersister

src/persisters/common/database/tabular.ts:31–234

(
  store: PersistedStore<Persist>,
  executeCommand: DatabaseExecuteCommand,
  addPersisterListener: (
    listener: PersisterListener<Persist>,
  ) => ListeningHandle | Promise<ListeningHandle>,
  delPersisterListener: (
    listeningHandle: ListeningHandle,
  ) => void | Promise<void>,
  onIgnoredError: ((error: any) => void) | undefined,
  extraDestroy: () => void,
  persist: Persist,
  [
    tablesLoadConfig,
    tablesSaveConfig,
    [
      valuesLoad,
      valuesSave,
      valuesTableName,
      valuesLoadValueIds,
      valuesSaveValueIds,
    ],
  ]: DefaultedTabularConfig,
  managedTableNames: string[],
  querySchema: QuerySchema,
  thing: any,
  getThing: string,
  columnType: string,
  upsert?: Upsert,
  encode?: (cellOrValue: any) => string | number,
  decode?: (field: string | number) => any,
)

import type {DefaultedTabularConfig} from './config.ts';

export const createTabularPersister = <
  ListeningHandle,
  Persist extends Persists = Persists.StoreOnly,
>(
  store: PersistedStore<Persist>,
  executeCommand: DatabaseExecuteCommand,
  addPersisterListener: (
    listener: PersisterListener<Persist>,
  ) => ListeningHandle | Promise<ListeningHandle>,
  delPersisterListener: (
    listeningHandle: ListeningHandle,
  ) => void | Promise<void>,
  onIgnoredError: ((error: any) => void) | undefined,
  extraDestroy: () => void,
  persist: Persist,
  [
    tablesLoadConfig,
    tablesSaveConfig,
    [
      valuesLoad,
      valuesSave,
      valuesTableName,
      valuesLoadValueIds,
      valuesSaveValueIds,
    ],
  ]: DefaultedTabularConfig,
  managedTableNames: string[],
  querySchema: QuerySchema,
  thing: any,
  getThing: string,
  columnType: string,
  upsert?: Upsert,
  encode?: (cellOrValue: any) => string | number,
  decode?: (field: string | number) => any,
): Persister<Persist> => {
  const [refreshSchema, loadTable, saveTable, transaction] =
    getCommandFunctions(
      executeCommand,
      managedTableNames,
      querySchema,
      onIgnoredError,
      columnType,
      upsert,
      encode,
      decode,
    );

  const saveTables = (
    tables:
      | Tables
      | {
          [tableId: Id]:
            | {[rowId: Id]: {[cellId: Id]: CellOrUndefined} | undefined}
            | undefined;
        },
    partial?: boolean,
  ) =>
    promiseAll(