Method commitMessages

sessionmemory/store.go:512–540

(ctx context.Context, commitNo, limit int)

		return err
	}
	for _, id := range ids {
		if _, err := tx.ExecContext(ctx, `INSERT OR IGNORE INTO commit_messages(commit_id, message_id) VALUES(?, ?)`, commitID, id); err != nil {
			return err
		}
	}
	if ftsAvailable {
		_, _ = tx.ExecContext(ctx, `INSERT INTO commit_fts(commit_id, title, summary, tags) VALUES(?, ?, ?, ?)`, commitID, title, summary, strings.Join(tags, " "))
	}
	if _, err := tx.ExecContext(ctx, `INSERT OR REPLACE INTO schema_meta(key, value) VALUES('last_committed_user_turn', ?)`, fmt.Sprint(endTurn)); err != nil {
		return err
	}
	if _, err := tx.ExecContext(ctx, `INSERT OR REPLACE INTO schema_meta(key, value) VALUES('next_commit_no', ?)`, fmt.Sprint(commitNo+1)); err != nil {
		return err
	}
	return tx.Commit()
}

func (s *Store) summarize(ctx context.Context, startTurn, endTurn int, previews []string) (string, string, []string, error) {
	joined := strings.Join(previews, "\n")
	system := "You summarize a coding-agent conversation segment. Return concise JSON only with keys: title, summary, tags. The summary must preserve user goals, decisions, files, tool findings, errors, and next steps. Do not invent facts."
	user := fmt.Sprintf("Summarize session turns %d-%d. This is one commit covering the whole interval, not separate summaries per turn.\n\n%s", startTurn, endTurn, joined)
	complete := s.complete
	if complete == nil {
		client, err := llmclient.Create(s.cfg, s.summaryModel(), s.cfg.SessionMemorySummaryMaxTokens, nil, api.DefaultRetryConfigPtr())
		if err != nil {
			return "", "", nil, err
		}
		complete = func(ctx context.Context, systemPrompt string, messages []map[string]any, maxTokens int) (string, error) {
			streamCtx := api.ContextWithStreamIdleTimeout(ctx,
				time.Duration(s.cfg.APIStreamIdleTimeoutSeconds*float64(time.Second)))
			return client.Complete(streamCtx, systemPrompt, messages, api.CompleteOptions{MaxTokens: maxTokens})
		}