Method forwardEvents

pkg/embeddedchat/embeddedchat.go:267–331

(ctx context.Context, events <-chan dagentruntime.Event, out chan<- Event, cancel context.CancelFunc, runID int)

}

func (s *Session) forwardEvents(ctx context.Context, events <-chan dagentruntime.Event, out chan<- Event, cancel context.CancelFunc, runID int) {
	defer close(out)
	defer cancel()
	defer func() {
		s.mu.Lock()
		defer s.mu.Unlock()
		if s.activeRun == runID {
			s.activeCancel = nil
		}
	}()

	emit := func(e Event) bool {
		select {
		case out <- e:
			return true
		case <-ctx.Done():
			return false
		}
	}

	errSent := false
	for event := range events {
		if ctx.Err() != nil {
			continue
		}

		switch e := event.(type) {
		case *dagentruntime.ToolCallConfirmationEvent:
			if errSent {
				s.rt.Resume(ctx, dagentruntime.ResumeReject("The run was aborted."))
				continue
			}
			if !emit(Event{RuntimeEvent: event, Tool: &ToolActivity{Call: e.ToolCall, Def: e.ToolDefinition, NeedsConfirmation: true}}) {
				s.rt.Resume(ctx, dagentruntime.ResumeReject("The run was aborted."))
			}
		case *dagentruntime.ElicitationRequestEvent:
			// This headless wrapper has no built-in elicitation UI. Decline so the
			// run cannot hang forever; embedders that need elicitation can consume
			// RuntimeEvent directly by driving the runtime themselves.
			_ = s.rt.ResumeElicitation(ctx, tools.ElicitationActionDecline, nil)
		case *dagentruntime.MaxIterationsReachedEvent:
			s.rt.Resume(ctx, dagentruntime.ResumeReject(""))
		case *dagentruntime.ErrorEvent:
			if errSent {
				continue
			}
			if !emit(Event{RuntimeEvent: event, Err: errors.New(e.Error)}) {
				return
			}
			errSent = true
		default:
			if errSent {
				continue
			}
			if translated, ok := TranslateRuntimeEvent(event); ok {
				if !emit(translated) {
					return
				}