Function assertImageContent

acceptance/registry/registry.go:252–307

(ctx context.Context, imageRef string, data *godog.DocString)

}

func assertImageContent(ctx context.Context, imageRef string, data *godog.DocString) error {
	state := testenv.FetchState[registryState](ctx)

	ref, err := name.ParseReference(fmt.Sprintf("%s/%s", state.HostAndPort, imageRef))
	if err != nil {
		return err
	}

	img, err := remote.Image(ref)
	if err != nil {
		return err
	}

	layers, err := img.Layers()
	if err != nil {
		return err
	}

	if len(layers) != 1 {
		return fmt.Errorf("unexpected number of layers: %d, expecting only one", len(layers))
	}

	in, err := layers[0].Uncompressed()
	if err != nil {
		return err
	}
	defer in.Close()

	content, err := io.ReadAll(in)
	if err != nil {
		return err
	}

	vals := map[string]string{
		"REGISTRY":           state.HostAndPort,
		"TODAY_PLUS_30_DAYS": time.Now().Round(time.Hour*24).UTC().AddDate(0, 0, 30).Format(time.RFC3339),
	}

	expected := os.Expand(data.Content, func(key string) string {
		return vals[key]
	})

	got := string(content)

	if expected == got {
		return nil
	}

	var b bytes.Buffer
	err = diff.Text("layer", "expected", got, expected, &b)
	if err != nil {
		return err
	}

	return fmt.Errorf("expected image layer and actual image layer differ:\n%s", b.String())
}

func Register(ctx context.Context, hostAndPort string) (context.Context, error) {