Method executePlugin

pkg/compose/plugins.go:108–190

(cmd *exec.Cmd, command string, service types.ServiceConfig)

}

func (s *composeService) executePlugin(cmd *exec.Cmd, command string, service types.ServiceConfig) (pluginVariables, error) { //nolint:gocyclo
	var action string
	switch command {
	case "up":
		s.events.On(creatingEvent(service.Name))
		action = "create"
	case "down":
		s.events.On(removingEvent(service.Name))
		action = "remove"
	case "stop":
		s.events.On(stoppingEvent(service.Name))
		action = "stop"
	default:
		return pluginVariables{}, fmt.Errorf("unsupported plugin command: %s", command)
	}

	stdout, err := cmd.StdoutPipe()
	if err != nil {
		return pluginVariables{}, err
	}

	err = cmd.Start()
	if err != nil {
		return pluginVariables{}, err
	}

	decoder := json.NewDecoder(stdout)
	defer func() { _ = stdout.Close() }()

	variables := pluginVariables{
		prefixed: types.Mapping{},
		raw:      types.Mapping{},
	}

	for {
		var msg JsonMessage
		err = decoder.Decode(&msg)
		if errors.Is(err, io.EOF) {
			break
		}
		if err != nil {
			return pluginVariables{}, err
		}
		switch msg.Type {
		case ErrorType:
			s.events.On(newEvent(service.Name, api.Error, firstLine(msg.Message)))
			return pluginVariables{}, errors.New(msg.Message)
		case InfoType:
			s.events.On(newEvent(service.Name, api.Working, firstLine(msg.Message)))
		case SetEnvType:
			key, val, found := strings.Cut(msg.Message, "=")
			if !found {
				return pluginVariables{}, fmt.Errorf("invalid response from plugin: %s", msg.Message)
			}
			variables.prefixed[key] = val
		case RawSetEnvType:
			key, val, found := strings.Cut(msg.Message, "=")
			if !found {