Use the stream's requestSnapshot method

Author: kevin-dp

packages/electric-db-collection/src/electric.ts

@@ -497,7 +497,7 @@ function createElectricSync<T extends Row<unknown>>(
       })
 
       return {
-        onLoadMore: (opts) => onLoadMore(params, opts),
+        onLoadMore: (opts) => onLoadMore(stream, params, opts),
         cleanup: () => {
           // Unsubscribe from the stream
           unsubscribeStream()
@@ -512,6 +512,7 @@ function createElectricSync<T extends Row<unknown>>(
 }
 
 async function onLoadMore<T extends Row<unknown>>(
+  stream: ShapeStream<T>,
   syncParams: Parameters<SyncConfig<T>[`sync`]>[0],
   options: OnLoadMoreOptions
 ) {
@@ -522,7 +523,7 @@ async function onLoadMore<T extends Row<unknown>>(
 
   const snapshotParams = compileSQL<T>(options)
 
-  const snapshot = await requestSnapshot(snapshotParams)
+  const snapshot = await stream.requestSnapshot(snapshotParams)
 
   begin()
 

packages/electric-db-collection/src/sql-compiler.ts

@@ -48,6 +48,8 @@ function compileBasicExpression(
       return exp.path[0]!
     case `func`:
       return compileFunction(exp, params)
+    default:
+      throw new Error(`Unknown expression type`)
   }
 }