Coder/deepseek-harness
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

style: prefix session fork private helpers

Browse Source
This commit is contained in:
Hypatia May
2026-07-02 16:46:37 +08:00
parent 680a41f43c
commit a35362bdd6
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
packages/session-fork/session-fork/src/index.ts
View File

@@ -75,8 +75,8 @@ export class SessionForkService extends Service {
* service rejects open turns rather than clipping to an older boundary. * service rejects open turns rather than clipping to an older boundary.
*/ */
snapshot(source: SessionForkSource): SessionForkSeed { snapshot(source: SessionForkSource): SessionForkSeed {
const session = this.resolve(source) const session = this._resolve(source)
this.assertTurnBoundary(session) this._assertTurnBoundary(session)
const seed = session.events.map(event => structuredClone(event)) const seed = session.events.map(event => structuredClone(event))
return { return {
source: session, source: session,
@@ -105,7 +105,7 @@ export class SessionForkService extends Service {
}) })
} }
private resolve(source: SessionForkSource): Session { private _resolve(source: SessionForkSource): Session {
if (typeof source === 'string') { if (typeof source === 'string') {
const session = this.ctx.sessions.get(source) const session = this.ctx.sessions.get(source)
if (session === undefined) throw new SessionForkError(`session "${source}" not found`, 'SESSION_NOT_FOUND') if (session === undefined) throw new SessionForkError(`session "${source}" not found`, 'SESSION_NOT_FOUND')
@@ -120,7 +120,7 @@ export class SessionForkService extends Service {
return source return source
} }
private assertTurnBoundary(session: Session): void { private _assertTurnBoundary(session: Session): void {
const last = session.events.at(-1) const last = session.events.at(-1)
if (last !== undefined && last.type !== 'turn/end') { if (last !== undefined && last.type !== 'turn/end') {
throw new SessionForkError( throw new SessionForkError(