File tree Expand file tree Collapse file tree 3 files changed +900
-969
lines changed
electric-db-collection/src Expand file tree Collapse file tree 3 files changed +900
-969
lines changed Original file line number Diff line number Diff line change 1
1
import { ensureIndexForExpression } from "../indexes/auto-index.js"
2
2
import { and , gt , lt } from "../query/index.js"
3
+ import { Value } from "../query/ir.js"
3
4
import {
4
5
createFilterFunctionFromExpression ,
5
6
createFilteredCallback ,
6
7
} from "./change-events.js"
7
- import { Value , type BasicExpression , type OrderBy } from "../query/ir.js"
8
+ import type { BasicExpression , OrderBy } from "../query/ir.js"
8
9
import type { BaseIndex } from "../indexes/base-index.js"
9
10
import type { ChangeMessage } from "../types.js"
10
11
import type { CollectionImpl } from "./index.js"
@@ -153,7 +154,6 @@ export class CollectionSubscription {
153
154
limit,
154
155
minValue,
155
156
} : RequestLimitedSnapshotOptions ) {
156
- console . log ( "in requestLimitedSnapshot" )
157
157
if ( ! limit ) throw new Error ( `limit is required` )
158
158
159
159
if ( ! this . orderByIndex ) {
Original file line number Diff line number Diff line change @@ -30,7 +30,6 @@ export function compileSQL<T>(
30
30
31
31
// Serialize the values in the params array into PG formatted strings
32
32
// and transform the array into a Record<string, string>
33
- console . log ( "params" , params )
34
33
const paramsRecord = params . reduce (
35
34
( acc , param , index ) => {
36
35
acc [ `${ index + 1 } ` ] = serialize ( param )
@@ -59,7 +58,7 @@ function compileBasicExpression(
59
58
case `val` :
60
59
params . push ( exp . value )
61
60
return `$${ params . length } `
62
- case `ref` :
61
+ case `ref` :
63
62
// TODO: doesn't yet support JSON(B) values which could be accessed with nested props
64
63
if ( exp . path . length !== 1 ) {
65
64
throw new Error (
You can’t perform that action at this time.
0 commit comments