Skip to content

Commit 8fe1292

Browse files
authored
indexer: fix bound checks in getDrizzleCursor (#109)
2 parents be83d17 + 85623a6 commit 8fe1292

File tree

3 files changed

+12
-8
lines changed

3 files changed

+12
-8
lines changed
Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,7 @@
1+
{
2+
"type": "prerelease",
3+
"comment": "indexer: fix conditions in getDrizzleCursor",
4+
"packageName": "@apibara/indexer",
5+
"email": "[email protected]",
6+
"dependentChangeType": "patch"
7+
}

packages/indexer/src/sinks/drizzle/drizzle.test.ts

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -9,16 +9,13 @@ import { drizzle } from "drizzle-orm/node-postgres";
99
import { serial, text } from "drizzle-orm/pg-core";
1010
import { Client } from "pg";
1111
import { beforeAll, beforeEach, describe, expect, it } from "vitest";
12-
import {
13-
type Int8Range,
14-
drizzle as drizzleSink,
15-
getDrizzleCursor,
16-
pgTable,
17-
} from ".";
1812
import { useSink } from "../../hooks";
1913
import { run } from "../../indexer";
2014
import { generateMockMessages } from "../../testing";
2115
import { getMockIndexer } from "../../testing/indexer";
16+
import type { Int8Range } from "./Int8Range";
17+
import { drizzle as drizzleSink } from "./drizzle";
18+
import { getDrizzleCursor, pgTable } from "./utils";
2219

2320
const testTable = pgTable("test_table", {
2421
id: serial("id").primaryKey(),

packages/indexer/src/sinks/drizzle/utils.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,10 @@ export const getDrizzleCursor = (
8383
const isArray = Array.isArray(cursor_range);
8484
const [lower, upper] = isArray ? cursor_range : [cursor_range, undefined];
8585
let isNoUpperBound = false;
86-
if (!lower) {
86+
if (lower === undefined) {
8787
throw new Error("Lower bound cursor is required");
8888
}
89-
if (!upper) {
89+
if (upper === undefined) {
9090
isNoUpperBound = true;
9191
}
9292
return new Int8Range(

0 commit comments

Comments
 (0)