Skip to content
This repository was archived by the owner on Jun 3, 2025. 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 integration/images.go
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ var additionalKanikoFlagsMap = map[string][]string{
}

var bucketContextTests = []string{"Dockerfile_test_copy_bucket"}
var reproducibleTests = []string{"Dockerfile_test_env"}
var reproducibleTests = []string{"Dockerfile_test_reproducible"}

// GetDockerImage constructs the name of the docker image that would be built with
// dockerfile if it was tagged with imageRepo.
Expand Down
50 changes: 35 additions & 15 deletions integration/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,16 @@ type gcpConfig struct {
onbuildBaseImage string
}

type imageDetails struct {
name string
numLayers int
digest string
}

func (i imageDetails) String() string {
return fmt.Sprintf("Image: [%s] Digest: [%s] Number of Layers: [%d]", i.name, i.digest, i.numLayers)
}

func initGCPConfig() *gcpConfig {
var c gcpConfig
flag.StringVar(&c.gcsBucket, "bucket", "", "The gcs bucket argument to uploaded the tar-ed contents of the `integration` dir to.")
Expand Down Expand Up @@ -206,42 +216,52 @@ func TestLayers(t *testing.T) {
kanikoImage := GetKanikoImage(config.imageRepo, dockerfile)
pullCmd := exec.Command("docker", "pull", kanikoImage)
RunCommand(pullCmd, t)
if err := checkLayers(dockerImage, kanikoImage, offset[dockerfile]); err != nil {
if err := checkLayers(t, dockerImage, kanikoImage, offset[dockerfile]); err != nil {
t.Error(err)
t.Fail()
}
})
}
}

func checkLayers(image1, image2 string, offset int) error {
lenImage1, err := numLayers(image1)
func checkLayers(t *testing.T, image1, image2 string, offset int) error {
img1, err := getImageDetails(image1)
if err != nil {
return fmt.Errorf("Couldn't get number of layers for image1 (%s): %s", image1, err)
return fmt.Errorf("Couldn't get details from image reference for (%s): %s", image1, err)
}
lenImage2, err := numLayers(image2)

img2, err := getImageDetails(image2)
if err != nil {
return fmt.Errorf("Couldn't get number of layers for image2 (%s): %s", image2, err)
return fmt.Errorf("Couldn't get details from image reference for (%s): %s", image2, err)
}
actualOffset := int(math.Abs(float64(lenImage1 - lenImage2)))

actualOffset := int(math.Abs(float64(img1.numLayers - img2.numLayers)))
if actualOffset != offset {
return fmt.Errorf("incorrect offset between layers of %s and %s: expected %d but got %d", image1, image2, offset, actualOffset)
return fmt.Errorf("Difference in number of layers in each image is %d but should be %d. Image 1: %s, Image 2: %s", actualOffset, offset, img1, img2)
}
return nil
}

func numLayers(image string) (int, error) {
func getImageDetails(image string) (*imageDetails, error) {
ref, err := name.ParseReference(image, name.WeakValidation)
if err != nil {
return 0, fmt.Errorf("Couldn't parse referance to image %s: %s", image, err)
return nil, fmt.Errorf("Couldn't parse referance to image %s: %s", image, err)
}
imgRef, err := daemon.Image(ref)
Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Only one of these should be a daemon.Image, right? The other is remote?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@dlorenc the kaniko image is pulled right before this executes (maybe that should be made more clear somehow?)

if err != nil {
return nil, fmt.Errorf("Couldn't get reference to image %s from daemon: %s", image, err)
}
img, err := daemon.Image(ref)
layers, err := imgRef.Layers()
if err != nil {
return 0, fmt.Errorf("Couldn't get reference to image %s from daemon: %s", image, err)
return nil, fmt.Errorf("Error getting layers for image %s: %s", image, err)
}
layers, err := img.Layers()
digest, err := imgRef.Digest()
if err != nil {
return 0, fmt.Errorf("Error getting layers for image %s: %s", image, err)
return nil, fmt.Errorf("Error getting digest for image %s: %s", image, err)
}
return len(layers), nil
return &imageDetails{
name: image,
numLayers: len(layers),
digest: digest.Hex,
}, nil
}