Method FollowUpSession

pkg/server/session_manager.go:766–812

FollowUpSession enqueues user messages for end-of-turn processing in a running session. Each message is popped one at a time after the current turn finishes, giving each follow-up a full undivided agent turn. idempotencyKey, when non-empty, makes the call safe to retry: if a request with the same k

(ctx context.Context, sessionID string, messages []api.Message, idempotencyKey string)

// still enqueued but are not consumed until the next RunSession starts a
// stream; the returned boolean indicates whether a stream is active.
func (sm *SessionManager) FollowUpSession(ctx context.Context, sessionID string, messages []api.Message, idempotencyKey string) (streaming, duplicate bool, err error) {
	rt, exists := sm.runtimeSessions.Load(sessionID)
	if !exists {
		return false, false, ErrSessionNotRunning
	}

	if idempotencyKey != "" {
		cache, _ := sm.followUpKeys.LoadOrStore(sessionID, newIdempotencyCache(defaultIdempotencyCapacity))
		if cache.reserve(idempotencyKey) {
			return false, true, nil
		}
		// Roll the reservation back if we end up returning an error, so the
		// caller can safely retry a failed request with the same key.
		defer func() {
			if err != nil {
				cache.release(idempotencyKey)
			}
		}()
	}

	// Attached session: hand the follow-up to its owner (the TUI App) so a
	// real turn starts and events reach all subscribers.
	if inject, ok := sm.followUpInjectors.Load(sessionID); ok {
		for _, msg := range messages {
			inject(ctx, msg.Content)
		}
		return true, false, nil
	}

	for _, msg := range messages {
		if err := rt.runtime.FollowUp(ctx, runtime.QueuedMessage{
			Content:      msg.Content,
			MultiContent: msg.MultiContent,
		}); err != nil {
			return false, false, err
		}
	}

	// Probe streaming state so the caller knows whether the follow-up
	// will be consumed by the current turn or sit idle until the next.
	streaming = !rt.streaming.TryLock()
	if !streaming {
		rt.streaming.Unlock()
	}

	return streaming, false, nil
}

// ResumeElicitation resumes an elicitation request.
func (sm *SessionManager) ResumeElicitation(ctx context.Context, sessionID, action string, content map[string]any) error {