Function runEagerSync

packages/powersync-db-collection/src/powersync.ts:468–506

()

      // Eager mode.
      // Registers a diff trigger for the entire table.
      function runEagerSync() {
        let onUnload: CleanupFn | void | null = null

        start(async () => {
          onUnload = await restConfig.onLoad?.()

          disposeTracking = await createDiffTrigger({
            when: {
              [DiffTriggerOperation.INSERT]: `TRUE`,
              [DiffTriggerOperation.UPDATE]: `TRUE`,
              [DiffTriggerOperation.DELETE]: `TRUE`,
            },
            writeType: (_rowId: string) => `insert`,
            batchQuery: (
              lockContext: LockContext,
              batchSize: number,
              cursor: number,
            ) =>
              lockContext.getAll<TableType>(
                sanitizeSQL`SELECT * FROM ${viewName} LIMIT ? OFFSET ?`,
                [batchSize, cursor],
              ),
            onReady: () => markReady(),
          })
        }).catch((error) =>
          database.logger.error(
            `Could not start syncing process for ${viewName} into ${trackedTableName}`,
            error,
          ),
        )

        return () => {
          database.logger.info(
            `Sync has been stopped for ${viewName} into ${trackedTableName}`,
          )
          abortController.abort()
          onUnload?.()
        }
      }

      // On-demand mode.
      // Registers a diff trigger for the active WHERE expressions.