Skip to content

Commit 5429b94

Browse files
authored
convert commitPosition to bigint (#424)
1 parent 69909c6 commit 5429b94

File tree

3 files changed

+3
-1
lines changed

3 files changed

+3
-1
lines changed

packages/db-client/src/utils/convertRustEvent.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ export const convertRustEvent = <T extends ResolvedEvent>(
2222
}
2323

2424
if (rustClient.commitPosition != undefined) {
25-
resolved.commitPosition = rustClient.commitPosition;
25+
resolved.commitPosition = BigInt(rustClient.commitPosition);
2626
}
2727

2828
return resolved as T;

packages/test/src/streams/readAll.test.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -168,6 +168,7 @@ describe("readAll", () => {
168168
// resolved event
169169
expect(doResolveEvent.event).toBeDefined();
170170
expect(doResolveEvent.event?.type).toBe("linky");
171+
expect(typeof doResolveEvent.commitPosition).toBe("bigint");
171172

172173
// link event
173174
expect(doResolveEvent.link).toBeDefined();

packages/test/src/streams/readStream.test.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -295,6 +295,7 @@ describe("readStream", () => {
295295
expect(resolvedEvent.event?.position?.prepare).toBe(
296296
appendResult.position?.prepare
297297
);
298+
expect(typeof resolvedEvent.commitPosition).toBe("bigint");
298299
});
299300
});
300301
});

0 commit comments

Comments
 (0)