From 67c0c79613d0af3f28818485c1d13e84a4a3713a Mon Sep 17 00:00:00 2001 From: Kit Langton Date: Thu, 2 Jul 2026 21:22:54 -0400 Subject: [PATCH] test(core): update session input promotion calls --- packages/core/test/session-create.test.ts | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/packages/core/test/session-create.test.ts b/packages/core/test/session-create.test.ts index 5554f9782a..ffc4abcd83 100644 --- a/packages/core/test/session-create.test.ts +++ b/packages/core/test/session-create.test.ts @@ -135,7 +135,7 @@ describe("SessionV2.create", () => { prompt: Prompt.make({ text: "First" }), resume: false, }) - yield* SessionInput.promoteSteers(db, events, parent.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, parent.id) yield* events.publish(SessionEvent.Synthetic, { sessionID: parent.id, messageID: SessionMessage.ID.create(), @@ -167,9 +167,9 @@ describe("SessionV2.create", () => { }) yield* session.prompt({ sessionID: parent.id, prompt: Prompt.make({ text: "Parent changed" }), resume: false }) - yield* SessionInput.promoteSteers(db, events, parent.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, parent.id) yield* session.prompt({ sessionID: forked.id, prompt: Prompt.make({ text: "Child continues" }), resume: false }) - yield* SessionInput.promoteSteers(db, events, forked.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, forked.id) expect((yield* session.context(parent.id)).map((message) => message.type)).toEqual(["user", "synthetic", "user"]) expect((yield* session.context(forked.id)).map((message) => message.type)).toEqual(["user", "synthetic", "user"]) @@ -192,13 +192,13 @@ describe("SessionV2.create", () => { prompt: Prompt.make({ text: "First" }), resume: false, }) - yield* SessionInput.promoteSteers(db, events, parent.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, parent.id) const second = yield* session.prompt({ sessionID: parent.id, prompt: Prompt.make({ text: "Second" }), resume: false, }) - yield* SessionInput.promoteSteers(db, events, parent.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, parent.id) const forked = yield* session.fork({ sessionID: parent.id, messageID: second.id }) @@ -314,7 +314,7 @@ describe("SessionV2.create", () => { const { db } = yield* Database.Service const created = yield* session.create({ location }) yield* session.prompt({ sessionID: created.id, prompt: Prompt.make({ text: "Hello" }), resume: false }) - yield* SessionInput.promoteSteers(db, events, created.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(db, events, created.id) expect( Array.from(yield* session.events({ sessionID: created.id }).pipe(Stream.take(2), Stream.runCollect)), @@ -336,7 +336,7 @@ describe("SessionV2.create", () => { prompt: Prompt.make({ text: "Replay lifecycle" }), resume: false, }) - yield* SessionInput.promoteSteers(sourceDb, sourceEvents, created.id, Number.MAX_SAFE_INTEGER) + yield* SessionInput.promoteSteers(sourceDb, sourceEvents, created.id) const serialized = (yield* sourceDb .select() .from(EventTable)