Function getMockedDatabase

test/unit/persisters/common/mocks.ts:224–286

(
  getLocation: () => Promise<Location>,
  getLocationMethod: GetLocationMethod<Location>,
  getPersister: (
    store: Store,
    location: Location,
    storeTableOrConfig: DatabasePersisterConfig,
  ) => Promise<Persister>,
  cmd: (
    location: Location,
    sql: string,
    args?: any[],
  ) => Promise<{[id: string]: any}[]>,
  close: (location: Location) => Promise<void>,
  autoLoadPause = 2,
  autoLoadIntervalSeconds = 0.001,
  _isPostgres = false,
  _supportsMultipleConnections = false,
  _skipSqlChecks = false,
)

};

const getMockedDatabase = <Location>(
  getLocation: () => Promise<Location>,
  getLocationMethod: GetLocationMethod<Location>,
  getPersister: (
    store: Store,
    location: Location,
    storeTableOrConfig: DatabasePersisterConfig,
  ) => Promise<Persister>,
  cmd: (
    location: Location,
    sql: string,
    args?: any[],
  ) => Promise<{[id: string]: any}[]>,
  close: (location: Location) => Promise<void>,
  autoLoadPause = 2,
  autoLoadIntervalSeconds = 0.001,
  _isPostgres = false,
  _supportsMultipleConnections = false,
  _skipSqlChecks = false,
): Persistable<Location> => {
  const mockDatabase = {
    getLocation,
    getLocationMethod,
    getPersister: (store: Store, location: Location) =>
      getPersister(store, location, {
        mode: 'json',
        autoLoadIntervalSeconds,
      }),
    get: async (location: Location): Promise<Content | void> =>
      JSON.parse(
        (
          await cmd(location, 'SELECT store FROM tinybase WHERE _id = $1', [
            '_',
          ])
        )[0]['store'],
      ),
    set: async (location: Location, rawContent: any): Promise<void> =>
      await mockDatabase.write(location, JSON.stringify(rawContent)),
    write: async (location: Location, rawContent: any): Promise<void> => {
      await cmd(
        location,
        'CREATE TABLE IF NOT EXISTS tinybase ' +
          '(_id text PRIMARY KEY, store text);',
      );
      await cmd(
        location,
        'INSERT INTO tinybase (_id, store) VALUES ($1, $2) ' +
          'ON CONFLICT (_id) DO UPDATE SET store=excluded.store',
        ['_', rawContent],
      );
    },
    del: async (location: Location) => {
      try {
        await close(location);
      } catch {}
    },
    afterEach: (location: Location) => mockDatabase.del(location),
    autoLoadPause,