Function startPolling

src/persisters/common/database/sqlite.ts:71–90

()

    let interval: number | NodeJS.Timeout;

    const startPolling = () =>
      (interval = startInterval(
        () =>
          tryCatch(async () => {
            const [{d, s, c}] = (await executeCommand(
              SELECT +
                // eslint-disable-next-line max-len
                ` ${DATA_VERSION} d,${SCHEMA_VERSION} s,TOTAL_CHANGES() c FROM ${PRAGMA}${DATA_VERSION} JOIN ${PRAGMA}${SCHEMA_VERSION}`,
            )) as [IdObj<number>];
            if (d != dataVersion || s != schemaVersion || c != totalChanges) {
              if (!isNullish(dataVersion)) {
                listener();
              }
              dataVersion = d;
              schemaVersion = s;
              totalChanges = c;
            }
          }),
        autoLoadIntervalSeconds as number,
      ));

    const stopPolling = () => {
      dataVersion = schemaVersion = totalChanges = null;