Method handleReadSession

pkg/runtime/sessioncontext_handlers.go:55–99

(ctx context.Context, sess *session.Session, toolCall tools.ToolCall, _ EventSink)

}

func (r *LocalRuntime) handleReadSession(ctx context.Context, sess *session.Session, toolCall tools.ToolCall, _ EventSink) (*tools.ToolCallResult, error) {
	if r.sessionStore == nil {
		return tools.ResultError("session history is not available in this runtime"), nil
	}

	var args sessioncontext.ReadSessionArgs
	if err := json.Unmarshal([]byte(toolCall.Function.Arguments), &args); err != nil {
		return nil, fmt.Errorf("invalid arguments: %w", err)
	}
	ref := strings.TrimSpace(args.SessionID)
	if ref == "" {
		return tools.ResultError("session_id must not be empty"), nil
	}

	id, err := session.ResolveSessionID(ctx, r.sessionStore, ref)
	if err != nil {
		return tools.ResultError(fmt.Sprintf("cannot resolve session %q: %v", ref, err)), nil
	}
	if id == sess.ID {
		return tools.ResultError("cannot read the current session; reference a different one"), nil
	}

	target, err := r.sessionStore.GetSession(ctx, id)
	if errors.Is(err, session.ErrNotFound) {
		return tools.ResultError(fmt.Sprintf("session %q not found", id)), nil
	}
	if err != nil {
		return nil, fmt.Errorf("reading session %q: %w", id, err)
	}

	owned := target.GetAllMessages()
	msgs := make([]chat.Message, 0, len(owned))
	for i := range owned {
		msgs = append(msgs, owned[i].Message)
	}

	transcript := sessioncontext.RenderTranscript(sessioncontext.Header{
		ID:          target.ID,
		Title:       target.Title,
		CreatedAt:   target.CreatedAt,
		NumMessages: len(msgs),
	}, msgs, sessioncontext.DefaultMaxChars)

	return tools.ResultSuccess(transcript), nil
}