Method CommitRange

sessionmemory/store.go:336–405

(ctx context.Context, startTurn, endTurn int)

	_, err := s.db.ExecContext(ctx, `INSERT OR IGNORE INTO schema_meta(key, value) VALUES('schema_version', ?)`, schemaVersion)
	if err != nil {
		return err
	}
	_, err = s.db.ExecContext(ctx, `INSERT INTO session_info(session_id, created_at, updated_at, cwd, model)
		VALUES(?, ?, ?, ?, ?)
		ON CONFLICT(session_id) DO UPDATE SET updated_at=excluded.updated_at, cwd=excluded.cwd, model=excluded.model`,
		s.sessionID, now, now, s.cfg.CWD, s.cfg.APIModel)
	return err
}

func (s *Store) IngestMessages(ctx context.Context, messages []map[string]any) error {
	tx, err := s.db.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer tx.Rollback()
	userTurn := 0
	for _, msg := range messages {
		if isTransientMessage(msg) || isCompactionHandoffMessage(msg) {
			continue
		}
		if taggedTurn := sessionUserTurn(msg); taggedTurn > 0 {
			userTurn = taggedTurn
		} else if isRealUserRequest(msg) {
			userTurn++
		}
		if userTurn == 0 {
			continue
		}
		role := stringValue(msg["role"])
		contentJSON, err := json.Marshal(msg["content"])
		if err != nil {
			continue
		}
		hash := messageHash(userTurn, role, contentJSON)
		preview := textPreview(msg, 1200)
		now := unixNow()
		if _, err := tx.ExecContext(ctx, `INSERT OR IGNORE INTO messages(turn_count, user_turn_count, role, content_json, text_preview, message_hash, created_at, last_accessed_at)
			VALUES(?, ?, ?, ?, ?, ?, ?, ?)`, userTurn, userTurn, role, string(contentJSON), preview, hash, now, now); err != nil {
			return err
		}
	}
	return tx.Commit()
}

func (s *Store) IngestEvents(ctx context.Context, events []harness.Event) error {
	if len(events) == 0 {
		return nil
	}
	userTurn := s.maxUserTurn(ctx)
	tx, err := s.db.BeginTx(ctx, nil)
	if err != nil {
		return err
	}
	defer tx.Rollback()
	for _, event := range events {
		if event.Type != harness.EventMessageUserAppended && event.Type != harness.EventMessageAssistantAppended {
			continue
		}