Method RunPluginContext

pkg/command/runner.go:458–523

RunPluginContext executes a plugin by name with the provided context.

(ctx context.Context, name string)

// RunPluginContext executes a plugin by name with the provided context.
func (cr *Runner) RunPluginContext(ctx context.Context, name string) Output {
	cr.mu.Lock()

	var (
		path = cr.path
		p    = cr.currentProfile
	)

	ctx, span := cr.tracer.Start(ctx, "plugin", trace.WithAttributes(
		attribute.String("name", name),
		attribute.String("path", path),
	))
	defer span.End()

	// Cancel any currently running command.
	if cr.cancelFunc != nil {
		// Note: The cancel event is broadcast by the canceled goroutine.
		cr.cancelFunc()
	}

	// Create a new context for this plugin execution.
	ctx, cr.cancelFunc = context.WithCancel(ctx)

	cr.mu.Unlock()

	cr.broadcast(NewEventStart(ctx, TypePlugin))

	co := NewOutput(TypePlugin)

	plugin := p.GetPlugin(name)
	if plugin == nil {
		co.Error = fmt.Errorf("plugin %q: not found", name)
		cr.broadcast(NewEventEnd(ctx, co))

		return co
	}

	_, err := cr.root.Stat(path)
	if err != nil {
		co.Error = fmt.Errorf("stat path: %w", err)
		cr.broadcast(NewEventEnd(ctx, co))

		return co
	}

	result, err := plugin.Exec(ctx, path)
	co.Error = err
	co.Stdout = result.Stdout
	co.Stderr = result.Stderr

	// Check if the command was canceled.
	if co.Error != nil && errors.Is(ctx.Err(), context.Canceled) {
		cr.broadcast(NewEventCancel(ctx))

		return co
	} else if co.Error != nil {
		co.Error = fmt.Errorf("plugin %q: %w", plugin.Description, co.Error)
		cr.broadcast(NewEventEnd(ctx, co))