Skip to content
This repository was archived by the owner on Jun 14, 2019. It is now read-only.
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion pkg/defaults/defaults.go
Original file line number Diff line number Diff line change
Expand Up @@ -117,7 +117,7 @@ func FromConfig(
}
step = steps.SourceStep(*rawStep.SourceStepConfiguration, config.Resources, buildClient, srcClient, imageClient, jobSpec)
} else if rawStep.ProjectDirectoryImageBuildStepConfiguration != nil {
step = steps.ProjectDirectoryImageBuildStep(*rawStep.ProjectDirectoryImageBuildStepConfiguration, config.Resources, buildClient, imageClient, jobSpec)
step = steps.ProjectDirectoryImageBuildStep(*rawStep.ProjectDirectoryImageBuildStepConfiguration, config.Resources, buildClient, imageClient, imageClient, jobSpec)
} else if rawStep.ProjectDirectoryImageBuildInputs != nil {
step = steps.GitSourceStep(*rawStep.ProjectDirectoryImageBuildInputs, config.Resources, buildClient, imageClient, jobSpec)
} else if rawStep.RPMImageInjectionStepConfiguration != nil {
Expand Down
26 changes: 24 additions & 2 deletions pkg/steps/project_image.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@ import (
"context"
"encoding/json"
"fmt"
"strings"

buildapi "github.com/openshift/api/build/v1"
"github.com/openshift/api/image/docker10"
Expand All @@ -17,6 +18,7 @@ type projectDirectoryImageBuildStep struct {
config api.ProjectDirectoryImageBuildStepConfiguration
resources api.ResourceConfiguration
buildClient BuildClient
imageClient imageclientset.ImageStreamsGetter
istClient imageclientset.ImageStreamTagsGetter
jobSpec *api.JobSpec
}
Expand Down Expand Up @@ -108,7 +110,26 @@ func (s *projectDirectoryImageBuildStep) Creates() []api.StepLink {
}

func (s *projectDirectoryImageBuildStep) Provides() (api.ParameterMap, api.StepLink) {
return nil, nil
if len(s.config.To) == 0 {
return nil, nil
}
return api.ParameterMap{
fmt.Sprintf("LOCAL_IMAGE_%s", strings.ToUpper(strings.Replace(string(s.config.To), "-", "_", -1))): func() (string, error) {
is, err := s.imageClient.ImageStreams(s.jobSpec.Namespace).Get(api.PipelineImageStream, meta.GetOptions{})
if err != nil {
return "", fmt.Errorf("could not retrieve output imagestream: %v", err)
}
var registry string
if len(is.Status.PublicDockerImageRepository) > 0 {
registry = is.Status.PublicDockerImageRepository
} else if len(is.Status.DockerImageRepository) > 0 {
registry = is.Status.DockerImageRepository
} else {
return "", fmt.Errorf("image stream %s has no accessible image registry value", s.config.To)
}
return fmt.Sprintf("%s:%s", registry, s.config.To), nil
},
}, api.InternalImageLink(s.config.To)
}

func (s *projectDirectoryImageBuildStep) Name() string { return string(s.config.To) }
Expand All @@ -117,11 +138,12 @@ func (s *projectDirectoryImageBuildStep) Description() string {
return fmt.Sprintf("Build image %s from the repository", s.config.To)
}

func ProjectDirectoryImageBuildStep(config api.ProjectDirectoryImageBuildStepConfiguration, resources api.ResourceConfiguration, buildClient BuildClient, istClient imageclientset.ImageStreamTagsGetter, jobSpec *api.JobSpec) api.Step {
func ProjectDirectoryImageBuildStep(config api.ProjectDirectoryImageBuildStepConfiguration, resources api.ResourceConfiguration, buildClient BuildClient, imageClient imageclientset.ImageStreamsGetter, istClient imageclientset.ImageStreamTagsGetter, jobSpec *api.JobSpec) api.Step {
return &projectDirectoryImageBuildStep{
config: config,
resources: resources,
buildClient: buildClient,
imageClient: imageClient,
istClient: istClient,
jobSpec: jobSpec,
}
Expand Down