start on conformance testing

Signed-off-by: Josh Dolitsky <[email protected]>

Author: jdolitsky

conformance/03_discovery_test.go

@@ -19,22 +19,24 @@ var test03ContentDiscovery = func() {
 		var tagList []string
 
 		g.Context("Setup", func() {
-			g.Specify("Populate registry with test blob", func() {
+			g.Specify("Populate registry with test blobs", func() {
 				SkipIfDisabled(contentDiscovery)
 				RunOnlyIf(runContentDiscoverySetup)
-				req := client.NewRequest(reggie.POST, "/v2/<name>/blobs/uploads/")
-				resp, err := client.Do(req)
-				Expect(err).To(BeNil())
-				req = client.NewRequest(reggie.PUT, resp.GetRelativeLocation()).
-					SetQueryParam("digest", configs[2].Digest).
-					SetHeader("Content-Type", "application/octet-stream").
-					SetHeader("Content-Length", configs[2].ContentLength).
-					SetBody(configs[2].Content)
-				resp, err = client.Do(req)
-				Expect(err).To(BeNil())
-				Expect(resp.StatusCode()).To(SatisfyAll(
-					BeNumerically(">=", 200),
-					BeNumerically("<", 300)))
+				for i := 1; i <= 2; i++ {
+					req := client.NewRequest(reggie.POST, "/v2/<name>/blobs/uploads/")
+					resp, err := client.Do(req)
+					Expect(err).To(BeNil())
+					req = client.NewRequest(reggie.PUT, resp.GetRelativeLocation()).
+						SetQueryParam("digest", configs[i].Digest).
+						SetHeader("Content-Type", "application/octet-stream").
+						SetHeader("Content-Length", configs[i].ContentLength).
+						SetBody(configs[i].Content)
+					resp, err = client.Do(req)
+					Expect(err).To(BeNil())
+					Expect(resp.StatusCode()).To(SatisfyAll(
+						BeNumerically(">=", 200),
+						BeNumerically("<", 300)))
+				}
 			})
 
 			g.Specify("Populate registry with test layer", func() {
@@ -77,6 +79,20 @@ var test03ContentDiscovery = func() {
 				_ = err
 			})
 
+			g.Specify("Populate registry with referred-to manifest", func() {
+				SkipIfDisabled(contentDiscovery)
+				RunOnlyIf(runContentDiscoverySetup)
+				req := client.NewRequest(reggie.PUT, "/v2/<name>/manifests/<reference>",
+					reggie.WithReference("test-something-points-to-me")).
+					SetHeader("Content-Type", "application/vnd.oci.image.manifest.v1+json").
+					SetBody(manifests[1].Content)
+				resp, err := client.Do(req)
+				Expect(err).To(BeNil())
+				Expect(resp.StatusCode()).To(SatisfyAll(
+					BeNumerically(">=", 200),
+					BeNumerically("<", 300)))
+			})
+
 			g.Specify("Populate registry with test tags (no push)", func() {
 				SkipIfDisabled(contentDiscovery)
 				RunOnlyIfNot(runContentDiscoverySetup)
@@ -125,6 +141,19 @@ var test03ContentDiscovery = func() {
 				Expect(len(tagList)).To(BeNumerically("<=", numResults))
 				Expect(tagList).To(ContainElement(tagList[numResults-1]))
 			})
+
+			g.Specify("GET request to list of referrers should yield 200 response", func() {
+				SkipIfDisabled(contentDiscovery)
+				// TODO: should move to this form per the spec,
+				// the endpoint used is supported currently by oci-playground/distribution
+				// req := client.NewRequest(reggie.GET, "/v2/<name>/referrers/<digest>", reggie.WithDigest(manifests[2].Digest))
+				req := client.NewRequest(reggie.GET, "/v2/<name>/_oci/artifacts/referrers")
+				// set the digest to the one being pointed to by manifests[2]
+				req.QueryParam.Add("digest", manifests[1].Digest)
+				resp, err := client.Do(req)
+				Expect(err).To(BeNil())
+				Expect(resp.StatusCode()).To(Equal(http.StatusOK))
+			})
 		})
 
 		g.Context("Teardown", func() {

conformance/image.go

@@ -20,6 +20,9 @@ type Manifest struct {
 
 	// Layers is an indexed list of layers referenced by the manifest.
 	Layers []Descriptor `json:"layers"`
+
+	// Refers links a manifest to another existing manifest.
+	Refers *Descriptor `json:"refers,omitempty"`
 }
 
 // Descriptor describes the disposition of targeted content.

conformance/setup.go

@@ -234,6 +234,15 @@ func init() {
 		}
 		manifest.SchemaVersion = 2
 
+		// except for the first one, add "refers" field pointing to the last one
+		if i > 0 {
+			manifest.Refers = &Descriptor{
+				MediaType: "application/vnd.oci.image.manifest.v1+json",
+				Digest:    godigest.Digest(configs[i-1].Digest),
+				Size:      int64(len(configs[i-1].Content)),
+			}
+		}
+
 		manifestContent, err := json.MarshalIndent(&manifest, "", "\t")
 		if err != nil {
 			log.Fatal(err)