1// pkg/session/session.go
 2type TurnStartData struct {
 3    Turn uint64 `json:"turn"`
 4}
 5
 6type TurnEndData struct {
 7    Turn   uint64        `json:"turn"`
 8    Reason TurnEndReason `json:"reason"`
 9}
10
11type StepStartData struct {
12    Turn   uint64 `json:"turn"`
13    Step   uint64 `json:"step"`
14    StepSeq uint64 `json:"stepSeq,omitempty"` // 旧字段别名
15}
16
17type StepEndData struct {
18    Turn   uint64 `json:"turn"`
19    Step   uint64 `json:"step"`
20    StepSeq uint64 `json:"stepSeq,omitempty"` // 旧字段别名
21}

 1// pkg/session/session.go
 2const (
 3    ReasonCompleted   TurnEndReason = "completed"
 4    ReasonFinished    TurnEndReason = "finished"    // 旧字段别名，等同于 completed
 5    ReasonInterrupted TurnEndReason = "interrupted"
 6    ReasonAborted     TurnEndReason = "aborted"
 7    ReasonBlocked     TurnEndReason = "blocked"
 8    ReasonError       TurnEndReason = "error"
 9    ReasonMaxTokens   TurnEndReason = "max-tokens"
10)

 1// 下一个 turn 编号（从 0 开始，每次 turn/end 后递增）
 2func (sl *SessionLog) NextTurn() uint64
 3
 4// 当前 turn 内下一个 step 编号（从 1 开始，每次 turn/start 时重置）
 5func (sl *SessionLog) NextStep() uint64
 6
 7// 当前打开的 turn（如果没有打开的 turn，返回 0, false）
 8func (sl *SessionLog) OpenTurn() (uint64, bool)
 9
10// 当前打开的 step（如果没有打开的 step，返回 0, false）
11func (sl *SessionLog) OpenStep() (uint64, bool)

 1// pkg/agent/agent.go — runTurn
 2func (a *Agent) runTurn(req *turnReq) {
 3    turnIdx := a.log.NextTurn()  // 查询当前编号
 4
 5    if _, err := a.log.Append(session.TurnStartData{Turn: turnIdx}); err != nil {
 6        return
 7    }
 8    // ... steps ...
 9    a.log.Append(session.TurnEndData{Turn: turnIdx, Reason: session.ReasonFinished})
10}

 1// pkg/persistence/jsonl.go — repairOrphanTurn
 2func repairOrphanTurn(events *[]session.SessionEvent) int {
 3    // 扫描所有事件，判断末尾是否有打开的 turn
 4    turnOpen := false
 5    var openTurn uint64
 6    for _, ev := range *events {
 7        switch ev.Type {
 8        case session.EventTurnStart:
 9            turnOpen = true
10            if td, ok := ev.Data.(session.TurnStartData); ok {
11                openTurn = td.Turn  // 捕获 turn 编号
12            }
13        case session.EventTurnEnd:
14            turnOpen = false
15        }
16    }
17    if !turnOpen {
18        return 0
19    }
20    // 追加合成的 turn/end，携带正确的 turn 编号
21    last := (*events)[len(*events)-1]
22    repaired := session.SessionEvent{
23        Seq:  last.Seq + 1,
24        Time: last.Time,
25        Type: session.EventTurnEnd,
26        Data: session.TurnEndData{Turn: openTurn, Reason: session.ReasonInterrupted},
27    }
28    *events = append(*events, repaired)
29    return 1
30}