resource_out.go

package resource

import (
	"os"

	"github.com/concourse/atc"
)

type outRequest struct {
	Source atc.Source `json:"source"`
	Params atc.Params `json:"params,omitempty"`
}

func (resource *resource) Put(
	ioConfig IOConfig,
	source atc.Source,
	params atc.Params,
	artifactSource ArtifactSource,
	signals <-chan os.Signal,
	ready chan<- struct{},
) (VersionedSource, error) {
	resourceDir := ResourcesDir("put")

	vs := &putVersionedSource{
		container:   resource.container,
		resourceDir: resourceDir,
	}

	runner := resource.runScript(
		"/opt/resource/out",
		[]string{resourceDir},
		outRequest{
			Params: params,
			Source: source,
		},
		&vs.versionResult,
		ioConfig.Stderr,
		artifactSource,
		vs,
		true,
	)

	err := runner.Run(signals, ready)
	if err != nil {
		return nil, err
	}

	return vs, nil
}